Skip to content

Commit 8ba323f

Browse files
mkolodeznymkolodezny
authored
refactor history and decision mappers (#729)
1 parent 03cfb7a commit 8ba323f

File tree

10 files changed

+309
-2077
lines changed

10 files changed

+309
-2077
lines changed

‎src/main/java/com/uber/cadence/internal/compatibility/proto/DecisionMapper.java

Lines changed: 173 additions & 186 deletions
Large diffs are not rendered by default.

‎src/main/java/com/uber/cadence/internal/compatibility/proto/EnumMapper.java

Lines changed: 0 additions & 170 deletions
Original file line numberDiff line numberDiff line change
@@ -15,10 +15,6 @@
1515
*/
1616
package com.uber.cadence.internal.compatibility.proto;
1717

18-
import static com.uber.cadence.api.v1.CancelExternalWorkflowExecutionFailedCause.CANCEL_EXTERNAL_WORKFLOW_EXECUTION_FAILED_CAUSE_INVALID;
19-
import static com.uber.cadence.api.v1.CancelExternalWorkflowExecutionFailedCause.CANCEL_EXTERNAL_WORKFLOW_EXECUTION_FAILED_CAUSE_UNKNOWN_EXTERNAL_WORKFLOW_EXECUTION;
20-
import static com.uber.cadence.api.v1.ChildWorkflowExecutionFailedCause.CHILD_WORKFLOW_EXECUTION_FAILED_CAUSE_INVALID;
21-
import static com.uber.cadence.api.v1.ChildWorkflowExecutionFailedCause.CHILD_WORKFLOW_EXECUTION_FAILED_CAUSE_WORKFLOW_ALREADY_RUNNING;
2218
import static com.uber.cadence.api.v1.DecisionTaskFailedCause.DECISION_TASK_FAILED_CAUSE_BAD_BINARY;
2319
import static com.uber.cadence.api.v1.DecisionTaskFailedCause.DECISION_TASK_FAILED_CAUSE_BAD_CANCEL_TIMER_ATTRIBUTES;
2420
import static com.uber.cadence.api.v1.DecisionTaskFailedCause.DECISION_TASK_FAILED_CAUSE_BAD_CANCEL_WORKFLOW_EXECUTION_ATTRIBUTES;
@@ -43,78 +39,25 @@
4339
import static com.uber.cadence.api.v1.DecisionTaskFailedCause.DECISION_TASK_FAILED_CAUSE_START_TIMER_DUPLICATE_ID;
4440
import static com.uber.cadence.api.v1.DecisionTaskFailedCause.DECISION_TASK_FAILED_CAUSE_UNHANDLED_DECISION;
4541
import static com.uber.cadence.api.v1.DecisionTaskFailedCause.DECISION_TASK_FAILED_CAUSE_WORKFLOW_WORKER_UNHANDLED_FAILURE;
46-
import static com.uber.cadence.api.v1.DecisionTaskTimedOutCause.DECISION_TASK_TIMED_OUT_CAUSE_INVALID;
47-
import static com.uber.cadence.api.v1.DecisionTaskTimedOutCause.DECISION_TASK_TIMED_OUT_CAUSE_RESET;
48-
import static com.uber.cadence.api.v1.DecisionTaskTimedOutCause.DECISION_TASK_TIMED_OUT_CAUSE_TIMEOUT;
49-
import static com.uber.cadence.api.v1.DomainStatus.DOMAIN_STATUS_DELETED;
50-
import static com.uber.cadence.api.v1.DomainStatus.DOMAIN_STATUS_DEPRECATED;
51-
import static com.uber.cadence.api.v1.DomainStatus.DOMAIN_STATUS_INVALID;
52-
import static com.uber.cadence.api.v1.DomainStatus.DOMAIN_STATUS_REGISTERED;
53-
import static com.uber.cadence.api.v1.EncodingType.ENCODING_TYPE_INVALID;
54-
import static com.uber.cadence.api.v1.EncodingType.ENCODING_TYPE_JSON;
55-
import static com.uber.cadence.api.v1.EncodingType.ENCODING_TYPE_THRIFTRW;
56-
import static com.uber.cadence.api.v1.IndexedValueType.INDEXED_VALUE_TYPE_BOOL;
57-
import static com.uber.cadence.api.v1.IndexedValueType.INDEXED_VALUE_TYPE_DATETIME;
58-
import static com.uber.cadence.api.v1.IndexedValueType.INDEXED_VALUE_TYPE_DOUBLE;
59-
import static com.uber.cadence.api.v1.IndexedValueType.INDEXED_VALUE_TYPE_INT;
60-
import static com.uber.cadence.api.v1.IndexedValueType.INDEXED_VALUE_TYPE_KEYWORD;
61-
import static com.uber.cadence.api.v1.IndexedValueType.INDEXED_VALUE_TYPE_STRING;
62-
import static com.uber.cadence.api.v1.PendingActivityState.PENDING_ACTIVITY_STATE_CANCEL_REQUESTED;
63-
import static com.uber.cadence.api.v1.PendingActivityState.PENDING_ACTIVITY_STATE_INVALID;
64-
import static com.uber.cadence.api.v1.PendingActivityState.PENDING_ACTIVITY_STATE_SCHEDULED;
65-
import static com.uber.cadence.api.v1.PendingActivityState.PENDING_ACTIVITY_STATE_STARTED;
66-
import static com.uber.cadence.api.v1.PendingDecisionState.PENDING_DECISION_STATE_INVALID;
67-
import static com.uber.cadence.api.v1.PendingDecisionState.PENDING_DECISION_STATE_SCHEDULED;
68-
import static com.uber.cadence.api.v1.PendingDecisionState.PENDING_DECISION_STATE_STARTED;
6942
import static com.uber.cadence.api.v1.QueryResultType.QUERY_RESULT_TYPE_ANSWERED;
7043
import static com.uber.cadence.api.v1.QueryResultType.QUERY_RESULT_TYPE_FAILED;
7144
import static com.uber.cadence.api.v1.QueryResultType.QUERY_RESULT_TYPE_INVALID;
72-
import static com.uber.cadence.api.v1.SignalExternalWorkflowExecutionFailedCause.SIGNAL_EXTERNAL_WORKFLOW_EXECUTION_FAILED_CAUSE_INVALID;
73-
import static com.uber.cadence.api.v1.SignalExternalWorkflowExecutionFailedCause.SIGNAL_EXTERNAL_WORKFLOW_EXECUTION_FAILED_CAUSE_UNKNOWN_EXTERNAL_WORKFLOW_EXECUTION;
74-
import static com.uber.cadence.api.v1.TimeoutType.TIMEOUT_TYPE_HEARTBEAT;
75-
import static com.uber.cadence.api.v1.TimeoutType.TIMEOUT_TYPE_SCHEDULE_TO_CLOSE;
76-
import static com.uber.cadence.api.v1.TimeoutType.TIMEOUT_TYPE_SCHEDULE_TO_START;
77-
import static com.uber.cadence.api.v1.TimeoutType.TIMEOUT_TYPE_START_TO_CLOSE;
7845

7946
import com.uber.cadence.api.v1.ArchivalStatus;
80-
import com.uber.cadence.api.v1.CancelExternalWorkflowExecutionFailedCause;
81-
import com.uber.cadence.api.v1.ChildWorkflowExecutionFailedCause;
8247
import com.uber.cadence.api.v1.ContinueAsNewInitiator;
8348
import com.uber.cadence.api.v1.DecisionTaskFailedCause;
84-
import com.uber.cadence.api.v1.DecisionTaskTimedOutCause;
85-
import com.uber.cadence.api.v1.DomainStatus;
86-
import com.uber.cadence.api.v1.EncodingType;
8749
import com.uber.cadence.api.v1.EventFilterType;
88-
import com.uber.cadence.api.v1.IndexedValueType;
8950
import com.uber.cadence.api.v1.ParentClosePolicy;
90-
import com.uber.cadence.api.v1.PendingActivityState;
91-
import com.uber.cadence.api.v1.PendingDecisionState;
9251
import com.uber.cadence.api.v1.QueryConsistencyLevel;
9352
import com.uber.cadence.api.v1.QueryRejectCondition;
9453
import com.uber.cadence.api.v1.QueryResultType;
95-
import com.uber.cadence.api.v1.SignalExternalWorkflowExecutionFailedCause;
9654
import com.uber.cadence.api.v1.TaskListKind;
9755
import com.uber.cadence.api.v1.TaskListType;
98-
import com.uber.cadence.api.v1.TimeoutType;
9956
import com.uber.cadence.api.v1.WorkflowExecutionCloseStatus;
10057
import com.uber.cadence.api.v1.WorkflowIdReusePolicy;
10158

10259
class EnumMapper {
10360

104-
static DecisionTaskTimedOutCause decisionTaskTimedOutCause(
105-
com.uber.cadence.DecisionTaskTimedOutCause t) {
106-
if (t == null) {
107-
return DECISION_TASK_TIMED_OUT_CAUSE_INVALID;
108-
}
109-
switch (t) {
110-
case TIMEOUT:
111-
return DECISION_TASK_TIMED_OUT_CAUSE_TIMEOUT;
112-
case RESET:
113-
return DECISION_TASK_TIMED_OUT_CAUSE_RESET;
114-
}
115-
throw new IllegalArgumentException("unexpected enum value");
116-
}
117-
11861
static TaskListKind taskListKind(com.uber.cadence.TaskListKind t) {
11962
if (t == null) {
12063
return TaskListKind.TASK_LIST_KIND_INVALID;
@@ -344,117 +287,4 @@ static QueryResultType queryTaskCompletedType(com.uber.cadence.QueryTaskComplete
344287
throw new IllegalArgumentException("unexpected enum value");
345288
}
346289

347-
static DomainStatus domainStatus(com.uber.cadence.DomainStatus t) {
348-
if (t == null) {
349-
return DOMAIN_STATUS_INVALID;
350-
}
351-
switch (t) {
352-
case REGISTERED:
353-
return DOMAIN_STATUS_REGISTERED;
354-
case DEPRECATED:
355-
return DOMAIN_STATUS_DEPRECATED;
356-
case DELETED:
357-
return DOMAIN_STATUS_DELETED;
358-
}
359-
throw new IllegalArgumentException("unexpected enum value");
360-
}
361-
362-
static PendingActivityState pendingActivityState(com.uber.cadence.PendingActivityState t) {
363-
if (t == null) {
364-
return PENDING_ACTIVITY_STATE_INVALID;
365-
}
366-
switch (t) {
367-
case SCHEDULED:
368-
return PENDING_ACTIVITY_STATE_SCHEDULED;
369-
case STARTED:
370-
return PENDING_ACTIVITY_STATE_STARTED;
371-
case CANCEL_REQUESTED:
372-
return PENDING_ACTIVITY_STATE_CANCEL_REQUESTED;
373-
}
374-
throw new IllegalArgumentException("unexpected enum value");
375-
}
376-
377-
static IndexedValueType indexedValueType(com.uber.cadence.IndexedValueType t) {
378-
switch (t) {
379-
case STRING:
380-
return INDEXED_VALUE_TYPE_STRING;
381-
case KEYWORD:
382-
return INDEXED_VALUE_TYPE_KEYWORD;
383-
case INT:
384-
return INDEXED_VALUE_TYPE_INT;
385-
case DOUBLE:
386-
return INDEXED_VALUE_TYPE_DOUBLE;
387-
case BOOL:
388-
return INDEXED_VALUE_TYPE_BOOL;
389-
case DATETIME:
390-
return INDEXED_VALUE_TYPE_DATETIME;
391-
}
392-
throw new IllegalArgumentException("unexpected enum value");
393-
}
394-
395-
static EncodingType encodingType(com.uber.cadence.EncodingType t) {
396-
if (t == null) {
397-
return ENCODING_TYPE_INVALID;
398-
}
399-
switch (t) {
400-
case ThriftRW:
401-
return ENCODING_TYPE_THRIFTRW;
402-
case JSON:
403-
return ENCODING_TYPE_JSON;
404-
}
405-
throw new IllegalArgumentException("unexpected enum value");
406-
}
407-
408-
static TimeoutType timeoutType(com.uber.cadence.TimeoutType t) {
409-
if (t == null) {
410-
return TimeoutType.TIMEOUT_TYPE_INVALID;
411-
}
412-
switch (t) {
413-
case START_TO_CLOSE:
414-
return TIMEOUT_TYPE_START_TO_CLOSE;
415-
case SCHEDULE_TO_START:
416-
return TIMEOUT_TYPE_SCHEDULE_TO_START;
417-
case SCHEDULE_TO_CLOSE:
418-
return TIMEOUT_TYPE_SCHEDULE_TO_CLOSE;
419-
case HEARTBEAT:
420-
return TIMEOUT_TYPE_HEARTBEAT;
421-
}
422-
throw new IllegalArgumentException("unexpected enum value");
423-
}
424-
425-
static CancelExternalWorkflowExecutionFailedCause cancelExternalWorkflowExecutionFailedCause(
426-
com.uber.cadence.CancelExternalWorkflowExecutionFailedCause t) {
427-
if (t == null) {
428-
return CANCEL_EXTERNAL_WORKFLOW_EXECUTION_FAILED_CAUSE_INVALID;
429-
}
430-
switch (t) {
431-
case UNKNOWN_EXTERNAL_WORKFLOW_EXECUTION:
432-
return CANCEL_EXTERNAL_WORKFLOW_EXECUTION_FAILED_CAUSE_UNKNOWN_EXTERNAL_WORKFLOW_EXECUTION;
433-
}
434-
throw new IllegalArgumentException("unexpected enum value");
435-
}
436-
437-
static SignalExternalWorkflowExecutionFailedCause signalExternalWorkflowExecutionFailedCause(
438-
com.uber.cadence.SignalExternalWorkflowExecutionFailedCause t) {
439-
if (t == null) {
440-
return SIGNAL_EXTERNAL_WORKFLOW_EXECUTION_FAILED_CAUSE_INVALID;
441-
}
442-
switch (t) {
443-
case UNKNOWN_EXTERNAL_WORKFLOW_EXECUTION:
444-
return SIGNAL_EXTERNAL_WORKFLOW_EXECUTION_FAILED_CAUSE_UNKNOWN_EXTERNAL_WORKFLOW_EXECUTION;
445-
}
446-
throw new IllegalArgumentException("unexpected enum value");
447-
}
448-
449-
static ChildWorkflowExecutionFailedCause childWorkflowExecutionFailedCause(
450-
com.uber.cadence.ChildWorkflowExecutionFailedCause t) {
451-
if (t == null) {
452-
return CHILD_WORKFLOW_EXECUTION_FAILED_CAUSE_INVALID;
453-
}
454-
switch (t) {
455-
case WORKFLOW_ALREADY_RUNNING:
456-
return CHILD_WORKFLOW_EXECUTION_FAILED_CAUSE_WORKFLOW_ALREADY_RUNNING;
457-
}
458-
throw new IllegalArgumentException("unexpected enum value");
459-
}
460290
}

0 commit comments

Comments
 (0)