@prisma/dev - npm Package Compare versions

Comparing version 0.22.2 to 0.22.3

dist/chunk-CW5JFXGL.js

+import{d as v}from"./chunk-NKHRQQEV.js";import{a as E}from"./chunk-FIY24ARL.js";import{g as p}from"./chunk-OTI5SWIV.js";import{a as S,c as d,d as f}from"./chunk-6ORCLJD5.js";import{createServer as b}from"http";import{promisify as D}from"util";import A from"@prisma/get-platform";async function h(o,e){let{port:r}=e;if(e.dryRun)return P(r,null);let t=await W(o,e),{promise:n,reject:m,resolve:s}=d(),{serve:a}=await import("@hono/node-server"),i=a({createServer:b,fetch:t.fetch,overrideGlobalObjects:!1,port:r},s);i.on("error",c=>{if(typeof c=="object"&&"code"in c&&c.code==="EADDRINUSE")return m(new p(r));console.error("[Accelerate]",c)});let{port:l}=await n;return e.port=l,P(l,i)}function P(o,e){return{async close(){e&&await Promise.allSettled([D(e.close.bind(e))(),f.stopAll()])},port:o,url:`http://localhost:${o}`}}async function W(o,e){let{debug:r}=e,[{Hono:t},{accelerateRoute:n},{utilityRoute:m}]=await Promise.all([import("hono/tiny"),import("./accelerate-HABH6RJU.js"),import("./utility-Q5A254LJ.js")]),s=new t,a=await A.getPlatformInfo();if(r&&console.debug("[Accelerate] platform info: %s",JSON.stringify(a)),r){let{logger:l}=await import("hono/logger");s.use("*",l((...c)=>console.log("[Accelerate]",...c)))}s.use("*",async(l,c)=>(l.set("databaseDumpPath",e.databaseDumpPath),l.set("db",o),l.set("debug",!!r),l.set("name",e.name),l.set("platform",a),l.set("shadowDBPort",e.shadowDatabasePort),await c()));let i=new t;return i.route("/",n),i.route("/",m),s.route("/",i),s}async function w(o){let e=await E.createExclusively(o),r=null,t=null,n=null;try{[r,n]=await Promise.all([v("database",e),v("shadow_database",e)]);let m=await r.attachWalEventBridge();t=await h(r,e);let s=R(r,n,t,e);await e.writeServerDump(s);let a=B(m),i=r,l=n,c=t,u=async()=>{a.close(),await x(e,[c,i,l])};return{close:u,dbServer:r,httpServer:t,server:{...s,close:u,experimental:{wal:a.api},name:e.name},serverState:e,shadowDbServer:n,walBridge:m}}catch(m){return await T(e,[t,r,n],m)}}function R(o,e,r,t){let n=`prisma+postgres://localhost:${r.port}/?${new URLSearchParams({api_key:S({databaseUrl:o.prismaORMConnectionString,name:t.name,shadowDatabaseUrl:e.prismaORMConnectionString})}).toString()}`;return{database:{connectionString:o.connectionString,prismaORMConnectionString:o.prismaORMConnectionString,terminalCommand:o.terminalCommand},http:{url:r.url},ppg:{url:n},shadowDatabase:{connectionString:e.prismaORMConnectionString,prismaORMConnectionString:e.prismaORMConnectionString,terminalCommand:e.terminalCommand}}}async function x(o,e){let t=(await Promise.allSettled(e.map(n=>n.close()))).filter(n=>n.status==="rejected").map(n=>new Error(n.reason));try{await o.close()}catch(n){t.push(n)}if(t.length>0)throw new AggregateError(t,"Failed to close some servers")}async function T(o,e,r){try{await x(o,e.filter(t=>t!==null))}catch(t){throw new AggregateError([r,t],"Failed to start Prisma Dev server cleanly")}throw r}function B(o){let e=new Set;return{api:{stream:()=>{let r=()=>{},t=C(o,()=>{e.delete(r)});return r=()=>t.close(),e.add(r),t.stream},subscribe:r=>o.subscribe(r)},close:()=>{for(let r of[...e])r();e.clear()}}}function C(o,e){let r=[],t=!1,n=null,m=o.subscribe(a=>{if(!t){if(n){let i=n;n=null,i.resolve({done:!1,value:a});return}r.push(a)}}),s=()=>{if(!t&&(t=!0,m(),r.length=0,e(),n)){let a=n;n=null,a.resolve({done:!0,value:void 0})}};return{close:s,stream:{[Symbol.asyncIterator](){return this},next(){return r.length>0?Promise.resolve({done:!1,value:r.shift()}):t?Promise.resolve({done:!0,value:void 0}):new Promise((a,i)=>{n={reject:i,resolve:a}})},return(){return s(),Promise.resolve({done:!0,value:void 0})},throw(a){let i=n;return s(),i&&i.reject(a),Promise.reject(a instanceof Error?a:new Error(String(a)))}}}}async function O(o){let{server:e}=await w(o);return e}async function re(o){return await O(o)}export{O as a,re as b};

dist/chunk-NKHRQQEV.js

+import{c as g}from"./chunk-NXMFOBF6.js";import{g as w}from"./chunk-OTI5SWIV.js";import{e as f}from"./chunk-DGKV2DPF.js";import{filename as k}from"pathe/utils";import{protocol as G}from"@electric-sql/pglite";var u="_prisma_dev_wal",p="events",R="install_all_triggers",N="capture_event",S="prisma_dev_wal_capture",E=new WeakMap,W=new Set(["ALTER","COMMIT","COPY","CREATE","DELETE","DROP","INSERT","MERGE","TRUNCATE","UPDATE"]);async function T(e,t){let o=E.get(e);if(o&&!o.closed)return o.bridge;let r=e.execProtocolRaw.bind(e),n={bridge:{close:async()=>{n.closed||(n.closed=!0,n.subscribers.clear(),e.execProtocolRaw===s&&(e.execProtocolRaw=r),await n.pollPromise,E.delete(e))},poll:async()=>{await _(n,e)},subscribe:d=>(n.subscribers.add(d),()=>{n.subscribers.delete(d)})},closed:!1,ensureInfrastructurePromise:null,pendingPoll:!1,pollPromise:null,subscribers:new Set,suppressDepth:0},s=async(d,l)=>{let a=await r(d,l);return!n.closed&&n.suppressDepth===0&&D(a)&&_(n,e),a};return e.execProtocolRaw=s,E.set(e,n),await v(n,e),n.bridge}async function A(e){let t=E.get(e);t&&await t.bridge.close()}function L(e){for(let t of e){if(t.name!=="commandComplete"||typeof t.text!="string")continue;let o=t.text.split(/\s+/,1)[0]?.toUpperCase();if(o&&W.has(o))return!0}return!1}function D(e){if(e.length===0)return!1;let t=[];return new G.Parser().parse(e,r=>{t.push(r)}),L(t)}async function v(e,t){e.ensureInfrastructurePromise??=P(e,t,async()=>{await t.exec(`CREATE SCHEMA IF NOT EXISTS "${u}"`),await t.exec(`
+      CREATE TABLE IF NOT EXISTS "${u}"."${p}" (
+        id BIGSERIAL PRIMARY KEY,
+        txid BIGINT NOT NULL DEFAULT txid_current(),
+        schema_name TEXT NOT NULL,
+        table_name TEXT NOT NULL,
+        op TEXT NOT NULL,
+        row_data JSONB,
+        old_row_data JSONB,
+        created_at TIMESTAMPTZ NOT NULL DEFAULT clock_timestamp()
+      )
+    `),await t.exec(`
+      CREATE OR REPLACE FUNCTION "${u}"."${N}"()
+      RETURNS trigger
+      LANGUAGE plpgsql
+      AS $$
+      BEGIN
+        IF TG_TABLE_SCHEMA = '${u}' THEN
+          RETURN COALESCE(NEW, OLD);
+        END IF;
+
+        INSERT INTO "${u}"."${p}" (
+          txid,
+          schema_name,
+          table_name,
+          op,
+          row_data,
+          old_row_data
+        )
+        VALUES (
+          txid_current(),
+          TG_TABLE_SCHEMA,
+          TG_TABLE_NAME,
+          lower(TG_OP),
+          CASE WHEN TG_OP IN ('INSERT', 'UPDATE') THEN to_jsonb(NEW) ELSE NULL END,
+          CASE WHEN TG_OP IN ('UPDATE', 'DELETE') THEN to_jsonb(OLD) ELSE NULL END
+        );
+
+        RETURN COALESCE(NEW, OLD);
+      END;
+      $$;
+    `),await t.exec(`
+      CREATE OR REPLACE FUNCTION "${u}"."${R}"()
+      RETURNS void
+      LANGUAGE plpgsql
+      AS $$
+      DECLARE
+        target REGCLASS;
+      BEGIN
+        FOR target IN
+          SELECT c.oid::regclass
+          FROM pg_class AS c
+          JOIN pg_namespace AS n ON n.oid = c.relnamespace
+          WHERE c.relkind IN ('r', 'p')
+            AND n.nspname NOT IN ('${u}', 'information_schema', 'pg_catalog')
+            AND n.nspname NOT LIKE 'pg_temp_%'
+            AND n.nspname NOT LIKE 'pg_toast%'
+        LOOP
+          IF EXISTS (
+            SELECT 1
+            FROM pg_trigger
+            WHERE tgrelid = target
+              AND tgname = '${S}'
+          ) THEN
+            CONTINUE;
+          END IF;
+
+          EXECUTE format(
+            'CREATE TRIGGER %I AFTER INSERT OR UPDATE OR DELETE ON %s FOR EACH ROW EXECUTE FUNCTION "${u}"."${N}"()',
+            '${S}',
+            target::text
+          );
+        END LOOP;
+      END;
+      $$;
+    `),await y(e,t)}),await e.ensureInfrastructurePromise}async function y(e,t){await P(e,t,async()=>{await t.query(`SELECT "${u}"."${R}"()`)})}async function M(e,t){await v(e,t),await y(e,t);let o=await P(e,t,async()=>await t.query(`
+      WITH drained AS (
+        DELETE FROM "${u}"."${p}"
+        RETURNING txid, schema_name, table_name, op, row_data, old_row_data, id
+      )
+      SELECT txid, schema_name, table_name, op, row_data, old_row_data
+      FROM drained
+      ORDER BY id
+    `));if(o.rows.length===0||e.subscribers.size===0)return;let r=o.rows.map(U);for(let n of e.subscribers)queueMicrotask(()=>{if(!e.closed&&e.subscribers.has(n))try{n(r)}catch(s){console.error("[WAL bridge] subscriber failed",s)}})}async function _(e,t){if(!e.closed){if(e.pollPromise){e.pendingPoll=!0,await e.pollPromise;return}e.pollPromise=(async()=>{do e.pendingPoll=!1,await M(e,t);while(e.pendingPoll&&!e.closed)})().finally(()=>{e.pollPromise=null}),await e.pollPromise}}async function P(e,t,o){e.suppressDepth+=1;try{return await o()}finally{e.suppressDepth-=1,e.suppressDepth===0&&!e.closed&&E.get(t)!==e&&(e.closed=!0)}}function U(e){return{oldRecord:e.old_row_data,record:e.row_data,schema:e.schema_name,table:e.table_name,txid:String(e.txid),type:F(e.op)}}function F(e){switch(e.toLowerCase()){case"delete":return"delete";case"insert":return"insert";case"update":return"update";default:throw new Error(`Unsupported WAL bridge operation: ${e}`)}}var H=10,i={connectionLimit:H,connectTimeout:0,database:"template1",maxIdleConnectionLifetime:0,password:"postgres",poolTimeout:0,socketTimeout:0,sslMode:"disable",username:"postgres"},q=`postgres://${i.username}:${i.password}@localhost`,O=new URLSearchParams({sslmode:i.sslMode}),X=new URLSearchParams({...Object.fromEntries(O.entries()),connection_limit:String(i.connectionLimit),connect_timeout:String(i.connectTimeout),max_idle_connection_lifetime:String(i.maxIdleConnectionLifetime),pool_timeout:String(i.poolTimeout),socket_timeout:String(i.socketTimeout)});async function re(e,t){let o=e==="database"?t.databasePort:t.shadowDatabasePort;if(t.dryRun)return I(e,t,{db:null,port:o,server:null});let{debug:r}=t,s=await(e==="shadow_database"?Y:B)(t.pgliteDataDirPath,r);r&&s.onNotification((c,m)=>{console.debug(`[${e}][${c}] ${m}`)});let{PGLiteSocketServer:d}=await import("@electric-sql/pglite-socket"),l=e==="shadow_database"?t.shadowDatabaseIdleTimeoutMillis:t.databaseIdleTimeoutMillis,a=new d({db:s,debug:r,idleTimeout:Number.isFinite(l)?l:0,inspect:r,maxConnections:i.connectionLimit,port:o});r&&(a.addEventListener("listening",c=>{let{detail:m}=c;console.debug(`[${e}] server listening on ${JSON.stringify(m)}`)}),a.addEventListener("connection",c=>{let{clientAddress:m,clientPort:$}=c.detail;console.debug(`[${e}] client connected from ${m}:${$}`)}),a.addEventListener("error",c=>{let{detail:m}=c;console.error(`[${e}] server error:`,m)}));try{await a.start()}catch(c){throw c instanceof Error&&"code"in c&&c.code==="EADDRINUSE"?new w(o):c}let b=Number(a.getServerConn().split(":").at(1));return t[e==="database"?"databasePort":"shadowDatabasePort"]=b,I(e,t,{db:s,port:b,server:a})}function I(e,t,o){let{debug:r}=t,{db:n,port:s,server:d}=o||{};return r&&console.debug(`[${e}] server started on port ${s}`),{...i,attachWalEventBridge:async()=>{if(e!=="database"||!n)throw new Error("WAL bridge is only available for the primary database server");return await T(n)},close:async()=>{let l=[];try{await d?.stop(),r&&console.debug(`[${e}] server stopped on port ${s}`)}catch(a){console.error(`[${e}] server stop error`,a),l.push(a)}if(e==="database"){try{n&&await A(n),r&&console.debug(`[${e}] closed WAL bridge`)}catch(a){console.error(`[${e}] WAL bridge close error`,a),l.push(a)}try{await n?.syncToFs(),r&&console.debug(`[${e}] synced to filesystem`)}catch(a){console.error(`[${e}] sync error`,a),l.push(a)}}try{await n?.close(),r&&console.debug(`[${e}] closed`)}catch(a){console.error(`[${e}] close error`,a),l.push(a)}if(l.length>0)throw new AggregateError(l,`Failed to close ${e} properly`)},connectionString:h(s,O),dump:async l=>{e==="shadow_database"||!n||await Q({db:n,debug:r,destinationPath:l})},port:s,prismaORMConnectionString:h(s,X),terminalCommand:`PGPASSWORD=${i.password} PGSSLMODE=${i.sslMode} psql -h localhost -p ${s} -U ${i.username} -d ${i.database}`}}function h(e,t){return`${q}:${e}/${i.database}?${t.toString()}`}async function B(e,t){let{PGlite:o}=await import("@electric-sql/pglite"),r=await g();return await o.create({database:i.database,dataDir:e,debug:t?5:void 0,extensions:r.extensions,fsBundle:r.fsBundle,relaxedDurability:!1,wasmModule:r.wasmModule,username:i.username})}async function Y(e,t){let{PGlite:o}=await import("@electric-sql/pglite"),r=await g();return await o.create({database:i.database,dataDir:"memory://",debug:t?5:void 0,extensions:r.extensions,fsBundle:r.fsBundle,relaxedDurability:!1,wasmModule:r.wasmModule,username:i.username})}async function Q(e){let{dataDir:t,db:o,debug:r,destinationPath:n}=e,s=o||await B(t,r),{pgDump:d}=await import("@electric-sql/pglite-tools/pg_dump"),l=await d({args:["--schema-only","--no-owner"],fileName:n?k(n):void 0,pg:await s.clone()});return n?(r&&console.debug(`[DB] Dumping database to ${n}`),await f(l,n)):(r&&console.debug("[DB] Dumping database to memory"),await l.text())}export{T as a,L as b,D as c,re as d,Q as e};

dist/chunk-NXMFOBF6.js

+import{existsSync as R,readFileSync as U}from"fs";import{copyFile as _,mkdir as S,readFile as m}from"fs/promises";import{createRequire as L}from"module";import{dirname as B}from"path";import{fileURLToPath as r,pathToFileURL as p}from"url";var z=L(import.meta.url),E=["pglite.data","pglite.wasm"],y={amcheck:"amcheck.tar.gz",bloom:"bloom.tar.gz",btree_gin:"btree_gin.tar.gz",btree_gist:"btree_gist.tar.gz",citext:"citext.tar.gz",cube:"cube.tar.gz",dict_int:"dict_int.tar.gz",dict_xsyn:"dict_xsyn.tar.gz",earthdistance:"earthdistance.tar.gz",file_fdw:"file_fdw.tar.gz",fuzzystrmatch:"fuzzystrmatch.tar.gz",hstore:"hstore.tar.gz",intarray:"intarray.tar.gz",isn:"isn.tar.gz",lo:"lo.tar.gz",ltree:"ltree.tar.gz",pageinspect:"pageinspect.tar.gz",pg_buffercache:"pg_buffercache.tar.gz",pg_freespacemap:"pg_freespacemap.tar.gz",pg_surgery:"pg_surgery.tar.gz",pg_trgm:"pg_trgm.tar.gz",pg_visibility:"pg_visibility.tar.gz",pg_walinspect:"pg_walinspect.tar.gz",seg:"seg.tar.gz",tablefunc:"tablefunc.tar.gz",tcn:"tcn.tar.gz",tsm_system_rows:"tsm_system_rows.tar.gz",tsm_system_time:"tsm_system_time.tar.gz",unaccent:"unaccent.tar.gz",uuid_ossp:"uuid-ossp.tar.gz",vector:"vector.tar.gz"},A=[...E.map(e=>({fileName:e,kind:"core",name:e})),...Object.entries(y).map(([e,t])=>({fileName:t,kind:"extension",name:e}))],o=new Map,w=Symbol.for("@prisma/dev/bundled-pglite-runtime-asset-sources"),a=null;async function q(e){let t=c(e),s=r(t);await S(s,{recursive:!0});let n=[];for(let i of v()){let l=new URL(i.fileName,t),d=r(l);await _(i.sourcePath,d),n.push({...i,destinationPath:d})}return n}function v(){let e=b();return A.map(t=>({...t,sourcePath:r(new URL(t.fileName,e))}))}async function Y(){await k();let e=P();if(e)return await x(e);let t=G(),s=t.href,n=o.get(s);return n||(n=D(t),o.set(s,n)),await n}function K(e){let t=globalThis;t[w]={extensions:Object.fromEntries(Object.entries(e.extensions).map(([s,n])=>[s,u(n)])),fsBundle:u(e.fsBundle),wasmModule:u(e.wasmModule)}}function u(e,t=import.meta.url){return e instanceof URL?e:/^(?:https?:|data:|file:)/.test(e)?new URL(e):e.startsWith("/")||/^[a-zA-Z]:[\\/]/.test(e)?p(e):new URL(e,t)}async function x(e){let t=`bundled:${e.wasmModule.href}:${e.fsBundle.href}`,s=o.get(t);return s||(s=T(e),o.set(t,s)),await s}async function D(e){let[t,s]=await Promise.all([m(new URL("pglite.data",e)),m(new URL("pglite.wasm",e))]),n=h();return{extensions:Object.fromEntries(Object.entries(y).map(([i,l])=>[i,new URL(l,e)])),fsBundle:new Blob([Uint8Array.from(t)]),wasmModule:await n.compile(s)}}async function T(e){let[t,s]=await Promise.all([f(e.fsBundle),f(e.wasmModule)]),n=h();return{extensions:e.extensions,fsBundle:new Blob([Uint8Array.from(t)]),wasmModule:await n.compile(s)}}function c(e){return e instanceof URL?g(e):g(p(e))}function g(e){return e.href.endsWith("/")?e:new URL(`${e.href}/`)}function b(){let e=z.resolve("@electric-sql/pglite");return c(B(e))}function G(){let e=c(new URL("./",import.meta.url));if(M(e))return e;if(N())return b();throw new Error("Unable to locate PGlite runtime assets. If you bundled @prisma/dev, copy them next to the bundle with copyPrismaDevRuntimeAssets().")}function M(e){return A.every(t=>R(r(new URL(t.fileName,e))))}function P(){return globalThis[w]??null}async function k(){!O()||P()||(a||(a=import("./runtime-assets-manifest.bun.js").then(()=>{}).catch(e=>{throw a=null,e})),await a)}function N(){let e=r(new URL("../package.json",import.meta.url));if(!R(e))return!1;try{return JSON.parse(U(e,"utf8")).name==="@prisma/dev"}catch{return!1}}function O(){return typeof globalThis.Bun<"u"}function h(){let e=globalThis.WebAssembly;if(!e)throw new Error("WebAssembly is not available in this runtime.");return e}async function f(e){if(e.protocol==="file:")return await m(e);let t=await fetch(e);if(!t.ok)throw new Error(`Failed to fetch runtime asset ${e.href}: ${t.status} ${t.statusText}`);return new Uint8Array(await t.arrayBuffer())}export{q as a,v as b,Y as c,K as d,u as e};

dist/runtime-assets-manifest.bun.js

+import {
+  registerBundledPGliteRuntimeAssetSources,
+  resolveBundledRuntimeAssetSource,
+} from "./runtime-assets.js";
+import fsBundleAsset from "./runtime-assets/pglite.data";
+import wasmModuleAsset from "./runtime-assets/pglite.wasm";
+import amcheckAsset from "./runtime-assets/amcheck.tar.gz";
+import bloomAsset from "./runtime-assets/bloom.tar.gz";
+import btree_ginAsset from "./runtime-assets/btree_gin.tar.gz";
+import btree_gistAsset from "./runtime-assets/btree_gist.tar.gz";
+import citextAsset from "./runtime-assets/citext.tar.gz";
+import cubeAsset from "./runtime-assets/cube.tar.gz";
+import dict_intAsset from "./runtime-assets/dict_int.tar.gz";
+import dict_xsynAsset from "./runtime-assets/dict_xsyn.tar.gz";
+import earthdistanceAsset from "./runtime-assets/earthdistance.tar.gz";
+import file_fdwAsset from "./runtime-assets/file_fdw.tar.gz";
+import fuzzystrmatchAsset from "./runtime-assets/fuzzystrmatch.tar.gz";
+import hstoreAsset from "./runtime-assets/hstore.tar.gz";
+import intarrayAsset from "./runtime-assets/intarray.tar.gz";
+import isnAsset from "./runtime-assets/isn.tar.gz";
+import loAsset from "./runtime-assets/lo.tar.gz";
+import ltreeAsset from "./runtime-assets/ltree.tar.gz";
+import pageinspectAsset from "./runtime-assets/pageinspect.tar.gz";
+import pg_buffercacheAsset from "./runtime-assets/pg_buffercache.tar.gz";
+import pg_freespacemapAsset from "./runtime-assets/pg_freespacemap.tar.gz";
+import pg_surgeryAsset from "./runtime-assets/pg_surgery.tar.gz";
+import pg_trgmAsset from "./runtime-assets/pg_trgm.tar.gz";
+import pg_visibilityAsset from "./runtime-assets/pg_visibility.tar.gz";
+import pg_walinspectAsset from "./runtime-assets/pg_walinspect.tar.gz";
+import segAsset from "./runtime-assets/seg.tar.gz";
+import tablefuncAsset from "./runtime-assets/tablefunc.tar.gz";
+import tcnAsset from "./runtime-assets/tcn.tar.gz";
+import tsm_system_rowsAsset from "./runtime-assets/tsm_system_rows.tar.gz";
+import tsm_system_timeAsset from "./runtime-assets/tsm_system_time.tar.gz";
+import unaccentAsset from "./runtime-assets/unaccent.tar.gz";
+import uuid_osspAsset from "./runtime-assets/uuid-ossp.tar.gz";
+import vectorAsset from "./runtime-assets/vector.tar.gz";
+
+registerBundledPGliteRuntimeAssetSources({
+  fsBundle: resolveBundledRuntimeAssetSource(fsBundleAsset, import.meta.url),
+  wasmModule: resolveBundledRuntimeAssetSource(wasmModuleAsset, import.meta.url),
+  extensions: {
+    "amcheck": resolveBundledRuntimeAssetSource(amcheckAsset, import.meta.url),
+    "bloom": resolveBundledRuntimeAssetSource(bloomAsset, import.meta.url),
+    "btree_gin": resolveBundledRuntimeAssetSource(btree_ginAsset, import.meta.url),
+    "btree_gist": resolveBundledRuntimeAssetSource(btree_gistAsset, import.meta.url),
+    "citext": resolveBundledRuntimeAssetSource(citextAsset, import.meta.url),
+    "cube": resolveBundledRuntimeAssetSource(cubeAsset, import.meta.url),
+    "dict_int": resolveBundledRuntimeAssetSource(dict_intAsset, import.meta.url),
+    "dict_xsyn": resolveBundledRuntimeAssetSource(dict_xsynAsset, import.meta.url),
+    "earthdistance": resolveBundledRuntimeAssetSource(earthdistanceAsset, import.meta.url),
+    "file_fdw": resolveBundledRuntimeAssetSource(file_fdwAsset, import.meta.url),
+    "fuzzystrmatch": resolveBundledRuntimeAssetSource(fuzzystrmatchAsset, import.meta.url),
+    "hstore": resolveBundledRuntimeAssetSource(hstoreAsset, import.meta.url),
+    "intarray": resolveBundledRuntimeAssetSource(intarrayAsset, import.meta.url),
+    "isn": resolveBundledRuntimeAssetSource(isnAsset, import.meta.url),
+    "lo": resolveBundledRuntimeAssetSource(loAsset, import.meta.url),
+    "ltree": resolveBundledRuntimeAssetSource(ltreeAsset, import.meta.url),
+    "pageinspect": resolveBundledRuntimeAssetSource(pageinspectAsset, import.meta.url),
+    "pg_buffercache": resolveBundledRuntimeAssetSource(pg_buffercacheAsset, import.meta.url),
+    "pg_freespacemap": resolveBundledRuntimeAssetSource(pg_freespacemapAsset, import.meta.url),
+    "pg_surgery": resolveBundledRuntimeAssetSource(pg_surgeryAsset, import.meta.url),
+    "pg_trgm": resolveBundledRuntimeAssetSource(pg_trgmAsset, import.meta.url),
+    "pg_visibility": resolveBundledRuntimeAssetSource(pg_visibilityAsset, import.meta.url),
+    "pg_walinspect": resolveBundledRuntimeAssetSource(pg_walinspectAsset, import.meta.url),
+    "seg": resolveBundledRuntimeAssetSource(segAsset, import.meta.url),
+    "tablefunc": resolveBundledRuntimeAssetSource(tablefuncAsset, import.meta.url),
+    "tcn": resolveBundledRuntimeAssetSource(tcnAsset, import.meta.url),
+    "tsm_system_rows": resolveBundledRuntimeAssetSource(tsm_system_rowsAsset, import.meta.url),
+    "tsm_system_time": resolveBundledRuntimeAssetSource(tsm_system_timeAsset, import.meta.url),
+    "unaccent": resolveBundledRuntimeAssetSource(unaccentAsset, import.meta.url),
+    "uuid_ossp": resolveBundledRuntimeAssetSource(uuid_osspAsset, import.meta.url),
+    "vector": resolveBundledRuntimeAssetSource(vectorAsset, import.meta.url),
+  },
+});

dist/runtime-assets.cjs

+"use strict";var z=Object.create;var u=Object.defineProperty;var E=Object.getOwnPropertyDescriptor;var v=Object.getOwnPropertyNames;var x=Object.getPrototypeOf,T=Object.prototype.hasOwnProperty;var D=(e,t)=>{for(var n in t)u(e,n,{get:t[n],enumerable:!0})},p=(e,t,n,s)=>{if(t&&typeof t=="object"||typeof t=="function")for(let i of v(t))!T.call(e,i)&&i!==n&&u(e,i,{get:()=>t[i],enumerable:!(s=E(t,i))||s.enumerable});return e};var G=(e,t,n)=>(n=e!=null?z(x(e)):{},p(t||!e||!e.__esModule?u(n,"default",{value:e,enumerable:!0}):n,e)),N=e=>p(u({},"__esModule",{value:!0}),e);var Z={};D(Z,{copyPrismaDevRuntimeAssets:()=>I,getPGliteRuntimeAssets:()=>C,getPrismaDevRuntimeAssetManifest:()=>_,registerBundledPGliteRuntimeAssetSources:()=>F,resolveBundledRuntimeAssetSource:()=>m});module.exports=N(Z);var k=()=>typeof document>"u"?new URL(`file:${__filename}`).href:document.currentScript&&document.currentScript.tagName.toUpperCase()==="SCRIPT"?document.currentScript.src:new URL("main.js",document.baseURI).href,o=k();var l=require("fs"),a=require("fs/promises"),A=require("module"),b=require("path"),r=require("url"),M=(0,A.createRequire)(o),O=["pglite.data","pglite.wasm"],P={amcheck:"amcheck.tar.gz",bloom:"bloom.tar.gz",btree_gin:"btree_gin.tar.gz",btree_gist:"btree_gist.tar.gz",citext:"citext.tar.gz",cube:"cube.tar.gz",dict_int:"dict_int.tar.gz",dict_xsyn:"dict_xsyn.tar.gz",earthdistance:"earthdistance.tar.gz",file_fdw:"file_fdw.tar.gz",fuzzystrmatch:"fuzzystrmatch.tar.gz",hstore:"hstore.tar.gz",intarray:"intarray.tar.gz",isn:"isn.tar.gz",lo:"lo.tar.gz",ltree:"ltree.tar.gz",pageinspect:"pageinspect.tar.gz",pg_buffercache:"pg_buffercache.tar.gz",pg_freespacemap:"pg_freespacemap.tar.gz",pg_surgery:"pg_surgery.tar.gz",pg_trgm:"pg_trgm.tar.gz",pg_visibility:"pg_visibility.tar.gz",pg_walinspect:"pg_walinspect.tar.gz",seg:"seg.tar.gz",tablefunc:"tablefunc.tar.gz",tcn:"tcn.tar.gz",tsm_system_rows:"tsm_system_rows.tar.gz",tsm_system_time:"tsm_system_time.tar.gz",unaccent:"unaccent.tar.gz",uuid_ossp:"uuid-ossp.tar.gz",vector:"vector.tar.gz"},h=[...O.map(e=>({fileName:e,kind:"core",name:e})),...Object.entries(P).map(([e,t])=>({fileName:t,kind:"extension",name:e}))],d=new Map,U=Symbol.for("@prisma/dev/bundled-pglite-runtime-asset-sources"),c=null;async function I(e){let t=g(e),n=(0,r.fileURLToPath)(t);await(0,a.mkdir)(n,{recursive:!0});let s=[];for(let i of _()){let f=new URL(i.fileName,t),R=(0,r.fileURLToPath)(f);await(0,a.copyFile)(i.sourcePath,R),s.push({...i,destinationPath:R})}return s}function _(){let e=S();return h.map(t=>({...t,sourcePath:(0,r.fileURLToPath)(new URL(t.fileName,e))}))}async function C(){await Y();let e=L();if(e)return await j(e);let t=J(),n=t.href,s=d.get(n);return s||(s=$(t),d.set(n,s)),await s}function F(e){let t=globalThis;t[U]={extensions:Object.fromEntries(Object.entries(e.extensions).map(([n,s])=>[n,m(s)])),fsBundle:m(e.fsBundle),wasmModule:m(e.wasmModule)}}function m(e,t=o){return e instanceof URL?e:/^(?:https?:|data:|file:)/.test(e)?new URL(e):e.startsWith("/")||/^[a-zA-Z]:[\\/]/.test(e)?(0,r.pathToFileURL)(e):new URL(e,t)}async function j(e){let t=`bundled:${e.wasmModule.href}:${e.fsBundle.href}`,n=d.get(t);return n||(n=W(e),d.set(t,n)),await n}async function $(e){let[t,n]=await Promise.all([(0,a.readFile)(new URL("pglite.data",e)),(0,a.readFile)(new URL("pglite.wasm",e))]),s=B();return{extensions:Object.fromEntries(Object.entries(P).map(([i,f])=>[i,new URL(f,e)])),fsBundle:new Blob([Uint8Array.from(t)]),wasmModule:await s.compile(n)}}async function W(e){let[t,n]=await Promise.all([w(e.fsBundle),w(e.wasmModule)]),s=B();return{extensions:e.extensions,fsBundle:new Blob([Uint8Array.from(t)]),wasmModule:await s.compile(n)}}function g(e){return e instanceof URL?y(e):y((0,r.pathToFileURL)(e))}function y(e){return e.href.endsWith("/")?e:new URL(`${e.href}/`)}function S(){let e=M.resolve("@electric-sql/pglite");return g((0,b.dirname)(e))}function J(){let e=g(new URL("./",o));if(q(e))return e;if(K())return S();throw new Error("Unable to locate PGlite runtime assets. If you bundled @prisma/dev, copy them next to the bundle with copyPrismaDevRuntimeAssets().")}function q(e){return h.every(t=>(0,l.existsSync)((0,r.fileURLToPath)(new URL(t.fileName,e))))}function L(){return globalThis[U]??null}async function Y(){!X()||L()||(c||(c=import("./runtime-assets-manifest.bun.js").then(()=>{}).catch(e=>{throw c=null,e})),await c)}function K(){let e=(0,r.fileURLToPath)(new URL("../package.json",o));if(!(0,l.existsSync)(e))return!1;try{return JSON.parse((0,l.readFileSync)(e,"utf8")).name==="@prisma/dev"}catch{return!1}}function X(){return typeof globalThis.Bun<"u"}function B(){let e=globalThis.WebAssembly;if(!e)throw new Error("WebAssembly is not available in this runtime.");return e}async function w(e){if(e.protocol==="file:")return await(0,a.readFile)(e);let t=await fetch(e);if(!t.ok)throw new Error(`Failed to fetch runtime asset ${e.href}: ${t.status} ${t.statusText}`);return new Uint8Array(await t.arrayBuffer())}0&&(module.exports={copyPrismaDevRuntimeAssets,getPGliteRuntimeAssets,getPrismaDevRuntimeAssetManifest,registerBundledPGliteRuntimeAssetSources,resolveBundledRuntimeAssetSource});

dist/runtime-assets.d.cts

+interface PGliteRuntimeAssets {
+    readonly extensions: Record<string, URL>;
+    readonly fsBundle: Blob;
+    readonly wasmModule: unknown;
+}
+interface PrismaDevRuntimeAsset {
+    readonly fileName: string;
+    readonly kind: "core" | "extension";
+    readonly name: string;
+    readonly sourcePath: string;
+}
+interface CopiedPrismaDevRuntimeAsset extends PrismaDevRuntimeAsset {
+    readonly destinationPath: string;
+}
+declare function copyPrismaDevRuntimeAssets(destinationDir: string | URL): Promise<CopiedPrismaDevRuntimeAsset[]>;
+declare function getPrismaDevRuntimeAssetManifest(): readonly PrismaDevRuntimeAsset[];
+declare function getPGliteRuntimeAssets(): Promise<PGliteRuntimeAssets>;
+declare function registerBundledPGliteRuntimeAssetSources(sources: {
+    extensions: Record<string, string | URL>;
+    fsBundle: string | URL;
+    wasmModule: string | URL;
+}): void;
+declare function resolveBundledRuntimeAssetSource(source: string | URL, baseURL?: string): URL;
+
+export { type CopiedPrismaDevRuntimeAsset, type PrismaDevRuntimeAsset, copyPrismaDevRuntimeAssets, getPGliteRuntimeAssets, getPrismaDevRuntimeAssetManifest, registerBundledPGliteRuntimeAssetSources, resolveBundledRuntimeAssetSource };

dist/runtime-assets.d.ts

+interface PGliteRuntimeAssets {
+    readonly extensions: Record<string, URL>;
+    readonly fsBundle: Blob;
+    readonly wasmModule: unknown;
+}
+interface PrismaDevRuntimeAsset {
+    readonly fileName: string;
+    readonly kind: "core" | "extension";
+    readonly name: string;
+    readonly sourcePath: string;
+}
+interface CopiedPrismaDevRuntimeAsset extends PrismaDevRuntimeAsset {
+    readonly destinationPath: string;
+}
+declare function copyPrismaDevRuntimeAssets(destinationDir: string | URL): Promise<CopiedPrismaDevRuntimeAsset[]>;
+declare function getPrismaDevRuntimeAssetManifest(): readonly PrismaDevRuntimeAsset[];
+declare function getPGliteRuntimeAssets(): Promise<PGliteRuntimeAssets>;
+declare function registerBundledPGliteRuntimeAssetSources(sources: {
+    extensions: Record<string, string | URL>;
+    fsBundle: string | URL;
+    wasmModule: string | URL;
+}): void;
+declare function resolveBundledRuntimeAssetSource(source: string | URL, baseURL?: string): URL;
+
+export { type CopiedPrismaDevRuntimeAsset, type PrismaDevRuntimeAsset, copyPrismaDevRuntimeAssets, getPGliteRuntimeAssets, getPrismaDevRuntimeAssetManifest, registerBundledPGliteRuntimeAssetSources, resolveBundledRuntimeAssetSource };

dist/runtime-assets.js

+import{a,b,c,d,e}from"./chunk-NXMFOBF6.js";export{a as copyPrismaDevRuntimeAssets,c as getPGliteRuntimeAssets,b as getPrismaDevRuntimeAssetManifest,d as registerBundledPGliteRuntimeAssetSources,e as resolveBundledRuntimeAssetSource};

dist/daemon.cjs

