Route events to workers

Entry point and worker routing

A CommonJS-oriented extraction entry point under code/src/functions/extraction/index.ts uses the public SDK and the bundled template mapping. Stateful initialization requires a valid IDM when its version state is missing or changes:

import { AirSyncEvent, spawn } from '@devrev/airsync-sdk';
import initialDomainMapping from '../external-system/initial_domain_mapping.json';

type ConnectorState = { cursor: string | null; completed: boolean };

export async function run(events: AirSyncEvent[]): Promise<void> {
  for (const event of events) {
    await spawn<ConnectorState>({
      event,
      initialState: { cursor: null, completed: false },
      initialDomainMapping,
      baseWorkerPath: __dirname,
      options: { timeout: 60_000, batchSize: 2_000 },
    });
  }
}

baseWorkerPath is the directory containing workers/. Package compiled worker files with the snap-in. workerPathOverrides maps incoming EventType values to path suffixes (for example /workers/cleanup.js) appended to that base when a custom layout or deletion worker is needed. Follow the public template layout for bundle and manifest wiring.

A missing metadata worker is a configuration error. Do not assume a misspelled or unbundled required worker will complete successfully.

Related:

• Worker results and errors.
• Connector state.
• Worker timeouts.