add serviceclient exceptions

Author: shijiesheng

src/main/java/com/uber/cadence/internal/compatibility/proto/ErrorMapper.java

@@ -0,0 +1,70 @@
+package com.uber.cadence.internal.compatibility.proto;
+
+import com.google.protobuf.Any;
+import com.google.protobuf.InvalidProtocolBufferException;
+import com.google.protobuf.Message;
+import com.google.rpc.Status;
+import com.uber.cadence.api.v1.*;
+import com.uber.cadence.serviceclient.exceptions.*;
+import io.grpc.StatusRuntimeException;
+import io.grpc.protobuf.StatusProto;
+
+public class ErrorMapper {
+    public static ServiceClientException Error(StatusRuntimeException e) {
+
+        Status status = StatusProto.fromThrowable(e);
+        if (status == null || status.getDetailsCount() == 0) {
+            return new ServiceClientException("empty status or status with empty details", e);
+        }
+
+        Any detail = status.getDetails(0);
+
+        try {
+            switch (e.getStatus().getCode()) {
+                case PERMISSION_DENIED:
+                    return new AccessDeniedException(e);
+                case INTERNAL:
+                    return new InternalServiceException(e);
+                case NOT_FOUND:
+                    if (detail.is(WorkflowExecutionAlreadyCompletedError.class)) {
+                        return new WorkflowExecutionAlreadyCompletedException(e);
+                    } else {
+                        return new EntityNotExistsException(e);
+                    }
+                case ALREADY_EXISTS:
+                    if (detail.is(CancellationAlreadyRequestedError.class)) {
+                        return new CancellationAlreadyRequestedException(e);
+                    } else if (detail.is(DomainAlreadyExistsError.class)) {
+                        return new DomainAlreadyExistsException(e);
+                    } else if (detail.is(WorkflowExecutionAlreadyStartedError.class)) {
+                        WorkflowExecutionAlreadyStartedError error = detail.unpack(WorkflowExecutionAlreadyStartedError.class);
+                        return new WorkflowExecutionAlreadyStartedException(error.getStartRequestId(), error.getRunId());
+                    }
+                case DATA_LOSS:
+                    return new InternalDataInconsistencyException(e);
+                case FAILED_PRECONDITION:
+                    if (detail.is(ClientVersionNotSupportedError.class)) {
+                        ClientVersionNotSupportedError error = detail.unpack(ClientVersionNotSupportedError.class);
+                        return new ClientVersionNotSupportedException(error.getFeatureVersion(), error.getClientImpl(), error.getSupportedVersions());
+                    }else if (detail.is(FeatureNotEnabledError.class)) {
+                        FeatureNotEnabledError error = detail.unpack(FeatureNotEnabledError.class);
+                        return new FeatureNotEnabledException(error.getFeatureFlag());
+                    } else if (detail.is(DomainNotActiveError.class)) {
+                        DomainNotActiveError error = detail.unpack(DomainNotActiveError.class);
+                        return new DomainNotActiveException(error.getDomain(), error.getCurrentCluster(), error.getActiveCluster());
+                    }
+                case RESOURCE_EXHAUSTED:
+                    if (detail.is(LimitExceededError.class)) {
+                        return new LimitExceededException(e);
+                    } else {
+                        return new ServiceBusyException(e);
+                    }
+                case UNKNOWN:
+                default:
+                    return new ServiceClientException(e);
+            }
+        } catch (InvalidProtocolBufferException ex) {
+            return new ServiceClientException(ex);
+        }
+    }
+}

src/main/java/com/uber/cadence/serviceclient/exceptions/AccessDeniedException.java

@@ -0,0 +1,8 @@
+package com.uber.cadence.serviceclient.exceptions;
+
+public class AccessDeniedException extends ServiceClientException {
+
+    public AccessDeniedException(Throwable cause) {
+        super(cause);
+    }
+}

