fix the next round of compile/test errors from idl changes

Author: c-warren

src/main/java/com/uber/cadence/internal/compatibility/Thrift2ProtoAdapter.java

@@ -843,7 +843,7 @@ public void DescribeDomain(
   public void DiagnoseWorkflowExecution(
       DiagnoseWorkflowExecutionRequest diagnoseRequest, AsyncMethodCallback resultHandler)
       throws TException {
-    throw new UnsupportedOperationException("DiagnoseWorkflowExecution is not implemented");
+    throw new UnsupportedOperationException("not implemented");
   }
 
   @Override

src/main/java/com/uber/cadence/internal/compatibility/thrift/HistoryMapper.java

@@ -947,6 +947,8 @@ static MarkerRecordedEventAttributes markerRecordedEventAttributes(
     res.setMemo(memo(t.getMemo()));
     res.setSearchAttributes(searchAttributes(t.getSearchAttributes()));
     res.setDelayStartSeconds(durationToSeconds(t.getDelayStart()));
+    res.setJitterStartSeconds(durationToSeconds(t.getJitterStart()));
+    res.setFirstRunAtTimestamp(timeToUnixNano(t.getFirstRunAt()));
     return res;
   }
 

src/main/java/com/uber/cadence/internal/compatibility/thrift/ResponseMapper.java

@@ -25,6 +25,7 @@
 import static com.uber.cadence.internal.compatibility.thrift.HistoryMapper.history;
 import static com.uber.cadence.internal.compatibility.thrift.TypeMapper.activityLocalDispatchInfoMap;
 import static com.uber.cadence.internal.compatibility.thrift.TypeMapper.activityType;
+import static com.uber.cadence.internal.compatibility.thrift.TypeMapper.autoConfigHint;
 import static com.uber.cadence.internal.compatibility.thrift.TypeMapper.badBinaries;
 import static com.uber.cadence.internal.compatibility.thrift.TypeMapper.clusterReplicationConfigurationArray;
 import static com.uber.cadence.internal.compatibility.thrift.TypeMapper.dataBlobArray;
@@ -239,6 +240,7 @@ public static PollForActivityTaskResponse pollForActivityTaskResponse(
     res.setWorkflowType(workflowType(t.getWorkflowType()));
     res.setWorkflowDomain(t.getWorkflowDomain());
     res.setHeader(header(t.getHeader()));
+    res.setAutoConfigHint(autoConfigHint(t.getAutoConfigHint()));
     return res;
   }
 
@@ -265,6 +267,7 @@ public static PollForDecisionTaskResponse pollForDecisionTaskResponse(
     res.setStartedTimestamp(timeToUnixNano(t.getStartedTime()));
     res.setQueries(workflowQueryMap(t.getQueriesMap()));
     res.setNextEventId(t.getNextEventId());
+    res.setAutoConfigHint(autoConfigHint(t.getAutoConfigHint()));
     return res;
   }
 

src/main/java/com/uber/cadence/internal/compatibility/thrift/TypeMapper.java

@@ -31,6 +31,7 @@
 
 import com.uber.cadence.ActivityLocalDispatchInfo;
 import com.uber.cadence.ActivityType;
+import com.uber.cadence.AutoConfigHint;
 import com.uber.cadence.BadBinaries;
 import com.uber.cadence.BadBinaryInfo;
 import com.uber.cadence.ClusterReplicationConfiguration;
@@ -686,4 +687,14 @@ static Map<String, ActivityLocalDispatchInfo> activityLocalDispatchInfoMap(
     }
     return v;
   }
+
+  static AutoConfigHint autoConfigHint(com.uber.cadence.api.v1.AutoConfigHint t) {
+    if (t == null) {
+      return null;
+    }
+    AutoConfigHint autoConfigHint = new AutoConfigHint();
+    autoConfigHint.setEnableAutoConfig(t.getEnableAutoConfig());
+    autoConfigHint.setPollerWaitTimeInMs(t.getPollerWaitTimeInMs());
+    return autoConfigHint;
+  }
 }

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