@@ -1,5 +0,5 @@
-"use strict";var ar=Object.create;var Q=Object.defineProperty;var ir=Object.getOwnPropertyDescriptor;var cr=Object.getOwnPropertyNames;var lr=Object.getPrototypeOf,ur=Object.prototype.hasOwnProperty;var w=(t,e)=>()=>(t&&(e=t(t=0)),e);var Me=(t,e)=>{for(var r in e)Q(t,r,{get:e[r],enumerable:!0})},ke=(t,e,r,n)=>{if(e&&typeof e=="object"||typeof e=="function")for(let o of cr(e))!ur.call(t,o)&&o!==r&&Q(t,o,{get:()=>e[o],enumerable:!(n=ir(e,o))||n.enumerable});return t};var u=(t,e,r)=>(r=t!=null?ar(lr(t)):{},ke(e||!t||!t.__esModule?Q(r,"default",{value:t,enumerable:!0}):r,t)),dr=t=>ke(Q({},"__esModule",{value:!0}),t);var d=w(()=>{"use strict"});function Ue(t){return Buffer.from(JSON.stringify(Object.fromEntries(Object.entries(t).sort(([[e],[r]])=>e.localeCompare(r)))),"utf8").toString("base64url")}function mr(t){let e=Buffer.from(t,"base64url").toString("utf8"),{issues:r,output:n,success:o}=(0,f.safeParse)(pr,e,{abortEarly:!0});return o?[null,n]:[r]}var f,He,pr,N,ce=w(()=>{"use strict";d();f=require("valibot"),He=/^(postgres|postgresql):\/\//,pr=(0,f.pipe)((0,f.string)(),(0,f.parseJson)(),(0,f.object)({databaseUrl:(0,f.pipe)((0,f.string)(),(0,f.url)(),(0,f.regex)(He)),name:(0,f.optional)((0,f.pipe)((0,f.string)(),(0,f.minLength)(1))),shadowDatabaseUrl:(0,f.pipe)((0,f.string)(),(0,f.url)(),(0,f.regex)(He))}));N=async(t,e)=>{let{authorization:r}=t,{HTTPException:n}=await import("hono/http-exception");if(!r)throw new n(401,{message:"Missing API Key"});let[o,s="",a]=r.split(" ");if(o!=="Bearer"||a)throw new n(401,{message:"Invalid API Key"});let[i,c]=mr(s);if(i)throw new n(401,{message:"Invalid API Key",cause:i.join(", ")});let{databaseUrl:p,name:l,shadowDatabaseUrl:P}=c,E=e.get("name"),x=new URL(e.req.url).port;if(!l)throw new n(401,{message:`Wrong API Key; The Prisma Dev server running at port ${x} requires an API Key from a newer version of \`prisma dev\`. Check the "${E}" server's output for the updated \`DATABASE_URL\` value.`});if(l!==E)throw new n(401,{message:`Wrong API Key; The Prisma Dev server running at port ${x} is named "${E}", but the API Key is for "${l}"`});let{hostname:A,port:W}=new URL(p),{port:rr}=e.get("db"),{hostname:or,port:nr}=new URL(P),sr=e.get("shadowDBPort");if(A!=="localhost"||Number(W)!==rr||or!=="localhost"||Number(nr)!==sr)throw new n(401,{message:"Wrong API Key; Check your Prisma schema's `provider.url` value (probably defined in `.env`'s `DATABASE_URL` environment variable) is aligned with `prisma dev`'s output"});return{decodedAPIKey:c}}});function de(t,{suffix:e="nodejs"}={}){if(typeof t!="string")throw new TypeError(`Expected a string, got ${typeof t}`);return e&&(t+=`-${e}`),J.default.platform==="darwin"?gr(t):J.default.platform==="win32"?fr(t):hr(t)}var h,le,J,O,ue,B,gr,fr,hr,We=w(()=>{"use strict";d();h=u(require("path"),1),le=u(require("os"),1),J=u(require("process"),1),O=le.default.homedir(),ue=le.default.tmpdir(),{env:B}=J.default,gr=t=>{let e=h.default.join(O,"Library");return{data:h.default.join(e,"Application Support",t),config:h.default.join(e,"Preferences",t),cache:h.default.join(e,"Caches",t),log:h.default.join(e,"Logs",t),temp:h.default.join(ue,t)}},fr=t=>{let e=B.APPDATA||h.default.join(O,"AppData","Roaming"),r=B.LOCALAPPDATA||h.default.join(O,"AppData","Local");return{data:h.default.join(r,t,"Data"),config:h.default.join(e,t,"Config"),cache:h.default.join(r,t,"Cache"),log:h.default.join(r,t,"Log"),temp:h.default.join(ue,t)}},hr=t=>{let e=h.default.basename(O);return{data:h.default.join(B.XDG_DATA_HOME||h.default.join(O,".local","share"),t),config:h.default.join(B.XDG_CONFIG_HOME||h.default.join(O,".config"),t),cache:h.default.join(B.XDG_CACHE_HOME||h.default.join(O,".cache"),t),log:h.default.join(B.XDG_STATE_HOME||h.default.join(O,".local","state"),t),temp:h.default.join(ue,e,t)}}});function Ve(t,e){return`${qe.cache}/engine/${t}/${e}`}function j(t){return`${qe.data}/${t}`}async function Ke(t){try{return await(0,S.access)(t,S.constants.F_OK),!0}catch(e){if(pe(e))return!1;throw e}}async function Qe(t,e){let r=await Pr(t);await(0,S.writeFile)(e,r),await(0,S.chmod)(e,"755")}async function Je(t,e){await t.stream().pipeTo(X.WriteStream.toWeb((0,X.createWriteStream)(e,{encoding:"utf8"})))}function pe(t){return t!=null&&typeof t=="object"&&"code"in t&&t.code==="ENOENT"}async function Xe(t){try{return await(0,S.readFile)(t,{encoding:"utf-8"})}catch(e){if(pe(e))return null;throw e}}async function ze(t){await(0,S.mkdir)(t,{recursive:!0})}async function Ye(t,e){try{return(await(0,S.readdir)(t,{withFileTypes:!0})).reduce((n,o)=>(o.isDirectory()&&!o.name.startsWith(".")&&(!e||(0,Fe.default)(e,o.name))&&n.push(o.name),n),[])}catch(r){if(pe(r))return[];throw r}}var X,S,je,Ge,Fe,qe,Pr,z=w(()=>{"use strict";d();X=require("fs"),S=require("fs/promises"),je=require("util"),Ge=require("zlib");We();Fe=u(require("zeptomatch"),1),qe=de("prisma-dev"),Pr=(0,je.promisify)(Ge.unzip)});function ee(t){let e,r,n=new Promise((a,i)=>{e=a,r=i}),o=a=>{o=s=null,r(a),t?.onRejected?.(a),t?.onFulfilled?.()},s=a=>{s=o=null,e(a),t?.onResolved?.(a),t?.onFulfilled?.()};return{isFulfilled:()=>s===o,promise:n,reject:a=>o?.(a),resolve:a=>s?.(a)}}var Ee=w(()=>{"use strict";d()});function te(t,e){return console.error(t),t instanceof F?e.json({EngineNotStarted:{reason:{EngineStartupError:{logs:[],msg:t.message}}}},500):t instanceof k?e.text(t.responseBody,t.statusCode):e.body(null,500)}var Pt,bt,yt,vt,St,wt,Ir,$r,ht,H,F,k,Te=w(()=>{"use strict";d();Pt=require("child_process"),bt=require("events"),yt=require("fs/promises"),vt=require("path"),St=require("timers/promises");Ee();wt=require("std-env");z();({PRISMA_DEV_FORCE_ENGINE_BINARY_DOWNLOAD:Ir,PRISMA_DEV_FORCE_ENGINE_BINARY_PATH:$r,PRISMA_DEV_FORCE_NETWORK_DELAY_MS:ht}=wt.process.env),H=class t{static#t=new Map;#e;#r;constructor(e){this.#e=e,this.#r=null}static async get(e){let{debug:r}=e,n=`${e.schemaHash}:${e.clientVersion}`;try{let o=t.#t.get(n);if(o)return o;let s=new t(e);return t.#t.set(n,s),r&&console.debug("[Query Engine] starting...",e),await s.start(),r&&console.debug("[Query Engine] started!"),s}finally{t.stopAll(n)}}static async stopAll(e){let n=(await Promise.allSettled(Array.from(t.#t.entries()).filter(([o])=>o!==e).map(async([o,s])=>{try{await s.stop()}finally{t.#t.delete(o)}}))).filter(o=>o.status==="rejected").map(o=>o.reason);if(n.length>0)throw new AggregateError(n,"Failed to stop engines")}async commitTransaction(e,r){return await this.#i(e,r,"commit")}async request(e,r){let{url:n}=await this.start(),o=this.#o(r),s=await fetch(n,{body:typeof e=="string"?e:JSON.stringify(e),headers:{...o,"Content-Type":"application/json"},method:"POST"});if(!s.ok)throw await k.fromResponse(s);return await s.text()}async rollbackTransaction(e,r){return await this.#i(e,r,"rollback")}async startTransaction(e,r){let{url:n}=await this.start(),o=this.#o(r),s=await fetch(`${n}/transaction/start`,{body:JSON.stringify(e),headers:{...o,"Content-Type":"application/json"},method:"POST"});if(!s.ok)throw await k.fromResponse(s);return await s.json()}async start(){if(this.#r!=null)return await this.#r;let{promise:e,reject:r,resolve:n}=ee();this.#r=e;let o=$r||await this.#s();this.#e.debug&&console.debug("[Query Engine] spinning up at path...",o);let{proxySignals:s}=await import("foreground-child/proxy-signals"),a=(0,Pt.spawn)(o,["--enable-raw-queries","--enable-telemetry-in-response","--port","0"],{env:{LOG_QUERIES:"y",PRISMA_DML:this.#e.base64Schema,QE_LOG_LEVEL:"TRACE",RUST_BACKTRACE:"1",RUST_LOG:"info"},stdio:["ignore","pipe","pipe"],windowsHide:!0});s(a),a.stderr.setEncoding("utf8"),a.stdout.setEncoding("utf8");let i=l=>{let P=l.split(`
-`).find(W=>W.includes("Started query engine http server"));if(!P)return;a.stdout.removeListener("data",i);let{fields:E}=JSON.parse(P);if(E==null)return r(new Error(`Unexpected data during initialization, "fields" are missing: ${l}`));let{ip:x,port:A}=E;if(x==null||A==null)return r(new Error(`This version of query-engine is not compatible with minippg, "ip" and "port" are missing in the startup log entry.
-Received data: ${l}`));n({childProcess:a,url:`http://${x}:${A}`})},c=l=>{this.#r=null,r(new F(String(l))),a.removeListener("exit",p),a.kill()};a.once("error",c);let p=(l,P)=>{this.#r=null,r(new F(`Query Engine exited with code ${l} and signal ${P}`))};return a.once("exit",p),a.stdout.on("data",i),this.#e.debug&&(a.stderr.on("data",console.error.bind(console,"[Query Engine]")),a.stdout.on("data",console.debug.bind(console,"[Query Engine]"))),await this.#r}async stop(){if(this.#r==null)return;let{childProcess:e}=await this.#r;e.exitCode==null&&e.signalCode==null&&(this.#r=null,e.kill(),await(0,bt.once)(e,"exit"))}async#s(){this.#e.debug&&console.debug("[Query Engine] getting engine commit hash...");let e=await this.#a();this.#e.debug&&console.debug("[Query Engine] got engine commit hash",e);let r=Ve(this.#e.clientVersion,e);this.#e.debug&&console.debug("[Query Engine] cache directory path",r),await(0,yt.mkdir)(r,{recursive:!0});let{binaryTarget:n}=this.#e.platform,o=n==="windows"?".exe":"",s=(0,vt.join)(r,`query-engine-${n}${o}`);return this.#e.debug&&console.debug("[Query Engine] binary path",s),(Ir==="1"||await Ke(s)===!1)&&await this.#n({commitHash:e,extension:o,engineBinaryPath:s}),s}async#a(){let e=await fetch(`https://registry.npmjs.org/@prisma/client/${this.#e.clientVersion}`);if(!e.ok)throw new Error(`Couldn't fetch package.json from npm registry, status code: ${e.status}`);let n=(await e.json()).devDependencies?.["@prisma/engines-version"];if(!n)throw new Error("Couldn't find engines version in package.json");let o=n.split(".").at(-1);if(!o)throw new Error("Couldn't find commit hash in engines version");return o}async#n(e){let{commitHash:r,extension:n,engineBinaryPath:o}=e,{binaryTarget:s}=this.#e.platform,a=`https://binaries.prisma.sh/all_commits/${r}/${s}/query-engine${n}.gz`;this.#e.debug&&console.debug("[Query Engine] downloading engine from url",a);let i=await fetch(a);if(!i.ok)throw new Error(`Couldn't download engine. URL: ${a}, status code: ${i.status}`);ht&&await(0,St.setTimeout)(Number(ht)),await Qe(await i.arrayBuffer(),o),this.#e.debug&&console.debug("[Query Engine] downloaded and saved at",o)}#o(e){let r={};for(let[n,o]of Object.entries(e))o!=null&&(r[n]=o);return r}async#i(e,r,n){let{url:o}=await this.#r,s=this.#o(r),a=await fetch(`${o}/transaction/${e}/${n}`,{headers:{...s,"Content-Type":"application/json"},method:"POST"});if(!a.ok)throw await k.fromResponse(a);try{return await a.json()}catch{return{}}}};F=class extends Error{name="EngineStartError"},k=class t extends Error{constructor(r,n,o){super(`${r}: Query Engine response status ${n}, body: ${o}`);this.action=r;this.statusCode=n;this.responseBody=o}name="EngineHttpError";static async fromResponse(r){let n=new URL(r.url),o=await r.text();return new t(n.pathname,r.status,o)}}});async function Et(t){let{output:e,success:r}=(0,v.safeParse)(Nr,await t.req.json(),{abortEarly:!0});return r?e:t.text("Invalid input",400)}var v,Nr,Tt=w(()=>{"use strict";d();v=require("valibot"),Nr=(0,v.object)({tags:(0,v.union)([(0,v.pipe)((0,v.array)((0,v.string)()),(0,v.minLength)(1)),(0,v.literal)("all")])})});async function Dt(t){return De===void 0&&(De=await $.Server.create({databaseUrl:t.get("db").connectionString,maxResponseSize:(0,$.parseSize)("128 MiB"),queryTimeout:(0,$.parseDuration)("PT5M"),maxTransactionTimeout:(0,$.parseDuration)("PT5M"),maxTransactionWaitTime:(0,$.parseDuration)("PT5M"),perRequestLogContext:{logFormat:"text",logLevel:t.get("debug")?"debug":"off"}})),De}var $,re,De,xt=w(()=>{"use strict";d();$=require("@prisma/query-plan-executor"),re=require("@prisma/query-plan-executor")});async function Re(t){let r=new TextEncoder().encode(t),n=await crypto.subtle.digest("SHA-256",r);return Array.from(new Uint8Array(n)).map(a=>a.toString(16).padStart(2,"0")).join("")}function Rt(t){let e=t.req.param("schemaHash"),r=ne.get(e);return r==null?t.json({EngineNotStarted:{reason:"SchemaMissing"}},404):{schemaHash:e,schemas:r}}async function At(t,e,r){let n=xe.Buffer.from(t,"base64").toString("utf8"),o=(0,oe.getSchema)(n),s=o.list.find(p=>p.type==="datasource");if(!s)throw new Error("No datasource block found in schema.");let a=s.assignments.find(p=>p.type==="assignment"&&p.key==="url");a?a.value=`"${e.toString()}"`:s.assignments.push({key:"url",type:"assignment",value:`"${e.toString()}"`});let i=(0,oe.printSchema)(o);r&&console.log("[Accelerate] schema with override:",i);let c=await Re(i);return{base64Override:xe.Buffer.from(i,"utf8").toString("base64"),overrideHash:c}}var xe,oe,ne,Ot=w(()=>{"use strict";d();xe=require("buffer"),oe=require("@mrleebo/prisma-ast"),ne=new Map});function se(t){let{req:e}=t;return{traceparent:e.header("traceparent"),"X-capture-telemetry":e.header("X-capture-telemetry")}}var _t=w(()=>{"use strict";d()});async function It(t){let{issues:e,output:r,success:n}=(0,g.safeParse)(Cr,await t.req.json(),{abortEarly:!0});return n?r:t.json({EngineNotStarted:{reason:"InvalidRequest",issues:e}},400)}function $t(t,e){let{output:r,success:n}=(0,g.safeParse)(Lr,t);return n?r:e.json({EngineMalfunction:{}},500)}var g,Cr,Lr,Nt=w(()=>{"use strict";d();g=require("valibot"),Cr=(0,g.object)({isolation_level:(0,g.optional)((0,g.string)()),max_wait:(0,g.pipe)((0,g.number)(),(0,g.integer)(),(0,g.minValue)(0)),timeout:(0,g.pipe)((0,g.number)(),(0,g.integer)(),(0,g.minValue)(0))});Lr=(0,g.looseObject)({id:(0,g.union)([(0,g.string)(),(0,g.number)()])})});var Bt={};Me(Bt,{accelerateRoute:()=>q});async function Ae(t){let{req:e}=t,r=Rt(t);if(r instanceof Response)return r;let{base64Override:n,overrideHash:o}=r.schemas;return await H.get({base64Schema:n,clientVersion:process.env.PRISMA_DEV_FORCE_CLIENT_VERSION||e.param("clientVersion"),debug:t.get("debug"),platform:t.get("platform"),schemaHash:o})}var Ct,Lt,C,q,Br,V,Mr,kr,Mt=w(()=>{"use strict";d();Ct=require("hono/http-exception"),Lt=require("hono/tiny"),C=require("hono/validator");ce();Tt();Te();xt();Ot();_t();Nt();q=new Lt.Hono;q.post("/invalidate",(0,C.validator)("header",N),async t=>{let e=await Et(t);return e instanceof Response?e:t.body(null)});Br="/:clientVersion/:schemaHash",V=q.basePath(Br);q.route("/",V);Mr=["/graphql","/itx/:transactionId/graphql"];V.on("POST",[...Mr],(0,C.validator)("header",N),async t=>{let{req:e}=t;try{let r=await Ae(t);if(r instanceof Response)return r;let n=await e.text(),o=e.param("transactionId"),s=await r.request(n,{...se(t),"X-transaction-id":o});return t.text(s)}catch(r){return te(r,t)}});V.basePath("/itx/:transactionId").on("POST",["/commit","/rollback"],(0,C.validator)("header",N),async t=>{let{req:e}=t;try{let r=await Ae(t);if(r instanceof Response)return r;let o=`${e.routePath.split("/").filter(Boolean).at(-1)}Transaction`,s=e.param("transactionId"),a=await r[o](s,se(t));return t.json(a)}catch(r){return te(r,t)}});V.put("/schema",(0,C.validator)("header",N),async t=>{let{req:e}=t,r=await e.text();if(!r)return t.text("Missing schema",400);let n=e.param("schemaHash"),o=ne.get(n);if(o==null){if(n!==await Re(r))return t.text("Schema hash mismatch",400);let s=await At(r,t.get("db").prismaORMConnectionString,t.get("debug"));return ne.set(n,{base64Original:r,...s}),t.text(n)}return r!==o.base64Original?t.text("Schema mismatch",400):t.text(n)});V.post("/transaction/start",(0,C.validator)("header",N),async t=>{let{req:e}=t,r=await It(t);if(r instanceof Response)return r;try{let n=await Ae(t);if(n instanceof Response)return n;let o=await n.startTransaction(r,se(t)),s=$t(o,t);if(s instanceof Response)return s;let{id:a}=s,i=e.param("clientVersion"),c=e.param("schemaHash");return t.json({...o,"data-proxy":{endpoint:`${new URL(e.url).origin}/${i}/${c}/itx/${a}`}})}catch(n){return te(n,t)}});kr=[["/connection-info","GET"],["/query","POST"],["/transaction/start","POST"],["/transaction/:transactionId/commit","POST"],["/transaction/:transactionId/query","POST"],["/transaction/:transactionId/rollback","POST"]];for(let[t,e]of kr)q.on(e,t,(0,C.validator)("header",N),async r=>{let n=r.req.header("prisma-engine-hash");if(n!=="0.0.0"&&n!==re.version)throw new Ct.HTTPException(400,{message:`Using an HTTP connection string is not supported with Prisma Client version ${n} by this version of \`prisma dev\`. Please either use a direct TCP connection string or upgrade your client to version ${re.version}.`});return await(await Dt(r)).fetch(r.req.raw)})});var Ut={};Me(Ut,{utilityRoute:()=>Oe});var kt,Ht,Oe,Wo,Wt=w(()=>{"use strict";d();kt=require("hono/tiny"),Ht=require("http-status-codes"),Oe=new kt.Hono;Oe.post("/database/dump",async t=>{let e=t.get("db"),r=t.get("databaseDumpPath");return await e.dump(r),t.json({dumpPath:r},Ht.StatusCodes.CREATED)});Wo=Oe.get("/health",t=>t.json({name:t.get("name")}))});var Jr={};module.exports=dr(Jr);d();var tr=require("timers/promises");d();d();ce();d();var pt=require("pathe/utils");z();d();var I=require("get-port-please"),Z=require("remeda"),me=51214,ge=51213,fe=51215,Y=65535,M=0,_=-1/0;async function be(t){let{debug:e,name:r,requestedPorts:n,servers:o}=t,{portsUsedByOtherServers:s,portsUsedByThisServerLastTime:a}=vr(r,o);e&&(console.debug(`ports used by other servers: ${Object.keys(s).join(", ")}`),console.debug(`ports used by "${r}" server last time: ${JSON.stringify(a)}`));let i={databasePort:_,port:_,shadowDatabasePort:_},c=["port","databasePort","shadowDatabasePort"];for(let p of c){let l=await br({debug:e,portKey:p,portsUsedByOtherServers:s,portsUsedByThisServerLastTime:a,requestedPorts:n})??await yr({debug:e,pickedPorts:i,portKey:p,portsUsedByOtherServers:s,portsUsedByThisServerLastTime:a});e&&console.debug(`Got port for "${p}": ${l}`),i[p]=l}return e&&console.debug(`Picked ports: ${JSON.stringify(i)}`),i}async function br(t){let{debug:e,portKey:r,portsUsedByOtherServers:n,portsUsedByThisServerLastTime:o,requestedPorts:s}=t,{[r]:a,...i}=s;if(Ze(a))return await Sr({debug:e,otherRequestedPorts:i,portKey:r,portsUsedByOtherServers:n,requestedPort:a}),a;let c=o?.[r]??_;if(!Ze(c))return e&&console.debug(`No port specified for "${r}". Trying to pick a new port.`),null;let p=c in n;return p||Object.values(i).includes(c)?(e&&console.debug(`Port ${c} that was used last time for this server, ${p?"is also used by another server":"has been requested for another service"}. Trying to pick a new port.`),null):await(0,I.checkPort)(c)===!1?(e&&console.debug(`Port ${c}, that was used last time for this server, is not available. Trying to pick a new port.`),null):(e&&console.debug(`Using port ${c} for "${r}" as it was used last time and is available.`),c)}async function yr(t){let{debug:e,pickedPorts:r,portKey:n,portsUsedByOtherServers:o,portsUsedByThisServerLastTime:s}=t,a=Math.max(me,ge,fe)+1,i=[...Object.values(r),...Object.keys(o).map(Number),...Object.values(s||{})],c=Math.min(Math.max(a,...i)+100,Y),p=(0,Z.difference)((0,Z.range)(a,c),i),l={port:ge,databasePort:me,shadowDatabasePort:fe}[n];try{return await(0,I.getPort)({port:l in o||Object.values(r).includes(l)||Object.values(s||{}).includes(l)?void 0:l,ports:p})}catch(P){if(P instanceof Error&&P.name==="GetPortError"&&c+1<=Y)return e&&console.debug(`Expanding port lookup to range [${c+1}, ${Y}].`),await(0,I.getPort)({portRange:[c+1,Y]});throw P}}function Ze(t){return Number.isFinite(t)&&t>=0}function vr(t,e){let r={},n;for(let o of e){let{databasePort:s,port:a,shadowDatabasePort:i}=o;if(o.name===t){n={databasePort:s,port:a,shadowDatabasePort:i};continue}r[s]=!0,r[a]=!0,r[i]=!0}return{portsUsedByOtherServers:r,portsUsedByThisServerLastTime:n}}async function Sr(t){let{debug:e,otherRequestedPorts:r,portKey:n,portsUsedByOtherServers:o,requestedPort:s}=t;if(s!==M){if(s in o)throw e&&console.error(`Port ${s} was requested for "${n}", but is already used by another server.`),new Pe(s);if(Object.values(r).includes(s))throw e&&console.error(`Port ${s} was requested for "${n}", but also for another key.`),new he(s);if((0,I.isUnsafePort)(s))throw e&&console.error(`Port ${s} was requested for "${n}", but is unsafe.`),new R(s);if(await(0,I.checkPort)(s)===!1)throw e&&console.error(`Port ${s} was requested for "${n}", but is not available.`),new R(s)}}var R=class extends Error{constructor(r){super(`Port \`${r}\` is not available.`);this.port=r}name="PortNotAvailableError"},he=class extends Error{constructor(r){super(`Port number \`${r}\` was requested twice. Please choose a different port for each service.`);this.port=r}name="PortRequestedTwiceError"},Pe=class extends Error{constructor(r){super(`Port number \`${r}\` belongs to another Prisma Dev server. Please choose a different port.`);this.port=r}name="PortBelongsToAnotherServerError"};d();var ot=require("@electric-sql/pglite"),T="_prisma_dev_wal",ye="events",nt="install_all_triggers",et="capture_event",tt="prisma_dev_wal_capture",G=new WeakMap,wr=new Set(["ALTER","COMMIT","COPY","CREATE","DELETE","DROP","INSERT","MERGE","TRUNCATE","UPDATE"]);async function ve(t,e){let r=G.get(t);if(r&&!r.closed)return r.bridge;let n=t.execProtocolRaw.bind(t),o={bridge:{close:async()=>{o.closed||(o.closed=!0,o.subscribers.clear(),t.execProtocolRaw===s&&(t.execProtocolRaw=n),await o.pollPromise,G.delete(t))},poll:async()=>{await rt(o,t)},subscribe:a=>(o.subscribers.add(a),()=>{o.subscribers.delete(a)})},closed:!1,ensureInfrastructurePromise:null,pendingPoll:!1,pollPromise:null,subscribers:new Set,suppressDepth:0},s=async(a,i)=>{let c=await n(a,i);return!o.closed&&o.suppressDepth===0&&it(c)&&rt(o,t),c};return t.execProtocolRaw=s,G.set(t,o),await ct(o,t),o.bridge}async function st(t){let e=G.get(t);e&&await e.bridge.close()}function at(t){for(let e of t){if(e.name!=="commandComplete"||typeof e.text!="string")continue;let r=e.text.split(/\s+/,1)[0]?.toUpperCase();if(r&&wr.has(r))return!0}return!1}function it(t){if(t.length===0)return!1;let e=[];return new ot.protocol.Parser().parse(t,n=>{e.push(n)}),at(e)}async function ct(t,e){t.ensureInfrastructurePromise??=Se(t,e,async()=>{await e.exec(`CREATE SCHEMA IF NOT EXISTS "${T}"`),await e.exec(`
-      CREATE TABLE IF NOT EXISTS "${T}"."${ye}" (
+"use strict";var br=Object.create;var X=Object.defineProperty;var vr=Object.getOwnPropertyDescriptor;var wr=Object.getOwnPropertyNames;var Sr=Object.getPrototypeOf,Er=Object.prototype.hasOwnProperty;var S=(e,t)=>()=>(e&&(t=e(e=0)),t);var je=(e,t)=>{for(var r in t)X(e,r,{get:t[r],enumerable:!0})},Fe=(e,t,r,n)=>{if(t&&typeof t=="object"||typeof t=="function")for(let o of wr(t))!Er.call(e,o)&&o!==r&&X(e,o,{get:()=>t[o],enumerable:!(n=vr(t,o))||n.enumerable});return e};var b=(e,t,r)=>(r=e!=null?br(Sr(e)):{},Fe(t||!e||!e.__esModule?X(r,"default",{value:e,enumerable:!0}):r,e)),Rr=e=>Fe(X({},"__esModule",{value:!0}),e);var Tr,f,u=S(()=>{"use strict";Tr=()=>typeof document>"u"?new URL(`file:${__filename}`).href:document.currentScript&&document.currentScript.tagName.toUpperCase()==="SCRIPT"?document.currentScript.src:new URL("main.js",document.baseURI).href,f=Tr()});function ze(e){return Buffer.from(JSON.stringify(Object.fromEntries(Object.entries(e).sort(([[t],[r]])=>t.localeCompare(r)))),"utf8").toString("base64url")}function Ar(e){let t=Buffer.from(e,"base64url").toString("utf8"),{issues:r,output:n,success:o}=(0,g.safeParse)(Dr,t,{abortEarly:!0});return o?[null,n]:[r]}var g,qe,Dr,B,pe=S(()=>{"use strict";u();g=require("valibot"),qe=/^(postgres|postgresql):\/\//,Dr=(0,g.pipe)((0,g.string)(),(0,g.parseJson)(),(0,g.object)({databaseUrl:(0,g.pipe)((0,g.string)(),(0,g.url)(),(0,g.regex)(qe)),name:(0,g.optional)((0,g.pipe)((0,g.string)(),(0,g.minLength)(1))),shadowDatabaseUrl:(0,g.pipe)((0,g.string)(),(0,g.url)(),(0,g.regex)(qe))}));B=async(e,t)=>{let{authorization:r}=e,{HTTPException:n}=await import("hono/http-exception");if(!r)throw new n(401,{message:"Missing API Key"});let[o,s="",a]=r.split(" ");if(o!=="Bearer"||a)throw new n(401,{message:"Invalid API Key"});let[i,c]=Ar(s);if(i)throw new n(401,{message:"Invalid API Key",cause:i.join(", ")});let{databaseUrl:d,name:l,shadowDatabaseUrl:P}=c,E=t.get("name"),D=new URL(t.req.url).port;if(!l)throw new n(401,{message:`Wrong API Key; The Prisma Dev server running at port ${D} requires an API Key from a newer version of \`prisma dev\`. Check the "${E}" server's output for the updated \`DATABASE_URL\` value.`});if(l!==E)throw new n(401,{message:`Wrong API Key; The Prisma Dev server running at port ${D} is named "${E}", but the API Key is for "${l}"`});let{hostname:x,port:W}=new URL(d),{port:fr}=t.get("db"),{hostname:hr,port:Pr}=new URL(P),yr=t.get("shadowDBPort");if(x!=="localhost"||Number(W)!==fr||hr!=="localhost"||Number(Pr)!==yr)throw new n(401,{message:"Wrong API Key; Check your Prisma schema's `provider.url` value (probably defined in `.env`'s `DATABASE_URL` environment variable) is aligned with `prisma dev`'s output"});return{decodedAPIKey:c}}});function he(e,{suffix:t="nodejs"}={}){if(typeof e!="string")throw new TypeError(`Expected a string, got ${typeof e}`);return t&&(e+=`-${t}`),Y.default.platform==="darwin"?xr(e):Y.default.platform==="win32"?_r(e):Or(e)}var h,ge,Y,_,fe,C,xr,_r,Or,Ve=S(()=>{"use strict";u();h=b(require("path"),1),ge=b(require("os"),1),Y=b(require("process"),1),_=ge.default.homedir(),fe=ge.default.tmpdir(),{env:C}=Y.default,xr=e=>{let t=h.default.join(_,"Library");return{data:h.default.join(t,"Application Support",e),config:h.default.join(t,"Preferences",e),cache:h.default.join(t,"Caches",e),log:h.default.join(t,"Logs",e),temp:h.default.join(fe,e)}},_r=e=>{let t=C.APPDATA||h.default.join(_,"AppData","Roaming"),r=C.LOCALAPPDATA||h.default.join(_,"AppData","Local");return{data:h.default.join(r,e,"Data"),config:h.default.join(t,e,"Config"),cache:h.default.join(r,e,"Cache"),log:h.default.join(r,e,"Log"),temp:h.default.join(fe,e)}},Or=e=>{let t=h.default.basename(_);return{data:h.default.join(C.XDG_DATA_HOME||h.default.join(_,".local","share"),e),config:h.default.join(C.XDG_CONFIG_HOME||h.default.join(_,".config"),e),cache:h.default.join(C.XDG_CACHE_HOME||h.default.join(_,".cache"),e),log:h.default.join(C.XDG_STATE_HOME||h.default.join(_,".local","state"),e),temp:h.default.join(fe,t,e)}}});function Ye(e,t){return`${Xe.cache}/engine/${e}/${t}`}function j(e){return`${Xe.data}/${e}`}async function Ze(e){try{return await(0,w.access)(e,w.constants.F_OK),!0}catch(t){if(Pe(t))return!1;throw t}}async function et(e,t){let r=await Ir(e);await(0,w.writeFile)(t,r),await(0,w.chmod)(t,"755")}async function tt(e,t){await e.stream().pipeTo(Z.WriteStream.toWeb((0,Z.createWriteStream)(t,{encoding:"utf8"})))}function Pe(e){return e!=null&&typeof e=="object"&&"code"in e&&e.code==="ENOENT"}async function rt(e){try{return await(0,w.readFile)(e,{encoding:"utf-8"})}catch(t){if(Pe(t))return null;throw t}}async function nt(e){await(0,w.mkdir)(e,{recursive:!0})}async function ot(e,t){try{return(await(0,w.readdir)(e,{withFileTypes:!0})).reduce((n,o)=>(o.isDirectory()&&!o.name.startsWith(".")&&(!t||(0,Qe.default)(t,o.name))&&n.push(o.name),n),[])}catch(r){if(Pe(r))return[];throw r}}var Z,w,Ke,Je,Qe,Xe,Ir,ee=S(()=>{"use strict";u();Z=require("fs"),w=require("fs/promises"),Ke=require("util"),Je=require("zlib");Ve();Qe=b(require("zeptomatch"),1),Xe=he("prisma-dev"),Ir=(0,Ke.promisify)(Je.unzip)});function se(e){let t,r,n=new Promise((a,i)=>{t=a,r=i}),o=a=>{o=s=null,r(a),e?.onRejected?.(a),e?.onFulfilled?.()},s=a=>{s=o=null,t(a),e?.onResolved?.(a),e?.onFulfilled?.()};return{isFulfilled:()=>s===o,promise:n,reject:a=>o?.(a),resolve:a=>s?.(a)}}var _e=S(()=>{"use strict";u()});function ae(e,t){return console.error(e),e instanceof V?t.json({EngineNotStarted:{reason:{EngineStartupError:{logs:[],msg:e.message}}}},500):e instanceof U?t.text(e.responseBody,e.statusCode):t.body(null,500)}var Ot,It,Lt,Bt,Nt,$t,on,sn,_t,H,V,U,Oe=S(()=>{"use strict";u();Ot=require("child_process"),It=require("events"),Lt=require("fs/promises"),Bt=require("path"),Nt=require("timers/promises");_e();$t=require("std-env");ee();({PRISMA_DEV_FORCE_ENGINE_BINARY_DOWNLOAD:on,PRISMA_DEV_FORCE_ENGINE_BINARY_PATH:sn,PRISMA_DEV_FORCE_NETWORK_DELAY_MS:_t}=$t.process.env),H=class e{static#t=new Map;#e;#r;constructor(t){this.#e=t,this.#r=null}static async get(t){let{debug:r}=t,n=`${t.schemaHash}:${t.clientVersion}`;try{let o=e.#t.get(n);if(o)return o;let s=new e(t);return e.#t.set(n,s),r&&console.debug("[Query Engine] starting...",t),await s.start(),r&&console.debug("[Query Engine] started!"),s}finally{e.stopAll(n)}}static async stopAll(t){let n=(await Promise.allSettled(Array.from(e.#t.entries()).filter(([o])=>o!==t).map(async([o,s])=>{try{await s.stop()}finally{e.#t.delete(o)}}))).filter(o=>o.status==="rejected").map(o=>o.reason);if(n.length>0)throw new AggregateError(n,"Failed to stop engines")}async commitTransaction(t,r){return await this.#i(t,r,"commit")}async request(t,r){let{url:n}=await this.start(),o=this.#n(r),s=await fetch(n,{body:typeof t=="string"?t:JSON.stringify(t),headers:{...o,"Content-Type":"application/json"},method:"POST"});if(!s.ok)throw await U.fromResponse(s);return await s.text()}async rollbackTransaction(t,r){return await this.#i(t,r,"rollback")}async startTransaction(t,r){let{url:n}=await this.start(),o=this.#n(r),s=await fetch(`${n}/transaction/start`,{body:JSON.stringify(t),headers:{...o,"Content-Type":"application/json"},method:"POST"});if(!s.ok)throw await U.fromResponse(s);return await s.json()}async start(){if(this.#r!=null)return await this.#r;let{promise:t,reject:r,resolve:n}=se();this.#r=t;let o=sn||await this.#s();this.#e.debug&&console.debug("[Query Engine] spinning up at path...",o);let{proxySignals:s}=await import("foreground-child/proxy-signals"),a=(0,Ot.spawn)(o,["--enable-raw-queries","--enable-telemetry-in-response","--port","0"],{env:{LOG_QUERIES:"y",PRISMA_DML:this.#e.base64Schema,QE_LOG_LEVEL:"TRACE",RUST_BACKTRACE:"1",RUST_LOG:"info"},stdio:["ignore","pipe","pipe"],windowsHide:!0});s(a),a.stderr.setEncoding("utf8"),a.stdout.setEncoding("utf8");let i=l=>{let P=l.split(`
+`).find(W=>W.includes("Started query engine http server"));if(!P)return;a.stdout.removeListener("data",i);let{fields:E}=JSON.parse(P);if(E==null)return r(new Error(`Unexpected data during initialization, "fields" are missing: ${l}`));let{ip:D,port:x}=E;if(D==null||x==null)return r(new Error(`This version of query-engine is not compatible with minippg, "ip" and "port" are missing in the startup log entry.
+Received data: ${l}`));n({childProcess:a,url:`http://${D}:${x}`})},c=l=>{this.#r=null,r(new V(String(l))),a.removeListener("exit",d),a.kill()};a.once("error",c);let d=(l,P)=>{this.#r=null,r(new V(`Query Engine exited with code ${l} and signal ${P}`))};return a.once("exit",d),a.stdout.on("data",i),this.#e.debug&&(a.stderr.on("data",console.error.bind(console,"[Query Engine]")),a.stdout.on("data",console.debug.bind(console,"[Query Engine]"))),await this.#r}async stop(){if(this.#r==null)return;let{childProcess:t}=await this.#r;t.exitCode==null&&t.signalCode==null&&(this.#r=null,t.kill(),await(0,It.once)(t,"exit"))}async#s(){this.#e.debug&&console.debug("[Query Engine] getting engine commit hash...");let t=await this.#a();this.#e.debug&&console.debug("[Query Engine] got engine commit hash",t);let r=Ye(this.#e.clientVersion,t);this.#e.debug&&console.debug("[Query Engine] cache directory path",r),await(0,Lt.mkdir)(r,{recursive:!0});let{binaryTarget:n}=this.#e.platform,o=n==="windows"?".exe":"",s=(0,Bt.join)(r,`query-engine-${n}${o}`);return this.#e.debug&&console.debug("[Query Engine] binary path",s),(on==="1"||await Ze(s)===!1)&&await this.#o({commitHash:t,extension:o,engineBinaryPath:s}),s}async#a(){let t=await fetch(`https://registry.npmjs.org/@prisma/client/${this.#e.clientVersion}`);if(!t.ok)throw new Error(`Couldn't fetch package.json from npm registry, status code: ${t.status}`);let n=(await t.json()).devDependencies?.["@prisma/engines-version"];if(!n)throw new Error("Couldn't find engines version in package.json");let o=n.split(".").at(-1);if(!o)throw new Error("Couldn't find commit hash in engines version");return o}async#o(t){let{commitHash:r,extension:n,engineBinaryPath:o}=t,{binaryTarget:s}=this.#e.platform,a=`https://binaries.prisma.sh/all_commits/${r}/${s}/query-engine${n}.gz`;this.#e.debug&&console.debug("[Query Engine] downloading engine from url",a);let i=await fetch(a);if(!i.ok)throw new Error(`Couldn't download engine. URL: ${a}, status code: ${i.status}`);_t&&await(0,Nt.setTimeout)(Number(_t)),await et(await i.arrayBuffer(),o),this.#e.debug&&console.debug("[Query Engine] downloaded and saved at",o)}#n(t){let r={};for(let[n,o]of Object.entries(t))o!=null&&(r[n]=o);return r}async#i(t,r,n){let{url:o}=await this.#r,s=this.#n(r),a=await fetch(`${o}/transaction/${t}/${n}`,{headers:{...s,"Content-Type":"application/json"},method:"POST"});if(!a.ok)throw await U.fromResponse(a);try{return await a.json()}catch{return{}}}};V=class extends Error{name="EngineStartError"},U=class e extends Error{constructor(r,n,o){super(`${r}: Query Engine response status ${n}, body: ${o}`);this.action=r;this.statusCode=n;this.responseBody=o}name="EngineHttpError";static async fromResponse(r){let n=new URL(r.url),o=await r.text();return new e(n.pathname,r.status,o)}}});async function Ct(e){let{output:t,success:r}=(0,v.safeParse)(an,await e.req.json(),{abortEarly:!0});return r?t:e.text("Invalid input",400)}var v,an,Mt=S(()=>{"use strict";u();v=require("valibot"),an=(0,v.object)({tags:(0,v.union)([(0,v.pipe)((0,v.array)((0,v.string)()),(0,v.minLength)(1)),(0,v.literal)("all")])})});async function kt(e){return Ie===void 0&&(Ie=await L.Server.create({databaseUrl:e.get("db").connectionString,maxResponseSize:(0,L.parseSize)("128 MiB"),queryTimeout:(0,L.parseDuration)("PT5M"),maxTransactionTimeout:(0,L.parseDuration)("PT5M"),maxTransactionWaitTime:(0,L.parseDuration)("PT5M"),perRequestLogContext:{logFormat:"text",logLevel:e.get("debug")?"debug":"off"}})),Ie}var L,ie,Ie,Ut=S(()=>{"use strict";u();L=require("@prisma/query-plan-executor"),ie=require("@prisma/query-plan-executor")});async function Be(e){let r=new TextEncoder().encode(e),n=await crypto.subtle.digest("SHA-256",r);return Array.from(new Uint8Array(n)).map(a=>a.toString(16).padStart(2,"0")).join("")}function Ht(e){let t=e.req.param("schemaHash"),r=le.get(t);return r==null?e.json({EngineNotStarted:{reason:"SchemaMissing"}},404):{schemaHash:t,schemas:r}}async function Gt(e,t,r){let n=Le.Buffer.from(e,"base64").toString("utf8"),o=(0,ce.getSchema)(n),s=o.list.find(d=>d.type==="datasource");if(!s)throw new Error("No datasource block found in schema.");let a=s.assignments.find(d=>d.type==="assignment"&&d.key==="url");a?a.value=`"${t.toString()}"`:s.assignments.push({key:"url",type:"assignment",value:`"${t.toString()}"`});let i=(0,ce.printSchema)(o);r&&console.log("[Accelerate] schema with override:",i);let c=await Be(i);return{base64Override:Le.Buffer.from(i,"utf8").toString("base64"),overrideHash:c}}var Le,ce,le,Wt=S(()=>{"use strict";u();Le=require("buffer"),ce=require("@mrleebo/prisma-ast"),le=new Map});function ue(e){let{req:t}=e;return{traceparent:t.header("traceparent"),"X-capture-telemetry":t.header("X-capture-telemetry")}}var jt=S(()=>{"use strict";u()});async function Ft(e){let{issues:t,output:r,success:n}=(0,p.safeParse)(cn,await e.req.json(),{abortEarly:!0});return n?r:e.json({EngineNotStarted:{reason:"InvalidRequest",issues:t}},400)}function qt(e,t){let{output:r,success:n}=(0,p.safeParse)(ln,e);return n?r:t.json({EngineMalfunction:{}},500)}var p,cn,ln,zt=S(()=>{"use strict";u();p=require("valibot"),cn=(0,p.object)({isolation_level:(0,p.optional)((0,p.string)()),max_wait:(0,p.pipe)((0,p.number)(),(0,p.integer)(),(0,p.minValue)(0)),timeout:(0,p.pipe)((0,p.number)(),(0,p.integer)(),(0,p.minValue)(0))});ln=(0,p.looseObject)({id:(0,p.union)([(0,p.string)(),(0,p.number)()])})});var Jt={};je(Jt,{accelerateRoute:()=>K});async function Ne(e){let{req:t}=e,r=Ht(e);if(r instanceof Response)return r;let{base64Override:n,overrideHash:o}=r.schemas;return await H.get({base64Schema:n,clientVersion:process.env.PRISMA_DEV_FORCE_CLIENT_VERSION||t.param("clientVersion"),debug:e.get("debug"),platform:e.get("platform"),schemaHash:o})}var Vt,Kt,N,K,un,J,dn,mn,Qt=S(()=>{"use strict";u();Vt=require("hono/http-exception"),Kt=require("hono/tiny"),N=require("hono/validator");pe();Mt();Oe();Ut();Wt();jt();zt();K=new Kt.Hono;K.post("/invalidate",(0,N.validator)("header",B),async e=>{let t=await Ct(e);return t instanceof Response?t:e.body(null)});un="/:clientVersion/:schemaHash",J=K.basePath(un);K.route("/",J);dn=["/graphql","/itx/:transactionId/graphql"];J.on("POST",[...dn],(0,N.validator)("header",B),async e=>{let{req:t}=e;try{let r=await Ne(e);if(r instanceof Response)return r;let n=await t.text(),o=t.param("transactionId"),s=await r.request(n,{...ue(e),"X-transaction-id":o});return e.text(s)}catch(r){return ae(r,e)}});J.basePath("/itx/:transactionId").on("POST",["/commit","/rollback"],(0,N.validator)("header",B),async e=>{let{req:t}=e;try{let r=await Ne(e);if(r instanceof Response)return r;let o=`${t.routePath.split("/").filter(Boolean).at(-1)}Transaction`,s=t.param("transactionId"),a=await r[o](s,ue(e));return e.json(a)}catch(r){return ae(r,e)}});J.put("/schema",(0,N.validator)("header",B),async e=>{let{req:t}=e,r=await t.text();if(!r)return e.text("Missing schema",400);let n=t.param("schemaHash"),o=le.get(n);if(o==null){if(n!==await Be(r))return e.text("Schema hash mismatch",400);let s=await Gt(r,e.get("db").prismaORMConnectionString,e.get("debug"));return le.set(n,{base64Original:r,...s}),e.text(n)}return r!==o.base64Original?e.text("Schema mismatch",400):e.text(n)});J.post("/transaction/start",(0,N.validator)("header",B),async e=>{let{req:t}=e,r=await Ft(e);if(r instanceof Response)return r;try{let n=await Ne(e);if(n instanceof Response)return n;let o=await n.startTransaction(r,ue(e)),s=qt(o,e);if(s instanceof Response)return s;let{id:a}=s,i=t.param("clientVersion"),c=t.param("schemaHash");return e.json({...o,"data-proxy":{endpoint:`${new URL(t.url).origin}/${i}/${c}/itx/${a}`}})}catch(n){return ae(n,e)}});mn=[["/connection-info","GET"],["/query","POST"],["/transaction/start","POST"],["/transaction/:transactionId/commit","POST"],["/transaction/:transactionId/query","POST"],["/transaction/:transactionId/rollback","POST"]];for(let[e,t]of mn)K.on(t,e,(0,N.validator)("header",B),async r=>{let n=r.req.header("prisma-engine-hash");if(n!=="0.0.0"&&n!==ie.version)throw new Vt.HTTPException(400,{message:`Using an HTTP connection string is not supported with Prisma Client version ${n} by this version of \`prisma dev\`. Please either use a direct TCP connection string or upgrade your client to version ${ie.version}.`});return await(await kt(r)).fetch(r.req.raw)})});var Zt={};je(Zt,{utilityRoute:()=>$e});var Xt,Yt,$e,yo,er=S(()=>{"use strict";u();Xt=require("hono/tiny"),Yt=require("http-status-codes"),$e=new Xt.Hono;$e.post("/database/dump",async e=>{let t=e.get("db"),r=e.get("databaseDumpPath");return await t.dump(r),e.json({dumpPath:r},Yt.StatusCodes.CREATED)});yo=$e.get("/health",e=>e.json({name:e.get("name")}))});var En={};module.exports=Rr(En);u();var gr=require("timers/promises");u();u();pe();u();var Dt=require("pathe/utils");ee();u();var I=require("get-port-please"),re=require("remeda"),ye=51214,be=51213,ve=51215,te=65535,M=0,O=-1/0;async function Ee(e){let{debug:t,name:r,requestedPorts:n,servers:o}=e,{portsUsedByOtherServers:s,portsUsedByThisServerLastTime:a}=Nr(r,o);t&&(console.debug(`ports used by other servers: ${Object.keys(s).join(", ")}`),console.debug(`ports used by "${r}" server last time: ${JSON.stringify(a)}`));let i={databasePort:O,port:O,shadowDatabasePort:O},c=["port","databasePort","shadowDatabasePort"];for(let d of c){let l=await Lr({debug:t,portKey:d,portsUsedByOtherServers:s,portsUsedByThisServerLastTime:a,requestedPorts:n})??await Br({debug:t,pickedPorts:i,portKey:d,portsUsedByOtherServers:s,portsUsedByThisServerLastTime:a});t&&console.debug(`Got port for "${d}": ${l}`),i[d]=l}return t&&console.debug(`Picked ports: ${JSON.stringify(i)}`),i}async function Lr(e){let{debug:t,portKey:r,portsUsedByOtherServers:n,portsUsedByThisServerLastTime:o,requestedPorts:s}=e,{[r]:a,...i}=s;if(st(a))return await $r({debug:t,otherRequestedPorts:i,portKey:r,portsUsedByOtherServers:n,requestedPort:a}),a;let c=o?.[r]??O;if(!st(c))return t&&console.debug(`No port specified for "${r}". Trying to pick a new port.`),null;let d=c in n;return d||Object.values(i).includes(c)?(t&&console.debug(`Port ${c} that was used last time for this server, ${d?"is also used by another server":"has been requested for another service"}. Trying to pick a new port.`),null):await(0,I.checkPort)(c)===!1?(t&&console.debug(`Port ${c}, that was used last time for this server, is not available. Trying to pick a new port.`),null):(t&&console.debug(`Using port ${c} for "${r}" as it was used last time and is available.`),c)}async function Br(e){let{debug:t,pickedPorts:r,portKey:n,portsUsedByOtherServers:o,portsUsedByThisServerLastTime:s}=e,a=Math.max(ye,be,ve)+1,i=[...Object.values(r),...Object.keys(o).map(Number),...Object.values(s||{})],c=Math.min(Math.max(a,...i)+100,te),d=(0,re.difference)((0,re.range)(a,c),i),l={port:be,databasePort:ye,shadowDatabasePort:ve}[n];try{return await(0,I.getPort)({port:l in o||Object.values(r).includes(l)||Object.values(s||{}).includes(l)?void 0:l,ports:d})}catch(P){if(P instanceof Error&&P.name==="GetPortError"&&c+1<=te)return t&&console.debug(`Expanding port lookup to range [${c+1}, ${te}].`),await(0,I.getPort)({portRange:[c+1,te]});throw P}}function st(e){return Number.isFinite(e)&&e>=0}function Nr(e,t){let r={},n;for(let o of t){let{databasePort:s,port:a,shadowDatabasePort:i}=o;if(o.name===e){n={databasePort:s,port:a,shadowDatabasePort:i};continue}r[s]=!0,r[a]=!0,r[i]=!0}return{portsUsedByOtherServers:r,portsUsedByThisServerLastTime:n}}async function $r(e){let{debug:t,otherRequestedPorts:r,portKey:n,portsUsedByOtherServers:o,requestedPort:s}=e;if(s!==M){if(s in o)throw t&&console.error(`Port ${s} was requested for "${n}", but is already used by another server.`),new Se(s);if(Object.values(r).includes(s))throw t&&console.error(`Port ${s} was requested for "${n}", but also for another key.`),new we(s);if((0,I.isUnsafePort)(s))throw t&&console.error(`Port ${s} was requested for "${n}", but is unsafe.`),new A(s);if(await(0,I.checkPort)(s)===!1)throw t&&console.error(`Port ${s} was requested for "${n}", but is not available.`),new A(s)}}var A=class extends Error{constructor(r){super(`Port \`${r}\` is not available.`);this.port=r}name="PortNotAvailableError"},we=class extends Error{constructor(r){super(`Port number \`${r}\` was requested twice. Please choose a different port for each service.`);this.port=r}name="PortRequestedTwiceError"},Se=class extends Error{constructor(r){super(`Port number \`${r}\` belongs to another Prisma Dev server. Please choose a different port.`);this.port=r}name="PortBelongsToAnotherServerError"};u();var F=require("fs"),k=require("fs/promises"),ct=require("module"),lt=require("path"),q=require("url"),Cr=(0,ct.createRequire)(f),Mr=["pglite.data","pglite.wasm"],ut={amcheck:"amcheck.tar.gz",bloom:"bloom.tar.gz",btree_gin:"btree_gin.tar.gz",btree_gist:"btree_gist.tar.gz",citext:"citext.tar.gz",cube:"cube.tar.gz",dict_int:"dict_int.tar.gz",dict_xsyn:"dict_xsyn.tar.gz",earthdistance:"earthdistance.tar.gz",file_fdw:"file_fdw.tar.gz",fuzzystrmatch:"fuzzystrmatch.tar.gz",hstore:"hstore.tar.gz",intarray:"intarray.tar.gz",isn:"isn.tar.gz",lo:"lo.tar.gz",ltree:"ltree.tar.gz",pageinspect:"pageinspect.tar.gz",pg_buffercache:"pg_buffercache.tar.gz",pg_freespacemap:"pg_freespacemap.tar.gz",pg_surgery:"pg_surgery.tar.gz",pg_trgm:"pg_trgm.tar.gz",pg_visibility:"pg_visibility.tar.gz",pg_walinspect:"pg_walinspect.tar.gz",seg:"seg.tar.gz",tablefunc:"tablefunc.tar.gz",tcn:"tcn.tar.gz",tsm_system_rows:"tsm_system_rows.tar.gz",tsm_system_time:"tsm_system_time.tar.gz",unaccent:"unaccent.tar.gz",uuid_ossp:"uuid-ossp.tar.gz",vector:"vector.tar.gz"},kr=[...Mr.map(e=>({fileName:e,kind:"core",name:e})),...Object.entries(ut).map(([e,t])=>({fileName:t,kind:"extension",name:e}))],oe=new Map,Ur=Symbol.for("@prisma/dev/bundled-pglite-runtime-asset-sources"),ne=null;async function Re(){await zr();let e=mt();if(e)return await Hr(e);let t=Fr(),r=t.href,n=oe.get(r);return n||(n=Gr(t),oe.set(r,n)),await n}async function Hr(e){let t=`bundled:${e.wasmModule.href}:${e.fsBundle.href}`,r=oe.get(t);return r||(r=Wr(e),oe.set(t,r)),await r}async function Gr(e){let[t,r]=await Promise.all([(0,k.readFile)(new URL("pglite.data",e)),(0,k.readFile)(new URL("pglite.wasm",e))]),n=pt();return{extensions:Object.fromEntries(Object.entries(ut).map(([o,s])=>[o,new URL(s,e)])),fsBundle:new Blob([Uint8Array.from(t)]),wasmModule:await n.compile(r)}}async function Wr(e){let[t,r]=await Promise.all([it(e.fsBundle),it(e.wasmModule)]),n=pt();return{extensions:e.extensions,fsBundle:new Blob([Uint8Array.from(t)]),wasmModule:await n.compile(r)}}function dt(e){return e instanceof URL?at(e):at((0,q.pathToFileURL)(e))}function at(e){return e.href.endsWith("/")?e:new URL(`${e.href}/`)}function jr(){let e=Cr.resolve("@electric-sql/pglite");return dt((0,lt.dirname)(e))}function Fr(){let e=dt(new URL("./",f));if(qr(e))return e;if(Vr())return jr();throw new Error("Unable to locate PGlite runtime assets. If you bundled @prisma/dev, copy them next to the bundle with copyPrismaDevRuntimeAssets().")}function qr(e){return kr.every(t=>(0,F.existsSync)((0,q.fileURLToPath)(new URL(t.fileName,e))))}function mt(){return globalThis[Ur]??null}async function zr(){!Kr()||mt()||(ne||(ne=import("./runtime-assets-manifest.bun.js").then(()=>{}).catch(e=>{throw ne=null,e})),await ne)}function Vr(){let e=(0,q.fileURLToPath)(new URL("../package.json",f));if(!(0,F.existsSync)(e))return!1;try{return JSON.parse((0,F.readFileSync)(e,"utf8")).name==="@prisma/dev"}catch{return!1}}function Kr(){return typeof globalThis.Bun<"u"}function pt(){let e=globalThis.WebAssembly;if(!e)throw new Error("WebAssembly is not available in this runtime.");return e}async function it(e){if(e.protocol==="file:")return await(0,k.readFile)(e);let t=await fetch(e);if(!t.ok)throw new Error(`Failed to fetch runtime asset ${e.href}: ${t.status} ${t.statusText}`);return new Uint8Array(await t.arrayBuffer())}u();var Pt=require("@electric-sql/pglite"),R="_prisma_dev_wal",Te="events",yt="install_all_triggers",gt="capture_event",ft="prisma_dev_wal_capture",z=new WeakMap,Jr=new Set(["ALTER","COMMIT","COPY","CREATE","DELETE","DROP","INSERT","MERGE","TRUNCATE","UPDATE"]);async function De(e,t){let r=z.get(e);if(r&&!r.closed)return r.bridge;let n=e.execProtocolRaw.bind(e),o={bridge:{close:async()=>{o.closed||(o.closed=!0,o.subscribers.clear(),e.execProtocolRaw===s&&(e.execProtocolRaw=n),await o.pollPromise,z.delete(e))},poll:async()=>{await ht(o,e)},subscribe:a=>(o.subscribers.add(a),()=>{o.subscribers.delete(a)})},closed:!1,ensureInfrastructurePromise:null,pendingPoll:!1,pollPromise:null,subscribers:new Set,suppressDepth:0},s=async(a,i)=>{let c=await n(a,i);return!o.closed&&o.suppressDepth===0&&wt(c)&&ht(o,e),c};return e.execProtocolRaw=s,z.set(e,o),await St(o,e),o.bridge}async function bt(e){let t=z.get(e);t&&await t.bridge.close()}function vt(e){for(let t of e){if(t.name!=="commandComplete"||typeof t.text!="string")continue;let r=t.text.split(/\s+/,1)[0]?.toUpperCase();if(r&&Jr.has(r))return!0}return!1}function wt(e){if(e.length===0)return!1;let t=[];return new Pt.protocol.Parser().parse(e,n=>{t.push(n)}),vt(t)}async function St(e,t){e.ensureInfrastructurePromise??=Ae(e,t,async()=>{await t.exec(`CREATE SCHEMA IF NOT EXISTS "${R}"`),await t.exec(`
+      CREATE TABLE IF NOT EXISTS "${R}"."${Te}" (
         id BIGSERIAL PRIMARY KEY,
@@ -14,4 +14,4 @@ txid BIGINT NOT NULL DEFAULT txid_current(),
       )
-    `),await e.exec(`
-      CREATE OR REPLACE FUNCTION "${T}"."${et}"()
+    `),await t.exec(`
+      CREATE OR REPLACE FUNCTION "${R}"."${gt}"()
       RETURNS trigger
@@ -21,7 +21,7 @@ LANGUAGE plpgsql
       BEGIN
-        IF TG_TABLE_SCHEMA = '${T}' THEN
+        IF TG_TABLE_SCHEMA = '${R}' THEN
           RETURN COALESCE(NEW, OLD);
         END IF;
 
-        INSERT INTO "${T}"."${ye}" (
+        INSERT INTO "${R}"."${Te}" (
           txid,
@@ -46,4 +46,4 @@ schema_name,
       $$;
-    `),await e.exec(`
-      CREATE OR REPLACE FUNCTION "${T}"."${nt}"()
+    `),await t.exec(`
+      CREATE OR REPLACE FUNCTION "${R}"."${yt}"()
       RETURNS void
@@ -60,3 +60,3 @@ LANGUAGE plpgsql
           WHERE c.relkind IN ('r', 'p')
-            AND n.nspname NOT IN ('${T}', 'information_schema', 'pg_catalog')
+            AND n.nspname NOT IN ('${R}', 'information_schema', 'pg_catalog')
             AND n.nspname NOT LIKE 'pg_temp_%'
@@ -69,3 +69,3 @@ AND n.nspname NOT LIKE 'pg_toast%'
             WHERE tgrelid = target
-              AND tgname = '${tt}'
+              AND tgname = '${ft}'
           ) THEN
@@ -76,4 +76,4 @@ CONTINUE;
           EXECUTE format(
-            'CREATE TRIGGER %I AFTER INSERT OR UPDATE OR DELETE ON %s FOR EACH ROW EXECUTE FUNCTION "${T}"."${et}"()',
-            '${tt}',
+            'CREATE TRIGGER %I AFTER INSERT OR UPDATE OR DELETE ON %s FOR EACH ROW EXECUTE FUNCTION "${R}"."${gt}"()',
+            '${ft}',
             target::text
@@ -84,5 +84,5 @@ );
       $$;
-    `),await lt(t,e)}),await t.ensureInfrastructurePromise}async function lt(t,e){await Se(t,e,async()=>{await e.query(`SELECT "${T}"."${nt}"()`)})}async function Er(t,e){await ct(t,e),await lt(t,e);let r=await Se(t,e,async()=>await e.query(`
+    `),await Et(e,t)}),await e.ensureInfrastructurePromise}async function Et(e,t){await Ae(e,t,async()=>{await t.query(`SELECT "${R}"."${yt}"()`)})}async function Qr(e,t){await St(e,t),await Et(e,t);let r=await Ae(e,t,async()=>await t.query(`
       WITH drained AS (
-        DELETE FROM "${T}"."${ye}"
+        DELETE FROM "${R}"."${Te}"
         RETURNING txid, schema_name, table_name, op, row_data, old_row_data, id
@@ -93,4 +93,4 @@ )
       ORDER BY id
-    `));if(r.rows.length===0||t.subscribers.size===0)return;let n=r.rows.map(Tr);for(let o of t.subscribers)queueMicrotask(()=>{if(!t.closed&&t.subscribers.has(o))try{o(n)}catch(s){console.error("[WAL bridge] subscriber failed",s)}})}async function rt(t,e){if(!t.closed){if(t.pollPromise){t.pendingPoll=!0,await t.pollPromise;return}t.pollPromise=(async()=>{do t.pendingPoll=!1,await Er(t,e);while(t.pendingPoll&&!t.closed)})().finally(()=>{t.pollPromise=null}),await t.pollPromise}}async function Se(t,e,r){t.suppressDepth+=1;try{return await r()}finally{t.suppressDepth-=1,t.suppressDepth===0&&!t.closed&&G.get(e)!==t&&(t.closed=!0)}}function Tr(t){return{oldRecord:t.old_row_data,record:t.row_data,schema:t.schema_name,table:t.table_name,txid:String(t.txid),type:Dr(t.op)}}function Dr(t){switch(t.toLowerCase()){case"delete":return"delete";case"insert":return"insert";case"update":return"update";default:throw new Error(`Unsupported WAL bridge operation: ${t}`)}}var xr=10,y={connectionLimit:xr,connectTimeout:0,database:"template1",maxIdleConnectionLifetime:0,password:"postgres",poolTimeout:0,socketTimeout:0,sslMode:"disable",username:"postgres"},Rr=`postgres://${y.username}:${y.password}@localhost`,mt=new URLSearchParams({sslmode:y.sslMode}),Ar=new URLSearchParams({...Object.fromEntries(mt.entries()),connection_limit:String(y.connectionLimit),connect_timeout:String(y.connectTimeout),max_idle_connection_lifetime:String(y.maxIdleConnectionLifetime),pool_timeout:String(y.poolTimeout),socket_timeout:String(y.socketTimeout)});async function we(t,e){let r=t==="database"?e.databasePort:e.shadowDatabasePort;if(e.dryRun)return ut(t,e,{db:null,port:r,server:null});let{debug:n}=e,s=await(t==="shadow_database"?Or:gt)(e.pgliteDataDirPath,n);n&&s.onNotification((l,P)=>{console.debug(`[${t}][${l}] ${P}`)});let{PGLiteSocketServer:a}=await import("@electric-sql/pglite-socket"),i=t==="shadow_database"?e.shadowDatabaseIdleTimeoutMillis:e.databaseIdleTimeoutMillis,c=new a({db:s,debug:n,idleTimeout:Number.isFinite(i)?i:0,inspect:n,maxConnections:y.connectionLimit,port:r});n&&(c.addEventListener("listening",l=>{let{detail:P}=l;console.debug(`[${t}] server listening on ${JSON.stringify(P)}`)}),c.addEventListener("connection",l=>{let{clientAddress:P,clientPort:E}=l.detail;console.debug(`[${t}] client connected from ${P}:${E}`)}),c.addEventListener("error",l=>{let{detail:P}=l;console.error(`[${t}] server error:`,P)}));try{await c.start()}catch(l){throw l instanceof Error&&"code"in l&&l.code==="EADDRINUSE"?new R(r):l}let p=Number(c.getServerConn().split(":").at(1));return e[t==="database"?"databasePort":"shadowDatabasePort"]=p,ut(t,e,{db:s,port:p,server:c})}function ut(t,e,r){let{debug:n}=e,{db:o,port:s,server:a}=r||{};return n&&console.debug(`[${t}] server started on port ${s}`),{...y,attachWalEventBridge:async()=>{if(t!=="database"||!o)throw new Error("WAL bridge is only available for the primary database server");return await ve(o)},close:async()=>{let i=[];try{await a?.stop(),n&&console.debug(`[${t}] server stopped on port ${s}`)}catch(c){console.error(`[${t}] server stop error`,c),i.push(c)}if(t==="database"){try{o&&await st(o),n&&console.debug(`[${t}] closed WAL bridge`)}catch(c){console.error(`[${t}] WAL bridge close error`,c),i.push(c)}try{await o?.syncToFs(),n&&console.debug(`[${t}] synced to filesystem`)}catch(c){console.error(`[${t}] sync error`,c),i.push(c)}}try{await o?.close(),n&&console.debug(`[${t}] closed`)}catch(c){console.error(`[${t}] close error`,c),i.push(c)}if(i.length>0)throw new AggregateError(i,`Failed to close ${t} properly`)},connectionString:dt(s,mt),dump:async i=>{t==="shadow_database"||!o||await _r({db:o,debug:n,destinationPath:i})},port:s,prismaORMConnectionString:dt(s,Ar),terminalCommand:`PGPASSWORD=${y.password} PGSSLMODE=${y.sslMode} psql -h localhost -p ${s} -U ${y.username} -d ${y.database}`}}function dt(t,e){return`${Rr}:${t}/${y.database}?${e.toString()}`}async function gt(t,e){let{PGlite:r}=await import("@electric-sql/pglite");return await r.create({database:y.database,dataDir:t,debug:e?5:void 0,extensions:await ft(),relaxedDurability:!1,username:y.username})}async function Or(t,e){let{PGlite:r}=await import("@electric-sql/pglite");return await r.create({database:y.database,dataDir:"memory://",debug:e?5:void 0,extensions:await ft(),relaxedDurability:!1,username:y.username})}async function ft(){let t=await Promise.all([import("@electric-sql/pglite/contrib/amcheck"),import("@electric-sql/pglite/contrib/bloom"),import("@electric-sql/pglite/contrib/btree_gin"),import("@electric-sql/pglite/contrib/btree_gist"),import("@electric-sql/pglite/contrib/citext"),import("@electric-sql/pglite/contrib/cube"),import("@electric-sql/pglite/contrib/dict_int"),import("@electric-sql/pglite/contrib/dict_xsyn"),import("@electric-sql/pglite/contrib/earthdistance"),import("@electric-sql/pglite/contrib/file_fdw"),import("@electric-sql/pglite/contrib/fuzzystrmatch"),import("@electric-sql/pglite/contrib/hstore"),import("@electric-sql/pglite/contrib/intarray"),import("@electric-sql/pglite/contrib/isn"),import("@electric-sql/pglite/contrib/lo"),import("@electric-sql/pglite/contrib/ltree"),import("@electric-sql/pglite/contrib/pageinspect"),import("@electric-sql/pglite/contrib/pg_buffercache"),import("@electric-sql/pglite/contrib/pg_freespacemap"),import("@electric-sql/pglite/contrib/pg_surgery"),import("@electric-sql/pglite/contrib/pg_trgm"),import("@electric-sql/pglite/contrib/pg_visibility"),import("@electric-sql/pglite/contrib/pg_walinspect"),import("@electric-sql/pglite/contrib/seg"),import("@electric-sql/pglite/contrib/tablefunc"),import("@electric-sql/pglite/contrib/tcn"),import("@electric-sql/pglite/contrib/tsm_system_rows"),import("@electric-sql/pglite/contrib/tsm_system_time"),import("@electric-sql/pglite/contrib/unaccent"),import("@electric-sql/pglite/contrib/uuid_ossp"),import("@electric-sql/pglite/vector")]);return Object.assign({},...t)}async function _r(t){let{dataDir:e,db:r,debug:n,destinationPath:o}=t,s=r||await gt(e,n),{pgDump:a}=await import("@electric-sql/pglite-tools/pg_dump"),i=await a({args:["--schema-only","--no-owner"],fileName:o?(0,pt.filename)(o):void 0,pg:await s.clone()});return o?(n&&console.debug(`[DB] Dumping database to ${o}`),await Je(i,o)):(n&&console.debug("[DB] Dumping database to memory"),await i.text())}d();var Gt=require("http"),Ft=require("util"),qt=u(require("@prisma/get-platform"),1);Ee();Te();async function Vt(t,e){let{port:r}=e;if(e.dryRun)return jt(r,null);let n=await Hr(t,e),{promise:o,reject:s,resolve:a}=ee(),{serve:i}=await import("@hono/node-server"),c=i({createServer:Gt.createServer,fetch:n.fetch,overrideGlobalObjects:!1,port:r},a);c.on("error",l=>{if(typeof l=="object"&&"code"in l&&l.code==="EADDRINUSE")return s(new R(r));console.error("[Accelerate]",l)});let{port:p}=await o;return e.port=p,jt(p,c)}function jt(t,e){return{async close(){e&&await Promise.allSettled([(0,Ft.promisify)(e.close.bind(e))(),H.stopAll()])},port:t,url:`http://localhost:${t}`}}async function Hr(t,e){let{debug:r}=e,[{Hono:n},{accelerateRoute:o},{utilityRoute:s}]=await Promise.all([import("hono/tiny"),Promise.resolve().then(()=>(Mt(),Bt)),Promise.resolve().then(()=>(Wt(),Ut))]),a=new n,i=await qt.default.getPlatformInfo();if(r&&console.debug("[Accelerate] platform info: %s",JSON.stringify(i)),r){let{logger:p}=await import("hono/logger");a.use("*",p((...l)=>console.log("[Accelerate]",...l)))}a.use("*",async(p,l)=>(p.set("databaseDumpPath",e.databaseDumpPath),p.set("db",t),p.set("debug",!!r),p.set("name",e.name),p.set("platform",i),p.set("shadowDBPort",e.shadowDatabasePort),await l()));let c=new n;return c.route("/",o),c.route("/",s),a.route("/",c),a}d();var zt=require("fs/promises"),L=require("pathe"),U=require("proper-lockfile"),Le=require("std-env"),m=require("valibot");z();d();var Ur=require("timers/promises"),Kt=require("std-env");function Qt(t,e){if(t==null)return!1;try{return Kt.process.kill?.(t,0)??!0}catch(r){return e&&console.error(`Error checking if process with PID ${t} exists:`,r),!1}}var $e=(0,m.pipe)((0,m.string)(),(0,m.url)()),Jt=(0,m.object)({connectionString:$e,prismaORMConnectionString:(0,m.optional)($e),terminalCommand:(0,m.optional)((0,m.string)())}),Xt=(0,m.object)({url:$e}),_e=(0,m.pipe)((0,m.number)(),(0,m.integer)(),(0,m.minValue)(1)),Wr=(0,m.object)({database:Jt,http:Xt,ppg:Xt,shadowDatabase:Jt}),jr=(0,m.object)({databasePort:_e,exports:(0,m.optional)(Wr),name:(0,m.pipe)((0,m.string)(),(0,m.minLength)(1)),pid:(0,m.optional)((0,m.pipe)((0,m.number)(),(0,m.integer)(),(0,m.minValue)(0))),port:_e,shadowDatabasePort:_e,version:(0,m.literal)("1")}),Be=Symbol("initialize"),Ie="default",D=class{_databasePort;databaseConnectTimeoutMillis;databaseIdleTimeoutMillis;debug;dryRun;name;persistenceMode;pid;shadowDatabaseConnectTimeoutMillis;shadowDatabaseIdleTimeoutMillis;_port;_shadowDatabasePort;constructor(e){this._databasePort=e.databasePort??_,this.databaseConnectTimeoutMillis=e.databaseConnectTimeoutMillis??6e4,this.databaseIdleTimeoutMillis=e.databaseIdleTimeoutMillis??1/0,this.debug=e.debug??!1,this.dryRun=e.dryRun??!1,this.name=e.name??Ie,this.persistenceMode=e.persistenceMode,this.pid=e.pid??Le.process.pid,this.shadowDatabaseConnectTimeoutMillis=e.shadowDatabaseConnectTimeoutMillis??this.databaseConnectTimeoutMillis,this.shadowDatabaseIdleTimeoutMillis=e.shadowDatabaseIdleTimeoutMillis??this.databaseIdleTimeoutMillis,this._port=e.port??_,this._shadowDatabasePort=e.shadowDatabasePort??_}static async createExclusively(e){let r=e?.dryRun!==!0&&e?.persistenceMode==="stateful"?new K(e):new Ne(e);return await r[Be](),r}static async fromServerDump(e){let{debug:r,name:n=Ie}=e??{},o=j(n),s=K.getServerDumpPath(o),a=await Xe(s);if(a==null)return r&&console.debug(`[State] No server dump file found at: ${s}`),null;r&&(console.debug(`[State] server dump file found at "${s}":`),console.debug(a));let{issues:i,output:c,success:p}=(0,m.safeParse)((0,m.pipe)((0,m.string)(),(0,m.parseJson)(),jr),a);if(!p)throw r&&console.debug(`[State] Invalid server dump file at "${s}":
-${JSON.stringify(i,null,2)}`),new Error(`Invalid Prisma Dev state for "${n}".`);return new K({databasePort:c.databasePort,debug:r,dryRun:!1,name:n,pid:c.pid,port:c.port,serverDump:c,shadowDatabasePort:c.shadowDatabasePort})}static async scan(e){let{debug:r,globs:n}=e??{},o=(0,L.join)(j(Ie),"..");r&&console.debug(`[State] scanning for server states in: ${o}`);let s=await Ye(o,n);return r&&console.debug(`[State] found server names: ${JSON.stringify(s)}`),await Promise.all(s.map(a=>Gr(a,e)))}get databasePort(){return this._databasePort}set databasePort(e){this.#t("databasePort",e)}get port(){return this._port}set port(e){this.#t("port",e)}get shadowDatabasePort(){return this._shadowDatabasePort}set shadowDatabasePort(e){this.#t("shadowDatabasePort",e)}#t(e,r){if(r<0||!Number.isInteger(r))throw new Error(`Invalid port number: ${r}`);let n=`_${e}`;if(this[n]!==M&&this[n]!==r)throw new Error(`\`${e}\` is already set to ${this[n]}, cannot change it to ${r}`);this[n]=r}},Ne=class extends D{constructor(e){super({...e,databasePort:e?.databasePort||M,persistenceMode:"stateless",port:e?.port||M,shadowDatabasePort:e?.shadowDatabasePort||M})}get databaseDumpPath(){return"<DUMP_PATH>"}get pgliteDataDirPath(){return"memory://"}async[Be](){let e;try{e=await D.scan({debug:this.debug,onlyMetadata:!0})}catch(n){this.debug&&console.warn("[State] failed to scan for existing servers, assuming filesystem does not exist or other reasons.",n),e=[]}let r=await be({debug:this.debug,name:this.dryRun?this.name:"",requestedPorts:{databasePort:this.databasePort,port:this.port,shadowDatabasePort:this.shadowDatabasePort},servers:e});this._databasePort=r.databasePort,this._port=r.port,this._shadowDatabasePort=r.shadowDatabasePort}async close(){}async writeServerDump(){}},K=class t extends D{#t;#e;#r;#s;#a;#n;#o;constructor(e){super({...e,persistenceMode:"stateful"}),this.#n=!1,this.#e=j(this.name),this.#t=(0,L.join)(this.#e,"db_dump.bak"),this.#r=(0,L.join)(this.#e,".lock"),this.#s=(0,L.join)(this.#e,".pglite"),this.#o=e?.serverDump??null,this.#a=t.getServerDumpPath(this.#e)}static getServerDumpPath(e){return(0,L.join)(e,"server.json")}get databaseDumpPath(){return this.#t}get exports(){return this.#o?.exports}get pgliteDataDirPath(){return this.#s}async[Be](){await ze(this.#e),this.debug&&console.debug(`[State] using data directory: ${this.#e}`);try{await(0,U.lock)(this.#e,{lockfilePath:this.#r}),this.debug&&console.debug(`[State] obtained lock on: ${this.#e}`);let e=await D.scan({debug:this.debug,onlyMetadata:!0}),r=await be({debug:this.debug,name:this.name,requestedPorts:{databasePort:this.databasePort,port:this.port,shadowDatabasePort:this.shadowDatabasePort},servers:e});this._databasePort=r.databasePort,this._port=r.port,this._shadowDatabasePort=r.shadowDatabasePort,await this.writeServerDump()}catch(e){throw e instanceof Error&&"code"in e&&e.code==="ELOCKED"?new ae(this):e}}async close(){if(!this.#n)try{await(0,U.unlock)(this.#e,{lockfilePath:this.#r}),this.#n=!0,this.debug&&console.debug(`[State] released lock on: ${this.#e}`)}catch(e){throw this.debug&&console.error(`[State] failed to release lock on: ${this.#e}`,e),e}}async writeServerDump(e){this.#o={name:this.name,version:"1",pid:Le.process.pid,port:this.port,databasePort:this.databasePort,shadowDatabasePort:this.shadowDatabasePort,exports:e},await(0,zt.writeFile)(this.#a,`${JSON.stringify(this.#o,null,2)}
-`,{encoding:"utf-8"})}};async function Gr(t,e){let{debug:r,onlyMetadata:n}=e||{},o=typeof t=="string"?t:t.name,s=typeof t!="string"?t:void 0,a={databasePort:s?.databasePort??-1,exports:s?.exports,name:o,pid:s?.pid,port:s?.port??-1,shadowDatabasePort:s?.shadowDatabasePort??-1,version:"1"};try{let i=s||await D.fromServerDump({debug:r,name:o});if(!i)return r&&console.debug(`[State] no server state found for name: ${o}`),{...a,status:"no_such_server"};a.databasePort=i.databasePort,a.exports=i.exports,a.pid=i.pid,a.port=i.port,a.shadowDatabasePort=i.shadowDatabasePort;let{exports:c,pid:p}=i;if(n)return{...a,status:"unknown"};if(!Qt(p,r))return r&&console.debug(`[State] server state for "${o}" has no running process with PID: ${p}`),{...a,status:"not_running"};let l=j(o);try{if(!await(0,U.check)(l,{lockfilePath:(0,L.join)(l,".lock")}))return r&&console.debug(`[State] server state for "${o}" is not locked, indicating it is not running.`),{...a,status:"starting_up"}}catch(W){r&&console.error(`[State] server state for "${o}" failed to check lock:`,W)}if(!c)return{...a,status:"starting_up"};let{http:P}=c,{hc:E}=await import("hono/client"),x=await E(P.url).health.$get();if(!x.ok)return r&&console.debug(`[State] server state for "${o}" is not live: ${JSON.stringify(x)}`),{...a,status:"not_running"};let A=await x.json();return A.name!==t?(r&&console.debug(`[State] server state for "${o}" has mismatched health response: ${JSON.stringify(A)}`),{...a,status:"unknown"}):(r&&console.debug(`[State] server state for "${t}" is live: ${JSON.stringify(A)}`),{...a,status:"running"})}catch(i){return r&&console.error(`[State] failed to get server status for "${o}":`,i),{...a,status:"error"}}}var Ce=class extends Error{name="ServerStateAlreadyExistsError";constructor(e){super(`A Prisma Dev server with the name "${e}" is already running.`)}},ae=class extends Ce{#t;name="ServerAlreadyRunningError";constructor(e){super(e.name),this.#t=e}get server(){return D.fromServerDump({debug:this.#t.debug,name:this.#t.name})}};async function Yt(t){let e=await D.createExclusively(t),r=null,n=null,o=null;try{[r,o]=await Promise.all([we("database",e),we("shadow_database",e)]);let s=await r.attachWalEventBridge();n=await Vt(r,e);let a=Fr(r,o,n,e);await e.writeServerDump(a);let i=Vr(s),c=r,p=o,l=n,P=async()=>{i.close(),await Zt(e,[l,c,p])};return{close:P,dbServer:r,httpServer:n,server:{...a,close:P,experimental:{wal:i.api},name:e.name},serverState:e,shadowDbServer:o,walBridge:s}}catch(s){return await qr(e,[n,r,o],s)}}function Fr(t,e,r,n){let o=`prisma+postgres://localhost:${r.port}/?${new URLSearchParams({api_key:Ue({databaseUrl:t.prismaORMConnectionString,name:n.name,shadowDatabaseUrl:e.prismaORMConnectionString})}).toString()}`;return{database:{connectionString:t.connectionString,prismaORMConnectionString:t.prismaORMConnectionString,terminalCommand:t.terminalCommand},http:{url:r.url},ppg:{url:o},shadowDatabase:{connectionString:e.prismaORMConnectionString,prismaORMConnectionString:e.prismaORMConnectionString,terminalCommand:e.terminalCommand}}}async function Zt(t,e){let n=(await Promise.allSettled(e.map(o=>o.close()))).filter(o=>o.status==="rejected").map(o=>new Error(o.reason));try{await t.close()}catch(o){n.push(o)}if(n.length>0)throw new AggregateError(n,"Failed to close some servers")}async function qr(t,e,r){try{await Zt(t,e.filter(n=>n!==null))}catch(n){throw new AggregateError([r,n],"Failed to start Prisma Dev server cleanly")}throw r}function Vr(t){let e=new Set;return{api:{stream:()=>{let r=()=>{},n=Kr(t,()=>{e.delete(r)});return r=()=>n.close(),e.add(r),n.stream},subscribe:r=>t.subscribe(r)},close:()=>{for(let r of[...e])r();e.clear()}}}function Kr(t,e){let r=[],n=!1,o=null,s=t.subscribe(i=>{if(!n){if(o){let c=o;o=null,c.resolve({done:!1,value:i});return}r.push(i)}}),a=()=>{if(!n&&(n=!0,s(),r.length=0,e(),o)){let i=o;o=null,i.resolve({done:!0,value:void 0})}};return{close:a,stream:{[Symbol.asyncIterator](){return this},next(){return r.length>0?Promise.resolve({done:!1,value:r.shift()}):n?Promise.resolve({done:!0,value:void 0}):new Promise((i,c)=>{o={reject:c,resolve:i}})},return(){return a(),Promise.resolve({done:!0,value:void 0})},throw(i){let c=o;return a(),c&&c.reject(i),Promise.reject(i instanceof Error?i:new Error(String(i)))}}}}async function er(t){let{server:e}=await Yt(t);return e}var ie;process.once("SIGTERM",()=>{console.log("SIGTERM received, shutting down..."),process.removeAllListeners("SIGINT"),process.exitCode=143,ie?.close().finally(()=>process.exit())});process.once("SIGINT",()=>{console.log("SIGINT received, shutting down..."),process.removeAllListeners("SIGTERM"),process.exitCode=130,ie?.close().finally(()=>process.exit())});async function Qr(){let[,,t]=process.argv;if(!t)return process.send?.({type:"error",error:'Missing "name" argument, server cannot be started'},void 0),process.exit(1);try{ie=await er({debug:!0,persistenceMode:"stateful",name:t});let{experimental:e,...r}=ie;process.send?.({type:"started",server:r},void 0)}catch(e){console.error(e);let r=e instanceof Error?e.message:String(e);process.send?.({type:"error",error:r},void 0),await(0,tr.setTimeout)(1e3),process.exit(1)}}Qr();
+    `));if(r.rows.length===0||e.subscribers.size===0)return;let n=r.rows.map(Xr);for(let o of e.subscribers)queueMicrotask(()=>{if(!e.closed&&e.subscribers.has(o))try{o(n)}catch(s){console.error("[WAL bridge] subscriber failed",s)}})}async function ht(e,t){if(!e.closed){if(e.pollPromise){e.pendingPoll=!0,await e.pollPromise;return}e.pollPromise=(async()=>{do e.pendingPoll=!1,await Qr(e,t);while(e.pendingPoll&&!e.closed)})().finally(()=>{e.pollPromise=null}),await e.pollPromise}}async function Ae(e,t,r){e.suppressDepth+=1;try{return await r()}finally{e.suppressDepth-=1,e.suppressDepth===0&&!e.closed&&z.get(t)!==e&&(e.closed=!0)}}function Xr(e){return{oldRecord:e.old_row_data,record:e.row_data,schema:e.schema_name,table:e.table_name,txid:String(e.txid),type:Yr(e.op)}}function Yr(e){switch(e.toLowerCase()){case"delete":return"delete";case"insert":return"insert";case"update":return"update";default:throw new Error(`Unsupported WAL bridge operation: ${e}`)}}var Zr=10,y={connectionLimit:Zr,connectTimeout:0,database:"template1",maxIdleConnectionLifetime:0,password:"postgres",poolTimeout:0,socketTimeout:0,sslMode:"disable",username:"postgres"},en=`postgres://${y.username}:${y.password}@localhost`,At=new URLSearchParams({sslmode:y.sslMode}),tn=new URLSearchParams({...Object.fromEntries(At.entries()),connection_limit:String(y.connectionLimit),connect_timeout:String(y.connectTimeout),max_idle_connection_lifetime:String(y.maxIdleConnectionLifetime),pool_timeout:String(y.poolTimeout),socket_timeout:String(y.socketTimeout)});async function xe(e,t){let r=e==="database"?t.databasePort:t.shadowDatabasePort;if(t.dryRun)return Rt(e,t,{db:null,port:r,server:null});let{debug:n}=t,s=await(e==="shadow_database"?rn:xt)(t.pgliteDataDirPath,n);n&&s.onNotification((l,P)=>{console.debug(`[${e}][${l}] ${P}`)});let{PGLiteSocketServer:a}=await import("@electric-sql/pglite-socket"),i=e==="shadow_database"?t.shadowDatabaseIdleTimeoutMillis:t.databaseIdleTimeoutMillis,c=new a({db:s,debug:n,idleTimeout:Number.isFinite(i)?i:0,inspect:n,maxConnections:y.connectionLimit,port:r});n&&(c.addEventListener("listening",l=>{let{detail:P}=l;console.debug(`[${e}] server listening on ${JSON.stringify(P)}`)}),c.addEventListener("connection",l=>{let{clientAddress:P,clientPort:E}=l.detail;console.debug(`[${e}] client connected from ${P}:${E}`)}),c.addEventListener("error",l=>{let{detail:P}=l;console.error(`[${e}] server error:`,P)}));try{await c.start()}catch(l){throw l instanceof Error&&"code"in l&&l.code==="EADDRINUSE"?new A(r):l}let d=Number(c.getServerConn().split(":").at(1));return t[e==="database"?"databasePort":"shadowDatabasePort"]=d,Rt(e,t,{db:s,port:d,server:c})}function Rt(e,t,r){let{debug:n}=t,{db:o,port:s,server:a}=r||{};return n&&console.debug(`[${e}] server started on port ${s}`),{...y,attachWalEventBridge:async()=>{if(e!=="database"||!o)throw new Error("WAL bridge is only available for the primary database server");return await De(o)},close:async()=>{let i=[];try{await a?.stop(),n&&console.debug(`[${e}] server stopped on port ${s}`)}catch(c){console.error(`[${e}] server stop error`,c),i.push(c)}if(e==="database"){try{o&&await bt(o),n&&console.debug(`[${e}] closed WAL bridge`)}catch(c){console.error(`[${e}] WAL bridge close error`,c),i.push(c)}try{await o?.syncToFs(),n&&console.debug(`[${e}] synced to filesystem`)}catch(c){console.error(`[${e}] sync error`,c),i.push(c)}}try{await o?.close(),n&&console.debug(`[${e}] closed`)}catch(c){console.error(`[${e}] close error`,c),i.push(c)}if(i.length>0)throw new AggregateError(i,`Failed to close ${e} properly`)},connectionString:Tt(s,At),dump:async i=>{e==="shadow_database"||!o||await nn({db:o,debug:n,destinationPath:i})},port:s,prismaORMConnectionString:Tt(s,tn),terminalCommand:`PGPASSWORD=${y.password} PGSSLMODE=${y.sslMode} psql -h localhost -p ${s} -U ${y.username} -d ${y.database}`}}function Tt(e,t){return`${en}:${e}/${y.database}?${t.toString()}`}async function xt(e,t){let{PGlite:r}=await import("@electric-sql/pglite"),n=await Re();return await r.create({database:y.database,dataDir:e,debug:t?5:void 0,extensions:n.extensions,fsBundle:n.fsBundle,relaxedDurability:!1,wasmModule:n.wasmModule,username:y.username})}async function rn(e,t){let{PGlite:r}=await import("@electric-sql/pglite"),n=await Re();return await r.create({database:y.database,dataDir:"memory://",debug:t?5:void 0,extensions:n.extensions,fsBundle:n.fsBundle,relaxedDurability:!1,wasmModule:n.wasmModule,username:y.username})}async function nn(e){let{dataDir:t,db:r,debug:n,destinationPath:o}=e,s=r||await xt(t,n),{pgDump:a}=await import("@electric-sql/pglite-tools/pg_dump"),i=await a({args:["--schema-only","--no-owner"],fileName:o?(0,Dt.filename)(o):void 0,pg:await s.clone()});return o?(n&&console.debug(`[DB] Dumping database to ${o}`),await tt(i,o)):(n&&console.debug("[DB] Dumping database to memory"),await i.text())}u();var rr=require("http"),nr=require("util"),or=b(require("@prisma/get-platform"),1);_e();Oe();async function sr(e,t){let{port:r}=t;if(t.dryRun)return tr(r,null);let n=await pn(e,t),{promise:o,reject:s,resolve:a}=se(),{serve:i}=await import("@hono/node-server"),c=i({createServer:rr.createServer,fetch:n.fetch,overrideGlobalObjects:!1,port:r},a);c.on("error",l=>{if(typeof l=="object"&&"code"in l&&l.code==="EADDRINUSE")return s(new A(r));console.error("[Accelerate]",l)});let{port:d}=await o;return t.port=d,tr(d,c)}function tr(e,t){return{async close(){t&&await Promise.allSettled([(0,nr.promisify)(t.close.bind(t))(),H.stopAll()])},port:e,url:`http://localhost:${e}`}}async function pn(e,t){let{debug:r}=t,[{Hono:n},{accelerateRoute:o},{utilityRoute:s}]=await Promise.all([import("hono/tiny"),Promise.resolve().then(()=>(Qt(),Jt)),Promise.resolve().then(()=>(er(),Zt))]),a=new n,i=await or.default.getPlatformInfo();if(r&&console.debug("[Accelerate] platform info: %s",JSON.stringify(i)),r){let{logger:d}=await import("hono/logger");a.use("*",d((...l)=>console.log("[Accelerate]",...l)))}a.use("*",async(d,l)=>(d.set("databaseDumpPath",t.databaseDumpPath),d.set("db",e),d.set("debug",!!r),d.set("name",t.name),d.set("platform",i),d.set("shadowDBPort",t.shadowDatabasePort),await l()));let c=new n;return c.route("/",o),c.route("/",s),a.route("/",c),a}u();var ur=require("fs/promises"),$=require("pathe"),G=require("proper-lockfile"),Ge=require("std-env"),m=require("valibot");ee();u();var gn=require("timers/promises"),ar=require("std-env");function ir(e,t){if(e==null)return!1;try{return ar.process.kill?.(e,0)??!0}catch(r){return t&&console.error(`Error checking if process with PID ${e} exists:`,r),!1}}var ke=(0,m.pipe)((0,m.string)(),(0,m.url)()),cr=(0,m.object)({connectionString:ke,prismaORMConnectionString:(0,m.optional)(ke),terminalCommand:(0,m.optional)((0,m.string)())}),lr=(0,m.object)({url:ke}),Ce=(0,m.pipe)((0,m.number)(),(0,m.integer)(),(0,m.minValue)(1)),fn=(0,m.object)({database:cr,http:lr,ppg:lr,shadowDatabase:cr}),hn=(0,m.object)({databasePort:Ce,exports:(0,m.optional)(fn),name:(0,m.pipe)((0,m.string)(),(0,m.minLength)(1)),pid:(0,m.optional)((0,m.pipe)((0,m.number)(),(0,m.integer)(),(0,m.minValue)(0))),port:Ce,shadowDatabasePort:Ce,version:(0,m.literal)("1")}),We=Symbol("initialize"),Me="default",T=class{_databasePort;databaseConnectTimeoutMillis;databaseIdleTimeoutMillis;debug;dryRun;name;persistenceMode;pid;shadowDatabaseConnectTimeoutMillis;shadowDatabaseIdleTimeoutMillis;_port;_shadowDatabasePort;constructor(t){this._databasePort=t.databasePort??O,this.databaseConnectTimeoutMillis=t.databaseConnectTimeoutMillis??6e4,this.databaseIdleTimeoutMillis=t.databaseIdleTimeoutMillis??1/0,this.debug=t.debug??!1,this.dryRun=t.dryRun??!1,this.name=t.name??Me,this.persistenceMode=t.persistenceMode,this.pid=t.pid??Ge.process.pid,this.shadowDatabaseConnectTimeoutMillis=t.shadowDatabaseConnectTimeoutMillis??this.databaseConnectTimeoutMillis,this.shadowDatabaseIdleTimeoutMillis=t.shadowDatabaseIdleTimeoutMillis??this.databaseIdleTimeoutMillis,this._port=t.port??O,this._shadowDatabasePort=t.shadowDatabasePort??O}static async createExclusively(t){let r=t?.dryRun!==!0&&t?.persistenceMode==="stateful"?new Q(t):new Ue(t);return await r[We](),r}static async fromServerDump(t){let{debug:r,name:n=Me}=t??{},o=j(n),s=Q.getServerDumpPath(o),a=await rt(s);if(a==null)return r&&console.debug(`[State] No server dump file found at: ${s}`),null;r&&(console.debug(`[State] server dump file found at "${s}":`),console.debug(a));let{issues:i,output:c,success:d}=(0,m.safeParse)((0,m.pipe)((0,m.string)(),(0,m.parseJson)(),hn),a);if(!d)throw r&&console.debug(`[State] Invalid server dump file at "${s}":
+${JSON.stringify(i,null,2)}`),new Error(`Invalid Prisma Dev state for "${n}".`);return new Q({databasePort:c.databasePort,debug:r,dryRun:!1,name:n,pid:c.pid,port:c.port,serverDump:c,shadowDatabasePort:c.shadowDatabasePort})}static async scan(t){let{debug:r,globs:n}=t??{},o=(0,$.join)(j(Me),"..");r&&console.debug(`[State] scanning for server states in: ${o}`);let s=await ot(o,n);return r&&console.debug(`[State] found server names: ${JSON.stringify(s)}`),await Promise.all(s.map(a=>Pn(a,t)))}get databasePort(){return this._databasePort}set databasePort(t){this.#t("databasePort",t)}get port(){return this._port}set port(t){this.#t("port",t)}get shadowDatabasePort(){return this._shadowDatabasePort}set shadowDatabasePort(t){this.#t("shadowDatabasePort",t)}#t(t,r){if(r<0||!Number.isInteger(r))throw new Error(`Invalid port number: ${r}`);let n=`_${t}`;if(this[n]!==M&&this[n]!==r)throw new Error(`\`${t}\` is already set to ${this[n]}, cannot change it to ${r}`);this[n]=r}},Ue=class extends T{constructor(t){super({...t,databasePort:t?.databasePort||M,persistenceMode:"stateless",port:t?.port||M,shadowDatabasePort:t?.shadowDatabasePort||M})}get databaseDumpPath(){return"<DUMP_PATH>"}get pgliteDataDirPath(){return"memory://"}async[We](){let t;try{t=await T.scan({debug:this.debug,onlyMetadata:!0})}catch(n){this.debug&&console.warn("[State] failed to scan for existing servers, assuming filesystem does not exist or other reasons.",n),t=[]}let r=await Ee({debug:this.debug,name:this.dryRun?this.name:"",requestedPorts:{databasePort:this.databasePort,port:this.port,shadowDatabasePort:this.shadowDatabasePort},servers:t});this._databasePort=r.databasePort,this._port=r.port,this._shadowDatabasePort=r.shadowDatabasePort}async close(){}async writeServerDump(){}},Q=class e extends T{#t;#e;#r;#s;#a;#o;#n;constructor(t){super({...t,persistenceMode:"stateful"}),this.#o=!1,this.#e=j(this.name),this.#t=(0,$.join)(this.#e,"db_dump.bak"),this.#r=(0,$.join)(this.#e,".lock"),this.#s=(0,$.join)(this.#e,".pglite"),this.#n=t?.serverDump??null,this.#a=e.getServerDumpPath(this.#e)}static getServerDumpPath(t){return(0,$.join)(t,"server.json")}get databaseDumpPath(){return this.#t}get exports(){return this.#n?.exports}get pgliteDataDirPath(){return this.#s}async[We](){await nt(this.#e),this.debug&&console.debug(`[State] using data directory: ${this.#e}`);try{await(0,G.lock)(this.#e,{lockfilePath:this.#r}),this.debug&&console.debug(`[State] obtained lock on: ${this.#e}`);let t=await T.scan({debug:this.debug,onlyMetadata:!0}),r=await Ee({debug:this.debug,name:this.name,requestedPorts:{databasePort:this.databasePort,port:this.port,shadowDatabasePort:this.shadowDatabasePort},servers:t});this._databasePort=r.databasePort,this._port=r.port,this._shadowDatabasePort=r.shadowDatabasePort,await this.writeServerDump()}catch(t){throw t instanceof Error&&"code"in t&&t.code==="ELOCKED"?new de(this):t}}async close(){if(!this.#o)try{await(0,G.unlock)(this.#e,{lockfilePath:this.#r}),this.#o=!0,this.debug&&console.debug(`[State] released lock on: ${this.#e}`)}catch(t){throw this.debug&&console.error(`[State] failed to release lock on: ${this.#e}`,t),t}}async writeServerDump(t){this.#n={name:this.name,version:"1",pid:Ge.process.pid,port:this.port,databasePort:this.databasePort,shadowDatabasePort:this.shadowDatabasePort,exports:t},await(0,ur.writeFile)(this.#a,`${JSON.stringify(this.#n,null,2)}
+`,{encoding:"utf-8"})}};async function Pn(e,t){let{debug:r,onlyMetadata:n}=t||{},o=typeof e=="string"?e:e.name,s=typeof e!="string"?e:void 0,a={databasePort:s?.databasePort??-1,exports:s?.exports,name:o,pid:s?.pid,port:s?.port??-1,shadowDatabasePort:s?.shadowDatabasePort??-1,version:"1"};try{let i=s||await T.fromServerDump({debug:r,name:o});if(!i)return r&&console.debug(`[State] no server state found for name: ${o}`),{...a,status:"no_such_server"};a.databasePort=i.databasePort,a.exports=i.exports,a.pid=i.pid,a.port=i.port,a.shadowDatabasePort=i.shadowDatabasePort;let{exports:c,pid:d}=i;if(n)return{...a,status:"unknown"};if(!ir(d,r))return r&&console.debug(`[State] server state for "${o}" has no running process with PID: ${d}`),{...a,status:"not_running"};let l=j(o);try{if(!await(0,G.check)(l,{lockfilePath:(0,$.join)(l,".lock")}))return r&&console.debug(`[State] server state for "${o}" is not locked, indicating it is not running.`),{...a,status:"starting_up"}}catch(W){r&&console.error(`[State] server state for "${o}" failed to check lock:`,W)}if(!c)return{...a,status:"starting_up"};let{http:P}=c,{hc:E}=await import("hono/client"),D=await E(P.url).health.$get();if(!D.ok)return r&&console.debug(`[State] server state for "${o}" is not live: ${JSON.stringify(D)}`),{...a,status:"not_running"};let x=await D.json();return x.name!==e?(r&&console.debug(`[State] server state for "${o}" has mismatched health response: ${JSON.stringify(x)}`),{...a,status:"unknown"}):(r&&console.debug(`[State] server state for "${e}" is live: ${JSON.stringify(x)}`),{...a,status:"running"})}catch(i){return r&&console.error(`[State] failed to get server status for "${o}":`,i),{...a,status:"error"}}}var He=class extends Error{name="ServerStateAlreadyExistsError";constructor(t){super(`A Prisma Dev server with the name "${t}" is already running.`)}},de=class extends He{#t;name="ServerAlreadyRunningError";constructor(t){super(t.name),this.#t=t}get server(){return T.fromServerDump({debug:this.#t.debug,name:this.#t.name})}};async function dr(e){let t=await T.createExclusively(e),r=null,n=null,o=null;try{[r,o]=await Promise.all([xe("database",t),xe("shadow_database",t)]);let s=await r.attachWalEventBridge();n=await sr(r,t);let a=yn(r,o,n,t);await t.writeServerDump(a);let i=vn(s),c=r,d=o,l=n,P=async()=>{i.close(),await mr(t,[l,c,d])};return{close:P,dbServer:r,httpServer:n,server:{...a,close:P,experimental:{wal:i.api},name:t.name},serverState:t,shadowDbServer:o,walBridge:s}}catch(s){return await bn(t,[n,r,o],s)}}function yn(e,t,r,n){let o=`prisma+postgres://localhost:${r.port}/?${new URLSearchParams({api_key:ze({databaseUrl:e.prismaORMConnectionString,name:n.name,shadowDatabaseUrl:t.prismaORMConnectionString})}).toString()}`;return{database:{connectionString:e.connectionString,prismaORMConnectionString:e.prismaORMConnectionString,terminalCommand:e.terminalCommand},http:{url:r.url},ppg:{url:o},shadowDatabase:{connectionString:t.prismaORMConnectionString,prismaORMConnectionString:t.prismaORMConnectionString,terminalCommand:t.terminalCommand}}}async function mr(e,t){let n=(await Promise.allSettled(t.map(o=>o.close()))).filter(o=>o.status==="rejected").map(o=>new Error(o.reason));try{await e.close()}catch(o){n.push(o)}if(n.length>0)throw new AggregateError(n,"Failed to close some servers")}async function bn(e,t,r){try{await mr(e,t.filter(n=>n!==null))}catch(n){throw new AggregateError([r,n],"Failed to start Prisma Dev server cleanly")}throw r}function vn(e){let t=new Set;return{api:{stream:()=>{let r=()=>{},n=wn(e,()=>{t.delete(r)});return r=()=>n.close(),t.add(r),n.stream},subscribe:r=>e.subscribe(r)},close:()=>{for(let r of[...t])r();t.clear()}}}function wn(e,t){let r=[],n=!1,o=null,s=e.subscribe(i=>{if(!n){if(o){let c=o;o=null,c.resolve({done:!1,value:i});return}r.push(i)}}),a=()=>{if(!n&&(n=!0,s(),r.length=0,t(),o)){let i=o;o=null,i.resolve({done:!0,value:void 0})}};return{close:a,stream:{[Symbol.asyncIterator](){return this},next(){return r.length>0?Promise.resolve({done:!1,value:r.shift()}):n?Promise.resolve({done:!0,value:void 0}):new Promise((i,c)=>{o={reject:c,resolve:i}})},return(){return a(),Promise.resolve({done:!0,value:void 0})},throw(i){let c=o;return a(),c&&c.reject(i),Promise.reject(i instanceof Error?i:new Error(String(i)))}}}}async function pr(e){let{server:t}=await dr(e);return t}var me;process.once("SIGTERM",()=>{console.log("SIGTERM received, shutting down..."),process.removeAllListeners("SIGINT"),process.exitCode=143,me?.close().finally(()=>process.exit())});process.once("SIGINT",()=>{console.log("SIGINT received, shutting down..."),process.removeAllListeners("SIGTERM"),process.exitCode=130,me?.close().finally(()=>process.exit())});async function Sn(){let[,,e]=process.argv;if(!e)return process.send?.({type:"error",error:'Missing "name" argument, server cannot be started'},void 0),process.exit(1);try{me=await pr({debug:!0,persistenceMode:"stateful",name:e});let{experimental:t,...r}=me;process.send?.({type:"started",server:r},void 0)}catch(t){console.error(t);let r=t instanceof Error?t.message:String(t);process.send?.({type:"error",error:r},void 0),await(0,gr.setTimeout)(1e3),process.exit(1)}}Sn();

dist/daemon.d.cts

@@ -6,2 +6,3 @@ import { ReadonlyServer } from './index.cjs';
 import '@electric-sql/pglite';
+import './runtime-assets.cjs';
 
@@ -8,0 +9,0 @@ type DaemonServer = Omit<ReadonlyServer, "experimental">;

dist/daemon.d.ts

@@ -6,2 +6,3 @@ import { ReadonlyServer } from './index.js';
 import '@electric-sql/pglite';
+import './runtime-assets.js';
 
@@ -8,0 +9,0 @@ type DaemonServer = Omit<ReadonlyServer, "experimental">;

dist/daemon.js

@@ -1,1 +0,1 @@
-import{a as t}from"./chunk-UZK2DL6R.js";import"./chunk-DZGCLGSX.js";import"./chunk-FIY24ARL.js";import"./chunk-OTI5SWIV.js";import"./chunk-6ORCLJD5.js";import"./chunk-DGKV2DPF.js";import{setTimeout as n}from"timers/promises";var r;process.once("SIGTERM",()=>{console.log("SIGTERM received, shutting down..."),process.removeAllListeners("SIGINT"),process.exitCode=143,r?.close().finally(()=>process.exit())});process.once("SIGINT",()=>{console.log("SIGINT received, shutting down..."),process.removeAllListeners("SIGTERM"),process.exitCode=130,r?.close().finally(()=>process.exit())});async function a(){let[,,o]=process.argv;if(!o)return process.send?.({type:"error",error:'Missing "name" argument, server cannot be started'},void 0),process.exit(1);try{r=await t({debug:!0,persistenceMode:"stateful",name:o});let{experimental:e,...s}=r;process.send?.({type:"started",server:s},void 0)}catch(e){console.error(e);let s=e instanceof Error?e.message:String(e);process.send?.({type:"error",error:s},void 0),await n(1e3),process.exit(1)}}a();
+import{a as t}from"./chunk-CW5JFXGL.js";import"./chunk-NKHRQQEV.js";import"./chunk-NXMFOBF6.js";import"./chunk-FIY24ARL.js";import"./chunk-OTI5SWIV.js";import"./chunk-6ORCLJD5.js";import"./chunk-DGKV2DPF.js";import{setTimeout as n}from"timers/promises";var r;process.once("SIGTERM",()=>{console.log("SIGTERM received, shutting down..."),process.removeAllListeners("SIGINT"),process.exitCode=143,r?.close().finally(()=>process.exit())});process.once("SIGINT",()=>{console.log("SIGINT received, shutting down..."),process.removeAllListeners("SIGTERM"),process.exitCode=130,r?.close().finally(()=>process.exit())});async function a(){let[,,o]=process.argv;if(!o)return process.send?.({type:"error",error:'Missing "name" argument, server cannot be started'},void 0),process.exit(1);try{r=await t({debug:!0,persistenceMode:"stateful",name:o});let{experimental:e,...s}=r;process.send?.({type:"started",server:s},void 0)}catch(e){console.error(e);let s=e instanceof Error?e.message:String(e);process.send?.({type:"error",error:s},void 0),await n(1e3),process.exit(1)}}a();

dist/db.cjs

@@ -1,3 +0,3 @@
-"use strict";var te=Object.create;var T=Object.defineProperty;var re=Object.getOwnPropertyDescriptor;var oe=Object.getOwnPropertyNames;var ne=Object.getPrototypeOf,se=Object.prototype.hasOwnProperty;var ie=(e,t)=>{for(var r in t)T(e,r,{get:t[r],enumerable:!0})},B=(e,t,r,s)=>{if(t&&typeof t=="object"||typeof t=="function")for(let n of oe(t))!se.call(e,n)&&n!==r&&T(e,n,{get:()=>t[n],enumerable:!(s=re(t,n))||s.enumerable});return e};var o=(e,t,r)=>(r=e!=null?te(ne(e)):{},B(t||!e||!e.__esModule?T(r,"default",{value:e,enumerable:!0}):r,e)),ae=e=>B(T({},"__esModule",{value:!0}),e);var ye={};ie(ye,{attachWalEventBridge:()=>v,dumpDB:()=>Z,shouldPollWalAfterMessages:()=>O,shouldPollWalAfterResponse:()=>L,startDBServer:()=>Te});module.exports=ae(ye);var V=require("pathe/utils");var h=require("fs"),f=require("fs/promises"),I=require("util"),C=require("zlib");var i=o(require("path"),1),_=o(require("os"),1),w=o(require("process"),1),g=_.default.homedir(),A=_.default.tmpdir(),{env:E}=w.default,ce=e=>{let t=i.default.join(g,"Library");return{data:i.default.join(t,"Application Support",e),config:i.default.join(t,"Preferences",e),cache:i.default.join(t,"Caches",e),log:i.default.join(t,"Logs",e),temp:i.default.join(A,e)}},le=e=>{let t=E.APPDATA||i.default.join(g,"AppData","Roaming"),r=E.LOCALAPPDATA||i.default.join(g,"AppData","Local");return{data:i.default.join(r,e,"Data"),config:i.default.join(t,e,"Config"),cache:i.default.join(r,e,"Cache"),log:i.default.join(r,e,"Log"),temp:i.default.join(A,e)}},de=e=>{let t=i.default.basename(g);return{data:i.default.join(E.XDG_DATA_HOME||i.default.join(g,".local","share"),e),config:i.default.join(E.XDG_CONFIG_HOME||i.default.join(g,".config"),e),cache:i.default.join(E.XDG_CACHE_HOME||i.default.join(g,".cache"),e),log:i.default.join(E.XDG_STATE_HOME||i.default.join(g,".local","state"),e),temp:i.default.join(A,t,e)}};function N(e,{suffix:t="nodejs"}={}){if(typeof e!="string")throw new TypeError(`Expected a string, got ${typeof e}`);return t&&(e+=`-${t}`),w.default.platform==="darwin"?ce(e):w.default.platform==="win32"?le(e):de(e)}var ue=o(require("zeptomatch"),1),Ae=N("prisma-dev"),Ne=(0,I.promisify)(C.unzip);async function U(e,t){await e.stream().pipeTo(h.WriteStream.toWeb((0,h.createWriteStream)(t,{encoding:"utf8"})))}var R=require("get-port-please"),G=require("remeda");var S=class extends Error{constructor(r){super(`Port \`${r}\` is not available.`);this.port=r}name="PortNotAvailableError"};var F=require("@electric-sql/pglite"),m="_prisma_dev_wal",D="events",j="install_all_triggers",W="capture_event",M="prisma_dev_wal_capture",b=new WeakMap,pe=new Set(["ALTER","COMMIT","COPY","CREATE","DELETE","DROP","INSERT","MERGE","TRUNCATE","UPDATE"]);async function v(e,t){let r=b.get(e);if(r&&!r.closed)return r.bridge;let s=e.execProtocolRaw.bind(e),n={bridge:{close:async()=>{n.closed||(n.closed=!0,n.subscribers.clear(),e.execProtocolRaw===l&&(e.execProtocolRaw=s),await n.pollPromise,b.delete(e))},poll:async()=>{await k(n,e)},subscribe:p=>(n.subscribers.add(p),()=>{n.subscribers.delete(p)})},closed:!1,ensureInfrastructurePromise:null,pendingPoll:!1,pollPromise:null,subscribers:new Set,suppressDepth:0},l=async(p,d)=>{let a=await s(p,d);return!n.closed&&n.suppressDepth===0&&L(a)&&k(n,e),a};return e.execProtocolRaw=l,b.set(e,n),await H(n,e),n.bridge}async function q(e){let t=b.get(e);t&&await t.bridge.close()}function O(e){for(let t of e){if(t.name!=="commandComplete"||typeof t.text!="string")continue;let r=t.text.split(/\s+/,1)[0]?.toUpperCase();if(r&&pe.has(r))return!0}return!1}function L(e){if(e.length===0)return!1;let t=[];return new F.protocol.Parser().parse(e,s=>{t.push(s)}),O(t)}async function H(e,t){e.ensureInfrastructurePromise??=x(e,t,async()=>{await t.exec(`CREATE SCHEMA IF NOT EXISTS "${m}"`),await t.exec(`
-      CREATE TABLE IF NOT EXISTS "${m}"."${D}" (
+"use strict";var ge=Object.create;var S=Object.defineProperty;var fe=Object.getOwnPropertyDescriptor;var Pe=Object.getOwnPropertyNames;var be=Object.getPrototypeOf,Ee=Object.prototype.hasOwnProperty;var ye=(e,t)=>{for(var r in t)S(e,r,{get:t[r],enumerable:!0})},k=(e,t,r,n)=>{if(t&&typeof t=="object"||typeof t=="function")for(let o of Pe(t))!Ee.call(e,o)&&o!==r&&S(e,o,{get:()=>t[o],enumerable:!(n=fe(t,o))||n.enumerable});return e};var p=(e,t,r)=>(r=e!=null?ge(be(e)):{},k(t||!e||!e.__esModule?S(r,"default",{value:e,enumerable:!0}):r,e)),we=e=>k(S({},"__esModule",{value:!0}),e);var Ke={};ye(Ke,{attachWalEventBridge:()=>D,dumpDB:()=>me,shouldPollWalAfterMessages:()=>I,shouldPollWalAfterResponse:()=>G,startDBServer:()=>He});module.exports=we(Ke);var Re=()=>typeof document>"u"?new URL(`file:${__filename}`).href:document.currentScript&&document.currentScript.tagName.toUpperCase()==="SCRIPT"?document.currentScript.src:new URL("main.js",document.baseURI).href,g=Re();var le=require("pathe/utils");var A=require("fs"),P=require("fs/promises"),W=require("util"),F=require("zlib");var s=p(require("path"),1),N=p(require("os"),1),T=p(require("process"),1),f=N.default.homedir(),O=N.default.tmpdir(),{env:E}=T.default,he=e=>{let t=s.default.join(f,"Library");return{data:s.default.join(t,"Application Support",e),config:s.default.join(t,"Preferences",e),cache:s.default.join(t,"Caches",e),log:s.default.join(t,"Logs",e),temp:s.default.join(O,e)}},Se=e=>{let t=E.APPDATA||s.default.join(f,"AppData","Roaming"),r=E.LOCALAPPDATA||s.default.join(f,"AppData","Local");return{data:s.default.join(r,e,"Data"),config:s.default.join(t,e,"Config"),cache:s.default.join(r,e,"Cache"),log:s.default.join(r,e,"Log"),temp:s.default.join(O,e)}},Te=e=>{let t=s.default.basename(f);return{data:s.default.join(E.XDG_DATA_HOME||s.default.join(f,".local","share"),e),config:s.default.join(E.XDG_CONFIG_HOME||s.default.join(f,".config"),e),cache:s.default.join(E.XDG_CACHE_HOME||s.default.join(f,".cache"),e),log:s.default.join(E.XDG_STATE_HOME||s.default.join(f,".local","state"),e),temp:s.default.join(O,t,e)}};function B(e,{suffix:t="nodejs"}={}){if(typeof e!="string")throw new TypeError(`Expected a string, got ${typeof e}`);return t&&(e+=`-${t}`),T.default.platform==="darwin"?he(e):T.default.platform==="win32"?Se(e):Te(e)}var Ae=p(require("zeptomatch"),1),et=B("prisma-dev"),tt=(0,W.promisify)(F.unzip);async function j(e,t){await e.stream().pipeTo(A.WriteStream.toWeb((0,A.createWriteStream)(t,{encoding:"utf8"})))}var x=require("get-port-please"),z=require("remeda");var _=class extends Error{constructor(r){super(`Port \`${r}\` is not available.`);this.port=r}name="PortNotAvailableError"};var w=require("fs"),y=require("fs/promises"),X=require("module"),K=require("path"),R=require("url"),_e=(0,X.createRequire)(g),ve=["pglite.data","pglite.wasm"],J={amcheck:"amcheck.tar.gz",bloom:"bloom.tar.gz",btree_gin:"btree_gin.tar.gz",btree_gist:"btree_gist.tar.gz",citext:"citext.tar.gz",cube:"cube.tar.gz",dict_int:"dict_int.tar.gz",dict_xsyn:"dict_xsyn.tar.gz",earthdistance:"earthdistance.tar.gz",file_fdw:"file_fdw.tar.gz",fuzzystrmatch:"fuzzystrmatch.tar.gz",hstore:"hstore.tar.gz",intarray:"intarray.tar.gz",isn:"isn.tar.gz",lo:"lo.tar.gz",ltree:"ltree.tar.gz",pageinspect:"pageinspect.tar.gz",pg_buffercache:"pg_buffercache.tar.gz",pg_freespacemap:"pg_freespacemap.tar.gz",pg_surgery:"pg_surgery.tar.gz",pg_trgm:"pg_trgm.tar.gz",pg_visibility:"pg_visibility.tar.gz",pg_walinspect:"pg_walinspect.tar.gz",seg:"seg.tar.gz",tablefunc:"tablefunc.tar.gz",tcn:"tcn.tar.gz",tsm_system_rows:"tsm_system_rows.tar.gz",tsm_system_time:"tsm_system_time.tar.gz",unaccent:"unaccent.tar.gz",uuid_ossp:"uuid-ossp.tar.gz",vector:"vector.tar.gz"},Le=[...ve.map(e=>({fileName:e,kind:"core",name:e})),...Object.entries(J).map(([e,t])=>({fileName:t,kind:"extension",name:e}))],L=new Map,De=Symbol.for("@prisma/dev/bundled-pglite-runtime-asset-sources"),v=null;async function U(){await Ie();let e=V();if(e)return await Ne(e);let t=Ue(),r=t.href,n=L.get(r);return n||(n=Oe(t),L.set(r,n)),await n}async function Ne(e){let t=`bundled:${e.wasmModule.href}:${e.fsBundle.href}`,r=L.get(t);return r||(r=Be(e),L.set(t,r)),await r}async function Oe(e){let[t,r]=await Promise.all([(0,y.readFile)(new URL("pglite.data",e)),(0,y.readFile)(new URL("pglite.wasm",e))]),n=Q();return{extensions:Object.fromEntries(Object.entries(J).map(([o,a])=>[o,new URL(a,e)])),fsBundle:new Blob([Uint8Array.from(t)]),wasmModule:await n.compile(r)}}async function Be(e){let[t,r]=await Promise.all([H(e.fsBundle),H(e.wasmModule)]),n=Q();return{extensions:e.extensions,fsBundle:new Blob([Uint8Array.from(t)]),wasmModule:await n.compile(r)}}function Y(e){return e instanceof URL?q(e):q((0,R.pathToFileURL)(e))}function q(e){return e.href.endsWith("/")?e:new URL(`${e.href}/`)}function xe(){let e=_e.resolve("@electric-sql/pglite");return Y((0,K.dirname)(e))}function Ue(){let e=Y(new URL("./",g));if($e(e))return e;if(Ge())return xe();throw new Error("Unable to locate PGlite runtime assets. If you bundled @prisma/dev, copy them next to the bundle with copyPrismaDevRuntimeAssets().")}function $e(e){return Le.every(t=>(0,w.existsSync)((0,R.fileURLToPath)(new URL(t.fileName,e))))}function V(){return globalThis[De]??null}async function Ie(){!Ce()||V()||(v||(v=import("./runtime-assets-manifest.bun.js").then(()=>{}).catch(e=>{throw v=null,e})),await v)}function Ge(){let e=(0,R.fileURLToPath)(new URL("../package.json",g));if(!(0,w.existsSync)(e))return!1;try{return JSON.parse((0,w.readFileSync)(e,"utf8")).name==="@prisma/dev"}catch{return!1}}function Ce(){return typeof globalThis.Bun<"u"}function Q(){let e=globalThis.WebAssembly;if(!e)throw new Error("WebAssembly is not available in this runtime.");return e}async function H(e){if(e.protocol==="file:")return await(0,y.readFile)(e);let t=await fetch(e);if(!t.ok)throw new Error(`Failed to fetch runtime asset ${e.href}: ${t.status} ${t.statusText}`);return new Uint8Array(await t.arrayBuffer())}var re=require("@electric-sql/pglite"),m="_prisma_dev_wal",$="events",ne="install_all_triggers",Z="capture_event",ee="prisma_dev_wal_capture",h=new WeakMap,Me=new Set(["ALTER","COMMIT","COPY","CREATE","DELETE","DROP","INSERT","MERGE","TRUNCATE","UPDATE"]);async function D(e,t){let r=h.get(e);if(r&&!r.closed)return r.bridge;let n=e.execProtocolRaw.bind(e),o={bridge:{close:async()=>{o.closed||(o.closed=!0,o.subscribers.clear(),e.execProtocolRaw===a&&(e.execProtocolRaw=n),await o.pollPromise,h.delete(e))},poll:async()=>{await te(o,e)},subscribe:d=>(o.subscribers.add(d),()=>{o.subscribers.delete(d)})},closed:!1,ensureInfrastructurePromise:null,pendingPoll:!1,pollPromise:null,subscribers:new Set,suppressDepth:0},a=async(d,l)=>{let i=await n(d,l);return!o.closed&&o.suppressDepth===0&&G(i)&&te(o,e),i};return e.execProtocolRaw=a,h.set(e,o),await se(o,e),o.bridge}async function oe(e){let t=h.get(e);t&&await t.bridge.close()}function I(e){for(let t of e){if(t.name!=="commandComplete"||typeof t.text!="string")continue;let r=t.text.split(/\s+/,1)[0]?.toUpperCase();if(r&&Me.has(r))return!0}return!1}function G(e){if(e.length===0)return!1;let t=[];return new re.protocol.Parser().parse(e,n=>{t.push(n)}),I(t)}async function se(e,t){e.ensureInfrastructurePromise??=C(e,t,async()=>{await t.exec(`CREATE SCHEMA IF NOT EXISTS "${m}"`),await t.exec(`
+      CREATE TABLE IF NOT EXISTS "${m}"."${$}" (
         id BIGSERIAL PRIMARY KEY,
@@ -13,3 +13,3 @@ txid BIGINT NOT NULL DEFAULT txid_current(),
     `),await t.exec(`
-      CREATE OR REPLACE FUNCTION "${m}"."${W}"()
+      CREATE OR REPLACE FUNCTION "${m}"."${Z}"()
       RETURNS trigger
@@ -23,3 +23,3 @@ LANGUAGE plpgsql
 
-        INSERT INTO "${m}"."${D}" (
+        INSERT INTO "${m}"."${$}" (
           txid,
@@ -45,3 +45,3 @@ schema_name,
     `),await t.exec(`
-      CREATE OR REPLACE FUNCTION "${m}"."${j}"()
+      CREATE OR REPLACE FUNCTION "${m}"."${ne}"()
       RETURNS void
@@ -66,3 +66,3 @@ LANGUAGE plpgsql
             WHERE tgrelid = target
-              AND tgname = '${M}'
+              AND tgname = '${ee}'
           ) THEN
@@ -73,4 +73,4 @@ CONTINUE;
           EXECUTE format(
-            'CREATE TRIGGER %I AFTER INSERT OR UPDATE OR DELETE ON %s FOR EACH ROW EXECUTE FUNCTION "${m}"."${W}"()',
-            '${M}',
+            'CREATE TRIGGER %I AFTER INSERT OR UPDATE OR DELETE ON %s FOR EACH ROW EXECUTE FUNCTION "${m}"."${Z}"()',
+            '${ee}',
             target::text
@@ -81,5 +81,5 @@ );
       $$;
-    `),await X(e,t)}),await e.ensureInfrastructurePromise}async function X(e,t){await x(e,t,async()=>{await t.query(`SELECT "${m}"."${j}"()`)})}async function me(e,t){await H(e,t),await X(e,t);let r=await x(e,t,async()=>await t.query(`
+    `),await ie(e,t)}),await e.ensureInfrastructurePromise}async function ie(e,t){await C(e,t,async()=>{await t.query(`SELECT "${m}"."${ne}"()`)})}async function ke(e,t){await se(e,t),await ie(e,t);let r=await C(e,t,async()=>await t.query(`
       WITH drained AS (
-        DELETE FROM "${m}"."${D}"
+        DELETE FROM "${m}"."${$}"
         RETURNING txid, schema_name, table_name, op, row_data, old_row_data, id
@@ -90,2 +90,2 @@ )
       ORDER BY id
-    `));if(r.rows.length===0||e.subscribers.size===0)return;let s=r.rows.map(ge);for(let n of e.subscribers)queueMicrotask(()=>{if(!e.closed&&e.subscribers.has(n))try{n(s)}catch(l){console.error("[WAL bridge] subscriber failed",l)}})}async function k(e,t){if(!e.closed){if(e.pollPromise){e.pendingPoll=!0,await e.pollPromise;return}e.pollPromise=(async()=>{do e.pendingPoll=!1,await me(e,t);while(e.pendingPoll&&!e.closed)})().finally(()=>{e.pollPromise=null}),await e.pollPromise}}async function x(e,t,r){e.suppressDepth+=1;try{return await r()}finally{e.suppressDepth-=1,e.suppressDepth===0&&!e.closed&&b.get(t)!==e&&(e.closed=!0)}}function ge(e){return{oldRecord:e.old_row_data,record:e.row_data,schema:e.schema_name,table:e.table_name,txid:String(e.txid),type:fe(e.op)}}function fe(e){switch(e.toLowerCase()){case"delete":return"delete";case"insert":return"insert";case"update":return"update";default:throw new Error(`Unsupported WAL bridge operation: ${e}`)}}var Pe=10,c={connectionLimit:Pe,connectTimeout:0,database:"template1",maxIdleConnectionLifetime:0,password:"postgres",poolTimeout:0,socketTimeout:0,sslMode:"disable",username:"postgres"},Ee=`postgres://${c.username}:${c.password}@localhost`,Y=new URLSearchParams({sslmode:c.sslMode}),be=new URLSearchParams({...Object.fromEntries(Y.entries()),connection_limit:String(c.connectionLimit),connect_timeout:String(c.connectTimeout),max_idle_connection_lifetime:String(c.maxIdleConnectionLifetime),pool_timeout:String(c.poolTimeout),socket_timeout:String(c.socketTimeout)});async function Te(e,t){let r=e==="database"?t.databasePort:t.shadowDatabasePort;if(t.dryRun)return K(e,t,{db:null,port:r,server:null});let{debug:s}=t,l=await(e==="shadow_database"?we:Q)(t.pgliteDataDirPath,s);s&&l.onNotification((u,P)=>{console.debug(`[${e}][${u}] ${P}`)});let{PGLiteSocketServer:p}=await import("@electric-sql/pglite-socket"),d=e==="shadow_database"?t.shadowDatabaseIdleTimeoutMillis:t.databaseIdleTimeoutMillis,a=new p({db:l,debug:s,idleTimeout:Number.isFinite(d)?d:0,inspect:s,maxConnections:c.connectionLimit,port:r});s&&(a.addEventListener("listening",u=>{let{detail:P}=u;console.debug(`[${e}] server listening on ${JSON.stringify(P)}`)}),a.addEventListener("connection",u=>{let{clientAddress:P,clientPort:ee}=u.detail;console.debug(`[${e}] client connected from ${P}:${ee}`)}),a.addEventListener("error",u=>{let{detail:P}=u;console.error(`[${e}] server error:`,P)}));try{await a.start()}catch(u){throw u instanceof Error&&"code"in u&&u.code==="EADDRINUSE"?new S(r):u}let $=Number(a.getServerConn().split(":").at(1));return t[e==="database"?"databasePort":"shadowDatabasePort"]=$,K(e,t,{db:l,port:$,server:a})}function K(e,t,r){let{debug:s}=t,{db:n,port:l,server:p}=r||{};return s&&console.debug(`[${e}] server started on port ${l}`),{...c,attachWalEventBridge:async()=>{if(e!=="database"||!n)throw new Error("WAL bridge is only available for the primary database server");return await v(n)},close:async()=>{let d=[];try{await p?.stop(),s&&console.debug(`[${e}] server stopped on port ${l}`)}catch(a){console.error(`[${e}] server stop error`,a),d.push(a)}if(e==="database"){try{n&&await q(n),s&&console.debug(`[${e}] closed WAL bridge`)}catch(a){console.error(`[${e}] WAL bridge close error`,a),d.push(a)}try{await n?.syncToFs(),s&&console.debug(`[${e}] synced to filesystem`)}catch(a){console.error(`[${e}] sync error`,a),d.push(a)}}try{await n?.close(),s&&console.debug(`[${e}] closed`)}catch(a){console.error(`[${e}] close error`,a),d.push(a)}if(d.length>0)throw new AggregateError(d,`Failed to close ${e} properly`)},connectionString:J(l,Y),dump:async d=>{e==="shadow_database"||!n||await Z({db:n,debug:s,destinationPath:d})},port:l,prismaORMConnectionString:J(l,be),terminalCommand:`PGPASSWORD=${c.password} PGSSLMODE=${c.sslMode} psql -h localhost -p ${l} -U ${c.username} -d ${c.database}`}}function J(e,t){return`${Ee}:${e}/${c.database}?${t.toString()}`}async function Q(e,t){let{PGlite:r}=await import("@electric-sql/pglite");return await r.create({database:c.database,dataDir:e,debug:t?5:void 0,extensions:await z(),relaxedDurability:!1,username:c.username})}async function we(e,t){let{PGlite:r}=await import("@electric-sql/pglite");return await r.create({database:c.database,dataDir:"memory://",debug:t?5:void 0,extensions:await z(),relaxedDurability:!1,username:c.username})}async function z(){let e=await Promise.all([import("@electric-sql/pglite/contrib/amcheck"),import("@electric-sql/pglite/contrib/bloom"),import("@electric-sql/pglite/contrib/btree_gin"),import("@electric-sql/pglite/contrib/btree_gist"),import("@electric-sql/pglite/contrib/citext"),import("@electric-sql/pglite/contrib/cube"),import("@electric-sql/pglite/contrib/dict_int"),import("@electric-sql/pglite/contrib/dict_xsyn"),import("@electric-sql/pglite/contrib/earthdistance"),import("@electric-sql/pglite/contrib/file_fdw"),import("@electric-sql/pglite/contrib/fuzzystrmatch"),import("@electric-sql/pglite/contrib/hstore"),import("@electric-sql/pglite/contrib/intarray"),import("@electric-sql/pglite/contrib/isn"),import("@electric-sql/pglite/contrib/lo"),import("@electric-sql/pglite/contrib/ltree"),import("@electric-sql/pglite/contrib/pageinspect"),import("@electric-sql/pglite/contrib/pg_buffercache"),import("@electric-sql/pglite/contrib/pg_freespacemap"),import("@electric-sql/pglite/contrib/pg_surgery"),import("@electric-sql/pglite/contrib/pg_trgm"),import("@electric-sql/pglite/contrib/pg_visibility"),import("@electric-sql/pglite/contrib/pg_walinspect"),import("@electric-sql/pglite/contrib/seg"),import("@electric-sql/pglite/contrib/tablefunc"),import("@electric-sql/pglite/contrib/tcn"),import("@electric-sql/pglite/contrib/tsm_system_rows"),import("@electric-sql/pglite/contrib/tsm_system_time"),import("@electric-sql/pglite/contrib/unaccent"),import("@electric-sql/pglite/contrib/uuid_ossp"),import("@electric-sql/pglite/vector")]);return Object.assign({},...e)}async function Z(e){let{dataDir:t,db:r,debug:s,destinationPath:n}=e,l=r||await Q(t,s),{pgDump:p}=await import("@electric-sql/pglite-tools/pg_dump"),d=await p({args:["--schema-only","--no-owner"],fileName:n?(0,V.filename)(n):void 0,pg:await l.clone()});return n?(s&&console.debug(`[DB] Dumping database to ${n}`),await U(d,n)):(s&&console.debug("[DB] Dumping database to memory"),await d.text())}0&&(module.exports={attachWalEventBridge,dumpDB,shouldPollWalAfterMessages,shouldPollWalAfterResponse,startDBServer});
+    `));if(r.rows.length===0||e.subscribers.size===0)return;let n=r.rows.map(We);for(let o of e.subscribers)queueMicrotask(()=>{if(!e.closed&&e.subscribers.has(o))try{o(n)}catch(a){console.error("[WAL bridge] subscriber failed",a)}})}async function te(e,t){if(!e.closed){if(e.pollPromise){e.pendingPoll=!0,await e.pollPromise;return}e.pollPromise=(async()=>{do e.pendingPoll=!1,await ke(e,t);while(e.pendingPoll&&!e.closed)})().finally(()=>{e.pollPromise=null}),await e.pollPromise}}async function C(e,t,r){e.suppressDepth+=1;try{return await r()}finally{e.suppressDepth-=1,e.suppressDepth===0&&!e.closed&&h.get(t)!==e&&(e.closed=!0)}}function We(e){return{oldRecord:e.old_row_data,record:e.row_data,schema:e.schema_name,table:e.table_name,txid:String(e.txid),type:Fe(e.op)}}function Fe(e){switch(e.toLowerCase()){case"delete":return"delete";case"insert":return"insert";case"update":return"update";default:throw new Error(`Unsupported WAL bridge operation: ${e}`)}}var je=10,c={connectionLimit:je,connectTimeout:0,database:"template1",maxIdleConnectionLifetime:0,password:"postgres",poolTimeout:0,socketTimeout:0,sslMode:"disable",username:"postgres"},ze=`postgres://${c.username}:${c.password}@localhost`,ue=new URLSearchParams({sslmode:c.sslMode}),qe=new URLSearchParams({...Object.fromEntries(ue.entries()),connection_limit:String(c.connectionLimit),connect_timeout:String(c.connectTimeout),max_idle_connection_lifetime:String(c.maxIdleConnectionLifetime),pool_timeout:String(c.poolTimeout),socket_timeout:String(c.socketTimeout)});async function He(e,t){let r=e==="database"?t.databasePort:t.shadowDatabasePort;if(t.dryRun)return ae(e,t,{db:null,port:r,server:null});let{debug:n}=t,a=await(e==="shadow_database"?Xe:de)(t.pgliteDataDirPath,n);n&&a.onNotification((u,b)=>{console.debug(`[${e}][${u}] ${b}`)});let{PGLiteSocketServer:d}=await import("@electric-sql/pglite-socket"),l=e==="shadow_database"?t.shadowDatabaseIdleTimeoutMillis:t.databaseIdleTimeoutMillis,i=new d({db:a,debug:n,idleTimeout:Number.isFinite(l)?l:0,inspect:n,maxConnections:c.connectionLimit,port:r});n&&(i.addEventListener("listening",u=>{let{detail:b}=u;console.debug(`[${e}] server listening on ${JSON.stringify(b)}`)}),i.addEventListener("connection",u=>{let{clientAddress:b,clientPort:pe}=u.detail;console.debug(`[${e}] client connected from ${b}:${pe}`)}),i.addEventListener("error",u=>{let{detail:b}=u;console.error(`[${e}] server error:`,b)}));try{await i.start()}catch(u){throw u instanceof Error&&"code"in u&&u.code==="EADDRINUSE"?new _(r):u}let M=Number(i.getServerConn().split(":").at(1));return t[e==="database"?"databasePort":"shadowDatabasePort"]=M,ae(e,t,{db:a,port:M,server:i})}function ae(e,t,r){let{debug:n}=t,{db:o,port:a,server:d}=r||{};return n&&console.debug(`[${e}] server started on port ${a}`),{...c,attachWalEventBridge:async()=>{if(e!=="database"||!o)throw new Error("WAL bridge is only available for the primary database server");return await D(o)},close:async()=>{let l=[];try{await d?.stop(),n&&console.debug(`[${e}] server stopped on port ${a}`)}catch(i){console.error(`[${e}] server stop error`,i),l.push(i)}if(e==="database"){try{o&&await oe(o),n&&console.debug(`[${e}] closed WAL bridge`)}catch(i){console.error(`[${e}] WAL bridge close error`,i),l.push(i)}try{await o?.syncToFs(),n&&console.debug(`[${e}] synced to filesystem`)}catch(i){console.error(`[${e}] sync error`,i),l.push(i)}}try{await o?.close(),n&&console.debug(`[${e}] closed`)}catch(i){console.error(`[${e}] close error`,i),l.push(i)}if(l.length>0)throw new AggregateError(l,`Failed to close ${e} properly`)},connectionString:ce(a,ue),dump:async l=>{e==="shadow_database"||!o||await me({db:o,debug:n,destinationPath:l})},port:a,prismaORMConnectionString:ce(a,qe),terminalCommand:`PGPASSWORD=${c.password} PGSSLMODE=${c.sslMode} psql -h localhost -p ${a} -U ${c.username} -d ${c.database}`}}function ce(e,t){return`${ze}:${e}/${c.database}?${t.toString()}`}async function de(e,t){let{PGlite:r}=await import("@electric-sql/pglite"),n=await U();return await r.create({database:c.database,dataDir:e,debug:t?5:void 0,extensions:n.extensions,fsBundle:n.fsBundle,relaxedDurability:!1,wasmModule:n.wasmModule,username:c.username})}async function Xe(e,t){let{PGlite:r}=await import("@electric-sql/pglite"),n=await U();return await r.create({database:c.database,dataDir:"memory://",debug:t?5:void 0,extensions:n.extensions,fsBundle:n.fsBundle,relaxedDurability:!1,wasmModule:n.wasmModule,username:c.username})}async function me(e){let{dataDir:t,db:r,debug:n,destinationPath:o}=e,a=r||await de(t,n),{pgDump:d}=await import("@electric-sql/pglite-tools/pg_dump"),l=await d({args:["--schema-only","--no-owner"],fileName:o?(0,le.filename)(o):void 0,pg:await a.clone()});return o?(n&&console.debug(`[DB] Dumping database to ${o}`),await j(l,o)):(n&&console.debug("[DB] Dumping database to memory"),await l.text())}0&&(module.exports={attachWalEventBridge,dumpDB,shouldPollWalAfterMessages,shouldPollWalAfterResponse,startDBServer});

dist/db.js

@@ -1,1 +0,1 @@
-import{a,b,c,d,e}from"./chunk-DZGCLGSX.js";import"./chunk-OTI5SWIV.js";import"./chunk-DGKV2DPF.js";export{a as attachWalEventBridge,e as dumpDB,b as shouldPollWalAfterMessages,c as shouldPollWalAfterResponse,d as startDBServer};
+import{a,b,c,d,e}from"./chunk-NKHRQQEV.js";import"./chunk-NXMFOBF6.js";import"./chunk-OTI5SWIV.js";import"./chunk-DGKV2DPF.js";export{a as attachWalEventBridge,e as dumpDB,b as shouldPollWalAfterMessages,c as shouldPollWalAfterResponse,d as startDBServer};

dist/index.cjs

@@ -1,5 +0,5 @@
-"use strict";var nr=Object.create;var J=Object.defineProperty;var sr=Object.getOwnPropertyDescriptor;var ar=Object.getOwnPropertyNames;var ir=Object.getPrototypeOf,cr=Object.prototype.hasOwnProperty;var S=(t,e)=>()=>(t&&(e=t(t=0)),e);var ue=(t,e)=>{for(var r in e)J(t,r,{get:e[r],enumerable:!0})},ke=(t,e,r,n)=>{if(e&&typeof e=="object"||typeof e=="function")for(let o of ar(e))!cr.call(t,o)&&o!==r&&J(t,o,{get:()=>e[o],enumerable:!(n=sr(e,o))||n.enumerable});return t};var u=(t,e,r)=>(r=t!=null?nr(ir(t)):{},ke(e||!t||!t.__esModule?J(r,"default",{value:t,enumerable:!0}):r,t)),lr=t=>ke(J({},"__esModule",{value:!0}),t);var p=S(()=>{"use strict"});function He(t){return Buffer.from(JSON.stringify(Object.fromEntries(Object.entries(t).sort(([[e],[r]])=>e.localeCompare(r)))),"utf8").toString("base64url")}function dr(t){let e=Buffer.from(t,"base64url").toString("utf8"),{issues:r,output:n,success:o}=(0,f.safeParse)(ur,e,{abortEarly:!0});return o?[null,n]:[r]}var f,Me,ur,N,de=S(()=>{"use strict";p();f=require("valibot"),Me=/^(postgres|postgresql):\/\//,ur=(0,f.pipe)((0,f.string)(),(0,f.parseJson)(),(0,f.object)({databaseUrl:(0,f.pipe)((0,f.string)(),(0,f.url)(),(0,f.regex)(Me)),name:(0,f.optional)((0,f.pipe)((0,f.string)(),(0,f.minLength)(1))),shadowDatabaseUrl:(0,f.pipe)((0,f.string)(),(0,f.url)(),(0,f.regex)(Me))}));N=async(t,e)=>{let{authorization:r}=t,{HTTPException:n}=await import("hono/http-exception");if(!r)throw new n(401,{message:"Missing API Key"});let[o,s="",a]=r.split(" ");if(o!=="Bearer"||a)throw new n(401,{message:"Invalid API Key"});let[i,c]=dr(s);if(i)throw new n(401,{message:"Invalid API Key",cause:i.join(", ")});let{databaseUrl:d,name:l,shadowDatabaseUrl:P}=c,E=e.get("name"),x=new URL(e.req.url).port;if(!l)throw new n(401,{message:`Wrong API Key; The Prisma Dev server running at port ${x} requires an API Key from a newer version of \`prisma dev\`. Check the "${E}" server's output for the updated \`DATABASE_URL\` value.`});if(l!==E)throw new n(401,{message:`Wrong API Key; The Prisma Dev server running at port ${x} is named "${E}", but the API Key is for "${l}"`});let{hostname:A,port:W}=new URL(d),{port:er}=e.get("db"),{hostname:tr,port:rr}=new URL(P),or=e.get("shadowDBPort");if(A!=="localhost"||Number(W)!==er||tr!=="localhost"||Number(rr)!==or)throw new n(401,{message:"Wrong API Key; Check your Prisma schema's `provider.url` value (probably defined in `.env`'s `DATABASE_URL` environment variable) is aligned with `prisma dev`'s output"});return{decodedAPIKey:c}}});function ge(t,{suffix:e="nodejs"}={}){if(typeof t!="string")throw new TypeError(`Expected a string, got ${typeof t}`);return e&&(t+=`-${e}`),X.default.platform==="darwin"?pr(t):X.default.platform==="win32"?mr(t):gr(t)}var h,pe,X,O,me,B,pr,mr,gr,Ue=S(()=>{"use strict";p();h=u(require("path"),1),pe=u(require("os"),1),X=u(require("process"),1),O=pe.default.homedir(),me=pe.default.tmpdir(),{env:B}=X.default,pr=t=>{let e=h.default.join(O,"Library");return{data:h.default.join(e,"Application Support",t),config:h.default.join(e,"Preferences",t),cache:h.default.join(e,"Caches",t),log:h.default.join(e,"Logs",t),temp:h.default.join(me,t)}},mr=t=>{let e=B.APPDATA||h.default.join(O,"AppData","Roaming"),r=B.LOCALAPPDATA||h.default.join(O,"AppData","Local");return{data:h.default.join(r,t,"Data"),config:h.default.join(e,t,"Config"),cache:h.default.join(r,t,"Cache"),log:h.default.join(r,t,"Log"),temp:h.default.join(me,t)}},gr=t=>{let e=h.default.basename(O);return{data:h.default.join(B.XDG_DATA_HOME||h.default.join(O,".local","share"),t),config:h.default.join(B.XDG_CONFIG_HOME||h.default.join(O,".config"),t),cache:h.default.join(B.XDG_CACHE_HOME||h.default.join(O,".cache"),t),log:h.default.join(B.XDG_STATE_HOME||h.default.join(O,".local","state"),t),temp:h.default.join(me,e,t)}}});function qe(t,e){return`${Ge.cache}/engine/${t}/${e}`}function j(t){return`${Ge.data}/${t}`}async function Ve(t){try{return await(0,w.access)(t,w.constants.F_OK),!0}catch(e){if(fe(e))return!1;throw e}}async function Ke(t,e){let r=await fr(t);await(0,w.writeFile)(e,r),await(0,w.chmod)(e,"755")}async function Qe(t,e){await t.stream().pipeTo(z.WriteStream.toWeb((0,z.createWriteStream)(e,{encoding:"utf8"})))}function fe(t){return t!=null&&typeof t=="object"&&"code"in t&&t.code==="ENOENT"}async function Je(t){try{return await(0,w.readFile)(t,{encoding:"utf-8"})}catch(e){if(fe(e))return null;throw e}}async function Xe(t){await(0,w.mkdir)(t,{recursive:!0})}async function ze(t,e){try{return(await(0,w.readdir)(t,{withFileTypes:!0})).reduce((n,o)=>(o.isDirectory()&&!o.name.startsWith(".")&&(!e||(0,Fe.default)(e,o.name))&&n.push(o.name),n),[])}catch(r){if(fe(r))return[];throw r}}var z,w,We,je,Fe,Ge,fr,Y=S(()=>{"use strict";p();z=require("fs"),w=require("fs/promises"),We=require("util"),je=require("zlib");Ue();Fe=u(require("zeptomatch"),1),Ge=ge("prisma-dev"),fr=(0,We.promisify)(je.unzip)});function ne(t){let e,r,n=new Promise((a,i)=>{e=a,r=i}),o=a=>{o=s=null,r(a),t?.onRejected?.(a),t?.onFulfilled?.()},s=a=>{s=o=null,e(a),t?.onResolved?.(a),t?.onFulfilled?.()};return{isFulfilled:()=>s===o,promise:n,reject:a=>o?.(a),resolve:a=>s?.(a)}}var Ee=S(()=>{"use strict";p()});function se(t,e){return console.error(t),t instanceof G?e.json({EngineNotStarted:{reason:{EngineStartupError:{logs:[],msg:t.message}}}},500):t instanceof M?e.text(t.responseBody,t.statusCode):e.body(null,500)}var ht,Pt,bt,yt,vt,wt,Or,_r,ft,H,G,M,Te=S(()=>{"use strict";p();ht=require("child_process"),Pt=require("events"),bt=require("fs/promises"),yt=require("path"),vt=require("timers/promises");Ee();wt=require("std-env");Y();({PRISMA_DEV_FORCE_ENGINE_BINARY_DOWNLOAD:Or,PRISMA_DEV_FORCE_ENGINE_BINARY_PATH:_r,PRISMA_DEV_FORCE_NETWORK_DELAY_MS:ft}=wt.process.env),H=class t{static#t=new Map;#e;#r;constructor(e){this.#e=e,this.#r=null}static async get(e){let{debug:r}=e,n=`${e.schemaHash}:${e.clientVersion}`;try{let o=t.#t.get(n);if(o)return o;let s=new t(e);return t.#t.set(n,s),r&&console.debug("[Query Engine] starting...",e),await s.start(),r&&console.debug("[Query Engine] started!"),s}finally{t.stopAll(n)}}static async stopAll(e){let n=(await Promise.allSettled(Array.from(t.#t.entries()).filter(([o])=>o!==e).map(async([o,s])=>{try{await s.stop()}finally{t.#t.delete(o)}}))).filter(o=>o.status==="rejected").map(o=>o.reason);if(n.length>0)throw new AggregateError(n,"Failed to stop engines")}async commitTransaction(e,r){return await this.#i(e,r,"commit")}async request(e,r){let{url:n}=await this.start(),o=this.#o(r),s=await fetch(n,{body:typeof e=="string"?e:JSON.stringify(e),headers:{...o,"Content-Type":"application/json"},method:"POST"});if(!s.ok)throw await M.fromResponse(s);return await s.text()}async rollbackTransaction(e,r){return await this.#i(e,r,"rollback")}async startTransaction(e,r){let{url:n}=await this.start(),o=this.#o(r),s=await fetch(`${n}/transaction/start`,{body:JSON.stringify(e),headers:{...o,"Content-Type":"application/json"},method:"POST"});if(!s.ok)throw await M.fromResponse(s);return await s.json()}async start(){if(this.#r!=null)return await this.#r;let{promise:e,reject:r,resolve:n}=ne();this.#r=e;let o=_r||await this.#s();this.#e.debug&&console.debug("[Query Engine] spinning up at path...",o);let{proxySignals:s}=await import("foreground-child/proxy-signals"),a=(0,ht.spawn)(o,["--enable-raw-queries","--enable-telemetry-in-response","--port","0"],{env:{LOG_QUERIES:"y",PRISMA_DML:this.#e.base64Schema,QE_LOG_LEVEL:"TRACE",RUST_BACKTRACE:"1",RUST_LOG:"info"},stdio:["ignore","pipe","pipe"],windowsHide:!0});s(a),a.stderr.setEncoding("utf8"),a.stdout.setEncoding("utf8");let i=l=>{let P=l.split(`
-`).find(W=>W.includes("Started query engine http server"));if(!P)return;a.stdout.removeListener("data",i);let{fields:E}=JSON.parse(P);if(E==null)return r(new Error(`Unexpected data during initialization, "fields" are missing: ${l}`));let{ip:x,port:A}=E;if(x==null||A==null)return r(new Error(`This version of query-engine is not compatible with minippg, "ip" and "port" are missing in the startup log entry.
-Received data: ${l}`));n({childProcess:a,url:`http://${x}:${A}`})},c=l=>{this.#r=null,r(new G(String(l))),a.removeListener("exit",d),a.kill()};a.once("error",c);let d=(l,P)=>{this.#r=null,r(new G(`Query Engine exited with code ${l} and signal ${P}`))};return a.once("exit",d),a.stdout.on("data",i),this.#e.debug&&(a.stderr.on("data",console.error.bind(console,"[Query Engine]")),a.stdout.on("data",console.debug.bind(console,"[Query Engine]"))),await this.#r}async stop(){if(this.#r==null)return;let{childProcess:e}=await this.#r;e.exitCode==null&&e.signalCode==null&&(this.#r=null,e.kill(),await(0,Pt.once)(e,"exit"))}async#s(){this.#e.debug&&console.debug("[Query Engine] getting engine commit hash...");let e=await this.#a();this.#e.debug&&console.debug("[Query Engine] got engine commit hash",e);let r=qe(this.#e.clientVersion,e);this.#e.debug&&console.debug("[Query Engine] cache directory path",r),await(0,bt.mkdir)(r,{recursive:!0});let{binaryTarget:n}=this.#e.platform,o=n==="windows"?".exe":"",s=(0,yt.join)(r,`query-engine-${n}${o}`);return this.#e.debug&&console.debug("[Query Engine] binary path",s),(Or==="1"||await Ve(s)===!1)&&await this.#n({commitHash:e,extension:o,engineBinaryPath:s}),s}async#a(){let e=await fetch(`https://registry.npmjs.org/@prisma/client/${this.#e.clientVersion}`);if(!e.ok)throw new Error(`Couldn't fetch package.json from npm registry, status code: ${e.status}`);let n=(await e.json()).devDependencies?.["@prisma/engines-version"];if(!n)throw new Error("Couldn't find engines version in package.json");let o=n.split(".").at(-1);if(!o)throw new Error("Couldn't find commit hash in engines version");return o}async#n(e){let{commitHash:r,extension:n,engineBinaryPath:o}=e,{binaryTarget:s}=this.#e.platform,a=`https://binaries.prisma.sh/all_commits/${r}/${s}/query-engine${n}.gz`;this.#e.debug&&console.debug("[Query Engine] downloading engine from url",a);let i=await fetch(a);if(!i.ok)throw new Error(`Couldn't download engine. URL: ${a}, status code: ${i.status}`);ft&&await(0,vt.setTimeout)(Number(ft)),await Ke(await i.arrayBuffer(),o),this.#e.debug&&console.debug("[Query Engine] downloaded and saved at",o)}#o(e){let r={};for(let[n,o]of Object.entries(e))o!=null&&(r[n]=o);return r}async#i(e,r,n){let{url:o}=await this.#r,s=this.#o(r),a=await fetch(`${o}/transaction/${e}/${n}`,{headers:{...s,"Content-Type":"application/json"},method:"POST"});if(!a.ok)throw await M.fromResponse(a);try{return await a.json()}catch{return{}}}};G=class extends Error{name="EngineStartError"},M=class t extends Error{constructor(r,n,o){super(`${r}: Query Engine response status ${n}, body: ${o}`);this.action=r;this.statusCode=n;this.responseBody=o}name="EngineHttpError";static async fromResponse(r){let n=new URL(r.url),o=await r.text();return new t(n.pathname,r.status,o)}}});async function St(t){let{output:e,success:r}=(0,v.safeParse)(Ir,await t.req.json(),{abortEarly:!0});return r?e:t.text("Invalid input",400)}var v,Ir,Et=S(()=>{"use strict";p();v=require("valibot"),Ir=(0,v.object)({tags:(0,v.union)([(0,v.pipe)((0,v.array)((0,v.string)()),(0,v.minLength)(1)),(0,v.literal)("all")])})});async function Tt(t){return De===void 0&&(De=await $.Server.create({databaseUrl:t.get("db").connectionString,maxResponseSize:(0,$.parseSize)("128 MiB"),queryTimeout:(0,$.parseDuration)("PT5M"),maxTransactionTimeout:(0,$.parseDuration)("PT5M"),maxTransactionWaitTime:(0,$.parseDuration)("PT5M"),perRequestLogContext:{logFormat:"text",logLevel:t.get("debug")?"debug":"off"}})),De}var $,ae,De,Dt=S(()=>{"use strict";p();$=require("@prisma/query-plan-executor"),ae=require("@prisma/query-plan-executor")});async function xe(t){let r=new TextEncoder().encode(t),n=await crypto.subtle.digest("SHA-256",r);return Array.from(new Uint8Array(n)).map(a=>a.toString(16).padStart(2,"0")).join("")}function Rt(t){let e=t.req.param("schemaHash"),r=ce.get(e);return r==null?t.json({EngineNotStarted:{reason:"SchemaMissing"}},404):{schemaHash:e,schemas:r}}async function xt(t,e,r){let n=Re.Buffer.from(t,"base64").toString("utf8"),o=(0,ie.getSchema)(n),s=o.list.find(d=>d.type==="datasource");if(!s)throw new Error("No datasource block found in schema.");let a=s.assignments.find(d=>d.type==="assignment"&&d.key==="url");a?a.value=`"${e.toString()}"`:s.assignments.push({key:"url",type:"assignment",value:`"${e.toString()}"`});let i=(0,ie.printSchema)(o);r&&console.log("[Accelerate] schema with override:",i);let c=await xe(i);return{base64Override:Re.Buffer.from(i,"utf8").toString("base64"),overrideHash:c}}var Re,ie,ce,At=S(()=>{"use strict";p();Re=require("buffer"),ie=require("@mrleebo/prisma-ast"),ce=new Map});function le(t){let{req:e}=t;return{traceparent:e.header("traceparent"),"X-capture-telemetry":e.header("X-capture-telemetry")}}var Ot=S(()=>{"use strict";p()});async function _t(t){let{issues:e,output:r,success:n}=(0,g.safeParse)($r,await t.req.json(),{abortEarly:!0});return n?r:t.json({EngineNotStarted:{reason:"InvalidRequest",issues:e}},400)}function It(t,e){let{output:r,success:n}=(0,g.safeParse)(Nr,t);return n?r:e.json({EngineMalfunction:{}},500)}var g,$r,Nr,$t=S(()=>{"use strict";p();g=require("valibot"),$r=(0,g.object)({isolation_level:(0,g.optional)((0,g.string)()),max_wait:(0,g.pipe)((0,g.number)(),(0,g.integer)(),(0,g.minValue)(0)),timeout:(0,g.pipe)((0,g.number)(),(0,g.integer)(),(0,g.minValue)(0))});Nr=(0,g.looseObject)({id:(0,g.union)([(0,g.string)(),(0,g.number)()])})});var Lt={};ue(Lt,{accelerateRoute:()=>q});async function Ae(t){let{req:e}=t,r=Rt(t);if(r instanceof Response)return r;let{base64Override:n,overrideHash:o}=r.schemas;return await H.get({base64Schema:n,clientVersion:process.env.PRISMA_DEV_FORCE_CLIENT_VERSION||e.param("clientVersion"),debug:t.get("debug"),platform:t.get("platform"),schemaHash:o})}var Nt,Ct,C,q,Cr,V,Lr,Br,Bt=S(()=>{"use strict";p();Nt=require("hono/http-exception"),Ct=require("hono/tiny"),C=require("hono/validator");de();Et();Te();Dt();At();Ot();$t();q=new Ct.Hono;q.post("/invalidate",(0,C.validator)("header",N),async t=>{let e=await St(t);return e instanceof Response?e:t.body(null)});Cr="/:clientVersion/:schemaHash",V=q.basePath(Cr);q.route("/",V);Lr=["/graphql","/itx/:transactionId/graphql"];V.on("POST",[...Lr],(0,C.validator)("header",N),async t=>{let{req:e}=t;try{let r=await Ae(t);if(r instanceof Response)return r;let n=await e.text(),o=e.param("transactionId"),s=await r.request(n,{...le(t),"X-transaction-id":o});return t.text(s)}catch(r){return se(r,t)}});V.basePath("/itx/:transactionId").on("POST",["/commit","/rollback"],(0,C.validator)("header",N),async t=>{let{req:e}=t;try{let r=await Ae(t);if(r instanceof Response)return r;let o=`${e.routePath.split("/").filter(Boolean).at(-1)}Transaction`,s=e.param("transactionId"),a=await r[o](s,le(t));return t.json(a)}catch(r){return se(r,t)}});V.put("/schema",(0,C.validator)("header",N),async t=>{let{req:e}=t,r=await e.text();if(!r)return t.text("Missing schema",400);let n=e.param("schemaHash"),o=ce.get(n);if(o==null){if(n!==await xe(r))return t.text("Schema hash mismatch",400);let s=await xt(r,t.get("db").prismaORMConnectionString,t.get("debug"));return ce.set(n,{base64Original:r,...s}),t.text(n)}return r!==o.base64Original?t.text("Schema mismatch",400):t.text(n)});V.post("/transaction/start",(0,C.validator)("header",N),async t=>{let{req:e}=t,r=await _t(t);if(r instanceof Response)return r;try{let n=await Ae(t);if(n instanceof Response)return n;let o=await n.startTransaction(r,le(t)),s=It(o,t);if(s instanceof Response)return s;let{id:a}=s,i=e.param("clientVersion"),c=e.param("schemaHash");return t.json({...o,"data-proxy":{endpoint:`${new URL(e.url).origin}/${i}/${c}/itx/${a}`}})}catch(n){return se(n,t)}});Br=[["/connection-info","GET"],["/query","POST"],["/transaction/start","POST"],["/transaction/:transactionId/commit","POST"],["/transaction/:transactionId/query","POST"],["/transaction/:transactionId/rollback","POST"]];for(let[t,e]of Br)q.on(e,t,(0,C.validator)("header",N),async r=>{let n=r.req.header("prisma-engine-hash");if(n!=="0.0.0"&&n!==ae.version)throw new Nt.HTTPException(400,{message:`Using an HTTP connection string is not supported with Prisma Client version ${n} by this version of \`prisma dev\`. Please either use a direct TCP connection string or upgrade your client to version ${ae.version}.`});return await(await Tt(r)).fetch(r.req.raw)})});var Ht={};ue(Ht,{utilityRoute:()=>Oe});var kt,Mt,Oe,Ho,Ut=S(()=>{"use strict";p();kt=require("hono/tiny"),Mt=require("http-status-codes"),Oe=new kt.Hono;Oe.post("/database/dump",async t=>{let e=t.get("db"),r=t.get("databaseDumpPath");return await e.dump(r),t.json({dumpPath:r},Mt.StatusCodes.CREATED)});Ho=Oe.get("/health",t=>t.json({name:t.get("name")}))});var Kr={};ue(Kr,{DEFAULT_DATABASE_PORT:()=>ee,DEFAULT_SERVER_PORT:()=>te,DEFAULT_SHADOW_DATABASE_PORT:()=>re,PortNotAvailableError:()=>T,ServerAlreadyRunningError:()=>Q,startPrismaDevServer:()=>Zt,unstable_startServer:()=>Vr});module.exports=lr(Kr);p();p();de();p();var dt=require("pathe/utils");Y();p();var I=require("get-port-please"),oe=require("remeda"),ee=51214,te=51213,re=51215,Z=65535,k=0,_=-1/0;async function be(t){let{debug:e,name:r,requestedPorts:n,servers:o}=t,{portsUsedByOtherServers:s,portsUsedByThisServerLastTime:a}=br(r,o);e&&(console.debug(`ports used by other servers: ${Object.keys(s).join(", ")}`),console.debug(`ports used by "${r}" server last time: ${JSON.stringify(a)}`));let i={databasePort:_,port:_,shadowDatabasePort:_},c=["port","databasePort","shadowDatabasePort"];for(let d of c){let l=await hr({debug:e,portKey:d,portsUsedByOtherServers:s,portsUsedByThisServerLastTime:a,requestedPorts:n})??await Pr({debug:e,pickedPorts:i,portKey:d,portsUsedByOtherServers:s,portsUsedByThisServerLastTime:a});e&&console.debug(`Got port for "${d}": ${l}`),i[d]=l}return e&&console.debug(`Picked ports: ${JSON.stringify(i)}`),i}async function hr(t){let{debug:e,portKey:r,portsUsedByOtherServers:n,portsUsedByThisServerLastTime:o,requestedPorts:s}=t,{[r]:a,...i}=s;if(Ye(a))return await yr({debug:e,otherRequestedPorts:i,portKey:r,portsUsedByOtherServers:n,requestedPort:a}),a;let c=o?.[r]??_;if(!Ye(c))return e&&console.debug(`No port specified for "${r}". Trying to pick a new port.`),null;let d=c in n;return d||Object.values(i).includes(c)?(e&&console.debug(`Port ${c} that was used last time for this server, ${d?"is also used by another server":"has been requested for another service"}. Trying to pick a new port.`),null):await(0,I.checkPort)(c)===!1?(e&&console.debug(`Port ${c}, that was used last time for this server, is not available. Trying to pick a new port.`),null):(e&&console.debug(`Using port ${c} for "${r}" as it was used last time and is available.`),c)}async function Pr(t){let{debug:e,pickedPorts:r,portKey:n,portsUsedByOtherServers:o,portsUsedByThisServerLastTime:s}=t,a=Math.max(ee,te,re)+1,i=[...Object.values(r),...Object.keys(o).map(Number),...Object.values(s||{})],c=Math.min(Math.max(a,...i)+100,Z),d=(0,oe.difference)((0,oe.range)(a,c),i),l={port:te,databasePort:ee,shadowDatabasePort:re}[n];try{return await(0,I.getPort)({port:l in o||Object.values(r).includes(l)||Object.values(s||{}).includes(l)?void 0:l,ports:d})}catch(P){if(P instanceof Error&&P.name==="GetPortError"&&c+1<=Z)return e&&console.debug(`Expanding port lookup to range [${c+1}, ${Z}].`),await(0,I.getPort)({portRange:[c+1,Z]});throw P}}function Ye(t){return Number.isFinite(t)&&t>=0}function br(t,e){let r={},n;for(let o of e){let{databasePort:s,port:a,shadowDatabasePort:i}=o;if(o.name===t){n={databasePort:s,port:a,shadowDatabasePort:i};continue}r[s]=!0,r[a]=!0,r[i]=!0}return{portsUsedByOtherServers:r,portsUsedByThisServerLastTime:n}}async function yr(t){let{debug:e,otherRequestedPorts:r,portKey:n,portsUsedByOtherServers:o,requestedPort:s}=t;if(s!==k){if(s in o)throw e&&console.error(`Port ${s} was requested for "${n}", but is already used by another server.`),new Pe(s);if(Object.values(r).includes(s))throw e&&console.error(`Port ${s} was requested for "${n}", but also for another key.`),new he(s);if((0,I.isUnsafePort)(s))throw e&&console.error(`Port ${s} was requested for "${n}", but is unsafe.`),new T(s);if(await(0,I.checkPort)(s)===!1)throw e&&console.error(`Port ${s} was requested for "${n}", but is not available.`),new T(s)}}var T=class extends Error{constructor(r){super(`Port \`${r}\` is not available.`);this.port=r}name="PortNotAvailableError"},he=class extends Error{constructor(r){super(`Port number \`${r}\` was requested twice. Please choose a different port for each service.`);this.port=r}name="PortRequestedTwiceError"},Pe=class extends Error{constructor(r){super(`Port number \`${r}\` belongs to another Prisma Dev server. Please choose a different port.`);this.port=r}name="PortBelongsToAnotherServerError"};p();var rt=require("@electric-sql/pglite"),D="_prisma_dev_wal",ye="events",ot="install_all_triggers",Ze="capture_event",et="prisma_dev_wal_capture",F=new WeakMap,vr=new Set(["ALTER","COMMIT","COPY","CREATE","DELETE","DROP","INSERT","MERGE","TRUNCATE","UPDATE"]);async function ve(t,e){let r=F.get(t);if(r&&!r.closed)return r.bridge;let n=t.execProtocolRaw.bind(t),o={bridge:{close:async()=>{o.closed||(o.closed=!0,o.subscribers.clear(),t.execProtocolRaw===s&&(t.execProtocolRaw=n),await o.pollPromise,F.delete(t))},poll:async()=>{await tt(o,t)},subscribe:a=>(o.subscribers.add(a),()=>{o.subscribers.delete(a)})},closed:!1,ensureInfrastructurePromise:null,pendingPoll:!1,pollPromise:null,subscribers:new Set,suppressDepth:0},s=async(a,i)=>{let c=await n(a,i);return!o.closed&&o.suppressDepth===0&&at(c)&&tt(o,t),c};return t.execProtocolRaw=s,F.set(t,o),await it(o,t),o.bridge}async function nt(t){let e=F.get(t);e&&await e.bridge.close()}function st(t){for(let e of t){if(e.name!=="commandComplete"||typeof e.text!="string")continue;let r=e.text.split(/\s+/,1)[0]?.toUpperCase();if(r&&vr.has(r))return!0}return!1}function at(t){if(t.length===0)return!1;let e=[];return new rt.protocol.Parser().parse(t,n=>{e.push(n)}),st(e)}async function it(t,e){t.ensureInfrastructurePromise??=we(t,e,async()=>{await e.exec(`CREATE SCHEMA IF NOT EXISTS "${D}"`),await e.exec(`
-      CREATE TABLE IF NOT EXISTS "${D}"."${ye}" (
+"use strict";var vr=Object.create;var Y=Object.defineProperty;var Sr=Object.getOwnPropertyDescriptor;var Er=Object.getOwnPropertyNames;var Rr=Object.getPrototypeOf,Tr=Object.prototype.hasOwnProperty;var S=(e,t)=>()=>(e&&(t=e(e=0)),t);var fe=(e,t)=>{for(var r in t)Y(e,r,{get:t[r],enumerable:!0})},qe=(e,t,r,n)=>{if(t&&typeof t=="object"||typeof t=="function")for(let o of Er(t))!Tr.call(e,o)&&o!==r&&Y(e,o,{get:()=>t[o],enumerable:!(n=Sr(t,o))||n.enumerable});return e};var y=(e,t,r)=>(r=e!=null?vr(Rr(e)):{},qe(t||!e||!e.__esModule?Y(r,"default",{value:e,enumerable:!0}):r,e)),Ar=e=>qe(Y({},"__esModule",{value:!0}),e);var Dr,f,u=S(()=>{"use strict";Dr=()=>typeof document>"u"?new URL(`file:${__filename}`).href:document.currentScript&&document.currentScript.tagName.toUpperCase()==="SCRIPT"?document.currentScript.src:new URL("main.js",document.baseURI).href,f=Dr()});function Ve(e){return Buffer.from(JSON.stringify(Object.fromEntries(Object.entries(e).sort(([[t],[r]])=>t.localeCompare(r)))),"utf8").toString("base64url")}function _r(e){let t=Buffer.from(e,"base64url").toString("utf8"),{issues:r,output:n,success:o}=(0,g.safeParse)(xr,t,{abortEarly:!0});return o?[null,n]:[r]}var g,ze,xr,$,he=S(()=>{"use strict";u();g=require("valibot"),ze=/^(postgres|postgresql):\/\//,xr=(0,g.pipe)((0,g.string)(),(0,g.parseJson)(),(0,g.object)({databaseUrl:(0,g.pipe)((0,g.string)(),(0,g.url)(),(0,g.regex)(ze)),name:(0,g.optional)((0,g.pipe)((0,g.string)(),(0,g.minLength)(1))),shadowDatabaseUrl:(0,g.pipe)((0,g.string)(),(0,g.url)(),(0,g.regex)(ze))}));$=async(e,t)=>{let{authorization:r}=e,{HTTPException:n}=await import("hono/http-exception");if(!r)throw new n(401,{message:"Missing API Key"});let[o,s="",a]=r.split(" ");if(o!=="Bearer"||a)throw new n(401,{message:"Invalid API Key"});let[i,c]=_r(s);if(i)throw new n(401,{message:"Invalid API Key",cause:i.join(", ")});let{databaseUrl:d,name:l,shadowDatabaseUrl:P}=c,E=t.get("name"),D=new URL(t.req.url).port;if(!l)throw new n(401,{message:`Wrong API Key; The Prisma Dev server running at port ${D} requires an API Key from a newer version of \`prisma dev\`. Check the "${E}" server's output for the updated \`DATABASE_URL\` value.`});if(l!==E)throw new n(401,{message:`Wrong API Key; The Prisma Dev server running at port ${D} is named "${E}", but the API Key is for "${l}"`});let{hostname:x,port:j}=new URL(d),{port:Pr}=t.get("db"),{hostname:br,port:yr}=new URL(P),wr=t.get("shadowDBPort");if(x!=="localhost"||Number(j)!==Pr||br!=="localhost"||Number(yr)!==wr)throw new n(401,{message:"Wrong API Key; Check your Prisma schema's `provider.url` value (probably defined in `.env`'s `DATABASE_URL` environment variable) is aligned with `prisma dev`'s output"});return{decodedAPIKey:c}}});function ye(e,{suffix:t="nodejs"}={}){if(typeof e!="string")throw new TypeError(`Expected a string, got ${typeof e}`);return t&&(e+=`-${t}`),Z.default.platform==="darwin"?Or(e):Z.default.platform==="win32"?Ir(e):Lr(e)}var h,Pe,Z,_,be,U,Or,Ir,Lr,Ke=S(()=>{"use strict";u();h=y(require("path"),1),Pe=y(require("os"),1),Z=y(require("process"),1),_=Pe.default.homedir(),be=Pe.default.tmpdir(),{env:U}=Z.default,Or=e=>{let t=h.default.join(_,"Library");return{data:h.default.join(t,"Application Support",e),config:h.default.join(t,"Preferences",e),cache:h.default.join(t,"Caches",e),log:h.default.join(t,"Logs",e),temp:h.default.join(be,e)}},Ir=e=>{let t=U.APPDATA||h.default.join(_,"AppData","Roaming"),r=U.LOCALAPPDATA||h.default.join(_,"AppData","Local");return{data:h.default.join(r,e,"Data"),config:h.default.join(t,e,"Config"),cache:h.default.join(r,e,"Cache"),log:h.default.join(r,e,"Log"),temp:h.default.join(be,e)}},Lr=e=>{let t=h.default.basename(_);return{data:h.default.join(U.XDG_DATA_HOME||h.default.join(_,".local","share"),e),config:h.default.join(U.XDG_CONFIG_HOME||h.default.join(_,".config"),e),cache:h.default.join(U.XDG_CACHE_HOME||h.default.join(_,".cache"),e),log:h.default.join(U.XDG_STATE_HOME||h.default.join(_,".local","state"),e),temp:h.default.join(be,t,e)}}});function Ze(e,t){return`${Ye.cache}/engine/${e}/${t}`}function F(e){return`${Ye.data}/${e}`}async function et(e){try{return await(0,v.access)(e,v.constants.F_OK),!0}catch(t){if(we(t))return!1;throw t}}async function tt(e,t){let r=await Br(e);await(0,v.writeFile)(t,r),await(0,v.chmod)(t,"755")}async function rt(e,t){await e.stream().pipeTo(ee.WriteStream.toWeb((0,ee.createWriteStream)(t,{encoding:"utf8"})))}function we(e){return e!=null&&typeof e=="object"&&"code"in e&&e.code==="ENOENT"}async function nt(e){try{return await(0,v.readFile)(e,{encoding:"utf-8"})}catch(t){if(we(t))return null;throw t}}async function ot(e){await(0,v.mkdir)(e,{recursive:!0})}async function st(e,t){try{return(await(0,v.readdir)(e,{withFileTypes:!0})).reduce((n,o)=>(o.isDirectory()&&!o.name.startsWith(".")&&(!t||(0,Xe.default)(t,o.name))&&n.push(o.name),n),[])}catch(r){if(we(r))return[];throw r}}var ee,v,Je,Qe,Xe,Ye,Br,te=S(()=>{"use strict";u();ee=require("fs"),v=require("fs/promises"),Je=require("util"),Qe=require("zlib");Ke();Xe=y(require("zeptomatch"),1),Ye=ye("prisma-dev"),Br=(0,Je.promisify)(Qe.unzip)});function le(e){let t,r,n=new Promise((a,i)=>{t=a,r=i}),o=a=>{o=s=null,r(a),e?.onRejected?.(a),e?.onFulfilled?.()},s=a=>{s=o=null,t(a),e?.onResolved?.(a),e?.onFulfilled?.()};return{isFulfilled:()=>s===o,promise:n,reject:a=>o?.(a),resolve:a=>s?.(a)}}var Ie=S(()=>{"use strict";u()});function ue(e,t){return console.error(e),e instanceof V?t.json({EngineNotStarted:{reason:{EngineStartupError:{logs:[],msg:e.message}}}},500):e instanceof H?t.text(e.responseBody,e.statusCode):t.body(null,500)}var Bt,Nt,$t,Ct,kt,Ut,on,sn,Lt,W,V,H,Le=S(()=>{"use strict";u();Bt=require("child_process"),Nt=require("events"),$t=require("fs/promises"),Ct=require("path"),kt=require("timers/promises");Ie();Ut=require("std-env");te();({PRISMA_DEV_FORCE_ENGINE_BINARY_DOWNLOAD:on,PRISMA_DEV_FORCE_ENGINE_BINARY_PATH:sn,PRISMA_DEV_FORCE_NETWORK_DELAY_MS:Lt}=Ut.process.env),W=class e{static#t=new Map;#e;#r;constructor(t){this.#e=t,this.#r=null}static async get(t){let{debug:r}=t,n=`${t.schemaHash}:${t.clientVersion}`;try{let o=e.#t.get(n);if(o)return o;let s=new e(t);return e.#t.set(n,s),r&&console.debug("[Query Engine] starting...",t),await s.start(),r&&console.debug("[Query Engine] started!"),s}finally{e.stopAll(n)}}static async stopAll(t){let n=(await Promise.allSettled(Array.from(e.#t.entries()).filter(([o])=>o!==t).map(async([o,s])=>{try{await s.stop()}finally{e.#t.delete(o)}}))).filter(o=>o.status==="rejected").map(o=>o.reason);if(n.length>0)throw new AggregateError(n,"Failed to stop engines")}async commitTransaction(t,r){return await this.#i(t,r,"commit")}async request(t,r){let{url:n}=await this.start(),o=this.#n(r),s=await fetch(n,{body:typeof t=="string"?t:JSON.stringify(t),headers:{...o,"Content-Type":"application/json"},method:"POST"});if(!s.ok)throw await H.fromResponse(s);return await s.text()}async rollbackTransaction(t,r){return await this.#i(t,r,"rollback")}async startTransaction(t,r){let{url:n}=await this.start(),o=this.#n(r),s=await fetch(`${n}/transaction/start`,{body:JSON.stringify(t),headers:{...o,"Content-Type":"application/json"},method:"POST"});if(!s.ok)throw await H.fromResponse(s);return await s.json()}async start(){if(this.#r!=null)return await this.#r;let{promise:t,reject:r,resolve:n}=le();this.#r=t;let o=sn||await this.#s();this.#e.debug&&console.debug("[Query Engine] spinning up at path...",o);let{proxySignals:s}=await import("foreground-child/proxy-signals"),a=(0,Bt.spawn)(o,["--enable-raw-queries","--enable-telemetry-in-response","--port","0"],{env:{LOG_QUERIES:"y",PRISMA_DML:this.#e.base64Schema,QE_LOG_LEVEL:"TRACE",RUST_BACKTRACE:"1",RUST_LOG:"info"},stdio:["ignore","pipe","pipe"],windowsHide:!0});s(a),a.stderr.setEncoding("utf8"),a.stdout.setEncoding("utf8");let i=l=>{let P=l.split(`
+`).find(j=>j.includes("Started query engine http server"));if(!P)return;a.stdout.removeListener("data",i);let{fields:E}=JSON.parse(P);if(E==null)return r(new Error(`Unexpected data during initialization, "fields" are missing: ${l}`));let{ip:D,port:x}=E;if(D==null||x==null)return r(new Error(`This version of query-engine is not compatible with minippg, "ip" and "port" are missing in the startup log entry.
+Received data: ${l}`));n({childProcess:a,url:`http://${D}:${x}`})},c=l=>{this.#r=null,r(new V(String(l))),a.removeListener("exit",d),a.kill()};a.once("error",c);let d=(l,P)=>{this.#r=null,r(new V(`Query Engine exited with code ${l} and signal ${P}`))};return a.once("exit",d),a.stdout.on("data",i),this.#e.debug&&(a.stderr.on("data",console.error.bind(console,"[Query Engine]")),a.stdout.on("data",console.debug.bind(console,"[Query Engine]"))),await this.#r}async stop(){if(this.#r==null)return;let{childProcess:t}=await this.#r;t.exitCode==null&&t.signalCode==null&&(this.#r=null,t.kill(),await(0,Nt.once)(t,"exit"))}async#s(){this.#e.debug&&console.debug("[Query Engine] getting engine commit hash...");let t=await this.#a();this.#e.debug&&console.debug("[Query Engine] got engine commit hash",t);let r=Ze(this.#e.clientVersion,t);this.#e.debug&&console.debug("[Query Engine] cache directory path",r),await(0,$t.mkdir)(r,{recursive:!0});let{binaryTarget:n}=this.#e.platform,o=n==="windows"?".exe":"",s=(0,Ct.join)(r,`query-engine-${n}${o}`);return this.#e.debug&&console.debug("[Query Engine] binary path",s),(on==="1"||await et(s)===!1)&&await this.#o({commitHash:t,extension:o,engineBinaryPath:s}),s}async#a(){let t=await fetch(`https://registry.npmjs.org/@prisma/client/${this.#e.clientVersion}`);if(!t.ok)throw new Error(`Couldn't fetch package.json from npm registry, status code: ${t.status}`);let n=(await t.json()).devDependencies?.["@prisma/engines-version"];if(!n)throw new Error("Couldn't find engines version in package.json");let o=n.split(".").at(-1);if(!o)throw new Error("Couldn't find commit hash in engines version");return o}async#o(t){let{commitHash:r,extension:n,engineBinaryPath:o}=t,{binaryTarget:s}=this.#e.platform,a=`https://binaries.prisma.sh/all_commits/${r}/${s}/query-engine${n}.gz`;this.#e.debug&&console.debug("[Query Engine] downloading engine from url",a);let i=await fetch(a);if(!i.ok)throw new Error(`Couldn't download engine. URL: ${a}, status code: ${i.status}`);Lt&&await(0,kt.setTimeout)(Number(Lt)),await tt(await i.arrayBuffer(),o),this.#e.debug&&console.debug("[Query Engine] downloaded and saved at",o)}#n(t){let r={};for(let[n,o]of Object.entries(t))o!=null&&(r[n]=o);return r}async#i(t,r,n){let{url:o}=await this.#r,s=this.#n(r),a=await fetch(`${o}/transaction/${t}/${n}`,{headers:{...s,"Content-Type":"application/json"},method:"POST"});if(!a.ok)throw await H.fromResponse(a);try{return await a.json()}catch{return{}}}};V=class extends Error{name="EngineStartError"},H=class e extends Error{constructor(r,n,o){super(`${r}: Query Engine response status ${n}, body: ${o}`);this.action=r;this.statusCode=n;this.responseBody=o}name="EngineHttpError";static async fromResponse(r){let n=new URL(r.url),o=await r.text();return new e(n.pathname,r.status,o)}}});async function Mt(e){let{output:t,success:r}=(0,w.safeParse)(an,await e.req.json(),{abortEarly:!0});return r?t:e.text("Invalid input",400)}var w,an,Ht=S(()=>{"use strict";u();w=require("valibot"),an=(0,w.object)({tags:(0,w.union)([(0,w.pipe)((0,w.array)((0,w.string)()),(0,w.minLength)(1)),(0,w.literal)("all")])})});async function Wt(e){return Be===void 0&&(Be=await N.Server.create({databaseUrl:e.get("db").connectionString,maxResponseSize:(0,N.parseSize)("128 MiB"),queryTimeout:(0,N.parseDuration)("PT5M"),maxTransactionTimeout:(0,N.parseDuration)("PT5M"),maxTransactionWaitTime:(0,N.parseDuration)("PT5M"),perRequestLogContext:{logFormat:"text",logLevel:e.get("debug")?"debug":"off"}})),Be}var N,de,Be,Gt=S(()=>{"use strict";u();N=require("@prisma/query-plan-executor"),de=require("@prisma/query-plan-executor")});async function $e(e){let r=new TextEncoder().encode(e),n=await crypto.subtle.digest("SHA-256",r);return Array.from(new Uint8Array(n)).map(a=>a.toString(16).padStart(2,"0")).join("")}function jt(e){let t=e.req.param("schemaHash"),r=pe.get(t);return r==null?e.json({EngineNotStarted:{reason:"SchemaMissing"}},404):{schemaHash:t,schemas:r}}async function Ft(e,t,r){let n=Ne.Buffer.from(e,"base64").toString("utf8"),o=(0,me.getSchema)(n),s=o.list.find(d=>d.type==="datasource");if(!s)throw new Error("No datasource block found in schema.");let a=s.assignments.find(d=>d.type==="assignment"&&d.key==="url");a?a.value=`"${t.toString()}"`:s.assignments.push({key:"url",type:"assignment",value:`"${t.toString()}"`});let i=(0,me.printSchema)(o);r&&console.log("[Accelerate] schema with override:",i);let c=await $e(i);return{base64Override:Ne.Buffer.from(i,"utf8").toString("base64"),overrideHash:c}}var Ne,me,pe,qt=S(()=>{"use strict";u();Ne=require("buffer"),me=require("@mrleebo/prisma-ast"),pe=new Map});function ge(e){let{req:t}=e;return{traceparent:t.header("traceparent"),"X-capture-telemetry":t.header("X-capture-telemetry")}}var zt=S(()=>{"use strict";u()});async function Vt(e){let{issues:t,output:r,success:n}=(0,p.safeParse)(cn,await e.req.json(),{abortEarly:!0});return n?r:e.json({EngineNotStarted:{reason:"InvalidRequest",issues:t}},400)}function Kt(e,t){let{output:r,success:n}=(0,p.safeParse)(ln,e);return n?r:t.json({EngineMalfunction:{}},500)}var p,cn,ln,Jt=S(()=>{"use strict";u();p=require("valibot"),cn=(0,p.object)({isolation_level:(0,p.optional)((0,p.string)()),max_wait:(0,p.pipe)((0,p.number)(),(0,p.integer)(),(0,p.minValue)(0)),timeout:(0,p.pipe)((0,p.number)(),(0,p.integer)(),(0,p.minValue)(0))});ln=(0,p.looseObject)({id:(0,p.union)([(0,p.string)(),(0,p.number)()])})});var Yt={};fe(Yt,{accelerateRoute:()=>K});async function Ce(e){let{req:t}=e,r=jt(e);if(r instanceof Response)return r;let{base64Override:n,overrideHash:o}=r.schemas;return await W.get({base64Schema:n,clientVersion:process.env.PRISMA_DEV_FORCE_CLIENT_VERSION||t.param("clientVersion"),debug:e.get("debug"),platform:e.get("platform"),schemaHash:o})}var Qt,Xt,C,K,un,J,dn,mn,Zt=S(()=>{"use strict";u();Qt=require("hono/http-exception"),Xt=require("hono/tiny"),C=require("hono/validator");he();Ht();Le();Gt();qt();zt();Jt();K=new Xt.Hono;K.post("/invalidate",(0,C.validator)("header",$),async e=>{let t=await Mt(e);return t instanceof Response?t:e.body(null)});un="/:clientVersion/:schemaHash",J=K.basePath(un);K.route("/",J);dn=["/graphql","/itx/:transactionId/graphql"];J.on("POST",[...dn],(0,C.validator)("header",$),async e=>{let{req:t}=e;try{let r=await Ce(e);if(r instanceof Response)return r;let n=await t.text(),o=t.param("transactionId"),s=await r.request(n,{...ge(e),"X-transaction-id":o});return e.text(s)}catch(r){return ue(r,e)}});J.basePath("/itx/:transactionId").on("POST",["/commit","/rollback"],(0,C.validator)("header",$),async e=>{let{req:t}=e;try{let r=await Ce(e);if(r instanceof Response)return r;let o=`${t.routePath.split("/").filter(Boolean).at(-1)}Transaction`,s=t.param("transactionId"),a=await r[o](s,ge(e));return e.json(a)}catch(r){return ue(r,e)}});J.put("/schema",(0,C.validator)("header",$),async e=>{let{req:t}=e,r=await t.text();if(!r)return e.text("Missing schema",400);let n=t.param("schemaHash"),o=pe.get(n);if(o==null){if(n!==await $e(r))return e.text("Schema hash mismatch",400);let s=await Ft(r,e.get("db").prismaORMConnectionString,e.get("debug"));return pe.set(n,{base64Original:r,...s}),e.text(n)}return r!==o.base64Original?e.text("Schema mismatch",400):e.text(n)});J.post("/transaction/start",(0,C.validator)("header",$),async e=>{let{req:t}=e,r=await Vt(e);if(r instanceof Response)return r;try{let n=await Ce(e);if(n instanceof Response)return n;let o=await n.startTransaction(r,ge(e)),s=Kt(o,e);if(s instanceof Response)return s;let{id:a}=s,i=t.param("clientVersion"),c=t.param("schemaHash");return e.json({...o,"data-proxy":{endpoint:`${new URL(t.url).origin}/${i}/${c}/itx/${a}`}})}catch(n){return ue(n,e)}});mn=[["/connection-info","GET"],["/query","POST"],["/transaction/start","POST"],["/transaction/:transactionId/commit","POST"],["/transaction/:transactionId/query","POST"],["/transaction/:transactionId/rollback","POST"]];for(let[e,t]of mn)K.on(t,e,(0,C.validator)("header",$),async r=>{let n=r.req.header("prisma-engine-hash");if(n!=="0.0.0"&&n!==de.version)throw new Qt.HTTPException(400,{message:`Using an HTTP connection string is not supported with Prisma Client version ${n} by this version of \`prisma dev\`. Please either use a direct TCP connection string or upgrade your client to version ${de.version}.`});return await(await Wt(r)).fetch(r.req.raw)})});var rr={};fe(rr,{utilityRoute:()=>ke});var er,tr,ke,bo,nr=S(()=>{"use strict";u();er=require("hono/tiny"),tr=require("http-status-codes"),ke=new er.Hono;ke.post("/database/dump",async e=>{let t=e.get("db"),r=e.get("databaseDumpPath");return await t.dump(r),e.json({dumpPath:r},tr.StatusCodes.CREATED)});bo=ke.get("/health",e=>e.json({name:e.get("name")}))});var En={};fe(En,{DEFAULT_DATABASE_PORT:()=>ne,DEFAULT_SERVER_PORT:()=>oe,DEFAULT_SHADOW_DATABASE_PORT:()=>se,PortNotAvailableError:()=>R,ServerAlreadyRunningError:()=>X,copyPrismaDevRuntimeAssets:()=>pt,getPrismaDevRuntimeAssetManifest:()=>Re,startPrismaDevServer:()=>hr,unstable_startServer:()=>Sn});module.exports=Ar(En);u();u();he();u();var _t=require("pathe/utils");te();u();var I=require("get-port-please"),ae=require("remeda"),ne=51214,oe=51213,se=51215,re=65535,M=0,O=-1/0;async function Ee(e){let{debug:t,name:r,requestedPorts:n,servers:o}=e,{portsUsedByOtherServers:s,portsUsedByThisServerLastTime:a}=Cr(r,o);t&&(console.debug(`ports used by other servers: ${Object.keys(s).join(", ")}`),console.debug(`ports used by "${r}" server last time: ${JSON.stringify(a)}`));let i={databasePort:O,port:O,shadowDatabasePort:O},c=["port","databasePort","shadowDatabasePort"];for(let d of c){let l=await Nr({debug:t,portKey:d,portsUsedByOtherServers:s,portsUsedByThisServerLastTime:a,requestedPorts:n})??await $r({debug:t,pickedPorts:i,portKey:d,portsUsedByOtherServers:s,portsUsedByThisServerLastTime:a});t&&console.debug(`Got port for "${d}": ${l}`),i[d]=l}return t&&console.debug(`Picked ports: ${JSON.stringify(i)}`),i}async function Nr(e){let{debug:t,portKey:r,portsUsedByOtherServers:n,portsUsedByThisServerLastTime:o,requestedPorts:s}=e,{[r]:a,...i}=s;if(at(a))return await kr({debug:t,otherRequestedPorts:i,portKey:r,portsUsedByOtherServers:n,requestedPort:a}),a;let c=o?.[r]??O;if(!at(c))return t&&console.debug(`No port specified for "${r}". Trying to pick a new port.`),null;let d=c in n;return d||Object.values(i).includes(c)?(t&&console.debug(`Port ${c} that was used last time for this server, ${d?"is also used by another server":"has been requested for another service"}. Trying to pick a new port.`),null):await(0,I.checkPort)(c)===!1?(t&&console.debug(`Port ${c}, that was used last time for this server, is not available. Trying to pick a new port.`),null):(t&&console.debug(`Using port ${c} for "${r}" as it was used last time and is available.`),c)}async function $r(e){let{debug:t,pickedPorts:r,portKey:n,portsUsedByOtherServers:o,portsUsedByThisServerLastTime:s}=e,a=Math.max(ne,oe,se)+1,i=[...Object.values(r),...Object.keys(o).map(Number),...Object.values(s||{})],c=Math.min(Math.max(a,...i)+100,re),d=(0,ae.difference)((0,ae.range)(a,c),i),l={port:oe,databasePort:ne,shadowDatabasePort:se}[n];try{return await(0,I.getPort)({port:l in o||Object.values(r).includes(l)||Object.values(s||{}).includes(l)?void 0:l,ports:d})}catch(P){if(P instanceof Error&&P.name==="GetPortError"&&c+1<=re)return t&&console.debug(`Expanding port lookup to range [${c+1}, ${re}].`),await(0,I.getPort)({portRange:[c+1,re]});throw P}}function at(e){return Number.isFinite(e)&&e>=0}function Cr(e,t){let r={},n;for(let o of t){let{databasePort:s,port:a,shadowDatabasePort:i}=o;if(o.name===e){n={databasePort:s,port:a,shadowDatabasePort:i};continue}r[s]=!0,r[a]=!0,r[i]=!0}return{portsUsedByOtherServers:r,portsUsedByThisServerLastTime:n}}async function kr(e){let{debug:t,otherRequestedPorts:r,portKey:n,portsUsedByOtherServers:o,requestedPort:s}=e;if(s!==M){if(s in o)throw t&&console.error(`Port ${s} was requested for "${n}", but is already used by another server.`),new Se(s);if(Object.values(r).includes(s))throw t&&console.error(`Port ${s} was requested for "${n}", but also for another key.`),new ve(s);if((0,I.isUnsafePort)(s))throw t&&console.error(`Port ${s} was requested for "${n}", but is unsafe.`),new R(s);if(await(0,I.checkPort)(s)===!1)throw t&&console.error(`Port ${s} was requested for "${n}", but is not available.`),new R(s)}}var R=class extends Error{constructor(r){super(`Port \`${r}\` is not available.`);this.port=r}name="PortNotAvailableError"},ve=class extends Error{constructor(r){super(`Port number \`${r}\` was requested twice. Please choose a different port for each service.`);this.port=r}name="PortRequestedTwiceError"},Se=class extends Error{constructor(r){super(`Port number \`${r}\` belongs to another Prisma Dev server. Please choose a different port.`);this.port=r}name="PortBelongsToAnotherServerError"};u();var q=require("fs"),L=require("fs/promises"),lt=require("module"),ut=require("path"),B=require("url"),Ur=(0,lt.createRequire)(f),Mr=["pglite.data","pglite.wasm"],dt={amcheck:"amcheck.tar.gz",bloom:"bloom.tar.gz",btree_gin:"btree_gin.tar.gz",btree_gist:"btree_gist.tar.gz",citext:"citext.tar.gz",cube:"cube.tar.gz",dict_int:"dict_int.tar.gz",dict_xsyn:"dict_xsyn.tar.gz",earthdistance:"earthdistance.tar.gz",file_fdw:"file_fdw.tar.gz",fuzzystrmatch:"fuzzystrmatch.tar.gz",hstore:"hstore.tar.gz",intarray:"intarray.tar.gz",isn:"isn.tar.gz",lo:"lo.tar.gz",ltree:"ltree.tar.gz",pageinspect:"pageinspect.tar.gz",pg_buffercache:"pg_buffercache.tar.gz",pg_freespacemap:"pg_freespacemap.tar.gz",pg_surgery:"pg_surgery.tar.gz",pg_trgm:"pg_trgm.tar.gz",pg_visibility:"pg_visibility.tar.gz",pg_walinspect:"pg_walinspect.tar.gz",seg:"seg.tar.gz",tablefunc:"tablefunc.tar.gz",tcn:"tcn.tar.gz",tsm_system_rows:"tsm_system_rows.tar.gz",tsm_system_time:"tsm_system_time.tar.gz",unaccent:"unaccent.tar.gz",uuid_ossp:"uuid-ossp.tar.gz",vector:"vector.tar.gz"},mt=[...Mr.map(e=>({fileName:e,kind:"core",name:e})),...Object.entries(dt).map(([e,t])=>({fileName:t,kind:"extension",name:e}))],ce=new Map,Hr=Symbol.for("@prisma/dev/bundled-pglite-runtime-asset-sources"),ie=null;async function pt(e){let t=Ae(e),r=(0,B.fileURLToPath)(t);await(0,L.mkdir)(r,{recursive:!0});let n=[];for(let o of Re()){let s=new URL(o.fileName,t),a=(0,B.fileURLToPath)(s);await(0,L.copyFile)(o.sourcePath,a),n.push({...o,destinationPath:a})}return n}function Re(){let e=gt();return mt.map(t=>({...t,sourcePath:(0,B.fileURLToPath)(new URL(t.fileName,e))}))}async function Te(){await zr();let e=ft();if(e)return await Wr(e);let t=Fr(),r=t.href,n=ce.get(r);return n||(n=Gr(t),ce.set(r,n)),await n}async function Wr(e){let t=`bundled:${e.wasmModule.href}:${e.fsBundle.href}`,r=ce.get(t);return r||(r=jr(e),ce.set(t,r)),await r}async function Gr(e){let[t,r]=await Promise.all([(0,L.readFile)(new URL("pglite.data",e)),(0,L.readFile)(new URL("pglite.wasm",e))]),n=ht();return{extensions:Object.fromEntries(Object.entries(dt).map(([o,s])=>[o,new URL(s,e)])),fsBundle:new Blob([Uint8Array.from(t)]),wasmModule:await n.compile(r)}}async function jr(e){let[t,r]=await Promise.all([ct(e.fsBundle),ct(e.wasmModule)]),n=ht();return{extensions:e.extensions,fsBundle:new Blob([Uint8Array.from(t)]),wasmModule:await n.compile(r)}}function Ae(e){return e instanceof URL?it(e):it((0,B.pathToFileURL)(e))}function it(e){return e.href.endsWith("/")?e:new URL(`${e.href}/`)}function gt(){let e=Ur.resolve("@electric-sql/pglite");return Ae((0,ut.dirname)(e))}function Fr(){let e=Ae(new URL("./",f));if(qr(e))return e;if(Vr())return gt();throw new Error("Unable to locate PGlite runtime assets. If you bundled @prisma/dev, copy them next to the bundle with copyPrismaDevRuntimeAssets().")}function qr(e){return mt.every(t=>(0,q.existsSync)((0,B.fileURLToPath)(new URL(t.fileName,e))))}function ft(){return globalThis[Hr]??null}async function zr(){!Kr()||ft()||(ie||(ie=import("./runtime-assets-manifest.bun.js").then(()=>{}).catch(e=>{throw ie=null,e})),await ie)}function Vr(){let e=(0,B.fileURLToPath)(new URL("../package.json",f));if(!(0,q.existsSync)(e))return!1;try{return JSON.parse((0,q.readFileSync)(e,"utf8")).name==="@prisma/dev"}catch{return!1}}function Kr(){return typeof globalThis.Bun<"u"}function ht(){let e=globalThis.WebAssembly;if(!e)throw new Error("WebAssembly is not available in this runtime.");return e}async function ct(e){if(e.protocol==="file:")return await(0,L.readFile)(e);let t=await fetch(e);if(!t.ok)throw new Error(`Failed to fetch runtime asset ${e.href}: ${t.status} ${t.statusText}`);return new Uint8Array(await t.arrayBuffer())}u();var wt=require("@electric-sql/pglite"),T="_prisma_dev_wal",De="events",vt="install_all_triggers",Pt="capture_event",bt="prisma_dev_wal_capture",z=new WeakMap,Jr=new Set(["ALTER","COMMIT","COPY","CREATE","DELETE","DROP","INSERT","MERGE","TRUNCATE","UPDATE"]);async function xe(e,t){let r=z.get(e);if(r&&!r.closed)return r.bridge;let n=e.execProtocolRaw.bind(e),o={bridge:{close:async()=>{o.closed||(o.closed=!0,o.subscribers.clear(),e.execProtocolRaw===s&&(e.execProtocolRaw=n),await o.pollPromise,z.delete(e))},poll:async()=>{await yt(o,e)},subscribe:a=>(o.subscribers.add(a),()=>{o.subscribers.delete(a)})},closed:!1,ensureInfrastructurePromise:null,pendingPoll:!1,pollPromise:null,subscribers:new Set,suppressDepth:0},s=async(a,i)=>{let c=await n(a,i);return!o.closed&&o.suppressDepth===0&&Rt(c)&&yt(o,e),c};return e.execProtocolRaw=s,z.set(e,o),await Tt(o,e),o.bridge}async function St(e){let t=z.get(e);t&&await t.bridge.close()}function Et(e){for(let t of e){if(t.name!=="commandComplete"||typeof t.text!="string")continue;let r=t.text.split(/\s+/,1)[0]?.toUpperCase();if(r&&Jr.has(r))return!0}return!1}function Rt(e){if(e.length===0)return!1;let t=[];return new wt.protocol.Parser().parse(e,n=>{t.push(n)}),Et(t)}async function Tt(e,t){e.ensureInfrastructurePromise??=_e(e,t,async()=>{await t.exec(`CREATE SCHEMA IF NOT EXISTS "${T}"`),await t.exec(`
+      CREATE TABLE IF NOT EXISTS "${T}"."${De}" (
         id BIGSERIAL PRIMARY KEY,
@@ -14,4 +14,4 @@ txid BIGINT NOT NULL DEFAULT txid_current(),
       )
-    `),await e.exec(`
-      CREATE OR REPLACE FUNCTION "${D}"."${Ze}"()
+    `),await t.exec(`
+      CREATE OR REPLACE FUNCTION "${T}"."${Pt}"()
       RETURNS trigger
@@ -21,7 +21,7 @@ LANGUAGE plpgsql
       BEGIN
-        IF TG_TABLE_SCHEMA = '${D}' THEN
+        IF TG_TABLE_SCHEMA = '${T}' THEN
           RETURN COALESCE(NEW, OLD);
         END IF;
 
-        INSERT INTO "${D}"."${ye}" (
+        INSERT INTO "${T}"."${De}" (
           txid,
@@ -46,4 +46,4 @@ schema_name,
       $$;
-    `),await e.exec(`
-      CREATE OR REPLACE FUNCTION "${D}"."${ot}"()
+    `),await t.exec(`
+      CREATE OR REPLACE FUNCTION "${T}"."${vt}"()
       RETURNS void
@@ -60,3 +60,3 @@ LANGUAGE plpgsql
           WHERE c.relkind IN ('r', 'p')
-            AND n.nspname NOT IN ('${D}', 'information_schema', 'pg_catalog')
+            AND n.nspname NOT IN ('${T}', 'information_schema', 'pg_catalog')
             AND n.nspname NOT LIKE 'pg_temp_%'
@@ -69,3 +69,3 @@ AND n.nspname NOT LIKE 'pg_toast%'
             WHERE tgrelid = target
-              AND tgname = '${et}'
+              AND tgname = '${bt}'
           ) THEN
@@ -76,4 +76,4 @@ CONTINUE;
           EXECUTE format(
-            'CREATE TRIGGER %I AFTER INSERT OR UPDATE OR DELETE ON %s FOR EACH ROW EXECUTE FUNCTION "${D}"."${Ze}"()',
-            '${et}',
+            'CREATE TRIGGER %I AFTER INSERT OR UPDATE OR DELETE ON %s FOR EACH ROW EXECUTE FUNCTION "${T}"."${Pt}"()',
+            '${bt}',
             target::text
@@ -84,5 +84,5 @@ );
       $$;
-    `),await ct(t,e)}),await t.ensureInfrastructurePromise}async function ct(t,e){await we(t,e,async()=>{await e.query(`SELECT "${D}"."${ot}"()`)})}async function wr(t,e){await it(t,e),await ct(t,e);let r=await we(t,e,async()=>await e.query(`
+    `),await At(e,t)}),await e.ensureInfrastructurePromise}async function At(e,t){await _e(e,t,async()=>{await t.query(`SELECT "${T}"."${vt}"()`)})}async function Qr(e,t){await Tt(e,t),await At(e,t);let r=await _e(e,t,async()=>await t.query(`
       WITH drained AS (
-        DELETE FROM "${D}"."${ye}"
+        DELETE FROM "${T}"."${De}"
         RETURNING txid, schema_name, table_name, op, row_data, old_row_data, id
@@ -93,4 +93,4 @@ )
       ORDER BY id
-    `));if(r.rows.length===0||t.subscribers.size===0)return;let n=r.rows.map(Sr);for(let o of t.subscribers)queueMicrotask(()=>{if(!t.closed&&t.subscribers.has(o))try{o(n)}catch(s){console.error("[WAL bridge] subscriber failed",s)}})}async function tt(t,e){if(!t.closed){if(t.pollPromise){t.pendingPoll=!0,await t.pollPromise;return}t.pollPromise=(async()=>{do t.pendingPoll=!1,await wr(t,e);while(t.pendingPoll&&!t.closed)})().finally(()=>{t.pollPromise=null}),await t.pollPromise}}async function we(t,e,r){t.suppressDepth+=1;try{return await r()}finally{t.suppressDepth-=1,t.suppressDepth===0&&!t.closed&&F.get(e)!==t&&(t.closed=!0)}}function Sr(t){return{oldRecord:t.old_row_data,record:t.row_data,schema:t.schema_name,table:t.table_name,txid:String(t.txid),type:Er(t.op)}}function Er(t){switch(t.toLowerCase()){case"delete":return"delete";case"insert":return"insert";case"update":return"update";default:throw new Error(`Unsupported WAL bridge operation: ${t}`)}}var Tr=10,y={connectionLimit:Tr,connectTimeout:0,database:"template1",maxIdleConnectionLifetime:0,password:"postgres",poolTimeout:0,socketTimeout:0,sslMode:"disable",username:"postgres"},Dr=`postgres://${y.username}:${y.password}@localhost`,pt=new URLSearchParams({sslmode:y.sslMode}),Rr=new URLSearchParams({...Object.fromEntries(pt.entries()),connection_limit:String(y.connectionLimit),connect_timeout:String(y.connectTimeout),max_idle_connection_lifetime:String(y.maxIdleConnectionLifetime),pool_timeout:String(y.poolTimeout),socket_timeout:String(y.socketTimeout)});async function Se(t,e){let r=t==="database"?e.databasePort:e.shadowDatabasePort;if(e.dryRun)return lt(t,e,{db:null,port:r,server:null});let{debug:n}=e,s=await(t==="shadow_database"?xr:mt)(e.pgliteDataDirPath,n);n&&s.onNotification((l,P)=>{console.debug(`[${t}][${l}] ${P}`)});let{PGLiteSocketServer:a}=await import("@electric-sql/pglite-socket"),i=t==="shadow_database"?e.shadowDatabaseIdleTimeoutMillis:e.databaseIdleTimeoutMillis,c=new a({db:s,debug:n,idleTimeout:Number.isFinite(i)?i:0,inspect:n,maxConnections:y.connectionLimit,port:r});n&&(c.addEventListener("listening",l=>{let{detail:P}=l;console.debug(`[${t}] server listening on ${JSON.stringify(P)}`)}),c.addEventListener("connection",l=>{let{clientAddress:P,clientPort:E}=l.detail;console.debug(`[${t}] client connected from ${P}:${E}`)}),c.addEventListener("error",l=>{let{detail:P}=l;console.error(`[${t}] server error:`,P)}));try{await c.start()}catch(l){throw l instanceof Error&&"code"in l&&l.code==="EADDRINUSE"?new T(r):l}let d=Number(c.getServerConn().split(":").at(1));return e[t==="database"?"databasePort":"shadowDatabasePort"]=d,lt(t,e,{db:s,port:d,server:c})}function lt(t,e,r){let{debug:n}=e,{db:o,port:s,server:a}=r||{};return n&&console.debug(`[${t}] server started on port ${s}`),{...y,attachWalEventBridge:async()=>{if(t!=="database"||!o)throw new Error("WAL bridge is only available for the primary database server");return await ve(o)},close:async()=>{let i=[];try{await a?.stop(),n&&console.debug(`[${t}] server stopped on port ${s}`)}catch(c){console.error(`[${t}] server stop error`,c),i.push(c)}if(t==="database"){try{o&&await nt(o),n&&console.debug(`[${t}] closed WAL bridge`)}catch(c){console.error(`[${t}] WAL bridge close error`,c),i.push(c)}try{await o?.syncToFs(),n&&console.debug(`[${t}] synced to filesystem`)}catch(c){console.error(`[${t}] sync error`,c),i.push(c)}}try{await o?.close(),n&&console.debug(`[${t}] closed`)}catch(c){console.error(`[${t}] close error`,c),i.push(c)}if(i.length>0)throw new AggregateError(i,`Failed to close ${t} properly`)},connectionString:ut(s,pt),dump:async i=>{t==="shadow_database"||!o||await Ar({db:o,debug:n,destinationPath:i})},port:s,prismaORMConnectionString:ut(s,Rr),terminalCommand:`PGPASSWORD=${y.password} PGSSLMODE=${y.sslMode} psql -h localhost -p ${s} -U ${y.username} -d ${y.database}`}}function ut(t,e){return`${Dr}:${t}/${y.database}?${e.toString()}`}async function mt(t,e){let{PGlite:r}=await import("@electric-sql/pglite");return await r.create({database:y.database,dataDir:t,debug:e?5:void 0,extensions:await gt(),relaxedDurability:!1,username:y.username})}async function xr(t,e){let{PGlite:r}=await import("@electric-sql/pglite");return await r.create({database:y.database,dataDir:"memory://",debug:e?5:void 0,extensions:await gt(),relaxedDurability:!1,username:y.username})}async function gt(){let t=await Promise.all([import("@electric-sql/pglite/contrib/amcheck"),import("@electric-sql/pglite/contrib/bloom"),import("@electric-sql/pglite/contrib/btree_gin"),import("@electric-sql/pglite/contrib/btree_gist"),import("@electric-sql/pglite/contrib/citext"),import("@electric-sql/pglite/contrib/cube"),import("@electric-sql/pglite/contrib/dict_int"),import("@electric-sql/pglite/contrib/dict_xsyn"),import("@electric-sql/pglite/contrib/earthdistance"),import("@electric-sql/pglite/contrib/file_fdw"),import("@electric-sql/pglite/contrib/fuzzystrmatch"),import("@electric-sql/pglite/contrib/hstore"),import("@electric-sql/pglite/contrib/intarray"),import("@electric-sql/pglite/contrib/isn"),import("@electric-sql/pglite/contrib/lo"),import("@electric-sql/pglite/contrib/ltree"),import("@electric-sql/pglite/contrib/pageinspect"),import("@electric-sql/pglite/contrib/pg_buffercache"),import("@electric-sql/pglite/contrib/pg_freespacemap"),import("@electric-sql/pglite/contrib/pg_surgery"),import("@electric-sql/pglite/contrib/pg_trgm"),import("@electric-sql/pglite/contrib/pg_visibility"),import("@electric-sql/pglite/contrib/pg_walinspect"),import("@electric-sql/pglite/contrib/seg"),import("@electric-sql/pglite/contrib/tablefunc"),import("@electric-sql/pglite/contrib/tcn"),import("@electric-sql/pglite/contrib/tsm_system_rows"),import("@electric-sql/pglite/contrib/tsm_system_time"),import("@electric-sql/pglite/contrib/unaccent"),import("@electric-sql/pglite/contrib/uuid_ossp"),import("@electric-sql/pglite/vector")]);return Object.assign({},...t)}async function Ar(t){let{dataDir:e,db:r,debug:n,destinationPath:o}=t,s=r||await mt(e,n),{pgDump:a}=await import("@electric-sql/pglite-tools/pg_dump"),i=await a({args:["--schema-only","--no-owner"],fileName:o?(0,dt.filename)(o):void 0,pg:await s.clone()});return o?(n&&console.debug(`[DB] Dumping database to ${o}`),await Qe(i,o)):(n&&console.debug("[DB] Dumping database to memory"),await i.text())}p();var jt=require("http"),Ft=require("util"),Gt=u(require("@prisma/get-platform"),1);Ee();Te();async function qt(t,e){let{port:r}=e;if(e.dryRun)return Wt(r,null);let n=await kr(t,e),{promise:o,reject:s,resolve:a}=ne(),{serve:i}=await import("@hono/node-server"),c=i({createServer:jt.createServer,fetch:n.fetch,overrideGlobalObjects:!1,port:r},a);c.on("error",l=>{if(typeof l=="object"&&"code"in l&&l.code==="EADDRINUSE")return s(new T(r));console.error("[Accelerate]",l)});let{port:d}=await o;return e.port=d,Wt(d,c)}function Wt(t,e){return{async close(){e&&await Promise.allSettled([(0,Ft.promisify)(e.close.bind(e))(),H.stopAll()])},port:t,url:`http://localhost:${t}`}}async function kr(t,e){let{debug:r}=e,[{Hono:n},{accelerateRoute:o},{utilityRoute:s}]=await Promise.all([import("hono/tiny"),Promise.resolve().then(()=>(Bt(),Lt)),Promise.resolve().then(()=>(Ut(),Ht))]),a=new n,i=await Gt.default.getPlatformInfo();if(r&&console.debug("[Accelerate] platform info: %s",JSON.stringify(i)),r){let{logger:d}=await import("hono/logger");a.use("*",d((...l)=>console.log("[Accelerate]",...l)))}a.use("*",async(d,l)=>(d.set("databaseDumpPath",e.databaseDumpPath),d.set("db",t),d.set("debug",!!r),d.set("name",e.name),d.set("platform",i),d.set("shadowDBPort",e.shadowDatabasePort),await l()));let c=new n;return c.route("/",o),c.route("/",s),a.route("/",c),a}p();var Xt=require("fs/promises"),L=require("pathe"),U=require("proper-lockfile"),Le=require("std-env"),m=require("valibot");Y();p();var Mr=require("timers/promises"),Vt=require("std-env");function Kt(t,e){if(t==null)return!1;try{return Vt.process.kill?.(t,0)??!0}catch(r){return e&&console.error(`Error checking if process with PID ${t} exists:`,r),!1}}var $e=(0,m.pipe)((0,m.string)(),(0,m.url)()),Qt=(0,m.object)({connectionString:$e,prismaORMConnectionString:(0,m.optional)($e),terminalCommand:(0,m.optional)((0,m.string)())}),Jt=(0,m.object)({url:$e}),_e=(0,m.pipe)((0,m.number)(),(0,m.integer)(),(0,m.minValue)(1)),Hr=(0,m.object)({database:Qt,http:Jt,ppg:Jt,shadowDatabase:Qt}),Ur=(0,m.object)({databasePort:_e,exports:(0,m.optional)(Hr),name:(0,m.pipe)((0,m.string)(),(0,m.minLength)(1)),pid:(0,m.optional)((0,m.pipe)((0,m.number)(),(0,m.integer)(),(0,m.minValue)(0))),port:_e,shadowDatabasePort:_e,version:(0,m.literal)("1")}),Be=Symbol("initialize"),Ie="default",R=class{_databasePort;databaseConnectTimeoutMillis;databaseIdleTimeoutMillis;debug;dryRun;name;persistenceMode;pid;shadowDatabaseConnectTimeoutMillis;shadowDatabaseIdleTimeoutMillis;_port;_shadowDatabasePort;constructor(e){this._databasePort=e.databasePort??_,this.databaseConnectTimeoutMillis=e.databaseConnectTimeoutMillis??6e4,this.databaseIdleTimeoutMillis=e.databaseIdleTimeoutMillis??1/0,this.debug=e.debug??!1,this.dryRun=e.dryRun??!1,this.name=e.name??Ie,this.persistenceMode=e.persistenceMode,this.pid=e.pid??Le.process.pid,this.shadowDatabaseConnectTimeoutMillis=e.shadowDatabaseConnectTimeoutMillis??this.databaseConnectTimeoutMillis,this.shadowDatabaseIdleTimeoutMillis=e.shadowDatabaseIdleTimeoutMillis??this.databaseIdleTimeoutMillis,this._port=e.port??_,this._shadowDatabasePort=e.shadowDatabasePort??_}static async createExclusively(e){let r=e?.dryRun!==!0&&e?.persistenceMode==="stateful"?new K(e):new Ne(e);return await r[Be](),r}static async fromServerDump(e){let{debug:r,name:n=Ie}=e??{},o=j(n),s=K.getServerDumpPath(o),a=await Je(s);if(a==null)return r&&console.debug(`[State] No server dump file found at: ${s}`),null;r&&(console.debug(`[State] server dump file found at "${s}":`),console.debug(a));let{issues:i,output:c,success:d}=(0,m.safeParse)((0,m.pipe)((0,m.string)(),(0,m.parseJson)(),Ur),a);if(!d)throw r&&console.debug(`[State] Invalid server dump file at "${s}":
-${JSON.stringify(i,null,2)}`),new Error(`Invalid Prisma Dev state for "${n}".`);return new K({databasePort:c.databasePort,debug:r,dryRun:!1,name:n,pid:c.pid,port:c.port,serverDump:c,shadowDatabasePort:c.shadowDatabasePort})}static async scan(e){let{debug:r,globs:n}=e??{},o=(0,L.join)(j(Ie),"..");r&&console.debug(`[State] scanning for server states in: ${o}`);let s=await ze(o,n);return r&&console.debug(`[State] found server names: ${JSON.stringify(s)}`),await Promise.all(s.map(a=>Wr(a,e)))}get databasePort(){return this._databasePort}set databasePort(e){this.#t("databasePort",e)}get port(){return this._port}set port(e){this.#t("port",e)}get shadowDatabasePort(){return this._shadowDatabasePort}set shadowDatabasePort(e){this.#t("shadowDatabasePort",e)}#t(e,r){if(r<0||!Number.isInteger(r))throw new Error(`Invalid port number: ${r}`);let n=`_${e}`;if(this[n]!==k&&this[n]!==r)throw new Error(`\`${e}\` is already set to ${this[n]}, cannot change it to ${r}`);this[n]=r}},Ne=class extends R{constructor(e){super({...e,databasePort:e?.databasePort||k,persistenceMode:"stateless",port:e?.port||k,shadowDatabasePort:e?.shadowDatabasePort||k})}get databaseDumpPath(){return"<DUMP_PATH>"}get pgliteDataDirPath(){return"memory://"}async[Be](){let e;try{e=await R.scan({debug:this.debug,onlyMetadata:!0})}catch(n){this.debug&&console.warn("[State] failed to scan for existing servers, assuming filesystem does not exist or other reasons.",n),e=[]}let r=await be({debug:this.debug,name:this.dryRun?this.name:"",requestedPorts:{databasePort:this.databasePort,port:this.port,shadowDatabasePort:this.shadowDatabasePort},servers:e});this._databasePort=r.databasePort,this._port=r.port,this._shadowDatabasePort=r.shadowDatabasePort}async close(){}async writeServerDump(){}},K=class t extends R{#t;#e;#r;#s;#a;#n;#o;constructor(e){super({...e,persistenceMode:"stateful"}),this.#n=!1,this.#e=j(this.name),this.#t=(0,L.join)(this.#e,"db_dump.bak"),this.#r=(0,L.join)(this.#e,".lock"),this.#s=(0,L.join)(this.#e,".pglite"),this.#o=e?.serverDump??null,this.#a=t.getServerDumpPath(this.#e)}static getServerDumpPath(e){return(0,L.join)(e,"server.json")}get databaseDumpPath(){return this.#t}get exports(){return this.#o?.exports}get pgliteDataDirPath(){return this.#s}async[Be](){await Xe(this.#e),this.debug&&console.debug(`[State] using data directory: ${this.#e}`);try{await(0,U.lock)(this.#e,{lockfilePath:this.#r}),this.debug&&console.debug(`[State] obtained lock on: ${this.#e}`);let e=await R.scan({debug:this.debug,onlyMetadata:!0}),r=await be({debug:this.debug,name:this.name,requestedPorts:{databasePort:this.databasePort,port:this.port,shadowDatabasePort:this.shadowDatabasePort},servers:e});this._databasePort=r.databasePort,this._port=r.port,this._shadowDatabasePort=r.shadowDatabasePort,await this.writeServerDump()}catch(e){throw e instanceof Error&&"code"in e&&e.code==="ELOCKED"?new Q(this):e}}async close(){if(!this.#n)try{await(0,U.unlock)(this.#e,{lockfilePath:this.#r}),this.#n=!0,this.debug&&console.debug(`[State] released lock on: ${this.#e}`)}catch(e){throw this.debug&&console.error(`[State] failed to release lock on: ${this.#e}`,e),e}}async writeServerDump(e){this.#o={name:this.name,version:"1",pid:Le.process.pid,port:this.port,databasePort:this.databasePort,shadowDatabasePort:this.shadowDatabasePort,exports:e},await(0,Xt.writeFile)(this.#a,`${JSON.stringify(this.#o,null,2)}
-`,{encoding:"utf-8"})}};async function Wr(t,e){let{debug:r,onlyMetadata:n}=e||{},o=typeof t=="string"?t:t.name,s=typeof t!="string"?t:void 0,a={databasePort:s?.databasePort??-1,exports:s?.exports,name:o,pid:s?.pid,port:s?.port??-1,shadowDatabasePort:s?.shadowDatabasePort??-1,version:"1"};try{let i=s||await R.fromServerDump({debug:r,name:o});if(!i)return r&&console.debug(`[State] no server state found for name: ${o}`),{...a,status:"no_such_server"};a.databasePort=i.databasePort,a.exports=i.exports,a.pid=i.pid,a.port=i.port,a.shadowDatabasePort=i.shadowDatabasePort;let{exports:c,pid:d}=i;if(n)return{...a,status:"unknown"};if(!Kt(d,r))return r&&console.debug(`[State] server state for "${o}" has no running process with PID: ${d}`),{...a,status:"not_running"};let l=j(o);try{if(!await(0,U.check)(l,{lockfilePath:(0,L.join)(l,".lock")}))return r&&console.debug(`[State] server state for "${o}" is not locked, indicating it is not running.`),{...a,status:"starting_up"}}catch(W){r&&console.error(`[State] server state for "${o}" failed to check lock:`,W)}if(!c)return{...a,status:"starting_up"};let{http:P}=c,{hc:E}=await import("hono/client"),x=await E(P.url).health.$get();if(!x.ok)return r&&console.debug(`[State] server state for "${o}" is not live: ${JSON.stringify(x)}`),{...a,status:"not_running"};let A=await x.json();return A.name!==t?(r&&console.debug(`[State] server state for "${o}" has mismatched health response: ${JSON.stringify(A)}`),{...a,status:"unknown"}):(r&&console.debug(`[State] server state for "${t}" is live: ${JSON.stringify(A)}`),{...a,status:"running"})}catch(i){return r&&console.error(`[State] failed to get server status for "${o}":`,i),{...a,status:"error"}}}var Ce=class extends Error{name="ServerStateAlreadyExistsError";constructor(e){super(`A Prisma Dev server with the name "${e}" is already running.`)}},Q=class extends Ce{#t;name="ServerAlreadyRunningError";constructor(e){super(e.name),this.#t=e}get server(){return R.fromServerDump({debug:this.#t.debug,name:this.#t.name})}};async function zt(t){let e=await R.createExclusively(t),r=null,n=null,o=null;try{[r,o]=await Promise.all([Se("database",e),Se("shadow_database",e)]);let s=await r.attachWalEventBridge();n=await qt(r,e);let a=jr(r,o,n,e);await e.writeServerDump(a);let i=Gr(s),c=r,d=o,l=n,P=async()=>{i.close(),await Yt(e,[l,c,d])};return{close:P,dbServer:r,httpServer:n,server:{...a,close:P,experimental:{wal:i.api},name:e.name},serverState:e,shadowDbServer:o,walBridge:s}}catch(s){return await Fr(e,[n,r,o],s)}}function jr(t,e,r,n){let o=`prisma+postgres://localhost:${r.port}/?${new URLSearchParams({api_key:He({databaseUrl:t.prismaORMConnectionString,name:n.name,shadowDatabaseUrl:e.prismaORMConnectionString})}).toString()}`;return{database:{connectionString:t.connectionString,prismaORMConnectionString:t.prismaORMConnectionString,terminalCommand:t.terminalCommand},http:{url:r.url},ppg:{url:o},shadowDatabase:{connectionString:e.prismaORMConnectionString,prismaORMConnectionString:e.prismaORMConnectionString,terminalCommand:e.terminalCommand}}}async function Yt(t,e){let n=(await Promise.allSettled(e.map(o=>o.close()))).filter(o=>o.status==="rejected").map(o=>new Error(o.reason));try{await t.close()}catch(o){n.push(o)}if(n.length>0)throw new AggregateError(n,"Failed to close some servers")}async function Fr(t,e,r){try{await Yt(t,e.filter(n=>n!==null))}catch(n){throw new AggregateError([r,n],"Failed to start Prisma Dev server cleanly")}throw r}function Gr(t){let e=new Set;return{api:{stream:()=>{let r=()=>{},n=qr(t,()=>{e.delete(r)});return r=()=>n.close(),e.add(r),n.stream},subscribe:r=>t.subscribe(r)},close:()=>{for(let r of[...e])r();e.clear()}}}function qr(t,e){let r=[],n=!1,o=null,s=t.subscribe(i=>{if(!n){if(o){let c=o;o=null,c.resolve({done:!1,value:i});return}r.push(i)}}),a=()=>{if(!n&&(n=!0,s(),r.length=0,e(),o)){let i=o;o=null,i.resolve({done:!0,value:void 0})}};return{close:a,stream:{[Symbol.asyncIterator](){return this},next(){return r.length>0?Promise.resolve({done:!1,value:r.shift()}):n?Promise.resolve({done:!0,value:void 0}):new Promise((i,c)=>{o={reject:c,resolve:i}})},return(){return a(),Promise.resolve({done:!0,value:void 0})},throw(i){let c=o;return a(),c&&c.reject(i),Promise.reject(i instanceof Error?i:new Error(String(i)))}}}}async function Zt(t){let{server:e}=await zt(t);return e}async function Vr(t){return await Zt(t)}0&&(module.exports={DEFAULT_DATABASE_PORT,DEFAULT_SERVER_PORT,DEFAULT_SHADOW_DATABASE_PORT,PortNotAvailableError,ServerAlreadyRunningError,startPrismaDevServer,unstable_startServer});
+    `));if(r.rows.length===0||e.subscribers.size===0)return;let n=r.rows.map(Xr);for(let o of e.subscribers)queueMicrotask(()=>{if(!e.closed&&e.subscribers.has(o))try{o(n)}catch(s){console.error("[WAL bridge] subscriber failed",s)}})}async function yt(e,t){if(!e.closed){if(e.pollPromise){e.pendingPoll=!0,await e.pollPromise;return}e.pollPromise=(async()=>{do e.pendingPoll=!1,await Qr(e,t);while(e.pendingPoll&&!e.closed)})().finally(()=>{e.pollPromise=null}),await e.pollPromise}}async function _e(e,t,r){e.suppressDepth+=1;try{return await r()}finally{e.suppressDepth-=1,e.suppressDepth===0&&!e.closed&&z.get(t)!==e&&(e.closed=!0)}}function Xr(e){return{oldRecord:e.old_row_data,record:e.row_data,schema:e.schema_name,table:e.table_name,txid:String(e.txid),type:Yr(e.op)}}function Yr(e){switch(e.toLowerCase()){case"delete":return"delete";case"insert":return"insert";case"update":return"update";default:throw new Error(`Unsupported WAL bridge operation: ${e}`)}}var Zr=10,b={connectionLimit:Zr,connectTimeout:0,database:"template1",maxIdleConnectionLifetime:0,password:"postgres",poolTimeout:0,socketTimeout:0,sslMode:"disable",username:"postgres"},en=`postgres://${b.username}:${b.password}@localhost`,Ot=new URLSearchParams({sslmode:b.sslMode}),tn=new URLSearchParams({...Object.fromEntries(Ot.entries()),connection_limit:String(b.connectionLimit),connect_timeout:String(b.connectTimeout),max_idle_connection_lifetime:String(b.maxIdleConnectionLifetime),pool_timeout:String(b.poolTimeout),socket_timeout:String(b.socketTimeout)});async function Oe(e,t){let r=e==="database"?t.databasePort:t.shadowDatabasePort;if(t.dryRun)return Dt(e,t,{db:null,port:r,server:null});let{debug:n}=t,s=await(e==="shadow_database"?rn:It)(t.pgliteDataDirPath,n);n&&s.onNotification((l,P)=>{console.debug(`[${e}][${l}] ${P}`)});let{PGLiteSocketServer:a}=await import("@electric-sql/pglite-socket"),i=e==="shadow_database"?t.shadowDatabaseIdleTimeoutMillis:t.databaseIdleTimeoutMillis,c=new a({db:s,debug:n,idleTimeout:Number.isFinite(i)?i:0,inspect:n,maxConnections:b.connectionLimit,port:r});n&&(c.addEventListener("listening",l=>{let{detail:P}=l;console.debug(`[${e}] server listening on ${JSON.stringify(P)}`)}),c.addEventListener("connection",l=>{let{clientAddress:P,clientPort:E}=l.detail;console.debug(`[${e}] client connected from ${P}:${E}`)}),c.addEventListener("error",l=>{let{detail:P}=l;console.error(`[${e}] server error:`,P)}));try{await c.start()}catch(l){throw l instanceof Error&&"code"in l&&l.code==="EADDRINUSE"?new R(r):l}let d=Number(c.getServerConn().split(":").at(1));return t[e==="database"?"databasePort":"shadowDatabasePort"]=d,Dt(e,t,{db:s,port:d,server:c})}function Dt(e,t,r){let{debug:n}=t,{db:o,port:s,server:a}=r||{};return n&&console.debug(`[${e}] server started on port ${s}`),{...b,attachWalEventBridge:async()=>{if(e!=="database"||!o)throw new Error("WAL bridge is only available for the primary database server");return await xe(o)},close:async()=>{let i=[];try{await a?.stop(),n&&console.debug(`[${e}] server stopped on port ${s}`)}catch(c){console.error(`[${e}] server stop error`,c),i.push(c)}if(e==="database"){try{o&&await St(o),n&&console.debug(`[${e}] closed WAL bridge`)}catch(c){console.error(`[${e}] WAL bridge close error`,c),i.push(c)}try{await o?.syncToFs(),n&&console.debug(`[${e}] synced to filesystem`)}catch(c){console.error(`[${e}] sync error`,c),i.push(c)}}try{await o?.close(),n&&console.debug(`[${e}] closed`)}catch(c){console.error(`[${e}] close error`,c),i.push(c)}if(i.length>0)throw new AggregateError(i,`Failed to close ${e} properly`)},connectionString:xt(s,Ot),dump:async i=>{e==="shadow_database"||!o||await nn({db:o,debug:n,destinationPath:i})},port:s,prismaORMConnectionString:xt(s,tn),terminalCommand:`PGPASSWORD=${b.password} PGSSLMODE=${b.sslMode} psql -h localhost -p ${s} -U ${b.username} -d ${b.database}`}}function xt(e,t){return`${en}:${e}/${b.database}?${t.toString()}`}async function It(e,t){let{PGlite:r}=await import("@electric-sql/pglite"),n=await Te();return await r.create({database:b.database,dataDir:e,debug:t?5:void 0,extensions:n.extensions,fsBundle:n.fsBundle,relaxedDurability:!1,wasmModule:n.wasmModule,username:b.username})}async function rn(e,t){let{PGlite:r}=await import("@electric-sql/pglite"),n=await Te();return await r.create({database:b.database,dataDir:"memory://",debug:t?5:void 0,extensions:n.extensions,fsBundle:n.fsBundle,relaxedDurability:!1,wasmModule:n.wasmModule,username:b.username})}async function nn(e){let{dataDir:t,db:r,debug:n,destinationPath:o}=e,s=r||await It(t,n),{pgDump:a}=await import("@electric-sql/pglite-tools/pg_dump"),i=await a({args:["--schema-only","--no-owner"],fileName:o?(0,_t.filename)(o):void 0,pg:await s.clone()});return o?(n&&console.debug(`[DB] Dumping database to ${o}`),await rt(i,o)):(n&&console.debug("[DB] Dumping database to memory"),await i.text())}u();var sr=require("http"),ar=require("util"),ir=y(require("@prisma/get-platform"),1);Ie();Le();async function cr(e,t){let{port:r}=t;if(t.dryRun)return or(r,null);let n=await pn(e,t),{promise:o,reject:s,resolve:a}=le(),{serve:i}=await import("@hono/node-server"),c=i({createServer:sr.createServer,fetch:n.fetch,overrideGlobalObjects:!1,port:r},a);c.on("error",l=>{if(typeof l=="object"&&"code"in l&&l.code==="EADDRINUSE")return s(new R(r));console.error("[Accelerate]",l)});let{port:d}=await o;return t.port=d,or(d,c)}function or(e,t){return{async close(){t&&await Promise.allSettled([(0,ar.promisify)(t.close.bind(t))(),W.stopAll()])},port:e,url:`http://localhost:${e}`}}async function pn(e,t){let{debug:r}=t,[{Hono:n},{accelerateRoute:o},{utilityRoute:s}]=await Promise.all([import("hono/tiny"),Promise.resolve().then(()=>(Zt(),Yt)),Promise.resolve().then(()=>(nr(),rr))]),a=new n,i=await ir.default.getPlatformInfo();if(r&&console.debug("[Accelerate] platform info: %s",JSON.stringify(i)),r){let{logger:d}=await import("hono/logger");a.use("*",d((...l)=>console.log("[Accelerate]",...l)))}a.use("*",async(d,l)=>(d.set("databaseDumpPath",t.databaseDumpPath),d.set("db",e),d.set("debug",!!r),d.set("name",t.name),d.set("platform",i),d.set("shadowDBPort",t.shadowDatabasePort),await l()));let c=new n;return c.route("/",o),c.route("/",s),a.route("/",c),a}u();var pr=require("fs/promises"),k=require("pathe"),G=require("proper-lockfile"),je=require("std-env"),m=require("valibot");te();u();var gn=require("timers/promises"),lr=require("std-env");function ur(e,t){if(e==null)return!1;try{return lr.process.kill?.(e,0)??!0}catch(r){return t&&console.error(`Error checking if process with PID ${e} exists:`,r),!1}}var He=(0,m.pipe)((0,m.string)(),(0,m.url)()),dr=(0,m.object)({connectionString:He,prismaORMConnectionString:(0,m.optional)(He),terminalCommand:(0,m.optional)((0,m.string)())}),mr=(0,m.object)({url:He}),Ue=(0,m.pipe)((0,m.number)(),(0,m.integer)(),(0,m.minValue)(1)),fn=(0,m.object)({database:dr,http:mr,ppg:mr,shadowDatabase:dr}),hn=(0,m.object)({databasePort:Ue,exports:(0,m.optional)(fn),name:(0,m.pipe)((0,m.string)(),(0,m.minLength)(1)),pid:(0,m.optional)((0,m.pipe)((0,m.number)(),(0,m.integer)(),(0,m.minValue)(0))),port:Ue,shadowDatabasePort:Ue,version:(0,m.literal)("1")}),Fe=Symbol("initialize"),Me="default",A=class{_databasePort;databaseConnectTimeoutMillis;databaseIdleTimeoutMillis;debug;dryRun;name;persistenceMode;pid;shadowDatabaseConnectTimeoutMillis;shadowDatabaseIdleTimeoutMillis;_port;_shadowDatabasePort;constructor(t){this._databasePort=t.databasePort??O,this.databaseConnectTimeoutMillis=t.databaseConnectTimeoutMillis??6e4,this.databaseIdleTimeoutMillis=t.databaseIdleTimeoutMillis??1/0,this.debug=t.debug??!1,this.dryRun=t.dryRun??!1,this.name=t.name??Me,this.persistenceMode=t.persistenceMode,this.pid=t.pid??je.process.pid,this.shadowDatabaseConnectTimeoutMillis=t.shadowDatabaseConnectTimeoutMillis??this.databaseConnectTimeoutMillis,this.shadowDatabaseIdleTimeoutMillis=t.shadowDatabaseIdleTimeoutMillis??this.databaseIdleTimeoutMillis,this._port=t.port??O,this._shadowDatabasePort=t.shadowDatabasePort??O}static async createExclusively(t){let r=t?.dryRun!==!0&&t?.persistenceMode==="stateful"?new Q(t):new We(t);return await r[Fe](),r}static async fromServerDump(t){let{debug:r,name:n=Me}=t??{},o=F(n),s=Q.getServerDumpPath(o),a=await nt(s);if(a==null)return r&&console.debug(`[State] No server dump file found at: ${s}`),null;r&&(console.debug(`[State] server dump file found at "${s}":`),console.debug(a));let{issues:i,output:c,success:d}=(0,m.safeParse)((0,m.pipe)((0,m.string)(),(0,m.parseJson)(),hn),a);if(!d)throw r&&console.debug(`[State] Invalid server dump file at "${s}":
+${JSON.stringify(i,null,2)}`),new Error(`Invalid Prisma Dev state for "${n}".`);return new Q({databasePort:c.databasePort,debug:r,dryRun:!1,name:n,pid:c.pid,port:c.port,serverDump:c,shadowDatabasePort:c.shadowDatabasePort})}static async scan(t){let{debug:r,globs:n}=t??{},o=(0,k.join)(F(Me),"..");r&&console.debug(`[State] scanning for server states in: ${o}`);let s=await st(o,n);return r&&console.debug(`[State] found server names: ${JSON.stringify(s)}`),await Promise.all(s.map(a=>Pn(a,t)))}get databasePort(){return this._databasePort}set databasePort(t){this.#t("databasePort",t)}get port(){return this._port}set port(t){this.#t("port",t)}get shadowDatabasePort(){return this._shadowDatabasePort}set shadowDatabasePort(t){this.#t("shadowDatabasePort",t)}#t(t,r){if(r<0||!Number.isInteger(r))throw new Error(`Invalid port number: ${r}`);let n=`_${t}`;if(this[n]!==M&&this[n]!==r)throw new Error(`\`${t}\` is already set to ${this[n]}, cannot change it to ${r}`);this[n]=r}},We=class extends A{constructor(t){super({...t,databasePort:t?.databasePort||M,persistenceMode:"stateless",port:t?.port||M,shadowDatabasePort:t?.shadowDatabasePort||M})}get databaseDumpPath(){return"<DUMP_PATH>"}get pgliteDataDirPath(){return"memory://"}async[Fe](){let t;try{t=await A.scan({debug:this.debug,onlyMetadata:!0})}catch(n){this.debug&&console.warn("[State] failed to scan for existing servers, assuming filesystem does not exist or other reasons.",n),t=[]}let r=await Ee({debug:this.debug,name:this.dryRun?this.name:"",requestedPorts:{databasePort:this.databasePort,port:this.port,shadowDatabasePort:this.shadowDatabasePort},servers:t});this._databasePort=r.databasePort,this._port=r.port,this._shadowDatabasePort=r.shadowDatabasePort}async close(){}async writeServerDump(){}},Q=class e extends A{#t;#e;#r;#s;#a;#o;#n;constructor(t){super({...t,persistenceMode:"stateful"}),this.#o=!1,this.#e=F(this.name),this.#t=(0,k.join)(this.#e,"db_dump.bak"),this.#r=(0,k.join)(this.#e,".lock"),this.#s=(0,k.join)(this.#e,".pglite"),this.#n=t?.serverDump??null,this.#a=e.getServerDumpPath(this.#e)}static getServerDumpPath(t){return(0,k.join)(t,"server.json")}get databaseDumpPath(){return this.#t}get exports(){return this.#n?.exports}get pgliteDataDirPath(){return this.#s}async[Fe](){await ot(this.#e),this.debug&&console.debug(`[State] using data directory: ${this.#e}`);try{await(0,G.lock)(this.#e,{lockfilePath:this.#r}),this.debug&&console.debug(`[State] obtained lock on: ${this.#e}`);let t=await A.scan({debug:this.debug,onlyMetadata:!0}),r=await Ee({debug:this.debug,name:this.name,requestedPorts:{databasePort:this.databasePort,port:this.port,shadowDatabasePort:this.shadowDatabasePort},servers:t});this._databasePort=r.databasePort,this._port=r.port,this._shadowDatabasePort=r.shadowDatabasePort,await this.writeServerDump()}catch(t){throw t instanceof Error&&"code"in t&&t.code==="ELOCKED"?new X(this):t}}async close(){if(!this.#o)try{await(0,G.unlock)(this.#e,{lockfilePath:this.#r}),this.#o=!0,this.debug&&console.debug(`[State] released lock on: ${this.#e}`)}catch(t){throw this.debug&&console.error(`[State] failed to release lock on: ${this.#e}`,t),t}}async writeServerDump(t){this.#n={name:this.name,version:"1",pid:je.process.pid,port:this.port,databasePort:this.databasePort,shadowDatabasePort:this.shadowDatabasePort,exports:t},await(0,pr.writeFile)(this.#a,`${JSON.stringify(this.#n,null,2)}
+`,{encoding:"utf-8"})}};async function Pn(e,t){let{debug:r,onlyMetadata:n}=t||{},o=typeof e=="string"?e:e.name,s=typeof e!="string"?e:void 0,a={databasePort:s?.databasePort??-1,exports:s?.exports,name:o,pid:s?.pid,port:s?.port??-1,shadowDatabasePort:s?.shadowDatabasePort??-1,version:"1"};try{let i=s||await A.fromServerDump({debug:r,name:o});if(!i)return r&&console.debug(`[State] no server state found for name: ${o}`),{...a,status:"no_such_server"};a.databasePort=i.databasePort,a.exports=i.exports,a.pid=i.pid,a.port=i.port,a.shadowDatabasePort=i.shadowDatabasePort;let{exports:c,pid:d}=i;if(n)return{...a,status:"unknown"};if(!ur(d,r))return r&&console.debug(`[State] server state for "${o}" has no running process with PID: ${d}`),{...a,status:"not_running"};let l=F(o);try{if(!await(0,G.check)(l,{lockfilePath:(0,k.join)(l,".lock")}))return r&&console.debug(`[State] server state for "${o}" is not locked, indicating it is not running.`),{...a,status:"starting_up"}}catch(j){r&&console.error(`[State] server state for "${o}" failed to check lock:`,j)}if(!c)return{...a,status:"starting_up"};let{http:P}=c,{hc:E}=await import("hono/client"),D=await E(P.url).health.$get();if(!D.ok)return r&&console.debug(`[State] server state for "${o}" is not live: ${JSON.stringify(D)}`),{...a,status:"not_running"};let x=await D.json();return x.name!==e?(r&&console.debug(`[State] server state for "${o}" has mismatched health response: ${JSON.stringify(x)}`),{...a,status:"unknown"}):(r&&console.debug(`[State] server state for "${e}" is live: ${JSON.stringify(x)}`),{...a,status:"running"})}catch(i){return r&&console.error(`[State] failed to get server status for "${o}":`,i),{...a,status:"error"}}}var Ge=class extends Error{name="ServerStateAlreadyExistsError";constructor(t){super(`A Prisma Dev server with the name "${t}" is already running.`)}},X=class extends Ge{#t;name="ServerAlreadyRunningError";constructor(t){super(t.name),this.#t=t}get server(){return A.fromServerDump({debug:this.#t.debug,name:this.#t.name})}};async function gr(e){let t=await A.createExclusively(e),r=null,n=null,o=null;try{[r,o]=await Promise.all([Oe("database",t),Oe("shadow_database",t)]);let s=await r.attachWalEventBridge();n=await cr(r,t);let a=bn(r,o,n,t);await t.writeServerDump(a);let i=wn(s),c=r,d=o,l=n,P=async()=>{i.close(),await fr(t,[l,c,d])};return{close:P,dbServer:r,httpServer:n,server:{...a,close:P,experimental:{wal:i.api},name:t.name},serverState:t,shadowDbServer:o,walBridge:s}}catch(s){return await yn(t,[n,r,o],s)}}function bn(e,t,r,n){let o=`prisma+postgres://localhost:${r.port}/?${new URLSearchParams({api_key:Ve({databaseUrl:e.prismaORMConnectionString,name:n.name,shadowDatabaseUrl:t.prismaORMConnectionString})}).toString()}`;return{database:{connectionString:e.connectionString,prismaORMConnectionString:e.prismaORMConnectionString,terminalCommand:e.terminalCommand},http:{url:r.url},ppg:{url:o},shadowDatabase:{connectionString:t.prismaORMConnectionString,prismaORMConnectionString:t.prismaORMConnectionString,terminalCommand:t.terminalCommand}}}async function fr(e,t){let n=(await Promise.allSettled(t.map(o=>o.close()))).filter(o=>o.status==="rejected").map(o=>new Error(o.reason));try{await e.close()}catch(o){n.push(o)}if(n.length>0)throw new AggregateError(n,"Failed to close some servers")}async function yn(e,t,r){try{await fr(e,t.filter(n=>n!==null))}catch(n){throw new AggregateError([r,n],"Failed to start Prisma Dev server cleanly")}throw r}function wn(e){let t=new Set;return{api:{stream:()=>{let r=()=>{},n=vn(e,()=>{t.delete(r)});return r=()=>n.close(),t.add(r),n.stream},subscribe:r=>e.subscribe(r)},close:()=>{for(let r of[...t])r();t.clear()}}}function vn(e,t){let r=[],n=!1,o=null,s=e.subscribe(i=>{if(!n){if(o){let c=o;o=null,c.resolve({done:!1,value:i});return}r.push(i)}}),a=()=>{if(!n&&(n=!0,s(),r.length=0,t(),o)){let i=o;o=null,i.resolve({done:!0,value:void 0})}};return{close:a,stream:{[Symbol.asyncIterator](){return this},next(){return r.length>0?Promise.resolve({done:!1,value:r.shift()}):n?Promise.resolve({done:!0,value:void 0}):new Promise((i,c)=>{o={reject:c,resolve:i}})},return(){return a(),Promise.resolve({done:!0,value:void 0})},throw(i){let c=o;return a(),c&&c.reject(i),Promise.reject(i instanceof Error?i:new Error(String(i)))}}}}async function hr(e){let{server:t}=await gr(e);return t}async function Sn(e){return await hr(e)}0&&(module.exports={DEFAULT_DATABASE_PORT,DEFAULT_SERVER_PORT,DEFAULT_SHADOW_DATABASE_PORT,PortNotAvailableError,ServerAlreadyRunningError,copyPrismaDevRuntimeAssets,getPrismaDevRuntimeAssetManifest,startPrismaDevServer,unstable_startServer});

dist/index.d.cts

 import { Exports, ServerOptions } from './state.cjs';
 export { ServerAlreadyRunningError } from './state.cjs';
 import { WalEvent, DBServerPurpose } from './db.cjs';
+export { CopiedPrismaDevRuntimeAsset, PrismaDevRuntimeAsset, copyPrismaDevRuntimeAssets, getPrismaDevRuntimeAssetManifest } from './runtime-assets.cjs';
 import 'valibot';
@@ -5,0 +6,0 @@ import '@electric-sql/pglite';

dist/index.d.ts

 import { Exports, ServerOptions } from './state.js';
 export { ServerAlreadyRunningError } from './state.js';
 import { WalEvent, DBServerPurpose } from './db.js';
+export { CopiedPrismaDevRuntimeAsset, PrismaDevRuntimeAsset, copyPrismaDevRuntimeAssets, getPrismaDevRuntimeAssetManifest } from './runtime-assets.js';
 import 'valibot';
@@ -5,0 +6,0 @@ import '@electric-sql/pglite';

dist/index.js

@@ -1,1 +0,1 @@
-import{a as f,b as g}from"./chunk-UZK2DL6R.js";import"./chunk-DZGCLGSX.js";import{g as e}from"./chunk-FIY24ARL.js";import{a,b,c,g as d}from"./chunk-OTI5SWIV.js";import"./chunk-6ORCLJD5.js";import"./chunk-DGKV2DPF.js";export{a as DEFAULT_DATABASE_PORT,b as DEFAULT_SERVER_PORT,c as DEFAULT_SHADOW_DATABASE_PORT,d as PortNotAvailableError,e as ServerAlreadyRunningError,f as startPrismaDevServer,g as unstable_startServer};
+import{a as h,b as i}from"./chunk-CW5JFXGL.js";import"./chunk-NKHRQQEV.js";import{a as e,b as f}from"./chunk-NXMFOBF6.js";import{g}from"./chunk-FIY24ARL.js";import{a,b,c,g as d}from"./chunk-OTI5SWIV.js";import"./chunk-6ORCLJD5.js";import"./chunk-DGKV2DPF.js";export{a as DEFAULT_DATABASE_PORT,b as DEFAULT_SERVER_PORT,c as DEFAULT_SHADOW_DATABASE_PORT,d as PortNotAvailableError,g as ServerAlreadyRunningError,e as copyPrismaDevRuntimeAssets,f as getPrismaDevRuntimeAssetManifest,h as startPrismaDevServer,i as unstable_startServer};

package.json

 {
   "name": "@prisma/dev",
-  "version": "0.22.2",
+  "version": "0.22.3",
   "description": "A local Prisma Postgres server for development and testing",
@@ -99,9 +99,10 @@ "type": "module",
   "scripts": {
-    "build": "tsup",
+    "build": "tsup && node ./scripts/generate-bun-runtime-assets.mjs --dist",
     "check:exports": "attw . --pack --profile node16",
     "dev": "tsup --watch",
     "lint": "eslint --fix .",
-    "test": "vitest run",
+    "postinstall": "node ./scripts/generate-bun-runtime-assets.mjs",
+    "test": "node ./scripts/generate-bun-runtime-assets.mjs && vitest run",
     "typecheck": "tsc --noEmit"
   }
 }

dist/chunk-DZGCLGSX.js

-import{g as w}from"./chunk-OTI5SWIV.js";import{e as b}from"./chunk-DGKV2DPF.js";import{filename as k}from"pathe/utils";import{protocol as G}from"@electric-sql/pglite";var m="_prisma_dev_wal",p="events",_="install_all_triggers",f="capture_event",N="prisma_dev_wal_capture",E=new WeakMap,W=new Set(["ALTER","COMMIT","COPY","CREATE","DELETE","DROP","INSERT","MERGE","TRUNCATE","UPDATE"]);async function g(e,t){let o=E.get(e);if(o&&!o.closed)return o.bridge;let n=e.execProtocolRaw.bind(e),r={bridge:{close:async()=>{r.closed||(r.closed=!0,r.subscribers.clear(),e.execProtocolRaw===s&&(e.execProtocolRaw=n),await r.pollPromise,E.delete(e))},poll:async()=>{await S(r,e)},subscribe:d=>(r.subscribers.add(d),()=>{r.subscribers.delete(d)})},closed:!1,ensureInfrastructurePromise:null,pendingPoll:!1,pollPromise:null,subscribers:new Set,suppressDepth:0},s=async(d,l)=>{let i=await n(d,l);return!r.closed&&r.suppressDepth===0&&L(i)&&S(r,e),i};return e.execProtocolRaw=s,E.set(e,r),await D(r,e),r.bridge}async function R(e){let t=E.get(e);t&&await t.bridge.close()}function A(e){for(let t of e){if(t.name!=="commandComplete"||typeof t.text!="string")continue;let o=t.text.split(/\s+/,1)[0]?.toUpperCase();if(o&&W.has(o))return!0}return!1}function L(e){if(e.length===0)return!1;let t=[];return new G.Parser().parse(e,n=>{t.push(n)}),A(t)}async function D(e,t){e.ensureInfrastructurePromise??=T(e,t,async()=>{await t.exec(`CREATE SCHEMA IF NOT EXISTS "${m}"`),await t.exec(`
-      CREATE TABLE IF NOT EXISTS "${m}"."${p}" (
-        id BIGSERIAL PRIMARY KEY,
-        txid BIGINT NOT NULL DEFAULT txid_current(),
-        schema_name TEXT NOT NULL,
-        table_name TEXT NOT NULL,
-        op TEXT NOT NULL,
-        row_data JSONB,
-        old_row_data JSONB,
-        created_at TIMESTAMPTZ NOT NULL DEFAULT clock_timestamp()
-      )
-    `),await t.exec(`
-      CREATE OR REPLACE FUNCTION "${m}"."${f}"()
-      RETURNS trigger
-      LANGUAGE plpgsql
-      AS $$
-      BEGIN
-        IF TG_TABLE_SCHEMA = '${m}' THEN
-          RETURN COALESCE(NEW, OLD);
-        END IF;
-
-        INSERT INTO "${m}"."${p}" (
-          txid,
-          schema_name,
-          table_name,
-          op,
-          row_data,
-          old_row_data
-        )
-        VALUES (
-          txid_current(),
-          TG_TABLE_SCHEMA,
-          TG_TABLE_NAME,
-          lower(TG_OP),
-          CASE WHEN TG_OP IN ('INSERT', 'UPDATE') THEN to_jsonb(NEW) ELSE NULL END,
-          CASE WHEN TG_OP IN ('UPDATE', 'DELETE') THEN to_jsonb(OLD) ELSE NULL END
-        );
-
-        RETURN COALESCE(NEW, OLD);
-      END;
-      $$;
-    `),await t.exec(`
-      CREATE OR REPLACE FUNCTION "${m}"."${_}"()
-      RETURNS void
-      LANGUAGE plpgsql
-      AS $$
-      DECLARE
-        target REGCLASS;
-      BEGIN
-        FOR target IN
-          SELECT c.oid::regclass
-          FROM pg_class AS c
-          JOIN pg_namespace AS n ON n.oid = c.relnamespace
-          WHERE c.relkind IN ('r', 'p')
-            AND n.nspname NOT IN ('${m}', 'information_schema', 'pg_catalog')
-            AND n.nspname NOT LIKE 'pg_temp_%'
-            AND n.nspname NOT LIKE 'pg_toast%'
-        LOOP
-          IF EXISTS (
-            SELECT 1
-            FROM pg_trigger
-            WHERE tgrelid = target
-              AND tgname = '${N}'
-          ) THEN
-            CONTINUE;
-          END IF;
-
-          EXECUTE format(
-            'CREATE TRIGGER %I AFTER INSERT OR UPDATE OR DELETE ON %s FOR EACH ROW EXECUTE FUNCTION "${m}"."${f}"()',
-            '${N}',
-            target::text
-          );
-        END LOOP;
-      END;
-      $$;
-    `),await v(e,t)}),await e.ensureInfrastructurePromise}async function v(e,t){await T(e,t,async()=>{await t.query(`SELECT "${m}"."${_}"()`)})}async function U(e,t){await D(e,t),await v(e,t);let o=await T(e,t,async()=>await t.query(`
-      WITH drained AS (
-        DELETE FROM "${m}"."${p}"
-        RETURNING txid, schema_name, table_name, op, row_data, old_row_data, id
-      )
-      SELECT txid, schema_name, table_name, op, row_data, old_row_data
-      FROM drained
-      ORDER BY id
-    `));if(o.rows.length===0||e.subscribers.size===0)return;let n=o.rows.map(M);for(let r of e.subscribers)queueMicrotask(()=>{if(!e.closed&&e.subscribers.has(r))try{r(n)}catch(s){console.error("[WAL bridge] subscriber failed",s)}})}async function S(e,t){if(!e.closed){if(e.pollPromise){e.pendingPoll=!0,await e.pollPromise;return}e.pollPromise=(async()=>{do e.pendingPoll=!1,await U(e,t);while(e.pendingPoll&&!e.closed)})().finally(()=>{e.pollPromise=null}),await e.pollPromise}}async function T(e,t,o){e.suppressDepth+=1;try{return await o()}finally{e.suppressDepth-=1,e.suppressDepth===0&&!e.closed&&E.get(t)!==e&&(e.closed=!0)}}function M(e){return{oldRecord:e.old_row_data,record:e.row_data,schema:e.schema_name,table:e.table_name,txid:String(e.txid),type:F(e.op)}}function F(e){switch(e.toLowerCase()){case"delete":return"delete";case"insert":return"insert";case"update":return"update";default:throw new Error(`Unsupported WAL bridge operation: ${e}`)}}var H=10,a={connectionLimit:H,connectTimeout:0,database:"template1",maxIdleConnectionLifetime:0,password:"postgres",poolTimeout:0,socketTimeout:0,sslMode:"disable",username:"postgres"},q=`postgres://${a.username}:${a.password}@localhost`,h=new URLSearchParams({sslmode:a.sslMode}),X=new URLSearchParams({...Object.fromEntries(h.entries()),connection_limit:String(a.connectionLimit),connect_timeout:String(a.connectTimeout),max_idle_connection_lifetime:String(a.maxIdleConnectionLifetime),pool_timeout:String(a.poolTimeout),socket_timeout:String(a.socketTimeout)});async function te(e,t){let o=e==="database"?t.databasePort:t.shadowDatabasePort;if(t.dryRun)return y(e,t,{db:null,port:o,server:null});let{debug:n}=t,s=await(e==="shadow_database"?Y:O)(t.pgliteDataDirPath,n);n&&s.onNotification((c,u)=>{console.debug(`[${e}][${c}] ${u}`)});let{PGLiteSocketServer:d}=await import("@electric-sql/pglite-socket"),l=e==="shadow_database"?t.shadowDatabaseIdleTimeoutMillis:t.databaseIdleTimeoutMillis,i=new d({db:s,debug:n,idleTimeout:Number.isFinite(l)?l:0,inspect:n,maxConnections:a.connectionLimit,port:o});n&&(i.addEventListener("listening",c=>{let{detail:u}=c;console.debug(`[${e}] server listening on ${JSON.stringify(u)}`)}),i.addEventListener("connection",c=>{let{clientAddress:u,clientPort:$}=c.detail;console.debug(`[${e}] client connected from ${u}:${$}`)}),i.addEventListener("error",c=>{let{detail:u}=c;console.error(`[${e}] server error:`,u)}));try{await i.start()}catch(c){throw c instanceof Error&&"code"in c&&c.code==="EADDRINUSE"?new w(o):c}let P=Number(i.getServerConn().split(":").at(1));return t[e==="database"?"databasePort":"shadowDatabasePort"]=P,y(e,t,{db:s,port:P,server:i})}function y(e,t,o){let{debug:n}=t,{db:r,port:s,server:d}=o||{};return n&&console.debug(`[${e}] server started on port ${s}`),{...a,attachWalEventBridge:async()=>{if(e!=="database"||!r)throw new Error("WAL bridge is only available for the primary database server");return await g(r)},close:async()=>{let l=[];try{await d?.stop(),n&&console.debug(`[${e}] server stopped on port ${s}`)}catch(i){console.error(`[${e}] server stop error`,i),l.push(i)}if(e==="database"){try{r&&await R(r),n&&console.debug(`[${e}] closed WAL bridge`)}catch(i){console.error(`[${e}] WAL bridge close error`,i),l.push(i)}try{await r?.syncToFs(),n&&console.debug(`[${e}] synced to filesystem`)}catch(i){console.error(`[${e}] sync error`,i),l.push(i)}}try{await r?.close(),n&&console.debug(`[${e}] closed`)}catch(i){console.error(`[${e}] close error`,i),l.push(i)}if(l.length>0)throw new AggregateError(l,`Failed to close ${e} properly`)},connectionString:I(s,h),dump:async l=>{e==="shadow_database"||!r||await Q({db:r,debug:n,destinationPath:l})},port:s,prismaORMConnectionString:I(s,X),terminalCommand:`PGPASSWORD=${a.password} PGSSLMODE=${a.sslMode} psql -h localhost -p ${s} -U ${a.username} -d ${a.database}`}}function I(e,t){return`${q}:${e}/${a.database}?${t.toString()}`}async function O(e,t){let{PGlite:o}=await import("@electric-sql/pglite");return await o.create({database:a.database,dataDir:e,debug:t?5:void 0,extensions:await B(),relaxedDurability:!1,username:a.username})}async function Y(e,t){let{PGlite:o}=await import("@electric-sql/pglite");return await o.create({database:a.database,dataDir:"memory://",debug:t?5:void 0,extensions:await B(),relaxedDurability:!1,username:a.username})}async function B(){let e=await Promise.all([import("@electric-sql/pglite/contrib/amcheck"),import("@electric-sql/pglite/contrib/bloom"),import("@electric-sql/pglite/contrib/btree_gin"),import("@electric-sql/pglite/contrib/btree_gist"),import("@electric-sql/pglite/contrib/citext"),import("@electric-sql/pglite/contrib/cube"),import("@electric-sql/pglite/contrib/dict_int"),import("@electric-sql/pglite/contrib/dict_xsyn"),import("@electric-sql/pglite/contrib/earthdistance"),import("@electric-sql/pglite/contrib/file_fdw"),import("@electric-sql/pglite/contrib/fuzzystrmatch"),import("@electric-sql/pglite/contrib/hstore"),import("@electric-sql/pglite/contrib/intarray"),import("@electric-sql/pglite/contrib/isn"),import("@electric-sql/pglite/contrib/lo"),import("@electric-sql/pglite/contrib/ltree"),import("@electric-sql/pglite/contrib/pageinspect"),import("@electric-sql/pglite/contrib/pg_buffercache"),import("@electric-sql/pglite/contrib/pg_freespacemap"),import("@electric-sql/pglite/contrib/pg_surgery"),import("@electric-sql/pglite/contrib/pg_trgm"),import("@electric-sql/pglite/contrib/pg_visibility"),import("@electric-sql/pglite/contrib/pg_walinspect"),import("@electric-sql/pglite/contrib/seg"),import("@electric-sql/pglite/contrib/tablefunc"),import("@electric-sql/pglite/contrib/tcn"),import("@electric-sql/pglite/contrib/tsm_system_rows"),import("@electric-sql/pglite/contrib/tsm_system_time"),import("@electric-sql/pglite/contrib/unaccent"),import("@electric-sql/pglite/contrib/uuid_ossp"),import("@electric-sql/pglite/vector")]);return Object.assign({},...e)}async function Q(e){let{dataDir:t,db:o,debug:n,destinationPath:r}=e,s=o||await O(t,n),{pgDump:d}=await import("@electric-sql/pglite-tools/pg_dump"),l=await d({args:["--schema-only","--no-owner"],fileName:r?k(r):void 0,pg:await s.clone()});return r?(n&&console.debug(`[DB] Dumping database to ${r}`),await b(l,r)):(n&&console.debug("[DB] Dumping database to memory"),await l.text())}export{g as a,A as b,L as c,te as d,Q as e};

dist/chunk-UZK2DL6R.js

-import{d as v}from"./chunk-DZGCLGSX.js";import{a as E}from"./chunk-FIY24ARL.js";import{g as p}from"./chunk-OTI5SWIV.js";import{a as S,c as d,d as f}from"./chunk-6ORCLJD5.js";import{createServer as b}from"http";import{promisify as W}from"util";import T from"@prisma/get-platform";async function h(o,e){let{port:r}=e;if(e.dryRun)return P(r,null);let t=await B(o,e),{promise:n,reject:m,resolve:s}=d(),{serve:a}=await import("@hono/node-server"),i=a({createServer:b,fetch:t.fetch,overrideGlobalObjects:!1,port:r},s);i.on("error",c=>{if(typeof c=="object"&&"code"in c&&c.code==="EADDRINUSE")return m(new p(r));console.error("[Accelerate]",c)});let{port:l}=await n;return e.port=l,P(l,i)}function P(o,e){return{async close(){e&&await Promise.allSettled([W(e.close.bind(e))(),f.stopAll()])},port:o,url:`http://localhost:${o}`}}async function B(o,e){let{debug:r}=e,[{Hono:t},{accelerateRoute:n},{utilityRoute:m}]=await Promise.all([import("hono/tiny"),import("./accelerate-HABH6RJU.js"),import("./utility-Q5A254LJ.js")]),s=new t,a=await T.getPlatformInfo();if(r&&console.debug("[Accelerate] platform info: %s",JSON.stringify(a)),r){let{logger:l}=await import("hono/logger");s.use("*",l((...c)=>console.log("[Accelerate]",...c)))}s.use("*",async(l,c)=>(l.set("databaseDumpPath",e.databaseDumpPath),l.set("db",o),l.set("debug",!!r),l.set("name",e.name),l.set("platform",a),l.set("shadowDBPort",e.shadowDatabasePort),await c()));let i=new t;return i.route("/",n),i.route("/",m),s.route("/",i),s}async function w(o){let e=await E.createExclusively(o),r=null,t=null,n=null;try{[r,n]=await Promise.all([v("database",e),v("shadow_database",e)]);let m=await r.attachWalEventBridge();t=await h(r,e);let s=D(r,n,t,e);await e.writeServerDump(s);let a=R(m),i=r,l=n,c=t,u=async()=>{a.close(),await x(e,[c,i,l])};return{close:u,dbServer:r,httpServer:t,server:{...s,close:u,experimental:{wal:a.api},name:e.name},serverState:e,shadowDbServer:n,walBridge:m}}catch(m){return await A(e,[t,r,n],m)}}function D(o,e,r,t){let n=`prisma+postgres://localhost:${r.port}/?${new URLSearchParams({api_key:S({databaseUrl:o.prismaORMConnectionString,name:t.name,shadowDatabaseUrl:e.prismaORMConnectionString})}).toString()}`;return{database:{connectionString:o.connectionString,prismaORMConnectionString:o.prismaORMConnectionString,terminalCommand:o.terminalCommand},http:{url:r.url},ppg:{url:n},shadowDatabase:{connectionString:e.prismaORMConnectionString,prismaORMConnectionString:e.prismaORMConnectionString,terminalCommand:e.terminalCommand}}}async function x(o,e){let t=(await Promise.allSettled(e.map(n=>n.close()))).filter(n=>n.status==="rejected").map(n=>new Error(n.reason));try{await o.close()}catch(n){t.push(n)}if(t.length>0)throw new AggregateError(t,"Failed to close some servers")}async function A(o,e,r){try{await x(o,e.filter(t=>t!==null))}catch(t){throw new AggregateError([r,t],"Failed to start Prisma Dev server cleanly")}throw r}function R(o){let e=new Set;return{api:{stream:()=>{let r=()=>{},t=C(o,()=>{e.delete(r)});return r=()=>t.close(),e.add(r),t.stream},subscribe:r=>o.subscribe(r)},close:()=>{for(let r of[...e])r();e.clear()}}}function C(o,e){let r=[],t=!1,n=null,m=o.subscribe(a=>{if(!t){if(n){let i=n;n=null,i.resolve({done:!1,value:a});return}r.push(a)}}),s=()=>{if(!t&&(t=!0,m(),r.length=0,e(),n)){let a=n;n=null,a.resolve({done:!0,value:void 0})}};return{close:s,stream:{[Symbol.asyncIterator](){return this},next(){return r.length>0?Promise.resolve({done:!1,value:r.shift()}):t?Promise.resolve({done:!0,value:void 0}):new Promise((a,i)=>{n={reject:i,resolve:a}})},return(){return s(),Promise.resolve({done:!0,value:void 0})},throw(a){let i=n;return s(),i&&i.reject(a),Promise.reject(a instanceof Error?a:new Error(String(a)))}}}}async function O(o){let{server:e}=await w(o);return e}async function Y(o){return await O(o)}export{O as a,Y as b};

New alerts

Install scripts

Supply chain risk

Install scripts are run when the package is installed or built. Malicious packages often use scripts that run automatically to execute payloads or fetch additional code.

Debug access

Supply chain risk

Uses debug, reflection and dynamic code execution features.

Minified code

Quality

This package contains minified code. This may be harmless in some cases where minified code is included in packaged libraries, however packages on npm should not minify code.

URL strings

Supply chain risk

Package contains fragments of external URLs or IP addresses, which the package may be accessing at runtime.

Fixed alerts

AI-detected potential code anomaly

Supply chain risk

AI has identified unusual behaviors that may pose a security risk.

Minified code

Quality

This package contains minified code. This may be harmless in some cases where minified code is included in packaged libraries, however packages on npm should not minify code.

URL strings

Supply chain risk

Package contains fragments of external URLs or IP addresses, which the package may be accessing at runtime.

Improved metrics

Total package byte prevSize

14343195

7360.85%

Number of package files

64

156%

Lines of code

1413

12.32%

Worsened metrics

Number of low quality alerts

17

13.33%

Number of high supply chain risk alerts

1

Infinity%

Number of low supply chain risk alerts

32

52.38%

Number of medium supply chain risk alerts

33

17.86%

No dependency changes