From 3401c0b9871c47edd7c9abc5e356b29e4cfcb067 Mon Sep 17 00:00:00 2001
From: wanjunlei <wanjunlei@kubesphere.io>
Date: Thu, 9 Mar 2023 14:44:44 +0800
Subject: [PATCH] fix bug java async function run failed in dapr proxy mode

Signed-off-by: wanjunlei <wanjunlei@kubesphere.io>
---
 functions-framework-api/pom.xml                                | 2 +-
 functions-framework-invoker/pom.xml                            | 2 +-
 .../dev/openfunction/invoker/runtime/AsynchronousRuntime.java  | 1 -
 .../dev/openfunction/invoker/runtime/SynchronizeRuntime.java   | 3 ++-
 4 files changed, 4 insertions(+), 4 deletions(-)

diff --git a/functions-framework-api/pom.xml b/functions-framework-api/pom.xml
index c69ae104..d100869d 100644
--- a/functions-framework-api/pom.xml
+++ b/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>
diff --git a/functions-framework-invoker/pom.xml b/functions-framework-invoker/pom.xml
index f35453ec..c087a900 100644
--- a/functions-framework-invoker/pom.xml
+++ b/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>
diff --git a/functions-framework-invoker/src/main/java/dev/openfunction/invoker/runtime/AsynchronousRuntime.java b/functions-framework-invoker/src/main/java/dev/openfunction/invoker/runtime/AsynchronousRuntime.java
index cc5d81fd..0d478f0b 100644
--- a/functions-framework-invoker/src/main/java/dev/openfunction/invoker/runtime/AsynchronousRuntime.java
+++ b/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)
diff --git a/functions-framework-invoker/src/main/java/dev/openfunction/invoker/runtime/SynchronizeRuntime.java b/functions-framework-invoker/src/main/java/dev/openfunction/invoker/runtime/SynchronizeRuntime.java
index f6f4767a..23083d60 100644
--- a/functions-framework-invoker/src/main/java/dev/openfunction/invoker/runtime/SynchronizeRuntime.java
+++ b/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);
         }