feat: Create a grouping utility that only parses new events (#1065)

* grouping utility

Signed-off-by: Assem Hafez <assem.hafez@uber.com>

* update test cases

Signed-off-by: Assem Hafez <assem.hafez@uber.com>

* change the api of onChange and add destroy method

Signed-off-by: Assem Hafez <assem.hafez@uber.com>

* replace getGroups with getState

Signed-off-by: Assem Hafez <assem.hafez@uber.com>

* call onchange after updating pending events

Signed-off-by: Assem Hafez <assem.hafez@uber.com>

* use sync processBatch for first page

Signed-off-by: Assem Hafez <assem.hafez@uber.com>

* Update src/views/workflow-history/helpers/workflow-history-grouper.ts

Co-authored-by: Copilot <175728472+Copilot@users.noreply.github.com>

* Apply PR comments

* Update src/views/workflow-history/helpers/workflow-history-grouper.types.ts

Co-authored-by: Copilot <175728472+Copilot@users.noreply.github.com>

---------

Signed-off-by: Assem Hafez <assem.hafez@uber.com>
Co-authored-by: Copilot <175728472+Copilot@users.noreply.github.com>

Author: Assem-Uber

src/views/workflow-history/__fixtures__/workflow-history-pending-events.ts

@@ -3,6 +3,9 @@ import type {
   PendingDecisionTaskStartEvent,
 } from '../workflow-history.types';
 
+import { scheduleActivityTaskEvent } from './workflow-history-activity-events';
+import { scheduleDecisionTaskEvent } from './workflow-history-decision-events';
+
 export const pendingActivityTaskStartEvent = {
   eventId: null,
   computedEventId: 'pending-7',
@@ -94,3 +97,54 @@ export const pendingDecisionTaskStartEventWithStartedState = {
     },
   },
 } as const satisfies PendingDecisionTaskStartEvent;
+
+// Factory functions for creating test data dynamically
+
+export function createPendingActivity(
+  scheduleId: string,
+  options?: { activityId?: string }
+): PendingActivityTaskStartEvent {
+  return {
+    ...pendingActivityTaskStartEvent,
+    computedEventId: `pending-${scheduleId}`,
+    pendingActivityTaskStartEventAttributes: {
+      ...pendingActivityTaskStartEvent.pendingActivityTaskStartEventAttributes,
+      scheduleId,
+      ...(options?.activityId && { activityId: options.activityId }),
+    },
+  } as PendingActivityTaskStartEvent;
+}
+
+export function createPendingDecision(
+  scheduleId: string
+): PendingDecisionTaskStartEvent {
+  return {
+    ...pendingDecisionTaskStartEvent,
+    computedEventId: `pending-${scheduleId}`,
+    pendingDecisionTaskStartEventAttributes: {
+      ...pendingDecisionTaskStartEvent.pendingDecisionTaskStartEventAttributes,
+      scheduleId,
+    },
+  } as PendingDecisionTaskStartEvent;
+}
+
+export function createScheduleActivityEvent(
+  eventId: string,
+  options?: { activityId?: string }
+) {
+  return {
+    ...scheduleActivityTaskEvent,
+    eventId,
+    activityTaskScheduledEventAttributes: {
+      ...scheduleActivityTaskEvent.activityTaskScheduledEventAttributes,
+      ...(options?.activityId && { activityId: options.activityId }),
+    },
+  };
+}
+
+export function createScheduleDecisionEvent(eventId: string) {
+  return {
+    ...scheduleDecisionTaskEvent,
+    eventId,
+  };
+}