Merge pull request #8 from wanjunlei/release-1.0

fix bug java async function run failed in dapr proxy mode

Author: benjaminhuo

functions-framework-api/pom.xml

@@ -32,7 +32,7 @@
 
   <groupId>dev.openfunction.functions</groupId>
   <artifactId>functions-framework-api</artifactId>
-  <version>1.0.0</version>
+  <version>1.0.1</version>
 
   <properties>
     <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>

functions-framework-invoker/pom.xml

@@ -10,7 +10,7 @@
 
     <groupId>dev.openfunction.functions</groupId>
     <artifactId>functions-framework-invoker</artifactId>
-    <version>1.0.0</version>
+    <version>1.0.1</version>
 
     <properties>
         <maven-compiler-plugin.version>3.8.0</maven-compiler-plugin.version>

functions-framework-invoker/src/main/java/dev/openfunction/invoker/runtime/AsynchronousRuntime.java

@@ -88,7 +88,6 @@ private class Service extends AppCallbackGrpc.AppCallbackImplBase {
         private DaprClient daprClient;
 
         public void start(int port) throws Exception {
-
             daprServer = ServerBuilder
                     .forPort(port)
                     .addService(Service.this)

functions-framework-invoker/src/main/java/dev/openfunction/invoker/runtime/SynchronizeRuntime.java

@@ -62,7 +62,8 @@ public SynchronizeRuntime(RuntimeContext runtimeContext, Class<?>[] functionClas
     @Override
     public void start() throws Exception {
         // create dapr client when dapr sidecar enabled.
-        if (System.getenv("DAPR_GRPC_PORT") != null || System.getenv("DAPR_HTTP_PORT") != null) {
+        if ((runtimeContext.getInputs() != null && !runtimeContext.getInputs().isEmpty()) ||
+                (runtimeContext.getOutputs() != null && !runtimeContext.getOutputs().isEmpty())) {
             daprClient = new DaprClientBuilder().build();
             daprClient.waitForSidecar(Runtime.WaitDaprSidecarTimeout);
         }