initial commit for openwhisk support

spring-cloud-function-adapters/spring-cloud-function-adapter-openwhisk/src/main/java/org/springframework/cloud/function/adapter/openwhisk/ActionApplication.java

@@ -0,0 +1,33 @@
+/*
+ * Copyright 2017 the original author or authors.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *      http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package org.springframework.cloud.function.adapter.openwhisk;
+
+import org.springframework.boot.SpringApplication;
+import org.springframework.boot.autoconfigure.SpringBootApplication;
+import org.springframework.boot.context.properties.EnableConfigurationProperties;
+
+/**
+ * @author Mark Fisher
+ */
+@SpringBootApplication
+@EnableConfigurationProperties(FunctionProperties.class)
+public class ActionApplication {
+
+	public static void main(String[] args) {
+		SpringApplication.run(ActionApplication.class, args);
+	}
+}

spring-cloud-function-adapters/spring-cloud-function-adapter-openwhisk/src/main/java/org/springframework/cloud/function/adapter/openwhisk/ActionController.java

@@ -0,0 +1,91 @@
+/*
+ * Copyright 2017 the original author or authors.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *      http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package org.springframework.cloud.function.adapter.openwhisk;
+
+import java.util.ArrayList;
+import java.util.Collection;
+import java.util.List;
+import java.util.Map;
+
+import org.springframework.cloud.function.context.FunctionScan;
+import org.springframework.web.bind.annotation.PostMapping;
+import org.springframework.web.bind.annotation.RequestBody;
+import org.springframework.web.bind.annotation.RestController;
+
+import com.fasterxml.jackson.core.JsonProcessingException;
+import com.fasterxml.jackson.databind.ObjectMapper;
+
+import reactor.core.publisher.Flux;
+
+/**
+ * @author Mark Fisher
+ */
+@FunctionScan
+@RestController
+public class ActionController extends FunctionInitializer {
+
+	private final ObjectMapper objectMapper = new ObjectMapper();
+
+	public ActionController() {
+		super();
+	}
+
+	@PostMapping("/init")
+	public void init(@RequestBody InitRequest request) {
+		initialize();
+	}
+
+	@PostMapping(value="/run", consumes="application/json", produces="application/json")
+	public Object run(@RequestBody ActionRequest request) {
+		Object input = convertEvent(request.getValue());
+		Flux<?> output = apply(extract(input));
+		Object result = result(input, output);
+		try {
+			return "{\"result\":" + this.objectMapper.writeValueAsString(result) + "}";
+		}
+		catch (JsonProcessingException e) {
+			throw new IllegalStateException("failed to write JSON response", e);
+		}
+	}
+
+	private Object result(Object input, Flux<?> output) {
+		List<Object> result = new ArrayList<>();
+		for (Object value : output.toIterable()) {
+			result.add(value);
+		}
+		if (isSingleValue(input) && result.size()==1) {
+			return result.get(0);
+		}
+		return result;
+	}
+
+	private boolean isSingleValue(Object input) {
+		return !(input instanceof Collection);
+	}
+
+	private Flux<?> extract(Object input) {
+		if (input instanceof Collection) {
+			return Flux.fromIterable((Iterable<?>) input);
+		}
+		return Flux.just(input);
+	}
+
+	protected Object convertEvent(Map<String, String> event) {
+		// just expecting "payload" for now
+		return event.get("payload");
+	}
+}

spring-cloud-function-adapters/spring-cloud-function-adapter-openwhisk/src/main/java/org/springframework/cloud/function/adapter/openwhisk/ActionRequest.java

@@ -0,0 +1,90 @@
+/*
+ * Copyright 2017 the original author or authors.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *      http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package org.springframework.cloud.function.adapter.openwhisk;
+
+import java.util.Map;
+
+import com.fasterxml.jackson.annotation.JsonProperty;
+
+/**
+ * @author Mark Fisher
+ */
+public class ActionRequest {
+
+	@JsonProperty("action_name")
+	private String actionName;
+
+	@JsonProperty("activation_id")
+	private String activationId;
+
+	@JsonProperty("api_key")
+	private String apiKey;
+
+	private String deadline;
+
+	private String namespace;
+
+	private Map<String, String> value;
+
+	public String getActionName() {
+		return actionName;
+	}
+
+	public void setActionName(String actionName) {
+		this.actionName = actionName;
+	}
+
+	public String getActivationId() {
+		return activationId;
+	}
+
+	public void setActivationId(String activationId) {
+		this.activationId = activationId;
+	}
+
+	public String getApiKey() {
+		return apiKey;
+	}
+
+	public void setApiKey(String apiKey) {
+		this.apiKey = apiKey;
+	}
+
+	public String getDeadline() {
+		return deadline;
+	}
+
+	public void setDeadline(String deadline) {
+		this.deadline = deadline;
+	}
+
+	public String getNamespace() {
+		return namespace;
+	}
+
+	public void setNamespace(String namespace) {
+		this.namespace = namespace;
+	}
+
+	public Map<String, String> getValue() {
+		return value;
+	}
+
+	public void setValue(Map<String, String> value) {
+		this.value = value;
+	}
+}

