fix formatting (#854)

Author: Assem-Uber

src/utils/data-formatters/__tests__/format-enum.test.ts

@@ -12,7 +12,7 @@ describe('formatEnum', () => {
     const input = ['PREFIX_ENUM_SNAKE_VALUE', 'PREFIX_ENUM'] as const;
     const output = formatEnum(...input);
 
-    expect(output).toEqual('snake_value');
+    expect(output).toEqual('SNAKE_VALUE');
   });
 
   it('should format enum by removing prefix and convert to pascal case when caseFormat is pascal.', () => {
@@ -23,6 +23,6 @@ describe('formatEnum', () => {
     ] as const;
     const output = formatEnum(...input);
 
-    expect(output).toEqual('pascal value');
+    expect(output).toEqual('PascalValue');
   });
 });

src/utils/data-formatters/format-enum.ts

@@ -1,4 +1,4 @@
-import flowRight from 'lodash/flowRight';
+import flow from 'lodash/flow';
 import lowerCase from 'lodash/lowerCase';
 import snakeCase from 'lodash/snakeCase';
 import startCase from 'lodash/startCase';
@@ -7,15 +7,11 @@ type Formatter = (value: string) => string;
 
 const convertToUpper: Formatter = (value: string) => value.toUpperCase();
 
-const upperSnakeCase: Formatter = flowRight([snakeCase, convertToUpper]);
+const upperSnakeCase: Formatter = flow([snakeCase, convertToUpper]);
 
 const removeWhiteSpace: Formatter = (value: string) => value.replace(/\s/g, '');
 
-const pascalCase: Formatter = flowRight([
-  lowerCase,
-  startCase,
-  removeWhiteSpace,
-]);
+const pascalCase: Formatter = flow([lowerCase, startCase, removeWhiteSpace]);
 
 // Case formatter map with strict typing
 const caseFormatterMap = {

src/utils/data-formatters/format-pending-workflow-history-event/__tests__/index.test.ts.snapshot

@@ -24,7 +24,7 @@ exports[`formatWorkflowHistoryEvent should format workflow pendingActivityTaskSt
   "scheduleId": 7,
   "scheduledTime": 1970-01-01T00:03:00.000Z,
   "startedWorkerIdentity": "worker-1",
-  "state": "scheduled",
+  "state": "Scheduled",
 }
 `;
 
@@ -52,7 +52,7 @@ exports[`formatWorkflowHistoryEvent should format workflow pendingActivityTaskSt
   "scheduleId": 7,
   "scheduledTime": 1970-01-01T00:03:00.000Z,
   "startedWorkerIdentity": "worker-1",
-  "state": "started",
+  "state": "Started",
 }
 `;
 
@@ -80,7 +80,7 @@ exports[`formatWorkflowHistoryEvent should format workflow pendingActivityTaskSt
   "scheduleId": 7,
   "scheduledTime": 1970-01-01T00:03:00.000Z,
   "startedWorkerIdentity": "worker-1",
-  "state": "cancel requested",
+  "state": "CancelRequested",
 }
 `;
 
@@ -93,7 +93,7 @@ exports[`formatWorkflowHistoryEvent should format workflow pendingDecisionTaskSt
   "scheduleId": 7,
   "scheduledTime": 1970-01-01T00:03:00.000Z,
   "startedTime": null,
-  "state": "scheduled",
+  "state": "Scheduled",
 }
 `;
 
@@ -106,6 +106,6 @@ exports[`formatWorkflowHistoryEvent should format workflow pendingDecisionTaskSt
   "scheduleId": 7,
   "scheduledTime": 1970-01-01T00:03:00.000Z,
   "startedTime": 2024-09-07T22:16:10.599Z,
-  "state": "started",
+  "state": "Started",
 }
 `;

src/utils/data-formatters/format-workflow-history-event/__tests__/index.test.ts.snapshot

@@ -117,7 +117,7 @@ exports[`formatWorkflowHistoryEvent should format workflow activityTaskTimedOutE
   "scheduledEventId": 7,
   "startedEventId": 9,
   "taskId": "22647174813",
-  "timeoutType": "TIMEOUT_TYPE_START_TO_CLOSE",
+  "timeoutType": "StartToClose",
   "timestamp": 2024-09-07T22:16:10.632Z,
   "version": "575102",
 }
@@ -528,7 +528,7 @@ exports[`formatWorkflowHistoryEvent should format workflow startChildWorkflowExe
   ],
   "jitterStart": null,
   "memo": null,
-  "parentClosePolicy": "abandon",
+  "parentClosePolicy": "ABANDON",
   "retryPolicy": null,
   "searchAttributes": null,
   "taskId": "5877269782",
@@ -540,7 +540,7 @@ exports[`formatWorkflowHistoryEvent should format workflow startChildWorkflowExe
   "timestamp": 1975-06-21T10:47:51.830Z,
   "version": "575102",
   "workflowId": "workflow.cancellation-workflow.cancellation.external-child",
-  "workflowIdReusePolicy": "allow duplicate",
+  "workflowIdReusePolicy": "AllowDuplicate",
   "workflowType": {
     "name": "workflow.cancellation.external",
   },
@@ -658,7 +658,7 @@ exports[`formatWorkflowHistoryEvent should format workflow workflowExecutionCont
   "header": {
     "fields": {},
   },
-  "initiator": "cron_schedule",
+  "initiator": "CRON_SCHEDULE",
   "input": [],
   "lastCompletionResult": null,
   "memo": null,
@@ -725,7 +725,7 @@ exports[`formatWorkflowHistoryEvent should format workflow workflowExecutionStar
     "fields": {},
   },
   "identity": null,
-  "initiator": "cron_schedule",
+  "initiator": "CRON_SCHEDULE",
   "input": [],
   "lastCompletionResult": null,
   "memo": null,

src/utils/data-formatters/format-workflow-history-event/format-activity-task-timed-out-event.ts

@@ -1,3 +1,4 @@
+import formatEnum from '../format-enum';
 import formatFailureDetails from '../format-failure-details';
 import formatPayload from '../format-payload';
 
@@ -10,13 +11,15 @@ const formatActivityTaskTimedOutEvent = ({
     lastFailure,
     scheduledEventId,
     startedEventId,
+    timeoutType,
     ...eventAttributes
   },
   ...eventFields
 }: ActivityTaskTimedOutEvent) => {
   return {
     ...formatWorkflowCommonEventFields(eventFields),
     ...eventAttributes,
+    timeoutType: formatEnum(timeoutType, 'TIMEOUT_TYPE', 'pascal'),
     details: formatPayload(details),
     lastFailureDetails: formatFailureDetails(lastFailure),
     lastFailureReason: lastFailure?.reason || '',