Add memo and search attributes to child workflow (#641)

Author: spmistry

src/main/java/com/uber/cadence/internal/common/InternalUtils.java

@@ -23,6 +23,7 @@
 import com.uber.cadence.History;
 import com.uber.cadence.HistoryEvent;
 import com.uber.cadence.HistoryEventFilterType;
+import com.uber.cadence.Memo;
 import com.uber.cadence.SearchAttributes;
 import com.uber.cadence.TaskList;
 import com.uber.cadence.TaskListKind;
@@ -142,6 +143,16 @@ public static Object getValueOrDefault(Object value, Class<?> valueClass) {
     return Defaults.defaultValue(valueClass);
   }
 
+  public static Memo convertMapToMemo(Map<String, Object> memo) {
+    DataConverter converter = JsonDataConverter.getInstance();
+    Map<String, ByteBuffer> mapOfByteBuffer = new HashMap<>();
+    memo.forEach(
+        (key, value) -> {
+          mapOfByteBuffer.put(key, ByteBuffer.wrap(converter.toData(value)));
+        });
+    return new Memo().setFields(mapOfByteBuffer);
+  }
+
   public static SearchAttributes convertMapToSearchAttributes(
       Map<String, Object> searchAttributes) {
     DataConverter converter = JsonDataConverter.getInstance();

src/main/java/com/uber/cadence/internal/replay/StartChildWorkflowExecutionParameters.java

@@ -51,6 +51,10 @@ public static final class Builder {
 
     private String cronSchedule;
 
+    private Map<String, Object> memo;
+
+    private Map<String, Object> searchAttributes;
+
     private Map<String, byte[]> context;
 
     private ParentClosePolicy parentClosePolicy;
@@ -111,6 +115,16 @@ public Builder setCronSchedule(String cronSchedule) {
       return this;
     }
 
+    public Builder setMemo(Map<String, Object> memo) {
+      this.memo = memo;
+      return this;
+    }
+
+    public Builder setSearchAttributes(Map<String, Object> searchAttributes) {
+      this.searchAttributes = searchAttributes;
+      return this;
+    }
+
     public Builder setContext(Map<String, byte[]> context) {
       this.context = context;
       return this;
@@ -134,6 +148,8 @@ public StartChildWorkflowExecutionParameters build() {
           workflowIdReusePolicy,
           retryParameters,
           cronSchedule,
+          memo,
+          searchAttributes,
           context,
           parentClosePolicy);
     }
@@ -161,6 +177,10 @@ public StartChildWorkflowExecutionParameters build() {
 
   private final String cronSchedule;
 
+  private Map<String, Object> memo;
+
+  private Map<String, Object> searchAttributes;
+
   private Map<String, byte[]> context;
 
   private final ParentClosePolicy parentClosePolicy;
@@ -177,6 +197,8 @@ private StartChildWorkflowExecutionParameters(
       WorkflowIdReusePolicy workflowIdReusePolicy,
       RetryParameters retryParameters,
       String cronSchedule,
+      Map<String, Object> memo,
+      Map<String, Object> searchAttributes,
       Map<String, byte[]> context,
       ParentClosePolicy parentClosePolicy) {
     this.domain = domain;
@@ -190,6 +212,8 @@ private StartChildWorkflowExecutionParameters(
     this.workflowIdReusePolicy = workflowIdReusePolicy;
     this.retryParameters = retryParameters;
     this.cronSchedule = cronSchedule;
+    this.memo = memo;
+    this.searchAttributes = searchAttributes;
     this.context = context;
     this.parentClosePolicy = parentClosePolicy;
   }
@@ -238,6 +262,14 @@ public String getCronSchedule() {
     return cronSchedule;
   }
 
+  public Map<String, Object> getMemo() {
+    return memo;
+  }
+
+  public Map<String, Object> getSearchAttributes() {
+    return searchAttributes;
+  }
+
   public Map<String, byte[]> getContext() {
     return context;
   }
@@ -262,6 +294,8 @@ public boolean equals(Object o) {
         && workflowIdReusePolicy == that.workflowIdReusePolicy
         && Objects.equals(retryParameters, that.retryParameters)
         && Objects.equals(cronSchedule, that.cronSchedule)
+        && Objects.equals(memo, that.memo)
+        && Objects.equals(searchAttributes, that.searchAttributes)
         && Objects.equals(context, that.context)
         && Objects.equals(parentClosePolicy, that.parentClosePolicy);
   }
@@ -280,6 +314,8 @@ public int hashCode() {
             workflowIdReusePolicy,
             retryParameters,
             cronSchedule,
+            memo,
+            searchAttributes,
             context,
             parentClosePolicy);
     result = 31 * result + Arrays.hashCode(input);
@@ -315,6 +351,10 @@ public String toString() {
         + retryParameters
         + ", cronSchedule="
         + cronSchedule
+        + ", memo="
+        + memo
+        + ", searchAttributes="
+        + searchAttributes
         + ", context='"
         + context
         + ", parentClosePolicy="

src/main/java/com/uber/cadence/internal/replay/WorkflowDecisionContext.java

@@ -37,6 +37,7 @@
 import com.uber.cadence.TaskList;
 import com.uber.cadence.WorkflowExecution;
 import com.uber.cadence.WorkflowType;
+import com.uber.cadence.internal.common.InternalUtils;
 import com.uber.cadence.internal.common.RetryParameters;
 import com.uber.cadence.workflow.ChildWorkflowTerminatedException;
 import com.uber.cadence.workflow.ChildWorkflowTimedOutException;
@@ -153,6 +154,17 @@ Consumer<Exception> startChildWorkflow(
       attributes.setParentClosePolicy(parentClosePolicy);
     }
 
+    Map<String, Object> memoMap = parameters.getMemo();
+    if (memoMap != null) {
+      attributes.setMemo(InternalUtils.convertMapToMemo(memoMap));
+    }
+
+    Map<String, Object> searchAttributesMap = parameters.getSearchAttributes();
+    if (searchAttributesMap != null) {
+      attributes.setSearchAttributes(
+          InternalUtils.convertMapToSearchAttributes(searchAttributesMap));
+    }
+
     long initiatedEventId = decisions.startChildWorkflowExecution(attributes);
     final OpenChildWorkflowRequestInfo context =
         new OpenChildWorkflowRequestInfo(executionCallback);

src/main/java/com/uber/cadence/internal/sync/SyncDecisionContext.java

@@ -375,6 +375,8 @@ private Promise<byte[]> executeChildWorkflow(
               .setTaskStartToCloseTimeout(options.getTaskStartToCloseTimeout())
               .setWorkflowId(options.getWorkflowId())
               .setWorkflowIdReusePolicy(options.getWorkflowIdReusePolicy())
+              .setMemo(options.getMemo())
+              .setSearchAttributes(options.getSearchAttributes())
               .setParentClosePolicy(options.getParentClosePolicy())
               .build();
       return WorkflowRetryerInternal.retryAsync(
@@ -412,6 +414,8 @@ private Promise<byte[]> executeChildWorkflowOnce(
             .setWorkflowIdReusePolicy(options.getWorkflowIdReusePolicy())
             .setRetryParameters(retryParameters)
             .setCronSchedule(options.getCronSchedule())
+            .setMemo(options.getMemo())
+            .setSearchAttributes(options.getSearchAttributes())
             .setContext(extractContextsAndConvertToBytes(propagators))
             .setParentClosePolicy(options.getParentClosePolicy())
             .build();