{"version":3,"sources":["../../src/workers/workerRunner.ts"],"sourcesContent":["import { parentPort, workerData } from \"node:worker_threads\";\nimport type { JobTask } from \"../types/job.js\";\nimport type { WorkerBridgeRequest } from \"./workerBridge.js\";\n\nconst request = workerData as WorkerBridgeRequest;\n\nasync function run(): Promise<void> {\n  const mod = (await import(request.modulePath)) as Record<string, unknown>;\n  const worker = mod[request.exportName] as JobTask | undefined;\n  if (typeof worker !== \"function\") {\n    throw new Error(`Worker export \"${request.exportName}\" was not found or is not a function`);\n  }\n  const result = await worker({\n    jobId: request.jobId,\n    name: request.name,\n    payload: request.payload,\n    attempt: request.attempt,\n    signal: new AbortController().signal,\n    createdAt: new Date(request.createdAt),\n    startedAt: new Date(request.startedAt),\n    progress: async () => {},\n  });\n  parentPort?.postMessage({ ok: true, result });\n}\n\nrun().catch((error: unknown) => {\n  parentPort?.postMessage({\n    ok: false,\n    error: error instanceof Error ? { name: error.name, message: error.message, stack: error.stack } : error,\n  });\n});\n"],"mappings":";;;AAAA,iCAAuC;AAIvC,IAAM,UAAU;AAEhB,eAAe,MAAqB;AAClC,QAAM,MAAO,MAAM,OAAO,QAAQ;AAClC,QAAM,SAAS,IAAI,QAAQ,UAAU;AACrC,MAAI,OAAO,WAAW,YAAY;AAChC,UAAM,IAAI,MAAM,kBAAkB,QAAQ,UAAU,sCAAsC;AAAA,EAC5F;AACA,QAAM,SAAS,MAAM,OAAO;AAAA,IAC1B,OAAO,QAAQ;AAAA,IACf,MAAM,QAAQ;AAAA,IACd,SAAS,QAAQ;AAAA,IACjB,SAAS,QAAQ;AAAA,IACjB,QAAQ,IAAI,gBAAgB,EAAE;AAAA,IAC9B,WAAW,IAAI,KAAK,QAAQ,SAAS;AAAA,IACrC,WAAW,IAAI,KAAK,QAAQ,SAAS;AAAA,IACrC,UAAU,YAAY;AAAA,IAAC;AAAA,EACzB,CAAC;AACD,yCAAY,YAAY,EAAE,IAAI,MAAM,OAAO,CAAC;AAC9C;AAEA,IAAI,EAAE,MAAM,CAAC,UAAmB;AAC9B,yCAAY,YAAY;AAAA,IACtB,IAAI;AAAA,IACJ,OAAO,iBAAiB,QAAQ,EAAE,MAAM,MAAM,MAAM,SAAS,MAAM,SAAS,OAAO,MAAM,MAAM,IAAI;AAAA,EACrG,CAAC;AACH,CAAC;","names":[]}