{"version":3,"sources":["../src/babel/mastra-instance-wrapper.ts","../src/plugins/mastra-instance-wrapper.ts","../src/babel/postgres-store-instance-checker.ts","../src/plugins/postgres-store-instance-checker.ts","../src/index.ts"],"names":["babel","mastraInstanceWrapper","transformSync","babel2","postgresStoreInstanceChecker","builtinModules","Deployer","writeFile","join","relative","virtual"],"mappings":";;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;AAwBO,SAAS,qBAAA,GAAmC;AACjD,EAAA,MAAM,UAAA,GAAa,QAAA;AACnB,EAAA,MAAM,SAAA,GAAY,QAAA;AAClB,EAAA,MAAM,CAAA,GAAUA,gBAAA,CAAA,KAAA;AAEhB,EAAA,OAAO;AAAA,IACL,IAAA,EAAM,aAAA;AAAA,IACN,OAAA,EAAS;AAAA,MACP,uBAAuB,IAAA,EAAM;AAC3B,QAAA,IAAI,CAAA,CAAE,qBAAA,CAAsB,IAAA,CAAK,IAAA,EAAM,WAAW,CAAA,EAAG;AACnD,UAAA,KAAA,MAAW,WAAA,IAAe,IAAA,CAAK,IAAA,CAAK,WAAA,CAAY,YAAA,EAAc;AAC5D,YAAA,IACE,CAAA,CAAE,aAAa,WAAA,EAAa,EAAA,EAAI,EAAE,IAAA,EAAM,UAAA,EAAY,CAAA,IACpD,CAAA,CAAE,eAAA,CAAgB,aAAa,IAAI,CAAA,IACnC,CAAA,CAAE,YAAA,CAAa,WAAA,CAAY,IAAA,CAAK,QAAQ,EAAE,IAAA,EAAM,SAAA,EAAW,CAAA,EAC3D;AACA,cAAA,WAAA,CAAY,OAAO,CAAA,CAAE,uBAAA,CAAwB,EAAC,EAAG,YAAY,IAAI,CAAA;AAEjE,cAAA;AAAA,YACF;AAAA,UACF;AAAA,QACF;AAAA,MACF;AAAA;AACF,GACF;AACF;;;AC7CO,SAASC,uBAAsB,eAAA,EAAiC;AACrE,EAAA,OAAO;AAAA,IACL,IAAA,EAAM,gBAAA;AAAA,IACN,SAAA,CAAU,MAAM,EAAA,EAAI;AAClB,MAAA,IAAI,OAAO,eAAA,EAAiB;AAC1B,QAAA,OAAO,IAAA;AAAA,MACT;AAEA,MAAA,MAAM,MAAA,GAASC,oBAAc,IAAA,EAAM;AAAA,QACjC,QAAA,EAAU,EAAA;AAAA,QACV,OAAA,EAAS,KAAA;AAAA,QACT,UAAA,EAAY,KAAA;AAAA,QACZ,OAAA,EAAS,CAAC,qBAA0B;AAAA,OACrC,CAAA;AAED,MAAA,IAAI,CAAC,QAAQ,IAAA,EAAM;AACjB,QAAA,MAAM,IAAI,MAAM,iFAAiF,CAAA;AAAA,MACnG;AAEA,MAAA,OAAO;AAAA,QACL,MAAM,MAAA,CAAO,IAAA;AAAA,QACb,KAAK,MAAA,EAAQ;AAAA,OACf;AAAA,IACF;AAAA,GACF;AACF;ACPO,SAAS,4BAAA,GAA0C;AACxD,EAAA,MAAM,CAAA,GAAUC,gBAAA,CAAA,KAAA;AAChB,EAAA,MAAM,YAAmE,EAAC;AAE1E,EAAA,OAAO;AAAA,IACL,IAAA,EAAM,gCAAA;AAAA,IACN,OAAA,EAAS;AAAA,MACP,aAAA,CAAc,MAAM,KAAA,EAAO;AACzB,QAAA,IAAI,CAAA,CAAE,YAAA,CAAa,IAAA,CAAK,IAAA,CAAK,MAAM,KAAK,IAAA,CAAK,IAAA,CAAK,MAAA,CAAO,IAAA,KAAS,eAAA,EAAiB;AACjF,UAAA,MAAM,QAAA,GAAW,KAAA,CAAM,IAAA,EAAM,IAAA,EAAM,QAAA,IAAY,cAAA;AAC/C,UAAA,MAAM,WAAW,IAAA,CAAK,IAAA,CAAK,MACvB,CAAA,EAAG,QAAQ,UAAU,IAAA,CAAK,IAAA,CAAK,GAAA,CAAI,KAAA,CAAM,IAAI,CAAA,SAAA,EAAY,IAAA,CAAK,KAAK,GAAA,CAAI,KAAA,CAAM,MAAM,CAAA,CAAA,GACnF,kBAAA;AAEJ,UAAA,SAAA,CAAU,IAAA,CAAK;AAAA,YACb,IAAA;AAAA,YACA;AAAA,WACD,CAAA;AAAA,QACH;AAAA,MACF;AAAA,KACF;AAAA,IACA,IAAA,GAAO;AACL,MAAA,IAAI,SAAA,CAAU,SAAS,CAAA,EAAG;AACxB,QAAA,MAAM,YAAA,GAAe;AAAA,UACnB,CAAA,MAAA,EAAS,UAAU,MAAM,CAAA,8BAAA,CAAA;AAAA,UACzB,GAAG,SAAA,CAAU,GAAA,CAAI,CAAC,QAAA,EAAU,CAAA,KAAM,CAAA,EAAA,EAAK,CAAA,GAAI,CAAC,CAAA,KAAA,EAAQ,QAAA,CAAS,QAAQ,CAAA,CAAE,CAAA;AAAA,UACvE;AAAA,SACF,CAAE,KAAK,IAAI,CAAA;AAEX,QAAA,MAAM,YAAA,GAAe,SAAA,CAAU,SAAA,CAAU,MAAA,GAAS,CAAC,CAAA;AACnD,QAAA,MAAM,YAAA,EAAc,IAAA,CAAK,mBAAA,CAAoB,YAAY,CAAA;AAAA,MAC3D;AAAA,IACF;AAAA,GACF;AACF;;;ACpDO,SAASC,6BAAAA,GAAuC;AACrD,EAAA,OAAO;AAAA,IACL,IAAA,EAAM,iCAAA;AAAA,IACN,SAAA,CAAU,MAAM,EAAA,EAAI;AAClB,MAAA,MAAM,MAAA,GAASF,oBAAc,IAAA,EAAM;AAAA,QACjC,QAAA,EAAU,EAAA;AAAA,QACV,OAAA,EAAS,KAAA;AAAA,QACT,UAAA,EAAY,KAAA;AAAA,QACZ,OAAA,EAAS,CAAC,4BAAiC;AAAA,OAC5C,CAAA;AAGD,MAAA,IAAI,CAAC,MAAA,IAAU,OAAO,MAAA,CAAO,SAAS,QAAA,EAAU;AAC9C,QAAA,OAAO,IAAA;AAAA,MACT;AAEA,MAAA,OAAO;AAAA,QACL,MAAM,MAAA,CAAO,IAAA;AAAA,QACb,GAAA,EAAK,OAAO,GAAA,IAAO;AAAA,OACrB;AAAA,IACF;AAAA,GACF;AACF;;;ACdA,IAAM,YAAA,GAAe,IAAI,GAAA,CAAIG,uBAAc,CAAA;AAO3C,SAAS,oBAAA,GAA+B;AACtC,EAAA,OAAO;AAAA,IACL,IAAA,EAAM,wBAAA;AAAA,IACN,UAAU,EAAA,EAAI;AACZ,MAAA,IAAI,YAAA,CAAa,GAAA,CAAI,EAAE,CAAA,EAAG;AACxB,QAAA,OAAO,EAAE,EAAA,EAAI,QAAA,EAAU,IAAA,EAAK;AAAA,MAC9B;AACA,MAAA,OAAO,IAAA;AAAA,IACT;AAAA,GACF;AACF;AAgBO,IAAM,kBAAA,GAAN,cAAiCC,iBAAA,CAAS;AAAA,EACtC,UAAA;AAAA,EAET,YACE,UAAA,EAYA;AACA,IAAA,KAAA,CAAM,EAAE,IAAA,EAAM,YAAA,EAAc,CAAA;AAM5B,IAAA,IAAA,CAAK,QAAA,GAAW,SAAA;AAEhB,IAAA,IAAA,CAAK,UAAA,GAAa,EAAE,GAAG,UAAA,EAAW;AAElC,IAAA,IAAI,WAAW,eAAA,EAAiB;AAC9B,MAAA,OAAA,CAAQ,KAAK,2DAA2D,CAAA;AAAA,IAC1E;AACA,IAAA,IAAI,CAAC,UAAA,CAAW,IAAA,IAAQ,UAAA,CAAW,WAAA,EAAa;AAC9C,MAAA,IAAA,CAAK,UAAA,CAAW,OAAO,UAAA,CAAW,WAAA;AAClC,MAAA,OAAA,CAAQ,KAAK,uEAAuE,CAAA;AAAA,IACtF;AACA,IAAA,IAAI,CAAC,UAAA,CAAW,YAAA,IAAgB,UAAA,CAAW,WAAA,EAAa;AACtD,MAAA,IAAA,CAAK,UAAA,CAAW,eAAe,UAAA,CAAW,WAAA;AAC1C,MAAA,OAAA,CAAQ,KAAK,+EAA+E,CAAA;AAAA,IAC9F;AACA,IAAA,IAAI,CAAC,UAAA,CAAW,aAAA,IAAiB,UAAA,CAAW,YAAA,EAAc;AACxD,MAAA,IAAA,CAAK,UAAA,CAAW,gBAAgB,UAAA,CAAW,YAAA;AAC3C,MAAA,OAAA,CAAQ,KAAK,iFAAiF,CAAA;AAAA,IAChG;AAAA,EACF;AAAA,EAEA,MAAM,WAAW,eAAA,EAAwC;AACvD,IAAA,MAAM;AAAA,MACJ,IAAA,EAAM,QAAA;AAAA,MACN,KAAA,EAAO,SAAA;AAAA;AAAA,MAEP,WAAA,EAAa,YAAA;AAAA,MACb,eAAA,EAAiB,gBAAA;AAAA,MACjB,WAAA,EAAa,YAAA;AAAA,MACb,YAAA,EAAc,aAAA;AAAA,MACd,GAAG;AAAA,QACD,IAAA,CAAK,UAAA;AAMT,IAAA,MAAM,aAAA,GAAgB,MAAM,IAAA,CAAK,WAAA,EAAY;AAC7C,IAAA,MAAM,YAAA,GAAe,MAAA,CAAO,MAAA,CAAO,IAAI,QAAQ,CAAA;AAE/C,IAAA,IAAI,aAAA,CAAc,OAAO,CAAA,EAAG;AAC1B,MAAA,MAAM,OAAA,GAAU,CAAC,GAAG,aAAA,CAAc,MAAM,CAAA,CAAE,KAAK,IAAI,CAAA;AACnD,MAAA,IAAA,CAAK,MAAA,CAAO,IAAA;AAAA,QACV,oCAAoC,OAAO,CAAA;AAAA;AAAA,6BAAA;AAAA,OAG7C;AAAA,IACF;AAMA,IAAA,MAAM,kBAAA,GAAqB,qBAAA;AAC3B,IAAA,MAAM,cAAA,GAAiB,CAAA;AAAA;AAAA;AAAA;AAAA;AAAA;AAAA;AAAA;AAAA;AAAA;AAAA;AAAA;AAAA;AAAA;AAAA;AAAA;AAAA;AAAA,CAAA;AAmBvB,IAAA,MAAMC,mBAAUC,SAAA,CAAK,eAAA,EAAiB,KAAK,SAAA,EAAW,kBAAkB,GAAG,cAAc,CAAA;AAIzF,IAAA,MAAM,aAAA,GAAgB,gBAAA;AACtB,IAAA,MAAM,SAAA,GAAY,CAAA;AAAA;AAAA;AAAA;AAAA;AAAA;AAAA;AAAA,CAAA;AAQlB,IAAA,MAAMD,mBAAUC,SAAA,CAAK,eAAA,EAAiB,KAAK,SAAA,EAAW,aAAa,GAAG,SAAS,CAAA;AAM/E,IAAA,MAAM,sBAAA,GAAyB,0BAAA;AAC/B,IAAA,MAAM,kBAAA,GAAqB,CAAA;AAAA;AAAA;AAAA;AAAA,CAAA;AAK3B,IAAA,MAAMD,mBAAUC,SAAA,CAAK,eAAA,EAAiB,KAAK,SAAA,EAAW,sBAAsB,GAAG,kBAAkB,CAAA;AAEjG,IAAA,MAAM,cAAA,GAAqC;AAAA,MACzC,IAAA,EAAM,QAAA;AAAA,MACN,kBAAA,EAAoB,YAAA;AAAA,MACpB,mBAAA,EAAqB,CAAC,eAAA,EAAiB,oCAAoC,CAAA;AAAA,MAC3E,aAAA,EAAe;AAAA,QACb,IAAA,EAAM;AAAA,UACJ,OAAA,EAAS;AAAA;AACX,OACF;AAAA,MACA,GAAG,UAAA;AAAA,MACH,IAAA,EAAM,aAAA;AAAA,MACN,IAAA,EAAM,YAAA;AAAA;AAAA,MAEN,KAAA,EAAO;AAAA,QACL,UAAA,EAAY,KAAK,kBAAkB,CAAA,CAAA;AAAA,QACnC,KAAA,EAAO,KAAK,aAAa,CAAA,CAAA;AAAA,QACzB,iBAAA,EAAmB,KAAK,sBAAsB,CAAA,CAAA;AAAA,QAC9C,GAAG;AAAA;AACL,KACF;AAGA,IAAA,MAAMD,kBAAA,CAAUC,SAAA,CAAK,eAAA,EAAiB,IAAA,CAAK,SAAA,EAAW,eAAe,CAAA,EAAG,IAAA,CAAK,SAAA,CAAU,cAAA,EAAgB,IAAA,EAAM,CAAC,CAAC,CAAA;AAE/G,IAAA,MAAM,WAAA,GAAcA,SAAA,CAAK,eAAA,EAAiB,KAAK,CAAA;AAC/C,IAAA,MAAM,aAAA,GAAgBA,SAAA,CAAK,WAAA,EAAa,gBAAgB,CAAA;AACxD,IAAA,MAAM,YAAA,GAAeA,SAAA,CAAK,eAAA,EAAiB,IAAA,CAAK,WAAW,WAAW,CAAA;AACtE,IAAA,MAAM,cAAA,GAAiBA,SAAA,CAAK,eAAA,EAAiB,IAAA,CAAK,WAAW,kBAAkB,CAAA;AAE/E,IAAA,MAAM,mBAAA,GAAoE;AAAA,MACxE,WAAA,EAAa,aAAA;AAAA,MACb,OAAA,EAAS,4CAAA;AAAA,MACT,GAAG,cAAA;AAAA,MACH,IAAA,EAAM,CAAA,EAAA,EAAKC,aAAA,CAAS,WAAA,EAAa,YAAY,CAAC,CAAA,CAAA;AAAA,MAC9C,KAAA,EAAO;AAAA,QACL,GAAG,cAAA,CAAe,KAAA;AAAA,QAClB,UAAA,EAAY,CAAA,EAAA,EAAKA,aAAA,CAAS,WAAA,EAAa,cAAc,CAAC,CAAA;AAAA;AACxD,KACF;AAEA,IAAA,MAAM,QAAQ,IAAA,CAAK,SAAA,CAAU,mBAAA,EAAqB,IAAA,EAAM,CAAC,CAAA,CAAE,OAAA;AAAA,MACzD,+BAAA;AAAA,MACA;AAAA,KACF;AACA,IAAA,MAAMF,kBAAA,CAAU,eAAe,KAAK,CAAA;AAAA,EACtC;AAAA,EAEQ,QAAA,GAAmB;AACzB,IAAA,OAAO;AAAA;AAAA;;AAAA;AAAA;AAAA;AAAA;AAAA;AAAA;;AAAA;AAAA;AAAA;;AAAA;AAAA;AAAA;AAAA;AAAA,CAAA;AAAA,EAoBT;AAAA,EACA,MAAM,QAAQ,eAAA,EAAwC;AACpD,IAAA,MAAM,KAAA,CAAM,QAAQ,eAAe,CAAA;AACnC,IAAA,MAAM,IAAA,CAAK,WAAW,eAAe,CAAA;AAAA,EACvC;AAAA,EAEA,MAAgB,iBAAA,CACd,UAAA,EACA,eAAA,EACA,kBAAA,EACA,YACA,cAAA,EACA;AACA,IAAA,MAAM,eAAe,MAAM,KAAA,CAAM,kBAAkB,UAAA,EAAY,eAAA,EAAiB,oBAAoB,UAAA,EAAY;AAAA,MAC9G,GAAG,cAAA;AAAA,MACH,aAAA,EAAe;AAAA,KAChB,CAAA;AAED,IAAA,MAAM,gBAAA,GAAoB,MAAM,IAAA,CAAK,IAAA,CAAK,kBAAkB,CAAC,YAAY,CAAC,CAAA,KAAO,CAAA,EAAA,CAAA;AAEjF,IAAA,IAAI,KAAA,CAAM,OAAA,CAAQ,YAAA,CAAa,OAAO,CAAA,EAAG;AACvC,MAAA,YAAA,CAAa,OAAA,GAAU;AAAA,QACrB,oBAAA,EAAqB;AAAA,QACrBG,wBAAA,CAAQ;AAAA,UACN,YAAA,EAAc;AAAA;AAAA,yBAAA,EAEG,OAAA,CAAQ,SAAS,IAAI,CAAA;AAAA,MAAA;AAAA,SAEvC,CAAA;AAAA,QACD,GAAG,YAAA,CAAa,OAAA;AAAA,QAChBT,uBAAsB,eAAe;AAAA,OACvC;AAEA,MAAA,IAAI,gBAAA,EAAkB;AACpB,QAAA,YAAA,CAAa,OAAA,CAAQ,IAAA,CAAKG,6BAAAA,EAA8B,CAAA;AAAA,MAC1D;AAAA,IACF;AAEA,IAAA,OAAO,YAAA;AAAA,EACT;AAAA,EAEA,MAAM,MAAA,CACJ,SAAA,EACA,iBACA,EAAE,UAAA,EAAY,aAAY,EACX;AACf,IAAA,OAAO,IAAA,CAAK,OAAA,CAAQ,IAAA,CAAK,QAAA,EAAS,EAAG,SAAA,EAAW,EAAE,eAAA,EAAiB,WAAA,EAAa,aAAA,EAAe,KAAA,EAAM,EAAG,UAAU,CAAA;AAAA,EACpH;AAAA,EAEA,MAAM,MAAA,GAAwB;AAC5B,IAAA,IAAA,CAAK,MAAA,EAAQ,KAAK,gFAAgF,CAAA;AAAA,EACpG;AAAA;AAAA;AAAA;AAAA;AAAA;AAAA,EAOA,MAAM,SAAA,GAA2B;AAC/B,IAAA,MAAM,IAAI,MAAM,wFAAwF,CAAA;AAAA,EAC1G;AAAA,EAEA,MAAM,IAAA,CAAK,SAAA,EAAmB,eAAA,EAAyB,UAAA,EAAkD;AACvG,IAAA,MAAM,KAAA,CAAM,IAAA,CAAK,SAAA,EAAW,eAAA,EAAiB,UAAU,CAAA;AAEvD,IAAA,MAAM,SAAA,GAAa,MAAM,IAAA,CAAK,IAAA,CAAK,kBAAkB,CAAC,gBAAgB,CAAC,CAAA,KAAO,CAAA,EAAA,CAAA;AAE9E,IAAA,IAAI,SAAA,EAAW;AACb,MAAA,IAAA,CAAK,MAAA,CAAO,KAAA;AAAA,QACV;AAAA,OACF;AACA,MAAA,OAAA,CAAQ,KAAK,CAAC,CAAA;AAAA,IAChB;AAAA,EACF;AACF","file":"index.cjs","sourcesContent":["import type { PluginObj } from '@babel/core';\nimport * as babel from '@babel/core';\n\n/**\n * Babel plugin that transforms Mastra exports for Cloudflare Workers compatibility.\n *\n * This plugin:\n * 1. Identifies named exports of the 'mastra' variable\n * 2. Checks if the export is a new instance of the 'Mastra' class\n * 3. Wraps the Mastra instantiation in an arrow function to ensure proper initialization\n * in the Cloudflare Workers environment\n *\n * The transformation ensures the Mastra instance is properly scoped and initialized\n * for each request in the Cloudflare Workers environment.\n *\n * @returns {PluginObj} A Babel plugin object with a visitor that performs the transformation\n *\n * @example\n * // Before transformation:\n * export const mastra = new Mastra();\n *\n * // After transformation:\n * export const mastra = () => new Mastra();\n */\nexport function mastraInstanceWrapper(): PluginObj {\n const exportName = 'mastra';\n const className = 'Mastra';\n const t = babel.types;\n\n return {\n name: 'wrap-mastra',\n visitor: {\n ExportNamedDeclaration(path) {\n if (t.isVariableDeclaration(path.node?.declaration)) {\n for (const declaration of path.node.declaration.declarations) {\n if (\n t.isIdentifier(declaration?.id, { name: exportName }) &&\n t.isNewExpression(declaration?.init) &&\n t.isIdentifier(declaration.init.callee, { name: className })\n ) {\n declaration.init = t.arrowFunctionExpression([], declaration.init);\n // there should be only one \"mastra\" export, so we can exit the loop\n break;\n }\n }\n }\n },\n },\n } as PluginObj;\n}\n","import { transformSync } from '@babel/core';\nimport type { Plugin } from 'rollup';\nimport { mastraInstanceWrapper as mastraInstanceWrapperBabel } from '../babel/mastra-instance-wrapper';\n\nexport function mastraInstanceWrapper(mastraEntryFile: string): Plugin {\n return {\n name: 'mastra-wrapper',\n transform(code, id) {\n if (id !== mastraEntryFile) {\n return null;\n }\n\n const result = transformSync(code, {\n filename: id,\n babelrc: false,\n configFile: false,\n plugins: [mastraInstanceWrapperBabel],\n });\n\n if (!result?.code) {\n throw new Error('mastra-wrapper plugin did not return code, there is likely a bug in the plugin.');\n }\n\n return {\n code: result.code,\n map: result?.map,\n };\n },\n };\n}\n","import type { NodePath, PluginObj } from '@babel/core';\nimport * as babel from '@babel/core';\nimport type { NewExpression } from '@babel/types';\n\n/**\n * Babel plugin that enforces singleton PostgresStore instances in Cloudflare Workers.\n *\n * This plugin:\n * 1. Scans for all `new PostgresStore()` instantiations\n * 2. Records their file locations\n * 3. Throws an error if multiple instances are found\n *\n * Cloudflare Workers should only create one PostgresStore instance to avoid connection\n * pool exhaustion and ensure proper resource management.\n *\n * @returns {PluginObj} A Babel plugin object that validates PostgresStore usage\n *\n * @example\n * // Throws error if multiple instances found:\n * const store1 = new PostgresStore();\n * const store2 = new PostgresStore(); // Error thrown here\n */\nexport function postgresStoreInstanceChecker(): PluginObj {\n const t = babel.types;\n const instances: { path: NodePath; location: string }[] = [];\n\n return {\n name: 'postgresstore-instance-checker',\n visitor: {\n NewExpression(path, state) {\n if (t.isIdentifier(path.node.callee) && path.node.callee.name === 'PostgresStore') {\n const filename = state.file?.opts?.filename || 'unknown file';\n const location = path.node.loc\n ? `${filename}: line ${path.node.loc.start.line}, column ${path.node.loc.start.column}`\n : 'unknown location';\n\n instances.push({\n path,\n location,\n });\n }\n },\n },\n post() {\n if (instances.length > 1) {\n const errorMessage = [\n `Found ${instances.length} PostgresStore instantiations:`,\n ...instances.map((instance, i) => ` ${i + 1}. At ${instance.location}`),\n 'Only one PostgresStore instance should be created per Cloudflare Worker.',\n ].join('\\n');\n\n const lastInstance = instances[instances.length - 1];\n throw lastInstance?.path.buildCodeFrameError(errorMessage);\n }\n },\n } as PluginObj;\n}\n","import { transformSync } from '@babel/core';\nimport type { Plugin } from 'rollup';\nimport { postgresStoreInstanceChecker as postgresStoreInstanceCheckerBabel } from '../babel/postgres-store-instance-checker';\n\nexport function postgresStoreInstanceChecker(): Plugin {\n return {\n name: 'postgres-store-instance-checker',\n transform(code, id) {\n const result = transformSync(code, {\n filename: id,\n babelrc: false,\n configFile: false,\n plugins: [postgresStoreInstanceCheckerBabel],\n });\n\n // If Babel didn't transform anything or returned no code, pass through original source.\n if (!result || typeof result.code !== 'string') {\n return null;\n }\n\n return {\n code: result.code,\n map: result.map ?? null,\n };\n },\n };\n}\n","import { writeFile } from 'node:fs/promises';\nimport { builtinModules } from 'node:module';\nimport { join, relative } from 'node:path';\nimport { Deployer } from '@mastra/deployer';\nimport type { analyzeBundle } from '@mastra/deployer/analyze';\nimport type { BundlerOptions } from '@mastra/deployer/bundler';\nimport virtual from '@rollup/plugin-virtual';\nimport type { Plugin } from 'rollup';\nimport type { Unstable_RawConfig } from 'wrangler'; // Unstable_RawConfig is unstable, and no stable alternative exists. However, `wrangler` is a peerDep, allowing users to use latest properties.\nimport { mastraInstanceWrapper } from './plugins/mastra-instance-wrapper';\nimport { postgresStoreInstanceChecker } from './plugins/postgres-store-instance-checker';\n\nconst nodeBuiltins = new Set(builtinModules);\n\n/**\n * Rollup plugin that marks bare Node.js builtin imports (e.g. `process`, `path`)\n * as external. Cloudflare Workers with `nodejs_compat` provides these at runtime,\n * so they must not be resolved to npm polyfill packages during bundling.\n */\nfunction nodeBuiltinsExternal(): Plugin {\n return {\n name: 'node-builtins-external',\n resolveId(id) {\n if (nodeBuiltins.has(id)) {\n return { id, external: true };\n }\n return null;\n },\n };\n}\n\n/** @deprecated */\ninterface D1DatabaseBinding {\n binding: string;\n database_name: string;\n database_id: string;\n preview_database_id?: string;\n}\n\n/** @deprecated */\ninterface KVNamespaceBinding {\n binding: string;\n id: string;\n}\n\nexport class CloudflareDeployer extends Deployer {\n readonly userConfig: Omit;\n\n constructor(\n userConfig: Omit &\n // TODO: Remove deprecated fields in next major version, and update type to just Omit.\n {\n /** @deprecated Use `name` instead. */\n projectName?: string;\n /** @deprecated This parameter is not used internally. */\n workerNamespace?: string;\n /** @deprecated Use `d1_databases` instead. */\n d1Databases?: D1DatabaseBinding[];\n /** @deprecated Use `kv_namespaces` instead. */\n kvNamespaces?: KVNamespaceBinding[];\n },\n ) {\n super({ name: 'CLOUDFLARE' });\n\n // Use 'browser' platform for Workers-compatible module resolution.\n // This ensures packages with conditional exports (like the Cloudflare SDK)\n // resolve to browser/worker implementations instead of Node.js-specific code\n // that depends on unavailable modules like 'https'.\n this.platform = 'browser';\n\n this.userConfig = { ...userConfig };\n\n if (userConfig.workerNamespace) {\n console.warn('[CloudflareDeployer]: `workerNamespace` is no longer used');\n }\n if (!userConfig.name && userConfig.projectName) {\n this.userConfig.name = userConfig.projectName;\n console.warn('[CloudflareDeployer]: `projectName` is deprecated, use `name` instead');\n }\n if (!userConfig.d1_databases && userConfig.d1Databases) {\n this.userConfig.d1_databases = userConfig.d1Databases;\n console.warn('[CloudflareDeployer]: `d1Databases` is deprecated, use `d1_databases` instead');\n }\n if (!userConfig.kv_namespaces && userConfig.kvNamespaces) {\n this.userConfig.kv_namespaces = userConfig.kvNamespaces;\n console.warn('[CloudflareDeployer]: `kvNamespaces` is deprecated, use `kv_namespaces` instead');\n }\n }\n\n async writeFiles(outputDirectory: string): Promise {\n const {\n vars: userVars,\n alias: userAlias,\n // Remove deprecated fields so they don't leak into wrangler.json\n projectName: _projectName,\n workerNamespace: _workerNamespace,\n d1Databases: _d1Databases,\n kvNamespaces: _kvNamespaces,\n ...userConfig\n } = this.userConfig as typeof this.userConfig & {\n projectName?: string;\n workerNamespace?: string;\n d1Databases?: unknown;\n kvNamespaces?: unknown;\n };\n const loadedEnvVars = await this.loadEnvVars();\n const envsAsObject = Object.assign({}, userVars);\n\n if (loadedEnvVars.size > 0) {\n const envKeys = [...loadedEnvVars.keys()].join(', ');\n this.logger.warn(\n `Environment variables from .env (${envKeys}) were not written to wrangler.jsonc.\nUpload them as Cloudflare Secrets instead:\nnpx wrangler secret bulk .env`,\n );\n }\n\n // Write TypeScript stub to prevent bundling the full TypeScript library (~10MB)\n // The agent-builder package dynamically imports TypeScript for code validation,\n // but gracefully falls back to basic validation when TypeScript is unavailable.\n // This stub ensures the import doesn't fail while keeping the bundle small.\n const typescriptStubPath = 'typescript-stub.mjs';\n const typescriptStub = `// Stub for TypeScript - not available at runtime in Cloudflare Workers\n// The @mastra/agent-builder package will fall back to basic validation\nexport default {};\nexport const createSourceFile = () => null;\nexport const createProgram = () => null;\nexport const findConfigFile = () => null;\nexport const readConfigFile = () => ({ error: new Error('TypeScript not available') });\nexport const parseJsonConfigFileContent = () => ({ errors: [new Error('TypeScript not available')], fileNames: [], options: {} });\nexport const flattenDiagnosticMessageText = (message) => typeof message === 'string' ? message : message?.messageText || '';\nexport const ScriptTarget = { Latest: 99 };\nexport const ModuleKind = { ESNext: 99 };\nexport const JsxEmit = { ReactJSX: 4 };\nexport const DiagnosticCategory = { Warning: 0, Error: 1, Suggestion: 2, Message: 3 };\nexport const sys = {\n fileExists: () => false,\n readFile: () => undefined,\n};\n`;\n\n await writeFile(join(outputDirectory, this.outputDir, typescriptStubPath), typescriptStub);\n\n // Write execa stub — execa is used by @mastra/core's local sandbox process manager\n // but is not available/needed in Cloudflare Workers\n const execaStubPath = 'execa-stub.mjs';\n const execaStub = `// Stub for execa - not available at runtime in Cloudflare Workers\nexport const execa = () => { throw new Error('execa is not available in Cloudflare Workers'); };\nexport const execaNode = execa;\nexport const execaSync = execa;\nexport const execaCommand = execa;\nexport const execaCommandSync = execa;\nexport const $ = execa;\n`;\n await writeFile(join(outputDirectory, this.outputDir, execaStubPath), execaStub);\n\n // Write readable-stream stub — redirects to native node:stream available via nodejs_compat.\n // readable-stream is a userland copy of Node.js streams used by packages like elevenlabs.\n // Bundling it for Workers pulls in Node.js polyfills (abort-controller, process/, string_decoder/)\n // that are unnecessary and fail to resolve. The native node:stream is API-compatible.\n const readableStreamStubPath = 'readable-stream-stub.mjs';\n const readableStreamStub = `// Redirect readable-stream to native node:stream (available via nodejs_compat)\nimport stream from 'node:stream';\nexport const { Readable, Writable, Duplex, Transform, PassThrough, Stream, pipeline, finished } = stream;\nexport default stream;\n`;\n await writeFile(join(outputDirectory, this.outputDir, readableStreamStubPath), readableStreamStub);\n\n const wranglerConfig: Unstable_RawConfig = {\n name: 'mastra',\n compatibility_date: '2025-04-01',\n compatibility_flags: ['nodejs_compat', 'nodejs_compat_populate_process_env'],\n observability: {\n logs: {\n enabled: true,\n },\n },\n ...userConfig,\n main: './index.mjs',\n vars: envsAsObject,\n // Alias stubs to prevent wrangler from bundling unavailable libraries\n alias: {\n typescript: `./${typescriptStubPath}`,\n execa: `./${execaStubPath}`,\n 'readable-stream': `./${readableStreamStubPath}`,\n ...userAlias,\n },\n };\n\n // TODO: Remove writing this file in the next major version, it should only be written to the root of the project\n await writeFile(join(outputDirectory, this.outputDir, 'wrangler.json'), JSON.stringify(wranglerConfig, null, 2));\n\n const projectRoot = join(outputDirectory, '../');\n const jsoncFilePath = join(projectRoot, 'wrangler.jsonc');\n const mainFilePath = join(outputDirectory, this.outputDir, 'index.mjs');\n const tsStubFilePath = join(outputDirectory, this.outputDir, typescriptStubPath);\n\n const wranglerJsoncConfig: Unstable_RawConfig & { placeholder: string } = {\n placeholder: 'PLACEHOLDER',\n $schema: './node_modules/wrangler/config-schema.json',\n ...wranglerConfig,\n main: `./${relative(projectRoot, mainFilePath)}`,\n alias: {\n ...wranglerConfig.alias,\n typescript: `./${relative(projectRoot, tsStubFilePath)}`,\n },\n };\n\n const jsonc = JSON.stringify(wranglerJsoncConfig, null, 2).replace(\n /\"placeholder\": \"PLACEHOLDER\",/,\n '/* This file was auto-generated through Mastra. Edit the CloudflareDeployer() instance directly. */',\n );\n await writeFile(jsoncFilePath, jsonc);\n }\n\n private getEntry(): string {\n return `\n import '#polyfills';\n import { scoreTracesWorkflow } from '@mastra/core/evals/scoreTraces';\n\n export default {\n fetch: async (request, env, context) => {\n const { mastra } = await import('#mastra');\n const { tools } = await import('#tools');\n const {createHonoServer, getToolExports} = await import('#server');\n const _mastra = mastra();\n\n if (_mastra.getStorage()) {\n _mastra.__registerInternalWorkflow(scoreTracesWorkflow);\n }\n\n const app = await createHonoServer(_mastra, { tools: getToolExports(tools) });\n return app.fetch(request, env, context);\n }\n }\n`;\n }\n async prepare(outputDirectory: string): Promise {\n await super.prepare(outputDirectory);\n await this.writeFiles(outputDirectory);\n }\n\n protected async getBundlerOptions(\n serverFile: string,\n mastraEntryFile: string,\n analyzedBundleInfo: Awaited>,\n toolsPaths: (string | string[])[],\n bundlerOptions: BundlerOptions,\n ) {\n const inputOptions = await super.getBundlerOptions(serverFile, mastraEntryFile, analyzedBundleInfo, toolsPaths, {\n ...bundlerOptions,\n enableEsmShim: false,\n });\n\n const hasPostgresStore = (await this.deps.checkDependencies(['@mastra/pg'])) === `ok`;\n\n if (Array.isArray(inputOptions.plugins)) {\n inputOptions.plugins = [\n nodeBuiltinsExternal(),\n virtual({\n '#polyfills': `\nprocess.versions = process.versions || {};\nprocess.versions.node = '${process.versions.node}';\n `,\n }),\n ...inputOptions.plugins,\n mastraInstanceWrapper(mastraEntryFile),\n ];\n\n if (hasPostgresStore) {\n inputOptions.plugins.push(postgresStoreInstanceChecker());\n }\n }\n\n return inputOptions;\n }\n\n async bundle(\n entryFile: string,\n outputDirectory: string,\n { toolsPaths, projectRoot }: { toolsPaths: (string | string[])[]; projectRoot: string },\n ): Promise {\n return this._bundle(this.getEntry(), entryFile, { outputDirectory, projectRoot, enableEsmShim: false }, toolsPaths);\n }\n\n async deploy(): Promise {\n this.logger?.info('Deploying to Cloudflare failed. Please use the Cloudflare dashboard to deploy.');\n }\n\n /**\n * TODO: Remove this method in the next major version\n *\n * @deprecated\n */\n async tagWorker(): Promise {\n throw new Error('tagWorker method is no longer supported. Use the Cloudflare dashboard or API directly.');\n }\n\n async lint(entryFile: string, outputDirectory: string, toolsPaths: (string | string[])[]): Promise {\n await super.lint(entryFile, outputDirectory, toolsPaths);\n\n const hasLibsql = (await this.deps.checkDependencies(['@mastra/libsql'])) === `ok`;\n\n if (hasLibsql) {\n this.logger.error(\n 'Cloudflare Deployer does not support @libsql/client (which may have been installed by @mastra/libsql) as a dependency. Please use Cloudflare D1 instead: @mastra/cloudflare-d1.',\n );\n process.exit(1);\n }\n }\n}\n"]}