@electric-sql/pglite - npm Package Compare versions

Comparing version 0.2.6 to 0.2.7

dist/contrib/adminpack.d.ts

@@ -1,2 +0,2 @@
-import { a as PGliteInterface } from '../interface-BChI4DHV.js';
+import { a as PGliteInterface } from '../interface-B1Tuaggj.js';
 import '@electric-sql/pg-protocol/messages';
@@ -3,0 +3,0 @@ import '../types-XE-2t5ub.js';

dist/contrib/adminpack.js

@@ -1,2 +0,2 @@
-import{i as e}from"../chunk-Y3AVQXKT.js";e();var t=async(n,s)=>({bundlePath:new URL("..//adminpack.tar.gz",import.meta.url)}),p={name:"adminpack",setup:t};export{p as adminpack};
+import{i as e}from"../chunk-Y3AVQXKT.js";e();var t=async(n,s)=>({bundlePath:new URL("../adminpack.tar.gz",import.meta.url)}),p={name:"adminpack",setup:t};export{p as adminpack};
 //# sourceMappingURL=adminpack.js.map

dist/contrib/amcheck.d.ts

@@ -1,2 +0,2 @@
-import { a as PGliteInterface } from '../interface-BChI4DHV.js';
+import { a as PGliteInterface } from '../interface-B1Tuaggj.js';
 import '@electric-sql/pg-protocol/messages';
@@ -3,0 +3,0 @@ import '../types-XE-2t5ub.js';

dist/contrib/amcheck.js

@@ -1,2 +0,2 @@
-import{i as e}from"../chunk-Y3AVQXKT.js";e();var t=async(n,s)=>({bundlePath:new URL("..//amcheck.tar.gz",import.meta.url)}),c={name:"amcheck",setup:t};export{c as amcheck};
+import{i as e}from"../chunk-Y3AVQXKT.js";e();var t=async(n,s)=>({bundlePath:new URL("../amcheck.tar.gz",import.meta.url)}),c={name:"amcheck",setup:t};export{c as amcheck};
 //# sourceMappingURL=amcheck.js.map

dist/contrib/auto_explain.d.ts

@@ -1,2 +0,2 @@
-import { a as PGliteInterface } from '../interface-BChI4DHV.js';
+import { a as PGliteInterface } from '../interface-B1Tuaggj.js';
 import '@electric-sql/pg-protocol/messages';
@@ -3,0 +3,0 @@ import '../types-XE-2t5ub.js';

dist/contrib/auto_explain.js

@@ -1,2 +0,2 @@
-import{i as e}from"../chunk-Y3AVQXKT.js";e();var t=async(n,s)=>({bundlePath:new URL("..//auto_explain.tar.gz",import.meta.url)}),o={name:"auto_explain",setup:t};export{o as auto_explain};
+import{i as e}from"../chunk-Y3AVQXKT.js";e();var t=async(n,s)=>({bundlePath:new URL("../auto_explain.tar.gz",import.meta.url)}),o={name:"auto_explain",setup:t};export{o as auto_explain};
 //# sourceMappingURL=auto_explain.js.map

dist/contrib/bloom.d.ts

@@ -1,2 +0,2 @@
-import { a as PGliteInterface } from '../interface-BChI4DHV.js';
+import { a as PGliteInterface } from '../interface-B1Tuaggj.js';
 import '@electric-sql/pg-protocol/messages';
@@ -3,0 +3,0 @@ import '../types-XE-2t5ub.js';

dist/contrib/bloom.js

@@ -1,2 +0,2 @@
-import{i as e}from"../chunk-Y3AVQXKT.js";e();var t=async(n,s)=>({bundlePath:new URL("..//bloom.tar.gz",import.meta.url)}),r={name:"bloom",setup:t};export{r as bloom};
+import{i as e}from"../chunk-Y3AVQXKT.js";e();var t=async(n,s)=>({bundlePath:new URL("../bloom.tar.gz",import.meta.url)}),r={name:"bloom",setup:t};export{r as bloom};
 //# sourceMappingURL=bloom.js.map

dist/contrib/btree_gin.d.ts

@@ -1,2 +0,2 @@
-import { a as PGliteInterface } from '../interface-BChI4DHV.js';
+import { a as PGliteInterface } from '../interface-B1Tuaggj.js';
 import '@electric-sql/pg-protocol/messages';
@@ -3,0 +3,0 @@ import '../types-XE-2t5ub.js';

dist/contrib/btree_gin.js

@@ -1,2 +0,2 @@
-import{i as e}from"../chunk-Y3AVQXKT.js";e();var t=async(n,s)=>({bundlePath:new URL("..//btree_gin.tar.gz",import.meta.url)}),a={name:"btree_gin",setup:t};export{a as btree_gin};
+import{i as e}from"../chunk-Y3AVQXKT.js";e();var t=async(n,s)=>({bundlePath:new URL("../btree_gin.tar.gz",import.meta.url)}),a={name:"btree_gin",setup:t};export{a as btree_gin};
 //# sourceMappingURL=btree_gin.js.map

dist/contrib/btree_gist.d.ts

@@ -1,2 +0,2 @@
-import { a as PGliteInterface } from '../interface-BChI4DHV.js';
+import { a as PGliteInterface } from '../interface-B1Tuaggj.js';
 import '@electric-sql/pg-protocol/messages';
@@ -3,0 +3,0 @@ import '../types-XE-2t5ub.js';

dist/contrib/btree_gist.js

@@ -1,2 +0,2 @@
-import{i as e}from"../chunk-Y3AVQXKT.js";e();var t=async(s,n)=>({bundlePath:new URL("..//btree_gist.tar.gz",import.meta.url)}),a={name:"btree_gist",setup:t};export{a as btree_gist};
+import{i as e}from"../chunk-Y3AVQXKT.js";e();var t=async(s,n)=>({bundlePath:new URL("../btree_gist.tar.gz",import.meta.url)}),a={name:"btree_gist",setup:t};export{a as btree_gist};
 //# sourceMappingURL=btree_gist.js.map

dist/contrib/citext.d.ts

@@ -1,2 +0,2 @@
-import { a as PGliteInterface } from '../interface-BChI4DHV.js';
+import { a as PGliteInterface } from '../interface-B1Tuaggj.js';
 import '@electric-sql/pg-protocol/messages';
@@ -3,0 +3,0 @@ import '../types-XE-2t5ub.js';

dist/contrib/citext.js

@@ -1,2 +0,2 @@
-import{i as e}from"../chunk-Y3AVQXKT.js";e();var t=async(n,s)=>({bundlePath:new URL("..//citext.tar.gz",import.meta.url)}),a={name:"citext",setup:t};export{a as citext};
+import{i as e}from"../chunk-Y3AVQXKT.js";e();var t=async(n,s)=>({bundlePath:new URL("../citext.tar.gz",import.meta.url)}),a={name:"citext",setup:t};export{a as citext};
 //# sourceMappingURL=citext.js.map

dist/contrib/cube.d.ts

@@ -1,2 +0,2 @@
-import { a as PGliteInterface } from '../interface-BChI4DHV.js';
+import { a as PGliteInterface } from '../interface-B1Tuaggj.js';
 import '@electric-sql/pg-protocol/messages';
@@ -3,0 +3,0 @@ import '../types-XE-2t5ub.js';

dist/contrib/cube.js

@@ -1,2 +0,2 @@
-import{i as e}from"../chunk-Y3AVQXKT.js";e();var t=async(n,s)=>({bundlePath:new URL("..//cube.tar.gz",import.meta.url)}),a={name:"cube",setup:t};export{a as cube};
+import{i as e}from"../chunk-Y3AVQXKT.js";e();var t=async(n,s)=>({bundlePath:new URL("../cube.tar.gz",import.meta.url)}),a={name:"cube",setup:t};export{a as cube};
 //# sourceMappingURL=cube.js.map

dist/contrib/earthdistance.d.ts

@@ -1,2 +0,2 @@
-import { a as PGliteInterface } from '../interface-BChI4DHV.js';
+import { a as PGliteInterface } from '../interface-B1Tuaggj.js';
 import '@electric-sql/pg-protocol/messages';
@@ -3,0 +3,0 @@ import '../types-XE-2t5ub.js';

dist/contrib/earthdistance.js

@@ -1,2 +0,2 @@
-import{i as e}from"../chunk-Y3AVQXKT.js";e();var t=async(n,s)=>({bundlePath:new URL("..//earthdistance.tar.gz",import.meta.url)}),r={name:"earthdistance",setup:t};export{r as earthdistance};
+import{i as e}from"../chunk-Y3AVQXKT.js";e();var t=async(n,s)=>({bundlePath:new URL("../earthdistance.tar.gz",import.meta.url)}),r={name:"earthdistance",setup:t};export{r as earthdistance};
 //# sourceMappingURL=earthdistance.js.map

dist/contrib/fuzzystrmatch.d.ts

@@ -1,2 +0,2 @@
-import { a as PGliteInterface } from '../interface-BChI4DHV.js';
+import { a as PGliteInterface } from '../interface-B1Tuaggj.js';
 import '@electric-sql/pg-protocol/messages';
@@ -3,0 +3,0 @@ import '../types-XE-2t5ub.js';

dist/contrib/fuzzystrmatch.js

@@ -1,2 +0,2 @@
-import{i as t}from"../chunk-Y3AVQXKT.js";t();var e=async(s,n)=>({bundlePath:new URL("..//fuzzystrmatch.tar.gz",import.meta.url)}),i={name:"fuzzystrmatch",setup:e};export{i as fuzzystrmatch};
+import{i as t}from"../chunk-Y3AVQXKT.js";t();var e=async(s,n)=>({bundlePath:new URL("../fuzzystrmatch.tar.gz",import.meta.url)}),i={name:"fuzzystrmatch",setup:e};export{i as fuzzystrmatch};
 //# sourceMappingURL=fuzzystrmatch.js.map

dist/contrib/hstore.d.ts

@@ -1,2 +0,2 @@
-import { a as PGliteInterface } from '../interface-BChI4DHV.js';
+import { a as PGliteInterface } from '../interface-B1Tuaggj.js';
 import '@electric-sql/pg-protocol/messages';
@@ -3,0 +3,0 @@ import '../types-XE-2t5ub.js';

dist/contrib/hstore.js

@@ -1,2 +0,2 @@
-import{i as e}from"../chunk-Y3AVQXKT.js";e();var t=async(s,n)=>({bundlePath:new URL("..//hstore.tar.gz",import.meta.url)}),o={name:"hstore",setup:t};export{o as hstore};
+import{i as e}from"../chunk-Y3AVQXKT.js";e();var t=async(s,n)=>({bundlePath:new URL("../hstore.tar.gz",import.meta.url)}),o={name:"hstore",setup:t};export{o as hstore};
 //# sourceMappingURL=hstore.js.map

dist/contrib/isn.d.ts

@@ -1,2 +0,2 @@
-import { a as PGliteInterface } from '../interface-BChI4DHV.js';
+import { a as PGliteInterface } from '../interface-B1Tuaggj.js';
 import '@electric-sql/pg-protocol/messages';
@@ -3,0 +3,0 @@ import '../types-XE-2t5ub.js';

dist/contrib/isn.js

@@ -1,2 +0,2 @@
-import{i as e}from"../chunk-Y3AVQXKT.js";e();var t=async(n,s)=>({bundlePath:new URL("..//isn.tar.gz",import.meta.url)}),a={name:"isn",setup:t};export{a as isn};
+import{i as e}from"../chunk-Y3AVQXKT.js";e();var t=async(n,s)=>({bundlePath:new URL("../isn.tar.gz",import.meta.url)}),a={name:"isn",setup:t};export{a as isn};
 //# sourceMappingURL=isn.js.map

dist/contrib/lo.d.ts

@@ -1,2 +0,2 @@
-import { a as PGliteInterface } from '../interface-BChI4DHV.js';
+import { a as PGliteInterface } from '../interface-B1Tuaggj.js';
 import '@electric-sql/pg-protocol/messages';
@@ -3,0 +3,0 @@ import '../types-XE-2t5ub.js';

dist/contrib/lo.js

@@ -1,2 +0,2 @@
-import{i as e}from"../chunk-Y3AVQXKT.js";e();var t=async(n,s)=>({bundlePath:new URL("..//lo.tar.gz",import.meta.url)}),r={name:"lo",setup:t};export{r as lo};
+import{i as e}from"../chunk-Y3AVQXKT.js";e();var t=async(n,s)=>({bundlePath:new URL("../lo.tar.gz",import.meta.url)}),r={name:"lo",setup:t};export{r as lo};
 //# sourceMappingURL=lo.js.map

dist/contrib/ltree.d.ts

@@ -1,2 +0,2 @@
-import { a as PGliteInterface } from '../interface-BChI4DHV.js';
+import { a as PGliteInterface } from '../interface-B1Tuaggj.js';
 import '@electric-sql/pg-protocol/messages';
@@ -3,0 +3,0 @@ import '../types-XE-2t5ub.js';

dist/contrib/ltree.js

@@ -1,2 +0,2 @@
-import{i as e}from"../chunk-Y3AVQXKT.js";e();var t=async(n,s)=>({bundlePath:new URL("..//ltree.tar.gz",import.meta.url)}),a={name:"ltree",setup:t};export{a as ltree};
+import{i as e}from"../chunk-Y3AVQXKT.js";e();var t=async(n,s)=>({bundlePath:new URL("../ltree.tar.gz",import.meta.url)}),a={name:"ltree",setup:t};export{a as ltree};
 //# sourceMappingURL=ltree.js.map

dist/contrib/pg_trgm.d.ts

@@ -1,2 +0,2 @@
-import { a as PGliteInterface } from '../interface-BChI4DHV.js';
+import { a as PGliteInterface } from '../interface-B1Tuaggj.js';
 import '@electric-sql/pg-protocol/messages';
@@ -3,0 +3,0 @@ import '../types-XE-2t5ub.js';

dist/contrib/pg_trgm.js

@@ -1,2 +0,2 @@
-import{i as e}from"../chunk-Y3AVQXKT.js";e();var t=async(n,s)=>({bundlePath:new URL("..//pg_trgm.tar.gz",import.meta.url)}),p={name:"pg_trgm",setup:t};export{p as pg_trgm};
+import{i as e}from"../chunk-Y3AVQXKT.js";e();var t=async(n,s)=>({bundlePath:new URL("../pg_trgm.tar.gz",import.meta.url)}),p={name:"pg_trgm",setup:t};export{p as pg_trgm};
 //# sourceMappingURL=pg_trgm.js.map

dist/contrib/seg.d.ts

@@ -1,2 +0,2 @@
-import { a as PGliteInterface } from '../interface-BChI4DHV.js';
+import { a as PGliteInterface } from '../interface-B1Tuaggj.js';
 import '@electric-sql/pg-protocol/messages';
@@ -3,0 +3,0 @@ import '../types-XE-2t5ub.js';

dist/contrib/seg.js

@@ -1,2 +0,2 @@
-import{i as e}from"../chunk-Y3AVQXKT.js";e();var t=async(s,n)=>({bundlePath:new URL("..//seg.tar.gz",import.meta.url)}),a={name:"seg",setup:t};export{a as seg};
+import{i as e}from"../chunk-Y3AVQXKT.js";e();var t=async(s,n)=>({bundlePath:new URL("../seg.tar.gz",import.meta.url)}),a={name:"seg",setup:t};export{a as seg};
 //# sourceMappingURL=seg.js.map

dist/contrib/tablefunc.d.ts

@@ -1,2 +0,2 @@
-import { a as PGliteInterface } from '../interface-BChI4DHV.js';
+import { a as PGliteInterface } from '../interface-B1Tuaggj.js';
 import '@electric-sql/pg-protocol/messages';
@@ -3,0 +3,0 @@ import '../types-XE-2t5ub.js';

dist/contrib/tablefunc.js

@@ -1,2 +0,2 @@
-import{i as e}from"../chunk-Y3AVQXKT.js";e();var t=async(n,s)=>({bundlePath:new URL("..//tablefunc.tar.gz",import.meta.url)}),r={name:"tablefunc",setup:t};export{r as tablefunc};
+import{i as e}from"../chunk-Y3AVQXKT.js";e();var t=async(n,s)=>({bundlePath:new URL("../tablefunc.tar.gz",import.meta.url)}),r={name:"tablefunc",setup:t};export{r as tablefunc};
 //# sourceMappingURL=tablefunc.js.map

dist/contrib/tcn.d.ts

@@ -1,2 +0,2 @@
-import { a as PGliteInterface } from '../interface-BChI4DHV.js';
+import { a as PGliteInterface } from '../interface-B1Tuaggj.js';
 import '@electric-sql/pg-protocol/messages';
@@ -3,0 +3,0 @@ import '../types-XE-2t5ub.js';

dist/contrib/tcn.js

@@ -1,2 +0,2 @@
-import{i as e}from"../chunk-Y3AVQXKT.js";e();var t=async(n,s)=>({bundlePath:new URL("..//tcn.tar.gz",import.meta.url)}),a={name:"tcn",setup:t};export{a as tcn};
+import{i as e}from"../chunk-Y3AVQXKT.js";e();var t=async(n,s)=>({bundlePath:new URL("../tcn.tar.gz",import.meta.url)}),a={name:"tcn",setup:t};export{a as tcn};
 //# sourceMappingURL=tcn.js.map

dist/contrib/tsm_system_rows.d.ts

@@ -1,2 +0,2 @@
-import { a as PGliteInterface } from '../interface-BChI4DHV.js';
+import { a as PGliteInterface } from '../interface-B1Tuaggj.js';
 import '@electric-sql/pg-protocol/messages';
@@ -3,0 +3,0 @@ import '../types-XE-2t5ub.js';

dist/contrib/tsm_system_rows.js

@@ -1,2 +0,2 @@
-import{i as e}from"../chunk-Y3AVQXKT.js";e();var t=async(s,n)=>({bundlePath:new URL("..//tsm_system_rows.tar.gz",import.meta.url)}),o={name:"tsm_system_rows",setup:t};export{o as tsm_system_rows};
+import{i as e}from"../chunk-Y3AVQXKT.js";e();var t=async(s,n)=>({bundlePath:new URL("../tsm_system_rows.tar.gz",import.meta.url)}),o={name:"tsm_system_rows",setup:t};export{o as tsm_system_rows};
 //# sourceMappingURL=tsm_system_rows.js.map

dist/contrib/tsm_system_time.d.ts

@@ -1,2 +0,2 @@
-import { a as PGliteInterface } from '../interface-BChI4DHV.js';
+import { a as PGliteInterface } from '../interface-B1Tuaggj.js';
 import '@electric-sql/pg-protocol/messages';
@@ -3,0 +3,0 @@ import '../types-XE-2t5ub.js';

dist/contrib/tsm_system_time.js

@@ -1,2 +0,2 @@
-import{i as e}from"../chunk-Y3AVQXKT.js";e();var t=async(s,n)=>({bundlePath:new URL("..//tsm_system_time.tar.gz",import.meta.url)}),r={name:"tsm_system_time",setup:t};export{r as tsm_system_time};
+import{i as e}from"../chunk-Y3AVQXKT.js";e();var t=async(s,n)=>({bundlePath:new URL("../tsm_system_time.tar.gz",import.meta.url)}),r={name:"tsm_system_time",setup:t};export{r as tsm_system_time};
 //# sourceMappingURL=tsm_system_time.js.map

dist/contrib/uuid_ossp.d.ts

@@ -1,2 +0,2 @@
-import { a as PGliteInterface } from '../interface-BChI4DHV.js';
+import { a as PGliteInterface } from '../interface-B1Tuaggj.js';
 import '@electric-sql/pg-protocol/messages';
@@ -3,0 +3,0 @@ import '../types-XE-2t5ub.js';

dist/contrib/uuid_ossp.js

@@ -1,2 +0,2 @@
-import{i as e}from"../chunk-Y3AVQXKT.js";e();var t=async(s,n)=>({bundlePath:new URL("..//uuid-ossp.tar.gz",import.meta.url)}),o={name:"uuid-ossp",setup:t};export{o as uuid_ossp};
+import{i as e}from"../chunk-Y3AVQXKT.js";e();var t=async(s,n)=>({bundlePath:new URL("../uuid-ossp.tar.gz",import.meta.url)}),o={name:"uuid-ossp",setup:t};export{o as uuid_ossp};
 //# sourceMappingURL=uuid_ossp.js.map

dist/index.d.ts

@@ -1,4 +0,4 @@
-export { P as PGlite } from './pglite-Dh_uQEOE.js';
-import { P as ParserOptions, Q as QueryOptions, R as Results, a as PGliteInterface, T as Transaction } from './interface-BChI4DHV.js';
-export { D as DebugLevel, g as DumpDataDirResult, E as ExecProtocolOptions, e as Extension, d as ExtensionSetup, c as ExtensionSetupResult, f as Extensions, F as FilesystemType, i as PGliteInterfaceExtensions, h as PGliteOptions, j as Row, b as RowMode } from './interface-BChI4DHV.js';
+export { P as PGlite } from './pglite-CvYCdS0t.js';
+import { P as ParserOptions, Q as QueryOptions, R as Results, a as PGliteInterface, T as Transaction } from './interface-B1Tuaggj.js';
+export { D as DebugLevel, g as DumpDataDirResult, E as ExecProtocolOptions, e as Extension, d as ExtensionSetup, c as ExtensionSetupResult, f as Extensions, F as FilesystemType, i as PGliteInterfaceExtensions, h as PGliteOptions, j as Row, b as RowMode } from './interface-B1Tuaggj.js';
 import { BackendMessage } from '@electric-sql/pg-protocol/messages';
@@ -5,0 +5,0 @@ import * as messages from '@electric-sql/pg-protocol/messages';

dist/index.js

@@ -1,2 +0,2 @@
-import{b as Ge,d as se,e as Ce,f as We,g as X,h as G,i as ie,j as re}from"./chunk-SJVDOE3S.js";import{A as Q,B as Ae,C as $,D as Me,E as Y,F as Ve,G as Re,a as ze,b as je,c as ae,d as le,e as ce,f as de,g as ue,h as pe,i as fe,j as me,k as he,l as ye,m as ge,n as we,o as xe,p as be,q as C,r as ve,s as Ee,t as Pe,u as _e,v as Te,w as Fe,x as Se,y as W,z as De}from"./chunk-7M5G4I52.js";import"./chunk-TAZBUB4Z.js";import{a as ne,b as oe,c as Qe,d as $e}from"./chunk-3BCYDNSE.js";import{b as Le,c as qe,d as i,e as p,f,g as S,i as h}from"./chunk-Y3AVQXKT.js";h();h();h();var et=new Error("timeout while waiting for mutex to become available"),tt=new Error("mutex already locked"),Ke=new Error("request for lock canceled"),Xe=function(u,t,e,s){function d(r){return r instanceof e?r:new e(function(n){n(r)})}return new(e||(e=Promise))(function(r,n){function o(c){try{l(s.next(c))}catch(m){n(m)}}function a(c){try{l(s.throw(c))}catch(m){n(m)}}function l(c){c.done?r(c.value):d(c.value).then(o,a)}l((s=s.apply(u,t||[])).next())})},H=class{constructor(t,e=Ke){this._value=t,this._cancelError=e,this._weightedQueues=[],this._weightedWaiters=[]}acquire(t=1){if(t<=0)throw new Error(`invalid weight ${t}: must be positive`);return new Promise((e,s)=>{this._weightedQueues[t-1]||(this._weightedQueues[t-1]=[]),this._weightedQueues[t-1].push({resolve:e,reject:s}),this._dispatch()})}runExclusive(t,e=1){return Xe(this,void 0,void 0,function*(){let[s,d]=yield this.acquire(e);try{return yield t(s)}finally{d()}})}waitForUnlock(t=1){if(t<=0)throw new Error(`invalid weight ${t}: must be positive`);return new Promise(e=>{this._weightedWaiters[t-1]||(this._weightedWaiters[t-1]=[]),this._weightedWaiters[t-1].push(e),this._dispatch()})}isLocked(){return this._value<=0}getValue(){return this._value}setValue(t){this._value=t,this._dispatch()}release(t=1){if(t<=0)throw new Error(`invalid weight ${t}: must be positive`);this._value+=t,this._dispatch()}cancel(){this._weightedQueues.forEach(t=>t.forEach(e=>e.reject(this._cancelError))),this._weightedQueues=[]}_dispatch(){var t;for(let e=this._value;e>0;e--){let s=(t=this._weightedQueues[e-1])===null||t===void 0?void 0:t.shift();if(!s)continue;let d=this._value,r=e;this._value-=e,e=this._value+1,s.resolve([d,this._newReleaser(r)])}this._drainUnlockWaiters()}_newReleaser(t){let e=!1;return()=>{e||(e=!0,this.release(t))}}_drainUnlockWaiters(){for(let t=this._value;t>0;t--)this._weightedWaiters[t-1]&&(this._weightedWaiters[t-1].forEach(e=>e()),this._weightedWaiters[t-1]=[])}},Ye=function(u,t,e,s){function d(r){return r instanceof e?r:new e(function(n){n(r)})}return new(e||(e=Promise))(function(r,n){function o(c){try{l(s.next(c))}catch(m){n(m)}}function a(c){try{l(s.throw(c))}catch(m){n(m)}}function l(c){c.done?r(c.value):d(c.value).then(o,a)}l((s=s.apply(u,t||[])).next())})},E=class{constructor(t){this._semaphore=new H(1,t)}acquire(){return Ye(this,void 0,void 0,function*(){let[,t]=yield this._semaphore.acquire();return t})}runExclusive(t){return this._semaphore.runExclusive(()=>t())}isLocked(){return this._semaphore.isLocked()}waitForUnlock(){return this._semaphore.waitForUnlock()}release(){this._semaphore.isLocked()&&this._semaphore.release()}cancel(){return this._semaphore.cancel()}};h();import He from"./postgres.js";var Oe=He;h();var Ie=qe(Ge(),1);async function J(u){if(ne){let t=await import("fs"),e=await import("zlib"),{Writable:s}=await import("stream"),{pipeline:d}=await import("stream/promises");if(!t.existsSync(u))throw new Error(`Extension bundle not found: ${u}`);let r=e.createGunzip(),n=[];return await d(t.createReadStream(u),r,new s({write(o,a,l){n.push(o),l()}})),new Blob(n)}else{let t=await fetch(u.toString());if(!t.ok||!t.body)return null;if(t.headers.get("Content-Encoding")==="gzip")return t.blob();{let e=new DecompressionStream("gzip");return new Response(t.body.pipeThrough(e)).blob()}}}async function ke(u,t){for(let e in u.pg_extensions){let s;try{s=await u.pg_extensions[e]}catch(d){console.error("Failed to fetch extension:",e,d);continue}if(s){let d=new Uint8Array(await s.arrayBuffer());Je(u,e,d,t)}else console.error("Could not get binary data for extension:",e)}}function Je(u,t,e,s){Ie.default.untar(e).forEach(r=>{if(!r.name.startsWith(".")){let n=u.WASM_PREFIX+"/"+r.name;if(r.name.endsWith(".so")){let o=(...l)=>{s("pgfs:ext OK",n,l)},a=(...l)=>{s("pgfs:ext FAIL",n,l)};u.FS.createPreloadedFile(Ze(n),r.name.split("/").pop().slice(0,-3),r.data,!0,!0,o,a,!1)}else u.FS.writeFile(n,r.data)}})}function Ze(u){let t=u.lastIndexOf("/");return t>0?u.slice(0,t):u}var Be={};Le(Be,{AuthenticationCleartextPassword:()=>ye,AuthenticationMD5Password:()=>ge,AuthenticationOk:()=>he,AuthenticationSASL:()=>we,AuthenticationSASLContinue:()=>xe,AuthenticationSASLFinal:()=>be,BackendKeyDataMessage:()=>Se,CommandCompleteMessage:()=>Q,CopyDataMessage:()=>ve,CopyResponse:()=>Ee,DataRowMessage:()=>Ae,DatabaseError:()=>C,Field:()=>Pe,NoticeMessage:()=>$,NotificationResponseMessage:()=>W,ParameterDescriptionMessage:()=>Te,ParameterStatusMessage:()=>Fe,ReadyForQueryMessage:()=>De,RowDescriptionMessage:()=>_e,bindComplete:()=>le,closeComplete:()=>ce,copyDone:()=>me,emptyQuery:()=>fe,noData:()=>de,parseComplete:()=>ae,portalSuspended:()=>ue,replicationStart:()=>pe});h();var M,P,_,R,O,z,j,V,I,N,U,L,T,x,y,F,w,Ue,B,Z=class Z extends Re{constructor(e={},s={}){super();p(this,w);p(this,M,!1);p(this,P,!1);p(this,_,!1);p(this,R,!1);p(this,O,!1);p(this,z,new E);p(this,j,new E);p(this,V,new E);p(this,I,!1);this.debug=0;p(this,N);p(this,U,[]);p(this,L,new Y);p(this,T);p(this,x);p(this,y,new Map);p(this,F,new Set);typeof e=="string"?s={dataDir:e,...s}:s=e,this.dataDir=s.dataDir,s?.debug!==void 0&&(this.debug=s.debug),s?.relaxedDurability!==void 0&&f(this,O,s.relaxedDurability),f(this,N,s.extensions??{}),this.waitReady=S(this,w,Ue).call(this,s??{})}static async create(e,s){let d=typeof e=="string"?{dataDir:e,...s??{}}:e??{},r=new Z(d);return await r.waitReady,r}get Module(){return this.mod}get ready(){return i(this,M)&&!i(this,P)&&!i(this,_)}get closed(){return i(this,_)}async close(){await this._checkReady(),f(this,P,!0);for(let e of i(this,U))await e();try{await this.execProtocol(Me.end())}catch(e){let s=e;if(!(s.name==="ExitStatus"&&s.status===0))throw e}await this.fs.close(this.mod.FS),f(this,_,!0),f(this,P,!1)}async[Symbol.asyncDispose](){await this.close()}async _handleBlob(e){f(this,T,e?await e.arrayBuffer():void 0)}async _cleanupBlob(){f(this,T,void 0)}async _getWrittenBlob(){if(!i(this,x))return;let e=new Blob(i(this,x));return f(this,x,void 0),e}async _checkReady(){if(i(this,P))throw new Error("PGlite is closing");if(i(this,_))throw new Error("PGlite is closed");i(this,M)||await this.waitReady}async execProtocolRaw(e,{syncToFs:s=!0}={}){let d=e.length,r=this.mod;r._interactive_write(d),r.HEAPU8.set(e,1),r._interactive_one();let n=d+2,o=n+r._interactive_read(),a=r.HEAPU8.subarray(n,o);return s&&await this.syncToFs(),a}async execProtocol(e,{syncToFs:s=!0,onNotice:d}={}){let r=await this.execProtocolRaw(e,{syncToFs:s}),n=[];return i(this,L).parse(r,o=>{if(o instanceof C)throw f(this,L,new Y),o;if(o instanceof $)this.debug>0&&console.warn(o),d&&d(o);else if(o instanceof Q)switch(o.text){case"BEGIN":f(this,R,!0);break;case"COMMIT":case"ROLLBACK":f(this,R,!1);break}else if(o instanceof W){let a=i(this,y).get(o.channel);a&&a.forEach(l=>{queueMicrotask(()=>l(o.payload))}),i(this,F).forEach(l=>{queueMicrotask(()=>l(o.channel,o.payload))})}n.push([o,r])}),n}isInTransaction(){return i(this,R)}async syncToFs(){if(i(this,I))return;f(this,I,!0);let e=async()=>{await i(this,V).runExclusive(async()=>{f(this,I,!1),await this.fs.syncToFs(this.mod.FS,i(this,O))})};i(this,O)?e():await e()}async listen(e,s){return i(this,y).has(e)||i(this,y).set(e,new Set),i(this,y).get(e).add(s),await this.exec(`LISTEN ${e}`),async()=>{await this.unlisten(e,s)}}async unlisten(e,s){s?(i(this,y).get(e)?.delete(s),i(this,y).get(e)?.size===0&&(await this.exec(`UNLISTEN ${e}`),i(this,y).delete(e))):(await this.exec(`UNLISTEN ${e}`),i(this,y).delete(e))}onNotification(e){return i(this,F).add(e),()=>{i(this,F).delete(e)}}offNotification(e){i(this,F).delete(e)}async dumpDataDir(e){let s=this.dataDir?.split("/").pop()??"pgdata";return this.fs.dumpTar(this.mod.FS,s,e)}_runExclusiveQuery(e){return i(this,z).runExclusive(e)}_runExclusiveTransaction(e){return i(this,j).runExclusive(e)}};M=new WeakMap,P=new WeakMap,_=new WeakMap,R=new WeakMap,O=new WeakMap,z=new WeakMap,j=new WeakMap,V=new WeakMap,I=new WeakMap,N=new WeakMap,U=new WeakMap,L=new WeakMap,T=new WeakMap,x=new WeakMap,y=new WeakMap,F=new WeakMap,w=new WeakSet,Ue=async function(e){if(e.fs)this.fs=e.fs;else{let{dataDir:a,fsType:l}=ie(e.dataDir);this.fs=await re(a,l)}let s={},d=[],r=[`PGDATA=${G}`,`PREFIX=${X}`,`PGUSER=${e.username??"postgres"}`,`PGDATABASE=${e.database??"template1"}`,"MODE=REACT","REPL=N",...this.debug?["-d",this.debug.toString()]:[]],n={WASM_PREFIX:X,arguments:r,INITIAL_MEMORY:e.initialMemory,noExitRuntime:!0,...this.debug>0?{print:console.info,printErr:console.error}:{print:()=>{},printErr:()=>{}},locateFile:await oe(),preRun:[a=>{let l=a.FS.makedev(64,0),c={open:m=>{},close:m=>{},read:(m,k,b,v,g)=>{let ee=i(this,T);if(!ee)throw new Error("No /dev/blob File or Blob provided to read from");let K=new Uint8Array(ee);if(g>=K.length)return 0;let te=Math.min(K.length-g,v);for(let q=0;q<te;q++)k[b+q]=K[g+q];return te},write:(m,k,b,v,g)=>(i(this,x)??f(this,x,[]),i(this,x).push(k.slice(b,b+v)),v),llseek:(m,k,b)=>{let v=i(this,T);if(!v)throw new Error("No /dev/blob File or Blob provided to llseek");let g=k;if(b===1?g+=m.position:b===2&&(g=new Uint8Array(v).length),g<0)throw new a.FS.ErrnoError(28);return g}};a.FS.registerDevice(l,c),a.FS.mkdev("/dev/blob",l)}]};n=await this.fs.emscriptenOpts(n);for(let[a,l]of Object.entries(i(this,N)))if(l instanceof URL)s[a]=J(l);else{let c=await l.setup(this,n);if(c.emscriptenOpts&&(n=c.emscriptenOpts),c.namespaceObj){let m=this;m[a]=c.namespaceObj}c.bundlePath&&(s[a]=J(c.bundlePath)),c.init&&d.push(c.init),c.close&&i(this,U).push(c.close)}if(n.pg_extensions=s,this.mod=await Oe(n),await this.fs.initialSyncFs(this.mod.FS),e.loadDataDir){if(this.mod.FS.analyzePath(G+"/PG_VERSION").exists)throw new Error("Database already exists, cannot load from tarball");S(this,w,B).call(this,"pglite: loading data from tarball"),await se(this.mod.FS,e.loadDataDir)}this.mod.FS.analyzePath(G+"/PG_VERSION").exists?S(this,w,B).call(this,"pglite: found DB, resuming"):S(this,w,B).call(this,"pglite: no db"),await ke(this.mod,(...a)=>S(this,w,B).call(this,...a));let o=this.mod._pg_initdb();if(!o)throw new Error("INITDB failed to return value");if(o&1)throw new Error("INITDB failed");if(o&2){let a=e.username??"postgres",l=e.database??"template1";if(o&4){if(!(o&12))throw new Error("Invalid db/user combination")}else if(l!=="template1"&&a!=="postgres")throw new Error("INITDB created a new datadir, but an alternative db/user was requested")}await this.syncToFs(),f(this,M,!0),await this.exec("SET search_path TO public;");for(let a of d)await a()},B=function(...e){this.debug>0&&console.log(...e)};var Ne=Z;h();export{Ce as IdbFs,We as MemoryFS,E as Mutex,Ne as PGlite,$e as formatQuery,Be as messages,je as parse,Ve as protocol,ze as types,Qe as uuid};
+import{b as Ge,d as se,e as Ce,f as We,g as X,h as G,i as ie,j as re}from"./chunk-SJVDOE3S.js";import{A as Q,B as Ae,C as $,D as Me,E as Y,F as Ve,G as Re,a as ze,b as je,c as ae,d as le,e as ce,f as de,g as ue,h as pe,i as fe,j as me,k as he,l as ye,m as ge,n as we,o as xe,p as be,q as C,r as ve,s as Ee,t as Pe,u as _e,v as Te,w as Fe,x as Se,y as W,z as De}from"./chunk-7M5G4I52.js";import"./chunk-TAZBUB4Z.js";import{a as ne,b as oe,c as Qe,d as $e}from"./chunk-3BCYDNSE.js";import{b as Le,c as qe,d as r,e as p,f,g as S,i as h}from"./chunk-Y3AVQXKT.js";h();h();h();var et=new Error("timeout while waiting for mutex to become available"),tt=new Error("mutex already locked"),Ke=new Error("request for lock canceled"),Xe=function(d,t,e,s){function c(n){return n instanceof e?n:new e(function(a){a(n)})}return new(e||(e=Promise))(function(n,a){function u(o){try{l(s.next(o))}catch(m){a(m)}}function i(o){try{l(s.throw(o))}catch(m){a(m)}}function l(o){o.done?n(o.value):c(o.value).then(u,i)}l((s=s.apply(d,t||[])).next())})},H=class{constructor(t,e=Ke){this._value=t,this._cancelError=e,this._weightedQueues=[],this._weightedWaiters=[]}acquire(t=1){if(t<=0)throw new Error(`invalid weight ${t}: must be positive`);return new Promise((e,s)=>{this._weightedQueues[t-1]||(this._weightedQueues[t-1]=[]),this._weightedQueues[t-1].push({resolve:e,reject:s}),this._dispatch()})}runExclusive(t,e=1){return Xe(this,void 0,void 0,function*(){let[s,c]=yield this.acquire(e);try{return yield t(s)}finally{c()}})}waitForUnlock(t=1){if(t<=0)throw new Error(`invalid weight ${t}: must be positive`);return new Promise(e=>{this._weightedWaiters[t-1]||(this._weightedWaiters[t-1]=[]),this._weightedWaiters[t-1].push(e),this._dispatch()})}isLocked(){return this._value<=0}getValue(){return this._value}setValue(t){this._value=t,this._dispatch()}release(t=1){if(t<=0)throw new Error(`invalid weight ${t}: must be positive`);this._value+=t,this._dispatch()}cancel(){this._weightedQueues.forEach(t=>t.forEach(e=>e.reject(this._cancelError))),this._weightedQueues=[]}_dispatch(){var t;for(let e=this._value;e>0;e--){let s=(t=this._weightedQueues[e-1])===null||t===void 0?void 0:t.shift();if(!s)continue;let c=this._value,n=e;this._value-=e,e=this._value+1,s.resolve([c,this._newReleaser(n)])}this._drainUnlockWaiters()}_newReleaser(t){let e=!1;return()=>{e||(e=!0,this.release(t))}}_drainUnlockWaiters(){for(let t=this._value;t>0;t--)this._weightedWaiters[t-1]&&(this._weightedWaiters[t-1].forEach(e=>e()),this._weightedWaiters[t-1]=[])}},Ye=function(d,t,e,s){function c(n){return n instanceof e?n:new e(function(a){a(n)})}return new(e||(e=Promise))(function(n,a){function u(o){try{l(s.next(o))}catch(m){a(m)}}function i(o){try{l(s.throw(o))}catch(m){a(m)}}function l(o){o.done?n(o.value):c(o.value).then(u,i)}l((s=s.apply(d,t||[])).next())})},E=class{constructor(t){this._semaphore=new H(1,t)}acquire(){return Ye(this,void 0,void 0,function*(){let[,t]=yield this._semaphore.acquire();return t})}runExclusive(t){return this._semaphore.runExclusive(()=>t())}isLocked(){return this._semaphore.isLocked()}waitForUnlock(){return this._semaphore.waitForUnlock()}release(){this._semaphore.isLocked()&&this._semaphore.release()}cancel(){return this._semaphore.cancel()}};h();import He from"./postgres.js";var Oe=He;h();var Ie=qe(Ge(),1);async function J(d){if(ne){let t=await import("fs"),e=await import("zlib"),{Writable:s}=await import("stream"),{pipeline:c}=await import("stream/promises");if(!t.existsSync(d))throw new Error(`Extension bundle not found: ${d}`);let n=e.createGunzip(),a=[];return await c(t.createReadStream(d),n,new s({write(u,i,l){a.push(u),l()}})),new Blob(a)}else{let t=await fetch(d.toString());if(!t.ok||!t.body)return null;if(t.headers.get("Content-Encoding")==="gzip")return t.blob();{let e=new DecompressionStream("gzip");return new Response(t.body.pipeThrough(e)).blob()}}}async function ke(d,t){for(let e in d.pg_extensions){let s;try{s=await d.pg_extensions[e]}catch(c){console.error("Failed to fetch extension:",e,c);continue}if(s){let c=new Uint8Array(await s.arrayBuffer());Je(d,e,c,t)}else console.error("Could not get binary data for extension:",e)}}function Je(d,t,e,s){Ie.default.untar(e).forEach(n=>{if(!n.name.startsWith(".")){let a=d.WASM_PREFIX+"/"+n.name;if(n.name.endsWith(".so")){let u=(...l)=>{s("pgfs:ext OK",a,l)},i=(...l)=>{s("pgfs:ext FAIL",a,l)};d.FS.createPreloadedFile(Ze(a),n.name.split("/").pop().slice(0,-3),n.data,!0,!0,u,i,!1)}else d.FS.writeFile(a,n.data)}})}function Ze(d){let t=d.lastIndexOf("/");return t>0?d.slice(0,t):d}var Be={};Le(Be,{AuthenticationCleartextPassword:()=>ye,AuthenticationMD5Password:()=>ge,AuthenticationOk:()=>he,AuthenticationSASL:()=>we,AuthenticationSASLContinue:()=>xe,AuthenticationSASLFinal:()=>be,BackendKeyDataMessage:()=>Se,CommandCompleteMessage:()=>Q,CopyDataMessage:()=>ve,CopyResponse:()=>Ee,DataRowMessage:()=>Ae,DatabaseError:()=>C,Field:()=>Pe,NoticeMessage:()=>$,NotificationResponseMessage:()=>W,ParameterDescriptionMessage:()=>Te,ParameterStatusMessage:()=>Fe,ReadyForQueryMessage:()=>De,RowDescriptionMessage:()=>_e,bindComplete:()=>le,closeComplete:()=>ce,copyDone:()=>me,emptyQuery:()=>fe,noData:()=>de,parseComplete:()=>ae,portalSuspended:()=>ue,replicationStart:()=>pe});h();var M,P,_,R,O,z,j,V,I,N,U,L,T,x,y,F,w,Ue,B,Z=class Z extends Re{constructor(e={},s={}){super();p(this,w);p(this,M,!1);p(this,P,!1);p(this,_,!1);p(this,R,!1);p(this,O,!1);p(this,z,new E);p(this,j,new E);p(this,V,new E);p(this,I,!1);this.debug=0;p(this,N);p(this,U,[]);p(this,L,new Y);p(this,T);p(this,x);p(this,y,new Map);p(this,F,new Set);typeof e=="string"?s={dataDir:e,...s}:s=e,this.dataDir=s.dataDir,s?.debug!==void 0&&(this.debug=s.debug),s?.relaxedDurability!==void 0&&f(this,O,s.relaxedDurability),f(this,N,s.extensions??{}),this.waitReady=S(this,w,Ue).call(this,s??{})}static async create(e,s){let c=typeof e=="string"?{dataDir:e,...s??{}}:e??{},n=new Z(c);return await n.waitReady,n}get Module(){return this.mod}get ready(){return r(this,M)&&!r(this,P)&&!r(this,_)}get closed(){return r(this,_)}async close(){await this._checkReady(),f(this,P,!0);for(let e of r(this,U))await e();try{await this.execProtocol(Me.end())}catch(e){let s=e;if(!(s.name==="ExitStatus"&&s.status===0))throw e}await this.fs.close(this.mod.FS),f(this,_,!0),f(this,P,!1)}async[Symbol.asyncDispose](){await this.close()}async _handleBlob(e){f(this,T,e?await e.arrayBuffer():void 0)}async _cleanupBlob(){f(this,T,void 0)}async _getWrittenBlob(){if(!r(this,x))return;let e=new Blob(r(this,x));return f(this,x,void 0),e}async _checkReady(){if(r(this,P))throw new Error("PGlite is closing");if(r(this,_))throw new Error("PGlite is closed");r(this,M)||await this.waitReady}async execProtocolRaw(e,{syncToFs:s=!0}={}){let c=e.length,n=this.mod;n._interactive_write(c),n.HEAPU8.set(e,1),n._interactive_one();let a=c+2,u=a+n._interactive_read(),i=n.HEAPU8.subarray(a,u);return s&&await this.syncToFs(),i}async execProtocol(e,{syncToFs:s=!0,throwOnError:c=!0,onNotice:n}={}){let a=await this.execProtocolRaw(e,{syncToFs:s}),u=[];return r(this,L).parse(a,i=>{if(i instanceof C){if(f(this,L,new Y),c)throw i}else if(i instanceof $)this.debug>0&&console.warn(i),n&&n(i);else if(i instanceof Q)switch(i.text){case"BEGIN":f(this,R,!0);break;case"COMMIT":case"ROLLBACK":f(this,R,!1);break}else if(i instanceof W){let l=r(this,y).get(i.channel);l&&l.forEach(o=>{queueMicrotask(()=>o(i.payload))}),r(this,F).forEach(o=>{queueMicrotask(()=>o(i.channel,i.payload))})}u.push([i,a])}),u}isInTransaction(){return r(this,R)}async syncToFs(){if(r(this,I))return;f(this,I,!0);let e=async()=>{await r(this,V).runExclusive(async()=>{f(this,I,!1),await this.fs.syncToFs(this.mod.FS,r(this,O))})};r(this,O)?e():await e()}async listen(e,s){return r(this,y).has(e)||r(this,y).set(e,new Set),r(this,y).get(e).add(s),await this.exec(`LISTEN ${e}`),async()=>{await this.unlisten(e,s)}}async unlisten(e,s){s?(r(this,y).get(e)?.delete(s),r(this,y).get(e)?.size===0&&(await this.exec(`UNLISTEN ${e}`),r(this,y).delete(e))):(await this.exec(`UNLISTEN ${e}`),r(this,y).delete(e))}onNotification(e){return r(this,F).add(e),()=>{r(this,F).delete(e)}}offNotification(e){r(this,F).delete(e)}async dumpDataDir(e){let s=this.dataDir?.split("/").pop()??"pgdata";return this.fs.dumpTar(this.mod.FS,s,e)}_runExclusiveQuery(e){return r(this,z).runExclusive(e)}_runExclusiveTransaction(e){return r(this,j).runExclusive(e)}};M=new WeakMap,P=new WeakMap,_=new WeakMap,R=new WeakMap,O=new WeakMap,z=new WeakMap,j=new WeakMap,V=new WeakMap,I=new WeakMap,N=new WeakMap,U=new WeakMap,L=new WeakMap,T=new WeakMap,x=new WeakMap,y=new WeakMap,F=new WeakMap,w=new WeakSet,Ue=async function(e){if(e.fs)this.fs=e.fs;else{let{dataDir:i,fsType:l}=ie(e.dataDir);this.fs=await re(i,l)}let s={},c=[],n=[`PGDATA=${G}`,`PREFIX=${X}`,`PGUSER=${e.username??"postgres"}`,`PGDATABASE=${e.database??"template1"}`,"MODE=REACT","REPL=N",...this.debug?["-d",this.debug.toString()]:[]],a={WASM_PREFIX:X,arguments:n,INITIAL_MEMORY:e.initialMemory,noExitRuntime:!0,...this.debug>0?{print:console.info,printErr:console.error}:{print:()=>{},printErr:()=>{}},locateFile:await oe(),preRun:[i=>{let l=i.FS.makedev(64,0),o={open:m=>{},close:m=>{},read:(m,k,b,v,g)=>{let ee=r(this,T);if(!ee)throw new Error("No /dev/blob File or Blob provided to read from");let K=new Uint8Array(ee);if(g>=K.length)return 0;let te=Math.min(K.length-g,v);for(let q=0;q<te;q++)k[b+q]=K[g+q];return te},write:(m,k,b,v,g)=>(r(this,x)??f(this,x,[]),r(this,x).push(k.slice(b,b+v)),v),llseek:(m,k,b)=>{let v=r(this,T);if(!v)throw new Error("No /dev/blob File or Blob provided to llseek");let g=k;if(b===1?g+=m.position:b===2&&(g=new Uint8Array(v).length),g<0)throw new i.FS.ErrnoError(28);return g}};i.FS.registerDevice(l,o),i.FS.mkdev("/dev/blob",l)}]};a=await this.fs.emscriptenOpts(a);for(let[i,l]of Object.entries(r(this,N)))if(l instanceof URL)s[i]=J(l);else{let o=await l.setup(this,a);if(o.emscriptenOpts&&(a=o.emscriptenOpts),o.namespaceObj){let m=this;m[i]=o.namespaceObj}o.bundlePath&&(s[i]=J(o.bundlePath)),o.init&&c.push(o.init),o.close&&r(this,U).push(o.close)}if(a.pg_extensions=s,this.mod=await Oe(a),await this.fs.initialSyncFs(this.mod.FS),e.loadDataDir){if(this.mod.FS.analyzePath(G+"/PG_VERSION").exists)throw new Error("Database already exists, cannot load from tarball");S(this,w,B).call(this,"pglite: loading data from tarball"),await se(this.mod.FS,e.loadDataDir)}this.mod.FS.analyzePath(G+"/PG_VERSION").exists?S(this,w,B).call(this,"pglite: found DB, resuming"):S(this,w,B).call(this,"pglite: no db"),await ke(this.mod,(...i)=>S(this,w,B).call(this,...i));let u=this.mod._pg_initdb();if(!u)throw new Error("INITDB failed to return value");if(u&1)throw new Error("INITDB failed");if(u&2){let i=e.username??"postgres",l=e.database??"template1";if(u&4){if(!(u&12))throw new Error("Invalid db/user combination")}else if(l!=="template1"&&i!=="postgres")throw new Error("INITDB created a new datadir, but an alternative db/user was requested")}await this.syncToFs(),f(this,M,!0),await this.exec("SET search_path TO public;");for(let i of c)await i()},B=function(...e){this.debug>0&&console.log(...e)};var Ne=Z;h();export{Ce as IdbFs,We as MemoryFS,E as Mutex,Ne as PGlite,$e as formatQuery,Be as messages,je as parse,Ve as protocol,ze as types,Qe as uuid};
 //# sourceMappingURL=index.js.map

dist/live/index.d.ts

@@ -1,2 +0,2 @@
-import { R as Results, a as PGliteInterface } from '../interface-BChI4DHV.js';
+import { R as Results, a as PGliteInterface } from '../interface-B1Tuaggj.js';
 import '@electric-sql/pg-protocol/messages';
@@ -3,0 +3,0 @@ import '../types-XE-2t5ub.js';

dist/vector/index.d.ts

@@ -1,2 +0,2 @@
-import { a as PGliteInterface } from '../interface-BChI4DHV.js';
+import { a as PGliteInterface } from '../interface-B1Tuaggj.js';
 import '@electric-sql/pg-protocol/messages';
@@ -3,0 +3,0 @@ import '../types-XE-2t5ub.js';

dist/vector/index.js

@@ -1,2 +0,2 @@
-import{i as e}from"../chunk-Y3AVQXKT.js";e();var n=async(s,t)=>({emscriptenOpts:t,bundlePath:new URL("..//vector.tar.gz",import.meta.url)}),o={name:"pgvector",setup:n};export{o as vector};
+import{i as e}from"../chunk-Y3AVQXKT.js";e();var n=async(s,t)=>({emscriptenOpts:t,bundlePath:new URL("../vector.tar.gz",import.meta.url)}),o={name:"pgvector",setup:n};export{o as vector};
 //# sourceMappingURL=index.js.map

dist/worker/index.d.ts

@@ -1,3 +0,3 @@
-import { h as PGliteOptions, a as PGliteInterface, i as PGliteInterfaceExtensions, D as DebugLevel } from '../interface-BChI4DHV.js';
-import { B as BasePGlite, P as PGlite } from '../pglite-Dh_uQEOE.js';
+import { h as PGliteOptions, a as PGliteInterface, i as PGliteInterfaceExtensions, D as DebugLevel } from '../interface-B1Tuaggj.js';
+import { B as BasePGlite, P as PGlite } from '../pglite-CvYCdS0t.js';
 import { BackendMessage } from '@electric-sql/pg-protocol/messages';
@@ -4,0 +4,0 @@ import '../types-XE-2t5ub.js';

package.json

 {
   "name": "@electric-sql/pglite",
-  "version": "0.2.6",
+  "version": "0.2.7",
   "private": false,
@@ -102,4 +102,4 @@ "publishConfig": {
     "test": "pnpm test:basic && pnpm test:node",
-    "test:basic": "pnpm test:clean && vitest tests/*.test.js tests/**/*.test.js",
-    "test:web": "pnpm test:clean && concurrently -s first --hide 1 --prefix none -k \"sleep 2 && vitest --fileParallelism false tests/targets/web/*.test.web.js\" \"npx http-server --port 3334 ./\"",
+    "test:basic": "pnpm test:clean && vitest tests/*.test.js tests/*.test.ts tests/**/*.test.js tests/**/*.test.ts",
+    "test:web": "pnpm test:clean && concurrently -s first --hide 1 --prefix none -k \"sleep 2 && vitest --fileParallelism false tests/targets/web/*.test.web.*\" \"npx http-server --port 3334 ./\"",
     "test:bun": "pnpm test:clean && pnpm bun test --timeout 15000 tests/basic.test.js tests/pgvector.test.js tests/live.test.js tests/targets/runtimes/node-fs.test.js",
@@ -106,0 +106,0 @@ "test:deno": "cd tests/targets/deno && deno task test",

New alerts

License Policy Violation

License

This package is not allowed per your license policy. Review the package's license to ensure compliance.

Found 1 instance in 1 package

Fixed alerts

License Policy Violation

License

This package is not allowed per your license policy. Review the package's license to ensure compliance.

Found 1 instance in 1 package

Improved metrics

Total package byte prevSize

16987458

Lines of code

15104

increased by0.01%

No dependency changes