spring-cloud-function-adapters/spring-cloud-function-adapter-openwhisk/src/main/java/org/springframework/cloud/function/adapter/openwhisk/FunctionInitializer.java

@@ -0,0 +1,96 @@
+/*
+ * Copyright 2017 the original author or authors.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *      http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package org.springframework.cloud.function.adapter.openwhisk;
+
+import java.util.concurrent.atomic.AtomicBoolean;
+import java.util.function.Consumer;
+import java.util.function.Function;
+import java.util.function.Supplier;
+
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.cloud.function.context.FunctionInspector;
+import org.springframework.cloud.function.registry.FunctionCatalog;
+import org.springframework.cloud.function.support.FluxFunction;
+import org.springframework.cloud.function.support.FunctionUtils;
+
+import reactor.core.publisher.Flux;
+
+/**
+ * @author Dave Syer
+ * @author Mark Fisher
+ */
+public class FunctionInitializer {
+
+	private Function<Flux<?>, Flux<?>> function;
+
+	private Consumer<Flux<?>> consumer;
+
+	private Supplier<Flux<?>> supplier;
+
+	private AtomicBoolean initialized = new AtomicBoolean();
+
+	@Autowired(required = false)
+	private FunctionInspector inspector;
+
+	@Autowired
+	private FunctionCatalog catalog;
+
+	@Autowired
+	private FunctionProperties properties;
+
+	@SuppressWarnings("unchecked")
+	protected void initialize() {
+		if (!this.initialized.compareAndSet(false, true)) {
+			return;
+		}
+		String name = this.properties.getName();
+		String type = this.properties.getType();
+		if ("function".equals(type)) {
+			this.function = this.catalog.lookupFunction(name);
+			if (this.function != null && !FunctionUtils.isFluxFunction(this.function)) {
+				this.function = new FluxFunction(this.function);
+			}
+		}
+		else if ("consumer".equals(type)) {
+			this.consumer = this.catalog.lookupConsumer(name);
+		}
+		else if ("supplier".equals(type)) {
+			this.supplier = this.catalog.lookupSupplier(name);
+		}
+	}
+
+	protected Class<?> getInputType() {
+		if (inspector != null) {
+			return inspector.getInputType(this.properties.getName());
+		}
+		return Object.class;
+	}
+
+	protected Flux<?> apply(Flux<?> input) {
+		if (this.function != null) {
+			return function.apply(input);
+		}
+		if (this.consumer != null) {
+			this.consumer.accept(input);
+			return Flux.empty();
+		}
+		if (this.supplier != null) {
+			return this.supplier.get();
+		}
+		throw new IllegalStateException("No function defined");
+	}
+}

spring-cloud-function-adapters/spring-cloud-function-adapter-openwhisk/src/main/java/org/springframework/cloud/function/adapter/openwhisk/FunctionProperties.java

@@ -0,0 +1,46 @@
+/*
+ * Copyright 2017 the original author or authors.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *      http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package org.springframework.cloud.function.adapter.openwhisk;
+
+import org.springframework.boot.context.properties.ConfigurationProperties;
+
+/**
+ * @author Mark Fisher
+ */
+@ConfigurationProperties(prefix = "function")
+public class FunctionProperties {
+
+	private String name = "function";
+
+	private String type = "function";
+
+	public String getName() {
+		return name;
+	}
+
+	public void setName(String name) {
+		this.name = name;
+	}
+
+	public String getType() {
+		return type;
+	}
+
+	public void setType(String type) {
+		this.type = type;
+	}
+}

spring-cloud-function-adapters/spring-cloud-function-adapter-openwhisk/src/main/java/org/springframework/cloud/function/adapter/openwhisk/InitRequest.java

@@ -0,0 +1,53 @@
+/*
+ * Copyright 2017 the original author or authors.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *      http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package org.springframework.cloud.function.adapter.openwhisk;
+
+/**
+ * @author Mark Fisher
+ */
+public class InitRequest {
+
+	private String name;
+
+	private boolean binary;
+
+	private String main;
+
+	public String getName() {
+		return name;
+	}
+
+	public void setName(String name) {
+		this.name = name;
+	}
+
+	public boolean isBinary() {
+		return binary;
+	}
+
+	public void setBinary(boolean binary) {
+		this.binary = binary;
+	}
+
+	public String getMain() {
+		return main;
+	}
+
+	public void setMain(String main) {
+		this.main = main;
+	}
+}