refactor(sdk): remove unused activeOperationsTracker dead code (#358)

- Remove ActiveOperationsTracker class and related files
- Update ExecutionContext type to remove activeOperationsTracker
property
- Simplify CheckpointManager constructor signature
- Simplify terminateForUnrecoverableError function
- Fix all test files with incorrect constructor parameters
- Verified build and all tests pass (2017 tests)

Author: ParidelPooya

package-lock.json

@@ -138,7 +138,7 @@ describe("initializeExecutionContext", () => {
         durableExecutionClient: mockDurableExecutionClient,
         _stepData: {},
         terminationManager: expect.any(Object),
-        activeOperationsTracker: expect.any(Object),
+
         durableExecutionArn: mockDurableExecutionArn,
         pendingCompletions: expect.any(Set),
         getStepData: expect.any(Function),

packages/aws-durable-execution-sdk-js/src/context/execution-context/execution-context.test.ts

@@ -8,7 +8,7 @@ import {
 import { log } from "../../utils/logger/logger";
 import { getStepData as getStepDataUtil } from "../../utils/step-id-utils/step-id-utils";
 import { createDefaultLogger } from "../../utils/logger/default-logger";
-import { ActiveOperationsTracker } from "../../utils/termination-helper/active-operations-tracker";
+
 import { Context } from "aws-lambda";
 import { DurableExecutionApiClient } from "../../durable-execution-api-client/durable-execution-api-client";
 import { DurableExecutionInvocationInputWithClient } from "../../utils/durable-execution-invocation-input/durable-execution-invocation-input";
@@ -84,7 +84,7 @@ export const initializeExecutionContext = async (
       durableExecutionClient,
       _stepData: stepData,
       terminationManager: new TerminationManager(),
-      activeOperationsTracker: new ActiveOperationsTracker(),
+
       durableExecutionArn,
       pendingCompletions: new Set<string>(),
       getStepData(stepId: string): Operation | undefined {

packages/aws-durable-execution-sdk-js/src/context/execution-context/execution-context.ts

@@ -18,7 +18,6 @@ const createCheckpoint = (
     {},
     context.durableExecutionClient,
     context.terminationManager,
-    undefined,
     token,
     emitter,
     logger,

packages/aws-durable-execution-sdk-js/src/termination-manager/termination-manager-checkpoint.test.ts

@@ -13,7 +13,6 @@ export const createTestCheckpointManager = (
     context._stepData,
     context.durableExecutionClient,
     context.terminationManager,
-    context.activeOperationsTracker,
     checkpointToken,
     emitter,
     logger,

packages/aws-durable-execution-sdk-js/src/testing/create-test-checkpoint-manager.ts

@@ -82,7 +82,6 @@ export function createTestDurableContext(options?: {
     },
     requestId: "mock-request-id",
     tenantId: undefined,
-    activeOperationsTracker: undefined,
   };
 
   const mockLambdaContext: Context = {

packages/aws-durable-execution-sdk-js/src/testing/create-test-durable-context.ts

@@ -20,7 +20,6 @@ export class MockCheckpointManager extends CheckpointManager {
       {},
       {} as DurableExecutionClient,
       {} as TerminationManager,
-      undefined,
       "mock-token",
       {} as EventEmitter,
       {} as DurableLogger,

packages/aws-durable-execution-sdk-js/src/testing/mock-checkpoint-manager.ts

@@ -1,7 +1,6 @@
 import { TerminationManager } from "../termination-manager/termination-manager";
 import { DurableExecutionClient } from "./durable-execution";
 import { ErrorObject, Operation } from "@aws-sdk/client-lambda";
-import { ActiveOperationsTracker } from "../utils/termination-helper/active-operations-tracker";
 
 /**
  * @internal
@@ -323,7 +322,7 @@ export interface ExecutionContext {
   _stepData: Record<string, Operation>; // Private, use getStepData() instead
   terminationManager: TerminationManager;
   durableExecutionArn: string;
-  activeOperationsTracker?: ActiveOperationsTracker;
+
   requestId: string;
   tenantId: string | undefined;
   pendingCompletions: Set<string>; // Track stepIds with pending SUCCEED/FAIL

packages/aws-durable-execution-sdk-js/src/types/core.ts

@@ -33,7 +33,6 @@ describe("CheckpointManager - Centralized Termination", () => {
       {},
       mockClient,
       mockTerminationManager,
-      undefined,
       "test-token",
       mockStepDataEmitter,
       {} as any,

packages/aws-durable-execution-sdk-js/src/utils/checkpoint/checkpoint-central-termination.test.ts

@@ -52,7 +52,6 @@ describe("Checkpoint Integration Tests", () => {
       {},
       mockState,
       { terminate: jest.fn() } as any,
-      undefined,
       TEST_CONSTANTS.CHECKPOINT_TOKEN,
       mockEmitter,
       mockLogger,
@@ -90,7 +89,6 @@ describe("Checkpoint Integration Tests", () => {
       {},
       mockState,
       { terminate: jest.fn() } as any,
-      undefined,
       TEST_CONSTANTS.CHECKPOINT_TOKEN,
       mockEmitter,
       mockLogger,
@@ -177,7 +175,6 @@ describe("Checkpoint Integration Tests", () => {
       {},
       mockState,
       { terminate: jest.fn() } as any,
-      undefined,
       TEST_CONSTANTS.CHECKPOINT_TOKEN,
       mockEmitter,
       mockLogger,
@@ -217,7 +214,6 @@ describe("Checkpoint Integration Tests", () => {
       {},
       mockState,
       { terminate: jest.fn() } as any,
-      undefined,
       TEST_CONSTANTS.CHECKPOINT_TOKEN,
       mockEmitter,
       mockLogger,
@@ -270,7 +266,6 @@ describe("Checkpoint Integration Tests", () => {
       {},
       mockState,
       { terminate: jest.fn() } as any,
-      undefined,
       TEST_CONSTANTS.CHECKPOINT_TOKEN,
       mockEmitter,
       mockLogger,
@@ -284,7 +279,6 @@ describe("Checkpoint Integration Tests", () => {
       {},
       mockState2,
       { terminate: jest.fn() } as any,
-      undefined,
       TEST_CONSTANTS.CHECKPOINT_TOKEN,
       mockEmitter,
       mockLogger,