add serviceclient exceptions (#989)

What changed?

added all exceptions to match thrift exceptions
added ErrorMapper which maps StatusRuntimeException to ServiceClientException
Why?

thrift exceptions are used across Java SDK. It's easier to abstract the protocol level error handling by introducing internal exception layer

Author: shijiesheng

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

@@ -0,0 +1,94 @@
+/*
+ *  Copyright 2012-2016 Amazon.com, Inc. or its affiliates. All Rights Reserved.
+ *
+ *  Modifications copyright (C) 2017 Uber Technologies, Inc.
+ *
+ *  Licensed under the Apache License, Version 2.0 (the "License"). You may not
+ *  use this file except in compliance with the License. A copy of the License is
+ *  located at
+ *
+ *  http://aws.amazon.com/apache2.0
+ *
+ *  or in the "license" file accompanying this file. This file is distributed on
+ *  an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either
+ *  express or implied. See the License for the specific language governing
+ *  permissions and limitations under the License.
+ */
+
+package com.uber.cadence.internal.compatibility.proto;
+
+import com.google.protobuf.Any;
+import com.google.protobuf.InvalidProtocolBufferException;
+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) {
+      return new ServiceClientException("empty status", e);
+    }
+
+    Any detail = Any.getDefaultInstance();
+    if (status.getDetailsCount() > 0) {
+      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,25 @@
+/*
+ *  Copyright 2012-2016 Amazon.com, Inc. or its affiliates. All Rights Reserved.
+ *
+ *  Modifications copyright (C) 2017 Uber Technologies, Inc.
+ *
+ *  Licensed under the Apache License, Version 2.0 (the "License"). You may not
+ *  use this file except in compliance with the License. A copy of the License is
+ *  located at
+ *
+ *  http://aws.amazon.com/apache2.0
+ *
+ *  or in the "license" file accompanying this file. This file is distributed on
+ *  an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either
+ *  express or implied. See the License for the specific language governing
+ *  permissions and limitations under the License.
+ */
+
+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,24 @@
+/*
+ *  Copyright 2012-2016 Amazon.com, Inc. or its affiliates. All Rights Reserved.
+ *
+ *  Modifications copyright (C) 2017 Uber Technologies, Inc.
+ *
+ *  Licensed under the Apache License, Version 2.0 (the "License"). You may not
+ *  use this file except in compliance with the License. A copy of the License is
+ *  located at
+ *
+ *  http://aws.amazon.com/apache2.0
+ *
+ *  or in the "license" file accompanying this file. This file is distributed on
+ *  an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either
+ *  express or implied. See the License for the specific language governing
+ *  permissions and limitations under the License.
+ */
+
+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,43 @@
+/*
+ *  Copyright 2012-2016 Amazon.com, Inc. or its affiliates. All Rights Reserved.
+ *
+ *  Modifications copyright (C) 2017 Uber Technologies, Inc.
+ *
+ *  Licensed under the Apache License, Version 2.0 (the "License"). You may not
+ *  use this file except in compliance with the License. A copy of the License is
+ *  located at
+ *
+ *  http://aws.amazon.com/apache2.0
+ *
+ *  or in the "license" file accompanying this file. This file is distributed on
+ *  an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either
+ *  express or implied. See the License for the specific language governing
+ *  permissions and limitations under the License.
+ */
+
+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,24 @@
+/*
+ *  Copyright 2012-2016 Amazon.com, Inc. or its affiliates. All Rights Reserved.
+ *
+ *  Modifications copyright (C) 2017 Uber Technologies, Inc.
+ *
+ *  Licensed under the Apache License, Version 2.0 (the "License"). You may not
+ *  use this file except in compliance with the License. A copy of the License is
+ *  located at
+ *
+ *  http://aws.amazon.com/apache2.0
+ *
+ *  or in the "license" file accompanying this file. This file is distributed on
+ *  an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either
+ *  express or implied. See the License for the specific language governing
+ *  permissions and limitations under the License.
+ */
+
+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,42 @@
+/*
+ *  Copyright 2012-2016 Amazon.com, Inc. or its affiliates. All Rights Reserved.
+ *
+ *  Modifications copyright (C) 2017 Uber Technologies, Inc.
+ *
+ *  Licensed under the Apache License, Version 2.0 (the "License"). You may not
+ *  use this file except in compliance with the License. A copy of the License is
+ *  located at
+ *
+ *  http://aws.amazon.com/apache2.0
+ *
+ *  or in the "license" file accompanying this file. This file is distributed on
+ *  an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either
+ *  express or implied. See the License for the specific language governing
+ *  permissions and limitations under the License.
+ */
+
+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,25 @@
+/*
+ *  Copyright 2012-2016 Amazon.com, Inc. or its affiliates. All Rights Reserved.
+ *
+ *  Modifications copyright (C) 2017 Uber Technologies, Inc.
+ *
+ *  Licensed under the Apache License, Version 2.0 (the "License"). You may not
+ *  use this file except in compliance with the License. A copy of the License is
+ *  located at
+ *
+ *  http://aws.amazon.com/apache2.0
+ *
+ *  or in the "license" file accompanying this file. This file is distributed on
+ *  an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either
+ *  express or implied. See the License for the specific language governing
+ *  permissions and limitations under the License.
+ */
+
+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,30 @@
+/*
+ *  Copyright 2012-2016 Amazon.com, Inc. or its affiliates. All Rights Reserved.
+ *
+ *  Modifications copyright (C) 2017 Uber Technologies, Inc.
+ *
+ *  Licensed under the Apache License, Version 2.0 (the "License"). You may not
+ *  use this file except in compliance with the License. A copy of the License is
+ *  located at
+ *
+ *  http://aws.amazon.com/apache2.0
+ *
+ *  or in the "license" file accompanying this file. This file is distributed on
+ *  an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either
+ *  express or implied. See the License for the specific language governing
+ *  permissions and limitations under the License.
+ */
+
+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,24 @@
+/*
+ *  Copyright 2012-2016 Amazon.com, Inc. or its affiliates. All Rights Reserved.
+ *
+ *  Modifications copyright (C) 2017 Uber Technologies, Inc.
+ *
+ *  Licensed under the Apache License, Version 2.0 (the "License"). You may not
+ *  use this file except in compliance with the License. A copy of the License is
+ *  located at
+ *
+ *  http://aws.amazon.com/apache2.0
+ *
+ *  or in the "license" file accompanying this file. This file is distributed on
+ *  an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either
+ *  express or implied. See the License for the specific language governing
+ *  permissions and limitations under the License.
+ */
+
+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,24 @@
+/*
+ *  Copyright 2012-2016 Amazon.com, Inc. or its affiliates. All Rights Reserved.
+ *
+ *  Modifications copyright (C) 2017 Uber Technologies, Inc.
+ *
+ *  Licensed under the Apache License, Version 2.0 (the "License"). You may not
+ *  use this file except in compliance with the License. A copy of the License is
+ *  located at
+ *
+ *  http://aws.amazon.com/apache2.0
+ *
+ *  or in the "license" file accompanying this file. This file is distributed on
+ *  an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either
+ *  express or implied. See the License for the specific language governing
+ *  permissions and limitations under the License.
+ */
+
+package com.uber.cadence.serviceclient.exceptions;
+
+public class InternalServiceException extends ServiceClientException {
+  public InternalServiceException(Throwable cause) {
+    super(cause);
+  }
+}