diff --git a/.github/workflows/build.yml b/.github/workflows/build.yml
index 5613ce1685..dfe9980410 100644
--- a/.github/workflows/build.yml
+++ b/.github/workflows/build.yml
@@ -116,7 +116,7 @@ jobs:
GOPROXY: https://proxy.golang.org
JDK_VER: ${{ matrix.java }}
DAPR_CLI_VER: 1.15.0
- DAPR_RUNTIME_VER: 1.16.0-rc.5
+ DAPR_RUNTIME_VER: 1.17.0-rc.1
DAPR_INSTALL_URL: https://raw.githubusercontent.com/dapr/cli/v1.15.0/install/install.sh
DAPR_CLI_REF:
DAPR_REF:
diff --git a/.github/workflows/validate.yml b/.github/workflows/validate.yml
index 43d19bcd37..34db9d800a 100644
--- a/.github/workflows/validate.yml
+++ b/.github/workflows/validate.yml
@@ -38,7 +38,7 @@ jobs:
GOPROXY: https://proxy.golang.org
JDK_VER: ${{ matrix.java }}
DAPR_CLI_VER: 1.15.0
- DAPR_RUNTIME_VER: 1.16.0-rc.5
+ DAPR_RUNTIME_VER: 1.17.0-rc.1
DAPR_INSTALL_URL: https://raw.githubusercontent.com/dapr/cli/v1.15.0/install/install.sh
DAPR_CLI_REF:
DAPR_REF:
diff --git a/pom.xml b/pom.xml
index 37c6ecea7d..3cf40985ef 100644
--- a/pom.xml
+++ b/pom.xml
@@ -16,7 +16,7 @@
UTF-8
1.69.0
3.25.5
- https://raw.githubusercontent.com/dapr/dapr/v1.16.0-rc.5/dapr/proto
+ https://raw.githubusercontent.com/dapr/dapr/release-1.17/dapr/proto
https://raw.githubusercontent.com/dapr/durabletask-protobuf/main/protos/orchestrator_service.proto
1.17.0-SNAPSHOT
1.7.1
diff --git a/sdk-actors/src/main/java/io/dapr/actors/client/DaprClientImpl.java b/sdk-actors/src/main/java/io/dapr/actors/client/DaprClientImpl.java
index 30ea4616c9..4e0fdfac4d 100644
--- a/sdk-actors/src/main/java/io/dapr/actors/client/DaprClientImpl.java
+++ b/sdk-actors/src/main/java/io/dapr/actors/client/DaprClientImpl.java
@@ -15,24 +15,15 @@
import com.google.protobuf.ByteString;
import io.dapr.client.resiliency.ResiliencyOptions;
-import io.dapr.config.Properties;
import io.dapr.exceptions.DaprException;
import io.dapr.internal.grpc.DaprClientGrpcInterceptors;
import io.dapr.internal.resiliency.RetryPolicy;
import io.dapr.internal.resiliency.TimeoutPolicy;
+import io.dapr.v1.DaprActorsProtos;
import io.dapr.v1.DaprGrpc;
-import io.dapr.v1.DaprProtos;
-import io.grpc.CallOptions;
-import io.grpc.Channel;
-import io.grpc.ClientCall;
-import io.grpc.ClientInterceptor;
-import io.grpc.ForwardingClientCall;
-import io.grpc.Metadata;
-import io.grpc.MethodDescriptor;
import io.grpc.stub.StreamObserver;
import reactor.core.publisher.Mono;
import reactor.core.publisher.MonoSink;
-import reactor.util.context.ContextView;
import java.util.Map;
import java.util.concurrent.ExecutionException;
@@ -89,8 +80,8 @@ class DaprClientImpl implements DaprClient {
*/
@Override
public Mono invoke(String actorType, String actorId, String methodName, byte[] jsonPayload) {
- DaprProtos.InvokeActorRequest req =
- DaprProtos.InvokeActorRequest.newBuilder()
+ DaprActorsProtos.InvokeActorRequest req =
+ DaprActorsProtos.InvokeActorRequest.newBuilder()
.setActorType(actorType)
.setActorId(actorId)
.setMethod(methodName)
@@ -98,7 +89,7 @@ public Mono invoke(String actorType, String actorId, String methodName,
.setData(jsonPayload == null ? ByteString.EMPTY : ByteString.copyFrom(jsonPayload))
.build();
return Mono.deferContextual(
- context -> this.createMono(
+ context -> this.createMono(
it -> this.grpcInterceptors.intercept(client, context).invokeActor(req, it)
)
).map(r -> r.getData().toByteArray());
diff --git a/sdk-actors/src/main/java/io/dapr/actors/runtime/DaprClientImpl.java b/sdk-actors/src/main/java/io/dapr/actors/runtime/DaprClientImpl.java
index a14d7e257a..6dfef68585 100644
--- a/sdk-actors/src/main/java/io/dapr/actors/runtime/DaprClientImpl.java
+++ b/sdk-actors/src/main/java/io/dapr/actors/runtime/DaprClientImpl.java
@@ -20,8 +20,8 @@
import io.dapr.config.Properties;
import io.dapr.exceptions.DaprException;
import io.dapr.utils.DurationUtils;
+import io.dapr.v1.DaprActorsProtos;
import io.dapr.v1.DaprGrpc;
-import io.dapr.v1.DaprProtos;
import io.grpc.ManagedChannel;
import io.grpc.stub.StreamObserver;
import reactor.core.publisher.Mono;
@@ -78,14 +78,14 @@ class DaprClientImpl implements DaprClient {
*/
@Override
public Mono getState(String actorType, String actorId, String keyName) {
- DaprProtos.GetActorStateRequest req =
- DaprProtos.GetActorStateRequest.newBuilder()
+ DaprActorsProtos.GetActorStateRequest req =
+ DaprActorsProtos.GetActorStateRequest.newBuilder()
.setActorType(actorType)
.setActorId(actorId)
.setKey(keyName)
.build();
- return Mono.create(it ->
+ return Mono.create(it ->
client.getActorState(req, createStreamObserver(it))).map(r -> r.getData().toByteArray());
}
@@ -97,13 +97,13 @@ public Mono saveStateTransactionally(
String actorType,
String actorId,
List operations) {
- List grpcOps = new ArrayList<>();
+ List grpcOps = new ArrayList<>();
for (ActorStateOperation op : operations) {
String operationType = op.getOperationType();
String key = op.getKey();
Object value = op.getValue();
- DaprProtos.TransactionalActorStateOperation.Builder opBuilder =
- DaprProtos.TransactionalActorStateOperation.newBuilder()
+ DaprActorsProtos.TransactionalActorStateOperation.Builder opBuilder =
+ DaprActorsProtos.TransactionalActorStateOperation.newBuilder()
.setOperationType(operationType)
.setKey(key);
if (value != null) {
@@ -126,8 +126,8 @@ public Mono saveStateTransactionally(
grpcOps.add(opBuilder.build());
}
- DaprProtos.ExecuteActorStateTransactionRequest req =
- DaprProtos.ExecuteActorStateTransactionRequest.newBuilder()
+ DaprActorsProtos.ExecuteActorStateTransactionRequest req =
+ DaprActorsProtos.ExecuteActorStateTransactionRequest.newBuilder()
.setActorType(actorType)
.setActorId(actorId)
.addAllOperations(grpcOps)
@@ -145,8 +145,8 @@ public Mono registerReminder(
String actorId,
String reminderName,
ActorReminderParams reminderParams) {
- DaprProtos.RegisterActorReminderRequest req =
- DaprProtos.RegisterActorReminderRequest.newBuilder()
+ DaprActorsProtos.RegisterActorReminderRequest req =
+ DaprActorsProtos.RegisterActorReminderRequest.newBuilder()
.setActorType(actorType)
.setActorId(actorId)
.setName(reminderName)
@@ -162,8 +162,8 @@ public Mono registerReminder(
*/
@Override
public Mono unregisterReminder(String actorType, String actorId, String reminderName) {
- DaprProtos.UnregisterActorReminderRequest req =
- DaprProtos.UnregisterActorReminderRequest.newBuilder()
+ DaprActorsProtos.UnregisterActorReminderRequest req =
+ DaprActorsProtos.UnregisterActorReminderRequest.newBuilder()
.setActorType(actorType)
.setActorId(actorId)
.setName(reminderName)
@@ -181,8 +181,8 @@ public Mono registerTimer(
String actorId,
String timerName,
ActorTimerParams timerParams) {
- DaprProtos.RegisterActorTimerRequest req =
- DaprProtos.RegisterActorTimerRequest.newBuilder()
+ DaprActorsProtos.RegisterActorTimerRequest req =
+ DaprActorsProtos.RegisterActorTimerRequest.newBuilder()
.setActorType(actorType)
.setActorId(actorId)
.setName(timerName)
@@ -200,8 +200,8 @@ public Mono registerTimer(
*/
@Override
public Mono unregisterTimer(String actorType, String actorId, String timerName) {
- DaprProtos.UnregisterActorTimerRequest req =
- DaprProtos.UnregisterActorTimerRequest.newBuilder()
+ DaprActorsProtos.UnregisterActorTimerRequest req =
+ DaprActorsProtos.UnregisterActorTimerRequest.newBuilder()
.setActorType(actorType)
.setActorId(actorId)
.setName(timerName)
diff --git a/sdk-actors/src/test/java/io/dapr/actors/client/DaprGrpcClientTest.java b/sdk-actors/src/test/java/io/dapr/actors/client/DaprGrpcClientTest.java
index 1f05e7ac6c..e2f75a2b41 100644
--- a/sdk-actors/src/test/java/io/dapr/actors/client/DaprGrpcClientTest.java
+++ b/sdk-actors/src/test/java/io/dapr/actors/client/DaprGrpcClientTest.java
@@ -14,8 +14,8 @@
package io.dapr.actors.client;
import com.google.protobuf.ByteString;
+import io.dapr.v1.DaprActorsProtos;
import io.dapr.v1.DaprGrpc;
-import io.dapr.v1.DaprProtos;
import io.grpc.ManagedChannel;
import io.grpc.Status;
import io.grpc.StatusException;
@@ -60,22 +60,22 @@ public class DaprGrpcClientTest {
mock(DaprGrpc.DaprImplBase.class, delegatesTo(
new DaprGrpc.DaprImplBase() {
@Override
- public void invokeActor(DaprProtos.InvokeActorRequest request,
- StreamObserver responseObserver) {
+ public void invokeActor(DaprActorsProtos.InvokeActorRequest request,
+ StreamObserver responseObserver) {
assertEquals(ACTOR_TYPE, request.getActorType());
assertEquals(METHOD_NAME, request.getMethod());
switch (request.getActorId()) {
case ACTOR_ID_OK:
assertArrayEquals(REQUEST_PAYLOAD, request.getData().toByteArray());
responseObserver.onNext(
- DaprProtos.InvokeActorResponse.newBuilder().setData(ByteString.copyFrom(RESPONSE_PAYLOAD))
+ DaprActorsProtos.InvokeActorResponse.newBuilder().setData(ByteString.copyFrom(RESPONSE_PAYLOAD))
.build());
responseObserver.onCompleted();
return;
case ACTOR_ID_NULL_INPUT:
assertArrayEquals(new byte[0], request.getData().toByteArray());
responseObserver.onNext(
- DaprProtos.InvokeActorResponse.newBuilder().setData(ByteString.copyFrom(RESPONSE_PAYLOAD))
+ DaprActorsProtos.InvokeActorResponse.newBuilder().setData(ByteString.copyFrom(RESPONSE_PAYLOAD))
.build());
responseObserver.onCompleted();
return;
diff --git a/sdk-actors/src/test/java/io/dapr/actors/runtime/DaprGrpcClientTest.java b/sdk-actors/src/test/java/io/dapr/actors/runtime/DaprGrpcClientTest.java
index 7f006df1ec..425ba64589 100644
--- a/sdk-actors/src/test/java/io/dapr/actors/runtime/DaprGrpcClientTest.java
+++ b/sdk-actors/src/test/java/io/dapr/actors/runtime/DaprGrpcClientTest.java
@@ -17,9 +17,8 @@
import com.google.protobuf.Any;
import com.google.protobuf.ByteString;
import com.google.protobuf.Empty;
-import com.google.protobuf.GeneratedMessageV3;
+import io.dapr.v1.DaprActorsProtos;
import io.dapr.v1.DaprGrpc;
-import io.dapr.v1.DaprProtos;
import io.grpc.ManagedChannel;
import io.grpc.Status;
import io.grpc.StatusException;
@@ -178,17 +177,83 @@ public void unregisterActorTimer() {
}
- private class CustomDaprClient extends DaprGrpc.DaprImplBase {
+ private static class OperationsMatcher {
+
+ private final List operations;
+
+ OperationsMatcher(List operations) {
+ this.operations = operations;
+ }
+
+ private static boolean nullableEquals(Object one, Any another) {
+ if (one == null) {
+ return another.getValue().isEmpty();
+ }
+
+ if ((one == null) ^ (another == null)) {
+ return false;
+ }
+
+ try {
+ Any oneAny = getAny(one);
+ return oneAny.getValue().equals(another.getValue());
+ } catch (IOException e) {
+ e.printStackTrace();
+ return false;
+ }
+ }
+
+ private static Any getAny(Object value) throws IOException {
+ if (value instanceof byte[]) {
+ String base64 = OBJECT_MAPPER.writeValueAsString(value);
+ return Any.newBuilder().setValue(ByteString.copyFrom(base64.getBytes())).build();
+ } else if (value instanceof String) {
+ return Any.newBuilder().setValue(ByteString.copyFrom(((String) value).getBytes())).build();
+ }
+
+ throw new IllegalArgumentException("Must be byte[] or String");
+ }
+
+ public boolean matches(DaprActorsProtos.ExecuteActorStateTransactionRequest argument) {
+ if (argument == null) {
+ return false;
+ }
+
+ if (operations.size() != argument.getOperationsCount()) {
+ return false;
+ }
+
+ for (ActorStateOperation operation : operations) {
+ boolean found = false;
+ for (DaprActorsProtos.TransactionalActorStateOperation grpcOperation : argument.getOperationsList()) {
+ if (operation.getKey().equals(grpcOperation.getKey())
+ && operation.getOperationType().equals(grpcOperation.getOperationType())
+ && nullableEquals(operation.getValue(), grpcOperation.getValue())) {
+ found = true;
+ break;
+ }
+ }
+
+ if (!found) {
+ return false;
+ }
+ }
+
+ return true;
+ }
+ }
+
+ private class CustomDaprClient extends DaprGrpc.DaprImplBase {
@Override
- public void getActorState(DaprProtos.GetActorStateRequest request,
- StreamObserver responseObserver) {
+ public void getActorState(DaprActorsProtos.GetActorStateRequest request,
+ StreamObserver responseObserver) {
assertEquals(ACTOR_TYPE, request.getActorType());
assertEquals(KEY, request.getKey());
assertEquals(ACTOR_ID, request.getActorId());
switch (request.getActorId()) {
case ACTOR_ID:
- populateObserver(responseObserver, DaprProtos.GetActorStateResponse.newBuilder().setData(ByteString.copyFrom(RESPONSE_PAYLOAD))
+ populateObserver(responseObserver, DaprActorsProtos.GetActorStateResponse.newBuilder().setData(ByteString.copyFrom(RESPONSE_PAYLOAD))
.build());
return;
@@ -199,7 +264,7 @@ public void getActorState(DaprProtos.GetActorStateRequest request,
super.getActorState(request, responseObserver);
}
- public void executeActorStateTransaction(io.dapr.v1.DaprProtos.ExecuteActorStateTransactionRequest request,
+ public void executeActorStateTransaction(DaprActorsProtos.ExecuteActorStateTransactionRequest request,
io.grpc.stub.StreamObserver responseObserver) {
assertEquals(ACTOR_TYPE, request.getActorType());
assertEquals(ACTOR_ID, request.getActorId());
@@ -217,7 +282,7 @@ public void executeActorStateTransaction(io.dapr.v1.DaprProtos.ExecuteActorState
}
@Override
- public void registerActorReminder(io.dapr.v1.DaprProtos.RegisterActorReminderRequest request,
+ public void registerActorReminder(DaprActorsProtos.RegisterActorReminderRequest request,
io.grpc.stub.StreamObserver responseObserver) {
assertEquals(REMINDER_NAME, request.getName());
assertEquals("0h0m1s0ms", request.getDueTime());
@@ -236,7 +301,7 @@ public void registerActorReminder(io.dapr.v1.DaprProtos.RegisterActorReminderReq
super.registerActorReminder(request, responseObserver);
}
- public void registerActorTimer(io.dapr.v1.DaprProtos.RegisterActorTimerRequest request,
+ public void registerActorTimer(DaprActorsProtos.RegisterActorTimerRequest request,
io.grpc.stub.StreamObserver responseObserver) {
assertEquals(ACTOR_TYPE, request.getActorType());
assertEquals(ACTOR_ID, request.getActorId());
@@ -261,7 +326,7 @@ public void registerActorTimer(io.dapr.v1.DaprProtos.RegisterActorTimerRequest r
* Unregister an actor timer.
*
*/
- public void unregisterActorTimer(io.dapr.v1.DaprProtos.UnregisterActorTimerRequest request,
+ public void unregisterActorTimer(DaprActorsProtos.UnregisterActorTimerRequest request,
io.grpc.stub.StreamObserver responseObserver) {
assertEquals(ACTOR_TYPE, request.getActorType());
assertEquals(ACTOR_ID, request.getActorId());
@@ -278,7 +343,7 @@ public void unregisterActorTimer(io.dapr.v1.DaprProtos.UnregisterActorTimerReque
super.unregisterActorTimer(request, responseObserver);
}
- public void unregisterActorReminder(io.dapr.v1.DaprProtos.UnregisterActorReminderRequest request,
+ public void unregisterActorReminder(DaprActorsProtos.UnregisterActorReminderRequest request,
io.grpc.stub.StreamObserver responseObserver) {
assertEquals(ACTOR_TYPE, request.getActorType());
assertEquals(ACTOR_ID, request.getActorId());
@@ -306,70 +371,4 @@ private void populateObserver(StreamObse
responseObserver.onCompleted();
}
}
-
- private static class OperationsMatcher {
-
- private final List operations;
-
- OperationsMatcher(List operations) {
- this.operations = operations;
- }
-
- public boolean matches(DaprProtos.ExecuteActorStateTransactionRequest argument) {
- if (argument == null) {
- return false;
- }
-
- if (operations.size() != argument.getOperationsCount()) {
- return false;
- }
-
- for (ActorStateOperation operation : operations) {
- boolean found = false;
- for (DaprProtos.TransactionalActorStateOperation grpcOperation : argument.getOperationsList()) {
- if (operation.getKey().equals(grpcOperation.getKey())
- && operation.getOperationType().equals(grpcOperation.getOperationType())
- && nullableEquals(operation.getValue(), grpcOperation.getValue())) {
- found = true;
- break;
- }
- }
-
- if (!found) {
- return false;
- }
- }
-
- return true;
- }
-
- private static boolean nullableEquals(Object one, Any another) {
- if (one == null) {
- return another.getValue().isEmpty();
- }
-
- if ((one == null) ^ (another == null)) {
- return false;
- }
-
- try {
- Any oneAny = getAny(one);
- return oneAny.getValue().equals(another.getValue());
- } catch (IOException e) {
- e.printStackTrace();
- return false;
- }
- }
-
- private static Any getAny(Object value) throws IOException {
- if (value instanceof byte[]) {
- String base64 = OBJECT_MAPPER.writeValueAsString(value);
- return Any.newBuilder().setValue(ByteString.copyFrom(base64.getBytes())).build();
- } else if (value instanceof String) {
- return Any.newBuilder().setValue(ByteString.copyFrom(((String)value).getBytes())).build();
- }
-
- throw new IllegalArgumentException("Must be byte[] or String");
- }
- }
}
diff --git a/sdk-autogen/pom.xml b/sdk-autogen/pom.xml
index b64287d811..d6339abaf9 100644
--- a/sdk-autogen/pom.xml
+++ b/sdk-autogen/pom.xml
@@ -59,6 +59,97 @@
download-maven-plugin
${download-maven-plugin.version}
+
+ getCommonProto
+ initialize
+
+ wget
+
+
+ true
+ ${dapr.proto.baseurl}/common/v1/common.proto
+ common.proto
+ ${protobuf.input.directory}/dapr/proto/common/v1
+
+
+
+ getActorsProto
+ initialize
+
+ wget
+
+
+ true
+ ${dapr.proto.baseurl}/runtime/v1/actors.proto
+ actors.proto
+ ${protobuf.input.directory}/dapr/proto/runtime/v1
+
+
+
+ getAiProto
+ initialize
+
+ wget
+
+
+ true
+ ${dapr.proto.baseurl}/runtime/v1/ai.proto
+ ai.proto
+ ${protobuf.input.directory}/dapr/proto/runtime/v1
+
+
+
+ getAppcallbackProto
+ initialize
+
+ wget
+
+
+ true
+ ${dapr.proto.baseurl}/runtime/v1/appcallback.proto
+ appcallback.proto
+ ${protobuf.input.directory}/dapr/proto/runtime/v1
+
+
+
+ getBindingProto
+ initialize
+
+ wget
+
+
+ true
+ ${dapr.proto.baseurl}/runtime/v1/binding.proto
+ binding.proto
+ ${protobuf.input.directory}/dapr/proto/runtime/v1
+
+
+
+ getConfigurationProto
+ initialize
+
+ wget
+
+
+ true
+ ${dapr.proto.baseurl}/runtime/v1/configuration.proto
+ configuration.proto
+ ${protobuf.input.directory}/dapr/proto/runtime/v1
+
+
+
+ getCryptoProto
+ initialize
+
+ wget
+
+
+ true
+ ${dapr.proto.baseurl}/runtime/v1/crypto.proto
+ crypto.proto
+ ${protobuf.input.directory}/dapr/proto/runtime/v1
+
+
getDaprProto
initialize
@@ -73,33 +164,113 @@
- getCommonProto
+ getInvokeProto
initialize
wget
true
- ${dapr.proto.baseurl}/common/v1/common.proto
- common.proto
- ${protobuf.input.directory}/dapr/proto/common/v1
+ ${dapr.proto.baseurl}/runtime/v1/invoke.proto
+ invoke.proto
+ ${protobuf.input.directory}/dapr/proto/runtime/v1
- getDaprClientProto
+ getJobsProto
initialize
wget
true
- ${dapr.proto.baseurl}/runtime/v1/appcallback.proto
- appcallback.proto
+ ${dapr.proto.baseurl}/runtime/v1/jobs.proto
+ jobs.proto
+ ${protobuf.input.directory}/dapr/proto/runtime/v1
+
+
+
+ getLockProto
+ initialize
+
+ wget
+
+
+ true
+ ${dapr.proto.baseurl}/runtime/v1/lock.proto
+ lock.proto
+ ${protobuf.input.directory}/dapr/proto/runtime/v1
+
+
+
+ getMetadataProto
+ initialize
+
+ wget
+
+
+ true
+ ${dapr.proto.baseurl}/runtime/v1/metadata.proto
+ metadata.proto
+ ${protobuf.input.directory}/dapr/proto/runtime/v1
+
+
+
+ getPubsubProto
+ initialize
+
+ wget
+
+
+ true
+ ${dapr.proto.baseurl}/runtime/v1/pubsub.proto
+ pubsub.proto
+ ${protobuf.input.directory}/dapr/proto/runtime/v1
+
+
+
+ getSecretProto
+ initialize
+
+ wget
+
+
+ true
+ ${dapr.proto.baseurl}/runtime/v1/secret.proto
+ secret.proto
+ ${protobuf.input.directory}/dapr/proto/runtime/v1
+
+
+
+ getStateProto
+ initialize
+
+ wget
+
+
+ true
+ ${dapr.proto.baseurl}/runtime/v1/state.proto
+ state.proto
+ ${protobuf.input.directory}/dapr/proto/runtime/v1
+
+
+
+ getWorkflowProto
+ initialize
+
+ wget
+
+
+ true
+ ${dapr.proto.baseurl}/runtime/v1/workflow.proto
+ workflow.proto
${protobuf.input.directory}/dapr/proto/runtime/v1
+
+
org.xolstice.maven.plugins
protobuf-maven-plugin
@@ -116,6 +287,13 @@
compile
compile-custom
+
+
+ dapr/proto/common/v1/common.proto
+ dapr/proto/runtime/v1/*.proto
+
+
+
diff --git a/sdk-tests/src/test/java/io/dapr/it/state/HelloWorldClientIT.java b/sdk-tests/src/test/java/io/dapr/it/state/HelloWorldClientIT.java
index 713f152f15..bdd25ae780 100644
--- a/sdk-tests/src/test/java/io/dapr/it/state/HelloWorldClientIT.java
+++ b/sdk-tests/src/test/java/io/dapr/it/state/HelloWorldClientIT.java
@@ -16,7 +16,7 @@
import io.dapr.it.BaseIT;
import io.dapr.it.DaprRun;
import io.dapr.v1.DaprGrpc;
-import io.dapr.v1.DaprProtos;
+import io.dapr.v1.DaprStateProtos;
import org.junit.jupiter.api.Assertions;
import org.junit.jupiter.api.Test;
@@ -36,12 +36,12 @@ public void testHelloWorldState() throws Exception {
String key = "mykey";
{
- DaprProtos.GetStateRequest req = DaprProtos.GetStateRequest
+ DaprStateProtos.GetStateRequest req = DaprStateProtos.GetStateRequest
.newBuilder()
.setStoreName(STATE_STORE_NAME)
.setKey(key)
.build();
- DaprProtos.GetStateResponse response = stub.getState(req);
+ DaprStateProtos.GetStateResponse response = stub.getState(req);
String value = response.getData().toStringUtf8();
System.out.println("Got: " + value);
Assertions.assertEquals("Hello World", value);
@@ -49,7 +49,7 @@ public void testHelloWorldState() throws Exception {
// Then, delete it.
{
- DaprProtos.DeleteStateRequest req = DaprProtos.DeleteStateRequest
+ DaprStateProtos.DeleteStateRequest req = DaprStateProtos.DeleteStateRequest
.newBuilder()
.setStoreName(STATE_STORE_NAME)
.setKey(key)
@@ -59,12 +59,12 @@ public void testHelloWorldState() throws Exception {
}
{
- DaprProtos.GetStateRequest req = DaprProtos.GetStateRequest
+ DaprStateProtos.GetStateRequest req = DaprStateProtos.GetStateRequest
.newBuilder()
.setStoreName(STATE_STORE_NAME)
.setKey(key)
.build();
- DaprProtos.GetStateResponse response = stub.getState(req);
+ DaprStateProtos.GetStateResponse response = stub.getState(req);
String value = response.getData().toStringUtf8();
System.out.println("Got: " + value);
Assertions.assertEquals("", value);
diff --git a/sdk-tests/src/test/java/io/dapr/it/state/HelloWorldGrpcStateService.java b/sdk-tests/src/test/java/io/dapr/it/state/HelloWorldGrpcStateService.java
index be493b4697..abab918be7 100644
--- a/sdk-tests/src/test/java/io/dapr/it/state/HelloWorldGrpcStateService.java
+++ b/sdk-tests/src/test/java/io/dapr/it/state/HelloWorldGrpcStateService.java
@@ -20,7 +20,7 @@
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.DaprStateProtos.SaveStateRequest;
import io.grpc.ManagedChannel;
import io.grpc.ManagedChannelBuilder;
diff --git a/sdk/src/main/java/io/dapr/client/DaprClientImpl.java b/sdk/src/main/java/io/dapr/client/DaprClientImpl.java
index 05b555b5e9..c32f8789ea 100644
--- a/sdk/src/main/java/io/dapr/client/DaprClientImpl.java
+++ b/sdk/src/main/java/io/dapr/client/DaprClientImpl.java
@@ -99,16 +99,18 @@
import io.dapr.utils.DefaultContentTypeConverter;
import io.dapr.utils.TypeRef;
import io.dapr.v1.CommonProtos;
+import io.dapr.v1.DaprAiProtos;
+import io.dapr.v1.DaprBindingsProtos;
+import io.dapr.v1.DaprConfigurationProtos;
+import io.dapr.v1.DaprCryptoProtos;
import io.dapr.v1.DaprGrpc;
+import io.dapr.v1.DaprJobsProtos;
+import io.dapr.v1.DaprLockProtos;
+import io.dapr.v1.DaprMetadataProtos;
import io.dapr.v1.DaprProtos;
-import io.dapr.v1.DaprProtos.ActiveActorsCount;
-import io.dapr.v1.DaprProtos.ActorRuntime;
-import io.dapr.v1.DaprProtos.AppConnectionHealthProperties;
-import io.dapr.v1.DaprProtos.AppConnectionProperties;
-import io.dapr.v1.DaprProtos.MetadataHTTPEndpoint;
-import io.dapr.v1.DaprProtos.PubsubSubscription;
-import io.dapr.v1.DaprProtos.PubsubSubscriptionRule;
-import io.dapr.v1.DaprProtos.RegisteredComponents;
+import io.dapr.v1.DaprPubsubProtos;
+import io.dapr.v1.DaprSecretProtos;
+import io.dapr.v1.DaprStateProtos;
import io.grpc.Channel;
import io.grpc.Metadata;
import io.grpc.stub.AbstractStub;
@@ -313,7 +315,7 @@ public > T newGrpcStub(String appId, Function waitForSidecar(int timeoutInMilliseconds) {
- String[] pathSegments = new String[] { DaprHttp.API_VERSION, "healthz", "outbound"};
+ String[] pathSegments = new String[]{DaprHttp.API_VERSION, "healthz", "outbound"};
// Do the Dapr Http endpoint check to have parity with Dotnet
Mono responseMono = this.httpClient.invokeApi(DaprHttp.HttpMethods.GET.name(), pathSegments,
@@ -345,7 +347,7 @@ public Mono publishEvent(PublishEventRequest request) {
String pubsubName = request.getPubsubName();
String topic = request.getTopic();
Object data = request.getData();
- DaprProtos.PublishEventRequest.Builder envelopeBuilder = DaprProtos.PublishEventRequest.newBuilder()
+ DaprPubsubProtos.PublishEventRequest.Builder envelopeBuilder = DaprPubsubProtos.PublishEventRequest.newBuilder()
.setTopic(topic)
.setPubsubName(pubsubName)
.setData(ByteString.copyFrom(objectSerializer.serialize(data)));
@@ -382,7 +384,7 @@ public Mono> publishEvents(BulkPublishRequest requ
try {
String pubsubName = request.getPubsubName();
String topic = request.getTopic();
- DaprProtos.BulkPublishRequest.Builder envelopeBuilder = DaprProtos.BulkPublishRequest.newBuilder();
+ DaprPubsubProtos.BulkPublishRequest.Builder envelopeBuilder = DaprPubsubProtos.BulkPublishRequest.newBuilder();
envelopeBuilder.setTopic(topic);
envelopeBuilder.setPubsubName(pubsubName);
@@ -414,10 +416,11 @@ public Mono> publishEvents(BulkPublishRequest requ
throw DaprException.propagate(ex);
}
- DaprProtos.BulkPublishRequestEntry.Builder reqEntryBuilder = DaprProtos.BulkPublishRequestEntry.newBuilder()
- .setEntryId(entry.getEntryId())
- .setEvent(ByteString.copyFrom(data))
- .setContentType(contentType);
+ DaprPubsubProtos.BulkPublishRequestEntry.Builder reqEntryBuilder =
+ DaprPubsubProtos.BulkPublishRequestEntry.newBuilder()
+ .setEntryId(entry.getEntryId())
+ .setEvent(ByteString.copyFrom(data))
+ .setContentType(contentType);
Map metadata = entry.getMetadata();
if (metadata != null) {
reqEntryBuilder.putAllMetadata(metadata);
@@ -437,13 +440,14 @@ public Mono> publishEvents(BulkPublishRequest requ
}
return Mono.deferContextual(
context ->
- this.createMono(
- it -> intercept(context, asyncStub).bulkPublishEventAlpha1(envelopeBuilder.build(), it)
+ this.createMono(
+ it ->
+ intercept(context, asyncStub).bulkPublishEventAlpha1(envelopeBuilder.build(), it)
)
).map(
it -> {
List> entries = new ArrayList<>();
- for (DaprProtos.BulkPublishResponseFailedEntry entry : it.getFailedEntriesList()) {
+ for (DaprPubsubProtos.BulkPublishResponseFailedEntry entry : it.getFailedEntriesList()) {
BulkPublishResponseFailedEntry domainEntry = new BulkPublishResponseFailedEntry(
entryMap.get(entry.getEntryId()),
entry.getError());
@@ -466,13 +470,13 @@ public Mono> publishEvents(BulkPublishRequest requ
@Override
public Subscription subscribeToEvents(
String pubsubName, String topic, SubscriptionListener listener, TypeRef type) {
- DaprProtos.SubscribeTopicEventsRequestInitialAlpha1 initialRequest =
- DaprProtos.SubscribeTopicEventsRequestInitialAlpha1.newBuilder()
+ DaprPubsubProtos.SubscribeTopicEventsRequestInitialAlpha1 initialRequest =
+ DaprPubsubProtos.SubscribeTopicEventsRequestInitialAlpha1.newBuilder()
.setTopic(topic)
.setPubsubName(pubsubName)
.build();
- DaprProtos.SubscribeTopicEventsRequestAlpha1 request =
- DaprProtos.SubscribeTopicEventsRequestAlpha1.newBuilder()
+ DaprPubsubProtos.SubscribeTopicEventsRequestAlpha1 request =
+ DaprPubsubProtos.SubscribeTopicEventsRequestAlpha1.newBuilder()
.setInitialRequest(initialRequest)
.build();
return buildSubscription(listener, type, request);
@@ -483,13 +487,13 @@ public Subscription subscribeToEvents(
*/
@Override
public Flux> subscribeToEvents(String pubsubName, String topic, TypeRef type) {
- DaprProtos.SubscribeTopicEventsRequestInitialAlpha1 initialRequest =
- DaprProtos.SubscribeTopicEventsRequestInitialAlpha1.newBuilder()
+ DaprPubsubProtos.SubscribeTopicEventsRequestInitialAlpha1 initialRequest =
+ DaprPubsubProtos.SubscribeTopicEventsRequestInitialAlpha1.newBuilder()
.setTopic(topic)
.setPubsubName(pubsubName)
.build();
- DaprProtos.SubscribeTopicEventsRequestAlpha1 request =
- DaprProtos.SubscribeTopicEventsRequestAlpha1.newBuilder()
+ DaprPubsubProtos.SubscribeTopicEventsRequestAlpha1 request =
+ DaprPubsubProtos.SubscribeTopicEventsRequestAlpha1.newBuilder()
.setInitialRequest(initialRequest)
.build();
@@ -501,7 +505,7 @@ public Flux> subscribeToEvents(String pubsubName, String topic
type,
this.objectSerializer
);
- StreamObserver requestStream = eventSubscriber.start(request);
+ StreamObserver requestStream = eventSubscriber.start(request);
// Cleanup when Flux is cancelled or completed
sink.onDispose(() -> {
@@ -518,36 +522,37 @@ public Flux> subscribeToEvents(String pubsubName, String topic
private Subscription buildSubscription(
SubscriptionListener listener,
TypeRef type,
- DaprProtos.SubscribeTopicEventsRequestAlpha1 request) {
+ DaprPubsubProtos.SubscribeTopicEventsRequestAlpha1 request) {
var interceptedStub = this.grpcInterceptors.intercept(this.asyncStub);
- Subscription subscription = new Subscription<>(interceptedStub, request, listener, response -> {
- if (response.getEventMessage() == null) {
- return null;
- }
+ Subscription subscription =
+ new Subscription<>(interceptedStub, request, listener, response -> {
+ if (response.getEventMessage() == null) {
+ return null;
+ }
- var message = response.getEventMessage();
- if ((message.getPubsubName() == null) || message.getPubsubName().isEmpty()) {
- return null;
- }
+ var message = response.getEventMessage();
+ if ((message.getPubsubName() == null) || message.getPubsubName().isEmpty()) {
+ return null;
+ }
- try {
- CloudEvent cloudEvent = new CloudEvent<>();
- T object = null;
- if (type != null) {
- object = DaprClientImpl.this.objectSerializer.deserialize(message.getData().toByteArray(), type);
- }
- cloudEvent.setData(object);
- cloudEvent.setDatacontenttype(message.getDataContentType());
- cloudEvent.setId(message.getId());
- cloudEvent.setTopic(message.getTopic());
- cloudEvent.setSpecversion(message.getSpecVersion());
- cloudEvent.setType(message.getType());
- cloudEvent.setPubsubName(message.getPubsubName());
- return cloudEvent;
- } catch (IOException e) {
- throw new RuntimeException(e);
- }
- });
+ try {
+ CloudEvent cloudEvent = new CloudEvent<>();
+ T object = null;
+ if (type != null) {
+ object = DaprClientImpl.this.objectSerializer.deserialize(message.getData().toByteArray(), type);
+ }
+ cloudEvent.setData(object);
+ cloudEvent.setDatacontenttype(message.getDataContentType());
+ cloudEvent.setId(message.getId());
+ cloudEvent.setTopic(message.getTopic());
+ cloudEvent.setSpecversion(message.getSpecVersion());
+ cloudEvent.setType(message.getType());
+ cloudEvent.setPubsubName(message.getPubsubName());
+ return cloudEvent;
+ } catch (IOException e) {
+ throw new RuntimeException(e);
+ }
+ });
subscription.start();
return subscription;
}
@@ -637,7 +642,7 @@ public Mono invokeBinding(InvokeBindingRequest request, TypeRef type)
}
byte[] byteData = objectSerializer.serialize(data);
- DaprProtos.InvokeBindingRequest.Builder builder = DaprProtos.InvokeBindingRequest.newBuilder()
+ DaprBindingsProtos.InvokeBindingRequest.Builder builder = DaprBindingsProtos.InvokeBindingRequest.newBuilder()
.setName(name).setOperation(operation);
if (byteData != null) {
builder.setData(ByteString.copyFrom(byteData));
@@ -645,13 +650,14 @@ public Mono invokeBinding(InvokeBindingRequest request, TypeRef type)
if (metadata != null) {
builder.putAllMetadata(metadata);
}
- DaprProtos.InvokeBindingRequest envelope = builder.build();
+ DaprBindingsProtos.InvokeBindingRequest envelope = builder.build();
Metadata responseMetadata = new Metadata();
return Mono.deferContextual(
- context -> this.createMono(
+ context -> this.createMono(
responseMetadata,
- it -> intercept(context, asyncStub, m -> responseMetadata.merge(m)).invokeBinding(envelope, it)
+ it ->
+ intercept(context, asyncStub, m -> responseMetadata.merge(m)).invokeBinding(envelope, it)
)
).flatMap(
it -> {
@@ -695,7 +701,7 @@ public Mono> getState(GetStateRequest request, TypeRef type) {
if ((key == null) || (key.trim().isEmpty())) {
throw new IllegalArgumentException("Key cannot be null or empty.");
}
- DaprProtos.GetStateRequest.Builder builder = DaprProtos.GetStateRequest.newBuilder()
+ DaprStateProtos.GetStateRequest.Builder builder = DaprStateProtos.GetStateRequest.newBuilder()
.setStoreName(stateStoreName)
.setKey(key);
if (metadata != null) {
@@ -705,11 +711,11 @@ public Mono> getState(GetStateRequest request, TypeRef type) {
builder.setConsistency(getGrpcStateConsistency(options));
}
- DaprProtos.GetStateRequest envelope = builder.build();
+ DaprStateProtos.GetStateRequest envelope = builder.build();
return Mono.deferContextual(
context ->
- this.createMono(
+ this.createMono(
it -> intercept(context, asyncStub).getState(envelope, it)
)
).map(
@@ -746,7 +752,7 @@ public Mono>> getBulkState(GetBulkStateRequest request, TypeRe
if (parallelism < 0) {
throw new IllegalArgumentException("Parallelism cannot be negative.");
}
- DaprProtos.GetBulkStateRequest.Builder builder = DaprProtos.GetBulkStateRequest.newBuilder()
+ DaprStateProtos.GetBulkStateRequest.Builder builder = DaprStateProtos.GetBulkStateRequest.newBuilder()
.setStoreName(stateStoreName)
.addAllKeys(keys)
.setParallelism(parallelism);
@@ -754,10 +760,10 @@ public Mono>> getBulkState(GetBulkStateRequest request, TypeRe
builder.putAllMetadata(metadata);
}
- DaprProtos.GetBulkStateRequest envelope = builder.build();
+ DaprStateProtos.GetBulkStateRequest envelope = builder.build();
return Mono.deferContextual(
- context -> this.createMono(it -> intercept(context, asyncStub)
+ context -> this.createMono(it -> intercept(context, asyncStub)
.getBulkState(envelope, it)
)
).map(
@@ -780,7 +786,7 @@ public Mono>> getBulkState(GetBulkStateRequest request, TypeRe
}
private State buildStateKeyValue(
- DaprProtos.BulkStateItem item,
+ DaprStateProtos.BulkStateItem item,
TypeRef type) throws IOException {
String key = item.getKey();
String error = item.getError();
@@ -804,7 +810,7 @@ private State buildStateKeyValue(
}
private State buildStateKeyValue(
- DaprProtos.GetStateResponse response,
+ DaprStateProtos.GetStateResponse response,
String requestedKey,
StateOptions stateOptions,
TypeRef type) throws IOException {
@@ -834,20 +840,20 @@ public Mono executeStateTransaction(ExecuteStateTransactionRequest request
if ((stateStoreName == null) || (stateStoreName.trim().isEmpty())) {
throw new IllegalArgumentException("State store name cannot be null or empty.");
}
- DaprProtos.ExecuteStateTransactionRequest.Builder builder = DaprProtos.ExecuteStateTransactionRequest
+ DaprStateProtos.ExecuteStateTransactionRequest.Builder builder = DaprStateProtos.ExecuteStateTransactionRequest
.newBuilder();
builder.setStoreName(stateStoreName);
if (metadata != null) {
builder.putAllMetadata(metadata);
}
for (TransactionalStateOperation> operation : operations) {
- DaprProtos.TransactionalStateOperation.Builder operationBuilder = DaprProtos.TransactionalStateOperation
- .newBuilder();
+ DaprStateProtos.TransactionalStateOperation.Builder operationBuilder =
+ DaprStateProtos.TransactionalStateOperation.newBuilder();
operationBuilder.setOperationType(operation.getOperation().toString().toLowerCase());
operationBuilder.setRequest(buildStateRequest(operation.getRequest()).build());
builder.addOperations(operationBuilder.build());
}
- DaprProtos.ExecuteStateTransactionRequest req = builder.build();
+ DaprStateProtos.ExecuteStateTransactionRequest req = builder.build();
return Mono.deferContextual(
context -> this.createMono(it -> intercept(context, asyncStub).executeStateTransaction(req, it))
@@ -868,12 +874,12 @@ public Mono saveBulkState(SaveStateRequest request) {
if ((stateStoreName == null) || (stateStoreName.trim().isEmpty())) {
throw new IllegalArgumentException("State store name cannot be null or empty.");
}
- DaprProtos.SaveStateRequest.Builder builder = DaprProtos.SaveStateRequest.newBuilder();
+ DaprStateProtos.SaveStateRequest.Builder builder = DaprStateProtos.SaveStateRequest.newBuilder();
builder.setStoreName(stateStoreName);
for (State> state : states) {
builder.addStates(buildStateRequest(state).build());
}
- DaprProtos.SaveStateRequest req = builder.build();
+ DaprStateProtos.SaveStateRequest req = builder.build();
return Mono.deferContextual(
context -> this.createMono(it -> intercept(context, asyncStub).saveState(req, it))
@@ -943,7 +949,7 @@ public Mono deleteState(DeleteStateRequest request) {
optionBuilder.setConsistency(getGrpcStateConsistency(options));
}
}
- DaprProtos.DeleteStateRequest.Builder builder = DaprProtos.DeleteStateRequest.newBuilder()
+ DaprStateProtos.DeleteStateRequest.Builder builder = DaprStateProtos.DeleteStateRequest.newBuilder()
.setStoreName(stateStoreName)
.setKey(key);
if (metadata != null) {
@@ -957,7 +963,7 @@ public Mono deleteState(DeleteStateRequest request) {
builder.setOptions(optionBuilder.build());
}
- DaprProtos.DeleteStateRequest req = builder.build();
+ DaprStateProtos.DeleteStateRequest req = builder.build();
return Mono.deferContextual(
context -> this.createMono(it -> intercept(context, asyncStub).deleteState(req, it))
@@ -986,18 +992,20 @@ public Mono