Make Shipment Sync Reliable

Problem/Feature Description

Operations runs a TypeScript job that syncs shipment status from a carrier API into the local system. When the carrier is slow, the job can hang. When the carrier returns intermittent failures, the job either hides the problem or writes partial results in unpredictable order.

Refactor the job so it can be exercised reliably in tests and so failures are visible enough for operators to act on. Keep the behavior focused on shipment synchronization rather than rebuilding the whole app.

Output Specification

Produce a TypeScript project in the current directory. Include updated source files and focused tests for successful syncs, carrier timeouts, retryable failures, and non-retryable failures.

Input Files

The following files are provided as inputs. Extract them before beginning.

=============== FILE: AGENTS.md ===============

Project Instructions

• Application modules use named exports.
• Tests use Vitest.
• Keep job code under src/jobs/.
• Keep external integrations under src/integrations/.

=============== FILE: package.json =============== { "type": "module", "scripts": { "test": "vitest run", "typecheck": "tsc --noEmit" }, "devDependencies": { "@types/node": "^20.14.10", "typescript": "^5.5.3", "vitest": "^2.0.4" } }

=============== FILE: tsconfig.json =============== { "compilerOptions": { "target": "ES2022", "module": "NodeNext", "moduleResolution": "NodeNext", "strict": true, "exactOptionalPropertyTypes": true, "skipLibCheck": true }, "include": ["src/**/*.ts"] }

=============== FILE: src/jobs/syncShipments.ts =============== type Shipment = { id: string; carrierTrackingId: string; status?: string; };

let lastSyncedIds: string[] = [];

async function helper(trackingId: string) { return fetch("https://carrier.example/status/" + trackingId).then((response) => response.json()); }

async function saveStatus(id: string, status: string) { console.log("saved", id, status); }

export async function syncShipments(shipments: Shipment[]) { shipments.forEach(async (shipment) => { try { const carrierStatus = await helper(shipment.carrierTrackingId); if (carrierStatus.status) { await saveStatus(shipment.id, carrierStatus.status); lastSyncedIds.push(shipment.id); } } catch (error) { console.warn("ignored carrier failure"); } });

return lastSyncedIds; }