Updating proto, daprd and cli + fix ITs for v1.0.0 Milestone 1. (#384)

* Updating proto, daprd and cli prior to v1.0.0 Milestone 1.

* Fixes integration tests.

.github/workflows/build.yml

@@ -24,8 +24,8 @@ jobs:
       JDK_VER: 13.0.x
       DAPR_RUNTIME_VER: 0.11.0-rc.2
       DAPR_INSTALL_URL: https://raw.githubusercontent.com/dapr/cli/e7c9a643dfefbcfff0c2c26c12029259e6e81180/install/install.sh
-      DAPR_CLI_REF: v0.11.0-rc.0
+      DAPR_CLI_REF: 8b3f62fb739b198bc07f36b08a7c77595a6d33c4
-      DAPR_REF: f4f3ee68960c5436fca9a19a40e1e91116e31776
+      DAPR_REF: 20c989955c66359665ae98181e7d021928ab2e0e
       OSSRH_USER_TOKEN: ${{ secrets.OSSRH_USER_TOKEN }}
       OSSRH_PWD_TOKEN: ${{ secrets.OSSRH_PWD_TOKEN }}
       GPG_KEY: ${{ secrets.GPG_KEY }}
@@ -40,7 +40,7 @@ jobs:
       run: wget -q ${{ env.DAPR_INSTALL_URL }} -O - | /bin/bash
     - name: Set up Go ${{ env.GOVER }}
       if: env.DAPR_REF != '' || env.DAPR_CLI_REF != ''
-      uses: actions/setup-go@v2-beta
+      uses: actions/setup-go@v2
       with:
         go-version: ${{ env.GOVER }}
     - name: Checkout Dapr CLI repo to override dapr command.

pom.xml

@@ -16,7 +16,7 @@
     <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
     <grpc.version>1.33.1</grpc.version>
     <protobuf.version>3.13.0</protobuf.version>
-    <dapr.proto.baseurl>https://raw.githubusercontent.com/dapr/dapr/67c4553aea13acef634540469f4a287b759a288e/dapr/proto</dapr.proto.baseurl>
+    <dapr.proto.baseurl>https://raw.githubusercontent.com/dapr/dapr/f3ddd345962d7e065e26a54f7b2f1f2db9af1fdb/dapr/proto</dapr.proto.baseurl>
     <os-maven-plugin.version>1.6.2</os-maven-plugin.version>
     <maven-dependency-plugin.version>3.1.1</maven-dependency-plugin.version>
     <maven-antrun-plugin.version>1.8</maven-antrun-plugin.version>

sdk-tests/src/test/java/io/dapr/it/actors/app/MyActorService.java

@@ -8,7 +8,7 @@ package io.dapr.it.actors.app;
 import io.dapr.actors.runtime.ActorRuntime;
 
 public class MyActorService {
-  public static final String SUCCESS_MESSAGE = "established connection to placement service at localhost";
+  public static final String SUCCESS_MESSAGE = "established connection to placement service at";
 
   /**
    * Starts the service.

sdk-tests/src/test/java/io/dapr/it/actors/services/springboot/DemoActorService.java

@@ -6,13 +6,12 @@
 package io.dapr.it.actors.services.springboot;
 
 import io.dapr.actors.runtime.ActorRuntime;
-import io.dapr.serializer.DefaultObjectSerializer;
 
 import java.time.Duration;
 
 public class DemoActorService {
 
-  public static final String SUCCESS_MESSAGE = "established connection to placement service at localhost";
+  public static final String SUCCESS_MESSAGE = "established connection to placement service at";
 
   /**
    * Starts the service.

sdk-tests/src/test/java/io/dapr/it/actors/services/springboot/StatefulActorService.java

@@ -12,7 +12,7 @@ import java.time.Duration;
 
 public class StatefulActorService {
 
-  public static final String SUCCESS_MESSAGE = "established connection to placement service at localhost";
+  public static final String SUCCESS_MESSAGE = "established connection to placement service at";
 
   /**
    * Starts the service.

sdk-tests/src/test/java/io/dapr/it/binding/http/InputBindingService.java

@@ -11,7 +11,7 @@ import org.springframework.boot.autoconfigure.SpringBootApplication;
 @SpringBootApplication
 public class InputBindingService {
 
-  public static final String SUCCESS_MESSAGE = "You're up and running!";
+  public static final String SUCCESS_MESSAGE = "Completed initialization in";
 
   public static void main(String[] args) throws Exception {
     // If port string is not valid, it will throw an exception.

sdk-tests/src/test/java/io/dapr/it/methodinvoke/http/MethodInvokeIT.java

@@ -2,18 +2,21 @@ package io.dapr.it.methodinvoke.http;
 
 import io.dapr.client.DaprClient;
 import io.dapr.client.DaprClientBuilder;
-import io.dapr.client.DaprHttp;
 import io.dapr.client.domain.HttpExtension;
 import io.dapr.it.BaseIT;
 import io.dapr.it.DaprRun;
-import org.junit.After;
 import org.junit.Before;
 import org.junit.Test;
 import org.junit.runner.RunWith;
 import org.junit.runners.Parameterized;
 
 import java.io.IOException;
-import java.util.*;
+import java.util.Arrays;
+import java.util.Calendar;
+import java.util.Collection;
+import java.util.Date;
+import java.util.List;
+import java.util.Map;
 
 import static org.junit.Assert.assertEquals;
 import static org.junit.runners.Parameterized.Parameter;
@@ -57,6 +60,9 @@ public class MethodInvokeIT extends BaseIT {
         } else {
             daprRun.switchToHTTP();
         }
+
+        // Wait since service might be ready even after port is available.
+        Thread.sleep(2000);
     }
 
     @Test

sdk-tests/src/test/java/io/dapr/it/methodinvoke/http/MethodInvokeService.java

@@ -15,7 +15,7 @@ import org.springframework.boot.autoconfigure.SpringBootApplication;
 @SpringBootApplication
 public class MethodInvokeService {
 
-  public static final String SUCCESS_MESSAGE = "You're up and running!";
+  public static final String SUCCESS_MESSAGE = "Completed initialization in";
 
   public static void main(String[] args) {
     int port = Integer.parseInt(args[0]);

sdk-tests/src/test/java/io/dapr/it/pubsub/http/SubscriberService.java

@@ -5,7 +5,6 @@
 
 package io.dapr.it.pubsub.http;
 
-import io.dapr.it.binding.http.InputBindingService;
 import org.springframework.boot.SpringApplication;
 import org.springframework.boot.autoconfigure.SpringBootApplication;
 
@@ -16,7 +15,7 @@ import org.springframework.boot.autoconfigure.SpringBootApplication;
 @SpringBootApplication(scanBasePackages = {"io.dapr.springboot", "io.dapr.it.pubsub.http"})
 public class SubscriberService {
 
-  public static final String SUCCESS_MESSAGE = "You're up and running!";
+  public static final String SUCCESS_MESSAGE = "Completed initialization in";
 
   public static void main(String[] args) throws Exception {
     int port = Integer.parseInt(args[0]);

sdk-tests/src/test/java/io/dapr/it/state/HelloWorldGrpcStateService.java

@@ -5,12 +5,11 @@
 
 package io.dapr.it.state;
 
-import com.google.protobuf.Any;
 import com.google.protobuf.ByteString;
+import io.dapr.v1.CommonProtos.StateItem;
 import io.dapr.v1.DaprGrpc;
 import io.dapr.v1.DaprGrpc.DaprBlockingStub;
 import io.dapr.v1.DaprProtos.SaveStateRequest;
-import io.dapr.v1.CommonProtos.StateItem;
 import io.grpc.ManagedChannel;
 import io.grpc.ManagedChannelBuilder;