{"version":3,"sources":["../src/instrumentation.ts","../src/instrumentation-runtime.ts"],"sourcesContent":["import { build } from \"esbuild\";\nimport fs from \"node:fs\";\nimport path from \"node:path\";\nimport { pathToFileURL } from \"node:url\";\nimport type { FarmInstrumentationModule } from \"./instrumentation-runtime\";\n\nexport * from \"./instrumentation-runtime\";\n\nconst INSTRUMENTATION_EXTENSIONS = [\"ts\", \"mts\", \"js\", \"mjs\"] as const;\n\nexport function resolveFarmInstrumentationFile(root: string, srcDir = \"src\"): string | null {\n const candidates = [\n ...INSTRUMENTATION_EXTENSIONS.map((extension) =>\n path.join(root, srcDir, `instrumentation.${extension}`),\n ),\n ...INSTRUMENTATION_EXTENSIONS.map((extension) =>\n path.join(root, `instrumentation.${extension}`),\n ),\n ].filter((candidate) => fs.existsSync(candidate));\n\n if (candidates.length > 1) {\n throw new Error(\n `Farm.js found multiple instrumentation files:\\n${candidates\n .map((candidate) => `- ${path.relative(root, candidate)}`)\n .join(\"\\n\")}\\nKeep only one instrumentation file in the project root or ${srcDir}/.`,\n );\n }\n\n return candidates[0] ?? null;\n}\n\nexport async function loadFarmInstrumentation(\n filePath: string | null,\n root: string,\n): Promise {\n if (!filePath) return null;\n\n const outputDirectory = path.join(root, \".farm\", \".instrumentation-loader\");\n const outputFile = path.join(outputDirectory, \"instrumentation.mjs\");\n await fs.promises.mkdir(outputDirectory, { recursive: true });\n await build({\n entryPoints: [filePath],\n outfile: outputFile,\n bundle: true,\n format: \"esm\",\n platform: \"node\",\n target: \"node20\",\n packages: \"external\",\n sourcemap: \"inline\",\n });\n\n const url = pathToFileURL(outputFile);\n url.searchParams.set(\"t\", String(Date.now()));\n return (await import(url.href)) as FarmInstrumentationModule;\n}\n","export type FarmInstrumentationRuntime = \"nodejs\" | \"edge\" | \"bun\";\nexport type FarmInstrumentationMode = \"development\" | \"production\" | \"test\";\n\nexport interface FarmInstrumentationContext {\n root: string;\n mode: FarmInstrumentationMode;\n runtime: FarmInstrumentationRuntime;\n}\n\nexport type FarmInstrumentationCleanup =\n | void\n | (() => void | Promise)\n | { shutdown: () => void | Promise };\n\nexport interface FarmInstrumentationModule {\n register?: (\n context: FarmInstrumentationContext,\n ) => FarmInstrumentationCleanup | Promise;\n shutdown?: () => void | Promise;\n}\n\nexport interface FarmInstrumentationLifecycle {\n start(): Promise;\n shutdown(): Promise;\n}\n\nexport function createFarmInstrumentationLifecycle(\n module: FarmInstrumentationModule | null | undefined,\n context: FarmInstrumentationContext,\n): FarmInstrumentationLifecycle {\n let startPromise: Promise | undefined;\n let shutdownPromise: Promise | undefined;\n let cleanup: Exclude | undefined;\n\n return {\n start() {\n if (!startPromise) {\n startPromise = Promise.resolve(module?.register?.(context)).then((result) => {\n cleanup = result || undefined;\n });\n }\n return startPromise;\n },\n shutdown() {\n if (!shutdownPromise) {\n shutdownPromise = (async () => {\n try {\n await startPromise;\n } catch {\n // A partially initialized module may still need its exported cleanup.\n }\n try {\n if (typeof cleanup === \"function\") {\n await cleanup();\n } else if (cleanup?.shutdown) {\n await cleanup.shutdown();\n }\n } finally {\n if (module?.shutdown) {\n await module.shutdown();\n }\n }\n })();\n }\n return shutdownPromise;\n },\n };\n}\n\nexport function resolveFarmInstrumentationRuntime(preset?: string): FarmInstrumentationRuntime {\n const normalized = preset?.toLowerCase() ?? \"\";\n if (\n normalized.includes(\"cloudflare\") ||\n normalized.includes(\"worker\") ||\n normalized.includes(\"edge\")\n ) {\n return \"edge\";\n }\n if (normalized.includes(\"bun\")) return \"bun\";\n return \"nodejs\";\n}\n"],"mappings":";;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;AAAA;AAAA;AAAA;AAAA;AAAA;AAAA;AAAA;AAAA;AAAA,qBAAsB;AACtB,qBAAe;AACf,uBAAiB;AACjB,sBAA8B;;;ACuBvB,SAAS,mCACdA,SACA,SAC8B;AAC9B,MAAI;AACJ,MAAI;AACJ,MAAI;AAEJ,SAAO;AAAA,IACL,QAAQ;AACN,UAAI,CAAC,cAAc;AACjB,uBAAe,QAAQ,QAAQA,SAAQ,WAAW,OAAO,CAAC,EAAE,KAAK,CAAC,WAAW;AAC3E,oBAAU,UAAU;AAAA,QACtB,CAAC;AAAA,MACH;AACA,aAAO;AAAA,IACT;AAAA,IACA,WAAW;AACT,UAAI,CAAC,iBAAiB;AACpB,2BAAmB,YAAY;AAC7B,cAAI;AACF,kBAAM;AAAA,UACR,QAAQ;AAAA,UAER;AACA,cAAI;AACF,gBAAI,OAAO,YAAY,YAAY;AACjC,oBAAM,QAAQ;AAAA,YAChB,WAAW,SAAS,UAAU;AAC5B,oBAAM,QAAQ,SAAS;AAAA,YACzB;AAAA,UACF,UAAE;AACA,gBAAIA,SAAQ,UAAU;AACpB,oBAAMA,QAAO,SAAS;AAAA,YACxB;AAAA,UACF;AAAA,QACF,GAAG;AAAA,MACL;AACA,aAAO;AAAA,IACT;AAAA,EACF;AACF;AAzCgB;AA2CT,SAAS,kCAAkC,QAA6C;AAC7F,QAAM,aAAa,QAAQ,YAAY,KAAK;AAC5C,MACE,WAAW,SAAS,YAAY,KAChC,WAAW,SAAS,QAAQ,KAC5B,WAAW,SAAS,MAAM,GAC1B;AACA,WAAO;AAAA,EACT;AACA,MAAI,WAAW,SAAS,KAAK,EAAG,QAAO;AACvC,SAAO;AACT;AAXgB;;;AD7DhB,IAAM,6BAA6B,CAAC,MAAM,OAAO,MAAM,KAAK;AAErD,SAAS,+BAA+B,MAAc,SAAS,OAAsB;AAC1F,QAAM,aAAa;AAAA,IACjB,GAAG,2BAA2B;AAAA,MAAI,CAAC,cACjC,iBAAAC,QAAK,KAAK,MAAM,QAAQ,mBAAmB,SAAS,EAAE;AAAA,IACxD;AAAA,IACA,GAAG,2BAA2B;AAAA,MAAI,CAAC,cACjC,iBAAAA,QAAK,KAAK,MAAM,mBAAmB,SAAS,EAAE;AAAA,IAChD;AAAA,EACF,EAAE,OAAO,CAAC,cAAc,eAAAC,QAAG,WAAW,SAAS,CAAC;AAEhD,MAAI,WAAW,SAAS,GAAG;AACzB,UAAM,IAAI;AAAA,MACR;AAAA,EAAkD,WAC/C,IAAI,CAAC,cAAc,KAAK,iBAAAD,QAAK,SAAS,MAAM,SAAS,CAAC,EAAE,EACxD,KAAK,IAAI,CAAC;AAAA,4DAA+D,MAAM;AAAA,IACpF;AAAA,EACF;AAEA,SAAO,WAAW,CAAC,KAAK;AAC1B;AAnBgB;AAqBhB,eAAsB,wBACpB,UACA,MAC2C;AAC3C,MAAI,CAAC,SAAU,QAAO;AAEtB,QAAM,kBAAkB,iBAAAA,QAAK,KAAK,MAAM,SAAS,yBAAyB;AAC1E,QAAM,aAAa,iBAAAA,QAAK,KAAK,iBAAiB,qBAAqB;AACnE,QAAM,eAAAC,QAAG,SAAS,MAAM,iBAAiB,EAAE,WAAW,KAAK,CAAC;AAC5D,YAAM,sBAAM;AAAA,IACV,aAAa,CAAC,QAAQ;AAAA,IACtB,SAAS;AAAA,IACT,QAAQ;AAAA,IACR,QAAQ;AAAA,IACR,UAAU;AAAA,IACV,QAAQ;AAAA,IACR,UAAU;AAAA,IACV,WAAW;AAAA,EACb,CAAC;AAED,QAAM,UAAM,+BAAc,UAAU;AACpC,MAAI,aAAa,IAAI,KAAK,OAAO,KAAK,IAAI,CAAC,CAAC;AAC5C,SAAQ,MAAM,OAAO,IAAI;AAC3B;AAvBsB;","names":["module","path","fs"]}