{"version":3,"sources":["../src/index.ts","../../../node_modules/.pnpm/tsup@8.3.0_@microsoft+api-extractor@7.47.7_@types+node@20.16.11__postcss@8.4.47_tsx@4.19.2_typescript@5.6.3/node_modules/tsup/assets/cjs_shims.js","../../pglite-utils/src/utils.ts"],"sourcesContent":["import { pglUtils } from '@electric-sql/pglite-utils'\n\nexport async function dataDir(): Promise {\n const moduleUrl = new URL('../dist/prepopulatedfs.tgz', import.meta.url)\n if (pglUtils.IN_NODE) {\n const fs = await import('fs/promises')\n const buffer = await fs.readFile(moduleUrl)\n return new Blob([new Uint8Array(buffer)])\n } else {\n const downloadPromise = await fetch(moduleUrl)\n return downloadPromise.blob()\n }\n}\n","// Shim globals in cjs bundle\n// There's a weird bug that esbuild will always inject importMetaUrl\n// if we export it as `const importMetaUrl = ... __filename ...`\n// But using a function will not cause this issue\n\nconst getImportMetaUrl = () =>\n typeof document === 'undefined'\n ? new URL(`file:${__filename}`).href\n : (document.currentScript && document.currentScript.src) ||\n new URL('main.js', document.baseURI).href\n\nexport const importMetaUrl = /* @__PURE__ */ getImportMetaUrl()\n","// Electron exposes a Node-like `process` in its renderer/worker/service-worker\n// contexts, which must use the browser fs path. Its main and utility processes\n// are real Node environments (#813).\nfunction isElectronWebContext(): boolean {\n const type = (process as { type?: string }).type\n return type === 'renderer' || type === 'worker' || type === 'service-worker'\n}\n\nexport const IN_NODE =\n typeof process === 'object' &&\n typeof process.versions === 'object' &&\n typeof process.versions.node === 'string' &&\n !isElectronWebContext()\n\nexport const WASM_PREFIX = '/pglite'\n\nconst artifactDownloadPromises = new Map>()\n\nexport async function startArtifactDownload(url: URL) {\n if (IN_NODE || artifactDownloadPromises.has(url.toString())) {\n return\n }\n artifactDownloadPromises.set(url.toString(), fetch(url))\n}\n\n// This is a global cache of the Wasm modules to avoid having to re-download or\n// compile them on subsequent calls.\nconst cachedWasmModules = new Map()\n\nexport const pgliteProc =\n globalThis && typeof globalThis.process !== 'undefined'\n ? globalThis.process\n : { exitCode: undefined }\n\nexport async function instantiateWasm(\n imports: WebAssembly.Imports,\n moduleUrl: URL,\n module?: WebAssembly.Module,\n): Promise<{\n instance: WebAssembly.Instance\n module: WebAssembly.Module\n}> {\n if (module || cachedWasmModules.has(moduleUrl.toString())) {\n const mod = module || cachedWasmModules.get(moduleUrl.toString())!\n return {\n instance: await WebAssembly.instantiate(mod, imports),\n module: mod,\n }\n }\n if (IN_NODE) {\n const fs = await import('fs/promises')\n const buffer = await fs.readFile(moduleUrl)\n const { module: newModule, instance } = await WebAssembly.instantiate(\n buffer,\n imports,\n )\n cachedWasmModules.set(moduleUrl.toString(), newModule)\n return {\n instance,\n module: newModule,\n }\n } else {\n if (!artifactDownloadPromises.has(moduleUrl.toString())) {\n startArtifactDownload(moduleUrl)\n // wasmDownloadPromises.set(moduleUrl, fetch(moduleUrl))\n }\n const response = await artifactDownloadPromises.get(moduleUrl.toString())\n const { module: newModule, instance } =\n await WebAssembly.instantiateStreaming(response!.clone(), imports)\n cachedWasmModules.set(moduleUrl.toString(), newModule)\n return {\n instance,\n module: newModule,\n }\n }\n}\n\nexport async function getFsBundle(fsBundleUrl: URL): Promise {\n if (IN_NODE) {\n const fs = await import('fs/promises')\n const fileData = await fs.readFile(fsBundleUrl)\n return fileData.buffer\n } else {\n startArtifactDownload(fsBundleUrl)\n const response = await artifactDownloadPromises.get(fsBundleUrl.toString())\n return response!.clone().arrayBuffer()\n }\n}\n\nexport const uuid = (): string => {\n // best case, `crypto.randomUUID` is available\n if (globalThis.crypto?.randomUUID) {\n return globalThis.crypto.randomUUID()\n }\n\n const bytes = new Uint8Array(16)\n\n if (globalThis.crypto?.getRandomValues) {\n // `crypto.getRandomValues` is available even in non-secure contexts\n globalThis.crypto.getRandomValues(bytes)\n } else {\n // fallback to Math.random, if the Crypto API is completely missing\n for (let i = 0; i < bytes.length; i++) {\n bytes[i] = Math.floor(Math.random() * 256)\n }\n }\n\n bytes[6] = (bytes[6] & 0x0f) | 0x40 // Set the 4 most significant bits to 0100\n bytes[8] = (bytes[8] & 0x3f) | 0x80 // Set the 2 most significant bits to 10\n\n const hexValues: string[] = []\n bytes.forEach((byte) => {\n hexValues.push(byte.toString(16).padStart(2, '0'))\n })\n\n return (\n hexValues.slice(0, 4).join('') +\n '-' +\n hexValues.slice(4, 6).join('') +\n '-' +\n hexValues.slice(6, 8).join('') +\n '-' +\n hexValues.slice(8, 10).join('') +\n '-' +\n hexValues.slice(10).join('')\n )\n}\n\n/**\n * Postgresql handles quoted names as CaseSensitive and unquoted as lower case.\n * If input is quoted, returns an unquoted string (same casing)\n * If input is unquoted, returns a lower-case string\n */\nexport function toPostgresName(input: string): string {\n let output\n if (input.startsWith('\"') && input.endsWith('\"')) {\n // Postgres sensitive case\n output = input.substring(1, input.length - 1)\n } else {\n // Postgres case insensitive - all to lower\n output = input.toLowerCase()\n }\n return output\n}\n\ninterface MinimalFS {\n readdir(path: string): string[]\n unlink(path: string): void\n rmdir(path: string): void\n}\n\nexport function rmdirRecursive(fs: MinimalFS, path: string) {\n try {\n // If readdir succeeds it's a directory\n const entries = fs.readdir(path).filter((n: any) => n !== '.' && n !== '..')\n for (const name of entries) {\n const child = path + '/' + name\n // Recurse or unlink depending on whether child is a directory\n try {\n fs.readdir(child)\n rmdirRecursive(fs, child)\n } catch (e) {\n // readdir failed => not a directory\n fs.unlink(child)\n }\n }\n fs.rmdir(path)\n } catch (e) {\n // not a directory: try unlink\n try {\n fs.unlink(path)\n } catch (_) {\n /* ignore if already gone */\n }\n }\n}\n"],"mappings":";;;;;;;;;;;;;;;;;;;;;;;;;;;;;;AAAA;AAAA;AAAA;AAAA;AAAA;;;ACKA,IAAM,mBAAmB,MACvB,OAAO,aAAa,cAChB,IAAI,IAAI,QAAQ,UAAU,EAAE,EAAE,OAC7B,SAAS,iBAAiB,SAAS,cAAc,OAClD,IAAI,IAAI,WAAW,SAAS,OAAO,EAAE;AAEpC,IAAM,gBAAgC,iCAAiB;;;;;;;ACX9D,IAAAA,IAAA,CAAA;AAAAC,EAAAD,GAAA,EAAA,SAAA,MAAAE,GAAA,aAAA,MAAAC,GAAA,aAAA,MAAAC,GAAA,iBAAA,MAAAC,GAAA,YAAA,MAAAC,GAAA,gBAAA,MAAAC,GAAA,uBAAA,MAAAC,GAAA,gBAAA,MAAAC,GAAA,MAAA,MAAAC,EAAAA,CAAAA;AAGA,SAASC,IAAgC;AACvC,MAAMC,IAAQ,QAA8B;AAC5C,SAAOA,MAAS,cAAcA,MAAS,YAAYA,MAAS;AAC9D;AAEO,IAAMV,IACX,OAAO,WAAY,YACnB,OAAO,QAAQ,YAAa,YAC5B,OAAO,QAAQ,SAAS,QAAS,YACjC,CAACS,EAAqB;AAJjB,IAMMR,IAAc;AANpB,IAQDU,IAA2B,oBAAI;AAErC,eAAsBL,EAAsBM,GAAU;AAChDZ,OAAWW,EAAyB,IAAIC,EAAI,SAAS,CAAC,KAG1DD,EAAyB,IAAIC,EAAI,SAAS,GAAG,MAAMA,CAAG,CAAC;AACzD;AAIA,IAAMC,IAAoB,oBAAI;AAA9B,IAEaT,IACX,cAAc,OAAO,WAAW,UAAY,MACxC,WAAW,UACX,EAAE,UAAU,OAAU;AAE5B,eAAsBD,EACpBW,GACAC,GACAC,GAIC;AACD,MAAIA,KAAUH,EAAkB,IAAIE,EAAU,SAAS,CAAC,GAAG;AACzD,QAAME,IAAMD,KAAUH,EAAkB,IAAIE,EAAU,SAAS,CAAC;AAChE,WAAO,EACL,UAAU,MAAM,YAAY,YAAYE,GAAKH,CAAO,GACpD,QAAQG,EACV;EACF;AACA,MAAIjB,GAAS;AAEX,QAAMkB,IAAS,OADJ,MAAM,OAAO,aAAa,GACb,SAASH,CAAS,GACpC,EAAE,QAAQI,GAAW,UAAAC,EAAS,IAAI,MAAM,YAAY,YACxDF,GACAJ,CACF;AACA,WAAAD,EAAkB,IAAIE,EAAU,SAAS,GAAGI,CAAS,GAC9C,EACL,UAAAC,GACA,QAAQD,EACV;EACF,OAAO;AACAR,MAAyB,IAAII,EAAU,SAAS,CAAC,KACpDT,EAAsBS,CAAS;AAGjC,QAAMM,IAAW,MAAMV,EAAyB,IAAII,EAAU,SAAS,CAAC,GAClE,EAAE,QAAQI,GAAW,UAAAC,EAAS,IAClC,MAAM,YAAY,qBAAqBC,EAAU,MAAM,GAAGP,CAAO;AACnE,WAAAD,EAAkB,IAAIE,EAAU,SAAS,GAAGI,CAAS,GAC9C,EACL,UAAAC,GACA,QAAQD,EACV;EACF;AACF;AAEA,eAAsBjB,EAAYoB,GAAwC;AACxE,SAAItB,KAEe,OADN,MAAM,OAAO,aAAa,GACX,SAASsB,CAAW,GAC9B,UAEhBhB,EAAsBgB,CAAW,IAChB,MAAMX,EAAyB,IAAIW,EAAY,SAAS,CAAC,GACzD,MAAM,EAAE,YAAY;AAEzC;AAEO,IAAMd,IAAO,MAAc;AAEhC,MAAI,WAAW,QAAQ,WACrB,QAAO,WAAW,OAAO,WAAW;AAGtC,MAAMe,IAAQ,IAAI,WAAW,EAAE;AAE/B,MAAI,WAAW,QAAQ,gBAErB,YAAW,OAAO,gBAAgBA,CAAK;MAGvC,UAASC,IAAI,GAAGA,IAAID,EAAM,QAAQC,IAChCD,GAAMC,CAAC,IAAI,KAAK,MAAM,KAAK,OAAO,IAAI,GAAG;AAI7CD,IAAM,CAAC,IAAKA,EAAM,CAAC,IAAI,KAAQ,IAC/BA,EAAM,CAAC,IAAKA,EAAM,CAAC,IAAI,KAAQ;AAE/B,MAAME,IAAsB,CAAC;AAC7B,SAAAF,EAAM,QAASG,OAAS;AACtBD,MAAU,KAAKC,EAAK,SAAS,EAAE,EAAE,SAAS,GAAG,GAAG,CAAC;EACnD,CAAC,GAGCD,EAAU,MAAM,GAAG,CAAC,EAAE,KAAK,EAAE,IAC7B,MACAA,EAAU,MAAM,GAAG,CAAC,EAAE,KAAK,EAAE,IAC7B,MACAA,EAAU,MAAM,GAAG,CAAC,EAAE,KAAK,EAAE,IAC7B,MACAA,EAAU,MAAM,GAAG,EAAE,EAAE,KAAK,EAAE,IAC9B,MACAA,EAAU,MAAM,EAAE,EAAE,KAAK,EAAE;AAE/B;AAOO,SAASlB,EAAeoB,GAAuB;AACpD,MAAIC;AACJ,SAAID,EAAM,WAAW,GAAG,KAAKA,EAAM,SAAS,GAAG,IAE7CC,IAASD,EAAM,UAAU,GAAGA,EAAM,SAAS,CAAC,IAG5CC,IAASD,EAAM,YAAY,GAEtBC;AACT;AAQO,SAASvB,EAAewB,GAAeC,GAAc;AAC1D,MAAI;AAEF,QAAMC,IAAUF,EAAG,QAAQC,CAAI,EAAE,OAAQ,OAAW,MAAM,OAAO,MAAM,IAAI;AAC3E,aAAWE,KAAQD,GAAS;AAC1B,UAAME,IAAQH,IAAO,MAAME;AAE3B,UAAI;AACFH,UAAG,QAAQI,CAAK,GAChB5B,EAAewB,GAAII,CAAK;MAC1B,QAAY;AAEVJ,UAAG,OAAOI,CAAK;MACjB;IACF;AACAJ,MAAG,MAAMC,CAAI;EACf,QAAY;AAEV,QAAI;AACFD,QAAG,OAAOC,CAAI;IAChB,QAAY;IAEZ;EACF;AACF;;;AF7KA,eAAsB,UAAyB;AAC7C,QAAM,YAAY,IAAI,IAAI,8BAA8B,aAAe;AACvE,MAAI,EAAS,SAAS;AACpB,UAAM,KAAK,MAAM,OAAO,aAAa;AACrC,UAAM,SAAS,MAAM,GAAG,SAAS,SAAS;AAC1C,WAAO,IAAI,KAAK,CAAC,IAAI,WAAW,MAAM,CAAC,CAAC;AAAA,EAC1C,OAAO;AACL,UAAM,kBAAkB,MAAM,MAAM,SAAS;AAC7C,WAAO,gBAAgB,KAAK;AAAA,EAC9B;AACF;","names":["utils_exports","__export","IN_NODE","WASM_PREFIX","getFsBundle","instantiateWasm","pgliteProc","rmdirRecursive","startArtifactDownload","toPostgresName","uuid","isElectronWebContext","type","artifactDownloadPromises","url","cachedWasmModules","imports","moduleUrl","module","mod","buffer","newModule","instance","response","fsBundleUrl","bytes","i","hexValues","byte","input","output","fs","path","entries","name","child"]}