Updated to the latest protos and added Proto converter (#148)

Author: mfateev

build.gradle

@@ -16,7 +16,7 @@ plugins {
     id 'maven-publish'
     id 'signing'
     id 'de.marcphilipp.nexus-publish' version '0.4.0'
-    id 'name.remal.check-updates' version '1.0.200'
+    id 'name.remal.check-updates' version '1.0.203'
 }
 
 repositories {
@@ -102,7 +102,7 @@ dependencies {
     api 'io.grpc:grpc-stub:1.30.2'
 
     implementation group: 'com.google.guava', name: 'guava', version: '29.0-jre'
-    implementation group: 'com.cronutils', name: 'cron-utils', version: '9.0.2'
+    implementation group: 'com.cronutils', name: 'cron-utils', version: '9.1.0'
     implementation 'io.grpc:grpc-netty-shaded:1.30.2'
     implementation group: 'com.google.protobuf', name: 'protobuf-java-util', version: '3.12.2'
     implementation group: 'com.fasterxml.jackson.core', name: 'jackson-databind', version: '2.11.1'

src/main/java/io/temporal/activity/ActivityInfo.java

@@ -19,7 +19,7 @@
 
 package io.temporal.activity;
 
-import io.temporal.common.v1.Payloads;
+import io.temporal.api.common.v1.Payloads;
 import java.time.Duration;
 import java.util.Optional;
 

src/main/java/io/temporal/client/WorkflowClient.java

@@ -21,7 +21,7 @@
 
 import io.temporal.activity.Activity;
 import io.temporal.activity.ActivityExecutionContext;
-import io.temporal.common.v1.WorkflowExecution;
+import io.temporal.api.common.v1.WorkflowExecution;
 import io.temporal.internal.sync.WorkflowClientInternal;
 import io.temporal.serviceclient.WorkflowServiceStubs;
 import io.temporal.workflow.Functions;

src/main/java/io/temporal/client/WorkflowClientOptions.java

@@ -19,10 +19,10 @@
 
 package io.temporal.client;
 
+import io.temporal.api.enums.v1.QueryRejectCondition;
 import io.temporal.common.context.ContextPropagator;
 import io.temporal.common.converter.DataConverter;
 import io.temporal.common.interceptors.WorkflowClientInterceptor;
-import io.temporal.enums.v1.QueryRejectCondition;
 import java.lang.management.ManagementFactory;
 import java.util.Arrays;
 import java.util.List;

src/main/java/io/temporal/client/WorkflowException.java

@@ -19,7 +19,7 @@
 
 package io.temporal.client;
 
-import io.temporal.common.v1.WorkflowExecution;
+import io.temporal.api.common.v1.WorkflowExecution;
 import io.temporal.failure.TemporalException;
 import java.util.Objects;
 import java.util.Optional;

src/main/java/io/temporal/client/WorkflowExecutionAlreadyStarted.java

@@ -19,7 +19,7 @@
 
 package io.temporal.client;
 
-import io.temporal.common.v1.WorkflowExecution;
+import io.temporal.api.common.v1.WorkflowExecution;
 
 /**
  * This exception is thrown in the following cases:
@@ -32,21 +32,21 @@
  * <ul>
  *   There is a closed workflow with the same ID and the {@link
  *   WorkflowOptions#getWorkflowIdReusePolicy()} is {@link
- *   io.temporal.enums.v1.WorkflowIdReusePolicy#WORKFLOW_ID_REUSE_POLICY_REJECT_DUPLICATE}.
+ *   io.temporal.api.enums.v1.WorkflowIdReusePolicy#WORKFLOW_ID_REUSE_POLICY_REJECT_DUPLICATE}.
  * </ul>
  *
  * <ul>
  *   There is successfully closed workflow with the same ID and the {@link
  *   WorkflowOptions#getWorkflowIdReusePolicy()} is {@link
- *   io.temporal.enums.v1.WorkflowIdReusePolicy#WORKFLOW_ID_REUSE_POLICY_ALLOW_DUPLICATE_FAILED_ONLY}.
+ *   io.temporal.api.enums.v1.WorkflowIdReusePolicy#WORKFLOW_ID_REUSE_POLICY_ALLOW_DUPLICATE_FAILED_ONLY}.
  * </ul>
  *
  * <ul>
  *   Method annotated with {@link io.temporal.workflow.WorkflowMethod} is called <i>more than
  *   once</i> on a stub created through {@link
  *   io.temporal.workflow.Workflow#newChildWorkflowStub(Class)} and the {@link
  *   WorkflowOptions#getWorkflowIdReusePolicy()} is {@link
- *   io.temporal.enums.v1.WorkflowIdReusePolicy#WORKFLOW_ID_REUSE_POLICY_ALLOW_DUPLICATE}
+ *   io.temporal.api.enums.v1.WorkflowIdReusePolicy#WORKFLOW_ID_REUSE_POLICY_ALLOW_DUPLICATE}
  * </ul>
  */
 public final class WorkflowExecutionAlreadyStarted extends WorkflowException {

src/main/java/io/temporal/client/WorkflowFailedException.java

@@ -19,35 +19,35 @@
 
 package io.temporal.client;
 
-import io.temporal.common.v1.WorkflowExecution;
-import io.temporal.enums.v1.RetryStatus;
+import io.temporal.api.common.v1.WorkflowExecution;
+import io.temporal.api.enums.v1.RetryState;
 
 /**
  * Indicates that a workflow failed. An original cause of the workflow failure can be retrieved
  * through {@link #getCause()}.
  */
 public final class WorkflowFailedException extends WorkflowException {
 
-  private final RetryStatus retryStatus;
+  private final RetryState retryState;
   private final long decisionTaskCompletedEventId;
 
   public WorkflowFailedException(
       WorkflowExecution workflowExecution,
       String workflowType,
       long decisionTaskCompletedEventId,
-      RetryStatus retryStatus,
+      RetryState retryState,
       Throwable cause) {
     super(
-        getMessage(workflowExecution, workflowType, decisionTaskCompletedEventId, retryStatus),
+        getMessage(workflowExecution, workflowType, decisionTaskCompletedEventId, retryState),
         workflowExecution,
         workflowType,
         cause);
-    this.retryStatus = retryStatus;
+    this.retryState = retryState;
     this.decisionTaskCompletedEventId = decisionTaskCompletedEventId;
   }
 
-  public RetryStatus getRetryStatus() {
-    return retryStatus;
+  public RetryState getRetryState() {
+    return retryState;
   }
 
   public long getDecisionTaskCompletedEventId() {
@@ -58,14 +58,14 @@ public static String getMessage(
       WorkflowExecution workflowExecution,
       String workflowType,
       long decisionTaskCompletedEventId,
-      RetryStatus retryStatus) {
+      RetryState retryState) {
     return "workflowId='"
         + workflowExecution.getWorkflowId()
         + "', runId='"
         + workflowExecution.getRunId()
         + (workflowType == null ? "'" : "', workflowType='" + workflowType + '\'')
-        + ", retryStatus="
-        + retryStatus
+        + ", retryState="
+        + retryState
         + ", decisionTaskCompletedEventId="
         + decisionTaskCompletedEventId;
   }

src/main/java/io/temporal/client/WorkflowNotFoundException.java

@@ -19,7 +19,7 @@
 
 package io.temporal.client;
 
-import io.temporal.common.v1.WorkflowExecution;
+import io.temporal.api.common.v1.WorkflowExecution;
 
 /**
  * Thrown when workflow with the given id is not known to the Temporal service. It could be because

src/main/java/io/temporal/client/WorkflowOptions.java

@@ -20,11 +20,11 @@
 package io.temporal.client;
 
 import com.google.common.base.Objects;
+import io.temporal.api.enums.v1.WorkflowIdReusePolicy;
 import io.temporal.common.CronSchedule;
 import io.temporal.common.MethodRetry;
 import io.temporal.common.RetryOptions;
 import io.temporal.common.context.ContextPropagator;
-import io.temporal.enums.v1.WorkflowIdReusePolicy;
 import io.temporal.internal.common.OptionsUtils;
 import java.time.Duration;
 import java.util.List;

src/main/java/io/temporal/client/WorkflowQueryException.java

@@ -19,7 +19,7 @@
 
 package io.temporal.client;
 
-import io.temporal.common.v1.WorkflowExecution;
+import io.temporal.api.common.v1.WorkflowExecution;
 
 public class WorkflowQueryException extends WorkflowException {