Exposed startedEventAttribute and DataConverter (#799)

* exposing startedEventAttributes through DecisionContext in WorkflowInfo for using in ContinueAsNew

* addition of workflowEventAttributes in dummy implementation

* Addition of dataConverter

Author: abhishekj720

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

@@ -19,6 +19,7 @@
 
 import com.uber.cadence.SearchAttributes;
 import com.uber.cadence.WorkflowExecution;
+import com.uber.cadence.WorkflowExecutionStartedEventAttributes;
 import com.uber.cadence.WorkflowType;
 import com.uber.cadence.context.ContextPropagator;
 import com.uber.cadence.converter.DataConverter;
@@ -79,6 +80,9 @@ public interface DecisionContext extends ReplayAware {
    */
   SearchAttributes getSearchAttributes();
 
+  /** Returns DataConverter that serializes data */
+  DataConverter getDataConverter();
+
   /**
    * Returns all of the current contexts being propagated by a {@link
    * com.uber.cadence.context.ContextPropagator}. The key is the {@link ContextPropagator#getName()}
@@ -89,6 +93,9 @@ public interface DecisionContext extends ReplayAware {
   /** Returns the set of configured context propagators */
   List<ContextPropagator> getContextPropagators();
 
+  /** Returns the startedEventWorkflow attributes */
+  WorkflowExecutionStartedEventAttributes getWorkflowExecutionStartedEventAttributes();
+
   /**
    * Used to dynamically schedule an activity for execution
    *

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

@@ -60,6 +60,8 @@ final class DecisionContextImpl implements DecisionContext, HistoryEventHandler
   private final WorkflowContext workflowContext;
   private final Scope metricsScope;
   private final boolean enableLoggingInReplay;
+  private final WorkflowExecutionStartedEventAttributes startedEventAttributes;
+  private final DataConverter dataConverter;
 
   DecisionContextImpl(
       DecisionsHelper decisionsHelper,
@@ -77,6 +79,8 @@ final class DecisionContextImpl implements DecisionContext, HistoryEventHandler
     this.workflowClock =
         new ClockDecisionContext(
             decisionsHelper, laTaskPoller, replayDecider, options.getDataConverter());
+    this.startedEventAttributes = startedAttributes;
+    this.dataConverter = options.getDataConverter();
     this.enableLoggingInReplay = options.getEnableLoggingInReplay();
     this.metricsScope =
         new ReplayAwareScope(options.getMetricsScope(), this, workflowClock::currentTimeMillis);
@@ -182,6 +186,16 @@ public List<ContextPropagator> getContextPropagators() {
     return workflowContext.getContextPropagators();
   }
 
+  @Override
+  public WorkflowExecutionStartedEventAttributes getWorkflowExecutionStartedEventAttributes() {
+    return startedEventAttributes;
+  }
+
+  @Override
+  public DataConverter getDataConverter() {
+    return dataConverter;
+  }
+
   @Override
   public Map<String, Object> getPropagatedContexts() {
     return workflowContext.getPropagatedContexts();

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

@@ -19,6 +19,7 @@
 
 import com.uber.cadence.SearchAttributes;
 import com.uber.cadence.WorkflowExecution;
+import com.uber.cadence.WorkflowExecutionStartedEventAttributes;
 import com.uber.cadence.WorkflowType;
 import com.uber.cadence.context.ContextPropagator;
 import com.uber.cadence.converter.DataConverter;
@@ -596,6 +597,11 @@ public SearchAttributes getSearchAttributes() {
       throw new UnsupportedOperationException("not implemented");
     }
 
+    @Override
+    public DataConverter getDataConverter() {
+      return null;
+    }
+
     @Override
     public Map<String, Object> getPropagatedContexts() {
       return null;
@@ -606,6 +612,11 @@ public List<ContextPropagator> getContextPropagators() {
       return null;
     }
 
+    @Override
+    public WorkflowExecutionStartedEventAttributes getWorkflowExecutionStartedEventAttributes() {
+      return null;
+    }
+
     @Override
     public Consumer<Exception> scheduleActivityTask(
         ExecuteActivityParameters parameters, BiConsumer<byte[], Exception> callback) {

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

@@ -19,6 +19,8 @@
 
 import com.uber.cadence.SearchAttributes;
 import com.uber.cadence.WorkflowExecution;
+import com.uber.cadence.WorkflowExecutionStartedEventAttributes;
+import com.uber.cadence.converter.DataConverter;
 import com.uber.cadence.internal.replay.DecisionContext;
 import com.uber.cadence.workflow.WorkflowInfo;
 import java.time.Duration;
@@ -77,4 +79,14 @@ public String getParentRunId() {
     WorkflowExecution parentWorkflowExecution = context.getParentWorkflowExecution();
     return parentWorkflowExecution == null ? null : parentWorkflowExecution.getRunId();
   }
+
+  @Override
+  public WorkflowExecutionStartedEventAttributes getWorkflowExecutionStartedEventAttributes() {
+    return context.getWorkflowExecutionStartedEventAttributes();
+  }
+
+  @Override
+  public DataConverter getDataConverter() {
+    return context.getDataConverter();
+  }
 }

src/main/java/com/uber/cadence/workflow/WorkflowInfo.java

@@ -18,6 +18,8 @@
 package com.uber.cadence.workflow;
 
 import com.uber.cadence.SearchAttributes;
+import com.uber.cadence.WorkflowExecutionStartedEventAttributes;
+import com.uber.cadence.converter.DataConverter;
 import java.time.Duration;
 
 public interface WorkflowInfo {
@@ -39,4 +41,8 @@ public interface WorkflowInfo {
   String getParentWorkflowId();
 
   String getParentRunId();
+
+  WorkflowExecutionStartedEventAttributes getWorkflowExecutionStartedEventAttributes();
+
+  DataConverter getDataConverter();
 }