Support Proto 3 and 4 (#2383)

Support Proto 3 and 4

Author: Quinn-With-Two-Ns

README.md

@@ -38,6 +38,12 @@ or to *build.gradle*:
 
     compile group: 'io.temporal', name: 'temporal-sdk', version: 'N.N.N'
 
+## Protobuf 3.x vs 4.x
+
+The Temporal Java SDK currently supports `protobuf-java` 3.x and 4.x. To support these, the Temporal Java SDK allows any protobuf library >= 3.25.
+Temporal strongly recommends using the latest `protobuf-java` 4.x library unless you absolutely cannot. 
+If you cannot use protobuf-java 3.25 >=, you can try `temporal-shaded` which includes a shaded version of the `protobuf-java` library.
+
 ## Contributing
 
 We'd love your help in improving the Temporal Java SDK. Please review our [contribution guidelines](CONTRIBUTING.md).

build.gradle

@@ -5,7 +5,7 @@ buildscript {
 }
 
 plugins {
-    id 'net.ltgt.errorprone' version '4.0.1' apply false
+    id 'net.ltgt.errorprone' version '4.1.0' apply false
     id 'org.cadixdev.licenser' version '0.6.1'
     id 'com.palantir.git-version' version "${palantirGitVersionVersion}" apply false
     id 'io.github.gradle-nexus.publish-plugin' version '1.3.0'
@@ -29,7 +29,7 @@ allprojects {
 
 ext {
     // Platforms
-    grpcVersion = '1.54.1' // [1.38.0,) Needed for io.grpc.protobuf.services.HealthStatusManager
+    grpcVersion = '1.58.1' // [1.38.0,) Needed for io.grpc.protobuf.services.HealthStatusManager
     jacksonVersion = '2.14.2' // [2.9.0,)
     nexusVersion = '0.3.0-alpha'
     // we don't upgrade to 1.10.x because it requires kotlin 1.6. Users may use 1.10.x in their environments though.
@@ -38,12 +38,13 @@ ext {
     // stay on 1.x for a while to don't use any APIs from 2.x which may break our users which still stay on 1.x
     // also slf4j 2.x is not compatible with spring boot 2.x
     slf4jVersion = project.hasProperty("edgeDepsTest") ? '2.0.16' : '1.7.36' // [1.4.0,)
-    // [3.12.0,)
-    // 3.12 is brought by min gRPC 1.38.
-    // We can't move pass 3.22.0 because 3.22.2 deprecates some methods used by generated code produced by
-    // the old protoc we keep for compatibility of our generated code with old protobuf-java versions.
-    // Which leads to build failure because of -Werror.
-    protoVersion = '3.22.0'
+    // [3.25.5,)
+    // 3.25.5 is required because of our protoc compiler 25.x. The proto version must be the same or greater then the protoc version.
+    // We use this version of protoc because it will generate code that is compatible with protobuf-java 3.x and 4.x.
+    // We don't move past 3.25.x because the next version is a major version bump and we don't want to break our users.
+    //
+    // For more information see: https://github.com/grpc/grpc-java/issues/11015#issuecomment-2560196695
+    protoVersion = '3.25.5'
     annotationApiVersion = '1.3.2'
     guavaVersion = '32.0.1-jre' // [10.0,)
     tallyVersion = '0.13.0' // [0.4.0,)

temporal-sdk/build.gradle

@@ -29,6 +29,10 @@ dependencies {
     testImplementation "org.mockito:mockito-core:${mockitoVersion}"
     testImplementation 'pl.pragmatists:JUnitParams:1.1.1'
     testImplementation group: 'ch.qos.logback', name: 'logback-classic', version: "${logbackVersion}"
+    if (project.hasProperty("edgeDepsTest")) {
+        testRuntimeOnly "com.google.protobuf:protobuf-java:4.29.3"
+        testRuntimeOnly "com.google.protobuf:protobuf-java-util:4.29.3"
+    }
 }
 
 // Temporal SDK supports Java 8 or later so to support virtual threads

temporal-sdk/src/main/java/io/temporal/client/WorkflowStubImpl.java

@@ -499,7 +499,7 @@ public WorkflowStub newInstance(WorkflowOptions options) {
   }
 
   private void checkStarted() {
-    if (execution.get() == null || execution.get().getWorkflowId() == null) {
+    if (execution.get() == null) {
       throw new IllegalStateException("Null workflowId. Was workflow started?");
     }
   }

temporal-sdk/src/main/java/io/temporal/internal/client/ScheduleProtoUtil.java

@@ -341,8 +341,7 @@ public io.temporal.client.schedules.ScheduleSpec protoToScheduleSpec(
     Objects.requireNonNull(scheduleSpec);
     io.temporal.client.schedules.ScheduleSpec.Builder specBuilder =
         io.temporal.client.schedules.ScheduleSpec.newBuilder()
-            .setTimeZoneName(
-                scheduleSpec.getTimezoneName() == null ? "" : scheduleSpec.getTimezoneName());
+            .setTimeZoneName(scheduleSpec.getTimezoneName());
 
     if (scheduleSpec.hasJitter()) {
       specBuilder.setJitter(ProtobufTimeUtils.toJavaDuration(scheduleSpec.getJitter()));
@@ -450,7 +449,7 @@ public io.temporal.client.schedules.ScheduleAction protoToAction(@Nonnull Schedu
       wfOptionsBuilder.setWorkflowTaskTimeout(
           ProtobufTimeUtils.toJavaDuration(startWfAction.getWorkflowTaskTimeout()));
 
-      if (startWfAction.getRetryPolicy() != null) {
+      if (startWfAction.hasRetryPolicy()) {
         wfOptionsBuilder.setRetryOptions(
             RetryOptionsUtils.toRetryOptions(startWfAction.getRetryPolicy()));
       }

temporal-sdk/src/main/java/io/temporal/internal/common/WorkflowExecutionHistory.java

@@ -71,7 +71,7 @@ public static WorkflowExecutionHistory fromJson(String serialized) {
 
   private static void checkHistory(History history) {
     List<HistoryEvent> events = history.getEventsList();
-    if (events == null || events.size() == 0) {
+    if (events.size() == 0) {
       throw new IllegalArgumentException("Empty history");
     }
     HistoryEvent startedEvent = events.get(0);

temporal-sdk/src/main/java/io/temporal/internal/common/WorkflowExecutionUtils.java

@@ -265,9 +265,8 @@ public static String prettyPrintCommands(Iterable<Command> commands) {
   }
 
   /** Pretty prints a proto message. */
-  @SuppressWarnings("deprecation")
   public static String prettyPrintObject(MessageOrBuilder object) {
-    return TextFormat.printToString(object);
+    return TextFormat.printer().printToString(object);
   }
 
   public static boolean containsEvent(List<HistoryEvent> history, EventType eventType) {

temporal-sdk/src/main/java/io/temporal/internal/replay/ReplayWorkflowExecutor.java

@@ -217,7 +217,7 @@ public void handleWorkflowExecutionUpdated(UpdateMessage updateMessage) {
       Message protocolMessage = updateMessage.getMessage();
       Request update = protocolMessage.getBody().unpack(Request.class);
       Input input = update.getInput();
-      Optional<Payloads> args = Optional.ofNullable(input.getArgs());
+      Optional<Payloads> args = Optional.of(input.getArgs());
       this.workflow.handleUpdate(
           input.getName(),
           update.getMeta().getUpdateId(),

temporal-sdk/src/main/java/io/temporal/internal/sync/SyncWorkflowContext.java

@@ -385,8 +385,7 @@ public WorkflowMetadata getWorkflowMetadata() {
     WorkflowMetadata.Builder workflowMetadata = WorkflowMetadata.newBuilder();
     WorkflowDefinition.Builder workflowDefinition = WorkflowDefinition.newBuilder();
     // Set the workflow type
-    if (replayContext.getWorkflowType() != null
-        && replayContext.getWorkflowType().getName() != null) {
+    if (replayContext.getWorkflowType() != null) {
       workflowDefinition.setType(replayContext.getWorkflowType().getName());
     }
     // Set built in queries

temporal-sdk/src/test/java/io/temporal/internal/statemachines/TestHistoryBuilder.java

@@ -434,8 +434,8 @@ private HistoryEvent newAttributes(EventType type, Object attributes) {
     } else if (attributes instanceof Number) {
       attributes = newAttributes(type, ((Number) attributes).intValue());
     }
-    if (attributes instanceof com.google.protobuf.GeneratedMessageV3.Builder) {
-      attributes = ((com.google.protobuf.GeneratedMessageV3.Builder) attributes).build();
+    if (attributes instanceof com.google.protobuf.Message.Builder) {
+      attributes = ((com.google.protobuf.Message.Builder) attributes).build();
     }
     HistoryEvent.Builder result =
         HistoryEvent.newBuilder()