fix: adapt to durabletask-protobuf proto file split (#1702)

The dapr/durabletask-protobuf#32 PR refactored protos by concept,
splitting orchestrator_service.proto into orchestration.proto,
history_events.proto, and orchestrator_actions.proto. This broke
the build because only the single file was being downloaded.

- Download all 4 proto files in durabletask-client/pom.xml
- Replace single-file URL property with base URL in parent pom
- Update Java type references from OrchestratorService.* to the
  correct new outer classes: Orchestration, HistoryEvents,
  OrchestratorActions

Signed-off-by: Javier Aliaga <javier@diagrid.io>

Author: javier-aliaga

durabletask-client/pom.xml

@@ -110,18 +110,57 @@
         <version>${download-maven-plugin.version}</version>
         <executions>
           <execution>
-            <id>getDaprProto</id>
+            <id>getOrchestratorServiceProto</id>
             <phase>initialize</phase>
             <goals>
               <goal>wget</goal>
             </goals>
             <configuration>
               <skipCache>true</skipCache>
-              <url>${durabletask.proto.url}</url>
+              <url>${durabletask.proto.baseurl}/orchestrator_service.proto</url>
               <outputFileName>orchestrator_service.proto</outputFileName>
               <outputDirectory>${protobuf.input.directory}</outputDirectory>
             </configuration>
           </execution>
+          <execution>
+            <id>getOrchestrationProto</id>
+            <phase>initialize</phase>
+            <goals>
+              <goal>wget</goal>
+            </goals>
+            <configuration>
+              <skipCache>true</skipCache>
+              <url>${durabletask.proto.baseurl}/orchestration.proto</url>
+              <outputFileName>orchestration.proto</outputFileName>
+              <outputDirectory>${protobuf.input.directory}</outputDirectory>
+            </configuration>
+          </execution>
+          <execution>
+            <id>getHistoryEventsProto</id>
+            <phase>initialize</phase>
+            <goals>
+              <goal>wget</goal>
+            </goals>
+            <configuration>
+              <skipCache>true</skipCache>
+              <url>${durabletask.proto.baseurl}/history_events.proto</url>
+              <outputFileName>history_events.proto</outputFileName>
+              <outputDirectory>${protobuf.input.directory}</outputDirectory>
+            </configuration>
+          </execution>
+          <execution>
+            <id>getOrchestratorActionsProto</id>
+            <phase>initialize</phase>
+            <goals>
+              <goal>wget</goal>
+            </goals>
+            <configuration>
+              <skipCache>true</skipCache>
+              <url>${durabletask.proto.baseurl}/orchestrator_actions.proto</url>
+              <outputFileName>orchestrator_actions.proto</outputFileName>
+              <outputDirectory>${protobuf.input.directory}</outputDirectory>
+            </configuration>
+          </execution>
         </executions>
       </plugin>
       <plugin>

durabletask-client/src/main/java/io/dapr/durabletask/DurableTaskGrpcWorker.java

@@ -13,6 +13,7 @@
 
 package io.dapr.durabletask;
 
+import io.dapr.durabletask.implementation.protobuf.Orchestration;
 import io.dapr.durabletask.implementation.protobuf.OrchestratorService;
 import io.dapr.durabletask.implementation.protobuf.TaskHubSidecarServiceGrpc;
 import io.dapr.durabletask.orchestration.TaskOrchestrationFactories;
@@ -279,7 +280,7 @@ private Context extractTraceContext(OrchestratorService.ActivityRequest activity
       return Context.current();
     }
 
-    OrchestratorService.TraceContext traceContext = activityRequest.getParentTraceContext();
+    Orchestration.TraceContext traceContext = activityRequest.getParentTraceContext();
     String traceParent = traceContext.getTraceParent();
 
     if (traceParent.isEmpty()) {

durabletask-client/src/main/java/io/dapr/durabletask/FailureDetails.java

@@ -14,7 +14,7 @@
 package io.dapr.durabletask;
 
 import com.google.protobuf.StringValue;
-import io.dapr.durabletask.implementation.protobuf.OrchestratorService.TaskFailureDetails;
+import io.dapr.durabletask.implementation.protobuf.Orchestration.TaskFailureDetails;
 
 import javax.annotation.Nonnull;
 import javax.annotation.Nullable;

durabletask-client/src/main/java/io/dapr/durabletask/OrchestrationMetadata.java

@@ -13,8 +13,8 @@
 
 package io.dapr.durabletask;
 
+import io.dapr.durabletask.implementation.protobuf.Orchestration.OrchestrationState;
 import io.dapr.durabletask.implementation.protobuf.OrchestratorService;
-import io.dapr.durabletask.implementation.protobuf.OrchestratorService.OrchestrationState;
 
 import java.time.Instant;
 

durabletask-client/src/main/java/io/dapr/durabletask/OrchestrationRuntimeStatus.java

@@ -13,16 +13,16 @@
 
 package io.dapr.durabletask;
 
-import io.dapr.durabletask.implementation.protobuf.OrchestratorService;
+import io.dapr.durabletask.implementation.protobuf.Orchestration;
 
-import static io.dapr.durabletask.implementation.protobuf.OrchestratorService.OrchestrationStatus.ORCHESTRATION_STATUS_CANCELED;
-import static io.dapr.durabletask.implementation.protobuf.OrchestratorService.OrchestrationStatus.ORCHESTRATION_STATUS_COMPLETED;
-import static io.dapr.durabletask.implementation.protobuf.OrchestratorService.OrchestrationStatus.ORCHESTRATION_STATUS_CONTINUED_AS_NEW;
-import static io.dapr.durabletask.implementation.protobuf.OrchestratorService.OrchestrationStatus.ORCHESTRATION_STATUS_FAILED;
-import static io.dapr.durabletask.implementation.protobuf.OrchestratorService.OrchestrationStatus.ORCHESTRATION_STATUS_PENDING;
-import static io.dapr.durabletask.implementation.protobuf.OrchestratorService.OrchestrationStatus.ORCHESTRATION_STATUS_RUNNING;
-import static io.dapr.durabletask.implementation.protobuf.OrchestratorService.OrchestrationStatus.ORCHESTRATION_STATUS_SUSPENDED;
-import static io.dapr.durabletask.implementation.protobuf.OrchestratorService.OrchestrationStatus.ORCHESTRATION_STATUS_TERMINATED;
+import static io.dapr.durabletask.implementation.protobuf.Orchestration.OrchestrationStatus.ORCHESTRATION_STATUS_CANCELED;
+import static io.dapr.durabletask.implementation.protobuf.Orchestration.OrchestrationStatus.ORCHESTRATION_STATUS_COMPLETED;
+import static io.dapr.durabletask.implementation.protobuf.Orchestration.OrchestrationStatus.ORCHESTRATION_STATUS_CONTINUED_AS_NEW;
+import static io.dapr.durabletask.implementation.protobuf.Orchestration.OrchestrationStatus.ORCHESTRATION_STATUS_FAILED;
+import static io.dapr.durabletask.implementation.protobuf.Orchestration.OrchestrationStatus.ORCHESTRATION_STATUS_PENDING;
+import static io.dapr.durabletask.implementation.protobuf.Orchestration.OrchestrationStatus.ORCHESTRATION_STATUS_RUNNING;
+import static io.dapr.durabletask.implementation.protobuf.Orchestration.OrchestrationStatus.ORCHESTRATION_STATUS_SUSPENDED;
+import static io.dapr.durabletask.implementation.protobuf.Orchestration.OrchestrationStatus.ORCHESTRATION_STATUS_TERMINATED;
 
 /**
  * Enum describing the runtime status of the orchestration.
@@ -75,7 +75,7 @@ public enum OrchestrationRuntimeStatus {
    */
   STALLED;
 
-  static OrchestrationRuntimeStatus fromProtobuf(OrchestratorService.OrchestrationStatus status) {
+  static OrchestrationRuntimeStatus fromProtobuf(Orchestration.OrchestrationStatus status) {
     switch (status) {
       case ORCHESTRATION_STATUS_RUNNING:
         return RUNNING;
@@ -100,7 +100,7 @@ static OrchestrationRuntimeStatus fromProtobuf(OrchestratorService.Orchestration
     }
   }
 
-  static OrchestratorService.OrchestrationStatus toProtobuf(OrchestrationRuntimeStatus status) {
+  static Orchestration.OrchestrationStatus toProtobuf(OrchestrationRuntimeStatus status) {
     switch (status) {
       case RUNNING:
         return ORCHESTRATION_STATUS_RUNNING;