src/main/java/com/uber/cadence/serviceclient/exceptions/CancellationAlreadyRequestedException.java

@@ -0,0 +1,7 @@
+package com.uber.cadence.serviceclient.exceptions;
+
+public class CancellationAlreadyRequestedException extends ServiceClientException {
+    public CancellationAlreadyRequestedException(Throwable cause) {
+        super(cause);
+    }
+}

src/main/java/com/uber/cadence/serviceclient/exceptions/ClientVersionNotSupportedException.java

@@ -0,0 +1,25 @@
+package com.uber.cadence.serviceclient.exceptions;
+
+public class ClientVersionNotSupportedException extends ServiceClientException {
+    private final String featureVersion;
+    private final String clientImpl;
+    private final String supportedVersions;
+
+    public ClientVersionNotSupportedException(String featureVersion, String clientImpl, String supportedVersions) {
+        this.featureVersion = featureVersion;
+        this.clientImpl = clientImpl;
+        this.supportedVersions = supportedVersions;
+    }
+
+    public String getFeatureVersion() {
+        return featureVersion;
+    }
+
+    public String getClientImpl() {
+        return clientImpl;
+    }
+
+    public String getSupportedVersions() {
+        return supportedVersions;
+    }
+}

src/main/java/com/uber/cadence/serviceclient/exceptions/DomainAlreadyExistsException.java

@@ -0,0 +1,7 @@
+package com.uber.cadence.serviceclient.exceptions;
+
+public class DomainAlreadyExistsException extends ServiceClientException {
+    public DomainAlreadyExistsException(Throwable cause) {
+        super(cause);
+    }
+}

src/main/java/com/uber/cadence/serviceclient/exceptions/DomainNotActiveException.java

@@ -0,0 +1,25 @@
+package com.uber.cadence.serviceclient.exceptions;
+
+public class DomainNotActiveException extends ServiceClientException {
+    private final String domain;
+    private final String currentCluster;
+    private final String activeCluster;
+
+    public DomainNotActiveException(String domain, String currentCluster, String activeCluster) {
+        this.domain = domain;
+        this.currentCluster = currentCluster;
+        this.activeCluster = activeCluster;
+    }
+
+    public String getDomain() {
+        return domain;
+    }
+
+    public String getCurrentCluster() {
+        return currentCluster;
+    }
+
+    public String getActiveCluster() {
+        return activeCluster;
+    }
+}

src/main/java/com/uber/cadence/serviceclient/exceptions/EntityNotExistsException.java

@@ -0,0 +1,8 @@
+package com.uber.cadence.serviceclient.exceptions;
+
+public class EntityNotExistsException extends ServiceClientException {
+
+    public EntityNotExistsException(Throwable cause) {
+        super(cause);
+    }
+}

src/main/java/com/uber/cadence/serviceclient/exceptions/FeatureNotEnabledException.java

@@ -0,0 +1,13 @@
+package com.uber.cadence.serviceclient.exceptions;
+
+public class FeatureNotEnabledException extends ServiceClientException {
+    private final String featureFlag;
+
+    public FeatureNotEnabledException(String featureFlag) {
+        this.featureFlag = featureFlag;
+    }
+
+    public String getFeatureFlag() {
+        return featureFlag;
+    }
+}

src/main/java/com/uber/cadence/serviceclient/exceptions/InternalDataInconsistencyException.java

@@ -0,0 +1,7 @@
+package com.uber.cadence.serviceclient.exceptions;
+
+public class InternalDataInconsistencyException extends ServiceClientException{
+    public InternalDataInconsistencyException(Throwable cause) {
+        super(cause);
+    }
+}

src/main/java/com/uber/cadence/serviceclient/exceptions/InternalServiceException.java

@@ -0,0 +1,7 @@
+package com.uber.cadence.serviceclient.exceptions;
+
+public class InternalServiceException extends ServiceClientException{
+    public InternalServiceException(Throwable cause) {
+        super(cause);
+    }
+}