add serviceclient exceptions

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);
+  }
+}

src/main/java/com/uber/cadence/serviceclient/exceptions/LimitExceededException.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 LimitExceededException extends ServiceClientException {
+  public LimitExceededException(Throwable cause) {
+    super(cause);
+  }
+}