StateMachine rewrite

build.gradle

@@ -120,7 +120,7 @@ configurations.all {
 
 license {
     header rootProject.file('license-header.txt')
-    exclude 'io/temporal/proto/**.java' // generated code
+    exclude '**/*.puml'
 }
 
 task initSubmodules(type: Exec) {
@@ -170,8 +170,8 @@ protobuf {
 
 idea {
     module {
-        sourceDirs += file("$buildDir/generated/main/java");
-        sourceDirs += file("$buildDir/generated/main/grpc");
+        sourceDirs += file("$buildDir/generated/main/java")
+        sourceDirs += file("$buildDir/generated/main/grpc")
     }
 }
 
@@ -327,15 +327,15 @@ allprojects {
     // add a testlistener to all tasks of type Test
     tasks.withType(Test) {
         afterTest { TestDescriptor descriptor, TestResult result ->
-            if(result.resultType == org.gradle.api.tasks.testing.TestResult.ResultType.FAILURE){
+            if (result.resultType == org.gradle.api.tasks.testing.TestResult.ResultType.FAILURE) {
                 failedTests << ["${descriptor.className}::${descriptor.name}"]
             }
         }
     }
 
     // print out tracked failed tests when the build has finished
     gradle.buildFinished {
-        if(!failedTests.empty){
+        if (!failedTests.empty) {
             println "Failed tests for ${project.name}:"
             failedTests.each { failedTest ->
                 println failedTest

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

@@ -24,7 +24,7 @@
 
 /**
  * Defines behaviour of the parent workflow when {@link CancellationScope} that wraps child workflow
- * execution request is cancelled. The result of the cancellation independently of the type is a
+ * execution request is canceled. The result of the cancellation independently of the type is a
  * {@link CanceledFailure} thrown from the child workflow method.
  */
 public enum ActivityCancellationType {

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

@@ -185,7 +185,7 @@ public ActivityOptions validateAndBuildWithDefaults() {
           taskQueue,
           retryOptions,
           contextPropagators,
-          cancellationType);
+          cancellationType == null ? ActivityCancellationType.TRY_CANCEL : cancellationType);
     }
   }
 

src/main/java/io/temporal/client/ActivityCancelledException.java → src/main/java/io/temporal/client/ActivityCanceledException.java

@@ -25,13 +25,13 @@
  * Usually indicates that activity was already completed (duplicated request to complete) or timed
  * out or workflow is closed.
  */
-public final class ActivityCancelledException extends ActivityCompletionException {
+public final class ActivityCanceledException extends ActivityCompletionException {
 
-  public ActivityCancelledException(ActivityInfo info) {
+  public ActivityCanceledException(ActivityInfo info) {
     super(info);
   }
 
-  public ActivityCancelledException() {
+  public ActivityCanceledException() {
     super();
   }
 }

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

@@ -132,7 +132,7 @@ public Builder setWorkflowId(String workflowId) {
      *
      *     <ul>
      *       AllowDuplicateFailedOnly is a default value. It means that workflow can start if
-     *       previous run failed or was cancelled or terminated.
+     *       previous run failed or was canceled or terminated.
      * </ul>
      *
      * <ul>
@@ -263,15 +263,15 @@ public WorkflowOptions validateBuildWithDefaults() {
 
   private final String taskQueue;
 
-  private RetryOptions retryOptions;
+  private final RetryOptions retryOptions;
 
-  private String cronSchedule;
+  private final String cronSchedule;
 
-  private Map<String, Object> memo;
+  private final Map<String, Object> memo;
 
-  private Map<String, Object> searchAttributes;
+  private final Map<String, Object> searchAttributes;
 
-  private List<ContextPropagator> contextPropagators;
+  private final List<ContextPropagator> contextPropagators;
 
   private WorkflowOptions(
       String workflowId,

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

@@ -143,7 +143,7 @@ <R> CompletableFuture<R> getResultAsync(
    * Request cancellation of a workflow execution.
    *
    * <p>Cancellation cancels {@link io.temporal.workflow.CancellationScope} that wraps the main
-   * workflow method. Note that workflow can take long time to get cancelled or even completely
+   * workflow method. Note that workflow can take long time to get canceled or even completely
    * ignore the cancellation request.
    */
   void cancel();

src/main/java/io/temporal/common/CronSchedule.java

@@ -31,7 +31,7 @@
  * supplied, and the workflow failed or timeout, the workflow will be retried based on the retry
  * policy. While the workflow is retrying, it won't schedule its next run. If next schedule is due
  * while workflow is running (or retrying), then it will skip that schedule. Cron workflow will not
- * stop until it is terminated or cancelled.
+ * stop until it is terminated or canceled.
  */
 @Retention(RetentionPolicy.RUNTIME)
 @Target(ElementType.METHOD)

src/main/java/io/temporal/common/converter/EncodedValues.java

@@ -27,7 +27,7 @@
 public final class EncodedValues implements Values {
   private Optional<Payloads> payloads;
   private DataConverter converter;
-  private Object[] values;
+  private final Object[] values;
 
   public EncodedValues(Optional<Payloads> payloads, DataConverter converter) {
     this.payloads = Objects.requireNonNull(payloads);

src/main/java/io/temporal/common/interceptors/WorkflowOutboundCallsInterceptor.java

@@ -129,4 +129,6 @@ void registerSignal(
   void upsertSearchAttributes(Map<String, Object> searchAttributes);
 
   Object newThread(Runnable runnable, boolean detached, String name);
+
+  long currentTimeMillis();
 }

src/main/java/io/temporal/common/interceptors/WorkflowOutboundCallsInterceptorBase.java

@@ -166,4 +166,9 @@ public void upsertSearchAttributes(Map<String, Object> searchAttributes) {
   public Object newThread(Runnable runnable, boolean detached, String name) {
     return next.newThread(runnable, detached, name);
   }
+
+  @Override
+  public long currentTimeMillis() {
+    return next.currentTimeMillis();
+  }
 }

src/main/java/io/temporal/failure/ApplicationFailure.java

@@ -120,7 +120,7 @@ public void setDataConverter(DataConverter converter) {
   }
 
   private static String getMessage(String message, String type, boolean nonRetryable) {
-    return (Strings.isNullOrEmpty(message) ? "" : "message='" + message + "\', ")
+    return (Strings.isNullOrEmpty(message) ? "" : "message='" + message + "', ")
         + "type='"
         + type
         + '\''

src/main/java/io/temporal/failure/CanceledFailure.java

@@ -22,13 +22,14 @@
 import io.temporal.common.converter.DataConverter;
 import io.temporal.common.converter.EncodedValues;
 import io.temporal.common.converter.Values;
+import java.util.Objects;
 
 public final class CanceledFailure extends TemporalFailure {
   private final Values details;
 
   public CanceledFailure(String message, Values details, Throwable cause) {
     super(message, message, cause);
-    this.details = details;
+    this.details = Objects.requireNonNull(details);
   }
 
   public CanceledFailure(String message, Object details) {

src/main/java/io/temporal/failure/FailureConverter.java

@@ -33,7 +33,7 @@
 import io.temporal.api.failure.v1.ServerFailureInfo;
 import io.temporal.api.failure.v1.TerminatedFailureInfo;
 import io.temporal.api.failure.v1.TimeoutFailureInfo;
-import io.temporal.client.ActivityCancelledException;
+import io.temporal.client.ActivityCanceledException;
 import io.temporal.common.converter.DataConverter;
 import io.temporal.common.converter.EncodedValues;
 import io.temporal.internal.common.CheckedExceptionWrapper;
@@ -66,11 +66,11 @@ public class FailureConverter {
 
   private static final Pattern TRACE_ELEMENT_PATTERN = Pattern.compile(TRACE_ELEMENT_REGEXP);
 
-  public static Exception failureToException(Failure failure, DataConverter dataConverter) {
+  public static RuntimeException failureToException(Failure failure, DataConverter dataConverter) {
     if (failure == null) {
       return null;
     }
-    Exception result = failureToExceptionImpl(failure, dataConverter);
+    RuntimeException result = failureToExceptionImpl(failure, dataConverter);
     if (result instanceof TemporalFailure) {
       ((TemporalFailure) result).setFailure(failure);
     }
@@ -81,8 +81,9 @@ public static Exception failureToException(Failure failure, DataConverter dataCo
     return result;
   }
 
-  private static Exception failureToExceptionImpl(Failure failure, DataConverter dataConverter) {
-    Exception cause =
+  private static RuntimeException failureToExceptionImpl(
+      Failure failure, DataConverter dataConverter) {
+    RuntimeException cause =
         failure.hasCause() ? failureToException(failure.getCause(), dataConverter) : null;
     switch (failure.getFailureInfoCase()) {
       case APPLICATION_FAILURE_INFO:
@@ -257,7 +258,7 @@ public static Failure exceptionToFailureNoUnwrapping(Throwable e) {
               .setWorkflowType(WorkflowType.newBuilder().setName(ce.getWorkflowType()))
               .setWorkflowExecution(ce.getExecution());
       failure.setChildWorkflowExecutionFailureInfo(info);
-    } else if (e instanceof ActivityCancelledException) {
+    } else if (e instanceof ActivityCanceledException) {
       CanceledFailureInfo.Builder info = CanceledFailureInfo.newBuilder();
       failure.setCanceledFailureInfo(info);
     } else {