add error proto mapper to workflow APIs (#691)

Author: mkolodezny

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

@@ -221,6 +221,9 @@ private void convertAndThrowStatusException(StatusRuntimeException e)
       throws BadRequestError, WorkflowExecutionAlreadyStartedError, ServiceBusyError,
       DomainNotActiveError, LimitExceededError, EntityNotExistsError,
       ClientVersionNotSupportedError {
+    if (e.getCause() != null) {
+      e.getMessage();
+    }
     // TODO handle all errors depending on status
     switch (e.getStatus().getCode()) {
       case ALREADY_EXISTS: {
@@ -451,8 +454,7 @@ public void RespondActivityTaskCanceledByID(
   }
 
   @Override
-  public void RequestCancelWorkflowExecution(RequestCancelWorkflowExecutionRequest
-      cancelRequest)
+  public void RequestCancelWorkflowExecution(RequestCancelWorkflowExecutionRequest cancelRequest)
       throws BadRequestError, EntityNotExistsError, CancellationAlreadyRequestedError,
       ServiceBusyError, DomainNotActiveError, LimitExceededError,
       ClientVersionNotSupportedError, WorkflowExecutionAlreadyCompletedError, TException {
@@ -490,37 +492,52 @@ public StartWorkflowExecutionResponse SignalWithStartWorkflowExecution(
       throws BadRequestError, EntityNotExistsError, ServiceBusyError, DomainNotActiveError,
       LimitExceededError, WorkflowExecutionAlreadyStartedError, ClientVersionNotSupportedError,
       TException {
-    signalWithStartRequest.setRequestId(UUID.randomUUID().toString());
-    com.uber.cadence.api.v1.SignalWithStartWorkflowExecutionResponse response =
-        grpcServiceStubs
-            .workflowBlockingStub()
-            .signalWithStartWorkflowExecution(
-                RequestMapper.signalWithStartWorkflowExecutionRequest(signalWithStartRequest));
-    return ResponseMapper.signalWithStartWorkflowExecutionResponse(response);
+    try {
+      signalWithStartRequest.setRequestId(UUID.randomUUID().toString());
+      com.uber.cadence.api.v1.SignalWithStartWorkflowExecutionResponse response =
+          grpcServiceStubs
+              .workflowBlockingStub()
+              .signalWithStartWorkflowExecution(
+                  RequestMapper.signalWithStartWorkflowExecutionRequest(signalWithStartRequest));
+      return ResponseMapper.signalWithStartWorkflowExecutionResponse(response);
+    } catch (StatusRuntimeException e) {
+      convertAndThrowStatusException(e);
+      throw e;
+    }
   }
 
   @Override
   public ResetWorkflowExecutionResponse ResetWorkflowExecution(
       ResetWorkflowExecutionRequest resetRequest)
       throws BadRequestError, EntityNotExistsError, ServiceBusyError, DomainNotActiveError,
       LimitExceededError, ClientVersionNotSupportedError, TException {
-    resetRequest.setRequestId(UUID.randomUUID().toString());
-    com.uber.cadence.api.v1.ResetWorkflowExecutionResponse response =
-        grpcServiceStubs
-            .workflowBlockingStub()
-            .resetWorkflowExecution(RequestMapper.resetWorkflowExecutionRequest(resetRequest));
-    return ResponseMapper.resetWorkflowExecutionResponse(response);
+    try {
+      resetRequest.setRequestId(UUID.randomUUID().toString());
+      com.uber.cadence.api.v1.ResetWorkflowExecutionResponse response =
+          grpcServiceStubs
+              .workflowBlockingStub()
+              .resetWorkflowExecution(RequestMapper.resetWorkflowExecutionRequest(resetRequest));
+      return ResponseMapper.resetWorkflowExecutionResponse(response);
+    } catch (StatusRuntimeException e) {
+      convertAndThrowStatusException(e);
+      throw e;
+    }
   }
 
   @Override
   public void TerminateWorkflowExecution(TerminateWorkflowExecutionRequest terminateRequest)
       throws BadRequestError, EntityNotExistsError, ServiceBusyError, DomainNotActiveError,
       LimitExceededError, ClientVersionNotSupportedError,
       WorkflowExecutionAlreadyCompletedError, TException {
-    grpcServiceStubs
-        .workflowBlockingStub()
-        .terminateWorkflowExecution(
-            RequestMapper.terminateWorkflowExecutionRequest(terminateRequest));
+    try {
+      grpcServiceStubs
+          .workflowBlockingStub()
+          .terminateWorkflowExecution(
+              RequestMapper.terminateWorkflowExecutionRequest(terminateRequest));
+    } catch (StatusRuntimeException e) {
+      convertAndThrowStatusException(e);
+      throw e;
+    }
   }
 
   @Override
@@ -594,8 +611,7 @@ public CountWorkflowExecutionsResponse CountWorkflowExecutions(
     com.uber.cadence.api.v1.CountWorkflowExecutionsResponse response =
         grpcServiceStubs
             .visibilityBlockingStub()
-            .countWorkflowExecutions(
-                RequestMapper.countWorkflowExecutionsRequest(countRequest));
+            .countWorkflowExecutions(RequestMapper.countWorkflowExecutionsRequest(countRequest));
     return ResponseMapper.countWorkflowExecutionsResponse(response);
   }
 
@@ -615,13 +631,11 @@ public void RespondQueryTaskCompleted(RespondQueryTaskCompletedRequest completeR
       DomainNotActiveError, ClientVersionNotSupportedError, TException {
     grpcServiceStubs
         .workerBlockingStub()
-        .respondQueryTaskCompleted(
-            RequestMapper.respondQueryTaskCompletedRequest(completeRequest));
+        .respondQueryTaskCompleted(RequestMapper.respondQueryTaskCompletedRequest(completeRequest));
   }
 
   @Override
-  public ResetStickyTaskListResponse ResetStickyTaskList(ResetStickyTaskListRequest
-      resetRequest)
+  public ResetStickyTaskListResponse ResetStickyTaskList(ResetStickyTaskListRequest resetRequest)
       throws BadRequestError, EntityNotExistsError, LimitExceededError, ServiceBusyError,
       DomainNotActiveError, ClientVersionNotSupportedError,
       WorkflowExecutionAlreadyCompletedError, TException {
@@ -705,15 +719,13 @@ public void RefreshWorkflowTasks(RefreshWorkflowTasksRequest request)
 
   @Override
   public void RegisterDomain(
-      RegisterDomainRequest registerRequest, AsyncMethodCallback resultHandler) throws
-      TException {
+      RegisterDomainRequest registerRequest, AsyncMethodCallback resultHandler) throws TException {
     throw new UnsupportedOperationException("not implemented");
   }
 
   @Override
   public void DescribeDomain(
-      DescribeDomainRequest describeRequest, AsyncMethodCallback resultHandler) throws
-      TException {
+      DescribeDomainRequest describeRequest, AsyncMethodCallback resultHandler) throws TException {
     throw new UnsupportedOperationException("not implemented");
   }
 
@@ -752,8 +764,7 @@ public void GetWorkflowExecutionHistory(
 
   @Override
   public void PollForDecisionTask(
-      PollForDecisionTaskRequest pollRequest, AsyncMethodCallback resultHandler) throws
-      TException {
+      PollForDecisionTaskRequest pollRequest, AsyncMethodCallback resultHandler) throws TException {
     throw new UnsupportedOperationException("not implemented");
   }
 
@@ -773,8 +784,7 @@ public void RespondDecisionTaskFailed(
 
   @Override
   public void PollForActivityTask(
-      PollForActivityTaskRequest pollRequest, AsyncMethodCallback resultHandler) throws
-      TException {
+      PollForActivityTaskRequest pollRequest, AsyncMethodCallback resultHandler) throws TException {
     throw new UnsupportedOperationException("not implemented");
   }
 
@@ -849,13 +859,11 @@ public void SignalWorkflowExecution(
     ListenableFuture<com.uber.cadence.api.v1.SignalWorkflowExecutionResponse> resultFuture =
         grpcServiceStubs
             .workflowFutureStub()
-            .signalWorkflowExecution(
-                RequestMapper.signalWorkflowExecutionRequest(signalRequest));
+            .signalWorkflowExecution(RequestMapper.signalWorkflowExecutionRequest(signalRequest));
     resultFuture.addListener(
         () -> {
           try {
-            com.uber.cadence.api.v1.SignalWorkflowExecutionResponse response = resultFuture
-                .get();
+            com.uber.cadence.api.v1.SignalWorkflowExecutionResponse response = resultFuture.get();
             resultHandler.onComplete(null);
           } catch (Exception e) {
             resultHandler.onError(e);
@@ -948,8 +956,7 @@ public void ResetStickyTaskList(
   }
 
   @Override
-  public void QueryWorkflow(QueryWorkflowRequest queryRequest, AsyncMethodCallback
-      resultHandler)
+  public void QueryWorkflow(QueryWorkflowRequest queryRequest, AsyncMethodCallback resultHandler)
       throws TException {
     throw new UnsupportedOperationException("not implemented");
   }
@@ -962,8 +969,7 @@ public void DescribeWorkflowExecution(
   }
 
   @Override
-  public void DescribeTaskList(DescribeTaskListRequest request, AsyncMethodCallback
-      resultHandler)
+  public void DescribeTaskList(DescribeTaskListRequest request, AsyncMethodCallback resultHandler)
       throws TException {
     throw new UnsupportedOperationException("not implemented");
   }
@@ -981,8 +987,7 @@ public void GetTaskListsByDomain(
 
   @Override
   public void ListTaskListPartitions(
-      ListTaskListPartitionsRequest request, AsyncMethodCallback resultHandler) throws
-      TException {
+      ListTaskListPartitionsRequest request, AsyncMethodCallback resultHandler) throws TException {
     throw new UnsupportedOperationException("not implemented");
   }
 
@@ -1042,8 +1047,7 @@ public void StartWorkflowExecutionWithTimeout(
     resultFuture.addListener(
         () -> {
           try {
-            com.uber.cadence.api.v1.StartWorkflowExecutionResponse response = resultFuture
-                .get();
+            com.uber.cadence.api.v1.StartWorkflowExecutionResponse response = resultFuture.get();
             resultHandler.onComplete(ResponseMapper.startWorkflowExecutionResponse(response));
           } catch (Exception e) {
             resultHandler.onError(e);
@@ -1082,8 +1086,7 @@ public void GetWorkflowExecutionHistoryWithTimeout(
           try {
             com.uber.cadence.api.v1.GetWorkflowExecutionHistoryResponse response =
                 resultFuture.get();
-            resultHandler
-                .onComplete(ResponseMapper.getWorkflowExecutionHistoryResponse(response));
+            resultHandler.onComplete(ResponseMapper.getWorkflowExecutionHistoryResponse(response));
           } catch (Exception e) {
             resultHandler.onError(e);
           }