@@ -597,7 +597,7 @@ public void DescribeDomain(
     public void DiagnoseWorkflowExecution(
         DiagnoseWorkflowExecutionRequest diagnoseRequest, AsyncMethodCallback resultHandler)
         throws TException {
-      throw new UnsupportedOperationException("DiagnoseWorkflowExecution is not implemented");
+      impl.DiagnoseWorkflowExecution(diagnoseRequest, resultHandler);
     }
 
     @Override
@@ -933,7 +933,7 @@ public DiagnoseWorkflowExecutionResponse DiagnoseWorkflowExecution(
         DiagnoseWorkflowExecutionRequest diagnoseRequest)
         throws DomainNotActiveError, ServiceBusyError, EntityNotExistsError,
             ClientVersionNotSupportedError, TException {
-      throw new UnsupportedOperationException("DiagnoseWorkflowExecution is not implemented");
+      return impl.DiagnoseWorkflowExecution(diagnoseRequest);
     }
 
     @Override

src/test/java/com/uber/cadence/internal/compatibility/ProtoObjects.java

@@ -80,6 +80,8 @@ public final class ProtoObjects {
   public static final Header HEADER =
       Header.newBuilder().putFields("key", payload("value")).build();
   public static final Memo MEMO = Memo.newBuilder().putFields("memo", payload("memoValue")).build();
+  public static final AutoConfigHint AUTO_CONFIG_HINT =
+      AutoConfigHint.newBuilder().setEnableAutoConfig(true).setPollerWaitTimeInMs(100).build();
   public static final SearchAttributes SEARCH_ATTRIBUTES =
       SearchAttributes.newBuilder().putIndexedFields("search", payload("attributes")).build();
   public static final Map<String, String> DATA = ImmutableMap.of("dataKey", "dataValue");
@@ -629,6 +631,8 @@ public final class ProtoObjects {
               .setMemo(MEMO)
               .setSearchAttributes(SEARCH_ATTRIBUTES)
               .setDelayStart(seconds(4))
+              .setJitterStart(seconds(5))
+              .setFirstRunAt(timestampNanos(123456789))
               .build();
 
   public static final StartChildWorkflowExecutionFailedEventAttributes
@@ -1304,6 +1308,7 @@ public final class ProtoObjects {
           .setWorkflowType(WORKFLOW_TYPE)
           .setWorkflowDomain("domain")
           .setHeader(HEADER)
+          .setAutoConfigHint(AUTO_CONFIG_HINT)
           .build();
   public static final PollForDecisionTaskResponse POLL_FOR_DECISION_TASK_RESPONSE =
       PollForDecisionTaskResponse.newBuilder()
@@ -1322,6 +1327,7 @@ public final class ProtoObjects {
           .setStartedTime(timestampNanos(6))
           .putAllQueries(ImmutableMap.of("query", WORKFLOW_QUERY))
           .setNextEventId(7)
+          .setAutoConfigHint(AUTO_CONFIG_HINT)
           .build();
 
   public static final QueryWorkflowResponse QUERY_WORKFLOW_RESPONSE =

src/test/java/com/uber/cadence/internal/compatibility/ThriftObjects.java

@@ -67,6 +67,8 @@ public final class ThriftObjects {
           .setErrorMessage("error");
   public static final Header HEADER = new Header().setFields(ImmutableMap.of("key", utf8("value")));
   public static final Memo MEMO = new Memo().setFields(ImmutableMap.of("memo", utf8("memoValue")));
+  public static final AutoConfigHint AUTO_CONFIG_HINT =
+      new AutoConfigHint().setEnableAutoConfig(true).setPollerWaitTimeInMs(100);
   public static final SearchAttributes SEARCH_ATTRIBUTES =
       new SearchAttributes().setIndexedFields(ImmutableMap.of("search", utf8("attributes")));
   public static final Map<String, String> DATA = ImmutableMap.of("dataKey", "dataValue");
@@ -539,7 +541,9 @@ public final class ThriftObjects {
               .setHeader(HEADER)
               .setMemo(MEMO)
               .setSearchAttributes(SEARCH_ATTRIBUTES)
-              .setDelayStartSeconds(4);
+              .setDelayStartSeconds(4)
+              .setJitterStartSeconds(5)
+              .setFirstRunAtTimestamp(123456789L);
 
   public static final StartChildWorkflowExecutionFailedEventAttributes
       START_CHILD_WORKFLOW_EXECUTION_FAILED_EVENT_ATTRIBUTES =
@@ -1109,7 +1113,8 @@ public final class ThriftObjects {
           .setHeartbeatDetails(utf8("heartbeatDetails"))
           .setWorkflowType(WORKFLOW_TYPE)
           .setWorkflowDomain("domain")
-          .setHeader(HEADER);
+          .setHeader(HEADER)
+          .setAutoConfigHint(AUTO_CONFIG_HINT);
   public static final PollForDecisionTaskResponse POLL_FOR_DECISION_TASK_RESPONSE =
       new PollForDecisionTaskResponse()
           .setTaskToken(utf8("taskToken"))
@@ -1126,7 +1131,8 @@ public final class ThriftObjects {
           .setScheduledTimestamp(5)
           .setStartedTimestamp(6)
           .setQueries(ImmutableMap.of("query", WORKFLOW_QUERY))
-          .setNextEventId(7);
+          .setNextEventId(7)
+          .setAutoConfigHint(AUTO_CONFIG_HINT);
 
   public static final QueryWorkflowResponse QUERY_WORKFLOW_RESPONSE =
       new QueryWorkflowResponse()

src/test/java/com/uber/cadence/internal/compatibility/thrift/HistoryMapperEventTest.java

@@ -283,8 +283,7 @@ public static Object[][] cases() {
       testCase(
           EventType.StartChildWorkflowExecutionInitiated,
           ProtoObjects.START_CHILD_WORKFLOW_EXECUTION_INITIATED_EVENT_ATTRIBUTES,
-          ThriftObjects.START_CHILD_WORKFLOW_EXECUTION_INITIATED_EVENT_ATTRIBUTES,
-          "jitterStartSeconds"),
+          ThriftObjects.START_CHILD_WORKFLOW_EXECUTION_INITIATED_EVENT_ATTRIBUTES),
       testCase(
           EventType.StartChildWorkflowExecutionFailed,
           ProtoObjects.START_CHILD_WORKFLOW_EXECUTION_FAILED_EVENT_ATTRIBUTES,