Skip to content

Commit 5a908a5

Browse files
bowenxiabowenxia
authored
add test for ErrorMapper (#942)
1 parent d38275f commit 5a908a5

File tree

1 file changed

+187
-0
lines changed

1 file changed

+187
-0
lines changed

‎src/test/java/com/uber/cadence/internal/compatibility/thrift/ErrorMapperTest.java

+187
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,187 @@
1+
/**
2+
* Copyright 2012-2016 Amazon.com, Inc. or its affiliates. All Rights Reserved.
3+
*
4+
* <p>Modifications copyright (C) 2017 Uber Technologies, Inc.
5+
*
6+
* <p>Licensed under the Apache License, Version 2.0 (the "License"). You may not use this file
7+
* except in compliance with the License. A copy of the License is located at
8+
*
9+
* <p>http://aws.amazon.com/apache2.0
10+
*
11+
* <p>or in the "license" file accompanying this file. This file is distributed on an "AS IS" BASIS,
12+
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the
13+
* specific language governing permissions and limitations under the License.
14+
*/
15+
package com.uber.cadence.internal.compatibility.thrift;
16+
17+
import static org.junit.Assert.assertTrue;
18+
19+
import com.uber.cadence.AccessDeniedError;
20+
import com.uber.cadence.CancellationAlreadyRequestedError;
21+
import com.uber.cadence.ClientVersionNotSupportedError;
22+
import com.uber.cadence.DomainAlreadyExistsError;
23+
import com.uber.cadence.DomainNotActiveError;
24+
import com.uber.cadence.EntityNotExistsError;
25+
import com.uber.cadence.FeatureNotEnabledError;
26+
import com.uber.cadence.InternalServiceError;
27+
import com.uber.cadence.LimitExceededError;
28+
import com.uber.cadence.ServiceBusyError;
29+
import com.uber.cadence.WorkflowExecutionAlreadyCompletedError;
30+
import com.uber.cadence.WorkflowExecutionAlreadyStartedError;
31+
import io.grpc.Metadata;
32+
import io.grpc.Status;
33+
import io.grpc.StatusRuntimeException;
34+
import org.apache.thrift.TException;
35+
import org.junit.Test;
36+
37+
public class ErrorMapperTest {
38+
39+
@Test
40+
public void testPermissionDeniedError() {
41+
StatusRuntimeException ex =
42+
new StatusRuntimeException(Status.PERMISSION_DENIED.withDescription("Access denied"));
43+
TException result = ErrorMapper.Error(ex);
44+
assertTrue(result instanceof AccessDeniedError);
45+
}
46+
47+
@Test
48+
public void testInternalServiceError() {
49+
StatusRuntimeException ex =
50+
new StatusRuntimeException(Status.INTERNAL.withDescription("Internal error"));
51+
TException result = ErrorMapper.Error(ex);
52+
assertTrue(result instanceof InternalServiceError);
53+
}
54+
55+
@Test
56+
public void testWorkflowExecutionAlreadyCompletedError() {
57+
Metadata metadata = new Metadata();
58+
metadata.put(
59+
Metadata.Key.of("rpc-application-error-name", Metadata.ASCII_STRING_MARSHALLER),
60+
"EntityNotExistsError");
61+
StatusRuntimeException ex =
62+
new StatusRuntimeException(
63+
Status.NOT_FOUND.withDescription("already completed."), metadata);
64+
TException result = ErrorMapper.Error(ex);
65+
assertTrue(result instanceof WorkflowExecutionAlreadyCompletedError);
66+
}
67+
68+
@Test
69+
public void testEntityNotExistsError() {
70+
StatusRuntimeException ex =
71+
new StatusRuntimeException(Status.NOT_FOUND.withDescription("Entity not found"));
72+
TException result = ErrorMapper.Error(ex);
73+
assertTrue(result instanceof EntityNotExistsError);
74+
}
75+
76+
@Test
77+
public void testCancellationAlreadyRequestedError() {
78+
Metadata metadata = new Metadata();
79+
metadata.put(
80+
Metadata.Key.of("rpc-application-error-name", Metadata.ASCII_STRING_MARSHALLER),
81+
"CancellationAlreadyRequestedError");
82+
StatusRuntimeException ex =
83+
new StatusRuntimeException(
84+
Status.ALREADY_EXISTS.withDescription("Cancellation already requested"), metadata);
85+
TException result = ErrorMapper.Error(ex);
86+
assertTrue(result instanceof CancellationAlreadyRequestedError);
87+
}
88+
89+
@Test
90+
public void testDomainAlreadyExistsError() {
91+
Metadata metadata = new Metadata();
92+
metadata.put(
93+
Metadata.Key.of("rpc-application-error-name", Metadata.ASCII_STRING_MARSHALLER),
94+
"DomainAlreadyExistsError");
95+
StatusRuntimeException ex =
96+
new StatusRuntimeException(
97+
Status.ALREADY_EXISTS.withDescription("Domain already exists"), metadata);
98+
TException result = ErrorMapper.Error(ex);
99+
assertTrue(result instanceof DomainAlreadyExistsError);
100+
}
101+
102+
@Test
103+
public void testWorkflowExecutionAlreadyStartedError() {
104+
Metadata metadata = new Metadata();
105+
metadata.put(
106+
Metadata.Key.of("rpc-application-error-name", Metadata.ASCII_STRING_MARSHALLER),
107+
"WorkflowExecutionAlreadyStartedError");
108+
StatusRuntimeException ex =
109+
new StatusRuntimeException(
110+
Status.ALREADY_EXISTS.withDescription("Workflow already started"), metadata);
111+
TException result = ErrorMapper.Error(ex);
112+
assertTrue(result instanceof WorkflowExecutionAlreadyStartedError);
113+
}
114+
115+
@Test
116+
public void testClientVersionNotSupportedError() {
117+
Metadata metadata = new Metadata();
118+
metadata.put(
119+
Metadata.Key.of("rpc-application-error-name", Metadata.ASCII_STRING_MARSHALLER),
120+
"ClientVersionNotSupportedError");
121+
StatusRuntimeException ex =
122+
new StatusRuntimeException(
123+
Status.FAILED_PRECONDITION.withDescription("Client version not supported"), metadata);
124+
TException result = ErrorMapper.Error(ex);
125+
assertTrue(result instanceof ClientVersionNotSupportedError);
126+
}
127+
128+
@Test
129+
public void testFeatureNotEnabledError() {
130+
Metadata metadata = new Metadata();
131+
metadata.put(
132+
Metadata.Key.of("rpc-application-error-name", Metadata.ASCII_STRING_MARSHALLER),
133+
"FeatureNotEnabledError");
134+
StatusRuntimeException ex =
135+
new StatusRuntimeException(
136+
Status.FAILED_PRECONDITION.withDescription("Feature not enabled"), metadata);
137+
TException result = ErrorMapper.Error(ex);
138+
assertTrue(result instanceof FeatureNotEnabledError);
139+
}
140+
141+
@Test
142+
public void testDomainNotActiveError() {
143+
Metadata metadata = new Metadata();
144+
metadata.put(
145+
Metadata.Key.of("rpc-application-error-name", Metadata.ASCII_STRING_MARSHALLER),
146+
"DomainNotActiveError");
147+
StatusRuntimeException ex =
148+
new StatusRuntimeException(
149+
Status.FAILED_PRECONDITION.withDescription("Domain not active"), metadata);
150+
TException result = ErrorMapper.Error(ex);
151+
assertTrue(result instanceof DomainNotActiveError);
152+
}
153+
154+
@Test
155+
public void testLimitExceededError() {
156+
Metadata metadata = new Metadata();
157+
metadata.put(
158+
Metadata.Key.of("rpc-application-error-name", Metadata.ASCII_STRING_MARSHALLER),
159+
"LimitExceededError");
160+
StatusRuntimeException ex =
161+
new StatusRuntimeException(
162+
Status.RESOURCE_EXHAUSTED.withDescription("Limit exceeded"), metadata);
163+
TException result = ErrorMapper.Error(ex);
164+
assertTrue(result instanceof LimitExceededError);
165+
}
166+
167+
@Test
168+
public void testServiceBusyError() {
169+
Metadata metadata = new Metadata();
170+
metadata.put(
171+
Metadata.Key.of("rpc-application-error-name", Metadata.ASCII_STRING_MARSHALLER),
172+
"ServiceBusyError");
173+
StatusRuntimeException ex =
174+
new StatusRuntimeException(
175+
Status.RESOURCE_EXHAUSTED.withDescription("Service busy"), metadata);
176+
TException result = ErrorMapper.Error(ex);
177+
assertTrue(result instanceof ServiceBusyError);
178+
}
179+
180+
@Test
181+
public void testUnknownError() {
182+
StatusRuntimeException ex =
183+
new StatusRuntimeException(Status.UNKNOWN.withDescription("Unknown error"));
184+
TException result = ErrorMapper.Error(ex);
185+
assertTrue(result instanceof TException);
186+
}
187+
}

0 commit comments

Comments
 (0)