Merge pull request #3 from wanjunlei/java

support multiple functions in one pod

Author: benjaminhuo

functions-framework-api/src/main/java/dev/openfunction/functions/BindingEvent.java

@@ -20,7 +20,6 @@
 import java.util.Map;
 
 public class BindingEvent {
-
     /**
      * The name of the input binding component.
      */

functions-framework-api/src/main/java/dev/openfunction/functions/CloudEventFunction.java

@@ -18,14 +18,12 @@
 
 import io.cloudevents.CloudEvent;
 
-@FunctionalInterface
 public interface CloudEventFunction {
-
-  /**
-   * @param ctx Context
-   * @param event cloud event
-   * @return Error
-   * @throws Exception Exception
-   */
-  Error accept(Context ctx, CloudEvent event) throws Exception;
+    /**
+     * @param ctx   Context
+     * @param event cloud event
+     * @return Error
+     * @throws Exception Exception
+     */
+    Error accept(Context ctx, CloudEvent event) throws Exception;
 }

functions-framework-api/src/main/java/dev/openfunction/functions/Component.java

@@ -19,12 +19,11 @@
 import java.util.Map;
 
 public class Component {
-
     private String uri;
     private String componentName;
     private String componentType;
     private Map<String, String> metadata;
-    private String Operation;
+    private String operation;
 
 
     public String getUri() {
@@ -60,11 +59,11 @@ public void setMetadata(Map<String, String> metadata) {
     }
 
     public String getOperation() {
-        return Operation;
+        return operation;
     }
 
     public void setOperation(String operation) {
-        Operation = operation;
+        this.operation = operation;
     }
 }
 

functions-framework-api/src/main/java/dev/openfunction/functions/Context.java

@@ -24,7 +24,6 @@
  * An interface for event function context.
  */
 public interface Context {
-
     /**
      * send provides the ability to allow the user to send data to a specified output target.
      *

functions-framework-api/src/main/java/dev/openfunction/functions/HttpFunction.java

@@ -17,14 +17,14 @@
 package dev.openfunction.functions;
 
 public interface HttpFunction {
-  /**
-   * Called to service an incoming HTTP request. This interface is implemented by user code to
-   * provide the action for a given function. If the method throws any exception (including any
-   * {@link Error}) then the HTTP response will have a 500 status code.
-   *
-   * @param request a representation of the incoming HTTP request.
-   * @param response an object that can be used to provide the corresponding HTTP response.
-   * @throws Exception if thrown, the HTTP response will have a 500 status code.
-   */
-  void service(HttpRequest request, HttpResponse response) throws Exception;
+    /**
+     * Called to service an incoming HTTP request. This interface is implemented by user code to
+     * provide the action for a given function. If the method throws any exception (including any
+     * {@link Error}) then the HTTP response will have a 500 status code.
+     *
+     * @param request  a representation of the incoming HTTP request.
+     * @param response an object that can be used to provide the corresponding HTTP response.
+     * @throws Exception if thrown, the HTTP response will have a 500 status code.
+     */
+    void service(HttpRequest request, HttpResponse response) throws Exception;
 }

functions-framework-api/src/main/java/dev/openfunction/functions/HttpMessage.java

@@ -23,94 +23,96 @@
 import java.util.Map;
 import java.util.Optional;
 
-/** Represents an HTTP message, either an HTTP request or a part of a multipart HTTP request. */
+/**
+ * Represents an HTTP message, either an HTTP request or a part of a multipart HTTP request.
+ */
 public interface HttpMessage {
-  /**
-   * Returns the value of the {@code Content-Type} header, if any.
-   *
-   * @return the content type, if any.
-   */
-  Optional<String> getContentType();
+    /**
+     * Returns the value of the {@code Content-Type} header, if any.
+     *
+     * @return the content type, if any.
+     */
+    Optional<String> getContentType();
 
-  /**
-   * Returns the numeric value of the {@code Content-Length} header.
-   *
-   * @return the content length.
-   */
-  long getContentLength();
+    /**
+     * Returns the numeric value of the {@code Content-Length} header.
+     *
+     * @return the content length.
+     */
+    long getContentLength();
 
-  /**
-   * Returns the character encoding specified in the {@code Content-Type} header, or {@code
-   * Optional.empty()} if there is no {@code Content-Type} header or it does not have the {@code
-   * charset} parameter.
-   *
-   * @return the character encoding for the content type, if one is specified.
-   */
-  Optional<String> getCharacterEncoding();
+    /**
+     * Returns the character encoding specified in the {@code Content-Type} header, or {@code
+     * Optional.empty()} if there is no {@code Content-Type} header or it does not have the {@code
+     * charset} parameter.
+     *
+     * @return the character encoding for the content type, if one is specified.
+     */
+    Optional<String> getCharacterEncoding();
 
-  /**
-   * Returns an {@link InputStream} that can be used to read the body of this HTTP request. Every
-   * call to this method on the same {@link HttpMessage} will return the same object. This method is
-   * typically used to read binary data. If the body is text, the {@link #getReader()} method is
-   * more appropriate.
-   *
-   * @return an {@link InputStream} that can be used to read the body of this HTTP request.
-   * @throws IOException if a valid {@link InputStream} cannot be returned for some reason.
-   * @throws IllegalStateException if {@link #getReader()} has already been called on this instance.
-   */
-  InputStream getInputStream() throws IOException;
+    /**
+     * Returns an {@link InputStream} that can be used to read the body of this HTTP request. Every
+     * call to this method on the same {@link HttpMessage} will return the same object. This method is
+     * typically used to read binary data. If the body is text, the {@link #getReader()} method is
+     * more appropriate.
+     *
+     * @return an {@link InputStream} that can be used to read the body of this HTTP request.
+     * @throws IOException           if a valid {@link InputStream} cannot be returned for some reason.
+     * @throws IllegalStateException if {@link #getReader()} has already been called on this instance.
+     */
+    InputStream getInputStream() throws IOException;
 
-  /**
-   * Returns a {@link BufferedReader} that can be used to read the text body of this HTTP request.
-   * Every call to this method on the same {@link HttpMessage} will return the same object.
-   *
-   * @return a {@link BufferedReader} that can be used to read the text body of this HTTP request.
-   * @throws IOException if a valid {@link BufferedReader} cannot be returned for some reason.
-   * @throws IllegalStateException if {@link #getInputStream()} has already been called on this
-   *     instance.
-   */
-  BufferedReader getReader() throws IOException;
+    /**
+     * Returns a {@link BufferedReader} that can be used to read the text body of this HTTP request.
+     * Every call to this method on the same {@link HttpMessage} will return the same object.
+     *
+     * @return a {@link BufferedReader} that can be used to read the text body of this HTTP request.
+     * @throws IOException           if a valid {@link BufferedReader} cannot be returned for some reason.
+     * @throws IllegalStateException if {@link #getInputStream()} has already been called on this
+     *                               instance.
+     */
+    BufferedReader getReader() throws IOException;
 
-  /**
-   * Returns a map describing the headers of this HTTP request, or this part of a multipart request.
-   * If the headers look like this...
-   *
-   * <pre>
-   *   Content-Type: text/plain
-   *   Some-Header: some value
-   *   Some-Header: another value
-   * </pre>
-   *
-   * ...then the returned value will map {@code "Content-Type"} to a one-element list containing
-   * {@code "text/plain"}, and {@code "Some-Header"} to a two-element list containing {@code "some
-   * value"} and {@code "another value"}.
-   *
-   * @return a map where each key is an HTTP header and the corresponding {@code List} value has one
-   *     element for each occurrence of that header.
-   */
-  Map<String, List<String>> getHeaders();
+    /**
+     * Returns a map describing the headers of this HTTP request, or this part of a multipart request.
+     * If the headers look like this...
+     *
+     * <pre>
+     *   Content-Type: text/plain
+     *   Some-Header: some value
+     *   Some-Header: another value
+     * </pre>
+     * <p>
+     * ...then the returned value will map {@code "Content-Type"} to a one-element list containing
+     * {@code "text/plain"}, and {@code "Some-Header"} to a two-element list containing {@code "some
+     * value"} and {@code "another value"}.
+     *
+     * @return a map where each key is an HTTP header and the corresponding {@code List} value has one
+     * element for each occurrence of that header.
+     */
+    Map<String, List<String>> getHeaders();
 
-  /**
-   * Convenience method that returns the value of the first header with the given name. If the
-   * headers look like this...
-   *
-   * <pre>
-   *   Content-Type: text/plain
-   *   Some-Header: some value
-   *   Some-Header: another value
-   * </pre>
-   *
-   * ...then {@code getFirstHeader("Some-Header")} will return {@code Optional.of("some value")},
-   * and {@code getFirstHeader("Another-Header")} will return {@code Optional.empty()}.
-   *
-   * @param name an HTTP header name.
-   * @return the first value of the given header, if present.
-   */
-  default Optional<String> getFirstHeader(String name) {
-    List<String> headers = getHeaders().get(name);
-    if (headers == null || headers.isEmpty()) {
-      return Optional.empty();
+    /**
+     * Convenience method that returns the value of the first header with the given name. If the
+     * headers look like this...
+     *
+     * <pre>
+     *   Content-Type: text/plain
+     *   Some-Header: some value
+     *   Some-Header: another value
+     * </pre>
+     * <p>
+     * ...then {@code getFirstHeader("Some-Header")} will return {@code Optional.of("some value")},
+     * and {@code getFirstHeader("Another-Header")} will return {@code Optional.empty()}.
+     *
+     * @param name an HTTP header name.
+     * @return the first value of the given header, if present.
+     */
+    default Optional<String> getFirstHeader(String name) {
+        List<String> headers = getHeaders().get(name);
+        if (headers == null || headers.isEmpty()) {
+            return Optional.empty();
+        }
+        return Optional.of(headers.get(0));
     }
-    return Optional.of(headers.get(0));
-  }
 }