handle data loss and version-feature check (#694)

Author: mkolodezny

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

@@ -15,10 +15,17 @@
  */
 package com.uber.cadence.internal.compatibility.thrift;
 
-import com.uber.cadence.*;
 import com.uber.cadence.AccessDeniedError;
+import com.uber.cadence.CancellationAlreadyRequestedError;
+import com.uber.cadence.ClientVersionNotSupportedError;
+import com.uber.cadence.DomainAlreadyExistsError;
+import com.uber.cadence.DomainNotActiveError;
 import com.uber.cadence.EntityNotExistsError;
+import com.uber.cadence.FeatureNotEnabledError;
+import com.uber.cadence.InternalDataInconsistencyError;
 import com.uber.cadence.InternalServiceError;
+import com.uber.cadence.WorkflowExecutionAlreadyCompletedError;
+import com.uber.cadence.WorkflowExecutionAlreadyStartedError;
 import io.grpc.Metadata;
 import io.grpc.StatusRuntimeException;
 import org.apache.thrift.TException;
@@ -32,30 +39,42 @@ public static TException Error(StatusRuntimeException ex) {
         return new AccessDeniedError(ex.getMessage());
       case INTERNAL:
         return new InternalServiceError(ex.getMessage());
-      case NOT_FOUND:
-        {
-          switch (details) {
-            case "EntityNotExistsError":
-              // TODO add cluster info
-              return new EntityNotExistsError(ex.getMessage());
-            case "WorkflowExecutionAlreadyCompletedError":
-              return new WorkflowExecutionAlreadyCompletedError(ex.getMessage());
+      case NOT_FOUND: {
+        switch (details) {
+          case "EntityNotExistsError":
+            // TODO add cluster info
+            return new EntityNotExistsError(ex.getMessage());
+          case "WorkflowExecutionAlreadyCompletedError":
+            return new WorkflowExecutionAlreadyCompletedError(ex.getMessage());
+        }
+      }
+      case ALREADY_EXISTS: {
+        switch (details) {
+          case "CancellationAlreadyRequestedError":
+            return new CancellationAlreadyRequestedError(ex.getMessage());
+          case "DomainAlreadyExistsError":
+            return new DomainAlreadyExistsError(ex.getMessage());
+          case "WorkflowExecutionAlreadyStartedError": {
+            // TODO add started wf info
+            WorkflowExecutionAlreadyStartedError e = new WorkflowExecutionAlreadyStartedError();
+            e.setMessage(ex.getMessage());
+            return e;
           }
         }
-      case ALREADY_EXISTS:
-        {
-          switch (details) {
-            case "CancellationAlreadyRequestedError":
-              return new CancellationAlreadyRequestedError(ex.getMessage());
-            case "DomainAlreadyExistsError":
-              return new DomainAlreadyExistsError(ex.getMessage());
-            case "WorkflowExecutionAlreadyStartedError":
-              {
-                // TODO add started wf info
-                WorkflowExecutionAlreadyStartedError e = new WorkflowExecutionAlreadyStartedError();
-                e.setMessage(ex.getMessage());
-                return e;
-              }
+      }
+      case DATA_LOSS:
+        return new InternalDataInconsistencyError(ex.getMessage());
+      case FAILED_PRECONDITION:
+        switch (details) {
+          // TODO add infos
+          case "ClientVersionNotSupportedError":
+            return new ClientVersionNotSupportedError();
+          case "FeatureNotEnabledError":
+            return new FeatureNotEnabledError();
+          case "DomainNotActiveError": {
+            DomainNotActiveError e = new DomainNotActiveError();
+            e.setMessage(ex.getMessage());
+            return e;
           }
         }
       default: