🎩 You're Invited:Meet the Socket team at Black Hat in Las Vegas, August 3-6.RSVP →

datastore-core

Advanced tools

License

Install Socket

Detect and block malicious and high-risk dependencies

Install

datastore-core - npm Package Compare versions

Comparing version

11.0.4

12.0.0

+5

-5

dist/index.min.js

		(function (root, factory) {(typeof module === 'object' && module.exports) ? module.exports = factory() : root.DatastoreCore = factory()}(typeof self !== 'undefined' ? self : this, function () {
		"use strict";var DatastoreCore=(()=>{var Ie=Object.defineProperty;var jt=Object.getOwnPropertyDescriptor;var Bt=Object.getOwnPropertyNames;var Vt=Object.prototype.hasOwnProperty;var S=(r,e)=>{for(var t in e)Ie(r,t,{get:e[t],enumerable:!0})},Jt=(r,e,t,n)=>{if(e&&typeof e=="object"\|\|typeof e=="function")for(let o of Bt(e))!Vt.call(r,o)&&o!==t&&Ie(r,o,{get:()=>e[o],enumerable:!(n=jt(e,o))\|\|n.enumerable});return r};var Wt=r=>Jt(Ie({},"__esModule",{value:!0}),r);var Bn={};S(Bn,{BaseDatastore:()=>E,KeyTransformDatastore:()=>P,MemoryDatastore:()=>ge,MountDatastore:()=>Ce,NamespaceDatastore:()=>Fe,ShardingDatastore:()=>ve,TieredDatastore:()=>Ae,shard:()=>Qe});var Qe={};S(Qe,{NextToLast:()=>fe,PREFIX:()=>ce,Prefix:()=>ue,SHARDING_FN:()=>he,ShardBase:()=>G,Suffix:()=>le,parseShardFun:()=>kt,readShardFun:()=>de});var Le={};S(Le,{base10:()=>Yt});var Jn=new Uint8Array(0);function st(r,e){if(r===e)return!0;if(r.byteLength!==e.byteLength)return!1;for(let t=0;t<r.byteLength;t++)if(r[t]!==e[t])return!1;return!0}function M(r){if(r instanceof Uint8Array&&r.constructor.name==="Uint8Array")return r;if(r instanceof ArrayBuffer)return new Uint8Array(r);if(ArrayBuffer.isView(r))return new Uint8Array(r.buffer,r.byteOffset,r.byteLength);throw new Error("Unknown type, must be binary type")}function it(r){return new TextEncoder().encode(r)}function at(r){return new TextDecoder().decode(r)}function Gt(r,e){if(r.length>=255)throw new TypeError("Alphabet too long");for(var t=new Uint8Array(256),n=0;n<t.length;n++)t[n]=255;for(var o=0;o<r.length;o++){var s=r.charAt(o),i=s.charCodeAt(0);if(t[i]!==255)throw new TypeError(s+" is ambiguous");t[i]=o}var a=r.length,h=r.charAt(0),F=Math.log(a)/Math.log(256),c=Math.log(256)/Math.log(a);function l(d){if(d instanceof Uint8Array\|\|(ArrayBuffer.isView(d)?d=new Uint8Array(d.buffer,d.byteOffset,d.byteLength):Array.isArray(d)&&(d=Uint8Array.from(d))),!(d instanceof Uint8Array))throw new TypeError("Expected Uint8Array");if(d.length===0)return"";for(var m=0,u=0,f=0,y=d.length;f!==y&&d[f]===0;)f++,m++;for(var b=(y-f)c+1>>>0,x=new Uint8Array(b);f!==y;){for(var w=d[f],L=0,v=b-1;(w!==0\|\|L<u)&&v!==-1;v--,L++)w+=256x[v]>>>0,x[v]=w%a>>>0,w=w/a>>>0;if(w!==0)throw new Error("Non-zero carry");u=L,f++}for(var $=b-u;$!==b&&x[$]===0;)$++;for(var _=h.repeat(m);$<b;++$)_+=r.charAt(x[$]);return _}function p(d){if(typeof d!="string")throw new TypeError("Expected String");if(d.length===0)return new Uint8Array;var m=0;if(d[m]!==" "){for(var u=0,f=0;d[m]===h;)u++,m++;for(var y=(d.length-m)F+1>>>0,b=new Uint8Array(y);d[m];){var x=t[d.charCodeAt(m)];if(x===255)return;for(var w=0,L=y-1;(x!==0\|\|w<f)&&L!==-1;L--,w++)x+=ab[L]>>>0,b[L]=x%256>>>0,x=x/256>>>0;if(x!==0)throw new Error("Non-zero carry");f=w,m++}if(d[m]!==" "){for(var v=y-f;v!==y&&b[v]===0;)v++;for(var $=new Uint8Array(u+(y-v)),_=u;v!==y;)$[_++]=b[v++];return $}}}function k(d){var m=p(d);if(m)return m;throw new Error(`Non-${e} character`)}return{encode:l,decodeUnsafe:p,decode:k}}var qt=Gt,Ht=qt,ut=Ht;var De=class{name;prefix;baseEncode;constructor(e,t,n){this.name=e,this.prefix=t,this.baseEncode=n}encode(e){if(e instanceof Uint8Array)return`${this.prefix}${this.baseEncode(e)}`;throw Error("Unknown type, must be binary type")}},Ne=class{name;prefix;baseDecode;prefixCodePoint;constructor(e,t,n){this.name=e,this.prefix=t;let o=t.codePointAt(0);if(o===void 0)throw new Error("Invalid prefix character");this.prefixCodePoint=o,this.baseDecode=n}decode(e){if(typeof e=="string"){if(e.codePointAt(0)!==this.prefixCodePoint)throw Error(`Unable to decode multibase string ${JSON.stringify(e)}, ${this.name} decoder only supports inputs prefixed with ${this.prefix}`);return this.baseDecode(e.slice(this.prefix.length))}else throw Error("Can only multibase decode strings")}or(e){return lt(this,e)}},$e=class{decoders;constructor(e){this.decoders=e}or(e){return lt(this,e)}decode(e){let t=e[0],n=this.decoders[t];if(n!=null)return n.decode(e);throw RangeError(`Unable to decode multibase string ${JSON.stringify(e)}, only inputs prefixed with ${Object.keys(this.decoders)} are supported`)}};function lt(r,e){return new $e({...r.decoders??{[r.prefix]:r},...e.decoders??{[e.prefix]:e}})}var ke=class{name;prefix;baseEncode;baseDecode;encoder;decoder;constructor(e,t,n,o){this.name=e,this.prefix=t,this.baseEncode=n,this.baseDecode=o,this.encoder=new De(e,t,n),this.decoder=new Ne(e,t,o)}encode(e){return this.encoder.encode(e)}decode(e){return this.decoder.decode(e)}};function j({name:r,prefix:e,encode:t,decode:n}){return new ke(r,e,t,n)}function O({name:r,prefix:e,alphabet:t}){let{encode:n,decode:o}=ut(t,r);return j({prefix:e,name:r,encode:n,decode:s=>M(o(s))})}function Xt(r,e,t,n){let o=r.length;for(;r[o-1]==="=";)--o;let s=new Uint8Array(ot/8\|0),i=0,a=0,h=0;for(let F=0;F<o;++F){let c=e[r[F]];if(c===void 0)throw new SyntaxError(`Non-${n} character`);a=a<<t\|c,i+=t,i>=8&&(i-=8,s[h++]=255&a>>i)}if(i>=t\|\|(255&a<<8-i)!==0)throw new SyntaxError("Unexpected end of data");return s}function Qt(r,e,t){let n=e[e.length-1]==="=",o=(1<<t)-1,s="",i=0,a=0;for(let h=0;h<r.length;++h)for(a=a<<8\|r[h],i+=8;i>t;)i-=t,s+=e[o&a>>i];if(i!==0&&(s+=e[o&a<<t-i]),n)for(;(s.lengtht&7)!==0;)s+="=";return s}function Zt(r){let e={};for(let t=0;t<r.length;++t)e[r[t]]=t;return e}function g({name:r,prefix:e,bitsPerChar:t,alphabet:n}){let o=Zt(n);return j({prefix:e,name:r,encode(s){return Qt(s,n,t)},decode(s){return Xt(s,o,t,r)}})}var Yt=O({prefix:"9",name:"base10",alphabet:"0123456789"});var Me={};S(Me,{base16:()=>er,base16upper:()=>tr});var er=g({prefix:"f",name:"base16",alphabet:"0123456789abcdef",bitsPerChar:4}),tr=g({prefix:"F",name:"base16upper",alphabet:"0123456789ABCDEF",bitsPerChar:4});var Ue={};S(Ue,{base2:()=>rr});var rr=g({prefix:"0",name:"base2",alphabet:"01",bitsPerChar:1});var Re={};S(Re,{base256emoji:()=>ar});var ft=Array.from("\u{1F680}\u{1FA90}\u2604\u{1F6F0}\u{1F30C}\u{1F311}\u{1F312}\u{1F313}\u{1F314}\u{1F315}\u{1F316}\u{1F317}\u{1F318}\u{1F30D}\u{1F30F}\u{1F30E}\u{1F409}\u2600\u{1F4BB}\u{1F5A5}\u{1F4BE}\u{1F4BF}\u{1F602}\u2764\u{1F60D}\u{1F923}\u{1F60A}\u{1F64F}\u{1F495}\u{1F62D}\u{1F618}\u{1F44D}\u{1F605}\u{1F44F}\u{1F601}\u{1F525}\u{1F970}\u{1F494}\u{1F496}\u{1F499}\u{1F622}\u{1F914}\u{1F606}\u{1F644}\u{1F4AA}\u{1F609}\u263A\u{1F44C}\u{1F917}\u{1F49C}\u{1F614}\u{1F60E}\u{1F607}\u{1F339}\u{1F926}\u{1F389}\u{1F49E}\u270C\u2728\u{1F937}\u{1F631}\u{1F60C}\u{1F338}\u{1F64C}\u{1F60B}\u{1F497}\u{1F49A}\u{1F60F}\u{1F49B}\u{1F642}\u{1F493}\u{1F929}\u{1F604}\u{1F600}\u{1F5A4}\u{1F603}\u{1F4AF}\u{1F648}\u{1F447}\u{1F3B6}\u{1F612}\u{1F92D}\u2763\u{1F61C}\u{1F48B}\u{1F440}\u{1F62A}\u{1F611}\u{1F4A5}\u{1F64B}\u{1F61E}\u{1F629}\u{1F621}\u{1F92A}\u{1F44A}\u{1F973}\u{1F625}\u{1F924}\u{1F449}\u{1F483}\u{1F633}\u270B\u{1F61A}\u{1F61D}\u{1F634}\u{1F31F}\u{1F62C}\u{1F643}\u{1F340}\u{1F337}\u{1F63B}\u{1F613}\u2B50\u2705\u{1F97A}\u{1F308}\u{1F608}\u{1F918}\u{1F4A6}\u2714\u{1F623}\u{1F3C3}\u{1F490}\u2639\u{1F38A}\u{1F498}\u{1F620}\u261D\u{1F615}\u{1F33A}\u{1F382}\u{1F33B}\u{1F610}\u{1F595}\u{1F49D}\u{1F64A}\u{1F639}\u{1F5E3}\u{1F4AB}\u{1F480}\u{1F451}\u{1F3B5}\u{1F91E}\u{1F61B}\u{1F534}\u{1F624}\u{1F33C}\u{1F62B}\u26BD\u{1F919}\u2615\u{1F3C6}\u{1F92B}\u{1F448}\u{1F62E}\u{1F646}\u{1F37B}\u{1F343}\u{1F436}\u{1F481}\u{1F632}\u{1F33F}\u{1F9E1}\u{1F381}\u26A1\u{1F31E}\u{1F388}\u274C\u270A\u{1F44B}\u{1F630}\u{1F928}\u{1F636}\u{1F91D}\u{1F6B6}\u{1F4B0}\u{1F353}\u{1F4A2}\u{1F91F}\u{1F641}\u{1F6A8}\u{1F4A8}\u{1F92C}\u2708\u{1F380}\u{1F37A}\u{1F913}\u{1F619}\u{1F49F}\u{1F331}\u{1F616}\u{1F476}\u{1F974}\u25B6\u27A1\u2753\u{1F48E}\u{1F4B8}\u2B07\u{1F628}\u{1F31A}\u{1F98B}\u{1F637}\u{1F57A}\u26A0\u{1F645}\u{1F61F}\u{1F635}\u{1F44E}\u{1F932}\u{1F920}\u{1F927}\u{1F4CC}\u{1F535}\u{1F485}\u{1F9D0}\u{1F43E}\u{1F352}\u{1F617}\u{1F911}\u{1F30A}\u{1F92F}\u{1F437}\u260E\u{1F4A7}\u{1F62F}\u{1F486}\u{1F446}\u{1F3A4}\u{1F647}\u{1F351}\u2744\u{1F334}\u{1F4A3}\u{1F438}\u{1F48C}\u{1F4CD}\u{1F940}\u{1F922}\u{1F445}\u{1F4A1}\u{1F4A9}\u{1F450}\u{1F4F8}\u{1F47B}\u{1F910}\u{1F92E}\u{1F3BC}\u{1F975}\u{1F6A9}\u{1F34E}\u{1F34A}\u{1F47C}\u{1F48D}\u{1F4E3}\u{1F942}"),nr=ft.reduce((r,e,t)=>(r[t]=e,r),[]),or=ft.reduce((r,e,t)=>{let n=e.codePointAt(0);if(n==null)throw new Error(`Invalid character: ${e}`);return r[n]=t,r},[]);function sr(r){return r.reduce((e,t)=>(e+=nr[t],e),"")}function ir(r){let e=[];for(let t of r){let n=t.codePointAt(0);if(n==null)throw new Error(`Invalid character: ${t}`);let o=or[n];if(o==null)throw new Error(`Non-base256emoji character: ${t}`);e.push(o)}return new Uint8Array(e)}var ar=j({prefix:"\u{1F680}",name:"base256emoji",encode:sr,decode:ir});var Oe={};S(Oe,{base32:()=>T,base32hex:()=>fr,base32hexpad:()=>dr,base32hexpadupper:()=>pr,base32hexupper:()=>hr,base32pad:()=>ur,base32padupper:()=>lr,base32upper:()=>cr,base32z:()=>mr});var T=g({prefix:"b",name:"base32",alphabet:"abcdefghijklmnopqrstuvwxyz234567",bitsPerChar:5}),cr=g({prefix:"B",name:"base32upper",alphabet:"ABCDEFGHIJKLMNOPQRSTUVWXYZ234567",bitsPerChar:5}),ur=g({prefix:"c",name:"base32pad",alphabet:"abcdefghijklmnopqrstuvwxyz234567=",bitsPerChar:5}),lr=g({prefix:"C",name:"base32padupper",alphabet:"ABCDEFGHIJKLMNOPQRSTUVWXYZ234567=",bitsPerChar:5}),fr=g({prefix:"v",name:"base32hex",alphabet:"0123456789abcdefghijklmnopqrstuv",bitsPerChar:5}),hr=g({prefix:"V",name:"base32hexupper",alphabet:"0123456789ABCDEFGHIJKLMNOPQRSTUV",bitsPerChar:5}),dr=g({prefix:"t",name:"base32hexpad",alphabet:"0123456789abcdefghijklmnopqrstuv=",bitsPerChar:5}),pr=g({prefix:"T",name:"base32hexpadupper",alphabet:"0123456789ABCDEFGHIJKLMNOPQRSTUV=",bitsPerChar:5}),mr=g({prefix:"h",name:"base32z",alphabet:"ybndrfg8ejkmcpqxot1uwisza345h769",bitsPerChar:5});var Te={};S(Te,{base36:()=>Z,base36upper:()=>yr});var Z=O({prefix:"k",name:"base36",alphabet:"0123456789abcdefghijklmnopqrstuvwxyz"}),yr=O({prefix:"K",name:"base36upper",alphabet:"0123456789ABCDEFGHIJKLMNOPQRSTUVWXYZ"});var ze={};S(ze,{base58btc:()=>I,base58flickr:()=>br});var I=O({name:"base58btc",prefix:"z",alphabet:"123456789ABCDEFGHJKLMNPQRSTUVWXYZabcdefghijkmnopqrstuvwxyz"}),br=O({name:"base58flickr",prefix:"Z",alphabet:"123456789abcdefghijkmnopqrstuvwxyzABCDEFGHJKLMNPQRSTUVWXYZ"});var _e={};S(_e,{base64:()=>Pe,base64pad:()=>gr,base64url:()=>wr,base64urlpad:()=>xr});var Pe=g({prefix:"m",name:"base64",alphabet:"ABCDEFGHIJKLMNOPQRSTUVWXYZabcdefghijklmnopqrstuvwxyz0123456789+/",bitsPerChar:6}),gr=g({prefix:"M",name:"base64pad",alphabet:"ABCDEFGHIJKLMNOPQRSTUVWXYZabcdefghijklmnopqrstuvwxyz0123456789+/=",bitsPerChar:6}),wr=g({prefix:"u",name:"base64url",alphabet:"ABCDEFGHIJKLMNOPQRSTUVWXYZabcdefghijklmnopqrstuvwxyz0123456789-_",bitsPerChar:6}),xr=g({prefix:"U",name:"base64urlpad",alphabet:"ABCDEFGHIJKLMNOPQRSTUVWXYZabcdefghijklmnopqrstuvwxyz0123456789-_=",bitsPerChar:6});var Ke={};S(Ke,{base8:()=>vr});var vr=g({prefix:"7",name:"base8",alphabet:"01234567",bitsPerChar:3});var je={};S(je,{identity:()=>Cr});var Cr=j({prefix:"\0",name:"identity",encode:r=>at(r),decode:r=>it(r)});var ao=new TextEncoder,co=new TextDecoder;var Ve={};S(Ve,{identity:()=>Jr});var Ar=pt,ht=128,Fr=127,Ir=~Fr,Dr=Math.pow(2,31);function pt(r,e,t){e=e\|\|[],t=t\|\|0;for(var n=t;r>=Dr;)e[t++]=r&255\|ht,r/=128;for(;r&Ir;)e[t++]=r&255\|ht,r>>>=7;return e[t]=r\|0,pt.bytes=t-n+1,e}var Nr=Be,$r=128,dt=127;function Be(r,n){var t=0,n=n\|\|0,o=0,s=n,i,a=r.length;do{if(s>=a)throw Be.bytes=0,new RangeError("Could not decode varint");i=r[s++],t+=o<28?(i&dt)<<o:(i&dt)Math.pow(2,o),o+=7}while(i>=$r);return Be.bytes=s-n,t}var kr=Math.pow(2,7),Lr=Math.pow(2,14),Mr=Math.pow(2,21),Ur=Math.pow(2,28),Rr=Math.pow(2,35),Or=Math.pow(2,42),Tr=Math.pow(2,49),zr=Math.pow(2,56),Pr=Math.pow(2,63),_r=function(r){return r<kr?1:r<Lr?2:r<Mr?3:r<Ur?4:r<Rr?5:r<Or?6:r<Tr?7:r<zr?8:r<Pr?9:10},Kr={encode:Ar,decode:Nr,encodingLength:_r},jr=Kr,Y=jr;function ee(r,e=0){return[Y.decode(r,e),Y.decode.bytes]}function B(r,e,t=0){return Y.encode(r,e,t),e}function V(r){return Y.encodingLength(r)}function W(r,e){let t=e.byteLength,n=V(r),o=n+V(t),s=new Uint8Array(o+t);return B(r,s,0),B(t,s,n),s.set(e,o),new J(r,t,e,s)}function mt(r){let e=M(r),[t,n]=ee(e),[o,s]=ee(e.subarray(n)),i=e.subarray(n+s);if(i.byteLength!==o)throw new Error("Incorrect length");return new J(t,o,i,e)}function yt(r,e){if(r===e)return!0;{let t=e;return r.code===t.code&&r.size===t.size&&t.bytes instanceof Uint8Array&&st(r.bytes,t.bytes)}}var J=class{code;size;digest;bytes;constructor(e,t,n,o){this.code=e,this.size=t,this.digest=n,this.bytes=o}};var bt=0,Br="identity",gt=M;function Vr(r,e){if(e?.truncate!=null&&e.truncate!==r.byteLength){if(e.truncate<0\|\|e.truncate>r.byteLength)throw new Error(`Invalid truncate option, must be less than or equal to ${r.byteLength}`);r=r.subarray(0,e.truncate)}return W(bt,gt(r))}var Jr={code:bt,name:Br,encode:gt,digest:Vr};var Ge={};S(Ge,{sha256:()=>Gr,sha512:()=>qr});var Wr=20;function We({name:r,code:e,encode:t,minDigestLength:n,maxDigestLength:o}){return new Je(r,e,t,n,o)}var Je=class{name;code;encode;minDigestLength;maxDigestLength;constructor(e,t,n,o,s){this.name=e,this.code=t,this.encode=n,this.minDigestLength=o??Wr,this.maxDigestLength=s}digest(e,t){if(t?.truncate!=null){if(t.truncate<this.minDigestLength)throw new Error(`Invalid truncate option, must be greater than or equal to ${this.minDigestLength}`);if(this.maxDigestLength!=null&&t.truncate>this.maxDigestLength)throw new Error(`Invalid truncate option, must be less than or equal to ${this.maxDigestLength}`)}if(e instanceof Uint8Array){let n=this.encode(e);return n instanceof Uint8Array?wt(n,this.code,t?.truncate):n.then(o=>wt(o,this.code,t?.truncate))}else throw Error("Unknown type, must be binary type")}};function wt(r,e,t){if(t!=null&&t!==r.byteLength){if(t>r.byteLength)throw new Error(`Invalid truncate option, must be less than or equal to ${r.byteLength}`);r=r.subarray(0,t)}return W(e,r)}function vt(r){return async e=>new Uint8Array(await crypto.subtle.digest(r,e))}var Gr=We({name:"sha2-256",code:18,encode:vt("SHA-256")}),qr=We({name:"sha2-512",code:19,encode:vt("SHA-512")});function Ct(r,e){let{bytes:t,version:n}=r;return n===0?Xr(t,qe(r),e??I.encoder):Qr(t,qe(r),e??T.encoder)}var St=new WeakMap;function qe(r){let e=St.get(r);if(e==null){let t=new Map;return St.set(r,t),t}return e}var se=class r{code;version;multihash;bytes;"/";constructor(e,t,n,o){this.code=t,this.version=e,this.multihash=n,this.bytes=o,this["/"]=o}get asCID(){return this}get byteOffset(){return this.bytes.byteOffset}get byteLength(){return this.bytes.byteLength}toV0(){switch(this.version){case 0:return this;case 1:{let{code:e,multihash:t}=this;if(e!==re)throw new Error("Cannot convert a non dag-pb CID to CIDv0");if(t.code!==Zr)throw new Error("Cannot convert non sha2-256 multihash CID to CIDv0");return r.createV0(t)}default:throw Error(`Can not convert CID version ${this.version} to version 0. This is a bug please report`)}}toV1(){switch(this.version){case 0:{let{code:e,digest:t}=this.multihash,n=W(e,t);return r.createV1(this.code,n)}case 1:return this;default:throw Error(`Can not convert CID version ${this.version} to version 1. This is a bug please report`)}}equals(e){return r.equals(this,e)}static equals(e,t){let n=t;return n!=null&&e.code===n.code&&e.version===n.version&&yt(e.multihash,n.multihash)}toString(e){return Ct(this,e)}toJSON(){return{"/":Ct(this)}}link(){return this}[Symbol.toStringTag]="CID";[Symbol.for("nodejs.util.inspect.custom")](){return`CID(${this.toString()})`}static asCID(e){if(e==null)return null;let t=e;if(t instanceof r)return t;if(t["/"]!=null&&t["/"]===t.bytes\|\|t.asCID===t){let{version:n,code:o,multihash:s,bytes:i}=t;return new r(n,o,s,i??Et(n,o,s.bytes))}else if(t[Yr]===!0){let{version:n,multihash:o,code:s}=t,i=mt(o);return r.create(n,s,i)}else return null}static create(e,t,n){if(typeof t!="number")throw new Error("String codecs are no longer supported");if(!(n.bytes instanceof Uint8Array))throw new Error("Invalid digest");switch(e){case 0:{if(t!==re)throw new Error(`Version 0 CID must use dag-pb (code: ${re}) block encoding`);return new r(e,t,n,n.bytes)}case 1:{let o=Et(e,t,n.bytes);return new r(e,t,n,o)}default:throw new Error("Invalid version")}}static createV0(e){return r.create(0,re,e)}static createV1(e,t){return r.create(1,e,t)}static decode(e){let[t,n]=r.decodeFirst(e);if(n.length!==0)throw new Error("Incorrect length");return t}static decodeFirst(e){let t=r.inspectBytes(e),n=t.size-t.multihashSize,o=M(e.subarray(n,n+t.multihashSize));if(o.byteLength!==t.multihashSize)throw new Error("Incorrect length");let s=o.subarray(t.multihashSize-t.digestSize),i=new J(t.multihashCode,t.digestSize,s,o);return[t.version===0?r.createV0(i):r.createV1(t.codec,i),e.subarray(t.size)]}static inspectBytes(e){let t=0,n=()=>{let[l,p]=ee(e.subarray(t));return t+=p,l},o=n(),s=re;if(o===18?(o=0,t=0):s=n(),o!==0&&o!==1)throw new RangeError(`Invalid CID version ${o}`);let i=t,a=n(),h=n(),F=t+h,c=F-i;return{version:o,codec:s,multihashCode:a,digestSize:h,multihashSize:c,size:F}}static parse(e,t){let[n,o]=Hr(e,t),s=r.decode(o);if(s.version===0&&e[0]!=="Q")throw Error("Version 0 CID string must not include multibase prefix");return qe(s).set(n,e),s}};function Hr(r,e){switch(r[0]){case"Q":{let t=e??I;return[I.prefix,t.decode(`${I.prefix}${r}`)]}case I.prefix:{let t=e??I;return[I.prefix,t.decode(r)]}case T.prefix:{let t=e??T;return[T.prefix,t.decode(r)]}case Z.prefix:{let t=e??Z;return[Z.prefix,t.decode(r)]}default:{if(e==null)throw Error("To parse non base32, base36 or base58btc encoded CID multibase decoder must be provided");return[r[0],e.decode(r)]}}}function Xr(r,e,t){let{prefix:n}=t;if(n!==I.prefix)throw Error(`Cannot string encode V0 in ${t.name} encoding`);let o=e.get(n);if(o==null){let s=t.encode(r).slice(1);return e.set(n,s),s}else return o}function Qr(r,e,t){let{prefix:n}=t,o=e.get(n);if(o==null){let s=t.encode(r);return e.set(n,s),s}else return o}var re=112,Zr=18;function Et(r,e,t){let n=V(r),o=n+V(e),s=new Uint8Array(o+t.byteLength);return B(r,s,0),B(e,s,n),s.set(t,o),s}var Yr=Symbol.for("@ipld/js-cid/CID");var He={...je,...Ue,...Ke,...Le,...Me,...Oe,...Te,...ze,..._e,...Re},ko={...Ge,...Ve};function At(r=0){return new Uint8Array(r)}function It(r,e,t,n){return{name:r,prefix:e,encoder:{name:r,prefix:e,encode:t},decoder:{decode:n}}}var Ft=It("utf8","u",r=>"u"+new TextDecoder("utf8").decode(r),r=>new TextEncoder().encode(r.substring(1))),Xe=It("ascii","a",r=>{let e="a";for(let t=0;t<r.length;t++)e+=String.fromCharCode(r[t]);return e},r=>{r=r.substring(1);let e=At(r.length);for(let t=0;t<r.length;t++)e[t]=r.charCodeAt(t);return e}),en={utf8:Ft,"utf-8":Ft,hex:He.base16,latin1:Xe,ascii:Xe,binary:Xe,...He},ie=en;function Dt(r,e="utf8"){let t=ie[e];if(t==null)throw new Error(`Unsupported encoding "${e}"`);return t.decoder.decode(`${t.prefix}${r}`)}function Nt(r,e="utf8"){let t=ie[e];if(t==null)throw new Error(`Unsupported encoding "${e}"`);return t.encoder.encode(r).substring(1)}var U="/",$t=new TextEncoder().encode(U),ae=$t[0],C=class r{_buf;constructor(e,t){if(typeof e=="string")this._buf=Dt(e);else if(e instanceof Uint8Array)this._buf=e;else throw new Error("Invalid key, should be String of Uint8Array");if(t==null&&(t=!0),t&&this.clean(),this._buf.byteLength===0\|\|this._buf[0]!==ae)throw new Error("Invalid key")}toString(e="utf8"){return Nt(this._buf,e)}uint8Array(){return this._buf}get[Symbol.toStringTag](){return`Key(${this.toString()})`}static withNamespaces(e){return new r(e.join(U))}static random(){return new r(Math.random().toString().substring(2))}static asKey(e){return e instanceof Uint8Array\|\|typeof e=="string"?new r(e):typeof e.uint8Array=="function"?new r(e.uint8Array()):null}clean(){if((this._buf==null\|\|this._buf.byteLength===0)&&(this._buf=$t),this._buf[0]!==ae){let e=new Uint8Array(this._buf.byteLength+1);e.fill(ae,0,1),e.set(this._buf,1),this._buf=e}for(;this._buf.byteLength>1&&this._buf[this._buf.byteLength-1]===ae;)this._buf=this._buf.subarray(0,-1)}less(e){let t=this.list(),n=e.list();for(let o=0;o<t.length;o++){if(n.length<o+1)return!1;let s=t[o],i=n[o];if(s<i)return!0;if(s>i)return!1}return t.length<n.length}reverse(){return r.withNamespaces(this.list().slice().reverse())}namespaces(){return this.list()}baseNamespace(){let e=this.namespaces();return e[e.length-1]}list(){return this.toString().split(U).slice(1)}type(){return tn(this.baseNamespace())}name(){return rn(this.baseNamespace())}instance(e){return new r(this.toString()+":"+e)}path(){let e=this.parent().toString();return e.endsWith(U)\|\|(e+=U),e+=this.type(),new r(e)}parent(){let e=this.list();return e.length===1?new r(U):new r(e.slice(0,-1).join(U))}child(e){return this.toString()===U?e:e.toString()===U?this:new r(this.toString()+e.toString(),!1)}isAncestorOf(e){return e.toString()===this.toString()?!1:e.toString().startsWith(this.toString())}isDecendantOf(e){return e.toString()===this.toString()?!1:this.toString().startsWith(e.toString())}isTopLevel(){return this.list().length===1}concat(...e){return r.withNamespaces([...this.namespaces(),...nn(e.map(t=>t.namespaces()))])}};function tn(r){let e=r.split(":");return e.length<2?"":e.slice(0,-1).join(":")}function rn(r){let e=r.split(":");return e[e.length-1]}function nn(r){return[].concat(...r)}var ce="/repo/flatfs/shard/",he="SHARDING",G=class{param;name;_padding;constructor(e){this.param=e,this.name="base",this._padding=""}fun(e){return"implement me"}toString(){return`${ce}v1/${this.name}/${this.param}`}},ue=class extends G{constructor(e){super(e),this._padding="".padStart(e,"_"),this.name="prefix"}fun(e){return(e+this._padding).slice(0,this.param)}},le=class extends G{constructor(e){super(e),this._padding="".padStart(e,"_"),this.name="suffix"}fun(e){let t=this._padding+e;return t.slice(t.length-this.param)}},fe=class extends G{constructor(e){super(e),this._padding="".padStart(e+1,"_"),this.name="next-to-last"}fun(e){let t=this._padding+e,n=t.length-this.param-1;return t.slice(n,n+this.param)}};function kt(r){if(r=r.trim(),r.length===0)throw new Error("empty shard string");if(!r.startsWith(ce))throw new Error(`invalid or no path prefix: ${r}`);let e=r.slice(ce.length).split("/"),t=e[0];if(t!=="v1")throw new Error(`expect 'v1' version, got '${t}'`);let n=e[1];if(e[2]==null\|\|e[2]==="")throw new Error("missing param");let o=parseInt(e[2],10);switch(n){case"prefix":return new ue(o);case"suffix":return new le(o);case"next-to-last":return new fe(o);default:throw new Error(`unkown sharding function: ${n}`)}}var de=async(r,e)=>{let t=new C(r).child(new C(he)),o=await(typeof e.getRaw=="function"?e.getRaw.bind(e):e.get.bind(e))(t);return kt(new TextDecoder().decode(o??"").trim())};function on(r){return r[Symbol.asyncIterator]!=null}function sn(r){if(on(r))return(async()=>{for await(let e of r);})();for(let e of r);}var Ze=sn;function an(r){let[e,t]=r[Symbol.asyncIterator]!=null?[r[Symbol.asyncIterator](),Symbol.asyncIterator]:[r[Symbol.iterator](),Symbol.iterator],n=[];return{peek:()=>e.next(),push:o=>{n.push(o)},next:()=>n.length>0?{done:!1,value:n.shift()}:e.next(),[t](){return this}}}var pe=an;function cn(r){return r[Symbol.asyncIterator]!=null}function un(r,e){let t=0;if(cn(r))return(async function(){for await(let h of r)await e(h,t++)&&(yield h)})();let n=pe(r),{value:o,done:s}=n.next();if(s===!0)return(function(){})();let i=e(o,t++);if(typeof i.then=="function")return(async function(){await i&&(yield o);for(let h of n)await e(h,t++)&&(yield h)})();let a=e;return(function(){i===!0&&(yield o);for(let h of n)a(h,t++)&&(yield h)})()}var D=un;function ln(r){return r[Symbol.asyncIterator]!=null}function fn(r){if(ln(r))return(async()=>{let t=[];for await(let n of r)t.push(n);return t})();let e=[];for(let t of r)e.push(t);return e}var Ye=fn;function hn(r){return r[Symbol.asyncIterator]!=null}function dn(r,e){return hn(r)?(async function(){yield(await Ye(r)).sort(e)})():(function(){yieldYe(r).sort(e)})()}var q=dn;function pn(r){return r[Symbol.asyncIterator]!=null}function mn(r,e){return pn(r)?(async function(){let t=0;if(!(e<1)){for await(let n of r)if(yield n,t++,t===e)return}})():(function(){let t=0;if(!(e<1)){for(let n of r)if(yield n,t++,t===e)return}})()}var H=mn;var E=class{put(e,t,n){return Promise.reject(new Error(".put is not implemented"))}get(e,t){return Promise.reject(new Error(".get is not implemented"))}has(e,t){return Promise.reject(new Error(".has is not implemented"))}delete(e,t){return Promise.reject(new Error(".delete is not implemented"))}asyncputMany(e,t={}){for await(let{key:n,value:o}of e)await this.put(n,o,t),yield n}asyncgetMany(e,t={}){for await(let n of e)yield{key:n,value:await this.get(n,t)}}asyncdeleteMany(e,t={}){for await(let n of e)await this.delete(n,t),yield n}batch(){let e=[],t=[];return{put(n,o){e.push({key:n,value:o})},delete(n){t.push(n)},commit:async n=>{await Ze(this.putMany(e,n)),e=[],await Ze(this.deleteMany(t,n)),t=[]}}}async_all(e,t){throw new Error("._all is not implemented")}async_allKeys(e,t){throw new Error("._allKeys is not implemented")}query(e,t){let n=this._all(e,t);if(e.prefix!=null){let o=e.prefix;n=D(n,s=>s.key.toString().startsWith(o))}if(Array.isArray(e.filters)&&(n=e.filters.reduce((o,s)=>D(o,s),n)),Array.isArray(e.orders)&&(n=e.orders.reduce((o,s)=>q(o,s),n)),e.offset!=null){let o=0,s=e.offset;n=D(n,()=>o++>=s)}return e.limit!=null&&(n=H(n,e.limit)),n}queryKeys(e,t){let n=this._allKeys(e,t);if(e.prefix!=null){let o=e.prefix;n=D(n,s=>s.toString().startsWith(o))}if(Array.isArray(e.filters)&&(n=e.filters.reduce((o,s)=>D(o,s),n)),Array.isArray(e.orders)&&(n=e.orders.reduce((o,s)=>q(o,s),n)),e.offset!=null){let o=e.offset,s=0;n=D(n,()=>s++>=o)}return e.limit!=null&&(n=H(n,e.limit)),n}};var me=class r extends Error{static name="OpenFailedError";name=r.name;static code="ERR_OPEN_FAILED";code=r.code;constructor(e="Open failed"){super(e)}};var ye=class r extends Error{static name="PutFailedError";name=r.name;static code="ERR_PUT_FAILED";code=r.code;constructor(e="Put failed"){super(e)}};var be=class r extends Error{static name="DeleteFailedError";name=r.name;static code="ERR_DELETE_FAILED";code=r.code;constructor(e="Delete failed"){super(e)}};var z=class r extends Error{static name="NotFoundError";name=r.name;static code="ERR_NOT_FOUND";code=r.code;constructor(e="Not Found"){super(e)}};var ge=class extends E{data;constructor(){super(),this.data=new Map}put(e,t,n){return n?.signal?.throwIfAborted(),this.data.set(e.toString(),t),e}get(e,t){t?.signal?.throwIfAborted();let n=this.data.get(e.toString());if(n==null)throw new z;return n}has(e,t){return t?.signal?.throwIfAborted(),this.data.has(e.toString())}delete(e,t){t?.signal?.throwIfAborted(),this.data.delete(e.toString())}_all(e,t){t?.signal?.throwIfAborted();for(let[n,o]of this.data.entries())yield{key:new C(n),value:o},t?.signal?.throwIfAborted()}_allKeys(e,t){t?.signal?.throwIfAborted();for(let n of this.data.keys())yield new C(n),t?.signal?.throwIfAborted()}};function yn(r){return r[Symbol.asyncIterator]!=null}function bn(r,e){let t=0;if(yn(r))return(async function(){for await(let h of r)yield e(h,t++)})();let n=pe(r),{value:o,done:s}=n.next();if(s===!0)return(function(){})();let i=e(o,t++);if(typeof i.then=="function")return(async function(){yield await i;for(let h of n)yield e(h,t++)})();let a=e;return(function(){yield i;for(let h of n)yield a(h,t++)})()}var N=bn;function R(){let r={};return r.promise=new Promise((e,t)=>{r.resolve=e,r.reject=t}),r}var we=class{buffer;mask;top;btm;next;constructor(e){if(!(e>0)\|\|(e-1&e)!==0)throw new Error("Max size for a FixedFIFO should be a power of two");this.buffer=new Array(e),this.mask=e-1,this.top=0,this.btm=0,this.next=null}push(e){return this.buffer[this.top]!==void 0?!1:(this.buffer[this.top]=e,this.top=this.top+1&this.mask,!0)}shift(){let e=this.buffer[this.btm];if(e!==void 0)return this.buffer[this.btm]=void 0,this.btm=this.btm+1&this.mask,e}isEmpty(){return this.buffer[this.btm]===void 0}},X=class{size;hwm;head;tail;constructor(e={}){this.hwm=e.splitLimit??16,this.head=new we(this.hwm),this.tail=this.head,this.size=0}calculateSize(e){return e?.byteLength!=null?e.byteLength:1}push(e){if(e?.value!=null&&(this.size+=this.calculateSize(e.value)),!this.head.push(e)){let t=this.head;this.head=t.next=new we(2this.head.buffer.length),this.head.push(e)}}shift(){let e=this.tail.shift();if(e===void 0&&this.tail.next!=null){let t=this.tail.next;this.tail.next=null,this.tail=t,e=this.tail.shift()}return e?.value!=null&&(this.size-=this.calculateSize(e.value)),e}isEmpty(){return this.head.isEmpty()}};var et=class extends Error{type;code;constructor(e,t){super(e??"The operation was aborted"),this.type="aborted",this.code=t??"ABORT_ERR"}};function Lt(r={}){return gn(t=>{let n=t.shift();if(n==null)return{done:!0};if(n.error!=null)throw n.error;return{done:n.done===!0,value:n.value}},r)}function gn(r,e){e=e??{};let t=e.onEnd,n=new X,o,s,i,a=R(),h=async()=>{try{return n.isEmpty()?i?{done:!0}:await new Promise((u,f)=>{s=y=>{s=null,n.push(y);try{u(r(n))}catch(b){f(b)}return o}}):r(n)}finally{n.isEmpty()&&queueMicrotask(()=>{a.resolve(),a=R()})}},F=u=>s!=null?s(u):(n.push(u),o),c=u=>(n=new X,s!=null?s({error:u}):(n.push({error:u}),o)),l=u=>{if(i)return o;if(e?.objectMode!==!0&&u?.byteLength==null)throw new Error("objectMode was not true but tried to push non-Uint8Array value");return F({done:!1,value:u})},p=u=>i?o:(i=!0,u!=null?c(u):F({done:!0})),k=()=>(n=new X,p(),{done:!0}),d=u=>(p(u),{done:!0});if(o={[Symbol.asyncIterator](){return this},next:h,return:k,throw:d,push:l,end:p,get readableLength(){return n.size},onEmpty:async u=>{let f=u?.signal;if(f?.throwIfAborted(),n.isEmpty())return;let y,b;f!=null&&(y=new Promise((x,w)=>{b=()=>{w(new et)},f.addEventListener("abort",b)}));try{await Promise.race([a.promise,y])}finally{b!=null&&f!=null&&f?.removeEventListener("abort",b)}}},t==null)return o;let m=o;return o={[Symbol.asyncIterator](){return this},next(){return m.next()},throw(u){return m.throw(u),t!=null&&(t(u),t=void 0),{done:!0}},return(){return m.return(),t!=null&&(t(),t=void 0),{done:!0}},push:l,end(u){return m.end(u),t!=null&&(t(u),t=void 0),o},get readableLength(){return m.readableLength},onEmpty:u=>m.onEmpty(u)},o}function wn(r){return r.reason}async function Mt(r,e,t){if(e==null)return r;let n=t?.translateError??wn;if(e.aborted)return r.catch(()=>{}),Promise.reject(n(e));let o;try{return await Promise.race([r,new Promise((s,i)=>{o=()=>{i(n(e))},e.addEventListener("abort",o)})])}finally{o!=null&&e.removeEventListener("abort",o)}}var tt=class{readNext;haveNext;ended;nextResult;error;constructor(){this.ended=!1,this.readNext=R(),this.haveNext=R()}[Symbol.asyncIterator](){return this}async next(){if(this.nextResult==null&&await this.haveNext.promise,this.nextResult==null)throw new Error("HaveNext promise resolved but nextResult was undefined");let e=this.nextResult;return this.nextResult=void 0,this.readNext.resolve(),this.readNext=R(),e}async throw(e){return this.ended=!0,this.error=e,e!=null&&(this.haveNext.promise.catch(()=>{}),this.haveNext.reject(e)),{done:!0,value:void 0}}async return(){let e={done:!0,value:void 0};return this.ended=!0,this.nextResult=e,this.haveNext.resolve(),e}async push(e,t){await this._push(e,t)}async end(e,t){e!=null?await this.throw(e):await this._push(void 0,t)}async _push(e,t){if(e!=null&&this.ended)throw this.error??new Error("Cannot push value onto an ended pushable");for(;this.nextResult!=null;)await this.readNext.promise;e!=null?this.nextResult={done:!1,value:e}:(this.ended=!0,this.nextResult={done:!0,value:void 0}),this.haveNext.resolve(),this.haveNext=R(),await Mt(this.readNext.promise,t?.signal,t)}};function Ut(){return new tt}function xn(r){return r[Symbol.asyncIterator]!=null}async function vn(r,e,t){try{await Promise.all(r.map(async n=>{for await(let o of n)await e.push(o,{signal:t}),t.throwIfAborted()})),await e.end(void 0,{signal:t})}catch(n){await e.end(n,{signal:t}).catch(()=>{})}}async functionCn(r){let e=new AbortController,t=Ut();vn(r,t,e.signal).catch(()=>{});try{yieldt}finally{e.abort()}}functionSn(r){for(let e of r)yielde}function En(...r){let e=[];for(let t of r)xn(t)\|\|e.push(t);return e.length===r.length?Sn(e):Cn(r)}var ne=En;function xe(r,...e){if(r==null)throw new Error("Empty pipeline");if(rt(r)){let n=r;r=()=>n.source}else if(Ot(r)\|\|Rt(r)){let n=r;r=()=>n}let t=[r,...e];if(t.length>1&&rt(t[t.length-1])&&(t[t.length-1]=t[t.length-1].sink),t.length>2)for(let n=1;n<t.length-1;n++)rt(t[n])&&(t[n]=Fn(t[n]));return An(...t)}var An=(...r)=>{let e;for(;r.length>0;)e=r.shift()(e);return e},Rt=r=>r?.[Symbol.asyncIterator]!=null,Ot=r=>r?.[Symbol.iterator]!=null,rt=r=>r==null?!1:r.sink!=null&&r.source!=null,Fn=r=>e=>{let t=r.sink(e);if(t?.then!=null){let n=Lt({objectMode:!0});t.then(()=>{n.end()},i=>{n.end(i)});let o,s=r.source;if(Rt(s))o=async function(){yields,n.end()};else if(Ot(s))o=function(){yields,n.end()};else throw new Error("Unknown duplex source type - must be Iterable or AsyncIterable");return ne(n,o())}return r.source};var P=class extends E{child;transform;constructor(e,t){super(),this.child=e,this.transform=t}async put(e,t,n){return await this.child.put(this.transform.convert(e),t,n),e}async get(e,t){return this.child.get(this.transform.convert(e),t)}async has(e,t){return this.child.has(this.transform.convert(e),t)}async delete(e,t){await this.child.delete(this.transform.convert(e),t)}asyncputMany(e,t={}){let n=this.transform,o=this.child;yieldxe(e,async function(s){yieldN(s,({key:i,value:a})=>({key:n.convert(i),value:a}))},async function(s){yieldo.putMany(s,t)},async function(s){yieldN(s,i=>n.invert(i))})}asyncgetMany(e,t={}){let n=this.transform,o=this.child;yieldxe(e,async function(s){yieldN(s,i=>n.convert(i))},async function(s){yieldo.getMany(s,t)},async function(s){yieldN(s,({key:i,value:a})=>({key:n.invert(i),value:a}))})}asyncdeleteMany(e,t={}){let n=this.transform,o=this.child;yieldxe(e,async function(s){yieldN(s,i=>n.convert(i))},async function(s){yieldo.deleteMany(s,t)},async function(s){yield*N(s,i=>n.invert(i))})}batch(){let e=this.child.batch();return{put:(t,n)=>{e.put(this.transform.convert(t),n)},delete:t=>{e.delete(this.transform.convert(t))},commit:async t=>{await e.commit(t)}}}query(e,t){let n={...e};n.filters=(n.filters??[]).map(s=>({key:i,value:a})=>s({key:this.transform.convert(i),value:a}));let{prefix:o}=e;return o!=null&&o!=="/"&&(delete n.prefix,n.filters.push(({key:s})=>this.transform.invert(s).toString().startsWith(o))),n.orders!=null&&(n.orders=n.orders.map(s=>(i,a)=>s({key:this.transform.invert(i.key),value:i.value},{key:this.transform.invert(a.key),value:a.value}))),N(this.child.query(n,t),({key:s,value:i})=>({key:this.transform.invert(s),value:i}))}queryKeys(e,t){let n={...e};n.filters=(n.filters??[]).map(s=>i=>s(this.transform.convert(i)));let{prefix:o}=e;return o!=null&&o!=="/"&&(delete n.prefix,n.filters.push(s=>this.transform.invert(s).toString().startsWith(o))),n.orders!=null&&(n.orders=n.orders.map(s=>(i,a)=>s(this.transform.invert(i),this.transform.invert(a)))),N(this.child.queryKeys(n,t),s=>this.transform.invert(s))}};var Q=new C(he),ve=class r extends E{child;shard;constructor(e,t){super(),this.child=new P(e,{convert:this._convertKey.bind(this),invert:this._invertKey.bind(this)}),this.shard=t}async open(){this.shard=await r.create(this.child,this.shard)}_convertKey(e){let t=e.toString();return t===Q.toString()?e:new C(this.shard.fun(t)).child(e)}_invertKey(e){return e.toString()===Q.toString()?e:C.withNamespaces(e.list().slice(1))}static async create(e,t){if(!await e.has(Q)){if(t==null)throw new me("Shard is required when datastore doesn't have a shard key already");await e.put(Q,new TextEncoder().encode(t.toString()+`
		`))}t==null&&(t=await de("/",e));let o=await de("/",e),s=o.toString(),i=t.toString();if(s!==i)throw new Error(`specified fun ${i} does not match repo shard fun ${s}`);return o}async put(e,t,n){return await this.child.put(e,t,n),e}async get(e,t){return this.child.get(e,t)}async has(e,t){return this.child.has(e,t)}async delete(e,t){await this.child.delete(e,t)}asyncputMany(e,t={}){yieldthis.child.putMany(e,t)}asyncgetMany(e,t={}){yieldthis.child.getMany(e,t)}asyncdeleteMany(e,t={}){yieldthis.child.deleteMany(e,t)}batch(){return this.child.batch()}query(e,t){let o={...e,filters:[({key:s})=>s.toString()!==Q.toString()].concat(e.filters??[])};return this.child.query(o,t)}queryKeys(e,t){let o={...e,filters:[s=>s.toString()!==Q.toString()].concat(e.filters??[])};return this.child.queryKeys(o,t)}};var Ce=class extends E{mounts;constructor(e){super(),this.mounts=e.slice()}_lookup(e){for(let t of this.mounts)if(t.prefix.toString()===e.toString()\|\|t.prefix.isAncestorOf(e))return{datastore:t.datastore,mountpoint:t.prefix}}async put(e,t,n){let o=this._lookup(e);if(o==null)throw new ye("No datastore mounted for this key");return await o.datastore.put(e,t,n),e}async get(e,t={}){let n=this._lookup(e);if(n==null)throw new z("No datastore mounted for this key");return n.datastore.get(e,t)}async has(e,t){let n=this._lookup(e);return n==null?Promise.resolve(!1):n.datastore.has(e,t)}async delete(e,t){let n=this._lookup(e);if(n==null)throw new be("No datastore mounted for this key");await n.datastore.delete(e,t)}batch(){let e={},t=n=>{let o=this._lookup(n);if(o==null)throw new Error(`No datastore mounted for key "${n}"`);let s=o.mountpoint.toString();return e[s]==null&&(e[s]=o.datastore.batch()),{batch:e[s]}};return{put:(n,o)=>{t(n).batch.put(n,o)},delete:n=>{t(n).batch.delete(n)},commit:async n=>{await Promise.all(Object.keys(e).map(async o=>{await e[o].commit(n)}))}}}query(e,t){let n=this.mounts.map(s=>s.datastore.query({prefix:e.prefix,filters:e.filters},t)),o=ne(...n);if(e.filters!=null&&e.filters.forEach(s=>{o=D(o,s)}),e.orders!=null&&e.orders.forEach(s=>{o=q(o,s)}),e.offset!=null){let s=0,i=e.offset;o=D(o,()=>s++>=i)}return e.limit!=null&&(o=H(o,e.limit)),o}queryKeys(e,t){let n=this.mounts.map(s=>s.datastore.queryKeys({prefix:e.prefix,filters:e.filters},t)),o=ne(...n);if(e.filters!=null&&e.filters.forEach(s=>{o=D(o,s)}),e.orders!=null&&e.orders.forEach(s=>{o=q(o,s)}),e.offset!=null){let s=0,i=e.offset;o=D(o,()=>s++>=i)}return e.limit!=null&&(o=H(o,e.limit)),o}};function In(r,e){if(typeof r=="string")return Dn(r);if(typeof r=="number")return kn(r,e);throw Error(`Value provided to ms() must be a string or number. value=${JSON.stringify(r)}`)}var Se=In;function Dn(r){if(typeof r!="string"\|\|r.length===0\|\|r.length>100)throw Error(`Value provided to ms.parse() must be a string with length between 1 and 99. value=${JSON.stringify(r)}`);let e=/^(?<value>-?\d\.?\d+) (?<unit>milliseconds?\|msecs?\|ms\|seconds?\|secs?\|s\|minutes?\|mins?\|m\|hours?\|hrs?\|h\|days?\|d\|weeks?\|w\|months?\|mo\|years?\|yrs?\|y)?$/i.exec(r);if(!e?.groups)return NaN;let{value:t,unit:n="ms"}=e.groups,o=parseFloat(t),s=n.toLowerCase();switch(s){case"years":case"year":case"yrs":case"yr":case"y":return o315576e5;case"months":case"month":case"mo":return o26298e5;case"weeks":case"week":case"w":return o6048e5;case"days":case"day":case"d":return o864e5;case"hours":case"hour":case"hrs":case"hr":case"h":return o36e5;case"minutes":case"minute":case"mins":case"min":case"m":return o6e4;case"seconds":case"second":case"secs":case"sec":case"s":return o1e3;case"milliseconds":case"millisecond":case"msecs":case"msec":case"ms":return o;default:throw Error(`Unknown unit "${s}" provided to ms.parse(). value=${JSON.stringify(r)}`)}}function Nn(r){let e=Math.abs(r);return e>=315576e5?`${Math.round(r/315576e5)}y`:e>=26298e5?`${Math.round(r/26298e5)}mo`:e>=6048e5?`${Math.round(r/6048e5)}w`:e>=864e5?`${Math.round(r/864e5)}d`:e>=36e5?`${Math.round(r/36e5)}h`:e>=6e4?`${Math.round(r/6e4)}m`:e>=1e3?`${Math.round(r/1e3)}s`:`${r}ms`}function $n(r){let e=Math.abs(r);return e>=315576e5?K(r,e,315576e5,"year"):e>=26298e5?K(r,e,26298e5,"month"):e>=6048e5?K(r,e,6048e5,"week"):e>=864e5?K(r,e,864e5,"day"):e>=36e5?K(r,e,36e5,"hour"):e>=6e4?K(r,e,6e4,"minute"):e>=1e3?K(r,e,1e3,"second"):`${r} ms`}function kn(r,e){if(typeof r!="number"\|\|!Number.isFinite(r))throw Error("Value provided to ms.format() must be of type number.");return e?.long?$n(r):Nn(r)}function K(r,e,t,n){let o=e>=t1.5;return`${Math.round(r/t)} ${n}${o?"s":""}`}function nt(r){t.debug=t,t.default=t,t.coerce=h,t.disable=s,t.enable=o,t.enabled=i,t.humanize=Se,t.destroy=F,Object.keys(r).forEach(c=>{t[c]=r[c]}),t.names=[],t.skips=[],t.formatters={};function e(c){let l=0;for(let p=0;p<c.length;p++)l=(l<<5)-l+c.charCodeAt(p),l\|=0;return t.colors[Math.abs(l)%t.colors.length]}t.selectColor=e;function t(c,l){let p,k=null,d,m;function u(...f){if(!u.enabled)return;let y=u,b=Number(new Date),x=b-(p\|\|b);y.diff=x,y.prev=p,y.curr=b,p=b,f[0]=t.coerce(f[0]),typeof f[0]!="string"&&f.unshift("%O");let w=0;f[0]=f[0].replace(/%([a-zA-Z%])/g,(v,$)=>{if(v==="%%")return"%";w++;let _=t.formatters[$];if(typeof _=="function"){let Kt=f[w];v=_.call(y,Kt),f.splice(w,1),w--}return v}),t.formatArgs.call(y,f),l?.onLog!=null&&l.onLog(...f),(y.log\|\|t.log).apply(y,f)}return u.namespace=c,u.useColors=t.useColors(),u.color=t.selectColor(c),u.extend=n,u.destroy=t.destroy,Object.defineProperty(u,"enabled",{enumerable:!0,configurable:!1,get:()=>k!==null?k:(d!==t.namespaces&&(d=t.namespaces,m=t.enabled(c)),m),set:f=>{k=f}}),typeof t.init=="function"&&t.init(u),u}function n(c,l){let p=t(this.namespace+(typeof l>"u"?":":l)+c);return p.log=this.log,p}function o(c){t.save(c),t.namespaces=c,t.names=[],t.skips=[];let l,p=(typeof c=="string"?c:"").split(/[\s,]+/),k=p.length;for(l=0;l<k;l++)p[l]&&(c=p[l].replace(/\/g,".?"),c[0]==="-"?t.skips.push(new RegExp("^"+c.substr(1)+"$")):t.names.push(new RegExp("^"+c+"$")))}function s(){let c=[...t.names.map(a),...t.skips.map(a).map(l=>"-"+l)].join(",");return t.enable(""),c}function i(c){if(c[c.length-1]==="")return!0;let l,p;for(l=0,p=t.skips.length;l<p;l++)if(t.skips[l].test(c))return!1;for(l=0,p=t.names.length;l<p;l++)if(t.names[l].test(c))return!0;return!1}function a(c){return c.toString().substring(2,c.toString().length-2).replace(/\.\\?$/,"*")}function h(c){return c instanceof Error?c.stack??c.message:c}function F(){console.warn("Instance method `debug.destroy()` is deprecated and no longer does anything. It will be removed in the next major version of `debug`.")}return t.setupFormatters(t.formatters),t.enable(t.load()),t}var Ee=zn(),Ln=["#0000CC","#0000FF","#0033CC","#0033FF","#0066CC","#0066FF","#0099CC","#0099FF","#00CC00","#00CC33","#00CC66","#00CC99","#00CCCC","#00CCFF","#3300CC","#3300FF","#3333CC","#3333FF","#3366CC","#3366FF","#3399CC","#3399FF","#33CC00","#33CC33","#33CC66","#33CC99","#33CCCC","#33CCFF","#6600CC","#6600FF","#6633CC","#6633FF","#66CC00","#66CC33","#9900CC","#9900FF","#9933CC","#9933FF","#99CC00","#99CC33","#CC0000","#CC0033","#CC0066","#CC0099","#CC00CC","#CC00FF","#CC3300","#CC3333","#CC3366","#CC3399","#CC33CC","#CC33FF","#CC6600","#CC6633","#CC9900","#CC9933","#CCCC00","#CCCC33","#FF0000","#FF0033","#FF0066","#FF0099","#FF00CC","#FF00FF","#FF3300","#FF3333","#FF3366","#FF3399","#FF33CC","#FF33FF","#FF6600","#FF6633","#FF9900","#FF9933","#FFCC00","#FFCC33"];function Mn(){return typeof window<"u"&&window.process&&(window.process.type==="renderer"\|\|window.process.__nwjs)?!0:typeof navigator<"u"&&navigator.userAgent?.toLowerCase().match(/(edge\|trident)\/(\d+)/)!=null?!1:typeof document<"u"&&document.documentElement?.style?.WebkitAppearance\|\|typeof window<"u"&&window.console&&(window.console.firebug\|\|window.console.exception&&window.console.table)\|\|typeof navigator<"u"&&navigator.userAgent?.toLowerCase().match(/firefox\/(\d+)/)!=null&&parseInt(RegExp.$1,10)>=31\|\|typeof navigator<"u"&&navigator.userAgent?.toLowerCase().match(/applewebkit\/(\d+)/)}function Un(r){if(r[0]=(this.useColors?"%c":"")+this.namespace+(this.useColors?" %c":" ")+r[0]+(this.useColors?"%c ":" ")+"+"+Se(this.diff),!this.useColors)return;let e="color: "+this.color;r.splice(1,0,e,"color: inherit");let t=0,n=0;r[0].replace(/%[a-zA-Z%]/g,o=>{o!=="%%"&&(t++,o==="%c"&&(n=t))}),r.splice(n,0,e)}var Rn=console.debug??console.log??(()=>{});function On(r){try{r?Ee?.setItem("debug",r):Ee?.removeItem("debug")}catch{}}function Tn(){let r;try{r=Ee?.getItem("debug")}catch{}return!r&&typeof globalThis.process<"u"&&"env"in globalThis.process&&(r=globalThis.process.env.DEBUG),r}function zn(){try{return localStorage}catch{}}function Pn(r){r.j=function(e){try{return JSON.stringify(e)}catch(t){return"[UnexpectedJSONParseError]: "+t.message}}}var Tt=nt({formatArgs:Un,save:On,load:Tn,useColors:Mn,setupFormatters:Pn,colors:Ln,storage:Ee,log:Rn});var A=Tt;A.formatters.b=r=>r==null?"undefined":I.baseEncode(r);A.formatters.t=r=>r==null?"undefined":T.baseEncode(r);A.formatters.m=r=>r==null?"undefined":Pe.baseEncode(r);A.formatters.p=r=>r==null?"undefined":r.toString();A.formatters.c=r=>r==null?"undefined":r.toString();A.formatters.k=r=>r==null?"undefined":r.toString();A.formatters.a=r=>r==null?"undefined":r.toString();function zt(r,e=""){let t=Pt(r.message),n=Pt(r.stack);return t!=null&&n!=null?n.includes(t)?`${n.split(`
		"use strict";var DatastoreCore=(()=>{var ke=Object.defineProperty;var tr=Object.getOwnPropertyDescriptor;var rr=Object.getOwnPropertyNames;var nr=Object.prototype.hasOwnProperty;var I=(r,e)=>{for(var t in e)ke(r,t,{get:e[t],enumerable:!0})},or=(r,e,t,n)=>{if(e&&typeof e=="object"\|\|typeof e=="function")for(let o of rr(e))!nr.call(r,o)&&o!==t&&ke(r,o,{get:()=>e[o],enumerable:!(n=tr(e,o))\|\|n.enumerable});return r};var sr=r=>or(ke({},"__esModule",{value:!0}),r);var fo={};I(fo,{BaseDatastore:()=>D,KeyTransformDatastore:()=>B,MemoryDatastore:()=>ge,MountDatastore:()=>Se,NamespaceDatastore:()=>De,ShardingDatastore:()=>Ee,TieredDatastore:()=>Ie,shard:()=>Ze});var Ze={};I(Ze,{NextToLast:()=>de,PREFIX:()=>fe,Prefix:()=>le,SHARDING_FN:()=>pe,ShardBase:()=>X,Suffix:()=>he,parseShardFun:()=>Ot,readShardFun:()=>me});var Le={};I(Le,{base10:()=>dr});var ho=new Uint8Array(0);function lt(r,e){if(r===e)return!0;if(r.byteLength!==e.byteLength)return!1;for(let t=0;t<r.byteLength;t++)if(r[t]!==e[t])return!1;return!0}function z(r){if(r instanceof Uint8Array&&r.constructor.name==="Uint8Array")return _(r);if(r instanceof ArrayBuffer)return new Uint8Array(r);if(ArrayBuffer.isView(r))return _(new Uint8Array(r.buffer,r.byteOffset,r.byteLength));throw new Error("Unknown type, must be binary type")}function ht(r){return new TextEncoder().encode(r)}function dt(r){return new TextDecoder().decode(r)}function ir(r){return r?.buffer instanceof ArrayBuffer}function _(r){return ir(r)?r:r.slice()}function ar(r,e){if(r.length>=255)throw new TypeError("Alphabet too long");for(var t=new Uint8Array(256),n=0;n<t.length;n++)t[n]=255;for(var o=0;o<r.length;o++){var s=r.charAt(o),i=s.charCodeAt(0);if(t[i]!==255)throw new TypeError(s+" is ambiguous");t[i]=o}var a=r.length,h=r.charAt(0),E=Math.log(a)/Math.log(256),f=Math.log(256)/Math.log(a);function p(c){if(c instanceof Uint8Array\|\|(ArrayBuffer.isView(c)?c=new Uint8Array(c.buffer,c.byteOffset,c.byteLength):Array.isArray(c)&&(c=Uint8Array.from(c))),!(c instanceof Uint8Array))throw new TypeError("Expected Uint8Array");if(c.length===0)return"";for(var d=0,u=0,l=0,m=c.length;l!==m&&c[l]===0;)l++,d++;for(var y=(m-l)f+1>>>0,w=new Uint8Array(y);l!==m;){for(var x=c[l],S=0,g=y-1;(x!==0\|\|S<u)&&g!==-1;g--,S++)x+=256w[g]>>>0,w[g]=x%a>>>0,x=x/a>>>0;if(x!==0)throw new Error("Non-zero carry");u=S,l++}for(var C=y-u;C!==y&&w[C]===0;)C++;for(var N=h.repeat(d);C<y;++C)N+=r.charAt(w[C]);return N}function b(c){if(typeof c!="string")throw new TypeError("Expected String");if(c.length===0)return new Uint8Array;var d=0;if(c[d]!==" "){for(var u=0,l=0;c[d]===h;)u++,d++;for(var m=(c.length-d)E+1>>>0,y=new Uint8Array(m);c[d];){var w=t[c.charCodeAt(d)];if(w===255)return;for(var x=0,S=m-1;(w!==0\|\|x<l)&&S!==-1;S--,x++)w+=ay[S]>>>0,y[S]=w%256>>>0,w=w/256>>>0;if(w!==0)throw new Error("Non-zero carry");l=x,d++}if(c[d]!==" "){for(var g=m-l;g!==m&&y[g]===0;)g++;for(var C=new Uint8Array(u+(m-g)),N=u;g!==m;)C[N++]=y[g++];return C}}}function M(c){var d=b(c);if(d)return d;throw new Error(`Non-${e} character`)}return{encode:p,decodeUnsafe:b,decode:M}}var cr=ar,ur=cr,mt=ur;var Ne=class{name;prefix;baseEncode;constructor(e,t,n){this.name=e,this.prefix=t,this.baseEncode=n}encode(e){if(e instanceof Uint8Array)return`${this.prefix}${this.baseEncode(e)}`;throw Error("Unknown type, must be binary type")}},Ue=class{name;prefix;baseDecode;prefixCodePoint;constructor(e,t,n){this.name=e,this.prefix=t;let o=t.codePointAt(0);if(o===void 0)throw new Error("Invalid prefix character");this.prefixCodePoint=o,this.baseDecode=n}decode(e){if(typeof e=="string"){if(e.codePointAt(0)!==this.prefixCodePoint)throw Error(`Unable to decode multibase string ${JSON.stringify(e)}, ${this.name} decoder only supports inputs prefixed with ${this.prefix}`);return this.baseDecode(e.slice(this.prefix.length))}else throw Error("Can only multibase decode strings")}or(e){return yt(this,e)}},$e=class{decoders;constructor(e){this.decoders=e}or(e){return yt(this,e)}decode(e){let t=e[0],n=this.decoders[t];if(n!=null)return n.decode(e);throw RangeError(`Unable to decode multibase string ${JSON.stringify(e)}, only inputs prefixed with ${Object.keys(this.decoders)} are supported`)}};function yt(r,e){return new $e({...r.decoders??{[r.prefix]:r},...e.decoders??{[e.prefix]:e}})}var Me=class{name;prefix;baseEncode;baseDecode;encoder;decoder;constructor(e,t,n,o){this.name=e,this.prefix=t,this.baseEncode=n,this.baseDecode=o,this.encoder=new Ne(e,t,n),this.decoder=new Ue(e,t,o)}encode(e){return this.encoder.encode(e)}decode(e){return this.decoder.decode(e)}};function j({name:r,prefix:e,encode:t,decode:n}){return new Me(r,e,t,n)}function P({name:r,prefix:e,alphabet:t}){let{encode:n,decode:o}=mt(t,r);return j({prefix:e,name:r,encode:n,decode:s=>z(o(s))})}function fr(r,e,t,n){let o=r.length;for(;r[o-1]==="=";)--o;let s=new Uint8Array(ot/8\|0),i=0,a=0,h=0;for(let E=0;E<o;++E){let f=e[r[E]];if(f===void 0)throw new SyntaxError(`Non-${n} character`);a=a<<t\|f,i+=t,i>=8&&(i-=8,s[h++]=255&a>>i)}if(i>=t\|\|(255&a<<8-i)!==0)throw new SyntaxError("Unexpected end of data");return s}function lr(r,e,t){let n=e[e.length-1]==="=",o=(1<<t)-1,s="",i=0,a=0;for(let h=0;h<r.length;++h)for(a=a<<8\|r[h],i+=8;i>t;)i-=t,s+=e[o&a>>i];if(i!==0&&(s+=e[o&a<<t-i]),n)for(;(s.lengtht&7)!==0;)s+="=";return s}function hr(r){let e={};for(let t=0;t<r.length;++t)e[r[t]]=t;return e}function v({name:r,prefix:e,bitsPerChar:t,alphabet:n}){let o=hr(n);return j({prefix:e,name:r,encode(s){return lr(s,n,t)},decode(s){return fr(s,o,t,r)}})}var dr=P({prefix:"9",name:"base10",alphabet:"0123456789"});var ze={};I(ze,{base16:()=>pr,base16upper:()=>mr});var pr=v({prefix:"f",name:"base16",alphabet:"0123456789abcdef",bitsPerChar:4}),mr=v({prefix:"F",name:"base16upper",alphabet:"0123456789ABCDEF",bitsPerChar:4});var Re={};I(Re,{base2:()=>yr});var yr=v({prefix:"0",name:"base2",alphabet:"01",bitsPerChar:1});var Oe={};I(Oe,{base256emoji:()=>vr});var bt=Array.from("\u{1F680}\u{1FA90}\u2604\u{1F6F0}\u{1F30C}\u{1F311}\u{1F312}\u{1F313}\u{1F314}\u{1F315}\u{1F316}\u{1F317}\u{1F318}\u{1F30D}\u{1F30F}\u{1F30E}\u{1F409}\u2600\u{1F4BB}\u{1F5A5}\u{1F4BE}\u{1F4BF}\u{1F602}\u2764\u{1F60D}\u{1F923}\u{1F60A}\u{1F64F}\u{1F495}\u{1F62D}\u{1F618}\u{1F44D}\u{1F605}\u{1F44F}\u{1F601}\u{1F525}\u{1F970}\u{1F494}\u{1F496}\u{1F499}\u{1F622}\u{1F914}\u{1F606}\u{1F644}\u{1F4AA}\u{1F609}\u263A\u{1F44C}\u{1F917}\u{1F49C}\u{1F614}\u{1F60E}\u{1F607}\u{1F339}\u{1F926}\u{1F389}\u{1F49E}\u270C\u2728\u{1F937}\u{1F631}\u{1F60C}\u{1F338}\u{1F64C}\u{1F60B}\u{1F497}\u{1F49A}\u{1F60F}\u{1F49B}\u{1F642}\u{1F493}\u{1F929}\u{1F604}\u{1F600}\u{1F5A4}\u{1F603}\u{1F4AF}\u{1F648}\u{1F447}\u{1F3B6}\u{1F612}\u{1F92D}\u2763\u{1F61C}\u{1F48B}\u{1F440}\u{1F62A}\u{1F611}\u{1F4A5}\u{1F64B}\u{1F61E}\u{1F629}\u{1F621}\u{1F92A}\u{1F44A}\u{1F973}\u{1F625}\u{1F924}\u{1F449}\u{1F483}\u{1F633}\u270B\u{1F61A}\u{1F61D}\u{1F634}\u{1F31F}\u{1F62C}\u{1F643}\u{1F340}\u{1F337}\u{1F63B}\u{1F613}\u2B50\u2705\u{1F97A}\u{1F308}\u{1F608}\u{1F918}\u{1F4A6}\u2714\u{1F623}\u{1F3C3}\u{1F490}\u2639\u{1F38A}\u{1F498}\u{1F620}\u261D\u{1F615}\u{1F33A}\u{1F382}\u{1F33B}\u{1F610}\u{1F595}\u{1F49D}\u{1F64A}\u{1F639}\u{1F5E3}\u{1F4AB}\u{1F480}\u{1F451}\u{1F3B5}\u{1F91E}\u{1F61B}\u{1F534}\u{1F624}\u{1F33C}\u{1F62B}\u26BD\u{1F919}\u2615\u{1F3C6}\u{1F92B}\u{1F448}\u{1F62E}\u{1F646}\u{1F37B}\u{1F343}\u{1F436}\u{1F481}\u{1F632}\u{1F33F}\u{1F9E1}\u{1F381}\u26A1\u{1F31E}\u{1F388}\u274C\u270A\u{1F44B}\u{1F630}\u{1F928}\u{1F636}\u{1F91D}\u{1F6B6}\u{1F4B0}\u{1F353}\u{1F4A2}\u{1F91F}\u{1F641}\u{1F6A8}\u{1F4A8}\u{1F92C}\u2708\u{1F380}\u{1F37A}\u{1F913}\u{1F619}\u{1F49F}\u{1F331}\u{1F616}\u{1F476}\u{1F974}\u25B6\u27A1\u2753\u{1F48E}\u{1F4B8}\u2B07\u{1F628}\u{1F31A}\u{1F98B}\u{1F637}\u{1F57A}\u26A0\u{1F645}\u{1F61F}\u{1F635}\u{1F44E}\u{1F932}\u{1F920}\u{1F927}\u{1F4CC}\u{1F535}\u{1F485}\u{1F9D0}\u{1F43E}\u{1F352}\u{1F617}\u{1F911}\u{1F30A}\u{1F92F}\u{1F437}\u260E\u{1F4A7}\u{1F62F}\u{1F486}\u{1F446}\u{1F3A4}\u{1F647}\u{1F351}\u2744\u{1F334}\u{1F4A3}\u{1F438}\u{1F48C}\u{1F4CD}\u{1F940}\u{1F922}\u{1F445}\u{1F4A1}\u{1F4A9}\u{1F450}\u{1F4F8}\u{1F47B}\u{1F910}\u{1F92E}\u{1F3BC}\u{1F975}\u{1F6A9}\u{1F34E}\u{1F34A}\u{1F47C}\u{1F48D}\u{1F4E3}\u{1F942}"),br=bt.reduce((r,e,t)=>(r[t]=e,r),[]),wr=bt.reduce((r,e,t)=>{let n=e.codePointAt(0);if(n==null)throw new Error(`Invalid character: ${e}`);return r[n]=t,r},[]);function xr(r){return r.reduce((e,t)=>(e+=br[t],e),"")}function gr(r){let e=[];for(let t of r){let n=t.codePointAt(0);if(n==null)throw new Error(`Invalid character: ${t}`);let o=wr[n];if(o==null)throw new Error(`Non-base256emoji character: ${t}`);e.push(o)}return new Uint8Array(e)}var vr=j({prefix:"\u{1F680}",name:"base256emoji",encode:xr,decode:gr});var Pe={};I(Pe,{base32:()=>V,base32hex:()=>Ar,base32hexpad:()=>Ir,base32hexpadupper:()=>Dr,base32hexupper:()=>Fr,base32pad:()=>Er,base32padupper:()=>Sr,base32upper:()=>Cr,base32z:()=>kr});var V=v({prefix:"b",name:"base32",alphabet:"abcdefghijklmnopqrstuvwxyz234567",bitsPerChar:5}),Cr=v({prefix:"B",name:"base32upper",alphabet:"ABCDEFGHIJKLMNOPQRSTUVWXYZ234567",bitsPerChar:5}),Er=v({prefix:"c",name:"base32pad",alphabet:"abcdefghijklmnopqrstuvwxyz234567=",bitsPerChar:5}),Sr=v({prefix:"C",name:"base32padupper",alphabet:"ABCDEFGHIJKLMNOPQRSTUVWXYZ234567=",bitsPerChar:5}),Ar=v({prefix:"v",name:"base32hex",alphabet:"0123456789abcdefghijklmnopqrstuv",bitsPerChar:5}),Fr=v({prefix:"V",name:"base32hexupper",alphabet:"0123456789ABCDEFGHIJKLMNOPQRSTUV",bitsPerChar:5}),Ir=v({prefix:"t",name:"base32hexpad",alphabet:"0123456789abcdefghijklmnopqrstuv=",bitsPerChar:5}),Dr=v({prefix:"T",name:"base32hexpadupper",alphabet:"0123456789ABCDEFGHIJKLMNOPQRSTUV=",bitsPerChar:5}),kr=v({prefix:"h",name:"base32z",alphabet:"ybndrfg8ejkmcpqxot1uwisza345h769",bitsPerChar:5});var Te={};I(Te,{base36:()=>ee,base36upper:()=>Nr});var ee=P({prefix:"k",name:"base36",alphabet:"0123456789abcdefghijklmnopqrstuvwxyz"}),Nr=P({prefix:"K",name:"base36upper",alphabet:"0123456789ABCDEFGHIJKLMNOPQRSTUVWXYZ"});var Be={};I(Be,{base58btc:()=>L,base58flickr:()=>Ur});var L=P({name:"base58btc",prefix:"z",alphabet:"123456789ABCDEFGHJKLMNPQRSTUVWXYZabcdefghijkmnopqrstuvwxyz"}),Ur=P({name:"base58flickr",prefix:"Z",alphabet:"123456789abcdefghijkmnopqrstuvwxyzABCDEFGHJKLMNPQRSTUVWXYZ"});var _e={};I(_e,{base64:()=>$r,base64pad:()=>Mr,base64url:()=>Lr,base64urlpad:()=>zr});var $r=v({prefix:"m",name:"base64",alphabet:"ABCDEFGHIJKLMNOPQRSTUVWXYZabcdefghijklmnopqrstuvwxyz0123456789+/",bitsPerChar:6}),Mr=v({prefix:"M",name:"base64pad",alphabet:"ABCDEFGHIJKLMNOPQRSTUVWXYZabcdefghijklmnopqrstuvwxyz0123456789+/=",bitsPerChar:6}),Lr=v({prefix:"u",name:"base64url",alphabet:"ABCDEFGHIJKLMNOPQRSTUVWXYZabcdefghijklmnopqrstuvwxyz0123456789-_",bitsPerChar:6}),zr=v({prefix:"U",name:"base64urlpad",alphabet:"ABCDEFGHIJKLMNOPQRSTUVWXYZabcdefghijklmnopqrstuvwxyz0123456789-_=",bitsPerChar:6});var Ke={};I(Ke,{base8:()=>Rr});var Rr=v({prefix:"7",name:"base8",alphabet:"01234567",bitsPerChar:3});var je={};I(je,{identity:()=>Or});var Or=j({prefix:"\0",name:"identity",encode:r=>dt(r),decode:r=>ht(r)});var ko=new TextEncoder,No=new TextDecoder;var Je={};I(Je,{identity:()=>an});var Br=gt,wt=128,_r=127,Kr=~_r,jr=Math.pow(2,31);function gt(r,e,t){e=e\|\|[],t=t\|\|0;for(var n=t;r>=jr;)e[t++]=r&255\|wt,r/=128;for(;r&Kr;)e[t++]=r&255\|wt,r>>>=7;return e[t]=r\|0,gt.bytes=t-n+1,e}var Vr=Ve,Jr=128,xt=127;function Ve(r,n){var t=0,n=n\|\|0,o=0,s=n,i,a=r.length;do{if(s>=a)throw Ve.bytes=0,new RangeError("Could not decode varint");i=r[s++],t+=o<28?(i&xt)<<o:(i&xt)Math.pow(2,o),o+=7}while(i>=Jr);return Ve.bytes=s-n,t}var qr=Math.pow(2,7),Wr=Math.pow(2,14),Gr=Math.pow(2,21),Xr=Math.pow(2,28),Hr=Math.pow(2,35),Qr=Math.pow(2,42),Zr=Math.pow(2,49),Yr=Math.pow(2,56),en=Math.pow(2,63),tn=function(r){return r<qr?1:r<Wr?2:r<Gr?3:r<Xr?4:r<Hr?5:r<Qr?6:r<Zr?7:r<Yr?8:r<en?9:10},rn={encode:Br,decode:Vr,encodingLength:tn},nn=rn,te=nn;function re(r,e=0){return[te.decode(r,e),te.decode.bytes]}function J(r,e,t=0){return te.encode(r,e,t),e}function q(r){return te.encodingLength(r)}function G(r,e){let t=e.byteLength,n=q(r),o=n+q(t),s=new Uint8Array(o+t);return J(r,s,0),J(t,s,n),s.set(e,o),new W(r,t,e,s)}function vt(r){let e=z(r),[t,n]=re(e),[o,s]=re(e.subarray(n)),i=e.subarray(n+s);if(i.byteLength!==o)throw new Error("Incorrect length");return new W(t,o,i,e)}function Ct(r,e){if(r===e)return!0;{let t=e;return r.code===t.code&&r.size===t.size&&t.bytes instanceof Uint8Array&&lt(r.bytes,t.bytes)}}var W=class{code;size;digest;bytes;constructor(e,t,n,o){this.code=e,this.size=t,this.digest=_(n),this.bytes=_(o)}};var Et=0,on="identity",St=z;function sn(r,e){if(e?.truncate!=null&&e.truncate!==r.byteLength){if(e.truncate<0\|\|e.truncate>r.byteLength)throw new Error(`Invalid truncate option, must be less than or equal to ${r.byteLength}`);r=r.subarray(0,e.truncate)}return G(Et,St(r))}var an={code:Et,name:on,encode:St,digest:sn};var Ge={};I(Ge,{sha256:()=>un,sha512:()=>fn});var cn=20;function We({name:r,code:e,encode:t,minDigestLength:n,maxDigestLength:o}){return new qe(r,e,t,n,o)}var qe=class{name;code;encode;minDigestLength;maxDigestLength;constructor(e,t,n,o,s){this.name=e,this.code=t,this.encode=n,this.minDigestLength=o??cn,this.maxDigestLength=s}digest(e,t){if(t?.truncate!=null){if(t.truncate<this.minDigestLength)throw new Error(`Invalid truncate option, must be greater than or equal to ${this.minDigestLength}`);if(this.maxDigestLength!=null&&t.truncate>this.maxDigestLength)throw new Error(`Invalid truncate option, must be less than or equal to ${this.maxDigestLength}`)}if(e instanceof Uint8Array){let n=this.encode(e);return n instanceof Uint8Array?At(n,this.code,t?.truncate):n.then(o=>At(o,this.code,t?.truncate))}else throw Error("Unknown type, must be binary type")}};function At(r,e,t){if(t!=null&&t!==r.byteLength){if(t>r.byteLength)throw new Error(`Invalid truncate option, must be less than or equal to ${r.byteLength}`);r=r.subarray(0,t)}return G(e,r)}function It(r){return async e=>new Uint8Array(await crypto.subtle.digest(r,e))}var un=We({name:"sha2-256",code:18,encode:It("SHA-256")}),fn=We({name:"sha2-512",code:19,encode:It("SHA-512")});function Dt(r,e){let{bytes:t,version:n}=r;return n===0?hn(t,Xe(r),e??L.encoder):dn(t,Xe(r),e??V.encoder)}var kt=new WeakMap;function Xe(r){let e=kt.get(r);if(e==null){let t=new Map;return kt.set(r,t),t}return e}var ae=class r{code;version;multihash;bytes;"/";constructor(e,t,n,o){this.code=t,this.version=e,this.multihash=n,this.bytes=_(o),this["/"]=this.bytes}get asCID(){return this}get byteOffset(){return this.bytes.byteOffset}get byteLength(){return this.bytes.byteLength}toV0(){switch(this.version){case 0:return this;case 1:{let{code:e,multihash:t}=this;if(e!==oe)throw new Error("Cannot convert a non dag-pb CID to CIDv0");if(t.code!==pn)throw new Error("Cannot convert non sha2-256 multihash CID to CIDv0");return r.createV0(t)}default:throw Error(`Can not convert CID version ${this.version} to version 0. This is a bug please report`)}}toV1(){switch(this.version){case 0:{let{code:e,digest:t}=this.multihash,n=G(e,t);return r.createV1(this.code,n)}case 1:return this;default:throw Error(`Can not convert CID version ${this.version} to version 1. This is a bug please report`)}}equals(e){return r.equals(this,e)}static equals(e,t){let n=t;return n!=null&&e.code===n.code&&e.version===n.version&&Ct(e.multihash,n.multihash)}toString(e){return Dt(this,e)}toJSON(){return{"/":Dt(this)}}link(){return this}[Symbol.toStringTag]="CID";[Symbol.for("nodejs.util.inspect.custom")](){return`CID(${this.toString()})`}static asCID(e){if(e==null)return null;let t=e;if(t instanceof r)return t;if(t["/"]!=null&&t["/"]===t.bytes\|\|t.asCID===t){let{version:n,code:o,multihash:s,bytes:i}=t;return new r(n,o,s,i??Nt(n,o,s.bytes))}else if(t[mn]===!0){let{version:n,multihash:o,code:s}=t,i=vt(o);return r.create(n,s,i)}else return null}static create(e,t,n){if(typeof t!="number")throw new Error("String codecs are no longer supported");if(!(n.bytes instanceof Uint8Array))throw new Error("Invalid digest");switch(e){case 0:{if(t!==oe)throw new Error(`Version 0 CID must use dag-pb (code: ${oe}) block encoding`);return new r(e,t,n,n.bytes)}case 1:{let o=Nt(e,t,n.bytes);return new r(e,t,n,o)}default:throw new Error("Invalid version")}}static createV0(e){return r.create(0,oe,e)}static createV1(e,t){return r.create(1,e,t)}static decode(e){let[t,n]=r.decodeFirst(e);if(n.length!==0)throw new Error("Incorrect length");return t}static decodeFirst(e){let t=r.inspectBytes(e),n=t.size-t.multihashSize,o=z(e.subarray(n,n+t.multihashSize));if(o.byteLength!==t.multihashSize)throw new Error("Incorrect length");let s=o.subarray(t.multihashSize-t.digestSize),i=new W(t.multihashCode,t.digestSize,s,o);return[t.version===0?r.createV0(i):r.createV1(t.codec,i),e.subarray(t.size)]}static inspectBytes(e){let t=0,n=()=>{let[p,b]=re(e.subarray(t));return t+=b,p},o=n(),s=oe;if(o===18?(o=0,t=0):s=n(),o!==0&&o!==1)throw new RangeError(`Invalid CID version ${o}`);let i=t,a=n(),h=n(),E=t+h,f=E-i;return{version:o,codec:s,multihashCode:a,digestSize:h,multihashSize:f,size:E}}static parse(e,t){let[n,o]=ln(e,t),s=r.decode(o);if(s.version===0&&e[0]!=="Q")throw Error("Version 0 CID string must not include multibase prefix");return Xe(s).set(n,e),s}};function ln(r,e){switch(r[0]){case"Q":{let t=e??L;return[L.prefix,t.decode(`${L.prefix}${r}`)]}case L.prefix:{let t=e??L;return[L.prefix,t.decode(r)]}case V.prefix:{let t=e??V;return[V.prefix,t.decode(r)]}case ee.prefix:{let t=e??ee;return[ee.prefix,t.decode(r)]}default:{if(e==null)throw Error("To parse non base32, base36 or base58btc encoded CID multibase decoder must be provided");return[r[0],e.decode(r)]}}}function hn(r,e,t){let{prefix:n}=t;if(n!==L.prefix)throw Error(`Cannot string encode V0 in ${t.name} encoding`);let o=e.get(n);if(o==null){let s=t.encode(r).slice(1);return e.set(n,s),s}else return o}function dn(r,e,t){let{prefix:n}=t,o=e.get(n);if(o==null){let s=t.encode(r);return e.set(n,s),s}else return o}var oe=112,pn=18;function Nt(r,e,t){let n=q(r),o=n+q(e),s=new Uint8Array(o+t.byteLength);return J(r,s,0),J(e,s,n),s.set(t,o),s}var mn=Symbol.for("@ipld/js-cid/CID");var He={...je,...Re,...Ke,...Le,...ze,...Pe,...Te,...Be,..._e,...Oe},Zo={...Ge,...Je};function Ut(r=0){return new Uint8Array(r)}function Mt(r,e,t,n){return{name:r,prefix:e,encoder:{name:r,prefix:e,encode:t},decoder:{decode:n}}}var $t=Mt("utf8","u",r=>"u"+new TextDecoder("utf8").decode(r),r=>new TextEncoder().encode(r.substring(1))),Qe=Mt("ascii","a",r=>{let e="a";for(let t=0;t<r.length;t++)e+=String.fromCharCode(r[t]);return e},r=>{r=r.substring(1);let e=Ut(r.length);for(let t=0;t<r.length;t++)e[t]=r.charCodeAt(t);return e}),yn={utf8:$t,"utf-8":$t,hex:He.base16,latin1:Qe,ascii:Qe,binary:Qe,...He},ce=yn;function Lt(r,e="utf8"){let t=ce[e];if(t==null)throw new Error(`Unsupported encoding "${e}"`);return t.decoder.decode(`${t.prefix}${r}`)}function zt(r,e="utf8"){let t=ce[e];if(t==null)throw new Error(`Unsupported encoding "${e}"`);return t.encoder.encode(r).substring(1)}var R="/",Rt=new TextEncoder().encode(R),ue=Rt[0],A=class r{_buf;constructor(e,t){if(typeof e=="string")this._buf=Lt(e);else if(e instanceof Uint8Array)this._buf=e;else throw new Error("Invalid key, should be String of Uint8Array");if(t==null&&(t=!0),t&&this.clean(),this._buf.byteLength===0\|\|this._buf[0]!==ue)throw new Error("Invalid key")}toString(e="utf8"){return zt(this._buf,e)}uint8Array(){return this._buf}get[Symbol.toStringTag](){return`Key(${this.toString()})`}static withNamespaces(e){return new r(e.join(R))}static random(){return new r(Math.random().toString().substring(2))}static asKey(e){return e instanceof Uint8Array\|\|typeof e=="string"?new r(e):typeof e.uint8Array=="function"?new r(e.uint8Array()):null}clean(){if((this._buf==null\|\|this._buf.byteLength===0)&&(this._buf=Rt),this._buf[0]!==ue){let e=new Uint8Array(this._buf.byteLength+1);e.fill(ue,0,1),e.set(this._buf,1),this._buf=e}for(;this._buf.byteLength>1&&this._buf[this._buf.byteLength-1]===ue;)this._buf=this._buf.subarray(0,-1)}less(e){let t=this.list(),n=e.list();for(let o=0;o<t.length;o++){if(n.length<o+1)return!1;let s=t[o],i=n[o];if(s<i)return!0;if(s>i)return!1}return t.length<n.length}reverse(){return r.withNamespaces(this.list().slice().reverse())}namespaces(){return this.list()}baseNamespace(){let e=this.namespaces();return e[e.length-1]}list(){return this.toString().split(R).slice(1)}type(){return bn(this.baseNamespace())}name(){return wn(this.baseNamespace())}instance(e){return new r(this.toString()+":"+e)}path(){let e=this.parent().toString();return e.endsWith(R)\|\|(e+=R),e+=this.type(),new r(e)}parent(){let e=this.list();return e.length===1?new r(R):new r(e.slice(0,-1).join(R))}child(e){return this.toString()===R?e:e.toString()===R?this:new r(this.toString()+e.toString(),!1)}isAncestorOf(e){return e.toString()===this.toString()?!1:e.toString().startsWith(this.toString())}isDecendantOf(e){return e.toString()===this.toString()?!1:this.toString().startsWith(e.toString())}isTopLevel(){return this.list().length===1}concat(...e){return r.withNamespaces([...this.namespaces(),...xn(e.map(t=>t.namespaces()))])}};function bn(r){let e=r.split(":");return e.length<2?"":e.slice(0,-1).join(":")}function wn(r){let e=r.split(":");return e[e.length-1]}function xn(r){return[].concat(...r)}var fe="/repo/flatfs/shard/",pe="SHARDING",X=class{param;name;_padding;constructor(e){this.param=e,this.name="base",this._padding=""}fun(e){return"implement me"}toString(){return`${fe}v1/${this.name}/${this.param}`}},le=class extends X{constructor(e){super(e),this._padding="".padStart(e,"_"),this.name="prefix"}fun(e){return(e+this._padding).slice(0,this.param)}},he=class extends X{constructor(e){super(e),this._padding="".padStart(e,"_"),this.name="suffix"}fun(e){let t=this._padding+e;return t.slice(t.length-this.param)}},de=class extends X{constructor(e){super(e),this._padding="".padStart(e+1,"_"),this.name="next-to-last"}fun(e){let t=this._padding+e,n=t.length-this.param-1;return t.slice(n,n+this.param)}};function Ot(r){if(r=r.trim(),r.length===0)throw new Error("empty shard string");if(!r.startsWith(fe))throw new Error(`invalid or no path prefix: ${r}`);let e=r.slice(fe.length).split("/"),t=e[0];if(t!=="v1")throw new Error(`expect 'v1' version, got '${t}'`);let n=e[1];if(e[2]==null\|\|e[2]==="")throw new Error("missing param");let o=parseInt(e[2],10);switch(n){case"prefix":return new le(o);case"suffix":return new he(o);case"next-to-last":return new de(o);default:throw new Error(`unkown sharding function: ${n}`)}}var me=async(r,e)=>{let t=new A(r).child(new A(pe)),o=await(typeof e.getRaw=="function"?e.getRaw.bind(e):e.get.bind(e))(t);return Ot(new TextDecoder().decode(o??"").trim())};function gn(r){return r[Symbol.asyncIterator]!=null}function vn(r){if(gn(r))return(async()=>{for await(let e of r);})();for(let e of r);}var Ye=vn;function Cn(r){let[e,t]=r[Symbol.asyncIterator]!=null?[r[Symbol.asyncIterator](),Symbol.asyncIterator]:[r[Symbol.iterator](),Symbol.iterator],n=[];return{peek:()=>e.next(),push:o=>{n.push(o)},next:()=>n.length>0?{done:!1,value:n.shift()}:e.next(),[t](){return this}}}var ye=Cn;function En(r){return r[Symbol.asyncIterator]!=null}function Sn(r,e){let t=0;if(En(r))return(async function(){for await(let h of r)await e(h,t++)&&(yield h)})();let n=ye(r),{value:o,done:s}=n.next();if(s===!0)return(function(){})();let i=e(o,t++);if(typeof i.then=="function")return(async function(){await i&&(yield o);for(let h of n)await e(h,t++)&&(yield h)})();let a=e;return(function(){i===!0&&(yield o);for(let h of n)a(h,t++)&&(yield h)})()}var U=Sn;function An(r){return r[Symbol.asyncIterator]!=null}function Fn(r){if(An(r))return(async()=>{let t=[];for await(let n of r)t.push(n);return t})();let e=[];for(let t of r)e.push(t);return e}var et=Fn;function In(r){return r[Symbol.asyncIterator]!=null}function Dn(r,e){return In(r)?(async function(){yield(await et(r)).sort(e)})():(function(){yieldet(r).sort(e)})()}var H=Dn;function kn(r){return r[Symbol.asyncIterator]!=null}function Nn(r,e){return kn(r)?(async function(){let t=0;if(!(e<1)){for await(let n of r)if(yield n,t++,t===e)return}})():(function(){let t=0;if(!(e<1)){for(let n of r)if(yield n,t++,t===e)return}})()}var Q=Nn;var D=class{put(e,t,n){return Promise.reject(new Error(".put is not implemented"))}get(e,t){return Promise.reject(new Error(".get is not implemented"))}has(e,t){return Promise.reject(new Error(".has is not implemented"))}delete(e,t){return Promise.reject(new Error(".delete is not implemented"))}asyncputMany(e,t={}){for await(let{key:n,value:o}of e)await this.put(n,o,t),yield n}asyncgetMany(e,t={}){for await(let n of e)yield{key:n,value:await this.get(n,t)}}asyncdeleteMany(e,t={}){for await(let n of e)await this.delete(n,t),yield n}batch(){let e=[],t=[];return{put(n,o){e.push({key:n,value:o})},delete(n){t.push(n)},commit:async n=>{await Ye(this.putMany(e,n)),e=[],await Ye(this.deleteMany(t,n)),t=[]}}}async_all(e,t){throw new Error("._all is not implemented")}async_allKeys(e,t){throw new Error("._allKeys is not implemented")}query(e,t){let n=this._all(e,t);if(e.prefix!=null){let o=e.prefix;n=U(n,s=>s.key.toString().startsWith(o))}if(Array.isArray(e.filters)&&(n=e.filters.reduce((o,s)=>U(o,s),n)),Array.isArray(e.orders)&&(n=e.orders.reduce((o,s)=>H(o,s),n)),e.offset!=null){let o=0,s=e.offset;n=U(n,()=>o++>=s)}return e.limit!=null&&(n=Q(n,e.limit)),n}queryKeys(e,t){let n=this._allKeys(e,t);if(e.prefix!=null){let o=e.prefix;n=U(n,s=>s.toString().startsWith(o))}if(Array.isArray(e.filters)&&(n=e.filters.reduce((o,s)=>U(o,s),n)),Array.isArray(e.orders)&&(n=e.orders.reduce((o,s)=>H(o,s),n)),e.offset!=null){let o=e.offset,s=0;n=U(n,()=>s++>=o)}return e.limit!=null&&(n=Q(n,e.limit)),n}};var be=class r extends Error{static name="OpenFailedError";name=r.name;static code="ERR_OPEN_FAILED";code=r.code;constructor(e="Open failed"){super(e)}};var we=class r extends Error{static name="PutFailedError";name=r.name;static code="ERR_PUT_FAILED";code=r.code;constructor(e="Put failed"){super(e)}};var xe=class r extends Error{static name="DeleteFailedError";name=r.name;static code="ERR_DELETE_FAILED";code=r.code;constructor(e="Delete failed"){super(e)}};var T=class r extends Error{static name="NotFoundError";name=r.name;static code="ERR_NOT_FOUND";code=r.code;constructor(e="Not Found"){super(e)}};var ge=class extends D{data;constructor(){super(),this.data=new Map}put(e,t,n){return n?.signal?.throwIfAborted(),this.data.set(e.toString(),t),e}get(e,t){t?.signal?.throwIfAborted();let n=this.data.get(e.toString());if(n==null)throw new T;return n}has(e,t){return t?.signal?.throwIfAborted(),this.data.has(e.toString())}delete(e,t){t?.signal?.throwIfAborted(),this.data.delete(e.toString())}_all(e,t){t?.signal?.throwIfAborted();for(let[n,o]of this.data.entries())yield{key:new A(n),value:o},t?.signal?.throwIfAborted()}_allKeys(e,t){t?.signal?.throwIfAborted();for(let n of this.data.keys())yield new A(n),t?.signal?.throwIfAborted()}};function Un(r){return r[Symbol.asyncIterator]!=null}function $n(r,e){let t=0;if(Un(r))return(async function(){for await(let h of r)yield e(h,t++)})();let n=ye(r),{value:o,done:s}=n.next();if(s===!0)return(function(){})();let i=e(o,t++);if(typeof i.then=="function")return(async function(){yield await i;for(let h of n)yield e(h,t++)})();let a=e;return(function(){yield i;for(let h of n)yield a(h,t++)})()}var $=$n;function O(){let r={};return r.promise=new Promise((e,t)=>{r.resolve=e,r.reject=t}),r}var ve=class{buffer;mask;top;btm;next;constructor(e){if(!(e>0)\|\|(e-1&e)!==0)throw new Error("Max size for a FixedFIFO should be a power of two");this.buffer=new Array(e),this.mask=e-1,this.top=0,this.btm=0,this.next=null}push(e){return this.buffer[this.top]!==void 0?!1:(this.buffer[this.top]=e,this.top=this.top+1&this.mask,!0)}shift(){let e=this.buffer[this.btm];if(e!==void 0)return this.buffer[this.btm]=void 0,this.btm=this.btm+1&this.mask,e}isEmpty(){return this.buffer[this.btm]===void 0}},Z=class{size;hwm;head;tail;constructor(e={}){this.hwm=e.splitLimit??16,this.head=new ve(this.hwm),this.tail=this.head,this.size=0}calculateSize(e){return e?.byteLength!=null?e.byteLength:1}push(e){if(e?.value!=null&&(this.size+=this.calculateSize(e.value)),!this.head.push(e)){let t=this.head;this.head=t.next=new ve(2this.head.buffer.length),this.head.push(e)}}shift(){let e=this.tail.shift();if(e===void 0&&this.tail.next!=null){let t=this.tail.next;this.tail.next=null,this.tail=t,e=this.tail.shift()}return e?.value!=null&&(this.size-=this.calculateSize(e.value)),e}isEmpty(){return this.head.isEmpty()}};var tt=class extends Error{type;code;constructor(e,t){super(e??"The operation was aborted"),this.type="aborted",this.code=t??"ABORT_ERR"}};function Pt(r={}){return Mn(t=>{let n=t.shift();if(n==null)return{done:!0};if(n.error!=null)throw n.error;return{done:n.done===!0,value:n.value}},r)}function Mn(r,e){e=e??{};let t=e.onEnd,n=new Z,o,s,i,a=O(),h=async()=>{try{return n.isEmpty()?i?{done:!0}:await new Promise((u,l)=>{s=m=>{s=null,n.push(m);try{u(r(n))}catch(y){l(y)}return o}}):r(n)}finally{n.isEmpty()&&queueMicrotask(()=>{a.resolve(),a=O()})}},E=u=>s!=null?s(u):(n.push(u),o),f=u=>(n=new Z,s!=null?s({error:u}):(n.push({error:u}),o)),p=u=>{if(i)return o;if(e?.objectMode!==!0&&u?.byteLength==null)throw new Error("objectMode was not true but tried to push non-Uint8Array value");return E({done:!1,value:u})},b=u=>i?o:(i=!0,u!=null?f(u):E({done:!0})),M=()=>(n=new Z,b(),{done:!0}),c=u=>(b(u),{done:!0});if(o={[Symbol.asyncIterator](){return this},next:h,return:M,throw:c,push:p,end:b,get readableLength(){return n.size},onEmpty:async u=>{let l=u?.signal;if(l?.throwIfAborted(),n.isEmpty())return;let m,y;l!=null&&(m=new Promise((w,x)=>{y=()=>{x(new tt)},l.addEventListener("abort",y)}));try{await Promise.race([a.promise,m])}finally{y!=null&&l!=null&&l?.removeEventListener("abort",y)}}},t==null)return o;let d=o;return o={[Symbol.asyncIterator](){return this},next(){return d.next()},throw(u){return d.throw(u),t!=null&&(t(u),t=void 0),{done:!0}},return(){return d.return(),t!=null&&(t(),t=void 0),{done:!0}},push:p,end(u){return d.end(u),t!=null&&(t(u),t=void 0),o},get readableLength(){return d.readableLength},onEmpty:u=>d.onEmpty(u)},o}function Ln(r){return r.reason}async function Tt(r,e,t){if(e==null)return r;let n=t?.translateError??Ln;if(e.aborted)return r.catch(()=>{}),Promise.reject(n(e));let o;try{return await Promise.race([r,new Promise((s,i)=>{o=()=>{i(n(e))},e.addEventListener("abort",o)})])}finally{o!=null&&e.removeEventListener("abort",o)}}var rt=class{readNext;haveNext;ended;nextResult;error;constructor(){this.ended=!1,this.readNext=O(),this.haveNext=O()}[Symbol.asyncIterator](){return this}async next(){if(this.nextResult==null&&await this.haveNext.promise,this.nextResult==null)throw new Error("HaveNext promise resolved but nextResult was undefined");let e=this.nextResult;return this.nextResult=void 0,this.readNext.resolve(),this.readNext=O(),e}async throw(e){return this.ended=!0,this.error=e,e!=null&&(this.haveNext.promise.catch(()=>{}),this.haveNext.reject(e)),{done:!0,value:void 0}}async return(){let e={done:!0,value:void 0};return this.ended=!0,this.nextResult=e,this.haveNext.resolve(),e}async push(e,t){await this._push(e,t)}async end(e,t){e!=null?await this.throw(e):await this._push(void 0,t)}async _push(e,t){if(e!=null&&this.ended)throw this.error??new Error("Cannot push value onto an ended pushable");for(;this.nextResult!=null;)await this.readNext.promise;e!=null?this.nextResult={done:!1,value:e}:(this.ended=!0,this.nextResult={done:!0,value:void 0}),this.haveNext.resolve(),this.haveNext=O(),await Tt(this.readNext.promise,t?.signal,t)}};function Bt(){return new rt}function zn(r){return r[Symbol.asyncIterator]!=null}async function Rn(r,e,t){try{await Promise.all(r.map(async n=>{for await(let o of n)await e.push(o,{signal:t}),t.throwIfAborted()})),await e.end(void 0,{signal:t})}catch(n){await e.end(n,{signal:t}).catch(()=>{})}}async functionOn(r){let e=new AbortController,t=Bt();Rn(r,t,e.signal).catch(()=>{});try{yieldt}finally{e.abort()}}functionPn(r){for(let e of r)yielde}function Tn(...r){let e=[];for(let t of r)zn(t)\|\|e.push(t);return e.length===r.length?Pn(e):On(r)}var se=Tn;function Ce(r,...e){if(r==null)throw new Error("Empty pipeline");if(nt(r)){let n=r;r=()=>n.source}else if(Kt(r)\|\|_t(r)){let n=r;r=()=>n}let t=[r,...e];if(t.length>1&&nt(t[t.length-1])&&(t[t.length-1]=t[t.length-1].sink),t.length>2)for(let n=1;n<t.length-1;n++)nt(t[n])&&(t[n]=_n(t[n]));return Bn(...t)}var Bn=(...r)=>{let e;for(;r.length>0;)e=r.shift()(e);return e},_t=r=>r?.[Symbol.asyncIterator]!=null,Kt=r=>r?.[Symbol.iterator]!=null,nt=r=>r==null?!1:r.sink!=null&&r.source!=null,_n=r=>e=>{let t=r.sink(e);if(t?.then!=null){let n=Pt({objectMode:!0});t.then(()=>{n.end()},i=>{n.end(i)});let o,s=r.source;if(_t(s))o=async function(){yields,n.end()};else if(Kt(s))o=function(){yields,n.end()};else throw new Error("Unknown duplex source type - must be Iterable or AsyncIterable");return se(n,o())}return r.source};var B=class extends D{child;transform;constructor(e,t){super(),this.child=e,this.transform=t}async put(e,t,n){return await this.child.put(this.transform.convert(e),t,n),e}async get(e,t){return this.child.get(this.transform.convert(e),t)}async has(e,t){return this.child.has(this.transform.convert(e),t)}async delete(e,t){await this.child.delete(this.transform.convert(e),t)}asyncputMany(e,t={}){let n=this.transform,o=this.child;yieldCe(e,async function(s){yield$(s,({key:i,value:a})=>({key:n.convert(i),value:a}))},async function(s){yieldo.putMany(s,t)},async function(s){yield$(s,i=>n.invert(i))})}asyncgetMany(e,t={}){let n=this.transform,o=this.child;yieldCe(e,async function(s){yield$(s,i=>n.convert(i))},async function(s){yieldo.getMany(s,t)},async function(s){yield$(s,({key:i,value:a})=>({key:n.invert(i),value:a}))})}asyncdeleteMany(e,t={}){let n=this.transform,o=this.child;yieldCe(e,async function(s){yield$(s,i=>n.convert(i))},async function(s){yieldo.deleteMany(s,t)},async function(s){yield*$(s,i=>n.invert(i))})}batch(){let e=this.child.batch();return{put:(t,n)=>{e.put(this.transform.convert(t),n)},delete:t=>{e.delete(this.transform.convert(t))},commit:async t=>{await e.commit(t)}}}query(e,t){let n={...e};n.filters=(n.filters??[]).map(s=>({key:i,value:a})=>s({key:this.transform.convert(i),value:a}));let{prefix:o}=e;return o!=null&&o!=="/"&&(delete n.prefix,n.filters.push(({key:s})=>this.transform.invert(s).toString().startsWith(o))),n.orders!=null&&(n.orders=n.orders.map(s=>(i,a)=>s({key:this.transform.invert(i.key),value:i.value},{key:this.transform.invert(a.key),value:a.value}))),$(this.child.query(n,t),({key:s,value:i})=>({key:this.transform.invert(s),value:i}))}queryKeys(e,t){let n={...e};n.filters=(n.filters??[]).map(s=>i=>s(this.transform.convert(i)));let{prefix:o}=e;return o!=null&&o!=="/"&&(delete n.prefix,n.filters.push(s=>this.transform.invert(s).toString().startsWith(o))),n.orders!=null&&(n.orders=n.orders.map(s=>(i,a)=>s(this.transform.invert(i),this.transform.invert(a)))),$(this.child.queryKeys(n,t),s=>this.transform.invert(s))}};var Y=new A(pe),Ee=class r extends D{child;shard;constructor(e,t){super(),this.child=new B(e,{convert:this._convertKey.bind(this),invert:this._invertKey.bind(this)}),this.shard=t}async open(){this.shard=await r.create(this.child,this.shard)}_convertKey(e){let t=e.toString();return t===Y.toString()?e:new A(this.shard.fun(t)).child(e)}_invertKey(e){return e.toString()===Y.toString()?e:A.withNamespaces(e.list().slice(1))}static async create(e,t){if(!await e.has(Y)){if(t==null)throw new be("Shard is required when datastore doesn't have a shard key already");await e.put(Y,new TextEncoder().encode(t.toString()+`
		`))}t==null&&(t=await me("/",e));let o=await me("/",e),s=o.toString(),i=t.toString();if(s!==i)throw new Error(`specified fun ${i} does not match repo shard fun ${s}`);return o}async put(e,t,n){return await this.child.put(e,t,n),e}async get(e,t){return this.child.get(e,t)}async has(e,t){return this.child.has(e,t)}async delete(e,t){await this.child.delete(e,t)}asyncputMany(e,t={}){yieldthis.child.putMany(e,t)}asyncgetMany(e,t={}){yieldthis.child.getMany(e,t)}asyncdeleteMany(e,t={}){yieldthis.child.deleteMany(e,t)}batch(){return this.child.batch()}query(e,t){let o={...e,filters:[({key:s})=>s.toString()!==Y.toString()].concat(e.filters??[])};return this.child.query(o,t)}queryKeys(e,t){let o={...e,filters:[s=>s.toString()!==Y.toString()].concat(e.filters??[])};return this.child.queryKeys(o,t)}};var Se=class extends D{mounts;constructor(e){super(),this.mounts=e.slice()}_lookup(e){for(let t of this.mounts)if(t.prefix.toString()===e.toString()\|\|t.prefix.isAncestorOf(e))return{datastore:t.datastore,mountpoint:t.prefix}}async put(e,t,n){let o=this._lookup(e);if(o==null)throw new we("No datastore mounted for this key");return await o.datastore.put(e,t,n),e}async get(e,t={}){let n=this._lookup(e);if(n==null)throw new T("No datastore mounted for this key");return n.datastore.get(e,t)}async has(e,t){let n=this._lookup(e);return n==null?Promise.resolve(!1):n.datastore.has(e,t)}async delete(e,t){let n=this._lookup(e);if(n==null)throw new xe("No datastore mounted for this key");await n.datastore.delete(e,t)}batch(){let e={},t=n=>{let o=this._lookup(n);if(o==null)throw new Error(`No datastore mounted for key "${n}"`);let s=o.mountpoint.toString();return e[s]==null&&(e[s]=o.datastore.batch()),{batch:e[s]}};return{put:(n,o)=>{t(n).batch.put(n,o)},delete:n=>{t(n).batch.delete(n)},commit:async n=>{await Promise.all(Object.keys(e).map(async o=>{await e[o].commit(n)}))}}}query(e,t){let n=this.mounts.map(s=>s.datastore.query({prefix:e.prefix,filters:e.filters},t)),o=se(...n);if(e.filters!=null&&e.filters.forEach(s=>{o=U(o,s)}),e.orders!=null&&e.orders.forEach(s=>{o=H(o,s)}),e.offset!=null){let s=0,i=e.offset;o=U(o,()=>s++>=i)}return e.limit!=null&&(o=Q(o,e.limit)),o}queryKeys(e,t){let n=this.mounts.map(s=>s.datastore.queryKeys({prefix:e.prefix,filters:e.filters},t)),o=se(...n);if(e.filters!=null&&e.filters.forEach(s=>{o=U(o,s)}),e.orders!=null&&e.orders.forEach(s=>{o=H(o,s)}),e.offset!=null){let s=0,i=e.offset;o=U(o,()=>s++>=i)}return e.limit!=null&&(o=Q(o,e.limit)),o}};var di=new Uint8Array(0);function jt(r){if(r instanceof Uint8Array&&r.constructor.name==="Uint8Array")return r;if(r instanceof ArrayBuffer)return new Uint8Array(r);if(ArrayBuffer.isView(r))return new Uint8Array(r.buffer,r.byteOffset,r.byteLength);throw new Error("Unknown type, must be binary type")}function Kn(r,e){if(r.length>=255)throw new TypeError("Alphabet too long");for(var t=new Uint8Array(256),n=0;n<t.length;n++)t[n]=255;for(var o=0;o<r.length;o++){var s=r.charAt(o),i=s.charCodeAt(0);if(t[i]!==255)throw new TypeError(s+" is ambiguous");t[i]=o}var a=r.length,h=r.charAt(0),E=Math.log(a)/Math.log(256),f=Math.log(256)/Math.log(a);function p(c){if(c instanceof Uint8Array\|\|(ArrayBuffer.isView(c)?c=new Uint8Array(c.buffer,c.byteOffset,c.byteLength):Array.isArray(c)&&(c=Uint8Array.from(c))),!(c instanceof Uint8Array))throw new TypeError("Expected Uint8Array");if(c.length===0)return"";for(var d=0,u=0,l=0,m=c.length;l!==m&&c[l]===0;)l++,d++;for(var y=(m-l)f+1>>>0,w=new Uint8Array(y);l!==m;){for(var x=c[l],S=0,g=y-1;(x!==0\|\|S<u)&&g!==-1;g--,S++)x+=256w[g]>>>0,w[g]=x%a>>>0,x=x/a>>>0;if(x!==0)throw new Error("Non-zero carry");u=S,l++}for(var C=y-u;C!==y&&w[C]===0;)C++;for(var N=h.repeat(d);C<y;++C)N+=r.charAt(w[C]);return N}function b(c){if(typeof c!="string")throw new TypeError("Expected String");if(c.length===0)return new Uint8Array;var d=0;if(c[d]!==" "){for(var u=0,l=0;c[d]===h;)u++,d++;for(var m=(c.length-d)E+1>>>0,y=new Uint8Array(m);c[d];){var w=t[c.charCodeAt(d)];if(w===255)return;for(var x=0,S=m-1;(w!==0\|\|x<l)&&S!==-1;S--,x++)w+=ay[S]>>>0,y[S]=w%256>>>0,w=w/256>>>0;if(w!==0)throw new Error("Non-zero carry");l=x,d++}if(c[d]!==" "){for(var g=m-l;g!==m&&y[g]===0;)g++;for(var C=new Uint8Array(u+(m-g)),N=u;g!==m;)C[N++]=y[g++];return C}}}function M(c){var d=b(c);if(d)return d;throw new Error(`Non-${e} character`)}return{encode:p,decodeUnsafe:b,decode:M}}var jn=Kn,Vn=jn,Vt=Vn;var ot=class{name;prefix;baseEncode;constructor(e,t,n){this.name=e,this.prefix=t,this.baseEncode=n}encode(e){if(e instanceof Uint8Array)return`${this.prefix}${this.baseEncode(e)}`;throw Error("Unknown type, must be binary type")}},st=class{name;prefix;baseDecode;prefixCodePoint;constructor(e,t,n){this.name=e,this.prefix=t;let o=t.codePointAt(0);if(o===void 0)throw new Error("Invalid prefix character");this.prefixCodePoint=o,this.baseDecode=n}decode(e){if(typeof e=="string"){if(e.codePointAt(0)!==this.prefixCodePoint)throw Error(`Unable to decode multibase string ${JSON.stringify(e)}, ${this.name} decoder only supports inputs prefixed with ${this.prefix}`);return this.baseDecode(e.slice(this.prefix.length))}else throw Error("Can only multibase decode strings")}or(e){return Jt(this,e)}},it=class{decoders;constructor(e){this.decoders=e}or(e){return Jt(this,e)}decode(e){let t=e[0],n=this.decoders[t];if(n!=null)return n.decode(e);throw RangeError(`Unable to decode multibase string ${JSON.stringify(e)}, only inputs prefixed with ${Object.keys(this.decoders)} are supported`)}};function Jt(r,e){return new it({...r.decoders??{[r.prefix]:r},...e.decoders??{[e.prefix]:e}})}var at=class{name;prefix;baseEncode;baseDecode;encoder;decoder;constructor(e,t,n,o){this.name=e,this.prefix=t,this.baseEncode=n,this.baseDecode=o,this.encoder=new ot(e,t,n),this.decoder=new st(e,t,o)}encode(e){return this.encoder.encode(e)}decode(e){return this.decoder.decode(e)}};function qt({name:r,prefix:e,encode:t,decode:n}){return new at(r,e,t,n)}function ct({name:r,prefix:e,alphabet:t}){let{encode:n,decode:o}=Vt(t,r);return qt({prefix:e,name:r,encode:n,decode:s=>jt(o(s))})}function Jn(r,e,t,n){let o=r.length;for(;r[o-1]==="=";)--o;let s=new Uint8Array(ot/8\|0),i=0,a=0,h=0;for(let E=0;E<o;++E){let f=e[r[E]];if(f===void 0)throw new SyntaxError(`Non-${n} character`);a=a<<t\|f,i+=t,i>=8&&(i-=8,s[h++]=255&a>>i)}if(i>=t\|\|(255&a<<8-i)!==0)throw new SyntaxError("Unexpected end of data");return s}function qn(r,e,t){let n=e[e.length-1]==="=",o=(1<<t)-1,s="",i=0,a=0;for(let h=0;h<r.length;++h)for(a=a<<8\|r[h],i+=8;i>t;)i-=t,s+=e[o&a>>i];if(i!==0&&(s+=e[o&a<<t-i]),n)for(;(s.lengtht&7)!==0;)s+="=";return s}function Wn(r){let e={};for(let t=0;t<r.length;++t)e[r[t]]=t;return e}function F({name:r,prefix:e,bitsPerChar:t,alphabet:n}){let o=Wn(n);return qt({prefix:e,name:r,encode(s){return qn(s,n,t)},decode(s){return Jn(s,o,t,r)}})}var Wt=F({prefix:"b",name:"base32",alphabet:"abcdefghijklmnopqrstuvwxyz234567",bitsPerChar:5}),gi=F({prefix:"B",name:"base32upper",alphabet:"ABCDEFGHIJKLMNOPQRSTUVWXYZ234567",bitsPerChar:5}),vi=F({prefix:"c",name:"base32pad",alphabet:"abcdefghijklmnopqrstuvwxyz234567=",bitsPerChar:5}),Ci=F({prefix:"C",name:"base32padupper",alphabet:"ABCDEFGHIJKLMNOPQRSTUVWXYZ234567=",bitsPerChar:5}),Ei=F({prefix:"v",name:"base32hex",alphabet:"0123456789abcdefghijklmnopqrstuv",bitsPerChar:5}),Si=F({prefix:"V",name:"base32hexupper",alphabet:"0123456789ABCDEFGHIJKLMNOPQRSTUV",bitsPerChar:5}),Ai=F({prefix:"t",name:"base32hexpad",alphabet:"0123456789abcdefghijklmnopqrstuv=",bitsPerChar:5}),Fi=F({prefix:"T",name:"base32hexpadupper",alphabet:"0123456789ABCDEFGHIJKLMNOPQRSTUV=",bitsPerChar:5}),Ii=F({prefix:"h",name:"base32z",alphabet:"ybndrfg8ejkmcpqxot1uwisza345h769",bitsPerChar:5});var Gt=ct({name:"base58btc",prefix:"z",alphabet:"123456789ABCDEFGHJKLMNPQRSTUVWXYZabcdefghijkmnopqrstuvwxyz"}),Ni=ct({name:"base58flickr",prefix:"Z",alphabet:"123456789abcdefghijkmnopqrstuvwxyzABCDEFGHJKLMNPQRSTUVWXYZ"});var Xt=F({prefix:"m",name:"base64",alphabet:"ABCDEFGHIJKLMNOPQRSTUVWXYZabcdefghijklmnopqrstuvwxyz0123456789+/",bitsPerChar:6}),Mi=F({prefix:"M",name:"base64pad",alphabet:"ABCDEFGHIJKLMNOPQRSTUVWXYZabcdefghijklmnopqrstuvwxyz0123456789+/=",bitsPerChar:6}),Li=F({prefix:"u",name:"base64url",alphabet:"ABCDEFGHIJKLMNOPQRSTUVWXYZabcdefghijklmnopqrstuvwxyz0123456789-_",bitsPerChar:6}),zi=F({prefix:"U",name:"base64urlpad",alphabet:"ABCDEFGHIJKLMNOPQRSTUVWXYZabcdefghijklmnopqrstuvwxyz0123456789-_=",bitsPerChar:6});function Gn(r,e){if(typeof r=="string")return Xn(r);if(typeof r=="number")return Zn(r,e);throw Error(`Value provided to ms() must be a string or number. value=${JSON.stringify(r)}`)}var Ae=Gn;function Xn(r){if(typeof r!="string"\|\|r.length===0\|\|r.length>100)throw Error(`Value provided to ms.parse() must be a string with length between 1 and 99. value=${JSON.stringify(r)}`);let e=/^(?<value>-?\d\.?\d+) (?<unit>milliseconds?\|msecs?\|ms\|seconds?\|secs?\|s\|minutes?\|mins?\|m\|hours?\|hrs?\|h\|days?\|d\|weeks?\|w\|months?\|mo\|years?\|yrs?\|y)?$/i.exec(r);if(!e?.groups)return NaN;let{value:t,unit:n="ms"}=e.groups,o=parseFloat(t),s=n.toLowerCase();switch(s){case"years":case"year":case"yrs":case"yr":case"y":return o315576e5;case"months":case"month":case"mo":return o26298e5;case"weeks":case"week":case"w":return o6048e5;case"days":case"day":case"d":return o864e5;case"hours":case"hour":case"hrs":case"hr":case"h":return o36e5;case"minutes":case"minute":case"mins":case"min":case"m":return o6e4;case"seconds":case"second":case"secs":case"sec":case"s":return o1e3;case"milliseconds":case"millisecond":case"msecs":case"msec":case"ms":return o;default:throw Error(`Unknown unit "${s}" provided to ms.parse(). value=${JSON.stringify(r)}`)}}function Hn(r){let e=Math.abs(r);return e>=315576e5?`${Math.round(r/315576e5)}y`:e>=26298e5?`${Math.round(r/26298e5)}mo`:e>=6048e5?`${Math.round(r/6048e5)}w`:e>=864e5?`${Math.round(r/864e5)}d`:e>=36e5?`${Math.round(r/36e5)}h`:e>=6e4?`${Math.round(r/6e4)}m`:e>=1e3?`${Math.round(r/1e3)}s`:`${r}ms`}function Qn(r){let e=Math.abs(r);return e>=315576e5?K(r,e,315576e5,"year"):e>=26298e5?K(r,e,26298e5,"month"):e>=6048e5?K(r,e,6048e5,"week"):e>=864e5?K(r,e,864e5,"day"):e>=36e5?K(r,e,36e5,"hour"):e>=6e4?K(r,e,6e4,"minute"):e>=1e3?K(r,e,1e3,"second"):`${r} ms`}function Zn(r,e){if(typeof r!="number"\|\|!Number.isFinite(r))throw Error("Value provided to ms.format() must be of type number.");return e?.long?Qn(r):Hn(r)}function K(r,e,t,n){let o=e>=t1.5;return`${Math.round(r/t)} ${n}${o?"s":""}`}function ut(r){t.debug=t,t.default=t,t.coerce=h,t.disable=s,t.enable=o,t.enabled=i,t.humanize=Ae,t.destroy=E,Object.keys(r).forEach(f=>{t[f]=r[f]}),t.names=[],t.skips=[],t.formatters={};function e(f){let p=0;for(let b=0;b<f.length;b++)p=(p<<5)-p+f.charCodeAt(b),p\|=0;return t.colors[Math.abs(p)%t.colors.length]}t.selectColor=e;function t(f,p){let b,M=null,c,d;function u(...l){if(!u.enabled)return;let m=u,y=Number(new Date),w=y-(b\|\|y);m.diff=w,m.prev=b,m.curr=y,b=y,l[0]=t.coerce(l[0]),typeof l[0]!="string"&&l.unshift("%O");let x=0;l[0]=l[0].replace(/%([a-zA-Z%])/g,(g,C)=>{if(g==="%%")return"%";x++;let N=t.formatters[C];if(typeof N=="function"){let er=l[x];g=N.call(m,er),l.splice(x,1),x--}return g}),t.formatArgs.call(m,l),p?.onLog!=null&&p.onLog(...l),(m.log\|\|t.log).apply(m,l)}return u.namespace=f,u.useColors=t.useColors(),u.color=t.selectColor(f),u.extend=n,u.destroy=t.destroy,Object.defineProperty(u,"enabled",{enumerable:!0,configurable:!1,get:()=>M!==null?M:(c!==t.namespaces&&(c=t.namespaces,d=t.enabled(f)),d),set:l=>{M=l}}),typeof t.init=="function"&&t.init(u),u}function n(f,p){let b=t(this.namespace+(typeof p>"u"?":":p)+f);return b.log=this.log,b}function o(f){t.save(f),t.namespaces=f,t.names=[],t.skips=[];let p,b=(typeof f=="string"?f:"").split(/[\s,]+/),M=b.length;for(p=0;p<M;p++)b[p]&&(f=b[p].replace(/\/g,".?"),f[0]==="-"?t.skips.push(new RegExp("^"+f.substr(1)+"$")):t.names.push(new RegExp("^"+f+"$")))}function s(){let f=[...t.names.map(a),...t.skips.map(a).map(p=>"-"+p)].join(",");return t.enable(""),f}function i(f){if(f[f.length-1]==="")return!0;let p,b;for(p=0,b=t.skips.length;p<b;p++)if(t.skips[p].test(f))return!1;for(p=0,b=t.names.length;p<b;p++)if(t.names[p].test(f))return!0;return!1}function a(f){return f.toString().substring(2,f.toString().length-2).replace(/\.\\?$/,"*")}function h(f){return f instanceof Error?f.stack??f.message:f}function E(){console.warn("Instance method `debug.destroy()` is deprecated and no longer does anything. It will be removed in the next major version of `debug`.")}return t.setupFormatters(t.formatters),t.enable(t.load()),t}var Fe=so(),Yn=["#0000CC","#0000FF","#0033CC","#0033FF","#0066CC","#0066FF","#0099CC","#0099FF","#00CC00","#00CC33","#00CC66","#00CC99","#00CCCC","#00CCFF","#3300CC","#3300FF","#3333CC","#3333FF","#3366CC","#3366FF","#3399CC","#3399FF","#33CC00","#33CC33","#33CC66","#33CC99","#33CCCC","#33CCFF","#6600CC","#6600FF","#6633CC","#6633FF","#66CC00","#66CC33","#9900CC","#9900FF","#9933CC","#9933FF","#99CC00","#99CC33","#CC0000","#CC0033","#CC0066","#CC0099","#CC00CC","#CC00FF","#CC3300","#CC3333","#CC3366","#CC3399","#CC33CC","#CC33FF","#CC6600","#CC6633","#CC9900","#CC9933","#CCCC00","#CCCC33","#FF0000","#FF0033","#FF0066","#FF0099","#FF00CC","#FF00FF","#FF3300","#FF3333","#FF3366","#FF3399","#FF33CC","#FF33FF","#FF6600","#FF6633","#FF9900","#FF9933","#FFCC00","#FFCC33"];function eo(){return typeof window<"u"&&window.process&&(window.process.type==="renderer"\|\|window.process.__nwjs)?!0:typeof navigator<"u"&&navigator.userAgent?.toLowerCase().match(/(edge\|trident)\/(\d+)/)!=null?!1:typeof document<"u"&&document.documentElement?.style?.WebkitAppearance\|\|typeof window<"u"&&window.console&&(window.console.firebug\|\|window.console.exception&&window.console.table)\|\|typeof navigator<"u"&&navigator.userAgent?.toLowerCase().match(/firefox\/(\d+)/)!=null&&parseInt(RegExp.$1,10)>=31\|\|typeof navigator<"u"&&navigator.userAgent?.toLowerCase().match(/applewebkit\/(\d+)/)}function to(r){if(r[0]=(this.useColors?"%c":"")+this.namespace+(this.useColors?" %c":" ")+r[0]+(this.useColors?"%c ":" ")+"+"+Ae(this.diff),!this.useColors)return;let e="color: "+this.color;r.splice(1,0,e,"color: inherit");let t=0,n=0;r[0].replace(/%[a-zA-Z%]/g,o=>{o!=="%%"&&(t++,o==="%c"&&(n=t))}),r.splice(n,0,e)}var ro=console.debug??console.log??(()=>{});function no(r){try{r?Fe?.setItem("debug",r):Fe?.removeItem("debug")}catch{}}function oo(){let r;try{r=Fe?.getItem("debug")}catch{}return!r&&typeof globalThis.process<"u"&&"env"in globalThis.process&&(r=globalThis.process.env.DEBUG),r}function so(){try{return localStorage}catch{}}function io(r){r.j=function(e){try{return JSON.stringify(e)}catch(t){return"[UnexpectedJSONParseError]: "+t.message}}}var Ht=ut({formatArgs:to,save:no,load:oo,useColors:eo,setupFormatters:io,colors:Yn,storage:Fe,log:ro});var k=Ht;k.formatters.b=r=>r==null?"undefined":Gt.baseEncode(r);k.formatters.t=r=>r==null?"undefined":Wt.baseEncode(r);k.formatters.m=r=>r==null?"undefined":Xt.baseEncode(r);k.formatters.p=r=>r==null?"undefined":r.toString();k.formatters.c=r=>r==null?"undefined":r.toString();k.formatters.k=r=>r==null?"undefined":r.toString();k.formatters.a=r=>r==null?"undefined":r.toString();function Qt(r,e=""){let t=Zt(r.message),n=Zt(r.stack);return t!=null&&n!=null?n.includes(t)?`${n.split(`
		`).join(`
		@@ -10,7 +10,7 @@ ${e}`)}`:`${t}
		`).join(`
		${e}`)}`:t!=null?`${t}`:`${r.toString()}`}function _n(r){return r instanceof AggregateError\|\|r?.name==="AggregateError"&&Array.isArray(r.errors)}function _t(r,e=""){if(_n(r)){let t=zt(r,e);return r.errors.length>0?(e=`${e} `,t+=`
		${e}${r.errors.map(n=>`${_t(n,`${e}`)}`).join(`
		${e}`)}`:t!=null?`${t}`:`${r.toString()}`}function ao(r){return r instanceof AggregateError\|\|r?.name==="AggregateError"&&Array.isArray(r.errors)}function Yt(r,e=""){if(ao(r)){let t=Qt(r,e);return r.errors.length>0?(e=`${e} `,t+=`
		${e}${r.errors.map(n=>`${Yt(n,`${e}`)}`).join(`
		${e}`)}`):t+=`
		${e}[Error list was empty]`,t.trim()}return zt(r,e)}A.formatters.e=r=>r==null?"undefined":_t(r);function Kn(r){let e=()=>{};return e.enabled=!1,e.color="",e.diff=0,e.log=()=>{},e.namespace=r,e.destroy=()=>!0,e.extend=()=>e,e}function ot(r,e){let t=Kn(`${r}:trace`);return A.enabled(`${r}:trace`)&&A.names.map(n=>n.toString()).find(n=>n.includes(":trace"))!=null&&(t=A(`${r}:trace`,e)),Object.assign(A(r,e),{error:A(`${r}:error`,e),trace:t,newScope:n=>ot(`${r}:${n}`,e)})}function Pt(r){if(r!=null&&(r=r.trim(),r.length!==0))return r}var jn=ot("datastore:core:tiered"),Ae=class extends E{stores;constructor(e){super(),this.stores=e.slice()}async put(e,t,n){return await Promise.all(this.stores.map(async o=>{await o.put(e,t,n)})),e}async get(e,t){let n;for(let o of this.stores)try{let s=await o.get(e,t);if(s!=null)return s}catch(s){n=s,jn.error(s)}throw n??new z}async has(e,t){for(let n of this.stores)if(await n.has(e,t))return!0;return!1}async delete(e,t){await Promise.all(this.stores.map(async n=>{await n.delete(e,t)}))}asyncputMany(e,t={}){for await(let n of e)await this.put(n.key,n.value,t),yield n.key}asyncdeleteMany(e,t={}){for await(let n of e)await this.delete(n,t),yield n}batch(){let e=this.stores.map(t=>t.batch());return{put:(t,n)=>{e.forEach(o=>{o.put(t,n)})},delete:t=>{e.forEach(n=>{n.delete(t)})},commit:async t=>{for(let n of e)await n.commit(t)}}}query(e,t){return this.stores[this.stores.length-1].query(e,t)}queryKeys(e,t){return this.stores[this.stores.length-1].queryKeys(e,t)}};var Fe=class extends P{iChild;iKey;constructor(e,t){super(e,{convert(n){return t.child(n)},invert(n){if(t.toString()==="/")return n;if(!t.isAncestorOf(n))throw new Error(`Expected prefix: (${t.toString()}) in key: ${n.toString()}`);return new C(n.toString().slice(t.toString().length),!1)}}),this.iChild=e,this.iKey=t}query(e,t){let n={...e};n.filters=(n.filters??[]).map(s=>({key:i,value:a})=>s({key:this.transform.invert(i),value:a}));let{prefix:o}=e;return o!=null&&o!=="/"&&(delete n.prefix,n.filters.push(({key:s})=>this.transform.invert(s).toString().startsWith(o))),n.orders!=null&&(n.orders=n.orders.map(s=>(i,a)=>s({key:this.transform.invert(i.key),value:i.value},{key:this.transform.invert(a.key),value:a.value}))),n.filters.unshift(({key:s})=>this.iKey.isAncestorOf(s)),N(this.iChild.query(n,t),({key:s,value:i})=>({key:this.transform.invert(s),value:i}))}queryKeys(e,t){let n={...e};n.filters=(n.filters??[]).map(s=>i=>s(this.transform.invert(i)));let{prefix:o}=e;return o!=null&&o!=="/"&&(delete n.prefix,n.filters.push(s=>this.transform.invert(s).toString().startsWith(o))),n.orders!=null&&(n.orders=n.orders.map(s=>(i,a)=>s(this.transform.invert(i),this.transform.invert(a)))),n.filters.unshift(s=>this.iKey.isAncestorOf(s)),N(this.iChild.queryKeys(n,t),s=>this.transform.invert(s))}};return Wt(Bn);})();
		${e}[Error list was empty]`,t.trim()}return Qt(r,e)}k.formatters.e=r=>r==null?"undefined":Yt(r);function co(r){let e=()=>{};return e.enabled=!1,e.color="",e.diff=0,e.log=()=>{},e.namespace=r,e.destroy=()=>!0,e.extend=()=>e,e}function ft(r,e){let t=co(`${r}:trace`);return k.enabled(`${r}:trace`)&&k.names.map(n=>n.toString()).find(n=>n.includes(":trace"))!=null&&(t=k(`${r}:trace`,e)),Object.assign(k(r,e),{error:k(`${r}:error`,e),trace:t,newScope:n=>ft(`${r}:${n}`,e)})}function Zt(r){if(r!=null&&(r=r.trim(),r.length!==0))return r}var uo=ft("datastore:core:tiered"),Ie=class extends D{stores;constructor(e){super(),this.stores=e.slice()}async put(e,t,n){return await Promise.all(this.stores.map(async o=>{await o.put(e,t,n)})),e}async get(e,t){let n;for(let o of this.stores)try{let s=await o.get(e,t);if(s!=null)return s}catch(s){n=s,uo.error(s)}throw n??new T}async has(e,t){for(let n of this.stores)if(await n.has(e,t))return!0;return!1}async delete(e,t){await Promise.all(this.stores.map(async n=>{await n.delete(e,t)}))}asyncputMany(e,t={}){for await(let n of e)await this.put(n.key,n.value,t),yield n.key}asyncdeleteMany(e,t={}){for await(let n of e)await this.delete(n,t),yield n}batch(){let e=this.stores.map(t=>t.batch());return{put:(t,n)=>{e.forEach(o=>{o.put(t,n)})},delete:t=>{e.forEach(n=>{n.delete(t)})},commit:async t=>{for(let n of e)await n.commit(t)}}}query(e,t){return this.stores[this.stores.length-1].query(e,t)}queryKeys(e,t){return this.stores[this.stores.length-1].queryKeys(e,t)}};var De=class extends B{iChild;iKey;constructor(e,t){super(e,{convert(n){return t.child(n)},invert(n){if(t.toString()==="/")return n;if(!t.isAncestorOf(n))throw new Error(`Expected prefix: (${t.toString()}) in key: ${n.toString()}`);return new A(n.toString().slice(t.toString().length),!1)}}),this.iChild=e,this.iKey=t}query(e,t){let n={...e};n.filters=(n.filters??[]).map(s=>({key:i,value:a})=>s({key:this.transform.invert(i),value:a}));let{prefix:o}=e;return o!=null&&o!=="/"&&(delete n.prefix,n.filters.push(({key:s})=>this.transform.invert(s).toString().startsWith(o))),n.orders!=null&&(n.orders=n.orders.map(s=>(i,a)=>s({key:this.transform.invert(i.key),value:i.value},{key:this.transform.invert(a.key),value:a.value}))),n.filters.unshift(({key:s})=>this.iKey.isAncestorOf(s)),$(this.iChild.query(n,t),({key:s,value:i})=>({key:this.transform.invert(s),value:i}))}queryKeys(e,t){let n={...e};n.filters=(n.filters??[]).map(s=>i=>s(this.transform.invert(i)));let{prefix:o}=e;return o!=null&&o!=="/"&&(delete n.prefix,n.filters.push(s=>this.transform.invert(s).toString().startsWith(o))),n.orders!=null&&(n.orders=n.orders.map(s=>(i,a)=>s(this.transform.invert(i),this.transform.invert(a)))),n.filters.unshift(s=>this.iKey.isAncestorOf(s)),$(this.iChild.queryKeys(n,t),s=>this.transform.invert(s))}};return sr(fo);})();
		return DatastoreCore}));
		//# sourceMappingURL=index.min.js.map

+12

-12

dist/src/base.d.ts

		@@ -0,11 +1,11 @@
		import type { AbortOptions } from 'abort-error';
		import type { Batch, Datastore, Key, KeyQuery, Pair, Query } from 'interface-datastore';
		import type { AbortOptions, Await, AwaitGenerator, AwaitIterable } from 'interface-store';
		export declare class BaseDatastore implements Datastore {
		put(key: Key, val: Uint8Array, options?: AbortOptions): Await<Key>;
		get(key: Key, options?: AbortOptions): Await<Uint8Array>;
		has(key: Key, options?: AbortOptions): Await<boolean>;
		delete(key: Key, options?: AbortOptions): Await<void>;
		putMany(source: AwaitIterable<Pair>, options?: AbortOptions): AwaitGenerator<Key>;
		getMany(source: AwaitIterable<Key>, options?: AbortOptions): AwaitGenerator<Pair>;
		deleteMany(source: AwaitIterable<Key>, options?: AbortOptions): AwaitGenerator<Key>;
		put(key: Key, val: Uint8Array, options?: AbortOptions): Key \| Promise<Key>;
		get(key: Key, options?: AbortOptions): Uint8Array \| Promise<Uint8Array>;
		has(key: Key, options?: AbortOptions): boolean \| Promise<boolean>;
		delete(key: Key, options?: AbortOptions): void \| Promise<void>;
		putMany(source: Iterable<Pair> \| AsyncIterable<Pair>, options?: AbortOptions): Generator<Key> \| AsyncGenerator<Key>;
		getMany(source: Iterable<Key> \| AsyncIterable<Key>, options?: AbortOptions): Generator<Pair> \| AsyncGenerator<Pair>;
		deleteMany(source: Iterable<Key> \| AsyncIterable<Key>, options?: AbortOptions): Generator<Key> \| AsyncGenerator<Key>;
		batch(): Batch;
		@@ -15,10 +15,10 @@ /**
		*/
		_all(q: Query, options?: AbortOptions): AwaitGenerator<Pair>;
		_all(q: Query, options?: AbortOptions): Generator<Pair> \| AsyncGenerator<Pair>;
		/**
		* Extending classes should override `queryKeys` or implement this method
		*/
		_allKeys(q: KeyQuery, options?: AbortOptions): AwaitGenerator<Key>;
		query(q: Query, options?: AbortOptions): AwaitGenerator<Pair>;
		queryKeys(q: KeyQuery, options?: AbortOptions): AwaitGenerator<Key>;
		_allKeys(q: KeyQuery, options?: AbortOptions): Generator<Key> \| AsyncGenerator<Key>;
		query(q: Query, options?: AbortOptions): Generator<Pair> \| AsyncGenerator<Pair>;
		queryKeys(q: KeyQuery, options?: AbortOptions): Generator<Key> \| AsyncGenerator<Key>;
		}
		//# sourceMappingURL=base.d.ts.map

+1

-1

dist/src/base.d.ts.map

		@@ -1,1 +0,1 @@
		{"version":3,"file":"base.d.ts","sourceRoot":"","sources":["../../src/base.ts"],"names":[],"mappings":"AAIA,OAAO,KAAK,EAAE,KAAK,EAAE,SAAS,EAAE,GAAG,EAAE,QAAQ,EAAE,IAAI,EAAE,KAAK,EAAE,MAAM,qBAAqB,CAAA;AACvF,OAAO,KAAK,EAAE,YAAY,EAAE,KAAK,EAAE,cAAc,EAAE,aAAa,EAAE,MAAM,iBAAiB,CAAA;AAEzF,qBAAa,aAAc,YAAW,SAAS;IAC7C,GAAG,CAAE,GAAG,EAAE,GAAG,EAAE,GAAG,EAAE,UAAU,EAAE,OAAO,CAAC,EAAE,YAAY,GAAG,KAAK,CAAC,GAAG,CAAC;IAInE,GAAG,CAAE,GAAG,EAAE,GAAG,EAAE,OAAO,CAAC,EAAE,YAAY,GAAG,KAAK,CAAC,UAAU,CAAC;IAIzD,GAAG,CAAE,GAAG,EAAE,GAAG,EAAE,OAAO,CAAC,EAAE,YAAY,GAAG,KAAK,CAAC,OAAO,CAAC;IAItD,MAAM,CAAE,GAAG,EAAE,GAAG,EAAE,OAAO,CAAC,EAAE,YAAY,GAAG,KAAK,CAAC,IAAI,CAAC;IAI9C,OAAO,CAAE,MAAM,EAAE,aAAa,CAAC,IAAI,CAAC,EAAE,OAAO,GAAE,YAAiB,GAAG,cAAc,CAAC,GAAG,CAAC;IAOtF,OAAO,CAAE,MAAM,EAAE,aAAa,CAAC,GAAG,CAAC,EAAE,OAAO,GAAE,YAAiB,GAAG,cAAc,CAAC,IAAI,CAAC;IAStF,UAAU,CAAE,MAAM,EAAE,aAAa,CAAC,GAAG,CAAC,EAAE,OAAO,GAAE,YAAiB,GAAG,cAAc,CAAC,GAAG,CAAC;IAOhG,KAAK,IAAK,KAAK;IAqBf;;OAEG;IAEK,IAAI,CAAE,CAAC,EAAE,KAAK,EAAE,OAAO,CAAC,EAAE,YAAY,GAAG,cAAc,CAAC,IAAI,CAAC;IAIrE;;OAEG;IAEK,QAAQ,CAAE,CAAC,EAAE,QAAQ,EAAE,OAAO,CAAC,EAAE,YAAY,GAAG,cAAc,CAAC,GAAG,CAAC;IAI3E,KAAK,CAAE,CAAC,EAAE,KAAK,EAAE,OAAO,CAAC,EAAE,YAAY,GAAG,cAAc,CAAC,IAAI,CAAC;IA6B9D,SAAS,CAAE,CAAC,EAAE,QAAQ,EAAE,OAAO,CAAC,EAAE,YAAY,GAAG,cAAc,CAAC,GAAG,CAAC;CA8BrE"}
		{"version":3,"file":"base.d.ts","sourceRoot":"","sources":["../../src/base.ts"],"names":[],"mappings":"AAIA,OAAO,KAAK,EAAE,YAAY,EAAE,MAAM,aAAa,CAAA;AAC/C,OAAO,KAAK,EAAE,KAAK,EAAE,SAAS,EAAE,GAAG,EAAE,QAAQ,EAAE,IAAI,EAAE,KAAK,EAAE,MAAM,qBAAqB,CAAA;AAEvF,qBAAa,aAAc,YAAW,SAAS;IAC7C,GAAG,CAAE,GAAG,EAAE,GAAG,EAAE,GAAG,EAAE,UAAU,EAAE,OAAO,CAAC,EAAE,YAAY,GAAG,GAAG,GAAG,OAAO,CAAC,GAAG,CAAC;IAI3E,GAAG,CAAE,GAAG,EAAE,GAAG,EAAE,OAAO,CAAC,EAAE,YAAY,GAAG,UAAU,GAAG,OAAO,CAAC,UAAU,CAAC;IAIxE,GAAG,CAAE,GAAG,EAAE,GAAG,EAAE,OAAO,CAAC,EAAE,YAAY,GAAG,OAAO,GAAG,OAAO,CAAC,OAAO,CAAC;IAIlE,MAAM,CAAE,GAAG,EAAE,GAAG,EAAE,OAAO,CAAC,EAAE,YAAY,GAAG,IAAI,GAAG,OAAO,CAAC,IAAI,CAAC;IAIvD,OAAO,CAAE,MAAM,EAAE,QAAQ,CAAC,IAAI,CAAC,GAAG,aAAa,CAAC,IAAI,CAAC,EAAE,OAAO,GAAE,YAAiB,GAAG,SAAS,CAAC,GAAG,CAAC,GAAG,cAAc,CAAC,GAAG,CAAC;IAOxH,OAAO,CAAE,MAAM,EAAE,QAAQ,CAAC,GAAG,CAAC,GAAG,aAAa,CAAC,GAAG,CAAC,EAAE,OAAO,GAAE,YAAiB,GAAG,SAAS,CAAC,IAAI,CAAC,GAAG,cAAc,CAAC,IAAI,CAAC;IASxH,UAAU,CAAE,MAAM,EAAE,QAAQ,CAAC,GAAG,CAAC,GAAG,aAAa,CAAC,GAAG,CAAC,EAAE,OAAO,GAAE,YAAiB,GAAG,SAAS,CAAC,GAAG,CAAC,GAAG,cAAc,CAAC,GAAG,CAAC;IAOjI,KAAK,IAAK,KAAK;IAqBf;;OAEG;IAEK,IAAI,CAAE,CAAC,EAAE,KAAK,EAAE,OAAO,CAAC,EAAE,YAAY,GAAG,SAAS,CAAC,IAAI,CAAC,GAAG,cAAc,CAAC,IAAI,CAAC;IAIvF;;OAEG;IAEK,QAAQ,CAAE,CAAC,EAAE,QAAQ,EAAE,OAAO,CAAC,EAAE,YAAY,GAAG,SAAS,CAAC,GAAG,CAAC,GAAG,cAAc,CAAC,GAAG,CAAC;IAI5F,KAAK,CAAE,CAAC,EAAE,KAAK,EAAE,OAAO,CAAC,EAAE,YAAY,GAAG,SAAS,CAAC,IAAI,CAAC,GAAG,cAAc,CAAC,IAAI,CAAC;IA6BhF,SAAS,CAAE,CAAC,EAAE,QAAQ,EAAE,OAAO,CAAC,EAAE,YAAY,GAAG,SAAS,CAAC,GAAG,CAAC,GAAG,cAAc,CAAC,GAAG,CAAC;CA8BtF"}

+1

-1

dist/src/base.js.map

		@@ -1,1 +0,1 @@
		{"version":3,"file":"base.js","sourceRoot":"","sources":["../../src/base.ts"],"names":[],"mappings":"AAAA,OAAO,KAAK,MAAM,UAAU,CAAA;AAC5B,OAAO,MAAM,MAAM,WAAW,CAAA;AAC9B,OAAO,IAAI,MAAM,SAAS,CAAA;AAC1B,OAAO,IAAI,MAAM,SAAS,CAAA;AAI1B,MAAM,OAAO,aAAa;IACxB,GAAG,CAAE,GAAQ,EAAE,GAAe,EAAE,OAAsB;QACpD,OAAO,OAAO,CAAC,MAAM,CAAC,IAAI,KAAK,CAAC,yBAAyB,CAAC,CAAC,CAAA;IAC7D,CAAC;IAED,GAAG,CAAE,GAAQ,EAAE,OAAsB;QACnC,OAAO,OAAO,CAAC,MAAM,CAAC,IAAI,KAAK,CAAC,yBAAyB,CAAC,CAAC,CAAA;IAC7D,CAAC;IAED,GAAG,CAAE,GAAQ,EAAE,OAAsB;QACnC,OAAO,OAAO,CAAC,MAAM,CAAC,IAAI,KAAK,CAAC,yBAAyB,CAAC,CAAC,CAAA;IAC7D,CAAC;IAED,MAAM,CAAE,GAAQ,EAAE,OAAsB;QACtC,OAAO,OAAO,CAAC,MAAM,CAAC,IAAI,KAAK,CAAC,4BAA4B,CAAC,CAAC,CAAA;IAChE,CAAC;IAED,KAAK,CAAC,CAAE,OAAO,CAAE,MAA2B,EAAE,UAAwB,EAAE;QACtE,IAAI,KAAK,EAAE,MAAM,EAAE,GAAG,EAAE,KAAK,EAAE,IAAI,MAAM,EAAE,CAAC;YAC1C,MAAM,IAAI,CAAC,GAAG,CAAC,GAAG,EAAE,KAAK,EAAE,OAAO,CAAC,CAAA;YACnC,MAAM,GAAG,CAAA;QACX,CAAC;IACH,CAAC;IAED,KAAK,CAAC,CAAE,OAAO,CAAE,MAA0B,EAAE,UAAwB,EAAE;QACrE,IAAI,KAAK,EAAE,MAAM,GAAG,IAAI,MAAM,EAAE,CAAC;YAC/B,MAAM;gBACJ,GAAG;gBACH,KAAK,EAAE,MAAM,IAAI,CAAC,GAAG,CAAC,GAAG,EAAE,OAAO,CAAC;aACpC,CAAA;QACH,CAAC;IACH,CAAC;IAED,KAAK,CAAC,CAAE,UAAU,CAAE,MAA0B,EAAE,UAAwB,EAAE;QACxE,IAAI,KAAK,EAAE,MAAM,GAAG,IAAI,MAAM,EAAE,CAAC;YAC/B,MAAM,IAAI,CAAC,MAAM,CAAC,GAAG,EAAE,OAAO,CAAC,CAAA;YAC/B,MAAM,GAAG,CAAA;QACX,CAAC;IACH,CAAC;IAED,KAAK;QACH,IAAI,IAAI,GAAW,EAAE,CAAA;QACrB,IAAI,IAAI,GAAU,EAAE,CAAA;QAEpB,OAAO;YACL,GAAG,CAAE,GAAG,EAAE,KAAK;gBACb,IAAI,CAAC,IAAI,CAAC,EAAE,GAAG,EAAE,KAAK,EAAE,CAAC,CAAA;YAC3B,CAAC;YAED,MAAM,CAAE,GAAG;gBACT,IAAI,CAAC,IAAI,CAAC,GAAG,CAAC,CAAA;YAChB,CAAC;YACD,MAAM,EAAE,KAAK,EAAE,OAAO,EAAE,EAAE;gBACxB,MAAM,KAAK,CAAC,IAAI,CAAC,OAAO,CAAC,IAAI,EAAE,OAAO,CAAC,CAAC,CAAA;gBACxC,IAAI,GAAG,EAAE,CAAA;gBACT,MAAM,KAAK,CAAC,IAAI,CAAC,UAAU,CAAC,IAAI,EAAE,OAAO,CAAC,CAAC,CAAA;gBAC3C,IAAI,GAAG,EAAE,CAAA;YACX,CAAC;SACF,CAAA;IACH,CAAC;IAED;;OAEG;IACH,yCAAyC;IACzC,KAAK,CAAC,CAAE,IAAI,CAAE,CAAQ,EAAE,OAAsB;QAC5C,MAAM,IAAI,KAAK,CAAC,0BAA0B,CAAC,CAAA;IAC7C,CAAC;IAED;;OAEG;IACH,yCAAyC;IACzC,KAAK,CAAC,CAAE,QAAQ,CAAE,CAAW,EAAE,OAAsB;QACnD,MAAM,IAAI,KAAK,CAAC,8BAA8B,CAAC,CAAA;IACjD,CAAC;IAED,KAAK,CAAE,CAAQ,EAAE,OAAsB;QACrC,IAAI,EAAE,GAAG,IAAI,CAAC,IAAI,CAAC,CAAC,EAAE,OAAO,CAAC,CAAA;QAE9B,IAAI,CAAC,CAAC,MAAM,IAAI,IAAI,EAAE,CAAC;YACrB,MAAM,MAAM,GAAG,CAAC,CAAC,MAAM,CAAA;YACvB,EAAE,GAAG,MAAM,CAAC,EAAE,EAAE,CAAC,CAAC,EAAE,EAAE,CAAC,CAAC,CAAC,GAAG,CAAC,QAAQ,EAAE,CAAC,UAAU,CAAC,MAAM,CAAC,CAAC,CAAA;QAC7D,CAAC;QAED,IAAI,KAAK,CAAC,OAAO,CAAC,CAAC,CAAC,OAAO,CAAC,EAAE,CAAC;YAC7B,EAAE,GAAG,CAAC,CAAC,OAAO,CAAC,MAAM,CAAC,CAAC,EAAE,EAAE,CAAC,EAAE,EAAE,CAAC,MAAM,CAAC,EAAE,EAAE,CAAC,CAAC,EAAE,EAAE,CAAC,CAAA;QACrD,CAAC;QAED,IAAI,KAAK,CAAC,OAAO,CAAC,CAAC,CAAC,MAAM,CAAC,EAAE,CAAC;YAC5B,EAAE,GAAG,CAAC,CAAC,MAAM,CAAC,MAAM,CAAC,CAAC,EAAE,EAAE,CAAC,EAAE,EAAE,CAAC,IAAI,CAAC,EAAE,EAAE,CAAC,CAAC,EAAE,EAAE,CAAC,CAAA;QAClD,CAAC;QAED,IAAI,CAAC,CAAC,MAAM,IAAI,IAAI,EAAE,CAAC;YACrB,IAAI,CAAC,GAAG,CAAC,CAAA;YACT,MAAM,MAAM,GAAG,CAAC,CAAC,MAAM,CAAA;YACvB,EAAE,GAAG,MAAM,CAAC,EAAE,EAAE,GAAG,EAAE,CAAC,CAAC,EAAE,IAAI,MAAM,CAAC,CAAA;QACtC,CAAC;QAED,IAAI,CAAC,CAAC,KAAK,IAAI,IAAI,EAAE,CAAC;YACpB,EAAE,GAAG,IAAI,CAAC,EAAE,EAAE,CAAC,CAAC,KAAK,CAAC,CAAA;QACxB,CAAC;QAED,OAAO,EAAE,CAAA;IACX,CAAC;IAED,SAAS,CAAE,CAAW,EAAE,OAAsB;QAC5C,IAAI,EAAE,GAAG,IAAI,CAAC,QAAQ,CAAC,CAAC,EAAE,OAAO,CAAC,CAAA;QAElC,IAAI,CAAC,CAAC,MAAM,IAAI,IAAI,EAAE,CAAC;YACrB,MAAM,MAAM,GAAG,CAAC,CAAC,MAAM,CAAA;YACvB,EAAE,GAAG,MAAM,CAAC,EAAE,EAAE,CAAC,GAAG,EAAE,EAAE,CACtB,GAAG,CAAC,QAAQ,EAAE,CAAC,UAAU,CAAC,MAAM,CAAC,CAClC,CAAA;QACH,CAAC;QAED,IAAI,KAAK,CAAC,OAAO,CAAC,CAAC,CAAC,OAAO,CAAC,EAAE,CAAC;YAC7B,EAAE,GAAG,CAAC,CAAC,OAAO,CAAC,MAAM,CAAC,CAAC,EAAE,EAAE,CAAC,EAAE,EAAE,CAAC,MAAM,CAAC,EAAE,EAAE,CAAC,CAAC,EAAE,EAAE,CAAC,CAAA;QACrD,CAAC;QAED,IAAI,KAAK,CAAC,OAAO,CAAC,CAAC,CAAC,MAAM,CAAC,EAAE,CAAC;YAC5B,EAAE,GAAG,CAAC,CAAC,MAAM,CAAC,MAAM,CAAC,CAAC,EAAE,EAAE,CAAC,EAAE,EAAE,CAAC,IAAI,CAAC,EAAE,EAAE,CAAC,CAAC,EAAE,EAAE,CAAC,CAAA;QAClD,CAAC;QAED,IAAI,CAAC,CAAC,MAAM,IAAI,IAAI,EAAE,CAAC;YACrB,MAAM,MAAM,GAAG,CAAC,CAAC,MAAM,CAAA;YACvB,IAAI,CAAC,GAAG,CAAC,CAAA;YACT,EAAE,GAAG,MAAM,CAAC,EAAE,EAAE,GAAG,EAAE,CAAC,CAAC,EAAE,IAAI,MAAM,CAAC,CAAA;QACtC,CAAC;QAED,IAAI,CAAC,CAAC,KAAK,IAAI,IAAI,EAAE,CAAC;YACpB,EAAE,GAAG,IAAI,CAAC,EAAE,EAAE,CAAC,CAAC,KAAK,CAAC,CAAA;QACxB,CAAC;QAED,OAAO,EAAE,CAAA;IACX,CAAC;CACF"}
		{"version":3,"file":"base.js","sourceRoot":"","sources":["../../src/base.ts"],"names":[],"mappings":"AAAA,OAAO,KAAK,MAAM,UAAU,CAAA;AAC5B,OAAO,MAAM,MAAM,WAAW,CAAA;AAC9B,OAAO,IAAI,MAAM,SAAS,CAAA;AAC1B,OAAO,IAAI,MAAM,SAAS,CAAA;AAI1B,MAAM,OAAO,aAAa;IACxB,GAAG,CAAE,GAAQ,EAAE,GAAe,EAAE,OAAsB;QACpD,OAAO,OAAO,CAAC,MAAM,CAAC,IAAI,KAAK,CAAC,yBAAyB,CAAC,CAAC,CAAA;IAC7D,CAAC;IAED,GAAG,CAAE,GAAQ,EAAE,OAAsB;QACnC,OAAO,OAAO,CAAC,MAAM,CAAC,IAAI,KAAK,CAAC,yBAAyB,CAAC,CAAC,CAAA;IAC7D,CAAC;IAED,GAAG,CAAE,GAAQ,EAAE,OAAsB;QACnC,OAAO,OAAO,CAAC,MAAM,CAAC,IAAI,KAAK,CAAC,yBAAyB,CAAC,CAAC,CAAA;IAC7D,CAAC;IAED,MAAM,CAAE,GAAQ,EAAE,OAAsB;QACtC,OAAO,OAAO,CAAC,MAAM,CAAC,IAAI,KAAK,CAAC,4BAA4B,CAAC,CAAC,CAAA;IAChE,CAAC;IAED,KAAK,CAAC,CAAE,OAAO,CAAE,MAA4C,EAAE,UAAwB,EAAE;QACvF,IAAI,KAAK,EAAE,MAAM,EAAE,GAAG,EAAE,KAAK,EAAE,IAAI,MAAM,EAAE,CAAC;YAC1C,MAAM,IAAI,CAAC,GAAG,CAAC,GAAG,EAAE,KAAK,EAAE,OAAO,CAAC,CAAA;YACnC,MAAM,GAAG,CAAA;QACX,CAAC;IACH,CAAC;IAED,KAAK,CAAC,CAAE,OAAO,CAAE,MAA0C,EAAE,UAAwB,EAAE;QACrF,IAAI,KAAK,EAAE,MAAM,GAAG,IAAI,MAAM,EAAE,CAAC;YAC/B,MAAM;gBACJ,GAAG;gBACH,KAAK,EAAE,MAAM,IAAI,CAAC,GAAG,CAAC,GAAG,EAAE,OAAO,CAAC;aACpC,CAAA;QACH,CAAC;IACH,CAAC;IAED,KAAK,CAAC,CAAE,UAAU,CAAE,MAA0C,EAAE,UAAwB,EAAE;QACxF,IAAI,KAAK,EAAE,MAAM,GAAG,IAAI,MAAM,EAAE,CAAC;YAC/B,MAAM,IAAI,CAAC,MAAM,CAAC,GAAG,EAAE,OAAO,CAAC,CAAA;YAC/B,MAAM,GAAG,CAAA;QACX,CAAC;IACH,CAAC;IAED,KAAK;QACH,IAAI,IAAI,GAAW,EAAE,CAAA;QACrB,IAAI,IAAI,GAAU,EAAE,CAAA;QAEpB,OAAO;YACL,GAAG,CAAE,GAAG,EAAE,KAAK;gBACb,IAAI,CAAC,IAAI,CAAC,EAAE,GAAG,EAAE,KAAK,EAAE,CAAC,CAAA;YAC3B,CAAC;YAED,MAAM,CAAE,GAAG;gBACT,IAAI,CAAC,IAAI,CAAC,GAAG,CAAC,CAAA;YAChB,CAAC;YACD,MAAM,EAAE,KAAK,EAAE,OAAO,EAAE,EAAE;gBACxB,MAAM,KAAK,CAAC,IAAI,CAAC,OAAO,CAAC,IAAI,EAAE,OAAO,CAAC,CAAC,CAAA;gBACxC,IAAI,GAAG,EAAE,CAAA;gBACT,MAAM,KAAK,CAAC,IAAI,CAAC,UAAU,CAAC,IAAI,EAAE,OAAO,CAAC,CAAC,CAAA;gBAC3C,IAAI,GAAG,EAAE,CAAA;YACX,CAAC;SACF,CAAA;IACH,CAAC;IAED;;OAEG;IACH,yCAAyC;IACzC,KAAK,CAAC,CAAE,IAAI,CAAE,CAAQ,EAAE,OAAsB;QAC5C,MAAM,IAAI,KAAK,CAAC,0BAA0B,CAAC,CAAA;IAC7C,CAAC;IAED;;OAEG;IACH,yCAAyC;IACzC,KAAK,CAAC,CAAE,QAAQ,CAAE,CAAW,EAAE,OAAsB;QACnD,MAAM,IAAI,KAAK,CAAC,8BAA8B,CAAC,CAAA;IACjD,CAAC;IAED,KAAK,CAAE,CAAQ,EAAE,OAAsB;QACrC,IAAI,EAAE,GAAG,IAAI,CAAC,IAAI,CAAC,CAAC,EAAE,OAAO,CAAC,CAAA;QAE9B,IAAI,CAAC,CAAC,MAAM,IAAI,IAAI,EAAE,CAAC;YACrB,MAAM,MAAM,GAAG,CAAC,CAAC,MAAM,CAAA;YACvB,EAAE,GAAG,MAAM,CAAC,EAAE,EAAE,CAAC,CAAC,EAAE,EAAE,CAAC,CAAC,CAAC,GAAG,CAAC,QAAQ,EAAE,CAAC,UAAU,CAAC,MAAM,CAAC,CAAC,CAAA;QAC7D,CAAC;QAED,IAAI,KAAK,CAAC,OAAO,CAAC,CAAC,CAAC,OAAO,CAAC,EAAE,CAAC;YAC7B,EAAE,GAAG,CAAC,CAAC,OAAO,CAAC,MAAM,CAAC,CAAC,EAAE,EAAE,CAAC,EAAE,EAAE,CAAC,MAAM,CAAC,EAAE,EAAE,CAAC,CAAC,EAAE,EAAE,CAAC,CAAA;QACrD,CAAC;QAED,IAAI,KAAK,CAAC,OAAO,CAAC,CAAC,CAAC,MAAM,CAAC,EAAE,CAAC;YAC5B,EAAE,GAAG,CAAC,CAAC,MAAM,CAAC,MAAM,CAAC,CAAC,EAAE,EAAE,CAAC,EAAE,EAAE,CAAC,IAAI,CAAC,EAAE,EAAE,CAAC,CAAC,EAAE,EAAE,CAAC,CAAA;QAClD,CAAC;QAED,IAAI,CAAC,CAAC,MAAM,IAAI,IAAI,EAAE,CAAC;YACrB,IAAI,CAAC,GAAG,CAAC,CAAA;YACT,MAAM,MAAM,GAAG,CAAC,CAAC,MAAM,CAAA;YACvB,EAAE,GAAG,MAAM,CAAC,EAAE,EAAE,GAAG,EAAE,CAAC,CAAC,EAAE,IAAI,MAAM,CAAC,CAAA;QACtC,CAAC;QAED,IAAI,CAAC,CAAC,KAAK,IAAI,IAAI,EAAE,CAAC;YACpB,EAAE,GAAG,IAAI,CAAC,EAAE,EAAE,CAAC,CAAC,KAAK,CAAC,CAAA;QACxB,CAAC;QAED,OAAO,EAAE,CAAA;IACX,CAAC;IAED,SAAS,CAAE,CAAW,EAAE,OAAsB;QAC5C,IAAI,EAAE,GAAG,IAAI,CAAC,QAAQ,CAAC,CAAC,EAAE,OAAO,CAAC,CAAA;QAElC,IAAI,CAAC,CAAC,MAAM,IAAI,IAAI,EAAE,CAAC;YACrB,MAAM,MAAM,GAAG,CAAC,CAAC,MAAM,CAAA;YACvB,EAAE,GAAG,MAAM,CAAC,EAAE,EAAE,CAAC,GAAG,EAAE,EAAE,CACtB,GAAG,CAAC,QAAQ,EAAE,CAAC,UAAU,CAAC,MAAM,CAAC,CAClC,CAAA;QACH,CAAC;QAED,IAAI,KAAK,CAAC,OAAO,CAAC,CAAC,CAAC,OAAO,CAAC,EAAE,CAAC;YAC7B,EAAE,GAAG,CAAC,CAAC,OAAO,CAAC,MAAM,CAAC,CAAC,EAAE,EAAE,CAAC,EAAE,EAAE,CAAC,MAAM,CAAC,EAAE,EAAE,CAAC,CAAC,EAAE,EAAE,CAAC,CAAA;QACrD,CAAC;QAED,IAAI,KAAK,CAAC,OAAO,CAAC,CAAC,CAAC,MAAM,CAAC,EAAE,CAAC;YAC5B,EAAE,GAAG,CAAC,CAAC,MAAM,CAAC,MAAM,CAAC,CAAC,EAAE,EAAE,CAAC,EAAE,EAAE,CAAC,IAAI,CAAC,EAAE,EAAE,CAAC,CAAC,EAAE,EAAE,CAAC,CAAA;QAClD,CAAC;QAED,IAAI,CAAC,CAAC,MAAM,IAAI,IAAI,EAAE,CAAC;YACrB,MAAM,MAAM,GAAG,CAAC,CAAC,MAAM,CAAA;YACvB,IAAI,CAAC,GAAG,CAAC,CAAA;YACT,EAAE,GAAG,MAAM,CAAC,EAAE,EAAE,GAAG,EAAE,CAAC,CAAC,EAAE,IAAI,MAAM,CAAC,CAAA;QACtC,CAAC;QAED,IAAI,CAAC,CAAC,KAAK,IAAI,IAAI,EAAE,CAAC;YACpB,EAAE,GAAG,IAAI,CAAC,EAAE,EAAE,CAAC,CAAC,KAAK,CAAC,CAAA;QACxB,CAAC;QAED,OAAO,EAAE,CAAA;IACX,CAAC;CACF"}

+7

-7

dist/src/black-hole.d.ts

		import { BaseDatastore } from './base.ts';
		import type { AbortOptions } from 'abort-error';
		import type { Pair, Query, KeyQuery } from 'interface-datastore';
		import type { Key } from 'interface-datastore/key';
		import type { AbortOptions, Await, AwaitGenerator } from 'interface-store';
		export declare class BlackHoleDatastore extends BaseDatastore {
		put(key: Key, value: Uint8Array, options?: AbortOptions): Await<Key>;
		get(key: Key, options?: AbortOptions): Await<Uint8Array>;
		has(key: Key, options?: AbortOptions): Await<boolean>;
		delete(key: Key, options?: AbortOptions): Await<void>;
		_all(q: Query, options?: AbortOptions): AwaitGenerator<Pair>;
		_allKeys(q: KeyQuery, options?: AbortOptions): AwaitGenerator<Key>;
		put(key: Key, value: Uint8Array, options?: AbortOptions): Key \| Promise<Key>;
		get(key: Key, options?: AbortOptions): Uint8Array \| Promise<Uint8Array>;
		has(key: Key, options?: AbortOptions): boolean \| Promise<boolean>;
		delete(key: Key, options?: AbortOptions): void \| Promise<void>;
		_all(q: Query, options?: AbortOptions): Generator<Pair> \| AsyncGenerator<Pair>;
		_allKeys(q: KeyQuery, options?: AbortOptions): Generator<Key> \| AsyncGenerator<Key>;
		}
		//# sourceMappingURL=black-hole.d.ts.map

+1

-1

dist/src/black-hole.d.ts.map

		@@ -1,1 +0,1 @@
		{"version":3,"file":"black-hole.d.ts","sourceRoot":"","sources":["../../src/black-hole.ts"],"names":[],"mappings":"AACA,OAAO,EAAE,aAAa,EAAE,MAAM,WAAW,CAAA;AACzC,OAAO,KAAK,EAAE,IAAI,EAAE,KAAK,EAAE,QAAQ,EAAE,MAAM,qBAAqB,CAAA;AAChE,OAAO,KAAK,EAAE,GAAG,EAAE,MAAM,yBAAyB,CAAA;AAClD,OAAO,KAAK,EAAE,YAAY,EAAE,KAAK,EAAE,cAAc,EAAE,MAAM,iBAAiB,CAAA;AAE1E,qBAAa,kBAAmB,SAAQ,aAAa;IACnD,GAAG,CAAE,GAAG,EAAE,GAAG,EAAE,KAAK,EAAE,UAAU,EAAE,OAAO,CAAC,EAAE,YAAY,GAAG,KAAK,CAAC,GAAG,CAAC;IAKrE,GAAG,CAAE,GAAG,EAAE,GAAG,EAAE,OAAO,CAAC,EAAE,YAAY,GAAG,KAAK,CAAC,UAAU,CAAC;IAKzD,GAAG,CAAE,GAAG,EAAE,GAAG,EAAE,OAAO,CAAC,EAAE,YAAY,GAAG,KAAK,CAAC,OAAO,CAAC;IAKtD,MAAM,CAAE,GAAG,EAAE,GAAG,EAAE,OAAO,CAAC,EAAE,YAAY,GAAG,KAAK,CAAC,IAAI,CAAC;IAKpD,IAAI,CAAE,CAAC,EAAE,KAAK,EAAE,OAAO,CAAC,EAAE,YAAY,GAAG,cAAc,CAAC,IAAI,CAAC;IAK7D,QAAQ,CAAE,CAAC,EAAE,QAAQ,EAAE,OAAO,CAAC,EAAE,YAAY,GAAG,cAAc,CAAC,GAAG,CAAC;CAGtE"}
		{"version":3,"file":"black-hole.d.ts","sourceRoot":"","sources":["../../src/black-hole.ts"],"names":[],"mappings":"AACA,OAAO,EAAE,aAAa,EAAE,MAAM,WAAW,CAAA;AACzC,OAAO,KAAK,EAAE,YAAY,EAAE,MAAM,aAAa,CAAA;AAC/C,OAAO,KAAK,EAAE,IAAI,EAAE,KAAK,EAAE,QAAQ,EAAE,MAAM,qBAAqB,CAAA;AAChE,OAAO,KAAK,EAAE,GAAG,EAAE,MAAM,yBAAyB,CAAA;AAElD,qBAAa,kBAAmB,SAAQ,aAAa;IACnD,GAAG,CAAE,GAAG,EAAE,GAAG,EAAE,KAAK,EAAE,UAAU,EAAE,OAAO,CAAC,EAAE,YAAY,GAAG,GAAG,GAAG,OAAO,CAAC,GAAG,CAAC;IAK7E,GAAG,CAAE,GAAG,EAAE,GAAG,EAAE,OAAO,CAAC,EAAE,YAAY,GAAG,UAAU,GAAG,OAAO,CAAC,UAAU,CAAC;IAKxE,GAAG,CAAE,GAAG,EAAE,GAAG,EAAE,OAAO,CAAC,EAAE,YAAY,GAAG,OAAO,GAAG,OAAO,CAAC,OAAO,CAAC;IAKlE,MAAM,CAAE,GAAG,EAAE,GAAG,EAAE,OAAO,CAAC,EAAE,YAAY,GAAG,IAAI,GAAG,OAAO,CAAC,IAAI,CAAC;IAK7D,IAAI,CAAE,CAAC,EAAE,KAAK,EAAE,OAAO,CAAC,EAAE,YAAY,GAAG,SAAS,CAAC,IAAI,CAAC,GAAG,cAAc,CAAC,IAAI,CAAC;IAK/E,QAAQ,CAAE,CAAC,EAAE,QAAQ,EAAE,OAAO,CAAC,EAAE,YAAY,GAAG,SAAS,CAAC,GAAG,CAAC,GAAG,cAAc,CAAC,GAAG,CAAC;CAGvF"}

+6

-6

dist/src/keytransform.d.ts

		import { BaseDatastore } from './base.ts';
		import type { KeyTransform } from './index.ts';
		import type { AbortOptions } from 'abort-error';
		import type { Batch, Datastore, Key, KeyQuery, Pair, Query } from 'interface-datastore';
		import type { AbortOptions, AwaitGenerator, AwaitIterable } from 'interface-store';
		/**
		@@ -18,9 +18,9 @@ * A datastore shim, that wraps around a given datastore, changing
		delete(key: Key, options?: AbortOptions): Promise<void>;
		putMany(source: AwaitIterable<Pair>, options?: AbortOptions): AwaitGenerator<Key>;
		getMany(source: AwaitIterable<Key>, options?: AbortOptions): AwaitGenerator<Pair>;
		deleteMany(source: AwaitIterable<Key>, options?: AbortOptions): AwaitGenerator<Key>;
		putMany(source: Iterable<Pair> \| AsyncIterable<Pair>, options?: AbortOptions): Generator<Key> \| AsyncGenerator<Key>;
		getMany(source: Iterable<Key> \| AsyncIterable<Key>, options?: AbortOptions): Generator<Pair> \| AsyncGenerator<Pair>;
		deleteMany(source: Iterable<Key> \| AsyncIterable<Key>, options?: AbortOptions): Generator<Key> \| AsyncGenerator<Key>;
		batch(): Batch;
		query(q: Query, options?: AbortOptions): AwaitGenerator<Pair>;
		queryKeys(q: KeyQuery, options?: AbortOptions): AwaitGenerator<Key>;
		query(q: Query, options?: AbortOptions): Generator<Pair> \| AsyncGenerator<Pair>;
		queryKeys(q: KeyQuery, options?: AbortOptions): Generator<Key> \| AsyncGenerator<Key>;
		}
		//# sourceMappingURL=keytransform.d.ts.map

+1

-1

dist/src/keytransform.d.ts.map

		@@ -1,1 +0,1 @@
		{"version":3,"file":"keytransform.d.ts","sourceRoot":"","sources":["../../src/keytransform.ts"],"names":[],"mappings":"AAEA,OAAO,EAAE,aAAa,EAAE,MAAM,WAAW,CAAA;AACzC,OAAO,KAAK,EAAE,YAAY,EAAE,MAAM,YAAY,CAAA;AAC9C,OAAO,KAAK,EAAE,KAAK,EAAE,SAAS,EAAE,GAAG,EAAE,QAAQ,EAAE,IAAI,EAAE,KAAK,EAAE,MAAM,qBAAqB,CAAA;AACvF,OAAO,KAAK,EAAE,YAAY,EAAE,cAAc,EAAE,aAAa,EAAE,MAAM,iBAAiB,CAAA;AAElF;;;;GAIG;AACH,qBAAa,qBAAsB,SAAQ,aAAa;IACtD,OAAO,CAAC,QAAQ,CAAC,KAAK,CAAW;IAC1B,SAAS,EAAE,YAAY,CAAA;gBAEjB,KAAK,EAAE,SAAS,EAAE,SAAS,EAAE,YAAY;IAOhD,GAAG,CAAE,GAAG,EAAE,GAAG,EAAE,GAAG,EAAE,UAAU,EAAE,OAAO,CAAC,EAAE,YAAY,GAAG,OAAO,CAAC,GAAG,CAAC;IAMrE,GAAG,CAAE,GAAG,EAAE,GAAG,EAAE,OAAO,CAAC,EAAE,YAAY,GAAG,OAAO,CAAC,UAAU,CAAC;IAI3D,GAAG,CAAE,GAAG,EAAE,GAAG,EAAE,OAAO,CAAC,EAAE,YAAY,GAAG,OAAO,CAAC,OAAO,CAAC;IAIxD,MAAM,CAAE,GAAG,EAAE,GAAG,EAAE,OAAO,CAAC,EAAE,YAAY,GAAG,OAAO,CAAC,IAAI,CAAC;IAItD,OAAO,CAAE,MAAM,EAAE,aAAa,CAAC,IAAI,CAAC,EAAE,OAAO,GAAE,YAAiB,GAAG,cAAc,CAAC,GAAG,CAAC;IAqBtF,OAAO,CAAE,MAAM,EAAE,aAAa,CAAC,GAAG,CAAC,EAAE,OAAO,GAAE,YAAiB,GAAG,cAAc,CAAC,IAAI,CAAC;IAqBtF,UAAU,CAAE,MAAM,EAAE,aAAa,CAAC,GAAG,CAAC,EAAE,OAAO,GAAE,YAAiB,GAAG,cAAc,CAAC,GAAG,CAAC;IAkBhG,KAAK,IAAK,KAAK;IAef,KAAK,CAAE,CAAC,EAAE,KAAK,EAAE,OAAO,CAAC,EAAE,YAAY,GAAG,cAAc,CAAC,IAAI,CAAC;IAkC9D,SAAS,CAAE,CAAC,EAAE,QAAQ,EAAE,OAAO,CAAC,EAAE,YAAY,GAAG,cAAc,CAAC,GAAG,CAAC;CA8BrE"}
		{"version":3,"file":"keytransform.d.ts","sourceRoot":"","sources":["../../src/keytransform.ts"],"names":[],"mappings":"AAEA,OAAO,EAAE,aAAa,EAAE,MAAM,WAAW,CAAA;AACzC,OAAO,KAAK,EAAE,YAAY,EAAE,MAAM,YAAY,CAAA;AAC9C,OAAO,KAAK,EAAE,YAAY,EAAE,MAAM,aAAa,CAAA;AAC/C,OAAO,KAAK,EAAE,KAAK,EAAE,SAAS,EAAE,GAAG,EAAE,QAAQ,EAAE,IAAI,EAAE,KAAK,EAAE,MAAM,qBAAqB,CAAA;AAEvF;;;;GAIG;AACH,qBAAa,qBAAsB,SAAQ,aAAa;IACtD,OAAO,CAAC,QAAQ,CAAC,KAAK,CAAW;IAC1B,SAAS,EAAE,YAAY,CAAA;gBAEjB,KAAK,EAAE,SAAS,EAAE,SAAS,EAAE,YAAY;IAOhD,GAAG,CAAE,GAAG,EAAE,GAAG,EAAE,GAAG,EAAE,UAAU,EAAE,OAAO,CAAC,EAAE,YAAY,GAAG,OAAO,CAAC,GAAG,CAAC;IAMrE,GAAG,CAAE,GAAG,EAAE,GAAG,EAAE,OAAO,CAAC,EAAE,YAAY,GAAG,OAAO,CAAC,UAAU,CAAC;IAI3D,GAAG,CAAE,GAAG,EAAE,GAAG,EAAE,OAAO,CAAC,EAAE,YAAY,GAAG,OAAO,CAAC,OAAO,CAAC;IAIxD,MAAM,CAAE,GAAG,EAAE,GAAG,EAAE,OAAO,CAAC,EAAE,YAAY,GAAG,OAAO,CAAC,IAAI,CAAC;IAItD,OAAO,CAAE,MAAM,EAAE,QAAQ,CAAC,IAAI,CAAC,GAAG,aAAa,CAAC,IAAI,CAAC,EAAE,OAAO,GAAE,YAAiB,GAAG,SAAS,CAAC,GAAG,CAAC,GAAG,cAAc,CAAC,GAAG,CAAC;IAqBxH,OAAO,CAAE,MAAM,EAAE,QAAQ,CAAC,GAAG,CAAC,GAAG,aAAa,CAAC,GAAG,CAAC,EAAE,OAAO,GAAE,YAAiB,GAAG,SAAS,CAAC,IAAI,CAAC,GAAG,cAAc,CAAC,IAAI,CAAC;IAqBxH,UAAU,CAAE,MAAM,EAAE,QAAQ,CAAC,GAAG,CAAC,GAAG,aAAa,CAAC,GAAG,CAAC,EAAE,OAAO,GAAE,YAAiB,GAAG,SAAS,CAAC,GAAG,CAAC,GAAG,cAAc,CAAC,GAAG,CAAC;IAkBjI,KAAK,IAAK,KAAK;IAef,KAAK,CAAE,CAAC,EAAE,KAAK,EAAE,OAAO,CAAC,EAAE,YAAY,GAAG,SAAS,CAAC,IAAI,CAAC,GAAG,cAAc,CAAC,IAAI,CAAC;IAkChF,SAAS,CAAE,CAAC,EAAE,QAAQ,EAAE,OAAO,CAAC,EAAE,YAAY,GAAG,SAAS,CAAC,GAAG,CAAC,GAAG,cAAc,CAAC,GAAG,CAAC;CA8BtF"}

+1

-1

dist/src/keytransform.js.map

		@@ -1,1 +0,1 @@
		{"version":3,"file":"keytransform.js","sourceRoot":"","sources":["../../src/keytransform.ts"],"names":[],"mappings":"AAAA,OAAO,GAAG,MAAM,QAAQ,CAAA;AACxB,OAAO,EAAE,IAAI,EAAE,MAAM,SAAS,CAAA;AAC9B,OAAO,EAAE,aAAa,EAAE,MAAM,WAAW,CAAA;AAKzC;;;;GAIG;AACH,MAAM,OAAO,qBAAsB,SAAQ,aAAa;IACrC,KAAK,CAAW;IAC1B,SAAS,CAAc;IAE9B,YAAa,KAAgB,EAAE,SAAuB;QACpD,KAAK,EAAE,CAAA;QAEP,IAAI,CAAC,KAAK,GAAG,KAAK,CAAA;QAClB,IAAI,CAAC,SAAS,GAAG,SAAS,CAAA;IAC5B,CAAC;IAED,KAAK,CAAC,GAAG,CAAE,GAAQ,EAAE,GAAe,EAAE,OAAsB;QAC1D,MAAM,IAAI,CAAC,KAAK,CAAC,GAAG,CAAC,IAAI,CAAC,SAAS,CAAC,OAAO,CAAC,GAAG,CAAC,EAAE,GAAG,EAAE,OAAO,CAAC,CAAA;QAE/D,OAAO,GAAG,CAAA;IACZ,CAAC;IAED,KAAK,CAAC,GAAG,CAAE,GAAQ,EAAE,OAAsB;QACzC,OAAO,IAAI,CAAC,KAAK,CAAC,GAAG,CAAC,IAAI,CAAC,SAAS,CAAC,OAAO,CAAC,GAAG,CAAC,EAAE,OAAO,CAAC,CAAA;IAC7D,CAAC;IAED,KAAK,CAAC,GAAG,CAAE,GAAQ,EAAE,OAAsB;QACzC,OAAO,IAAI,CAAC,KAAK,CAAC,GAAG,CAAC,IAAI,CAAC,SAAS,CAAC,OAAO,CAAC,GAAG,CAAC,EAAE,OAAO,CAAC,CAAA;IAC7D,CAAC;IAED,KAAK,CAAC,MAAM,CAAE,GAAQ,EAAE,OAAsB;QAC5C,MAAM,IAAI,CAAC,KAAK,CAAC,MAAM,CAAC,IAAI,CAAC,SAAS,CAAC,OAAO,CAAC,GAAG,CAAC,EAAE,OAAO,CAAC,CAAA;IAC/D,CAAC;IAED,KAAK,CAAC,CAAE,OAAO,CAAE,MAA2B,EAAE,UAAwB,EAAE;QACtE,MAAM,SAAS,GAAG,IAAI,CAAC,SAAS,CAAA;QAChC,MAAM,KAAK,GAAG,IAAI,CAAC,KAAK,CAAA;QAExB,KAAM,CAAC,CAAC,IAAI,CACV,MAAM,EACN,KAAK,SAAU,CAAC,EAAE,MAAM;YACtB,KAAM,CAAC,CAAC,GAAG,CAAC,MAAM,EAAE,CAAC,EAAE,GAAG,EAAE,KAAK,EAAE,EAAE,EAAE,CAAC,CAAC;gBACvC,GAAG,EAAE,SAAS,CAAC,OAAO,CAAC,GAAG,CAAC;gBAC3B,KAAK;aACN,CAAC,CAAC,CAAA;QACL,CAAC,EACD,KAAK,SAAU,CAAC,EAAE,MAAM;YACtB,KAAM,CAAC,CAAC,KAAK,CAAC,OAAO,CAAC,MAAM,EAAE,OAAO,CAAC,CAAA;QACxC,CAAC,EACD,KAAK,SAAU,CAAC,EAAE,MAAM;YACtB,KAAM,CAAC,CAAC,GAAG,CAAC,MAAM,EAAE,GAAG,CAAC,EAAE,CAAC,SAAS,CAAC,MAAM,CAAC,GAAG,CAAC,CAAC,CAAA;QACnD,CAAC,CACF,CAAA;IACH,CAAC;IAED,KAAK,CAAC,CAAE,OAAO,CAAE,MAA0B,EAAE,UAAwB,EAAE;QACrE,MAAM,SAAS,GAAG,IAAI,CAAC,SAAS,CAAA;QAChC,MAAM,KAAK,GAAG,IAAI,CAAC,KAAK,CAAA;QAExB,KAAM,CAAC,CAAC,IAAI,CACV,MAAM,EACN,KAAK,SAAU,CAAC,EAAE,MAAM;YACtB,KAAM,CAAC,CAAC,GAAG,CAAC,MAAM,EAAE,GAAG,CAAC,EAAE,CAAC,SAAS,CAAC,OAAO,CAAC,GAAG,CAAC,CAAC,CAAA;QACpD,CAAC,EACD,KAAK,SAAU,CAAC,EAAE,MAAM;YACtB,KAAM,CAAC,CAAC,KAAK,CAAC,OAAO,CAAC,MAAM,EAAE,OAAO,CAAC,CAAA;QACxC,CAAC,EACD,KAAK,SAAU,CAAC,EAAE,MAAM;YACtB,KAAM,CAAC,CAAC,GAAG,CAAC,MAAM,EAAE,CAAC,EAAE,GAAG,EAAE,KAAK,EAAE,EAAE,EAAE,CAAC,CAAC;gBACvC,GAAG,EAAE,SAAS,CAAC,MAAM,CAAC,GAAG,CAAC;gBAC1B,KAAK;aACN,CAAC,CAAC,CAAA;QACL,CAAC,CACF,CAAA;IACH,CAAC;IAED,KAAK,CAAC,CAAE,UAAU,CAAE,MAA0B,EAAE,UAAwB,EAAE;QACxE,MAAM,SAAS,GAAG,IAAI,CAAC,SAAS,CAAA;QAChC,MAAM,KAAK,GAAG,IAAI,CAAC,KAAK,CAAA;QAExB,KAAM,CAAC,CAAC,IAAI,CACV,MAAM,EACN,KAAK,SAAU,CAAC,EAAE,MAAM;YACtB,KAAM,CAAC,CAAC,GAAG,CAAC,MAAM,EAAE,GAAG,CAAC,EAAE,CAAC,SAAS,CAAC,OAAO,CAAC,GAAG,CAAC,CAAC,CAAA;QACpD,CAAC,EACD,KAAK,SAAU,CAAC,EAAE,MAAM;YACtB,KAAM,CAAC,CAAC,KAAK,CAAC,UAAU,CAAC,MAAM,EAAE,OAAO,CAAC,CAAA;QAC3C,CAAC,EACD,KAAK,SAAU,CAAC,EAAE,MAAM;YACtB,KAAM,CAAC,CAAC,GAAG,CAAC,MAAM,EAAE,GAAG,CAAC,EAAE,CAAC,SAAS,CAAC,MAAM,CAAC,GAAG,CAAC,CAAC,CAAA;QACnD,CAAC,CACF,CAAA;IACH,CAAC;IAED,KAAK;QACH,MAAM,CAAC,GAAG,IAAI,CAAC,KAAK,CAAC,KAAK,EAAE,CAAA;QAC5B,OAAO;YACL,GAAG,EAAE,CAAC,GAAG,EAAE,KAAK,EAAE,EAAE;gBAClB,CAAC,CAAC,GAAG,CAAC,IAAI,CAAC,SAAS,CAAC,OAAO,CAAC,GAAG,CAAC,EAAE,KAAK,CAAC,CAAA;YAC3C,CAAC;YACD,MAAM,EAAE,CAAC,GAAG,EAAE,EAAE;gBACd,CAAC,CAAC,MAAM,CAAC,IAAI,CAAC,SAAS,CAAC,OAAO,CAAC,GAAG,CAAC,CAAC,CAAA;YACvC,CAAC;YACD,MAAM,EAAE,KAAK,EAAE,OAAO,EAAE,EAAE;gBACxB,MAAM,CAAC,CAAC,MAAM,CAAC,OAAO,CAAC,CAAA;YACzB,CAAC;SACF,CAAA;IACH,CAAC;IAED,KAAK,CAAE,CAAQ,EAAE,OAAsB;QACrC,MAAM,KAAK,GAAU;YACnB,GAAG,CAAC;SACL,CAAA;QAED,KAAK,CAAC,OAAO,GAAG,CAAC,KAAK,CAAC,OAAO,IAAI,EAAE,CAAC,CAAC,GAAG,CAAC,MAAM,CAAC,EAAE;YACjD,OAAO,CAAC,EAAE,GAAG,EAAE,KAAK,EAAE,EAAE,EAAE,CAAC,MAAM,CAAC,EAAE,GAAG,EAAE,IAAI,CAAC,SAAS,CAAC,OAAO,CAAC,GAAG,CAAC,EAAE,KAAK,EAAE,CAAC,CAAA;QAChF,CAAC,CAAC,CAAA;QAEF,MAAM,EAAE,MAAM,EAAE,GAAG,CAAC,CAAA;QACpB,IAAI,MAAM,IAAI,IAAI,IAAI,MAAM,KAAK,GAAG,EAAE,CAAC;YACrC,OAAO,KAAK,CAAC,MAAM,CAAA;YACnB,KAAK,CAAC,OAAO,CAAC,IAAI,CAAC,CAAC,EAAE,GAAG,EAAE,EAAE,EAAE;gBAC7B,OAAO,IAAI,CAAC,SAAS,CAAC,MAAM,CAAC,GAAG,CAAC,CAAC,QAAQ,EAAE,CAAC,UAAU,CAAC,MAAM,CAAC,CAAA;YACjE,CAAC,CAAC,CAAA;QACJ,CAAC;QAED,IAAI,KAAK,CAAC,MAAM,IAAI,IAAI,EAAE,CAAC;YACzB,KAAK,CAAC,MAAM,GAAG,KAAK,CAAC,MAAM,CAAC,GAAG,CAAC,KAAK,CAAC,EAAE;gBACtC,OAAO,CAAC,CAAC,EAAE,CAAC,EAAE,EAAE,CAAC,KAAK,CACpB,EAAE,GAAG,EAAE,IAAI,CAAC,SAAS,CAAC,MAAM,CAAC,CAAC,CAAC,GAAG,CAAC,EAAE,KAAK,EAAE,CAAC,CAAC,KAAK,EAAE,EACrD,EAAE,GAAG,EAAE,IAAI,CAAC,SAAS,CAAC,MAAM,CAAC,CAAC,CAAC,GAAG,CAAC,EAAE,KAAK,EAAE,CAAC,CAAC,KAAK,EAAE,CACtD,CAAA;YACH,CAAC,CAAC,CAAA;QACJ,CAAC;QAED,OAAO,GAAG,CAAC,IAAI,CAAC,KAAK,CAAC,KAAK,CAAC,KAAK,EAAE,OAAO,CAAC,EAAE,CAAC,EAAE,GAAG,EAAE,KAAK,EAAE,EAAE,EAAE;YAC9D,OAAO;gBACL,GAAG,EAAE,IAAI,CAAC,SAAS,CAAC,MAAM,CAAC,GAAG,CAAC;gBAC/B,KAAK;aACN,CAAA;QACH,CAAC,CAAC,CAAA;IACJ,CAAC;IAED,SAAS,CAAE,CAAW,EAAE,OAAsB;QAC5C,MAAM,KAAK,GAAG;YACZ,GAAG,CAAC;SACL,CAAA;QAED,KAAK,CAAC,OAAO,GAAG,CAAC,KAAK,CAAC,OAAO,IAAI,EAAE,CAAC,CAAC,GAAG,CAAC,MAAM,CAAC,EAAE;YACjD,OAAO,CAAC,GAAG,EAAE,EAAE,CAAC,MAAM,CAAC,IAAI,CAAC,SAAS,CAAC,OAAO,CAAC,GAAG,CAAC,CAAC,CAAA;QACrD,CAAC,CAAC,CAAA;QAEF,MAAM,EAAE,MAAM,EAAE,GAAG,CAAC,CAAA;QACpB,IAAI,MAAM,IAAI,IAAI,IAAI,MAAM,KAAK,GAAG,EAAE,CAAC;YACrC,OAAO,KAAK,CAAC,MAAM,CAAA;YACnB,KAAK,CAAC,OAAO,CAAC,IAAI,CAAC,CAAC,GAAG,EAAE,EAAE;gBACzB,OAAO,IAAI,CAAC,SAAS,CAAC,MAAM,CAAC,GAAG,CAAC,CAAC,QAAQ,EAAE,CAAC,UAAU,CAAC,MAAM,CAAC,CAAA;YACjE,CAAC,CAAC,CAAA;QACJ,CAAC;QAED,IAAI,KAAK,CAAC,MAAM,IAAI,IAAI,EAAE,CAAC;YACzB,KAAK,CAAC,MAAM,GAAG,KAAK,CAAC,MAAM,CAAC,GAAG,CAAC,KAAK,CAAC,EAAE;gBACtC,OAAO,CAAC,CAAC,EAAE,CAAC,EAAE,EAAE,CAAC,KAAK,CACpB,IAAI,CAAC,SAAS,CAAC,MAAM,CAAC,CAAC,CAAC,EACxB,IAAI,CAAC,SAAS,CAAC,MAAM,CAAC,CAAC,CAAC,CACzB,CAAA;YACH,CAAC,CAAC,CAAA;QACJ,CAAC;QAED,OAAO,GAAG,CAAC,IAAI,CAAC,KAAK,CAAC,SAAS,CAAC,KAAK,EAAE,OAAO,CAAC,EAAE,GAAG,CAAC,EAAE;YACrD,OAAO,IAAI,CAAC,SAAS,CAAC,MAAM,CAAC,GAAG,CAAC,CAAA;QACnC,CAAC,CAAC,CAAA;IACJ,CAAC;CACF"}
		{"version":3,"file":"keytransform.js","sourceRoot":"","sources":["../../src/keytransform.ts"],"names":[],"mappings":"AAAA,OAAO,GAAG,MAAM,QAAQ,CAAA;AACxB,OAAO,EAAE,IAAI,EAAE,MAAM,SAAS,CAAA;AAC9B,OAAO,EAAE,aAAa,EAAE,MAAM,WAAW,CAAA;AAKzC;;;;GAIG;AACH,MAAM,OAAO,qBAAsB,SAAQ,aAAa;IACrC,KAAK,CAAW;IAC1B,SAAS,CAAc;IAE9B,YAAa,KAAgB,EAAE,SAAuB;QACpD,KAAK,EAAE,CAAA;QAEP,IAAI,CAAC,KAAK,GAAG,KAAK,CAAA;QAClB,IAAI,CAAC,SAAS,GAAG,SAAS,CAAA;IAC5B,CAAC;IAED,KAAK,CAAC,GAAG,CAAE,GAAQ,EAAE,GAAe,EAAE,OAAsB;QAC1D,MAAM,IAAI,CAAC,KAAK,CAAC,GAAG,CAAC,IAAI,CAAC,SAAS,CAAC,OAAO,CAAC,GAAG,CAAC,EAAE,GAAG,EAAE,OAAO,CAAC,CAAA;QAE/D,OAAO,GAAG,CAAA;IACZ,CAAC;IAED,KAAK,CAAC,GAAG,CAAE,GAAQ,EAAE,OAAsB;QACzC,OAAO,IAAI,CAAC,KAAK,CAAC,GAAG,CAAC,IAAI,CAAC,SAAS,CAAC,OAAO,CAAC,GAAG,CAAC,EAAE,OAAO,CAAC,CAAA;IAC7D,CAAC;IAED,KAAK,CAAC,GAAG,CAAE,GAAQ,EAAE,OAAsB;QACzC,OAAO,IAAI,CAAC,KAAK,CAAC,GAAG,CAAC,IAAI,CAAC,SAAS,CAAC,OAAO,CAAC,GAAG,CAAC,EAAE,OAAO,CAAC,CAAA;IAC7D,CAAC;IAED,KAAK,CAAC,MAAM,CAAE,GAAQ,EAAE,OAAsB;QAC5C,MAAM,IAAI,CAAC,KAAK,CAAC,MAAM,CAAC,IAAI,CAAC,SAAS,CAAC,OAAO,CAAC,GAAG,CAAC,EAAE,OAAO,CAAC,CAAA;IAC/D,CAAC;IAED,KAAK,CAAC,CAAE,OAAO,CAAE,MAA4C,EAAE,UAAwB,EAAE;QACvF,MAAM,SAAS,GAAG,IAAI,CAAC,SAAS,CAAA;QAChC,MAAM,KAAK,GAAG,IAAI,CAAC,KAAK,CAAA;QAExB,KAAM,CAAC,CAAC,IAAI,CACV,MAAM,EACN,KAAK,SAAU,CAAC,EAAE,MAAM;YACtB,KAAM,CAAC,CAAC,GAAG,CAAC,MAAM,EAAE,CAAC,EAAE,GAAG,EAAE,KAAK,EAAE,EAAE,EAAE,CAAC,CAAC;gBACvC,GAAG,EAAE,SAAS,CAAC,OAAO,CAAC,GAAG,CAAC;gBAC3B,KAAK;aACN,CAAC,CAAC,CAAA;QACL,CAAC,EACD,KAAK,SAAU,CAAC,EAAE,MAAM;YACtB,KAAM,CAAC,CAAC,KAAK,CAAC,OAAO,CAAC,MAAM,EAAE,OAAO,CAAC,CAAA;QACxC,CAAC,EACD,KAAK,SAAU,CAAC,EAAE,MAAM;YACtB,KAAM,CAAC,CAAC,GAAG,CAAC,MAAM,EAAE,GAAG,CAAC,EAAE,CAAC,SAAS,CAAC,MAAM,CAAC,GAAG,CAAC,CAAC,CAAA;QACnD,CAAC,CACF,CAAA;IACH,CAAC;IAED,KAAK,CAAC,CAAE,OAAO,CAAE,MAA0C,EAAE,UAAwB,EAAE;QACrF,MAAM,SAAS,GAAG,IAAI,CAAC,SAAS,CAAA;QAChC,MAAM,KAAK,GAAG,IAAI,CAAC,KAAK,CAAA;QAExB,KAAM,CAAC,CAAC,IAAI,CACV,MAAM,EACN,KAAK,SAAU,CAAC,EAAE,MAAM;YACtB,KAAM,CAAC,CAAC,GAAG,CAAC,MAAM,EAAE,GAAG,CAAC,EAAE,CAAC,SAAS,CAAC,OAAO,CAAC,GAAG,CAAC,CAAC,CAAA;QACpD,CAAC,EACD,KAAK,SAAU,CAAC,EAAE,MAAM;YACtB,KAAM,CAAC,CAAC,KAAK,CAAC,OAAO,CAAC,MAAM,EAAE,OAAO,CAAC,CAAA;QACxC,CAAC,EACD,KAAK,SAAU,CAAC,EAAE,MAAM;YACtB,KAAM,CAAC,CAAC,GAAG,CAAC,MAAM,EAAE,CAAC,EAAE,GAAG,EAAE,KAAK,EAAE,EAAE,EAAE,CAAC,CAAC;gBACvC,GAAG,EAAE,SAAS,CAAC,MAAM,CAAC,GAAG,CAAC;gBAC1B,KAAK;aACN,CAAC,CAAC,CAAA;QACL,CAAC,CACF,CAAA;IACH,CAAC;IAED,KAAK,CAAC,CAAE,UAAU,CAAE,MAA0C,EAAE,UAAwB,EAAE;QACxF,MAAM,SAAS,GAAG,IAAI,CAAC,SAAS,CAAA;QAChC,MAAM,KAAK,GAAG,IAAI,CAAC,KAAK,CAAA;QAExB,KAAM,CAAC,CAAC,IAAI,CACV,MAAM,EACN,KAAK,SAAU,CAAC,EAAE,MAAM;YACtB,KAAM,CAAC,CAAC,GAAG,CAAC,MAAM,EAAE,GAAG,CAAC,EAAE,CAAC,SAAS,CAAC,OAAO,CAAC,GAAG,CAAC,CAAC,CAAA;QACpD,CAAC,EACD,KAAK,SAAU,CAAC,EAAE,MAAM;YACtB,KAAM,CAAC,CAAC,KAAK,CAAC,UAAU,CAAC,MAAM,EAAE,OAAO,CAAC,CAAA;QAC3C,CAAC,EACD,KAAK,SAAU,CAAC,EAAE,MAAM;YACtB,KAAM,CAAC,CAAC,GAAG,CAAC,MAAM,EAAE,GAAG,CAAC,EAAE,CAAC,SAAS,CAAC,MAAM,CAAC,GAAG,CAAC,CAAC,CAAA;QACnD,CAAC,CACF,CAAA;IACH,CAAC;IAED,KAAK;QACH,MAAM,CAAC,GAAG,IAAI,CAAC,KAAK,CAAC,KAAK,EAAE,CAAA;QAC5B,OAAO;YACL,GAAG,EAAE,CAAC,GAAG,EAAE,KAAK,EAAE,EAAE;gBAClB,CAAC,CAAC,GAAG,CAAC,IAAI,CAAC,SAAS,CAAC,OAAO,CAAC,GAAG,CAAC,EAAE,KAAK,CAAC,CAAA;YAC3C,CAAC;YACD,MAAM,EAAE,CAAC,GAAG,EAAE,EAAE;gBACd,CAAC,CAAC,MAAM,CAAC,IAAI,CAAC,SAAS,CAAC,OAAO,CAAC,GAAG,CAAC,CAAC,CAAA;YACvC,CAAC;YACD,MAAM,EAAE,KAAK,EAAE,OAAO,EAAE,EAAE;gBACxB,MAAM,CAAC,CAAC,MAAM,CAAC,OAAO,CAAC,CAAA;YACzB,CAAC;SACF,CAAA;IACH,CAAC;IAED,KAAK,CAAE,CAAQ,EAAE,OAAsB;QACrC,MAAM,KAAK,GAAU;YACnB,GAAG,CAAC;SACL,CAAA;QAED,KAAK,CAAC,OAAO,GAAG,CAAC,KAAK,CAAC,OAAO,IAAI,EAAE,CAAC,CAAC,GAAG,CAAC,MAAM,CAAC,EAAE;YACjD,OAAO,CAAC,EAAE,GAAG,EAAE,KAAK,EAAE,EAAE,EAAE,CAAC,MAAM,CAAC,EAAE,GAAG,EAAE,IAAI,CAAC,SAAS,CAAC,OAAO,CAAC,GAAG,CAAC,EAAE,KAAK,EAAE,CAAC,CAAA;QAChF,CAAC,CAAC,CAAA;QAEF,MAAM,EAAE,MAAM,EAAE,GAAG,CAAC,CAAA;QACpB,IAAI,MAAM,IAAI,IAAI,IAAI,MAAM,KAAK,GAAG,EAAE,CAAC;YACrC,OAAO,KAAK,CAAC,MAAM,CAAA;YACnB,KAAK,CAAC,OAAO,CAAC,IAAI,CAAC,CAAC,EAAE,GAAG,EAAE,EAAE,EAAE;gBAC7B,OAAO,IAAI,CAAC,SAAS,CAAC,MAAM,CAAC,GAAG,CAAC,CAAC,QAAQ,EAAE,CAAC,UAAU,CAAC,MAAM,CAAC,CAAA;YACjE,CAAC,CAAC,CAAA;QACJ,CAAC;QAED,IAAI,KAAK,CAAC,MAAM,IAAI,IAAI,EAAE,CAAC;YACzB,KAAK,CAAC,MAAM,GAAG,KAAK,CAAC,MAAM,CAAC,GAAG,CAAC,KAAK,CAAC,EAAE;gBACtC,OAAO,CAAC,CAAC,EAAE,CAAC,EAAE,EAAE,CAAC,KAAK,CACpB,EAAE,GAAG,EAAE,IAAI,CAAC,SAAS,CAAC,MAAM,CAAC,CAAC,CAAC,GAAG,CAAC,EAAE,KAAK,EAAE,CAAC,CAAC,KAAK,EAAE,EACrD,EAAE,GAAG,EAAE,IAAI,CAAC,SAAS,CAAC,MAAM,CAAC,CAAC,CAAC,GAAG,CAAC,EAAE,KAAK,EAAE,CAAC,CAAC,KAAK,EAAE,CACtD,CAAA;YACH,CAAC,CAAC,CAAA;QACJ,CAAC;QAED,OAAO,GAAG,CAAC,IAAI,CAAC,KAAK,CAAC,KAAK,CAAC,KAAK,EAAE,OAAO,CAAC,EAAE,CAAC,EAAE,GAAG,EAAE,KAAK,EAAE,EAAE,EAAE;YAC9D,OAAO;gBACL,GAAG,EAAE,IAAI,CAAC,SAAS,CAAC,MAAM,CAAC,GAAG,CAAC;gBAC/B,KAAK;aACN,CAAA;QACH,CAAC,CAAC,CAAA;IACJ,CAAC;IAED,SAAS,CAAE,CAAW,EAAE,OAAsB;QAC5C,MAAM,KAAK,GAAG;YACZ,GAAG,CAAC;SACL,CAAA;QAED,KAAK,CAAC,OAAO,GAAG,CAAC,KAAK,CAAC,OAAO,IAAI,EAAE,CAAC,CAAC,GAAG,CAAC,MAAM,CAAC,EAAE;YACjD,OAAO,CAAC,GAAG,EAAE,EAAE,CAAC,MAAM,CAAC,IAAI,CAAC,SAAS,CAAC,OAAO,CAAC,GAAG,CAAC,CAAC,CAAA;QACrD,CAAC,CAAC,CAAA;QAEF,MAAM,EAAE,MAAM,EAAE,GAAG,CAAC,CAAA;QACpB,IAAI,MAAM,IAAI,IAAI,IAAI,MAAM,KAAK,GAAG,EAAE,CAAC;YACrC,OAAO,KAAK,CAAC,MAAM,CAAA;YACnB,KAAK,CAAC,OAAO,CAAC,IAAI,CAAC,CAAC,GAAG,EAAE,EAAE;gBACzB,OAAO,IAAI,CAAC,SAAS,CAAC,MAAM,CAAC,GAAG,CAAC,CAAC,QAAQ,EAAE,CAAC,UAAU,CAAC,MAAM,CAAC,CAAA;YACjE,CAAC,CAAC,CAAA;QACJ,CAAC;QAED,IAAI,KAAK,CAAC,MAAM,IAAI,IAAI,EAAE,CAAC;YACzB,KAAK,CAAC,MAAM,GAAG,KAAK,CAAC,MAAM,CAAC,GAAG,CAAC,KAAK,CAAC,EAAE;gBACtC,OAAO,CAAC,CAAC,EAAE,CAAC,EAAE,EAAE,CAAC,KAAK,CACpB,IAAI,CAAC,SAAS,CAAC,MAAM,CAAC,CAAC,CAAC,EACxB,IAAI,CAAC,SAAS,CAAC,MAAM,CAAC,CAAC,CAAC,CACzB,CAAA;YACH,CAAC,CAAC,CAAA;QACJ,CAAC;QAED,OAAO,GAAG,CAAC,IAAI,CAAC,KAAK,CAAC,SAAS,CAAC,KAAK,EAAE,OAAO,CAAC,EAAE,GAAG,CAAC,EAAE;YACrD,OAAO,IAAI,CAAC,SAAS,CAAC,MAAM,CAAC,GAAG,CAAC,CAAA;QACnC,CAAC,CAAC,CAAA;IACJ,CAAC;CACF"}

+7

-7

dist/src/memory.d.ts

		import { Key } from 'interface-datastore/key';
		import { BaseDatastore } from './base.ts';
		import type { AbortOptions } from 'abort-error';
		import type { KeyQuery, Pair, Query } from 'interface-datastore';
		import type { AbortOptions, Await, AwaitGenerator } from 'interface-store';
		export declare class MemoryDatastore extends BaseDatastore {
		private readonly data;
		constructor();
		put(key: Key, val: Uint8Array, options?: AbortOptions): Await<Key>;
		get(key: Key, options?: AbortOptions): Await<Uint8Array>;
		has(key: Key, options?: AbortOptions): Await<boolean>;
		delete(key: Key, options?: AbortOptions): Await<void>;
		_all(q: Query, options?: AbortOptions): AwaitGenerator<Pair>;
		_allKeys(q: KeyQuery, options?: AbortOptions): AwaitGenerator<Key>;
		put(key: Key, val: Uint8Array, options?: AbortOptions): Key \| Promise<Key>;
		get(key: Key, options?: AbortOptions): Uint8Array \| Promise<Uint8Array>;
		has(key: Key, options?: AbortOptions): boolean \| Promise<boolean>;
		delete(key: Key, options?: AbortOptions): void \| Promise<void>;
		_all(q: Query, options?: AbortOptions): Generator<Pair> \| AsyncGenerator<Pair>;
		_allKeys(q: KeyQuery, options?: AbortOptions): Generator<Key> \| AsyncGenerator<Key>;
		}
		//# sourceMappingURL=memory.d.ts.map

+1

-1

dist/src/memory.d.ts.map

		@@ -1,1 +0,1 @@
		{"version":3,"file":"memory.d.ts","sourceRoot":"","sources":["../../src/memory.ts"],"names":[],"mappings":"AAAA,OAAO,EAAE,GAAG,EAAE,MAAM,yBAAyB,CAAA;AAE7C,OAAO,EAAE,aAAa,EAAE,MAAM,WAAW,CAAA;AACzC,OAAO,KAAK,EAAE,QAAQ,EAAE,IAAI,EAAE,KAAK,EAAE,MAAM,qBAAqB,CAAA;AAChE,OAAO,KAAK,EAAE,YAAY,EAAE,KAAK,EAAE,cAAc,EAAE,MAAM,iBAAiB,CAAA;AAE1E,qBAAa,eAAgB,SAAQ,aAAa;IAChD,OAAO,CAAC,QAAQ,CAAC,IAAI,CAAyB;;IAQ9C,GAAG,CAAE,GAAG,EAAE,GAAG,EAAE,GAAG,EAAE,UAAU,EAAE,OAAO,CAAC,EAAE,YAAY,GAAG,KAAK,CAAC,GAAG,CAAC;IAQnE,GAAG,CAAE,GAAG,EAAE,GAAG,EAAE,OAAO,CAAC,EAAE,YAAY,GAAG,KAAK,CAAC,UAAU,CAAC;IAYzD,GAAG,CAAE,GAAG,EAAE,GAAG,EAAE,OAAO,CAAC,EAAE,YAAY,GAAG,KAAK,CAAC,OAAO,CAAC;IAKtD,MAAM,CAAE,GAAG,EAAE,GAAG,EAAE,OAAO,CAAC,EAAE,YAAY,GAAG,KAAK,CAAC,IAAI,CAAC;IAKpD,IAAI,CAAE,CAAC,EAAE,KAAK,EAAE,OAAO,CAAC,EAAE,YAAY,GAAG,cAAc,CAAC,IAAI,CAAC;IAQ7D,QAAQ,CAAE,CAAC,EAAE,QAAQ,EAAE,OAAO,CAAC,EAAE,YAAY,GAAG,cAAc,CAAC,GAAG,CAAC;CAOtE"}
		{"version":3,"file":"memory.d.ts","sourceRoot":"","sources":["../../src/memory.ts"],"names":[],"mappings":"AAAA,OAAO,EAAE,GAAG,EAAE,MAAM,yBAAyB,CAAA;AAE7C,OAAO,EAAE,aAAa,EAAE,MAAM,WAAW,CAAA;AACzC,OAAO,KAAK,EAAE,YAAY,EAAE,MAAM,aAAa,CAAA;AAC/C,OAAO,KAAK,EAAE,QAAQ,EAAE,IAAI,EAAE,KAAK,EAAE,MAAM,qBAAqB,CAAA;AAEhE,qBAAa,eAAgB,SAAQ,aAAa;IAChD,OAAO,CAAC,QAAQ,CAAC,IAAI,CAAyB;;IAQ9C,GAAG,CAAE,GAAG,EAAE,GAAG,EAAE,GAAG,EAAE,UAAU,EAAE,OAAO,CAAC,EAAE,YAAY,GAAG,GAAG,GAAG,OAAO,CAAC,GAAG,CAAC;IAQ3E,GAAG,CAAE,GAAG,EAAE,GAAG,EAAE,OAAO,CAAC,EAAE,YAAY,GAAG,UAAU,GAAG,OAAO,CAAC,UAAU,CAAC;IAYxE,GAAG,CAAE,GAAG,EAAE,GAAG,EAAE,OAAO,CAAC,EAAE,YAAY,GAAG,OAAO,GAAG,OAAO,CAAC,OAAO,CAAC;IAKlE,MAAM,CAAE,GAAG,EAAE,GAAG,EAAE,OAAO,CAAC,EAAE,YAAY,GAAG,IAAI,GAAG,OAAO,CAAC,IAAI,CAAC;IAK7D,IAAI,CAAE,CAAC,EAAE,KAAK,EAAE,OAAO,CAAC,EAAE,YAAY,GAAG,SAAS,CAAC,IAAI,CAAC,GAAG,cAAc,CAAC,IAAI,CAAC;IAQ/E,QAAQ,CAAE,CAAC,EAAE,QAAQ,EAAE,OAAO,CAAC,EAAE,YAAY,GAAG,SAAS,CAAC,GAAG,CAAC,GAAG,cAAc,CAAC,GAAG,CAAC;CAOvF"}

+3

-3

dist/src/mount.d.ts

		import { BaseDatastore } from './base.ts';
		import type { AbortOptions } from 'abort-error';
		import type { Batch, Datastore, Key, KeyQuery, Pair, Query } from 'interface-datastore';
		import type { AbortOptions, AwaitGenerator } from 'interface-store';
		/**
		@@ -27,5 +27,5 @@ * A datastore that can combine multiple stores inside various
		batch(): Batch;
		query(q: Query, options?: AbortOptions): AwaitGenerator<Pair>;
		queryKeys(q: KeyQuery, options?: AbortOptions): AwaitGenerator<Key>;
		query(q: Query, options?: AbortOptions): Generator<Pair> \| AsyncGenerator<Pair>;
		queryKeys(q: KeyQuery, options?: AbortOptions): Generator<Key> \| AsyncGenerator<Key>;
		}
		//# sourceMappingURL=mount.d.ts.map

+1

-1

dist/src/mount.d.ts.map

		@@ -1,1 +0,1 @@
		{"version":3,"file":"mount.d.ts","sourceRoot":"","sources":["../../src/mount.ts"],"names":[],"mappings":"AAKA,OAAO,EAAE,aAAa,EAAE,MAAM,WAAW,CAAA;AACzC,OAAO,KAAK,EAAE,KAAK,EAAE,SAAS,EAAE,GAAG,EAAE,QAAQ,EAAE,IAAI,EAAE,KAAK,EAAE,MAAM,qBAAqB,CAAA;AACvF,OAAO,KAAK,EAAE,YAAY,EAAE,cAAc,EAAE,MAAM,iBAAiB,CAAA;AAEnE;;;GAGG;AACH,qBAAa,cAAe,SAAQ,aAAa;IAC/C,OAAO,CAAC,QAAQ,CAAC,MAAM,CAA8C;gBAExD,MAAM,EAAE,KAAK,CAAC;QAAE,MAAM,EAAE,GAAG,CAAC;QAAC,SAAS,EAAE,SAAS,CAAA;KAAE,CAAC;IAMjE;;OAEG;IACH,OAAO,CAAC,OAAO;IAWT,GAAG,CAAE,GAAG,EAAE,GAAG,EAAE,KAAK,EAAE,UAAU,EAAE,OAAO,CAAC,EAAE,YAAY,GAAG,OAAO,CAAC,GAAG,CAAC;IAW7E;;;OAGG;IACG,GAAG,CAAE,GAAG,EAAE,GAAG,EAAE,OAAO,GAAE,YAAiB,GAAG,OAAO,CAAC,UAAU,CAAC;IAQ/D,GAAG,CAAE,GAAG,EAAE,GAAG,EAAE,OAAO,CAAC,EAAE,YAAY,GAAG,OAAO,CAAC,OAAO,CAAC;IAQxD,MAAM,CAAE,GAAG,EAAE,GAAG,EAAE,OAAO,CAAC,EAAE,YAAY,GAAG,OAAO,CAAC,IAAI,CAAC;IAS9D,KAAK,IAAK,KAAK;IAkCf,KAAK,CAAE,CAAC,EAAE,KAAK,EAAE,OAAO,CAAC,EAAE,YAAY,GAAG,cAAc,CAAC,IAAI,CAAC;IAqB9D,SAAS,CAAE,CAAC,EAAE,QAAQ,EAAE,OAAO,CAAC,EAAE,YAAY,GAAG,cAAc,CAAC,GAAG,CAAC;CAoBrE"}
		{"version":3,"file":"mount.d.ts","sourceRoot":"","sources":["../../src/mount.ts"],"names":[],"mappings":"AAKA,OAAO,EAAE,aAAa,EAAE,MAAM,WAAW,CAAA;AACzC,OAAO,KAAK,EAAE,YAAY,EAAE,MAAM,aAAa,CAAA;AAC/C,OAAO,KAAK,EAAE,KAAK,EAAE,SAAS,EAAE,GAAG,EAAE,QAAQ,EAAE,IAAI,EAAE,KAAK,EAAE,MAAM,qBAAqB,CAAA;AAEvF;;;GAGG;AACH,qBAAa,cAAe,SAAQ,aAAa;IAC/C,OAAO,CAAC,QAAQ,CAAC,MAAM,CAA8C;gBAExD,MAAM,EAAE,KAAK,CAAC;QAAE,MAAM,EAAE,GAAG,CAAC;QAAC,SAAS,EAAE,SAAS,CAAA;KAAE,CAAC;IAMjE;;OAEG;IACH,OAAO,CAAC,OAAO;IAWT,GAAG,CAAE,GAAG,EAAE,GAAG,EAAE,KAAK,EAAE,UAAU,EAAE,OAAO,CAAC,EAAE,YAAY,GAAG,OAAO,CAAC,GAAG,CAAC;IAW7E;;;OAGG;IACG,GAAG,CAAE,GAAG,EAAE,GAAG,EAAE,OAAO,GAAE,YAAiB,GAAG,OAAO,CAAC,UAAU,CAAC;IAQ/D,GAAG,CAAE,GAAG,EAAE,GAAG,EAAE,OAAO,CAAC,EAAE,YAAY,GAAG,OAAO,CAAC,OAAO,CAAC;IAQxD,MAAM,CAAE,GAAG,EAAE,GAAG,EAAE,OAAO,CAAC,EAAE,YAAY,GAAG,OAAO,CAAC,IAAI,CAAC;IAS9D,KAAK,IAAK,KAAK;IAkCf,KAAK,CAAE,CAAC,EAAE,KAAK,EAAE,OAAO,CAAC,EAAE,YAAY,GAAG,SAAS,CAAC,IAAI,CAAC,GAAG,cAAc,CAAC,IAAI,CAAC;IAqBhF,SAAS,CAAE,CAAC,EAAE,QAAQ,EAAE,OAAO,CAAC,EAAE,YAAY,GAAG,SAAS,CAAC,GAAG,CAAC,GAAG,cAAc,CAAC,GAAG,CAAC;CAoBtF"}

+3

-3

dist/src/namespace.d.ts

		import { Key } from 'interface-datastore';
		import { KeyTransformDatastore } from './keytransform.ts';
		import type { AbortOptions } from 'abort-error';
		import type { Datastore, Query, Pair, KeyQuery } from 'interface-datastore';
		import type { AbortOptions, AwaitGenerator } from 'interface-store';
		/**
		@@ -17,5 +17,5 @@ * Wraps a given datastore into a keytransform which
		constructor(child: Datastore, prefix: Key);
		query(q: Query, options?: AbortOptions): AwaitGenerator<Pair>;
		queryKeys(q: KeyQuery, options?: AbortOptions): AwaitGenerator<Key>;
		query(q: Query, options?: AbortOptions): Generator<Pair> \| AsyncGenerator<Pair>;
		queryKeys(q: KeyQuery, options?: AbortOptions): Generator<Key> \| AsyncGenerator<Key>;
		}
		//# sourceMappingURL=namespace.d.ts.map

+1

-1

dist/src/namespace.d.ts.map

		@@ -1,1 +0,1 @@
		{"version":3,"file":"namespace.d.ts","sourceRoot":"","sources":["../../src/namespace.ts"],"names":[],"mappings":"AAAA,OAAO,EAAE,GAAG,EAAE,MAAM,qBAAqB,CAAA;AAEzC,OAAO,EAAE,qBAAqB,EAAE,MAAM,mBAAmB,CAAA;AACzD,OAAO,KAAK,EAAE,SAAS,EAAE,KAAK,EAAE,IAAI,EAAE,QAAQ,EAAE,MAAM,qBAAqB,CAAA;AAC3E,OAAO,KAAK,EAAE,YAAY,EAAE,cAAc,EAAE,MAAM,iBAAiB,CAAA;AAEnE;;;;;;;GAOG;AACH,qBAAa,kBAAmB,SAAQ,qBAAqB;IAC3D,OAAO,CAAC,QAAQ,CAAC,MAAM,CAAW;IAClC,OAAO,CAAC,QAAQ,CAAC,IAAI,CAAK;gBAEb,KAAK,EAAE,SAAS,EAAE,MAAM,EAAE,GAAG;IAsB1C,KAAK,CAAE,CAAC,EAAE,KAAK,EAAE,OAAO,CAAC,EAAE,YAAY,GAAG,cAAc,CAAC,IAAI,CAAC;IAoC9D,SAAS,CAAE,CAAC,EAAE,QAAQ,EAAE,OAAO,CAAC,EAAE,YAAY,GAAG,cAAc,CAAC,GAAG,CAAC;CAgCrE"}
		{"version":3,"file":"namespace.d.ts","sourceRoot":"","sources":["../../src/namespace.ts"],"names":[],"mappings":"AAAA,OAAO,EAAE,GAAG,EAAE,MAAM,qBAAqB,CAAA;AAEzC,OAAO,EAAE,qBAAqB,EAAE,MAAM,mBAAmB,CAAA;AACzD,OAAO,KAAK,EAAE,YAAY,EAAE,MAAM,aAAa,CAAA;AAC/C,OAAO,KAAK,EAAE,SAAS,EAAE,KAAK,EAAE,IAAI,EAAE,QAAQ,EAAE,MAAM,qBAAqB,CAAA;AAE3E;;;;;;;GAOG;AACH,qBAAa,kBAAmB,SAAQ,qBAAqB;IAC3D,OAAO,CAAC,QAAQ,CAAC,MAAM,CAAW;IAClC,OAAO,CAAC,QAAQ,CAAC,IAAI,CAAK;gBAEb,KAAK,EAAE,SAAS,EAAE,MAAM,EAAE,GAAG;IAsB1C,KAAK,CAAE,CAAC,EAAE,KAAK,EAAE,OAAO,CAAC,EAAE,YAAY,GAAG,SAAS,CAAC,IAAI,CAAC,GAAG,cAAc,CAAC,IAAI,CAAC;IAoChF,SAAS,CAAE,CAAC,EAAE,QAAQ,EAAE,OAAO,CAAC,EAAE,YAAY,GAAG,SAAS,CAAC,GAAG,CAAC,GAAG,cAAc,CAAC,GAAG,CAAC;CAgCtF"}

+6

-6

dist/src/sharding.d.ts

		import { Key } from 'interface-datastore';
		import { BaseDatastore } from './base.ts';
		import type { Shard } from './index.ts';
		import type { AbortOptions } from 'abort-error';
		import type { Batch, KeyQuery, Pair, Query, Datastore } from 'interface-datastore';
		import type { AbortOptions, AwaitGenerator, AwaitIterable } from 'interface-store';
		/**
		@@ -24,9 +24,9 @@ * Backend independent abstraction of go-ds-flatfs.
		delete(key: Key, options?: AbortOptions): Promise<void>;
		putMany(source: AwaitIterable<Pair>, options?: AbortOptions): AwaitGenerator<Key>;
		getMany(source: AwaitIterable<Key>, options?: AbortOptions): AwaitGenerator<Pair>;
		deleteMany(source: AwaitIterable<Key>, options?: AbortOptions): AwaitGenerator<Key>;
		putMany(source: Iterable<Pair> \| AsyncIterable<Pair>, options?: AbortOptions): Generator<Key> \| AsyncGenerator<Key>;
		getMany(source: Iterable<Key> \| AsyncIterable<Key>, options?: AbortOptions): Generator<Pair> \| AsyncGenerator<Pair>;
		deleteMany(source: Iterable<Key> \| AsyncIterable<Key>, options?: AbortOptions): Generator<Key> \| AsyncGenerator<Key>;
		batch(): Batch;
		query(q: Query, options?: AbortOptions): AwaitGenerator<Pair>;
		queryKeys(q: KeyQuery, options?: AbortOptions): AwaitGenerator<Key>;
		query(q: Query, options?: AbortOptions): Generator<Pair> \| AsyncGenerator<Pair>;
		queryKeys(q: KeyQuery, options?: AbortOptions): Generator<Key> \| AsyncGenerator<Key>;
		}
		//# sourceMappingURL=sharding.d.ts.map

+1

-1

dist/src/sharding.d.ts.map

		@@ -1,1 +0,1 @@
		{"version":3,"file":"sharding.d.ts","sourceRoot":"","sources":["../../src/sharding.ts"],"names":[],"mappings":"AAAA,OAAO,EAAE,GAAG,EAAE,MAAM,qBAAqB,CAAA;AAEzC,OAAO,EAAE,aAAa,EAAE,MAAM,WAAW,CAAA;AAMzC,OAAO,KAAK,EAAE,KAAK,EAAE,MAAM,YAAY,CAAA;AACvC,OAAO,KAAK,EAAE,KAAK,EAAE,QAAQ,EAAkB,IAAI,EAAE,KAAK,EAAe,SAAS,EAAE,MAAM,qBAAqB,CAAA;AAC/G,OAAO,KAAK,EAAE,YAAY,EAAE,cAAc,EAAE,aAAa,EAAE,MAAM,iBAAiB,CAAA;AAIlF;;;;;GAKG;AACH,qBAAa,iBAAkB,SAAQ,aAAa;IAClD,OAAO,CAAC,QAAQ,CAAC,KAAK,CAAuB;IAC7C,OAAO,CAAC,KAAK,CAAO;gBAEP,KAAK,EAAE,SAAS,EAAE,KAAK,EAAE,KAAK;IAUrC,IAAI,IAAK,OAAO,CAAC,IAAI,CAAC;IAI5B,WAAW,CAAE,GAAG,EAAE,GAAG,GAAG,GAAG;IAU3B,UAAU,CAAE,GAAG,EAAE,GAAG,GAAG,GAAG;WAQb,MAAM,CAAE,KAAK,EAAE,SAAS,EAAE,KAAK,CAAC,EAAE,KAAK,GAAG,OAAO,CAAC,KAAK,CAAC;IA2B/D,GAAG,CAAE,GAAG,EAAE,GAAG,EAAE,GAAG,EAAE,UAAU,EAAE,OAAO,CAAC,EAAE,YAAY,GAAG,OAAO,CAAC,GAAG,CAAC;IAMrE,GAAG,CAAE,GAAG,EAAE,GAAG,EAAE,OAAO,CAAC,EAAE,YAAY,GAAG,OAAO,CAAC,UAAU,CAAC;IAI3D,GAAG,CAAE,GAAG,EAAE,GAAG,EAAE,OAAO,CAAC,EAAE,YAAY,GAAG,OAAO,CAAC,OAAO,CAAC;IAIxD,MAAM,CAAE,GAAG,EAAE,GAAG,EAAE,OAAO,CAAC,EAAE,YAAY,GAAG,OAAO,CAAC,IAAI,CAAC;IAItD,OAAO,CAAE,MAAM,EAAE,aAAa,CAAC,IAAI,CAAC,EAAE,OAAO,GAAE,YAAiB,GAAG,cAAc,CAAC,GAAG,CAAC;IAItF,OAAO,CAAE,MAAM,EAAE,aAAa,CAAC,GAAG,CAAC,EAAE,OAAO,GAAE,YAAiB,GAAG,cAAc,CAAC,IAAI,CAAC;IAItF,UAAU,CAAE,MAAM,EAAE,aAAa,CAAC,GAAG,CAAC,EAAE,OAAO,GAAE,YAAiB,GAAG,cAAc,CAAC,GAAG,CAAC;IAIhG,KAAK,IAAK,KAAK;IAIf,KAAK,CAAE,CAAC,EAAE,KAAK,EAAE,OAAO,CAAC,EAAE,YAAY,GAAG,cAAc,CAAC,IAAI,CAAC;IAa9D,SAAS,CAAE,CAAC,EAAE,QAAQ,EAAE,OAAO,CAAC,EAAE,YAAY,GAAG,cAAc,CAAC,GAAG,CAAC;CAYrE"}
		{"version":3,"file":"sharding.d.ts","sourceRoot":"","sources":["../../src/sharding.ts"],"names":[],"mappings":"AAAA,OAAO,EAAE,GAAG,EAAE,MAAM,qBAAqB,CAAA;AAEzC,OAAO,EAAE,aAAa,EAAE,MAAM,WAAW,CAAA;AAMzC,OAAO,KAAK,EAAE,KAAK,EAAE,MAAM,YAAY,CAAA;AACvC,OAAO,KAAK,EAAE,YAAY,EAAE,MAAM,aAAa,CAAA;AAC/C,OAAO,KAAK,EAAE,KAAK,EAAE,QAAQ,EAAkB,IAAI,EAAE,KAAK,EAAe,SAAS,EAAE,MAAM,qBAAqB,CAAA;AAI/G;;;;;GAKG;AACH,qBAAa,iBAAkB,SAAQ,aAAa;IAClD,OAAO,CAAC,QAAQ,CAAC,KAAK,CAAuB;IAC7C,OAAO,CAAC,KAAK,CAAO;gBAEP,KAAK,EAAE,SAAS,EAAE,KAAK,EAAE,KAAK;IAUrC,IAAI,IAAK,OAAO,CAAC,IAAI,CAAC;IAI5B,WAAW,CAAE,GAAG,EAAE,GAAG,GAAG,GAAG;IAU3B,UAAU,CAAE,GAAG,EAAE,GAAG,GAAG,GAAG;WAQb,MAAM,CAAE,KAAK,EAAE,SAAS,EAAE,KAAK,CAAC,EAAE,KAAK,GAAG,OAAO,CAAC,KAAK,CAAC;IA2B/D,GAAG,CAAE,GAAG,EAAE,GAAG,EAAE,GAAG,EAAE,UAAU,EAAE,OAAO,CAAC,EAAE,YAAY,GAAG,OAAO,CAAC,GAAG,CAAC;IAMrE,GAAG,CAAE,GAAG,EAAE,GAAG,EAAE,OAAO,CAAC,EAAE,YAAY,GAAG,OAAO,CAAC,UAAU,CAAC;IAI3D,GAAG,CAAE,GAAG,EAAE,GAAG,EAAE,OAAO,CAAC,EAAE,YAAY,GAAG,OAAO,CAAC,OAAO,CAAC;IAIxD,MAAM,CAAE,GAAG,EAAE,GAAG,EAAE,OAAO,CAAC,EAAE,YAAY,GAAG,OAAO,CAAC,IAAI,CAAC;IAItD,OAAO,CAAE,MAAM,EAAE,QAAQ,CAAC,IAAI,CAAC,GAAG,aAAa,CAAC,IAAI,CAAC,EAAE,OAAO,GAAE,YAAiB,GAAG,SAAS,CAAC,GAAG,CAAC,GAAG,cAAc,CAAC,GAAG,CAAC;IAIxH,OAAO,CAAE,MAAM,EAAE,QAAQ,CAAC,GAAG,CAAC,GAAG,aAAa,CAAC,GAAG,CAAC,EAAE,OAAO,GAAE,YAAiB,GAAG,SAAS,CAAC,IAAI,CAAC,GAAG,cAAc,CAAC,IAAI,CAAC;IAIxH,UAAU,CAAE,MAAM,EAAE,QAAQ,CAAC,GAAG,CAAC,GAAG,aAAa,CAAC,GAAG,CAAC,EAAE,OAAO,GAAE,YAAiB,GAAG,SAAS,CAAC,GAAG,CAAC,GAAG,cAAc,CAAC,GAAG,CAAC;IAIjI,KAAK,IAAK,KAAK;IAIf,KAAK,CAAE,CAAC,EAAE,KAAK,EAAE,OAAO,CAAC,EAAE,YAAY,GAAG,SAAS,CAAC,IAAI,CAAC,GAAG,cAAc,CAAC,IAAI,CAAC;IAahF,SAAS,CAAE,CAAC,EAAE,QAAQ,EAAE,OAAO,CAAC,EAAE,YAAY,GAAG,SAAS,CAAC,GAAG,CAAC,GAAG,cAAc,CAAC,GAAG,CAAC;CAYtF"}

+1

-1

dist/src/sharding.js.map

		@@ -1,1 +0,1 @@
		{"version":3,"file":"sharding.js","sourceRoot":"","sources":["../../src/sharding.ts"],"names":[],"mappings":"AAAA,OAAO,EAAE,GAAG,EAAE,MAAM,qBAAqB,CAAA;AACzC,OAAO,EAAE,eAAe,EAAE,MAAM,iBAAiB,CAAA;AACjD,OAAO,EAAE,aAAa,EAAE,MAAM,WAAW,CAAA;AACzC,OAAO,EAAE,qBAAqB,EAAE,MAAM,mBAAmB,CAAA;AACzD,OAAO,EACL,YAAY,EACZ,WAAW,EACZ,MAAM,YAAY,CAAA;AAKnB,MAAM,QAAQ,GAAG,IAAI,GAAG,CAAC,WAAW,CAAC,CAAA;AAErC;;;;;GAKG;AACH,MAAM,OAAO,iBAAkB,SAAQ,aAAa;IACjC,KAAK,CAAuB;IACrC,KAAK,CAAO;IAEpB,YAAa,KAAgB,EAAE,KAAY;QACzC,KAAK,EAAE,CAAA;QAEP,IAAI,CAAC,KAAK,GAAG,IAAI,qBAAqB,CAAC,KAAK,EAAE;YAC5C,OAAO,EAAE,IAAI,CAAC,WAAW,CAAC,IAAI,CAAC,IAAI,CAAC;YACpC,MAAM,EAAE,IAAI,CAAC,UAAU,CAAC,IAAI,CAAC,IAAI,CAAC;SACnC,CAAC,CAAA;QACF,IAAI,CAAC,KAAK,GAAG,KAAK,CAAA;IACpB,CAAC;IAED,KAAK,CAAC,IAAI;QACR,IAAI,CAAC,KAAK,GAAG,MAAM,iBAAiB,CAAC,MAAM,CAAC,IAAI,CAAC,KAAK,EAAE,IAAI,CAAC,KAAK,CAAC,CAAA;IACrE,CAAC;IAED,WAAW,CAAE,GAAQ;QACnB,MAAM,CAAC,GAAG,GAAG,CAAC,QAAQ,EAAE,CAAA;QACxB,IAAI,CAAC,KAAK,QAAQ,CAAC,QAAQ,EAAE,EAAE,CAAC;YAC9B,OAAO,GAAG,CAAA;QACZ,CAAC;QAED,MAAM,MAAM,GAAG,IAAI,GAAG,CAAC,IAAI,CAAC,KAAK,CAAC,GAAG,CAAC,CAAC,CAAC,CAAC,CAAA;QACzC,OAAO,MAAM,CAAC,KAAK,CAAC,GAAG,CAAC,CAAA;IAC1B,CAAC;IAED,UAAU,CAAE,GAAQ;QAClB,MAAM,CAAC,GAAG,GAAG,CAAC,QAAQ,EAAE,CAAA;QACxB,IAAI,CAAC,KAAK,QAAQ,CAAC,QAAQ,EAAE,EAAE,CAAC;YAC9B,OAAO,GAAG,CAAA;QACZ,CAAC;QACD,OAAO,GAAG,CAAC,cAAc,CAAC,GAAG,CAAC,IAAI,EAAE,CAAC,KAAK,CAAC,CAAC,CAAC,CAAC,CAAA;IAChD,CAAC;IAED,MAAM,CAAC,KAAK,CAAC,MAAM,CAAE,KAAgB,EAAE,KAAa;QAClD,MAAM,QAAQ,GAAG,MAAM,KAAK,CAAC,GAAG,CAAC,QAAQ,CAAC,CAAA;QAE1C,IAAI,CAAC,QAAQ,EAAE,CAAC;YACd,IAAI,KAAK,IAAI,IAAI,EAAE,CAAC;gBAClB,MAAM,IAAI,eAAe,CAAC,oEAAoE,CAAC,CAAA;YACjG,CAAC;YAED,MAAM,KAAK,CAAC,GAAG,CAAC,QAAQ,EAAE,IAAI,WAAW,EAAE,CAAC,MAAM,CAAC,KAAK,CAAC,QAAQ,EAAE,GAAG,IAAI,CAAC,CAAC,CAAA;QAC9E,CAAC;QAED,IAAI,KAAK,IAAI,IAAI,EAAE,CAAC;YAClB,KAAK,GAAG,MAAM,YAAY,CAAC,GAAG,EAAE,KAAK,CAAC,CAAA;QACxC,CAAC;QAED,cAAc;QACd,MAAM,SAAS,GAAG,MAAM,YAAY,CAAC,GAAG,EAAE,KAAK,CAAC,CAAA;QAChD,MAAM,CAAC,GAAG,SAAS,CAAC,QAAQ,EAAE,CAAA;QAC9B,MAAM,CAAC,GAAG,KAAK,CAAC,QAAQ,EAAE,CAAA;QAE1B,IAAI,CAAC,KAAK,CAAC,EAAE,CAAC;YACZ,MAAM,IAAI,KAAK,CAAC,iBAAiB,CAAC,kCAAkC,CAAC,EAAE,CAAC,CAAA;QAC1E,CAAC;QAED,OAAO,SAAS,CAAA;IAClB,CAAC;IAED,KAAK,CAAC,GAAG,CAAE,GAAQ,EAAE,GAAe,EAAE,OAAsB;QAC1D,MAAM,IAAI,CAAC,KAAK,CAAC,GAAG,CAAC,GAAG,EAAE,GAAG,EAAE,OAAO,CAAC,CAAA;QAEvC,OAAO,GAAG,CAAA;IACZ,CAAC;IAED,KAAK,CAAC,GAAG,CAAE,GAAQ,EAAE,OAAsB;QACzC,OAAO,IAAI,CAAC,KAAK,CAAC,GAAG,CAAC,GAAG,EAAE,OAAO,CAAC,CAAA;IACrC,CAAC;IAED,KAAK,CAAC,GAAG,CAAE,GAAQ,EAAE,OAAsB;QACzC,OAAO,IAAI,CAAC,KAAK,CAAC,GAAG,CAAC,GAAG,EAAE,OAAO,CAAC,CAAA;IACrC,CAAC;IAED,KAAK,CAAC,MAAM,CAAE,GAAQ,EAAE,OAAsB;QAC5C,MAAM,IAAI,CAAC,KAAK,CAAC,MAAM,CAAC,GAAG,EAAE,OAAO,CAAC,CAAA;IACvC,CAAC;IAED,KAAK,CAAC,CAAE,OAAO,CAAE,MAA2B,EAAE,UAAwB,EAAE;QACtE,KAAM,CAAC,CAAC,IAAI,CAAC,KAAK,CAAC,OAAO,CAAC,MAAM,EAAE,OAAO,CAAC,CAAA;IAC7C,CAAC;IAED,KAAK,CAAC,CAAE,OAAO,CAAE,MAA0B,EAAE,UAAwB,EAAE;QACrE,KAAM,CAAC,CAAC,IAAI,CAAC,KAAK,CAAC,OAAO,CAAC,MAAM,EAAE,OAAO,CAAC,CAAA;IAC7C,CAAC;IAED,KAAK,CAAC,CAAE,UAAU,CAAE,MAA0B,EAAE,UAAwB,EAAE;QACxE,KAAM,CAAC,CAAC,IAAI,CAAC,KAAK,CAAC,UAAU,CAAC,MAAM,EAAE,OAAO,CAAC,CAAA;IAChD,CAAC;IAED,KAAK;QACH,OAAO,IAAI,CAAC,KAAK,CAAC,KAAK,EAAE,CAAA;IAC3B,CAAC;IAED,KAAK,CAAE,CAAQ,EAAE,OAAsB;QACrC,MAAM,SAAS,GAAgB,CAAC,EAAE,GAAG,EAAE,EAAE,EAAE,CAAC,GAAG,CAAC,QAAQ,EAAE,KAAK,QAAQ,CAAC,QAAQ,EAAE,CAAA;QAElF,MAAM,EAAE,GAAU;YAChB,GAAG,CAAC;YACJ,OAAO,EAAE;gBACP,SAAS;aACV,CAAC,MAAM,CAAC,CAAC,CAAC,OAAO,IAAI,EAAE,CAAC;SAC1B,CAAA;QAED,OAAO,IAAI,CAAC,KAAK,CAAC,KAAK,CAAC,EAAE,EAAE,OAAO,CAAC,CAAA;IACtC,CAAC;IAED,SAAS,CAAE,CAAW,EAAE,OAAsB;QAC5C,MAAM,SAAS,GAAmB,CAAC,GAAG,EAAE,EAAE,CAAC,GAAG,CAAC,QAAQ,EAAE,KAAK,QAAQ,CAAC,QAAQ,EAAE,CAAA;QAEjF,MAAM,EAAE,GAAa;YACnB,GAAG,CAAC;YACJ,OAAO,EAAE;gBACP,SAAS;aACV,CAAC,MAAM,CAAC,CAAC,CAAC,OAAO,IAAI,EAAE,CAAC;SAC1B,CAAA;QAED,OAAO,IAAI,CAAC,KAAK,CAAC,SAAS,CAAC,EAAE,EAAE,OAAO,CAAC,CAAA;IAC1C,CAAC;CACF"}
		{"version":3,"file":"sharding.js","sourceRoot":"","sources":["../../src/sharding.ts"],"names":[],"mappings":"AAAA,OAAO,EAAE,GAAG,EAAE,MAAM,qBAAqB,CAAA;AACzC,OAAO,EAAE,eAAe,EAAE,MAAM,iBAAiB,CAAA;AACjD,OAAO,EAAE,aAAa,EAAE,MAAM,WAAW,CAAA;AACzC,OAAO,EAAE,qBAAqB,EAAE,MAAM,mBAAmB,CAAA;AACzD,OAAO,EACL,YAAY,EACZ,WAAW,EACZ,MAAM,YAAY,CAAA;AAKnB,MAAM,QAAQ,GAAG,IAAI,GAAG,CAAC,WAAW,CAAC,CAAA;AAErC;;;;;GAKG;AACH,MAAM,OAAO,iBAAkB,SAAQ,aAAa;IACjC,KAAK,CAAuB;IACrC,KAAK,CAAO;IAEpB,YAAa,KAAgB,EAAE,KAAY;QACzC,KAAK,EAAE,CAAA;QAEP,IAAI,CAAC,KAAK,GAAG,IAAI,qBAAqB,CAAC,KAAK,EAAE;YAC5C,OAAO,EAAE,IAAI,CAAC,WAAW,CAAC,IAAI,CAAC,IAAI,CAAC;YACpC,MAAM,EAAE,IAAI,CAAC,UAAU,CAAC,IAAI,CAAC,IAAI,CAAC;SACnC,CAAC,CAAA;QACF,IAAI,CAAC,KAAK,GAAG,KAAK,CAAA;IACpB,CAAC;IAED,KAAK,CAAC,IAAI;QACR,IAAI,CAAC,KAAK,GAAG,MAAM,iBAAiB,CAAC,MAAM,CAAC,IAAI,CAAC,KAAK,EAAE,IAAI,CAAC,KAAK,CAAC,CAAA;IACrE,CAAC;IAED,WAAW,CAAE,GAAQ;QACnB,MAAM,CAAC,GAAG,GAAG,CAAC,QAAQ,EAAE,CAAA;QACxB,IAAI,CAAC,KAAK,QAAQ,CAAC,QAAQ,EAAE,EAAE,CAAC;YAC9B,OAAO,GAAG,CAAA;QACZ,CAAC;QAED,MAAM,MAAM,GAAG,IAAI,GAAG,CAAC,IAAI,CAAC,KAAK,CAAC,GAAG,CAAC,CAAC,CAAC,CAAC,CAAA;QACzC,OAAO,MAAM,CAAC,KAAK,CAAC,GAAG,CAAC,CAAA;IAC1B,CAAC;IAED,UAAU,CAAE,GAAQ;QAClB,MAAM,CAAC,GAAG,GAAG,CAAC,QAAQ,EAAE,CAAA;QACxB,IAAI,CAAC,KAAK,QAAQ,CAAC,QAAQ,EAAE,EAAE,CAAC;YAC9B,OAAO,GAAG,CAAA;QACZ,CAAC;QACD,OAAO,GAAG,CAAC,cAAc,CAAC,GAAG,CAAC,IAAI,EAAE,CAAC,KAAK,CAAC,CAAC,CAAC,CAAC,CAAA;IAChD,CAAC;IAED,MAAM,CAAC,KAAK,CAAC,MAAM,CAAE,KAAgB,EAAE,KAAa;QAClD,MAAM,QAAQ,GAAG,MAAM,KAAK,CAAC,GAAG,CAAC,QAAQ,CAAC,CAAA;QAE1C,IAAI,CAAC,QAAQ,EAAE,CAAC;YACd,IAAI,KAAK,IAAI,IAAI,EAAE,CAAC;gBAClB,MAAM,IAAI,eAAe,CAAC,oEAAoE,CAAC,CAAA;YACjG,CAAC;YAED,MAAM,KAAK,CAAC,GAAG,CAAC,QAAQ,EAAE,IAAI,WAAW,EAAE,CAAC,MAAM,CAAC,KAAK,CAAC,QAAQ,EAAE,GAAG,IAAI,CAAC,CAAC,CAAA;QAC9E,CAAC;QAED,IAAI,KAAK,IAAI,IAAI,EAAE,CAAC;YAClB,KAAK,GAAG,MAAM,YAAY,CAAC,GAAG,EAAE,KAAK,CAAC,CAAA;QACxC,CAAC;QAED,cAAc;QACd,MAAM,SAAS,GAAG,MAAM,YAAY,CAAC,GAAG,EAAE,KAAK,CAAC,CAAA;QAChD,MAAM,CAAC,GAAG,SAAS,CAAC,QAAQ,EAAE,CAAA;QAC9B,MAAM,CAAC,GAAG,KAAK,CAAC,QAAQ,EAAE,CAAA;QAE1B,IAAI,CAAC,KAAK,CAAC,EAAE,CAAC;YACZ,MAAM,IAAI,KAAK,CAAC,iBAAiB,CAAC,kCAAkC,CAAC,EAAE,CAAC,CAAA;QAC1E,CAAC;QAED,OAAO,SAAS,CAAA;IAClB,CAAC;IAED,KAAK,CAAC,GAAG,CAAE,GAAQ,EAAE,GAAe,EAAE,OAAsB;QAC1D,MAAM,IAAI,CAAC,KAAK,CAAC,GAAG,CAAC,GAAG,EAAE,GAAG,EAAE,OAAO,CAAC,CAAA;QAEvC,OAAO,GAAG,CAAA;IACZ,CAAC;IAED,KAAK,CAAC,GAAG,CAAE,GAAQ,EAAE,OAAsB;QACzC,OAAO,IAAI,CAAC,KAAK,CAAC,GAAG,CAAC,GAAG,EAAE,OAAO,CAAC,CAAA;IACrC,CAAC;IAED,KAAK,CAAC,GAAG,CAAE,GAAQ,EAAE,OAAsB;QACzC,OAAO,IAAI,CAAC,KAAK,CAAC,GAAG,CAAC,GAAG,EAAE,OAAO,CAAC,CAAA;IACrC,CAAC;IAED,KAAK,CAAC,MAAM,CAAE,GAAQ,EAAE,OAAsB;QAC5C,MAAM,IAAI,CAAC,KAAK,CAAC,MAAM,CAAC,GAAG,EAAE,OAAO,CAAC,CAAA;IACvC,CAAC;IAED,KAAK,CAAC,CAAE,OAAO,CAAE,MAA4C,EAAE,UAAwB,EAAE;QACvF,KAAM,CAAC,CAAC,IAAI,CAAC,KAAK,CAAC,OAAO,CAAC,MAAM,EAAE,OAAO,CAAC,CAAA;IAC7C,CAAC;IAED,KAAK,CAAC,CAAE,OAAO,CAAE,MAA0C,EAAE,UAAwB,EAAE;QACrF,KAAM,CAAC,CAAC,IAAI,CAAC,KAAK,CAAC,OAAO,CAAC,MAAM,EAAE,OAAO,CAAC,CAAA;IAC7C,CAAC;IAED,KAAK,CAAC,CAAE,UAAU,CAAE,MAA0C,EAAE,UAAwB,EAAE;QACxF,KAAM,CAAC,CAAC,IAAI,CAAC,KAAK,CAAC,UAAU,CAAC,MAAM,EAAE,OAAO,CAAC,CAAA;IAChD,CAAC;IAED,KAAK;QACH,OAAO,IAAI,CAAC,KAAK,CAAC,KAAK,EAAE,CAAA;IAC3B,CAAC;IAED,KAAK,CAAE,CAAQ,EAAE,OAAsB;QACrC,MAAM,SAAS,GAAgB,CAAC,EAAE,GAAG,EAAE,EAAE,EAAE,CAAC,GAAG,CAAC,QAAQ,EAAE,KAAK,QAAQ,CAAC,QAAQ,EAAE,CAAA;QAElF,MAAM,EAAE,GAAU;YAChB,GAAG,CAAC;YACJ,OAAO,EAAE;gBACP,SAAS;aACV,CAAC,MAAM,CAAC,CAAC,CAAC,OAAO,IAAI,EAAE,CAAC;SAC1B,CAAA;QAED,OAAO,IAAI,CAAC,KAAK,CAAC,KAAK,CAAC,EAAE,EAAE,OAAO,CAAC,CAAA;IACtC,CAAC;IAED,SAAS,CAAE,CAAW,EAAE,OAAsB;QAC5C,MAAM,SAAS,GAAmB,CAAC,GAAG,EAAE,EAAE,CAAC,GAAG,CAAC,QAAQ,EAAE,KAAK,QAAQ,CAAC,QAAQ,EAAE,CAAA;QAEjF,MAAM,EAAE,GAAa;YACnB,GAAG,CAAC;YACJ,OAAO,EAAE;gBACP,SAAS;aACV,CAAC,MAAM,CAAC,CAAC,CAAC,OAAO,IAAI,EAAE,CAAC;SAC1B,CAAA;QAED,OAAO,IAAI,CAAC,KAAK,CAAC,SAAS,CAAC,EAAE,EAAE,OAAO,CAAC,CAAA;IAC1C,CAAC;CACF"}

+5

-5

dist/src/tiered.d.ts

		import { BaseDatastore } from './base.ts';
		import type { AbortOptions } from 'abort-error';
		import type { Batch, Datastore, Key, KeyQuery, Pair, Query } from 'interface-datastore';
		import type { AbortOptions, AwaitGenerator, AwaitIterable } from 'interface-store';
		/**
		@@ -18,8 +18,8 @@ * A datastore that can combine multiple stores. Puts and deletes
		delete(key: Key, options?: AbortOptions): Promise<void>;
		putMany(source: AwaitIterable<Pair>, options?: AbortOptions): AwaitGenerator<Key>;
		deleteMany(source: AwaitIterable<Key>, options?: AbortOptions): AwaitGenerator<Key>;
		putMany(source: Iterable<Pair> \| AsyncIterable<Pair>, options?: AbortOptions): Generator<Key> \| AsyncGenerator<Key>;
		deleteMany(source: Iterable<Key> \| AsyncIterable<Key>, options?: AbortOptions): Generator<Key> \| AsyncGenerator<Key>;
		batch(): Batch;
		query(q: Query, options?: AbortOptions): AwaitGenerator<Pair>;
		queryKeys(q: KeyQuery, options?: AbortOptions): AwaitGenerator<Key>;
		query(q: Query, options?: AbortOptions): Generator<Pair> \| AsyncGenerator<Pair>;
		queryKeys(q: KeyQuery, options?: AbortOptions): Generator<Key> \| AsyncGenerator<Key>;
		}
		//# sourceMappingURL=tiered.d.ts.map

+1

-1

dist/src/tiered.d.ts.map

		@@ -1,1 +0,1 @@
		{"version":3,"file":"tiered.d.ts","sourceRoot":"","sources":["../../src/tiered.ts"],"names":[],"mappings":"AAEA,OAAO,EAAE,aAAa,EAAE,MAAM,WAAW,CAAA;AACzC,OAAO,KAAK,EAAE,KAAK,EAAE,SAAS,EAAE,GAAG,EAAE,QAAQ,EAAE,IAAI,EAAE,KAAK,EAAE,MAAM,qBAAqB,CAAA;AACvF,OAAO,KAAK,EAAE,YAAY,EAAE,cAAc,EAAE,aAAa,EAAE,MAAM,iBAAiB,CAAA;AAIlF;;;;;;GAMG;AACH,qBAAa,eAAgB,SAAQ,aAAa;IAChD,OAAO,CAAC,QAAQ,CAAC,MAAM,CAAa;gBAEvB,MAAM,EAAE,SAAS,EAAE;IAM1B,GAAG,CAAE,GAAG,EAAE,GAAG,EAAE,KAAK,EAAE,UAAU,EAAE,OAAO,CAAC,EAAE,YAAY,GAAG,OAAO,CAAC,GAAG,CAAC;IAUvE,GAAG,CAAE,GAAG,EAAE,GAAG,EAAE,OAAO,CAAC,EAAE,YAAY,GAAG,OAAO,CAAC,UAAU,CAAC;IAmB3D,GAAG,CAAE,GAAG,EAAE,GAAG,EAAE,OAAO,CAAC,EAAE,YAAY,GAAG,OAAO,CAAC,OAAO,CAAC;IAUxD,MAAM,CAAE,GAAG,EAAE,GAAG,EAAE,OAAO,CAAC,EAAE,YAAY,GAAG,OAAO,CAAC,IAAI,CAAC;IAQtD,OAAO,CAAE,MAAM,EAAE,aAAa,CAAC,IAAI,CAAC,EAAE,OAAO,GAAE,YAAiB,GAAG,cAAc,CAAC,GAAG,CAAC;IAOtF,UAAU,CAAE,MAAM,EAAE,aAAa,CAAC,GAAG,CAAC,EAAE,OAAO,GAAE,YAAiB,GAAG,cAAc,CAAC,GAAG,CAAC;IAOhG,KAAK,IAAK,KAAK;IAkBf,KAAK,CAAE,CAAC,EAAE,KAAK,EAAE,OAAO,CAAC,EAAE,YAAY,GAAG,cAAc,CAAC,IAAI,CAAC;IAI9D,SAAS,CAAE,CAAC,EAAE,QAAQ,EAAE,OAAO,CAAC,EAAE,YAAY,GAAG,cAAc,CAAC,GAAG,CAAC;CAGrE"}
		{"version":3,"file":"tiered.d.ts","sourceRoot":"","sources":["../../src/tiered.ts"],"names":[],"mappings":"AAEA,OAAO,EAAE,aAAa,EAAE,MAAM,WAAW,CAAA;AACzC,OAAO,KAAK,EAAE,YAAY,EAAE,MAAM,aAAa,CAAA;AAC/C,OAAO,KAAK,EAAE,KAAK,EAAE,SAAS,EAAE,GAAG,EAAE,QAAQ,EAAE,IAAI,EAAE,KAAK,EAAE,MAAM,qBAAqB,CAAA;AAIvF;;;;;;GAMG;AACH,qBAAa,eAAgB,SAAQ,aAAa;IAChD,OAAO,CAAC,QAAQ,CAAC,MAAM,CAAa;gBAEvB,MAAM,EAAE,SAAS,EAAE;IAM1B,GAAG,CAAE,GAAG,EAAE,GAAG,EAAE,KAAK,EAAE,UAAU,EAAE,OAAO,CAAC,EAAE,YAAY,GAAG,OAAO,CAAC,GAAG,CAAC;IAUvE,GAAG,CAAE,GAAG,EAAE,GAAG,EAAE,OAAO,CAAC,EAAE,YAAY,GAAG,OAAO,CAAC,UAAU,CAAC;IAmB3D,GAAG,CAAE,GAAG,EAAE,GAAG,EAAE,OAAO,CAAC,EAAE,YAAY,GAAG,OAAO,CAAC,OAAO,CAAC;IAUxD,MAAM,CAAE,GAAG,EAAE,GAAG,EAAE,OAAO,CAAC,EAAE,YAAY,GAAG,OAAO,CAAC,IAAI,CAAC;IAQtD,OAAO,CAAE,MAAM,EAAE,QAAQ,CAAC,IAAI,CAAC,GAAG,aAAa,CAAC,IAAI,CAAC,EAAE,OAAO,GAAE,YAAiB,GAAG,SAAS,CAAC,GAAG,CAAC,GAAG,cAAc,CAAC,GAAG,CAAC;IAOxH,UAAU,CAAE,MAAM,EAAE,QAAQ,CAAC,GAAG,CAAC,GAAG,aAAa,CAAC,GAAG,CAAC,EAAE,OAAO,GAAE,YAAiB,GAAG,SAAS,CAAC,GAAG,CAAC,GAAG,cAAc,CAAC,GAAG,CAAC;IAOjI,KAAK,IAAK,KAAK;IAkBf,KAAK,CAAE,CAAC,EAAE,KAAK,EAAE,OAAO,CAAC,EAAE,YAAY,GAAG,SAAS,CAAC,IAAI,CAAC,GAAG,cAAc,CAAC,IAAI,CAAC;IAIhF,SAAS,CAAE,CAAC,EAAE,QAAQ,EAAE,OAAO,CAAC,EAAE,YAAY,GAAG,SAAS,CAAC,GAAG,CAAC,GAAG,cAAc,CAAC,GAAG,CAAC;CAGtF"}

+1

-1

dist/src/tiered.js.map

		@@ -1,1 +0,1 @@
		{"version":3,"file":"tiered.js","sourceRoot":"","sources":["../../src/tiered.ts"],"names":[],"mappings":"AAAA,OAAO,EAAE,MAAM,EAAE,MAAM,gBAAgB,CAAA;AACvC,OAAO,EAAE,aAAa,EAAE,MAAM,iBAAiB,CAAA;AAC/C,OAAO,EAAE,aAAa,EAAE,MAAM,WAAW,CAAA;AAIzC,MAAM,GAAG,GAAG,MAAM,CAAC,uBAAuB,CAAC,CAAA;AAE3C;;;;;;GAMG;AACH,MAAM,OAAO,eAAgB,SAAQ,aAAa;IAC/B,MAAM,CAAa;IAEpC,YAAa,MAAmB;QAC9B,KAAK,EAAE,CAAA;QAEP,IAAI,CAAC,MAAM,GAAG,MAAM,CAAC,KAAK,EAAE,CAAA;IAC9B,CAAC;IAED,KAAK,CAAC,GAAG,CAAE,GAAQ,EAAE,KAAiB,EAAE,OAAsB;QAC5D,MAAM,OAAO,CAAC,GAAG,CACf,IAAI,CAAC,MAAM,CAAC,GAAG,CAAC,KAAK,EAAC,KAAK,EAAC,EAAE;YAC5B,MAAM,KAAK,CAAC,GAAG,CAAC,GAAG,EAAE,KAAK,EAAE,OAAO,CAAC,CAAA;QACtC,CAAC,CAAC,CACH,CAAA;QAED,OAAO,GAAG,CAAA;IACZ,CAAC;IAED,KAAK,CAAC,GAAG,CAAE,GAAQ,EAAE,OAAsB;QACzC,IAAI,KAAwB,CAAA;QAE5B,KAAK,MAAM,KAAK,IAAI,IAAI,CAAC,MAAM,EAAE,CAAC;YAChC,IAAI,CAAC;gBACH,MAAM,GAAG,GAAG,MAAM,KAAK,CAAC,GAAG,CAAC,GAAG,EAAE,OAAO,CAAC,CAAA;gBAEzC,IAAI,GAAG,IAAI,IAAI,EAAE,CAAC;oBAChB,OAAO,GAAG,CAAA;gBACZ,CAAC;YACH,CAAC;YAAC,OAAO,GAAQ,EAAE,CAAC;gBAClB,KAAK,GAAG,GAAG,CAAA;gBACX,GAAG,CAAC,KAAK,CAAC,GAAG,CAAC,CAAA;YAChB,CAAC;QACH,CAAC;QAED,MAAM,KAAK,IAAI,IAAI,aAAa,EAAE,CAAA;IACpC,CAAC;IAED,KAAK,CAAC,GAAG,CAAE,GAAQ,EAAE,OAAsB;QACzC,KAAK,MAAM,CAAC,IAAI,IAAI,CAAC,MAAM,EAAE,CAAC;YAC5B,IAAI,MAAM,CAAC,CAAC,GAAG,CAAC,GAAG,EAAE,OAAO,CAAC,EAAE,CAAC;gBAC9B,OAAO,IAAI,CAAA;YACb,CAAC;QACH,CAAC;QAED,OAAO,KAAK,CAAA;IACd,CAAC;IAED,KAAK,CAAC,MAAM,CAAE,GAAQ,EAAE,OAAsB;QAC5C,MAAM,OAAO,CAAC,GAAG,CACf,IAAI,CAAC,MAAM,CAAC,GAAG,CAAC,KAAK,EAAC,KAAK,EAAC,EAAE;YAC5B,MAAM,KAAK,CAAC,MAAM,CAAC,GAAG,EAAE,OAAO,CAAC,CAAA;QAClC,CAAC,CAAC,CACH,CAAA;IACH,CAAC;IAED,KAAK,CAAC,CAAE,OAAO,CAAE,MAA2B,EAAE,UAAwB,EAAE;QACtE,IAAI,KAAK,EAAE,MAAM,IAAI,IAAI,MAAM,EAAE,CAAC;YAChC,MAAM,IAAI,CAAC,GAAG,CAAC,IAAI,CAAC,GAAG,EAAE,IAAI,CAAC,KAAK,EAAE,OAAO,CAAC,CAAA;YAC7C,MAAM,IAAI,CAAC,GAAG,CAAA;QAChB,CAAC;IACH,CAAC;IAED,KAAK,CAAC,CAAE,UAAU,CAAE,MAA0B,EAAE,UAAwB,EAAE;QACxE,IAAI,KAAK,EAAE,MAAM,GAAG,IAAI,MAAM,EAAE,CAAC;YAC/B,MAAM,IAAI,CAAC,MAAM,CAAC,GAAG,EAAE,OAAO,CAAC,CAAA;YAC/B,MAAM,GAAG,CAAA;QACX,CAAC;IACH,CAAC;IAED,KAAK;QACH,MAAM,OAAO,GAAG,IAAI,CAAC,MAAM,CAAC,GAAG,CAAC,KAAK,CAAC,EAAE,CAAC,KAAK,CAAC,KAAK,EAAE,CAAC,CAAA;QAEvD,OAAO;YACL,GAAG,EAAE,CAAC,GAAG,EAAE,KAAK,EAAE,EAAE;gBAClB,OAAO,CAAC,OAAO,CAAC,CAAC,CAAC,EAAE,GAAG,CAAC,CAAC,GAAG,CAAC,GAAG,EAAE,KAAK,CAAC,CAAA,CAAC,CAAC,CAAC,CAAA;YAC7C,CAAC;YACD,MAAM,EAAE,CAAC,GAAG,EAAE,EAAE;gBACd,OAAO,CAAC,OAAO,CAAC,CAAC,CAAC,EAAE,GAAG,CAAC,CAAC,MAAM,CAAC,GAAG,CAAC,CAAA,CAAC,CAAC,CAAC,CAAA;YACzC,CAAC;YACD,MAAM,EAAE,KAAK,EAAE,OAAO,EAAE,EAAE;gBACxB,KAAK,MAAM,KAAK,IAAI,OAAO,EAAE,CAAC;oBAC5B,MAAM,KAAK,CAAC,MAAM,CAAC,OAAO,CAAC,CAAA;gBAC7B,CAAC;YACH,CAAC;SACF,CAAA;IACH,CAAC;IAED,KAAK,CAAE,CAAQ,EAAE,OAAsB;QACrC,OAAO,IAAI,CAAC,MAAM,CAAC,IAAI,CAAC,MAAM,CAAC,MAAM,GAAG,CAAC,CAAC,CAAC,KAAK,CAAC,CAAC,EAAE,OAAO,CAAC,CAAA;IAC9D,CAAC;IAED,SAAS,CAAE,CAAW,EAAE,OAAsB;QAC5C,OAAO,IAAI,CAAC,MAAM,CAAC,IAAI,CAAC,MAAM,CAAC,MAAM,GAAG,CAAC,CAAC,CAAC,SAAS,CAAC,CAAC,EAAE,OAAO,CAAC,CAAA;IAClE,CAAC;CACF"}
		{"version":3,"file":"tiered.js","sourceRoot":"","sources":["../../src/tiered.ts"],"names":[],"mappings":"AAAA,OAAO,EAAE,MAAM,EAAE,MAAM,gBAAgB,CAAA;AACvC,OAAO,EAAE,aAAa,EAAE,MAAM,iBAAiB,CAAA;AAC/C,OAAO,EAAE,aAAa,EAAE,MAAM,WAAW,CAAA;AAIzC,MAAM,GAAG,GAAG,MAAM,CAAC,uBAAuB,CAAC,CAAA;AAE3C;;;;;;GAMG;AACH,MAAM,OAAO,eAAgB,SAAQ,aAAa;IAC/B,MAAM,CAAa;IAEpC,YAAa,MAAmB;QAC9B,KAAK,EAAE,CAAA;QAEP,IAAI,CAAC,MAAM,GAAG,MAAM,CAAC,KAAK,EAAE,CAAA;IAC9B,CAAC;IAED,KAAK,CAAC,GAAG,CAAE,GAAQ,EAAE,KAAiB,EAAE,OAAsB;QAC5D,MAAM,OAAO,CAAC,GAAG,CACf,IAAI,CAAC,MAAM,CAAC,GAAG,CAAC,KAAK,EAAC,KAAK,EAAC,EAAE;YAC5B,MAAM,KAAK,CAAC,GAAG,CAAC,GAAG,EAAE,KAAK,EAAE,OAAO,CAAC,CAAA;QACtC,CAAC,CAAC,CACH,CAAA;QAED,OAAO,GAAG,CAAA;IACZ,CAAC;IAED,KAAK,CAAC,GAAG,CAAE,GAAQ,EAAE,OAAsB;QACzC,IAAI,KAAwB,CAAA;QAE5B,KAAK,MAAM,KAAK,IAAI,IAAI,CAAC,MAAM,EAAE,CAAC;YAChC,IAAI,CAAC;gBACH,MAAM,GAAG,GAAG,MAAM,KAAK,CAAC,GAAG,CAAC,GAAG,EAAE,OAAO,CAAC,CAAA;gBAEzC,IAAI,GAAG,IAAI,IAAI,EAAE,CAAC;oBAChB,OAAO,GAAG,CAAA;gBACZ,CAAC;YACH,CAAC;YAAC,OAAO,GAAQ,EAAE,CAAC;gBAClB,KAAK,GAAG,GAAG,CAAA;gBACX,GAAG,CAAC,KAAK,CAAC,GAAG,CAAC,CAAA;YAChB,CAAC;QACH,CAAC;QAED,MAAM,KAAK,IAAI,IAAI,aAAa,EAAE,CAAA;IACpC,CAAC;IAED,KAAK,CAAC,GAAG,CAAE,GAAQ,EAAE,OAAsB;QACzC,KAAK,MAAM,CAAC,IAAI,IAAI,CAAC,MAAM,EAAE,CAAC;YAC5B,IAAI,MAAM,CAAC,CAAC,GAAG,CAAC,GAAG,EAAE,OAAO,CAAC,EAAE,CAAC;gBAC9B,OAAO,IAAI,CAAA;YACb,CAAC;QACH,CAAC;QAED,OAAO,KAAK,CAAA;IACd,CAAC;IAED,KAAK,CAAC,MAAM,CAAE,GAAQ,EAAE,OAAsB;QAC5C,MAAM,OAAO,CAAC,GAAG,CACf,IAAI,CAAC,MAAM,CAAC,GAAG,CAAC,KAAK,EAAC,KAAK,EAAC,EAAE;YAC5B,MAAM,KAAK,CAAC,MAAM,CAAC,GAAG,EAAE,OAAO,CAAC,CAAA;QAClC,CAAC,CAAC,CACH,CAAA;IACH,CAAC;IAED,KAAK,CAAC,CAAE,OAAO,CAAE,MAA4C,EAAE,UAAwB,EAAE;QACvF,IAAI,KAAK,EAAE,MAAM,IAAI,IAAI,MAAM,EAAE,CAAC;YAChC,MAAM,IAAI,CAAC,GAAG,CAAC,IAAI,CAAC,GAAG,EAAE,IAAI,CAAC,KAAK,EAAE,OAAO,CAAC,CAAA;YAC7C,MAAM,IAAI,CAAC,GAAG,CAAA;QAChB,CAAC;IACH,CAAC;IAED,KAAK,CAAC,CAAE,UAAU,CAAE,MAA0C,EAAE,UAAwB,EAAE;QACxF,IAAI,KAAK,EAAE,MAAM,GAAG,IAAI,MAAM,EAAE,CAAC;YAC/B,MAAM,IAAI,CAAC,MAAM,CAAC,GAAG,EAAE,OAAO,CAAC,CAAA;YAC/B,MAAM,GAAG,CAAA;QACX,CAAC;IACH,CAAC;IAED,KAAK;QACH,MAAM,OAAO,GAAG,IAAI,CAAC,MAAM,CAAC,GAAG,CAAC,KAAK,CAAC,EAAE,CAAC,KAAK,CAAC,KAAK,EAAE,CAAC,CAAA;QAEvD,OAAO;YACL,GAAG,EAAE,CAAC,GAAG,EAAE,KAAK,EAAE,EAAE;gBAClB,OAAO,CAAC,OAAO,CAAC,CAAC,CAAC,EAAE,GAAG,CAAC,CAAC,GAAG,CAAC,GAAG,EAAE,KAAK,CAAC,CAAA,CAAC,CAAC,CAAC,CAAA;YAC7C,CAAC;YACD,MAAM,EAAE,CAAC,GAAG,EAAE,EAAE;gBACd,OAAO,CAAC,OAAO,CAAC,CAAC,CAAC,EAAE,GAAG,CAAC,CAAC,MAAM,CAAC,GAAG,CAAC,CAAA,CAAC,CAAC,CAAC,CAAA;YACzC,CAAC;YACD,MAAM,EAAE,KAAK,EAAE,OAAO,EAAE,EAAE;gBACxB,KAAK,MAAM,KAAK,IAAI,OAAO,EAAE,CAAC;oBAC5B,MAAM,KAAK,CAAC,MAAM,CAAC,OAAO,CAAC,CAAA;gBAC7B,CAAC;YACH,CAAC;SACF,CAAA;IACH,CAAC;IAED,KAAK,CAAE,CAAQ,EAAE,OAAsB;QACrC,OAAO,IAAI,CAAC,MAAM,CAAC,IAAI,CAAC,MAAM,CAAC,MAAM,GAAG,CAAC,CAAC,CAAC,KAAK,CAAC,CAAC,EAAE,OAAO,CAAC,CAAA;IAC9D,CAAC;IAED,SAAS,CAAE,CAAW,EAAE,OAAsB;QAC5C,OAAO,IAAI,CAAC,MAAM,CAAC,IAAI,CAAC,MAAM,CAAC,MAAM,GAAG,CAAC,CAAC,CAAC,SAAS,CAAC,CAAC,EAAE,OAAO,CAAC,CAAA;IAClE,CAAC;CACF"}

+4

-3

package.json

		{
		"name": "datastore-core",
		"version": "11.0.4",
		"version": "12.0.0",
		"description": "Wrapper implementation for interface-datastore",
		@@ -215,2 +215,3 @@ "author": "Friedel Ziegelmayer <dignifiedquire@gmail.com>",
		"@libp2p/logger": "^6.2.4",
		"abort-error": "^1.0.2",
		"interface-datastore": "^9.0.0",
		@@ -227,7 +228,7 @@ "interface-store": "^7.0.0",
		"devDependencies": {
		"aegir": "^47.1.0",
		"aegir": "^48.0.4",
		"interface-datastore-tests": "^6.0.0",
		"it-all": "^3.0.9",
		"uint8arrays": "^5.1.0"
		"uint8arrays": "^6.1.1"
		}
		}

+12

-12

src/base.ts

		@@ -5,23 +5,23 @@ import drain from 'it-drain'
		import take from 'it-take'
		import type { AbortOptions } from 'abort-error'
		import type { Batch, Datastore, Key, KeyQuery, Pair, Query } from 'interface-datastore'
		import type { AbortOptions, Await, AwaitGenerator, AwaitIterable } from 'interface-store'

		export class BaseDatastore implements Datastore {
		put (key: Key, val: Uint8Array, options?: AbortOptions): Await<Key> {
		put (key: Key, val: Uint8Array, options?: AbortOptions): Key \| Promise<Key> {
		return Promise.reject(new Error('.put is not implemented'))
		}

		get (key: Key, options?: AbortOptions): Await<Uint8Array> {
		get (key: Key, options?: AbortOptions): Uint8Array \| Promise<Uint8Array> {
		return Promise.reject(new Error('.get is not implemented'))
		}

		has (key: Key, options?: AbortOptions): Await<boolean> {
		has (key: Key, options?: AbortOptions): boolean \| Promise<boolean> {
		return Promise.reject(new Error('.has is not implemented'))
		}

		delete (key: Key, options?: AbortOptions): Await<void> {
		delete (key: Key, options?: AbortOptions): void \| Promise<void> {
		return Promise.reject(new Error('.delete is not implemented'))
		}

		async * putMany (source: AwaitIterable<Pair>, options: AbortOptions = {}): AwaitGenerator<Key> {
		async * putMany (source: Iterable<Pair> \| AsyncIterable<Pair>, options: AbortOptions = {}): Generator<Key> \| AsyncGenerator<Key> {
		for await (const { key, value } of source) {
		@@ -33,3 +33,3 @@ await this.put(key, value, options)

		async * getMany (source: AwaitIterable<Key>, options: AbortOptions = {}): AwaitGenerator<Pair> {
		async * getMany (source: Iterable<Key> \| AsyncIterable<Key>, options: AbortOptions = {}): Generator<Pair> \| AsyncGenerator<Pair> {
		for await (const key of source) {
		@@ -43,3 +43,3 @@ yield {

		async * deleteMany (source: AwaitIterable<Key>, options: AbortOptions = {}): AwaitGenerator<Key> {
		async * deleteMany (source: Iterable<Key> \| AsyncIterable<Key>, options: AbortOptions = {}): Generator<Key> \| AsyncGenerator<Key> {
		for await (const key of source) {
		@@ -76,3 +76,3 @@ await this.delete(key, options)
		// eslint-disable-next-line require-yield
		async * _all (q: Query, options?: AbortOptions): AwaitGenerator<Pair> {
		async * _all (q: Query, options?: AbortOptions): Generator<Pair> \| AsyncGenerator<Pair> {
		throw new Error('._all is not implemented')
		@@ -85,7 +85,7 @@ }
		// eslint-disable-next-line require-yield
		async * _allKeys (q: KeyQuery, options?: AbortOptions): AwaitGenerator<Key> {
		async * _allKeys (q: KeyQuery, options?: AbortOptions): Generator<Key> \| AsyncGenerator<Key> {
		throw new Error('._allKeys is not implemented')
		}

		query (q: Query, options?: AbortOptions): AwaitGenerator<Pair> {
		query (q: Query, options?: AbortOptions): Generator<Pair> \| AsyncGenerator<Pair> {
		let it = this._all(q, options)
		@@ -119,3 +119,3 @@

		queryKeys (q: KeyQuery, options?: AbortOptions): AwaitGenerator<Key> {
		queryKeys (q: KeyQuery, options?: AbortOptions): Generator<Key> \| AsyncGenerator<Key> {
		let it = this._allKeys(q, options)
		@@ -122,0 +122,0 @@

+7

-7

src/black-hole.ts

		import { NotFoundError } from 'interface-store'
		import { BaseDatastore } from './base.ts'
		import type { AbortOptions } from 'abort-error'
		import type { Pair, Query, KeyQuery } from 'interface-datastore'
		import type { Key } from 'interface-datastore/key'
		import type { AbortOptions, Await, AwaitGenerator } from 'interface-store'

		export class BlackHoleDatastore extends BaseDatastore {
		put (key: Key, value: Uint8Array, options?: AbortOptions): Await<Key> {
		put (key: Key, value: Uint8Array, options?: AbortOptions): Key \| Promise<Key> {
		options?.signal?.throwIfAborted()
		@@ -13,3 +13,3 @@ return key

		get (key: Key, options?: AbortOptions): Await<Uint8Array> {
		get (key: Key, options?: AbortOptions): Uint8Array \| Promise<Uint8Array> {
		options?.signal?.throwIfAborted()
		@@ -19,3 +19,3 @@ throw new NotFoundError()

		has (key: Key, options?: AbortOptions): Await<boolean> {
		has (key: Key, options?: AbortOptions): boolean \| Promise<boolean> {
		options?.signal?.throwIfAborted()
		@@ -25,3 +25,3 @@ return false

		delete (key: Key, options?: AbortOptions): Await<void> {
		delete (key: Key, options?: AbortOptions): void \| Promise<void> {
		options?.signal?.throwIfAborted()
		@@ -31,3 +31,3 @@ }
		// eslint-disable-next-line require-yield
		* _all (q: Query, options?: AbortOptions): AwaitGenerator<Pair> {
		* _all (q: Query, options?: AbortOptions): Generator<Pair> \| AsyncGenerator<Pair> {
		options?.signal?.throwIfAborted()
		@@ -37,5 +37,5 @@ }
		// eslint-disable-next-line require-yield
		* _allKeys (q: KeyQuery, options?: AbortOptions): AwaitGenerator<Key> {
		* _allKeys (q: KeyQuery, options?: AbortOptions): Generator<Key> \| AsyncGenerator<Key> {
		options?.signal?.throwIfAborted()
		}
		}

+6

-6

src/keytransform.ts

		@@ -5,4 +5,4 @@ import map from 'it-map'
		import type { KeyTransform } from './index.ts'
		import type { AbortOptions } from 'abort-error'
		import type { Batch, Datastore, Key, KeyQuery, Pair, Query } from 'interface-datastore'
		import type { AbortOptions, AwaitGenerator, AwaitIterable } from 'interface-store'

		@@ -43,3 +43,3 @@ /**

		async * putMany (source: AwaitIterable<Pair>, options: AbortOptions = {}): AwaitGenerator<Key> {
		async * putMany (source: Iterable<Pair> \| AsyncIterable<Pair>, options: AbortOptions = {}): Generator<Key> \| AsyncGenerator<Key> {
		const transform = this.transform
		@@ -65,3 +65,3 @@ const child = this.child

		async * getMany (source: AwaitIterable<Key>, options: AbortOptions = {}): AwaitGenerator<Pair> {
		async * getMany (source: Iterable<Key> \| AsyncIterable<Key>, options: AbortOptions = {}): Generator<Pair> \| AsyncGenerator<Pair> {
		const transform = this.transform
		@@ -87,3 +87,3 @@ const child = this.child

		async * deleteMany (source: AwaitIterable<Key>, options: AbortOptions = {}): AwaitGenerator<Key> {
		async * deleteMany (source: Iterable<Key> \| AsyncIterable<Key>, options: AbortOptions = {}): Generator<Key> \| AsyncGenerator<Key> {
		const transform = this.transform
		@@ -121,3 +121,3 @@ const child = this.child

		query (q: Query, options?: AbortOptions): AwaitGenerator<Pair> {
		query (q: Query, options?: AbortOptions): Generator<Pair> \| AsyncGenerator<Pair> {
		const query: Query = {
		@@ -156,3 +156,3 @@ ...q

		queryKeys (q: KeyQuery, options?: AbortOptions): AwaitGenerator<Key> {
		queryKeys (q: KeyQuery, options?: AbortOptions): Generator<Key> \| AsyncGenerator<Key> {
		const query = {
		@@ -159,0 +159,0 @@ ...q

+7

-7

src/memory.ts

		import { Key } from 'interface-datastore/key'
		import { NotFoundError } from 'interface-store'
		import { BaseDatastore } from './base.ts'
		import type { AbortOptions } from 'abort-error'
		import type { KeyQuery, Pair, Query } from 'interface-datastore'
		import type { AbortOptions, Await, AwaitGenerator } from 'interface-store'

		@@ -16,3 +16,3 @@ export class MemoryDatastore extends BaseDatastore {

		put (key: Key, val: Uint8Array, options?: AbortOptions): Await<Key> {
		put (key: Key, val: Uint8Array, options?: AbortOptions): Key \| Promise<Key> {
		options?.signal?.throwIfAborted()
		@@ -25,3 +25,3 @@

		get (key: Key, options?: AbortOptions): Await<Uint8Array> {
		get (key: Key, options?: AbortOptions): Uint8Array \| Promise<Uint8Array> {
		options?.signal?.throwIfAborted()
		@@ -38,3 +38,3 @@

		has (key: Key, options?: AbortOptions): Await<boolean> {
		has (key: Key, options?: AbortOptions): boolean \| Promise<boolean> {
		options?.signal?.throwIfAborted()
		@@ -44,3 +44,3 @@ return this.data.has(key.toString())

		delete (key: Key, options?: AbortOptions): Await<void> {
		delete (key: Key, options?: AbortOptions): void \| Promise<void> {
		options?.signal?.throwIfAborted()
		@@ -50,3 +50,3 @@ this.data.delete(key.toString())

		* _all (q: Query, options?: AbortOptions): AwaitGenerator<Pair> {
		* _all (q: Query, options?: AbortOptions): Generator<Pair> \| AsyncGenerator<Pair> {
		options?.signal?.throwIfAborted()
		@@ -59,3 +59,3 @@ for (const [key, value] of this.data.entries()) {

		* _allKeys (q: KeyQuery, options?: AbortOptions): AwaitGenerator<Key> {
		* _allKeys (q: KeyQuery, options?: AbortOptions): Generator<Key> \| AsyncGenerator<Key> {
		options?.signal?.throwIfAborted()
		@@ -62,0 +62,0 @@ for (const key of this.data.keys()) {

+3

-3

src/mount.ts

		@@ -7,4 +7,4 @@ import { DeleteFailedError, NotFoundError, PutFailedError } from 'interface-store'
		import { BaseDatastore } from './base.ts'
		import type { AbortOptions } from 'abort-error'
		import type { Batch, Datastore, Key, KeyQuery, Pair, Query } from 'interface-datastore'
		import type { AbortOptions, AwaitGenerator } from 'interface-store'

		@@ -112,3 +112,3 @@ /**

		query (q: Query, options?: AbortOptions): AwaitGenerator<Pair> {
		query (q: Query, options?: AbortOptions): Generator<Pair> \| AsyncGenerator<Pair> {
		const qs = this.mounts.map(m => {
		@@ -134,3 +134,3 @@ return m.datastore.query({

		queryKeys (q: KeyQuery, options?: AbortOptions): AwaitGenerator<Key> {
		queryKeys (q: KeyQuery, options?: AbortOptions): Generator<Key> \| AsyncGenerator<Key> {
		const qs = this.mounts.map(m => {
		@@ -137,0 +137,0 @@ return m.datastore.queryKeys({

+3

-3

src/namespace.ts

		import { Key } from 'interface-datastore'
		import map from 'it-map'
		import { KeyTransformDatastore } from './keytransform.ts'
		import type { AbortOptions } from 'abort-error'
		import type { Datastore, Query, Pair, KeyQuery } from 'interface-datastore'
		import type { AbortOptions, AwaitGenerator } from 'interface-store'

		@@ -41,3 +41,3 @@ /**

		query (q: Query, options?: AbortOptions): AwaitGenerator<Pair> {
		query (q: Query, options?: AbortOptions): Generator<Pair> \| AsyncGenerator<Pair> {
		const query: Query = {
		@@ -78,3 +78,3 @@ ...q

		queryKeys (q: KeyQuery, options?: AbortOptions): AwaitGenerator<Key> {
		queryKeys (q: KeyQuery, options?: AbortOptions): Generator<Key> \| AsyncGenerator<Key> {
		const query = {
		@@ -81,0 +81,0 @@ ...q

+6

-6

src/sharding.ts

		@@ -10,4 +10,4 @@ import { Key } from 'interface-datastore'
		import type { Shard } from './index.ts'
		import type { AbortOptions } from 'abort-error'
		import type { Batch, KeyQuery, KeyQueryFilter, Pair, Query, QueryFilter, Datastore } from 'interface-datastore'
		import type { AbortOptions, AwaitGenerator, AwaitIterable } from 'interface-store'

		@@ -103,11 +103,11 @@ const shardKey = new Key(SHARDING_FN)

		async * putMany (source: AwaitIterable<Pair>, options: AbortOptions = {}): AwaitGenerator<Key> {
		async * putMany (source: Iterable<Pair> \| AsyncIterable<Pair>, options: AbortOptions = {}): Generator<Key> \| AsyncGenerator<Key> {
		yield * this.child.putMany(source, options)
		}

		async * getMany (source: AwaitIterable<Key>, options: AbortOptions = {}): AwaitGenerator<Pair> {
		async * getMany (source: Iterable<Key> \| AsyncIterable<Key>, options: AbortOptions = {}): Generator<Pair> \| AsyncGenerator<Pair> {
		yield * this.child.getMany(source, options)
		}

		async * deleteMany (source: AwaitIterable<Key>, options: AbortOptions = {}): AwaitGenerator<Key> {
		async * deleteMany (source: Iterable<Key> \| AsyncIterable<Key>, options: AbortOptions = {}): Generator<Key> \| AsyncGenerator<Key> {
		yield * this.child.deleteMany(source, options)
		@@ -120,3 +120,3 @@ }

		query (q: Query, options?: AbortOptions): AwaitGenerator<Pair> {
		query (q: Query, options?: AbortOptions): Generator<Pair> \| AsyncGenerator<Pair> {
		const omitShard: QueryFilter = ({ key }) => key.toString() !== shardKey.toString()
		@@ -134,3 +134,3 @@

		queryKeys (q: KeyQuery, options?: AbortOptions): AwaitGenerator<Key> {
		queryKeys (q: KeyQuery, options?: AbortOptions): Generator<Key> \| AsyncGenerator<Key> {
		const omitShard: KeyQueryFilter = (key) => key.toString() !== shardKey.toString()
		@@ -137,0 +137,0 @@

+5

-5

src/tiered.ts

		import { logger } from '@libp2p/logger'
		import { NotFoundError } from 'interface-store'
		import { BaseDatastore } from './base.ts'
		import type { AbortOptions } from 'abort-error'
		import type { Batch, Datastore, Key, KeyQuery, Pair, Query } from 'interface-datastore'
		import type { AbortOptions, AwaitGenerator, AwaitIterable } from 'interface-store'

		@@ -72,3 +72,3 @@ const log = logger('datastore:core:tiered')

		async * putMany (source: AwaitIterable<Pair>, options: AbortOptions = {}): AwaitGenerator<Key> {
		async * putMany (source: Iterable<Pair> \| AsyncIterable<Pair>, options: AbortOptions = {}): Generator<Key> \| AsyncGenerator<Key> {
		for await (const pair of source) {
		@@ -80,3 +80,3 @@ await this.put(pair.key, pair.value, options)

		async * deleteMany (source: AwaitIterable<Key>, options: AbortOptions = {}): AwaitGenerator<Key> {
		async * deleteMany (source: Iterable<Key> \| AsyncIterable<Key>, options: AbortOptions = {}): Generator<Key> \| AsyncGenerator<Key> {
		for await (const key of source) {
		@@ -106,9 +106,9 @@ await this.delete(key, options)

		query (q: Query, options?: AbortOptions): AwaitGenerator<Pair> {
		query (q: Query, options?: AbortOptions): Generator<Pair> \| AsyncGenerator<Pair> {
		return this.stores[this.stores.length - 1].query(q, options)
		}

		queryKeys (q: KeyQuery, options?: AbortOptions): AwaitGenerator<Key> {
		queryKeys (q: KeyQuery, options?: AbortOptions): Generator<Key> \| AsyncGenerator<Key> {
		return this.stores[this.stores.length - 1].queryKeys(q, options)
		}
		}

dist/index.min.js.map

Sorry, the diff of this file is too big to display

datastore-core - npm Package Compare versions

Improved metrics

Worsened metrics

Dependency changes