@fortify-ts/core - npm Package Compare versions

Comparing version

0.1.1

0.1.2

+6

-0

dist/index.cjs

		@@ -246,2 +246,7 @@ 'use strict';
		}
		function throwIfAborted(signal) {
		if (signal?.aborted) {
		throw signal.reason ?? new DOMException("Aborted", "AbortError");
		}
		}
		function safeCallback(callback, onError) {
		@@ -403,2 +408,3 @@ if (!callback) return void 0;
		exports.sleep = sleep;
		exports.throwIfAborted = throwIfAborted;
		exports.timeoutConfigSchema = timeoutConfigSchema;
		@@ -405,0 +411,0 @@ exports.withTimeout = withTimeout;

+1

-1

dist/index.cjs.map

		@@ -1,1 +0,1 @@
		{"version":3,"sources":["../src/errors.ts","../src/types.ts","../src/utils.ts","../src/schemas.ts"],"names":["z"],"mappings":";;;;;;;;;AAGO,IAAM,YAAA,GAAN,cAA2B,KAAA,CAAM;AAAA,EACtC,YAAY,OAAA,EAAiB;AAC3B,IAAA,KAAA,CAAM,OAAO,CAAA;AACb,IAAA,IAAA,CAAK,IAAA,GAAO,cAAA;AAGZ,IAAA,IAAI,OAAO,KAAA,CAAM,iBAAA,KAAsB,UAAA,EAAY;AACjD,MAAA,KAAA,CAAM,iBAAA,CAAkB,IAAA,EAAM,IAAA,CAAK,WAAW,CAAA;AAAA,IAChD;AAAA,EACF;AACF;AAKO,IAAM,gBAAA,GAAN,cAA+B,YAAA,CAAa;AAAA,EACjD,WAAA,CAAY,UAAU,yBAAA,EAA2B;AAC/C,IAAA,KAAA,CAAM,OAAO,CAAA;AACb,IAAA,IAAA,CAAK,IAAA,GAAO,kBAAA;AAAA,EACd;AACF;AAKO,IAAM,sBAAA,GAAN,cAAqC,YAAA,CAAa;AAAA,EAGvD,WAAA,CAAY,OAAA,GAAU,qBAAA,EAAuB,GAAA,EAAc;AACzD,IAAA,KAAA,CAAM,OAAO,CAAA;AAHf,IAAA,aAAA,CAAA,IAAA,EAAgB,KAAA,CAAA;AAId,IAAA,IAAA,CAAK,IAAA,GAAO,wBAAA;AACZ,IAAA,IAAA,CAAK,GAAA,GAAM,GAAA;AAAA,EACb;AACF;AAKO,IAAM,iBAAA,GAAN,cAAgC,YAAA,CAAa;AAAA,EAIlD,YACE,OAAA,GAAU,kBAAA,EACV,WAAA,GAAc,CAAA,EACd,cAAc,CAAA,EACd;AACA,IAAA,KAAA,CAAM,OAAO,CAAA;AARf,IAAA,aAAA,CAAA,IAAA,EAAgB,aAAA,CAAA;AAChB,IAAA,aAAA,CAAA,IAAA,EAAgB,aAAA,CAAA;AAQd,IAAA,IAAA,CAAK,IAAA,GAAO,mBAAA;AACZ,IAAA,IAAA,CAAK,WAAA,GAAc,WAAA;AACnB,IAAA,IAAA,CAAK,WAAA,GAAc,WAAA;AAAA,EACrB;AACF;AAKO,IAAM,YAAA,GAAN,cAA2B,YAAA,CAAa;AAAA,EAG7C,WAAA,CAAY,OAAA,GAAU,qBAAA,EAAuB,SAAA,GAAY,CAAA,EAAG;AAC1D,IAAA,KAAA,CAAM,OAAO,CAAA;AAHf,IAAA,aAAA,CAAA,IAAA,EAAgB,WAAA,CAAA;AAId,IAAA,IAAA,CAAK,IAAA,GAAO,cAAA;AACZ,IAAA,IAAA,CAAK,SAAA,GAAY,SAAA;AAAA,EACnB;AACF;AAKO,IAAM,uBAAA,GAAN,cAAsC,YAAA,CAAa;AAAA,EAIxD,WAAA,CACE,OAAA,GAAU,gCAAA,EACV,QAAA,GAAW,GACX,SAAA,EACA;AACA,IAAA,KAAA,CAAM,OAAO,CAAA;AARf,IAAA,aAAA,CAAA,IAAA,EAAgB,UAAA,CAAA;AAChB,IAAA,aAAA,CAAA,IAAA,EAAgB,WAAA,CAAA;AAQd,IAAA,IAAA,CAAK,IAAA,GAAO,yBAAA;AACZ,IAAA,IAAA,CAAK,QAAA,GAAW,QAAA;AAChB,IAAA,IAAA,CAAK,SAAA,GAAY,SAAA;AAAA,EACnB;AACF;AAKO,IAAM,mBAAA,GAAN,cAAkC,YAAA,CAAa;AAAA,EACpD,WAAA,CAAY,UAAU,oBAAA,EAAsB;AAC1C,IAAA,KAAA,CAAM,OAAO,CAAA;AACb,IAAA,IAAA,CAAK,IAAA,GAAO,qBAAA;AAAA,EACd;AACF;AAYO,SAAS,iBAAiB,KAAA,EAAiD;AAChF,EAAA,OACE,iBAAiB,KAAA,IACjB,WAAA,IAAe,KAAA,IACf,OAAQ,MAAyB,SAAA,KAAc,SAAA;AAEnD;AAKO,IAAM,qBAAA,GAAN,cAAoC,KAAA,CAAgC;AAAA,EAIzE,WAAA,CAAY,OAAc,SAAA,EAAoB;AAC5C,IAAA,KAAA,CAAM,KAAA,CAAM,OAAA,EAAS,EAAE,KAAA,EAAO,OAAO,CAAA;AAJvC,IAAA,aAAA,CAAA,IAAA,EAAgB,WAAA,CAAA;AAChB,IAAA,aAAA,CAAA,IAAA,EAAyB,OAAA,CAAA;AAIvB,IAAA,IAAA,CAAK,IAAA,GAAO,uBAAA;AACZ,IAAA,IAAA,CAAK,SAAA,GAAY,SAAA;AACjB,IAAA,IAAA,CAAK,KAAA,GAAQ,KAAA;AACb,IAAA,IAAI,MAAM,KAAA,EAAO;AACf,MAAA,IAAA,CAAK,QAAQ,KAAA,CAAM,KAAA;AAAA,IACrB;AAAA,EACF;AACF;AAKO,SAAS,WAAA,CAAY,KAAA,EAAc,SAAA,GAAY,IAAA,EAA6B;AACjF,EAAA,OAAO,IAAI,qBAAA,CAAsB,KAAA,EAAO,SAAS,CAAA;AACnD;AAKO,SAAS,eAAe,KAAA,EAAqC;AAClE,EAAA,OAAO,IAAI,qBAAA,CAAsB,KAAA,EAAO,KAAK,CAAA;AAC/C;AAOO,SAAS,YAAY,KAAA,EAAqC;AAC/D,EAAA,IAAI,gBAAA,CAAiB,KAAK,CAAA,EAAG;AAC3B,IAAA,OAAO,KAAA,CAAM,SAAA;AAAA,EACf;AACA,EAAA,OAAO,MAAA;AACT;;;AC7GO,IAAM,UAAA,GAA4B;AAAA,EACvC,OAAO,MAAM,MAAA;AAAA,EACb,MAAM,MAAM,MAAA;AAAA,EACZ,MAAM,MAAM,MAAA;AAAA,EACZ,OAAO,MAAM;AACf;AAMO,IAAM,aAAA,GAA+B;AAAA,EAC1C,KAAA,EAAO,CAAC,GAAA,EAAK,OAAA,KAAY;AACvB,IAAA,IAAI,OAAA,EAAS;AACX,MAAA,OAAA,CAAQ,KAAA,CAAM,CAAA,UAAA,EAAa,GAAG,CAAA,CAAA,EAAI,OAAO,CAAA;AAAA,IAC3C,CAAA,MAAO;AACL,MAAA,OAAA,CAAQ,KAAA,CAAM,CAAA,UAAA,EAAa,GAAG,CAAA,CAAE,CAAA;AAAA,IAClC;AAAA,EACF,CAAA;AAAA,EACA,IAAA,EAAM,CAAC,GAAA,EAAK,OAAA,KAAY;AACtB,IAAA,IAAI,OAAA,EAAS;AACX,MAAA,OAAA,CAAQ,IAAA,CAAK,CAAA,UAAA,EAAa,GAAG,CAAA,CAAA,EAAI,OAAO,CAAA;AAAA,IAC1C,CAAA,MAAO;AACL,MAAA,OAAA,CAAQ,IAAA,CAAK,CAAA,UAAA,EAAa,GAAG,CAAA,CAAE,CAAA;AAAA,IACjC;AAAA,EACF,CAAA;AAAA,EACA,IAAA,EAAM,CAAC,GAAA,EAAK,OAAA,KAAY;AACtB,IAAA,IAAI,OAAA,EAAS;AACX,MAAA,OAAA,CAAQ,IAAA,CAAK,CAAA,UAAA,EAAa,GAAG,CAAA,CAAA,EAAI,OAAO,CAAA;AAAA,IAC1C,CAAA,MAAO;AACL,MAAA,OAAA,CAAQ,IAAA,CAAK,CAAA,UAAA,EAAa,GAAG,CAAA,CAAE,CAAA;AAAA,IACjC;AAAA,EACF,CAAA;AAAA,EACA,KAAA,EAAO,CAAC,GAAA,EAAK,OAAA,KAAY;AACvB,IAAA,IAAI,OAAA,EAAS;AACX,MAAA,OAAA,CAAQ,KAAA,CAAM,CAAA,UAAA,EAAa,GAAG,CAAA,CAAA,EAAI,OAAO,CAAA;AAAA,IAC3C,CAAA,MAAO;AACL,MAAA,OAAA,CAAQ,KAAA,CAAM,CAAA,UAAA,EAAa,GAAG,CAAA,CAAE,CAAA;AAAA,IAClC;AAAA,EACF;AACF;;;ACjFO,SAAS,KAAA,CAAM,IAAY,MAAA,EAAqC;AACrE,EAAA,OAAO,IAAI,OAAA,CAAQ,CAAC,OAAA,EAAS,MAAA,KAAW;AACtC,IAAA,IAAI,QAAQ,OAAA,EAAS;AACnB,MAAA,MAAA,CAAO,WAAA,CAAY,MAAA,CAAO,MAAM,CAAC,CAAA;AACjC,MAAA;AAAA,IACF;AAEA,IAAA,MAAM,SAAA,GAAY,UAAA,CAAW,OAAA,EAAS,EAAE,CAAA;AAExC,IAAA,MAAA,EAAQ,gBAAA;AAAA,MACN,OAAA;AAAA,MACA,MAAM;AACJ,QAAA,YAAA,CAAa,SAAS,CAAA;AACtB,QAAA,MAAA,CAAO,WAAA,CAAY,MAAA,CAAO,MAAM,CAAC,CAAA;AAAA,MACnC,CAAA;AAAA,MACA,EAAE,MAAM,IAAA;AAAK,KACf;AAAA,EACF,CAAC,CAAA;AACH;AAOA,SAAS,YAAY,MAAA,EAAwB;AAC3C,EAAA,IAAI,kBAAkB,KAAA,EAAO;AAC3B,IAAA,OAAO,MAAA;AAAA,EACT;AACA,EAAA,IAAI,OAAO,WAAW,QAAA,EAAU;AAC9B,IAAA,OAAO,IAAI,MAAM,MAAM,CAAA;AAAA,EACzB;AACA,EAAA,IAAI,MAAA,KAAW,MAAA,IAAa,MAAA,KAAW,IAAA,EAAM;AAE3C,IAAA,IAAI;AACF,MAAA,OAAO,IAAI,KAAA,CAAM,IAAA,CAAK,SAAA,CAAU,MAAM,CAAC,CAAA;AAAA,IACzC,CAAA,CAAA,MAAQ;AACN,MAAA,OAAO,IAAI,MAAM,eAAe,CAAA;AAAA,IAClC;AAAA,EACF;AACA,EAAA,OAAO,IAAI,YAAA,CAAa,SAAA,EAAW,YAAY,CAAA;AACjD;AAWA,eAAsB,WAAA,CACpB,OAAA,EACA,EAAA,EACA,MAAA,EACY;AAEZ,EAAA,IAAI,QAAQ,OAAA,EAAS;AACnB,IAAA,MAAM,WAAA,CAAY,OAAO,MAAM,CAAA;AAAA,EACjC;AAEA,EAAA,IAAI,SAAA;AAEJ,EAAA,MAAM,cAAA,GAAiB,IAAI,OAAA,CAAe,CAAC,GAAG,MAAA,KAAW;AACvD,IAAA,SAAA,GAAY,WAAW,MAAM;AAC3B,MAAA,MAAA,CAAO,IAAI,aAAa,CAAA,0BAAA,EAA6B,MAAA,CAAO,EAAE,CAAC,CAAA,EAAA,CAAA,EAAM,EAAE,CAAC,CAAA;AAAA,IAC1E,GAAG,EAAE,CAAA;AAAA,EACP,CAAC,CAAA;AAGD,EAAA,MAAM,eAAe,MAAA,GACjB,IAAI,OAAA,CAAe,CAAC,GAAG,MAAA,KAAW;AAChC,IAAA,MAAA,CAAO,gBAAA;AAAA,MACL,OAAA;AAAA,MACA,MAAM,MAAA,CAAO,WAAA,CAAY,MAAA,CAAO,MAAM,CAAC,CAAA;AAAA,MACvC,EAAE,MAAM,IAAA;AAAK,KACf;AAAA,EACF,CAAC,CAAA,GACD,IAAA;AAEJ,EAAA,IAAI;AACF,IAAA,MAAM,MAAA,GAAuB,CAAC,OAAA,EAAS,cAAc,CAAA;AACrD,IAAA,IAAI,YAAA,EAAc;AAChB,MAAA,MAAA,CAAO,KAAK,YAAY,CAAA;AAAA,IAC1B;AACA,IAAA,OAAO,MAAM,OAAA,CAAQ,IAAA,CAAK,MAAM,CAAA;AAAA,EAClC,CAAA,SAAE;AACA,IAAA,IAAI,cAAc,MAAA,EAAW;AAC3B,MAAA,YAAA,CAAa,SAAS,CAAA;AAAA,IACxB;AAAA,EACF;AACF;AAWA,eAAsB,kBAAA,CACpB,SAAA,EACA,EAAA,EACA,MAAA,EACY;AACZ,EAAA,MAAM,UAAA,GAAa,IAAI,eAAA,EAAgB;AAGvC,EAAA,MAAM,cAAA,GAAiB,cAAA,CAAe,MAAA,EAAQ,UAAA,CAAW,MAAM,CAAA;AAE/D,EAAA,MAAM,SAAA,GAAY,WAAW,MAAM;AACjC,IAAA,UAAA,CAAW,KAAA,CAAM,IAAI,YAAA,CAAa,CAAA,0BAAA,EAA6B,OAAO,EAAE,CAAC,CAAA,EAAA,CAAA,EAAM,EAAE,CAAC,CAAA;AAAA,EACpF,GAAG,EAAE,CAAA;AAEL,EAAA,IAAI;AACF,IAAA,OAAO,MAAM,UAAU,cAAc,CAAA;AAAA,EACvC,CAAA,SAAE;AACA,IAAA,YAAA,CAAa,SAAS,CAAA;AAAA,EACxB;AACF;AAYO,SAAS,kBAAkB,OAAA,EAAmD;AACnF,EAAA,MAAM,eAAe,OAAA,CAAQ,MAAA,CAAO,CAAC,CAAA,KAAwB,MAAM,MAAS,CAAA;AAE5E,EAAA,IAAI,YAAA,CAAa,WAAW,CAAA,EAAG;AAC7B,IAAA,OAAO,IAAI,iBAAgB,CAAE,MAAA;AAAA,EAC/B;AAEA,EAAA,MAAM,WAAA,GAAc,aAAa,CAAC,CAAA;AAClC,EAAA,IAAI,YAAA,CAAa,MAAA,KAAW,CAAA,IAAK,WAAA,EAAa;AAC5C,IAAA,OAAO,WAAA;AAAA,EACT;AAGA,EAAA,IAAI,SAAS,WAAA,EAAa;AACxB,IAAA,OAAO,WAAA,CAAY,IAAI,YAAY,CAAA;AAAA,EACrC;AAIA,EAAA,MAAM,UAAA,GAAa,IAAI,eAAA,EAAgB;AACvC,EAAA,MAAM,YAA6D,EAAC;AAGpE,EAAA,MAAM,UAAU,MAAM;AACpB,IAAA,KAAA,MAAW,EAAE,MAAA,EAAQ,QAAA,EAAS,IAAK,SAAA,EAAW;AAC5C,MAAA,MAAA,CAAO,mBAAA,CAAoB,SAAS,QAAQ,CAAA;AAAA,IAC9C;AACA,IAAA,SAAA,CAAU,MAAA,GAAS,CAAA;AAAA,EACrB,CAAA;AAEA,EAAA,KAAA,MAAW,UAAU,YAAA,EAAc;AACjC,IAAA,IAAI,OAAO,OAAA,EAAS;AAClB,MAAA,UAAA,CAAW,KAAA,CAAM,OAAO,MAAM,CAAA;AAC9B,MAAA,OAAO,UAAA,CAAW,MAAA;AAAA,IACpB;AAEA,IAAA,MAAM,WAAW,MAAM;AACrB,MAAA,OAAA,EAAQ;AACR,MAAA,UAAA,CAAW,KAAA,CAAM,OAAO,MAAM,CAAA;AAAA,IAChC,CAAA;AAEA,IAAA,SAAA,CAAU,IAAA,CAAK,EAAE,MAAA,EAAQ,QAAA,EAAU,CAAA;AACnC,IAAA,MAAA,CAAO,iBAAiB,OAAA,EAAS,QAAA,EAAU,EAAE,IAAA,EAAM,MAAM,CAAA;AAAA,EAC3D;AAEA,EAAA,OAAO,UAAA,CAAW,MAAA;AACpB;AAQO,SAAS,aAAa,KAAA,EAAyB;AACpD,EAAA,OACE,KAAA,YAAiB,YAAA,IACjB,KAAA,CAAM,IAAA,KAAS,YAAA;AAEnB;AASO,SAAS,YAAA,CACd,UACA,OAAA,EACe;AACf,EAAA,IAAI,CAAC,UAAU,OAAO,MAAA;AAEtB,EAAA,QAAQ,IAAI,IAAA,KAAmD;AAC7D,IAAA,IAAI;AACF,MAAA,OAAO,QAAA,CAAS,GAAG,IAAI,CAAA;AAAA,IACzB,SAAS,KAAA,EAAO;AACd,MAAA,IAAI,OAAA,IAAW,iBAAiB,KAAA,EAAO;AACrC,QAAA,OAAA,CAAQ,KAAK,CAAA;AAAA,MACf;AACA,MAAA,OAAO,MAAA;AAAA,IACT;AAAA,EACF,CAAA;AACF;AASO,SAAS,UAAU,KAAA,EAAuB;AAC/C,EAAA,MAAM,YAAA,GAAe,CAAA,GAAI,IAAA,CAAK,MAAA,EAAO,GAAI,GAAA;AACzC,EAAA,OAAO,IAAA,CAAK,KAAA,CAAM,KAAA,GAAQ,YAAY,CAAA;AACxC;AAUO,SAAS,KAAA,CAAM,KAAA,EAAe,GAAA,EAAa,GAAA,EAAqB;AACrE,EAAA,OAAO,KAAK,GAAA,CAAI,IAAA,CAAK,IAAI,KAAA,EAAO,GAAG,GAAG,GAAG,CAAA;AAC3C;AAQO,SAAS,GAAA,GAAc;AAC5B,EAAA,IAAI,OAAO,WAAA,KAAgB,WAAA,IAAe,OAAO,WAAA,CAAY,QAAQ,UAAA,EAAY;AAC/E,IAAA,OAAO,YAAY,GAAA,EAAI;AAAA,EACzB;AACA,EAAA,OAAO,KAAK,GAAA,EAAI;AAClB;AClQA,IAAM,cAAA,GAAiBA,MAAE,QAAA,EAAS;AAM3B,IAAM,YAAA,GAAeA,MAAE,MAAA,CAAO;AAAA,EACnC,KAAA,EAAO,cAAA;AAAA,EACP,IAAA,EAAM,cAAA;AAAA,EACN,IAAA,EAAM,cAAA;AAAA,EACN,KAAA,EAAO;AACT,CAAC,EAAE,QAAA;AAKI,IAAM,mBAAA,GAAsBA,MAAE,MAAA,CAAO;AAAA;AAAA,EAE1C,cAAA,EAAgBA,MAAE,MAAA,EAAO,CAAE,KAAI,CAAE,QAAA,EAAS,CAAE,OAAA,CAAQ,GAAK,CAAA;AAAA;AAAA,EAEzD,SAAA,EAAW,eAAe,QAAA,EAAS;AAAA;AAAA,EAEnC,MAAA,EAAQ;AACV,CAAC;AAOM,IAAM,sBAAsBA,KAAA,CAAE,IAAA,CAAK,CAAC,aAAA,EAAe,QAAA,EAAU,UAAU,CAAC;AAOxE,IAAM,iBAAA,GAAoBA,MAAE,MAAA,CAAO;AAAA;AAAA,EAExC,WAAA,EAAaA,MAAE,MAAA,EAAO,CAAE,KAAI,CAAE,QAAA,EAAS,CAAE,OAAA,CAAQ,CAAC,CAAA;AAAA;AAAA,EAElD,YAAA,EAAcA,MAAE,MAAA,EAAO,CAAE,KAAI,CAAE,QAAA,EAAS,CAAE,OAAA,CAAQ,GAAG,CAAA;AAAA;AAAA,EAErD,QAAA,EAAUA,MAAE,MAAA,EAAO,CAAE,KAAI,CAAE,QAAA,GAAW,QAAA,EAAS;AAAA;AAAA,EAE/C,aAAA,EAAe,mBAAA,CAAoB,OAAA,CAAQ,aAAa,CAAA;AAAA;AAAA,EAExD,YAAYA,KAAA,CAAE,MAAA,GAAS,QAAA,EAAS,CAAE,QAAQ,CAAG,CAAA;AAAA;AAAA,EAE7C,MAAA,EAAQA,KAAA,CAAE,OAAA,EAAQ,CAAE,QAAQ,KAAK,CAAA;AAAA;AAAA,EAEjC,WAAA,EAAa,eAAe,QAAA,EAAS;AAAA;AAAA,EAErC,OAAA,EAAS,eAAe,QAAA,EAAS;AAAA;AAAA,EAEjC,MAAA,EAAQ;AACV,CAAC;AAOM,IAAM,4BAA4BA,KAAA,CAAE,IAAA,CAAK,CAAC,QAAA,EAAU,MAAA,EAAQ,WAAW,CAAC;AAOxE,IAAM,0BAAA,GAA6BA,MAAE,MAAA,CAAO;AAAA,EACjD,UAAUA,KAAA,CAAE,MAAA,EAAO,CAAE,GAAA,GAAM,WAAA,EAAY;AAAA,EACvC,gBAAgBA,KAAA,CAAE,MAAA,EAAO,CAAE,GAAA,GAAM,WAAA,EAAY;AAAA,EAC7C,eAAeA,KAAA,CAAE,MAAA,EAAO,CAAE,GAAA,GAAM,WAAA,EAAY;AAAA,EAC5C,sBAAsBA,KAAA,CAAE,MAAA,EAAO,CAAE,GAAA,GAAM,WAAA,EAAY;AAAA,EACnD,qBAAqBA,KAAA,CAAE,MAAA,EAAO,CAAE,GAAA,GAAM,WAAA;AACxC,CAAC;AAOM,IAAM,0BAAA,GAA6BA,MAAE,MAAA,CAAO;AAAA;AAAA,EAEjD,WAAA,EAAaA,MAAE,MAAA,EAAO,CAAE,KAAI,CAAE,QAAA,EAAS,CAAE,OAAA,CAAQ,CAAC,CAAA;AAAA;AAAA,EAElD,OAAA,EAASA,MAAE,MAAA,EAAO,CAAE,KAAI,CAAE,QAAA,EAAS,CAAE,OAAA,CAAQ,GAAK,CAAA;AAAA;AAAA,EAElD,mBAAA,EAAqBA,MAAE,MAAA,EAAO,CAAE,KAAI,CAAE,QAAA,EAAS,CAAE,OAAA,CAAQ,CAAC,CAAA;AAAA;AAAA,EAE1D,QAAA,EAAUA,MAAE,MAAA,EAAO,CAAE,KAAI,CAAE,WAAA,EAAY,CAAE,OAAA,CAAQ,CAAC,CAAA;AAAA;AAAA,EAElD,WAAA,EAAa,eAAe,QAAA,EAAS;AAAA;AAAA,EAErC,YAAA,EAAc,eAAe,QAAA,EAAS;AAAA;AAAA,EAEtC,aAAA,EAAe,eAAe,QAAA,EAAS;AAAA;AAAA,EAEvC,MAAA,EAAQ;AACV,CAAC;AAOM,IAAM,qBAAA,GAAwBA,MAAE,MAAA,CAAO;AAAA;AAAA,EAE5C,IAAA,EAAMA,MAAE,MAAA,EAAO,CAAE,KAAI,CAAE,QAAA,EAAS,CAAE,OAAA,CAAQ,GAAG,CAAA;AAAA;AAAA,EAE7C,KAAA,EAAOA,MAAE,MAAA,EAAO,CAAE,KAAI,CAAE,QAAA,GAAW,QAAA,EAAS;AAAA;AAAA,EAE5C,QAAA,EAAUA,MAAE,MAAA,EAAO,CAAE,KAAI,CAAE,QAAA,EAAS,CAAE,OAAA,CAAQ,GAAI,CAAA;AAAA;AAAA,EAElD,OAAA,EAAS,eAAe,QAAA,EAAS;AAAA;AAAA,EAEjC,MAAA,EAAQ;AACV,CAAC;AAOM,IAAM,oBAAA,GAAuBA,MAAE,MAAA,CAAO;AAAA;AAAA,EAE3C,aAAA,EAAeA,MAAE,MAAA,EAAO,CAAE,KAAI,CAAE,QAAA,EAAS,CAAE,OAAA,CAAQ,EAAE,CAAA;AAAA;AAAA,EAErD,QAAA,EAAUA,MAAE,MAAA,EAAO,CAAE,KAAI,CAAE,WAAA,EAAY,CAAE,OAAA,CAAQ,CAAC,CAAA;AAAA;AAAA,EAElD,YAAA,EAAcA,MAAE,MAAA,EAAO,CAAE,KAAI,CAAE,QAAA,GAAW,QAAA,EAAS;AAAA;AAAA,EAEnD,UAAA,EAAY,eAAe,QAAA,EAAS;AAAA;AAAA,EAEpC,MAAA,EAAQ;AACV,CAAC;AAOM,IAAM,oBAAA,GAAuBA,MAAE,MAAA,CAAO;AAAA;AAAA,EAE3C,QAAA,EAAU,cAAA;AAAA;AAAA,EAEV,cAAA,EAAgB,eAAe,QAAA,EAAS;AAAA;AAAA,EAExC,UAAA,EAAY,eAAe,QAAA,EAAS;AAAA;AAAA,EAEpC,SAAA,EAAW,eAAe,QAAA,EAAS;AAAA;AAAA,EAEnC,MAAA,EAAQ;AACV,CAAC","file":"index.cjs","sourcesContent":["/*\n Base error class for all Fortify errors.\n /\nexport class FortifyError extends Error {\n constructor(message: string) {\n super(message);\n this.name = 'FortifyError';\n // Maintains proper stack trace for where our error was thrown (only available on V8)\n // Use typeof check to avoid unnecessary-condition lint error\n if (typeof Error.captureStackTrace === 'function') {\n Error.captureStackTrace(this, this.constructor);\n }\n }\n}\n\n/\n Error thrown when circuit breaker is in open state and rejecting requests.\n /\nexport class CircuitOpenError extends FortifyError {\n constructor(message = 'Circuit breaker is open') {\n super(message);\n this.name = 'CircuitOpenError';\n }\n}\n\n/\n Error thrown when rate limit is exceeded.\n /\nexport class RateLimitExceededError extends FortifyError {\n public readonly key: string \| undefined;\n\n constructor(message = 'Rate limit exceeded', key?: string) {\n super(message);\n this.name = 'RateLimitExceededError';\n this.key = key;\n }\n}\n\n/\n Error thrown when bulkhead is at capacity.\n /\nexport class BulkheadFullError extends FortifyError {\n public readonly activeCount: number;\n public readonly queuedCount: number;\n\n constructor(\n message = 'Bulkhead is full',\n activeCount = 0,\n queuedCount = 0\n ) {\n super(message);\n this.name = 'BulkheadFullError';\n this.activeCount = activeCount;\n this.queuedCount = queuedCount;\n }\n}\n\n/\n Error thrown when operation times out.\n /\nexport class TimeoutError extends FortifyError {\n public readonly timeoutMs: number;\n\n constructor(message = 'Operation timed out', timeoutMs = 0) {\n super(message);\n this.name = 'TimeoutError';\n this.timeoutMs = timeoutMs;\n }\n}\n\n/\n Error thrown when maximum retry attempts are reached.\n /\nexport class MaxAttemptsReachedError extends FortifyError {\n public readonly attempts: number;\n public readonly lastError: Error \| undefined;\n\n constructor(\n message = 'Maximum retry attempts reached',\n attempts = 0,\n lastError?: Error\n ) {\n super(message);\n this.name = 'MaxAttemptsReachedError';\n this.attempts = attempts;\n this.lastError = lastError;\n }\n}\n\n/\n Error thrown when bulkhead is closed and no new operations accepted.\n /\nexport class BulkheadClosedError extends FortifyError {\n constructor(message = 'Bulkhead is closed') {\n super(message);\n this.name = 'BulkheadClosedError';\n }\n}\n\n/\n Interface for errors that can indicate whether they are retryable.\n /\nexport interface RetryableError {\n retryable: boolean;\n}\n\n/\n Type guard to check if an error implements RetryableError interface.\n /\nexport function isRetryableError(error: unknown): error is Error & RetryableError {\n return (\n error instanceof Error &&\n 'retryable' in error &&\n typeof (error as RetryableError).retryable === 'boolean'\n );\n}\n\n/\n Wrapper class to mark an error as retryable.\n /\nexport class RetryableErrorWrapper extends Error implements RetryableError {\n public readonly retryable: boolean;\n public override readonly cause: Error;\n\n constructor(error: Error, retryable: boolean) {\n super(error.message, { cause: error });\n this.name = 'RetryableErrorWrapper';\n this.retryable = retryable;\n this.cause = error;\n if (error.stack) {\n this.stack = error.stack;\n }\n }\n}\n\n/\n Wrap an error as retryable.\n /\nexport function asRetryable(error: Error, retryable = true): RetryableErrorWrapper {\n return new RetryableErrorWrapper(error, retryable);\n}\n\n/\n Wrap an error as non-retryable.\n /\nexport function asNonRetryable(error: Error): RetryableErrorWrapper {\n return new RetryableErrorWrapper(error, false);\n}\n\n/\n Check if an error is retryable.\n * Returns true if the error implements RetryableError and retryable is true.\n * Returns undefined if the error doesn't implement RetryableError (let caller decide).\n /\nexport function isRetryable(error: unknown): boolean \| undefined {\n if (isRetryableError(error)) {\n return error.retryable;\n }\n return undefined;\n}\n","/\n Represents an async operation that can be executed with cancellation support.\n * The signal parameter allows the operation to be cancelled via AbortController.\n \n @template T - The return type of the operation\n /\nexport type Operation<T> = (signal: AbortSignal) => Promise<T>;\n\n/\n Callback for state changes in stateful patterns (e.g., circuit breaker).\n \n @template S - The state type\n /\nexport type StateChangeCallback<S> = (from: S, to: S) => void;\n\n/\n Callback for error events.\n /\nexport type ErrorCallback = (error: Error) => void;\n\n/\n Simple void callback.\n /\nexport type VoidCallback = () => void;\n\n/\n Callback for retry events.\n /\nexport type RetryCallback = (attempt: number, error: Error) => void;\n\n/\n Callback for rate limit events.\n /\nexport type RateLimitCallback = (key: string) => void;\n\n/\n Logger interface for structured logging across all patterns.\n * Compatible with pino, winston, console, and custom implementations.\n /\nexport interface FortifyLogger {\n debug(msg: string, context?: Record<string, unknown>): void;\n info(msg: string, context?: Record<string, unknown>): void;\n warn(msg: string, context?: Record<string, unknown>): void;\n error(msg: string, context?: Record<string, unknown>): void;\n}\n\n/\n No-operation logger that discards all log messages.\n * Useful for testing or when logging is not needed.\n /\nexport const noopLogger: FortifyLogger = {\n debug: () => undefined,\n info: () => undefined,\n warn: () => undefined,\n error: () => undefined,\n};\n\n/\n Console-based logger implementation.\n * Browser-friendly and works in all environments.\n /\nexport const consoleLogger: FortifyLogger = {\n debug: (msg, context) => {\n if (context) {\n console.debug(`[fortify] ${msg}`, context);\n } else {\n console.debug(`[fortify] ${msg}`);\n }\n },\n info: (msg, context) => {\n if (context) {\n console.info(`[fortify] ${msg}`, context);\n } else {\n console.info(`[fortify] ${msg}`);\n }\n },\n warn: (msg, context) => {\n if (context) {\n console.warn(`[fortify] ${msg}`, context);\n } else {\n console.warn(`[fortify] ${msg}`);\n }\n },\n error: (msg, context) => {\n if (context) {\n console.error(`[fortify] ${msg}`, context);\n } else {\n console.error(`[fortify] ${msg}`);\n }\n },\n};\n\n/\n Generic pattern interface that all resilience patterns implement.\n \n @template T - The return type of the operation\n /\nexport interface Pattern<T> {\n /\n Execute an operation with the pattern's resilience logic.\n \n @param operation - The async operation to execute\n * @param signal - Optional AbortSignal for cancellation\n * @returns Promise resolving to the operation result\n /\n execute(operation: Operation<T>, signal?: AbortSignal): Promise<T>;\n}\n\n/\n Interface for patterns that support closing/cleanup.\n /\nexport interface Closeable {\n /\n Close the pattern and release resources.\n * May wait for in-flight operations to complete.\n /\n close(): Promise<void>;\n}\n\n/\n Interface for patterns that support resetting state.\n /\nexport interface Resettable {\n /\n Reset the pattern to its initial state.\n /\n reset(): void;\n}\n","import { TimeoutError } from './errors.js';\n\n/\n Sleep for a specified duration with optional cancellation support.\n \n @param ms - Duration in milliseconds\n * @param signal - Optional AbortSignal for cancellation\n * @returns Promise that resolves after the delay or rejects if cancelled\n /\nexport function sleep(ms: number, signal?: AbortSignal): Promise<void> {\n return new Promise((resolve, reject) => {\n if (signal?.aborted) {\n reject(ensureError(signal.reason));\n return;\n }\n\n const timeoutId = setTimeout(resolve, ms);\n\n signal?.addEventListener(\n 'abort',\n () => {\n clearTimeout(timeoutId);\n reject(ensureError(signal.reason));\n },\n { once: true }\n );\n });\n}\n\n/\n Ensure a value is an Error instance.\n * @param reason - The reason to convert to an Error\n * @returns An Error instance\n /\nfunction ensureError(reason: unknown): Error {\n if (reason instanceof Error) {\n return reason;\n }\n if (typeof reason === 'string') {\n return new Error(reason);\n }\n if (reason !== undefined && reason !== null) {\n // Handle objects and other types safely\n try {\n return new Error(JSON.stringify(reason));\n } catch {\n return new Error('Unknown error');\n }\n }\n return new DOMException('Aborted', 'AbortError');\n}\n\n/\n Wrap a promise with a timeout.\n \n @template T - The promise return type\n * @param promise - The promise to wrap\n * @param ms - Timeout duration in milliseconds\n * @param signal - Optional external AbortSignal for cancellation\n * @returns Promise that resolves with the result or rejects with TimeoutError\n /\nexport async function withTimeout<T>(\n promise: Promise<T>,\n ms: number,\n signal?: AbortSignal\n): Promise<T> {\n // Check if already aborted\n if (signal?.aborted) {\n throw ensureError(signal.reason);\n }\n\n let timeoutId: ReturnType<typeof setTimeout> \| undefined;\n\n const timeoutPromise = new Promise<never>((_, reject) => {\n timeoutId = setTimeout(() => {\n reject(new TimeoutError(`Operation timed out after ${String(ms)}ms`, ms));\n }, ms);\n });\n\n // Handle external signal\n const abortPromise = signal\n ? new Promise<never>((_, reject) => {\n signal.addEventListener(\n 'abort',\n () => reject(ensureError(signal.reason)),\n { once: true }\n );\n })\n : null;\n\n try {\n const racers: Promise<T>[] = [promise, timeoutPromise];\n if (abortPromise) {\n racers.push(abortPromise);\n }\n return await Promise.race(racers);\n } finally {\n if (timeoutId !== undefined) {\n clearTimeout(timeoutId);\n }\n }\n}\n\n/\n Execute an operation with a timeout, passing the combined signal to the operation.\n \n @template T - The operation return type\n * @param operation - The operation to execute\n * @param ms - Timeout duration in milliseconds\n * @param signal - Optional external AbortSignal for cancellation\n * @returns Promise that resolves with the result or rejects with TimeoutError\n /\nexport async function executeWithTimeout<T>(\n operation: (signal: AbortSignal) => Promise<T>,\n ms: number,\n signal?: AbortSignal\n): Promise<T> {\n const controller = new AbortController();\n\n // Combine signals\n const combinedSignal = combineSignals(signal, controller.signal);\n\n const timeoutId = setTimeout(() => {\n controller.abort(new TimeoutError(`Operation timed out after ${String(ms)}ms`, ms));\n }, ms);\n\n try {\n return await operation(combinedSignal);\n } finally {\n clearTimeout(timeoutId);\n }\n}\n\n/\n Combine multiple AbortSignals into one.\n * Returns a signal that aborts when any of the input signals abort.\n \n Uses AbortSignal.any() when available (Node 20+, modern browsers).\n * Falls back to a manual implementation that properly cleans up event listeners.\n \n @param signals - AbortSignals to combine (undefined values are filtered out)\n * @returns Combined AbortSignal\n /\nexport function combineSignals(...signals: (AbortSignal \| undefined)[]): AbortSignal {\n const validSignals = signals.filter((s): s is AbortSignal => s !== undefined);\n\n if (validSignals.length === 0) {\n return new AbortController().signal;\n }\n\n const firstSignal = validSignals[0];\n if (validSignals.length === 1 && firstSignal) {\n return firstSignal;\n }\n\n // Use AbortSignal.any if available (Node 20+, modern browsers)\n if ('any' in AbortSignal) {\n return AbortSignal.any(validSignals);\n }\n\n // Fallback: create a new controller and link it to all signals\n // Track listeners so we can clean them up to prevent memory leaks\n const controller = new AbortController();\n const listeners: { signal: AbortSignal; listener: () => void }[] = [];\n\n // Cleanup function to remove all listeners\n const cleanup = () => {\n for (const { signal, listener } of listeners) {\n signal.removeEventListener('abort', listener);\n }\n listeners.length = 0;\n };\n\n for (const signal of validSignals) {\n if (signal.aborted) {\n controller.abort(signal.reason);\n return controller.signal;\n }\n\n const listener = () => {\n cleanup(); // Clean up all listeners when any signal aborts\n controller.abort(signal.reason);\n };\n\n listeners.push({ signal, listener });\n signal.addEventListener('abort', listener, { once: true });\n }\n\n return controller.signal;\n}\n\n/\n Check if an error is an abort error (from AbortController).\n \n @param error - Error to check\n * @returns True if the error is an AbortError\n /\nexport function isAbortError(error: unknown): boolean {\n return (\n error instanceof DOMException &&\n error.name === 'AbortError'\n );\n}\n\n/\n Safely execute a callback, catching and logging any errors.\n * Used for user-provided callbacks to prevent them from breaking the pattern.\n \n @param callback - Callback to execute\n * @param onError - Optional error handler\n /\nexport function safeCallback<T extends (...args: unknown[]) => unknown>(\n callback: T \| undefined,\n onError?: (error: Error) => void\n): T \| undefined {\n if (!callback) return undefined;\n\n return ((...args: Parameters<T>): ReturnType<T> \| undefined => {\n try {\n return callback(...args) as ReturnType<T>;\n } catch (error) {\n if (onError && error instanceof Error) {\n onError(error);\n }\n return undefined;\n }\n }) as T;\n}\n\n/\n Calculate jittered delay.\n * Adds 0-10% random variance to prevent thundering herd.\n \n @param delay - Base delay in milliseconds\n * @returns Jittered delay\n /\nexport function addJitter(delay: number): number {\n const jitterFactor = 1 + Math.random() 0.1; // 0-10% jitter\n return Math.floor(delay * jitterFactor);\n}\n\n/*\n Clamp a number between min and max values.\n \n @param value - Value to clamp\n * @param min - Minimum value\n * @param max - Maximum value\n * @returns Clamped value\n /\nexport function clamp(value: number, min: number, max: number): number {\n return Math.min(Math.max(value, min), max);\n}\n\n/\n Get current timestamp in milliseconds.\n * Uses performance.now() if available for higher precision.\n \n @returns Current timestamp in milliseconds\n /\nexport function now(): number {\n if (typeof performance !== 'undefined' && typeof performance.now === 'function') {\n return performance.now();\n }\n return Date.now();\n}\n","import { z } from 'zod';\n\n/\n Schema for a function type (Zod 4 compatible).\n * Uses z.function() which validates that the value is a function.\n /\nconst functionSchema = z.function();\n\n/\n Base schema for logger configuration.\n * Validates that the logger has the required methods.\n /\nexport const loggerSchema = z.object({\n debug: functionSchema,\n info: functionSchema,\n warn: functionSchema,\n error: functionSchema,\n}).optional();\n\n/\n Schema for timeout configuration.\n /\nexport const timeoutConfigSchema = z.object({\n /* Default timeout in milliseconds (default: 30000) /\n defaultTimeout: z.number().int().positive().default(30000),\n /* Callback when timeout occurs /\n onTimeout: functionSchema.optional(),\n /* Logger instance /\n logger: loggerSchema,\n});\n\nexport type TimeoutConfig = z.infer<typeof timeoutConfigSchema>;\n\n/\n Schema for retry backoff policy.\n /\nexport const backoffPolicySchema = z.enum(['exponential', 'linear', 'constant']);\n\nexport type BackoffPolicy = z.infer<typeof backoffPolicySchema>;\n\n/\n Schema for retry configuration.\n /\nexport const retryConfigSchema = z.object({\n /* Maximum number of attempts including the first (default: 3) /\n maxAttempts: z.number().int().positive().default(3),\n /* Initial delay before first retry in milliseconds (default: 100) /\n initialDelay: z.number().int().positive().default(100),\n /* Maximum delay between retries in milliseconds /\n maxDelay: z.number().int().positive().optional(),\n /* Backoff strategy (default: 'exponential') /\n backoffPolicy: backoffPolicySchema.default('exponential'),\n /* Multiplier for exponential backoff (default: 2.0) /\n multiplier: z.number().positive().default(2.0),\n /* Add random jitter to delays (default: false) /\n jitter: z.boolean().default(false),\n /* Custom function to determine if error is retryable /\n isRetryable: functionSchema.optional(),\n /* Callback on each retry attempt /\n onRetry: functionSchema.optional(),\n /* Logger instance /\n logger: loggerSchema,\n});\n\nexport type RetryConfig = z.infer<typeof retryConfigSchema>;\n\n/\n Schema for circuit breaker state.\n /\nexport const circuitBreakerStateSchema = z.enum(['closed', 'open', 'half-open']);\n\nexport type CircuitBreakerState = z.infer<typeof circuitBreakerStateSchema>;\n\n/\n Schema for circuit breaker counts/metrics.\n /\nexport const circuitBreakerCountsSchema = z.object({\n requests: z.number().int().nonnegative(),\n totalSuccesses: z.number().int().nonnegative(),\n totalFailures: z.number().int().nonnegative(),\n consecutiveSuccesses: z.number().int().nonnegative(),\n consecutiveFailures: z.number().int().nonnegative(),\n});\n\nexport type CircuitBreakerCounts = z.infer<typeof circuitBreakerCountsSchema>;\n\n/\n Schema for circuit breaker configuration.\n /\nexport const circuitBreakerConfigSchema = z.object({\n /* Maximum consecutive failures before opening (default: 5) /\n maxFailures: z.number().int().positive().default(5),\n /* Duration in open state before transitioning to half-open in milliseconds (default: 60000) /\n timeout: z.number().int().positive().default(60000),\n /* Maximum requests allowed in half-open state (default: 1) /\n halfOpenMaxRequests: z.number().int().positive().default(1),\n /* Period to clear counts when closed, 0 means never (default: 0) /\n interval: z.number().int().nonnegative().default(0),\n /* Custom function to determine when to trip the breaker /\n readyToTrip: functionSchema.optional(),\n /* Custom function to determine if result is successful /\n isSuccessful: functionSchema.optional(),\n /* Callback on state change /\n onStateChange: functionSchema.optional(),\n /* Logger instance /\n logger: loggerSchema,\n});\n\nexport type CircuitBreakerConfig = z.infer<typeof circuitBreakerConfigSchema>;\n\n/\n Schema for rate limiter configuration.\n /\nexport const rateLimitConfigSchema = z.object({\n /* Number of tokens added per interval (default: 100) /\n rate: z.number().int().positive().default(100),\n /* Maximum bucket capacity (defaults to rate) /\n burst: z.number().int().positive().optional(),\n /* Interval for token refill in milliseconds (default: 1000) /\n interval: z.number().int().positive().default(1000),\n /* Callback when rate limit is hit /\n onLimit: functionSchema.optional(),\n /* Logger instance /\n logger: loggerSchema,\n});\n\nexport type RateLimitConfig = z.infer<typeof rateLimitConfigSchema>;\n\n/\n Schema for bulkhead configuration.\n /\nexport const bulkheadConfigSchema = z.object({\n /* Maximum concurrent executions (default: 10) /\n maxConcurrent: z.number().int().positive().default(10),\n /* Maximum queued requests, 0 means no queueing (default: 0) /\n maxQueue: z.number().int().nonnegative().default(0),\n /* Maximum time to wait in queue in milliseconds /\n queueTimeout: z.number().int().positive().optional(),\n /* Callback when request is rejected /\n onRejected: functionSchema.optional(),\n /* Logger instance /\n logger: loggerSchema,\n});\n\nexport type BulkheadConfig = z.infer<typeof bulkheadConfigSchema>;\n\n/\n Schema for fallback configuration.\n /\nexport const fallbackConfigSchema = z.object({\n /* Fallback function to execute when primary fails /\n fallback: functionSchema,\n /* Custom function to determine if fallback should be used /\n shouldFallback: functionSchema.optional(),\n /* Callback when fallback is triggered /\n onFallback: functionSchema.optional(),\n /* Callback when primary succeeds /\n onSuccess: functionSchema.optional(),\n /* Logger instance */\n logger: loggerSchema,\n});\n\nexport type FallbackConfig = z.infer<typeof fallbackConfigSchema>;\n"]}
		{"version":3,"sources":["../src/errors.ts","../src/types.ts","../src/utils.ts","../src/schemas.ts"],"names":["z"],"mappings":";;;;;;;;;AAGO,IAAM,YAAA,GAAN,cAA2B,KAAA,CAAM;AAAA,EACtC,YAAY,OAAA,EAAiB;AAC3B,IAAA,KAAA,CAAM,OAAO,CAAA;AACb,IAAA,IAAA,CAAK,IAAA,GAAO,cAAA;AAGZ,IAAA,IAAI,OAAO,KAAA,CAAM,iBAAA,KAAsB,UAAA,EAAY;AACjD,MAAA,KAAA,CAAM,iBAAA,CAAkB,IAAA,EAAM,IAAA,CAAK,WAAW,CAAA;AAAA,IAChD;AAAA,EACF;AACF;AAKO,IAAM,gBAAA,GAAN,cAA+B,YAAA,CAAa;AAAA,EACjD,WAAA,CAAY,UAAU,yBAAA,EAA2B;AAC/C,IAAA,KAAA,CAAM,OAAO,CAAA;AACb,IAAA,IAAA,CAAK,IAAA,GAAO,kBAAA;AAAA,EACd;AACF;AAKO,IAAM,sBAAA,GAAN,cAAqC,YAAA,CAAa;AAAA,EAGvD,WAAA,CAAY,OAAA,GAAU,qBAAA,EAAuB,GAAA,EAAc;AACzD,IAAA,KAAA,CAAM,OAAO,CAAA;AAHf,IAAA,aAAA,CAAA,IAAA,EAAgB,KAAA,CAAA;AAId,IAAA,IAAA,CAAK,IAAA,GAAO,wBAAA;AACZ,IAAA,IAAA,CAAK,GAAA,GAAM,GAAA;AAAA,EACb;AACF;AAKO,IAAM,iBAAA,GAAN,cAAgC,YAAA,CAAa;AAAA,EAIlD,YACE,OAAA,GAAU,kBAAA,EACV,WAAA,GAAc,CAAA,EACd,cAAc,CAAA,EACd;AACA,IAAA,KAAA,CAAM,OAAO,CAAA;AARf,IAAA,aAAA,CAAA,IAAA,EAAgB,aAAA,CAAA;AAChB,IAAA,aAAA,CAAA,IAAA,EAAgB,aAAA,CAAA;AAQd,IAAA,IAAA,CAAK,IAAA,GAAO,mBAAA;AACZ,IAAA,IAAA,CAAK,WAAA,GAAc,WAAA;AACnB,IAAA,IAAA,CAAK,WAAA,GAAc,WAAA;AAAA,EACrB;AACF;AAKO,IAAM,YAAA,GAAN,cAA2B,YAAA,CAAa;AAAA,EAG7C,WAAA,CAAY,OAAA,GAAU,qBAAA,EAAuB,SAAA,GAAY,CAAA,EAAG;AAC1D,IAAA,KAAA,CAAM,OAAO,CAAA;AAHf,IAAA,aAAA,CAAA,IAAA,EAAgB,WAAA,CAAA;AAId,IAAA,IAAA,CAAK,IAAA,GAAO,cAAA;AACZ,IAAA,IAAA,CAAK,SAAA,GAAY,SAAA;AAAA,EACnB;AACF;AAKO,IAAM,uBAAA,GAAN,cAAsC,YAAA,CAAa;AAAA,EAIxD,WAAA,CACE,OAAA,GAAU,gCAAA,EACV,QAAA,GAAW,GACX,SAAA,EACA;AACA,IAAA,KAAA,CAAM,OAAO,CAAA;AARf,IAAA,aAAA,CAAA,IAAA,EAAgB,UAAA,CAAA;AAChB,IAAA,aAAA,CAAA,IAAA,EAAgB,WAAA,CAAA;AAQd,IAAA,IAAA,CAAK,IAAA,GAAO,yBAAA;AACZ,IAAA,IAAA,CAAK,QAAA,GAAW,QAAA;AAChB,IAAA,IAAA,CAAK,SAAA,GAAY,SAAA;AAAA,EACnB;AACF;AAKO,IAAM,mBAAA,GAAN,cAAkC,YAAA,CAAa;AAAA,EACpD,WAAA,CAAY,UAAU,oBAAA,EAAsB;AAC1C,IAAA,KAAA,CAAM,OAAO,CAAA;AACb,IAAA,IAAA,CAAK,IAAA,GAAO,qBAAA;AAAA,EACd;AACF;AAYO,SAAS,iBAAiB,KAAA,EAAiD;AAChF,EAAA,OACE,iBAAiB,KAAA,IACjB,WAAA,IAAe,KAAA,IACf,OAAQ,MAAyB,SAAA,KAAc,SAAA;AAEnD;AAKO,IAAM,qBAAA,GAAN,cAAoC,KAAA,CAAgC;AAAA,EAIzE,WAAA,CAAY,OAAc,SAAA,EAAoB;AAC5C,IAAA,KAAA,CAAM,KAAA,CAAM,OAAA,EAAS,EAAE,KAAA,EAAO,OAAO,CAAA;AAJvC,IAAA,aAAA,CAAA,IAAA,EAAgB,WAAA,CAAA;AAChB,IAAA,aAAA,CAAA,IAAA,EAAyB,OAAA,CAAA;AAIvB,IAAA,IAAA,CAAK,IAAA,GAAO,uBAAA;AACZ,IAAA,IAAA,CAAK,SAAA,GAAY,SAAA;AACjB,IAAA,IAAA,CAAK,KAAA,GAAQ,KAAA;AACb,IAAA,IAAI,MAAM,KAAA,EAAO;AACf,MAAA,IAAA,CAAK,QAAQ,KAAA,CAAM,KAAA;AAAA,IACrB;AAAA,EACF;AACF;AAKO,SAAS,WAAA,CAAY,KAAA,EAAc,SAAA,GAAY,IAAA,EAA6B;AACjF,EAAA,OAAO,IAAI,qBAAA,CAAsB,KAAA,EAAO,SAAS,CAAA;AACnD;AAKO,SAAS,eAAe,KAAA,EAAqC;AAClE,EAAA,OAAO,IAAI,qBAAA,CAAsB,KAAA,EAAO,KAAK,CAAA;AAC/C;AAOO,SAAS,YAAY,KAAA,EAAqC;AAC/D,EAAA,IAAI,gBAAA,CAAiB,KAAK,CAAA,EAAG;AAC3B,IAAA,OAAO,KAAA,CAAM,SAAA;AAAA,EACf;AACA,EAAA,OAAO,MAAA;AACT;;;AC7GO,IAAM,UAAA,GAA4B;AAAA,EACvC,OAAO,MAAM,MAAA;AAAA,EACb,MAAM,MAAM,MAAA;AAAA,EACZ,MAAM,MAAM,MAAA;AAAA,EACZ,OAAO,MAAM;AACf;AAMO,IAAM,aAAA,GAA+B;AAAA,EAC1C,KAAA,EAAO,CAAC,GAAA,EAAK,OAAA,KAAY;AACvB,IAAA,IAAI,OAAA,EAAS;AACX,MAAA,OAAA,CAAQ,KAAA,CAAM,CAAA,UAAA,EAAa,GAAG,CAAA,CAAA,EAAI,OAAO,CAAA;AAAA,IAC3C,CAAA,MAAO;AACL,MAAA,OAAA,CAAQ,KAAA,CAAM,CAAA,UAAA,EAAa,GAAG,CAAA,CAAE,CAAA;AAAA,IAClC;AAAA,EACF,CAAA;AAAA,EACA,IAAA,EAAM,CAAC,GAAA,EAAK,OAAA,KAAY;AACtB,IAAA,IAAI,OAAA,EAAS;AACX,MAAA,OAAA,CAAQ,IAAA,CAAK,CAAA,UAAA,EAAa,GAAG,CAAA,CAAA,EAAI,OAAO,CAAA;AAAA,IAC1C,CAAA,MAAO;AACL,MAAA,OAAA,CAAQ,IAAA,CAAK,CAAA,UAAA,EAAa,GAAG,CAAA,CAAE,CAAA;AAAA,IACjC;AAAA,EACF,CAAA;AAAA,EACA,IAAA,EAAM,CAAC,GAAA,EAAK,OAAA,KAAY;AACtB,IAAA,IAAI,OAAA,EAAS;AACX,MAAA,OAAA,CAAQ,IAAA,CAAK,CAAA,UAAA,EAAa,GAAG,CAAA,CAAA,EAAI,OAAO,CAAA;AAAA,IAC1C,CAAA,MAAO;AACL,MAAA,OAAA,CAAQ,IAAA,CAAK,CAAA,UAAA,EAAa,GAAG,CAAA,CAAE,CAAA;AAAA,IACjC;AAAA,EACF,CAAA;AAAA,EACA,KAAA,EAAO,CAAC,GAAA,EAAK,OAAA,KAAY;AACvB,IAAA,IAAI,OAAA,EAAS;AACX,MAAA,OAAA,CAAQ,KAAA,CAAM,CAAA,UAAA,EAAa,GAAG,CAAA,CAAA,EAAI,OAAO,CAAA;AAAA,IAC3C,CAAA,MAAO;AACL,MAAA,OAAA,CAAQ,KAAA,CAAM,CAAA,UAAA,EAAa,GAAG,CAAA,CAAE,CAAA;AAAA,IAClC;AAAA,EACF;AACF;;;ACjFO,SAAS,KAAA,CAAM,IAAY,MAAA,EAAqC;AACrE,EAAA,OAAO,IAAI,OAAA,CAAQ,CAAC,OAAA,EAAS,MAAA,KAAW;AACtC,IAAA,IAAI,QAAQ,OAAA,EAAS;AACnB,MAAA,MAAA,CAAO,WAAA,CAAY,MAAA,CAAO,MAAM,CAAC,CAAA;AACjC,MAAA;AAAA,IACF;AAEA,IAAA,MAAM,SAAA,GAAY,UAAA,CAAW,OAAA,EAAS,EAAE,CAAA;AAExC,IAAA,MAAA,EAAQ,gBAAA;AAAA,MACN,OAAA;AAAA,MACA,MAAM;AACJ,QAAA,YAAA,CAAa,SAAS,CAAA;AACtB,QAAA,MAAA,CAAO,WAAA,CAAY,MAAA,CAAO,MAAM,CAAC,CAAA;AAAA,MACnC,CAAA;AAAA,MACA,EAAE,MAAM,IAAA;AAAK,KACf;AAAA,EACF,CAAC,CAAA;AACH;AAOA,SAAS,YAAY,MAAA,EAAwB;AAC3C,EAAA,IAAI,kBAAkB,KAAA,EAAO;AAC3B,IAAA,OAAO,MAAA;AAAA,EACT;AACA,EAAA,IAAI,OAAO,WAAW,QAAA,EAAU;AAC9B,IAAA,OAAO,IAAI,MAAM,MAAM,CAAA;AAAA,EACzB;AACA,EAAA,IAAI,MAAA,KAAW,MAAA,IAAa,MAAA,KAAW,IAAA,EAAM;AAE3C,IAAA,IAAI;AACF,MAAA,OAAO,IAAI,KAAA,CAAM,IAAA,CAAK,SAAA,CAAU,MAAM,CAAC,CAAA;AAAA,IACzC,CAAA,CAAA,MAAQ;AACN,MAAA,OAAO,IAAI,MAAM,eAAe,CAAA;AAAA,IAClC;AAAA,EACF;AACA,EAAA,OAAO,IAAI,YAAA,CAAa,SAAA,EAAW,YAAY,CAAA;AACjD;AAWA,eAAsB,WAAA,CACpB,OAAA,EACA,EAAA,EACA,MAAA,EACY;AAEZ,EAAA,IAAI,QAAQ,OAAA,EAAS;AACnB,IAAA,MAAM,WAAA,CAAY,OAAO,MAAM,CAAA;AAAA,EACjC;AAEA,EAAA,IAAI,SAAA;AAEJ,EAAA,MAAM,cAAA,GAAiB,IAAI,OAAA,CAAe,CAAC,GAAG,MAAA,KAAW;AACvD,IAAA,SAAA,GAAY,WAAW,MAAM;AAC3B,MAAA,MAAA,CAAO,IAAI,aAAa,CAAA,0BAAA,EAA6B,MAAA,CAAO,EAAE,CAAC,CAAA,EAAA,CAAA,EAAM,EAAE,CAAC,CAAA;AAAA,IAC1E,GAAG,EAAE,CAAA;AAAA,EACP,CAAC,CAAA;AAGD,EAAA,MAAM,eAAe,MAAA,GACjB,IAAI,OAAA,CAAe,CAAC,GAAG,MAAA,KAAW;AAChC,IAAA,MAAA,CAAO,gBAAA;AAAA,MACL,OAAA;AAAA,MACA,MAAM,MAAA,CAAO,WAAA,CAAY,MAAA,CAAO,MAAM,CAAC,CAAA;AAAA,MACvC,EAAE,MAAM,IAAA;AAAK,KACf;AAAA,EACF,CAAC,CAAA,GACD,IAAA;AAEJ,EAAA,IAAI;AACF,IAAA,MAAM,MAAA,GAAuB,CAAC,OAAA,EAAS,cAAc,CAAA;AACrD,IAAA,IAAI,YAAA,EAAc;AAChB,MAAA,MAAA,CAAO,KAAK,YAAY,CAAA;AAAA,IAC1B;AACA,IAAA,OAAO,MAAM,OAAA,CAAQ,IAAA,CAAK,MAAM,CAAA;AAAA,EAClC,CAAA,SAAE;AACA,IAAA,IAAI,cAAc,MAAA,EAAW;AAC3B,MAAA,YAAA,CAAa,SAAS,CAAA;AAAA,IACxB;AAAA,EACF;AACF;AAWA,eAAsB,kBAAA,CACpB,SAAA,EACA,EAAA,EACA,MAAA,EACY;AACZ,EAAA,MAAM,UAAA,GAAa,IAAI,eAAA,EAAgB;AAGvC,EAAA,MAAM,cAAA,GAAiB,cAAA,CAAe,MAAA,EAAQ,UAAA,CAAW,MAAM,CAAA;AAE/D,EAAA,MAAM,SAAA,GAAY,WAAW,MAAM;AACjC,IAAA,UAAA,CAAW,KAAA,CAAM,IAAI,YAAA,CAAa,CAAA,0BAAA,EAA6B,OAAO,EAAE,CAAC,CAAA,EAAA,CAAA,EAAM,EAAE,CAAC,CAAA;AAAA,EACpF,GAAG,EAAE,CAAA;AAEL,EAAA,IAAI;AACF,IAAA,OAAO,MAAM,UAAU,cAAc,CAAA;AAAA,EACvC,CAAA,SAAE;AACA,IAAA,YAAA,CAAa,SAAS,CAAA;AAAA,EACxB;AACF;AAYO,SAAS,kBAAkB,OAAA,EAAmD;AACnF,EAAA,MAAM,eAAe,OAAA,CAAQ,MAAA,CAAO,CAAC,CAAA,KAAwB,MAAM,MAAS,CAAA;AAE5E,EAAA,IAAI,YAAA,CAAa,WAAW,CAAA,EAAG;AAC7B,IAAA,OAAO,IAAI,iBAAgB,CAAE,MAAA;AAAA,EAC/B;AAEA,EAAA,MAAM,WAAA,GAAc,aAAa,CAAC,CAAA;AAClC,EAAA,IAAI,YAAA,CAAa,MAAA,KAAW,CAAA,IAAK,WAAA,EAAa;AAC5C,IAAA,OAAO,WAAA;AAAA,EACT;AAGA,EAAA,IAAI,SAAS,WAAA,EAAa;AACxB,IAAA,OAAO,WAAA,CAAY,IAAI,YAAY,CAAA;AAAA,EACrC;AAIA,EAAA,MAAM,UAAA,GAAa,IAAI,eAAA,EAAgB;AACvC,EAAA,MAAM,YAA6D,EAAC;AAGpE,EAAA,MAAM,UAAU,MAAM;AACpB,IAAA,KAAA,MAAW,EAAE,MAAA,EAAQ,QAAA,EAAS,IAAK,SAAA,EAAW;AAC5C,MAAA,MAAA,CAAO,mBAAA,CAAoB,SAAS,QAAQ,CAAA;AAAA,IAC9C;AACA,IAAA,SAAA,CAAU,MAAA,GAAS,CAAA;AAAA,EACrB,CAAA;AAEA,EAAA,KAAA,MAAW,UAAU,YAAA,EAAc;AACjC,IAAA,IAAI,OAAO,OAAA,EAAS;AAClB,MAAA,UAAA,CAAW,KAAA,CAAM,OAAO,MAAM,CAAA;AAC9B,MAAA,OAAO,UAAA,CAAW,MAAA;AAAA,IACpB;AAEA,IAAA,MAAM,WAAW,MAAM;AACrB,MAAA,OAAA,EAAQ;AACR,MAAA,UAAA,CAAW,KAAA,CAAM,OAAO,MAAM,CAAA;AAAA,IAChC,CAAA;AAEA,IAAA,SAAA,CAAU,IAAA,CAAK,EAAE,MAAA,EAAQ,QAAA,EAAU,CAAA;AACnC,IAAA,MAAA,CAAO,iBAAiB,OAAA,EAAS,QAAA,EAAU,EAAE,IAAA,EAAM,MAAM,CAAA;AAAA,EAC3D;AAEA,EAAA,OAAO,UAAA,CAAW,MAAA;AACpB;AAQO,SAAS,aAAa,KAAA,EAAyB;AACpD,EAAA,OACE,KAAA,YAAiB,YAAA,IACjB,KAAA,CAAM,IAAA,KAAS,YAAA;AAEnB;AASO,SAAS,eAAe,MAAA,EAAuC;AACpE,EAAA,IAAI,QAAQ,OAAA,EAAS;AACnB,IAAA,MAAM,MAAA,CAAO,MAAA,IAAU,IAAI,YAAA,CAAa,WAAW,YAAY,CAAA;AAAA,EACjE;AACF;AASO,SAAS,YAAA,CACd,UACA,OAAA,EACe;AACf,EAAA,IAAI,CAAC,UAAU,OAAO,MAAA;AAEtB,EAAA,QAAQ,IAAI,IAAA,KAAmD;AAC7D,IAAA,IAAI;AACF,MAAA,OAAO,QAAA,CAAS,GAAG,IAAI,CAAA;AAAA,IACzB,SAAS,KAAA,EAAO;AACd,MAAA,IAAI,OAAA,IAAW,iBAAiB,KAAA,EAAO;AACrC,QAAA,OAAA,CAAQ,KAAK,CAAA;AAAA,MACf;AACA,MAAA,OAAO,MAAA;AAAA,IACT;AAAA,EACF,CAAA;AACF;AASO,SAAS,UAAU,KAAA,EAAuB;AAC/C,EAAA,MAAM,YAAA,GAAe,CAAA,GAAI,IAAA,CAAK,MAAA,EAAO,GAAI,GAAA;AACzC,EAAA,OAAO,IAAA,CAAK,KAAA,CAAM,KAAA,GAAQ,YAAY,CAAA;AACxC;AAUO,SAAS,KAAA,CAAM,KAAA,EAAe,GAAA,EAAa,GAAA,EAAqB;AACrE,EAAA,OAAO,KAAK,GAAA,CAAI,IAAA,CAAK,IAAI,KAAA,EAAO,GAAG,GAAG,GAAG,CAAA;AAC3C;AAQO,SAAS,GAAA,GAAc;AAC5B,EAAA,IAAI,OAAO,WAAA,KAAgB,WAAA,IAAe,OAAO,WAAA,CAAY,QAAQ,UAAA,EAAY;AAC/E,IAAA,OAAO,YAAY,GAAA,EAAI;AAAA,EACzB;AACA,EAAA,OAAO,KAAK,GAAA,EAAI;AAClB;AC/QA,IAAM,cAAA,GAAiBA,MAAE,QAAA,EAAS;AAM3B,IAAM,YAAA,GAAeA,MAAE,MAAA,CAAO;AAAA,EACnC,KAAA,EAAO,cAAA;AAAA,EACP,IAAA,EAAM,cAAA;AAAA,EACN,IAAA,EAAM,cAAA;AAAA,EACN,KAAA,EAAO;AACT,CAAC,EAAE,QAAA;AAKI,IAAM,mBAAA,GAAsBA,MAAE,MAAA,CAAO;AAAA;AAAA,EAE1C,cAAA,EAAgBA,MAAE,MAAA,EAAO,CAAE,KAAI,CAAE,QAAA,EAAS,CAAE,OAAA,CAAQ,GAAK,CAAA;AAAA;AAAA,EAEzD,SAAA,EAAW,eAAe,QAAA,EAAS;AAAA;AAAA,EAEnC,MAAA,EAAQ;AACV,CAAC;AAOM,IAAM,sBAAsBA,KAAA,CAAE,IAAA,CAAK,CAAC,aAAA,EAAe,QAAA,EAAU,UAAU,CAAC;AAOxE,IAAM,iBAAA,GAAoBA,MAAE,MAAA,CAAO;AAAA;AAAA,EAExC,WAAA,EAAaA,MAAE,MAAA,EAAO,CAAE,KAAI,CAAE,QAAA,EAAS,CAAE,OAAA,CAAQ,CAAC,CAAA;AAAA;AAAA,EAElD,YAAA,EAAcA,MAAE,MAAA,EAAO,CAAE,KAAI,CAAE,QAAA,EAAS,CAAE,OAAA,CAAQ,GAAG,CAAA;AAAA;AAAA,EAErD,QAAA,EAAUA,MAAE,MAAA,EAAO,CAAE,KAAI,CAAE,QAAA,GAAW,QAAA,EAAS;AAAA;AAAA,EAE/C,aAAA,EAAe,mBAAA,CAAoB,OAAA,CAAQ,aAAa,CAAA;AAAA;AAAA,EAExD,YAAYA,KAAA,CAAE,MAAA,GAAS,QAAA,EAAS,CAAE,QAAQ,CAAG,CAAA;AAAA;AAAA,EAE7C,MAAA,EAAQA,KAAA,CAAE,OAAA,EAAQ,CAAE,QAAQ,KAAK,CAAA;AAAA;AAAA,EAEjC,WAAA,EAAa,eAAe,QAAA,EAAS;AAAA;AAAA,EAErC,OAAA,EAAS,eAAe,QAAA,EAAS;AAAA;AAAA,EAEjC,MAAA,EAAQ;AACV,CAAC;AAOM,IAAM,4BAA4BA,KAAA,CAAE,IAAA,CAAK,CAAC,QAAA,EAAU,MAAA,EAAQ,WAAW,CAAC;AAOxE,IAAM,0BAAA,GAA6BA,MAAE,MAAA,CAAO;AAAA,EACjD,UAAUA,KAAA,CAAE,MAAA,EAAO,CAAE,GAAA,GAAM,WAAA,EAAY;AAAA,EACvC,gBAAgBA,KAAA,CAAE,MAAA,EAAO,CAAE,GAAA,GAAM,WAAA,EAAY;AAAA,EAC7C,eAAeA,KAAA,CAAE,MAAA,EAAO,CAAE,GAAA,GAAM,WAAA,EAAY;AAAA,EAC5C,sBAAsBA,KAAA,CAAE,MAAA,EAAO,CAAE,GAAA,GAAM,WAAA,EAAY;AAAA,EACnD,qBAAqBA,KAAA,CAAE,MAAA,EAAO,CAAE,GAAA,GAAM,WAAA;AACxC,CAAC;AAOM,IAAM,0BAAA,GAA6BA,MAAE,MAAA,CAAO;AAAA;AAAA,EAEjD,WAAA,EAAaA,MAAE,MAAA,EAAO,CAAE,KAAI,CAAE,QAAA,EAAS,CAAE,OAAA,CAAQ,CAAC,CAAA;AAAA;AAAA,EAElD,OAAA,EAASA,MAAE,MAAA,EAAO,CAAE,KAAI,CAAE,QAAA,EAAS,CAAE,OAAA,CAAQ,GAAK,CAAA;AAAA;AAAA,EAElD,mBAAA,EAAqBA,MAAE,MAAA,EAAO,CAAE,KAAI,CAAE,QAAA,EAAS,CAAE,OAAA,CAAQ,CAAC,CAAA;AAAA;AAAA,EAE1D,QAAA,EAAUA,MAAE,MAAA,EAAO,CAAE,KAAI,CAAE,WAAA,EAAY,CAAE,OAAA,CAAQ,CAAC,CAAA;AAAA;AAAA,EAElD,WAAA,EAAa,eAAe,QAAA,EAAS;AAAA;AAAA,EAErC,YAAA,EAAc,eAAe,QAAA,EAAS;AAAA;AAAA,EAEtC,aAAA,EAAe,eAAe,QAAA,EAAS;AAAA;AAAA,EAEvC,MAAA,EAAQ;AACV,CAAC;AAOM,IAAM,qBAAA,GAAwBA,MAAE,MAAA,CAAO;AAAA;AAAA,EAE5C,IAAA,EAAMA,MAAE,MAAA,EAAO,CAAE,KAAI,CAAE,QAAA,EAAS,CAAE,OAAA,CAAQ,GAAG,CAAA;AAAA;AAAA,EAE7C,KAAA,EAAOA,MAAE,MAAA,EAAO,CAAE,KAAI,CAAE,QAAA,GAAW,QAAA,EAAS;AAAA;AAAA,EAE5C,QAAA,EAAUA,MAAE,MAAA,EAAO,CAAE,KAAI,CAAE,QAAA,EAAS,CAAE,OAAA,CAAQ,GAAI,CAAA;AAAA;AAAA,EAElD,OAAA,EAAS,eAAe,QAAA,EAAS;AAAA;AAAA,EAEjC,MAAA,EAAQ;AACV,CAAC;AAOM,IAAM,oBAAA,GAAuBA,MAAE,MAAA,CAAO;AAAA;AAAA,EAE3C,aAAA,EAAeA,MAAE,MAAA,EAAO,CAAE,KAAI,CAAE,QAAA,EAAS,CAAE,OAAA,CAAQ,EAAE,CAAA;AAAA;AAAA,EAErD,QAAA,EAAUA,MAAE,MAAA,EAAO,CAAE,KAAI,CAAE,WAAA,EAAY,CAAE,OAAA,CAAQ,CAAC,CAAA;AAAA;AAAA,EAElD,YAAA,EAAcA,MAAE,MAAA,EAAO,CAAE,KAAI,CAAE,QAAA,GAAW,QAAA,EAAS;AAAA;AAAA,EAEnD,UAAA,EAAY,eAAe,QAAA,EAAS;AAAA;AAAA,EAEpC,MAAA,EAAQ;AACV,CAAC;AAOM,IAAM,oBAAA,GAAuBA,MAAE,MAAA,CAAO;AAAA;AAAA,EAE3C,QAAA,EAAU,cAAA;AAAA;AAAA,EAEV,cAAA,EAAgB,eAAe,QAAA,EAAS;AAAA;AAAA,EAExC,UAAA,EAAY,eAAe,QAAA,EAAS;AAAA;AAAA,EAEpC,SAAA,EAAW,eAAe,QAAA,EAAS;AAAA;AAAA,EAEnC,MAAA,EAAQ;AACV,CAAC","file":"index.cjs","sourcesContent":["/*\n Base error class for all Fortify errors.\n /\nexport class FortifyError extends Error {\n constructor(message: string) {\n super(message);\n this.name = 'FortifyError';\n // Maintains proper stack trace for where our error was thrown (only available on V8)\n // Use typeof check to avoid unnecessary-condition lint error\n if (typeof Error.captureStackTrace === 'function') {\n Error.captureStackTrace(this, this.constructor);\n }\n }\n}\n\n/\n Error thrown when circuit breaker is in open state and rejecting requests.\n /\nexport class CircuitOpenError extends FortifyError {\n constructor(message = 'Circuit breaker is open') {\n super(message);\n this.name = 'CircuitOpenError';\n }\n}\n\n/\n Error thrown when rate limit is exceeded.\n /\nexport class RateLimitExceededError extends FortifyError {\n public readonly key: string \| undefined;\n\n constructor(message = 'Rate limit exceeded', key?: string) {\n super(message);\n this.name = 'RateLimitExceededError';\n this.key = key;\n }\n}\n\n/\n Error thrown when bulkhead is at capacity.\n /\nexport class BulkheadFullError extends FortifyError {\n public readonly activeCount: number;\n public readonly queuedCount: number;\n\n constructor(\n message = 'Bulkhead is full',\n activeCount = 0,\n queuedCount = 0\n ) {\n super(message);\n this.name = 'BulkheadFullError';\n this.activeCount = activeCount;\n this.queuedCount = queuedCount;\n }\n}\n\n/\n Error thrown when operation times out.\n /\nexport class TimeoutError extends FortifyError {\n public readonly timeoutMs: number;\n\n constructor(message = 'Operation timed out', timeoutMs = 0) {\n super(message);\n this.name = 'TimeoutError';\n this.timeoutMs = timeoutMs;\n }\n}\n\n/\n Error thrown when maximum retry attempts are reached.\n /\nexport class MaxAttemptsReachedError extends FortifyError {\n public readonly attempts: number;\n public readonly lastError: Error \| undefined;\n\n constructor(\n message = 'Maximum retry attempts reached',\n attempts = 0,\n lastError?: Error\n ) {\n super(message);\n this.name = 'MaxAttemptsReachedError';\n this.attempts = attempts;\n this.lastError = lastError;\n }\n}\n\n/\n Error thrown when bulkhead is closed and no new operations accepted.\n /\nexport class BulkheadClosedError extends FortifyError {\n constructor(message = 'Bulkhead is closed') {\n super(message);\n this.name = 'BulkheadClosedError';\n }\n}\n\n/\n Interface for errors that can indicate whether they are retryable.\n /\nexport interface RetryableError {\n retryable: boolean;\n}\n\n/\n Type guard to check if an error implements RetryableError interface.\n /\nexport function isRetryableError(error: unknown): error is Error & RetryableError {\n return (\n error instanceof Error &&\n 'retryable' in error &&\n typeof (error as RetryableError).retryable === 'boolean'\n );\n}\n\n/\n Wrapper class to mark an error as retryable.\n /\nexport class RetryableErrorWrapper extends Error implements RetryableError {\n public readonly retryable: boolean;\n public override readonly cause: Error;\n\n constructor(error: Error, retryable: boolean) {\n super(error.message, { cause: error });\n this.name = 'RetryableErrorWrapper';\n this.retryable = retryable;\n this.cause = error;\n if (error.stack) {\n this.stack = error.stack;\n }\n }\n}\n\n/\n Wrap an error as retryable.\n /\nexport function asRetryable(error: Error, retryable = true): RetryableErrorWrapper {\n return new RetryableErrorWrapper(error, retryable);\n}\n\n/\n Wrap an error as non-retryable.\n /\nexport function asNonRetryable(error: Error): RetryableErrorWrapper {\n return new RetryableErrorWrapper(error, false);\n}\n\n/\n Check if an error is retryable.\n * Returns true if the error implements RetryableError and retryable is true.\n * Returns undefined if the error doesn't implement RetryableError (let caller decide).\n /\nexport function isRetryable(error: unknown): boolean \| undefined {\n if (isRetryableError(error)) {\n return error.retryable;\n }\n return undefined;\n}\n","/\n Represents an async operation that can be executed with cancellation support.\n * The signal parameter allows the operation to be cancelled via AbortController.\n \n @template T - The return type of the operation\n /\nexport type Operation<T> = (signal: AbortSignal) => Promise<T>;\n\n/\n Callback for state changes in stateful patterns (e.g., circuit breaker).\n \n @template S - The state type\n /\nexport type StateChangeCallback<S> = (from: S, to: S) => void;\n\n/\n Callback for error events.\n /\nexport type ErrorCallback = (error: Error) => void;\n\n/\n Simple void callback.\n /\nexport type VoidCallback = () => void;\n\n/\n Callback for retry events.\n /\nexport type RetryCallback = (attempt: number, error: Error) => void;\n\n/\n Callback for rate limit events.\n /\nexport type RateLimitCallback = (key: string) => void;\n\n/\n Logger interface for structured logging across all patterns.\n * Compatible with pino, winston, console, and custom implementations.\n /\nexport interface FortifyLogger {\n debug(msg: string, context?: Record<string, unknown>): void;\n info(msg: string, context?: Record<string, unknown>): void;\n warn(msg: string, context?: Record<string, unknown>): void;\n error(msg: string, context?: Record<string, unknown>): void;\n}\n\n/\n No-operation logger that discards all log messages.\n * Useful for testing or when logging is not needed.\n /\nexport const noopLogger: FortifyLogger = {\n debug: () => undefined,\n info: () => undefined,\n warn: () => undefined,\n error: () => undefined,\n};\n\n/\n Console-based logger implementation.\n * Browser-friendly and works in all environments.\n /\nexport const consoleLogger: FortifyLogger = {\n debug: (msg, context) => {\n if (context) {\n console.debug(`[fortify] ${msg}`, context);\n } else {\n console.debug(`[fortify] ${msg}`);\n }\n },\n info: (msg, context) => {\n if (context) {\n console.info(`[fortify] ${msg}`, context);\n } else {\n console.info(`[fortify] ${msg}`);\n }\n },\n warn: (msg, context) => {\n if (context) {\n console.warn(`[fortify] ${msg}`, context);\n } else {\n console.warn(`[fortify] ${msg}`);\n }\n },\n error: (msg, context) => {\n if (context) {\n console.error(`[fortify] ${msg}`, context);\n } else {\n console.error(`[fortify] ${msg}`);\n }\n },\n};\n\n/\n Generic pattern interface that all resilience patterns implement.\n \n @template T - The return type of the operation\n /\nexport interface Pattern<T> {\n /\n Execute an operation with the pattern's resilience logic.\n \n @param operation - The async operation to execute\n * @param signal - Optional AbortSignal for cancellation\n * @returns Promise resolving to the operation result\n /\n execute(operation: Operation<T>, signal?: AbortSignal): Promise<T>;\n}\n\n/\n Interface for patterns that support closing/cleanup.\n /\nexport interface Closeable {\n /\n Close the pattern and release resources.\n * May wait for in-flight operations to complete.\n /\n close(): Promise<void>;\n}\n\n/\n Interface for patterns that support resetting state.\n /\nexport interface Resettable {\n /\n Reset the pattern to its initial state.\n /\n reset(): void;\n}\n","import { TimeoutError } from './errors.js';\n\n/\n Sleep for a specified duration with optional cancellation support.\n \n @param ms - Duration in milliseconds\n * @param signal - Optional AbortSignal for cancellation\n * @returns Promise that resolves after the delay or rejects if cancelled\n /\nexport function sleep(ms: number, signal?: AbortSignal): Promise<void> {\n return new Promise((resolve, reject) => {\n if (signal?.aborted) {\n reject(ensureError(signal.reason));\n return;\n }\n\n const timeoutId = setTimeout(resolve, ms);\n\n signal?.addEventListener(\n 'abort',\n () => {\n clearTimeout(timeoutId);\n reject(ensureError(signal.reason));\n },\n { once: true }\n );\n });\n}\n\n/\n Ensure a value is an Error instance.\n * @param reason - The reason to convert to an Error\n * @returns An Error instance\n /\nfunction ensureError(reason: unknown): Error {\n if (reason instanceof Error) {\n return reason;\n }\n if (typeof reason === 'string') {\n return new Error(reason);\n }\n if (reason !== undefined && reason !== null) {\n // Handle objects and other types safely\n try {\n return new Error(JSON.stringify(reason));\n } catch {\n return new Error('Unknown error');\n }\n }\n return new DOMException('Aborted', 'AbortError');\n}\n\n/\n Wrap a promise with a timeout.\n \n @template T - The promise return type\n * @param promise - The promise to wrap\n * @param ms - Timeout duration in milliseconds\n * @param signal - Optional external AbortSignal for cancellation\n * @returns Promise that resolves with the result or rejects with TimeoutError\n /\nexport async function withTimeout<T>(\n promise: Promise<T>,\n ms: number,\n signal?: AbortSignal\n): Promise<T> {\n // Check if already aborted\n if (signal?.aborted) {\n throw ensureError(signal.reason);\n }\n\n let timeoutId: ReturnType<typeof setTimeout> \| undefined;\n\n const timeoutPromise = new Promise<never>((_, reject) => {\n timeoutId = setTimeout(() => {\n reject(new TimeoutError(`Operation timed out after ${String(ms)}ms`, ms));\n }, ms);\n });\n\n // Handle external signal\n const abortPromise = signal\n ? new Promise<never>((_, reject) => {\n signal.addEventListener(\n 'abort',\n () => reject(ensureError(signal.reason)),\n { once: true }\n );\n })\n : null;\n\n try {\n const racers: Promise<T>[] = [promise, timeoutPromise];\n if (abortPromise) {\n racers.push(abortPromise);\n }\n return await Promise.race(racers);\n } finally {\n if (timeoutId !== undefined) {\n clearTimeout(timeoutId);\n }\n }\n}\n\n/\n Execute an operation with a timeout, passing the combined signal to the operation.\n \n @template T - The operation return type\n * @param operation - The operation to execute\n * @param ms - Timeout duration in milliseconds\n * @param signal - Optional external AbortSignal for cancellation\n * @returns Promise that resolves with the result or rejects with TimeoutError\n /\nexport async function executeWithTimeout<T>(\n operation: (signal: AbortSignal) => Promise<T>,\n ms: number,\n signal?: AbortSignal\n): Promise<T> {\n const controller = new AbortController();\n\n // Combine signals\n const combinedSignal = combineSignals(signal, controller.signal);\n\n const timeoutId = setTimeout(() => {\n controller.abort(new TimeoutError(`Operation timed out after ${String(ms)}ms`, ms));\n }, ms);\n\n try {\n return await operation(combinedSignal);\n } finally {\n clearTimeout(timeoutId);\n }\n}\n\n/\n Combine multiple AbortSignals into one.\n * Returns a signal that aborts when any of the input signals abort.\n \n Uses AbortSignal.any() when available (Node 20+, modern browsers).\n * Falls back to a manual implementation that properly cleans up event listeners.\n \n @param signals - AbortSignals to combine (undefined values are filtered out)\n * @returns Combined AbortSignal\n /\nexport function combineSignals(...signals: (AbortSignal \| undefined)[]): AbortSignal {\n const validSignals = signals.filter((s): s is AbortSignal => s !== undefined);\n\n if (validSignals.length === 0) {\n return new AbortController().signal;\n }\n\n const firstSignal = validSignals[0];\n if (validSignals.length === 1 && firstSignal) {\n return firstSignal;\n }\n\n // Use AbortSignal.any if available (Node 20+, modern browsers)\n if ('any' in AbortSignal) {\n return AbortSignal.any(validSignals);\n }\n\n // Fallback: create a new controller and link it to all signals\n // Track listeners so we can clean them up to prevent memory leaks\n const controller = new AbortController();\n const listeners: { signal: AbortSignal; listener: () => void }[] = [];\n\n // Cleanup function to remove all listeners\n const cleanup = () => {\n for (const { signal, listener } of listeners) {\n signal.removeEventListener('abort', listener);\n }\n listeners.length = 0;\n };\n\n for (const signal of validSignals) {\n if (signal.aborted) {\n controller.abort(signal.reason);\n return controller.signal;\n }\n\n const listener = () => {\n cleanup(); // Clean up all listeners when any signal aborts\n controller.abort(signal.reason);\n };\n\n listeners.push({ signal, listener });\n signal.addEventListener('abort', listener, { once: true });\n }\n\n return controller.signal;\n}\n\n/\n Check if an error is an abort error (from AbortController).\n \n @param error - Error to check\n * @returns True if the error is an AbortError\n /\nexport function isAbortError(error: unknown): boolean {\n return (\n error instanceof DOMException &&\n error.name === 'AbortError'\n );\n}\n\n/\n Throw if the given signal is aborted.\n * Useful for checking signal state early in operations to avoid unnecessary work.\n \n @param signal - AbortSignal to check\n * @throws {DOMException} If signal is aborted (AbortError)\n /\nexport function throwIfAborted(signal: AbortSignal \| undefined): void {\n if (signal?.aborted) {\n throw signal.reason ?? new DOMException('Aborted', 'AbortError');\n }\n}\n\n/\n Safely execute a callback, catching and logging any errors.\n * Used for user-provided callbacks to prevent them from breaking the pattern.\n \n @param callback - Callback to execute\n * @param onError - Optional error handler\n /\nexport function safeCallback<T extends (...args: unknown[]) => unknown>(\n callback: T \| undefined,\n onError?: (error: Error) => void\n): T \| undefined {\n if (!callback) return undefined;\n\n return ((...args: Parameters<T>): ReturnType<T> \| undefined => {\n try {\n return callback(...args) as ReturnType<T>;\n } catch (error) {\n if (onError && error instanceof Error) {\n onError(error);\n }\n return undefined;\n }\n }) as T;\n}\n\n/\n Calculate jittered delay.\n * Adds 0-10% random variance to prevent thundering herd.\n \n @param delay - Base delay in milliseconds\n * @returns Jittered delay\n /\nexport function addJitter(delay: number): number {\n const jitterFactor = 1 + Math.random() 0.1; // 0-10% jitter\n return Math.floor(delay * jitterFactor);\n}\n\n/*\n Clamp a number between min and max values.\n \n @param value - Value to clamp\n * @param min - Minimum value\n * @param max - Maximum value\n * @returns Clamped value\n /\nexport function clamp(value: number, min: number, max: number): number {\n return Math.min(Math.max(value, min), max);\n}\n\n/\n Get current timestamp in milliseconds.\n * Uses performance.now() if available for higher precision.\n \n @returns Current timestamp in milliseconds\n /\nexport function now(): number {\n if (typeof performance !== 'undefined' && typeof performance.now === 'function') {\n return performance.now();\n }\n return Date.now();\n}\n","import { z } from 'zod';\n\n/\n Schema for a function type (Zod 4 compatible).\n * Uses z.function() which validates that the value is a function.\n /\nconst functionSchema = z.function();\n\n/\n Base schema for logger configuration.\n * Validates that the logger has the required methods.\n /\nexport const loggerSchema = z.object({\n debug: functionSchema,\n info: functionSchema,\n warn: functionSchema,\n error: functionSchema,\n}).optional();\n\n/\n Schema for timeout configuration.\n /\nexport const timeoutConfigSchema = z.object({\n /* Default timeout in milliseconds (default: 30000) /\n defaultTimeout: z.number().int().positive().default(30000),\n /* Callback when timeout occurs /\n onTimeout: functionSchema.optional(),\n /* Logger instance /\n logger: loggerSchema,\n});\n\nexport type TimeoutConfig = z.infer<typeof timeoutConfigSchema>;\n\n/\n Schema for retry backoff policy.\n /\nexport const backoffPolicySchema = z.enum(['exponential', 'linear', 'constant']);\n\nexport type BackoffPolicy = z.infer<typeof backoffPolicySchema>;\n\n/\n Schema for retry configuration.\n /\nexport const retryConfigSchema = z.object({\n /* Maximum number of attempts including the first (default: 3) /\n maxAttempts: z.number().int().positive().default(3),\n /* Initial delay before first retry in milliseconds (default: 100) /\n initialDelay: z.number().int().positive().default(100),\n /* Maximum delay between retries in milliseconds /\n maxDelay: z.number().int().positive().optional(),\n /* Backoff strategy (default: 'exponential') /\n backoffPolicy: backoffPolicySchema.default('exponential'),\n /* Multiplier for exponential backoff (default: 2.0) /\n multiplier: z.number().positive().default(2.0),\n /* Add random jitter to delays (default: false) /\n jitter: z.boolean().default(false),\n /* Custom function to determine if error is retryable /\n isRetryable: functionSchema.optional(),\n /* Callback on each retry attempt /\n onRetry: functionSchema.optional(),\n /* Logger instance /\n logger: loggerSchema,\n});\n\nexport type RetryConfig = z.infer<typeof retryConfigSchema>;\n\n/\n Schema for circuit breaker state.\n /\nexport const circuitBreakerStateSchema = z.enum(['closed', 'open', 'half-open']);\n\nexport type CircuitBreakerState = z.infer<typeof circuitBreakerStateSchema>;\n\n/\n Schema for circuit breaker counts/metrics.\n /\nexport const circuitBreakerCountsSchema = z.object({\n requests: z.number().int().nonnegative(),\n totalSuccesses: z.number().int().nonnegative(),\n totalFailures: z.number().int().nonnegative(),\n consecutiveSuccesses: z.number().int().nonnegative(),\n consecutiveFailures: z.number().int().nonnegative(),\n});\n\nexport type CircuitBreakerCounts = z.infer<typeof circuitBreakerCountsSchema>;\n\n/\n Schema for circuit breaker configuration.\n /\nexport const circuitBreakerConfigSchema = z.object({\n /* Maximum consecutive failures before opening (default: 5) /\n maxFailures: z.number().int().positive().default(5),\n /* Duration in open state before transitioning to half-open in milliseconds (default: 60000) /\n timeout: z.number().int().positive().default(60000),\n /* Maximum requests allowed in half-open state (default: 1) /\n halfOpenMaxRequests: z.number().int().positive().default(1),\n /* Period to clear counts when closed, 0 means never (default: 0) /\n interval: z.number().int().nonnegative().default(0),\n /* Custom function to determine when to trip the breaker /\n readyToTrip: functionSchema.optional(),\n /* Custom function to determine if result is successful /\n isSuccessful: functionSchema.optional(),\n /* Callback on state change /\n onStateChange: functionSchema.optional(),\n /* Logger instance /\n logger: loggerSchema,\n});\n\nexport type CircuitBreakerConfig = z.infer<typeof circuitBreakerConfigSchema>;\n\n/\n Schema for rate limiter configuration.\n /\nexport const rateLimitConfigSchema = z.object({\n /* Number of tokens added per interval (default: 100) /\n rate: z.number().int().positive().default(100),\n /* Maximum bucket capacity (defaults to rate) /\n burst: z.number().int().positive().optional(),\n /* Interval for token refill in milliseconds (default: 1000) /\n interval: z.number().int().positive().default(1000),\n /* Callback when rate limit is hit /\n onLimit: functionSchema.optional(),\n /* Logger instance /\n logger: loggerSchema,\n});\n\nexport type RateLimitConfig = z.infer<typeof rateLimitConfigSchema>;\n\n/\n Schema for bulkhead configuration.\n /\nexport const bulkheadConfigSchema = z.object({\n /* Maximum concurrent executions (default: 10) /\n maxConcurrent: z.number().int().positive().default(10),\n /* Maximum queued requests, 0 means no queueing (default: 0) /\n maxQueue: z.number().int().nonnegative().default(0),\n /* Maximum time to wait in queue in milliseconds /\n queueTimeout: z.number().int().positive().optional(),\n /* Callback when request is rejected /\n onRejected: functionSchema.optional(),\n /* Logger instance /\n logger: loggerSchema,\n});\n\nexport type BulkheadConfig = z.infer<typeof bulkheadConfigSchema>;\n\n/\n Schema for fallback configuration.\n /\nexport const fallbackConfigSchema = z.object({\n /* Fallback function to execute when primary fails /\n fallback: functionSchema,\n /* Custom function to determine if fallback should be used /\n shouldFallback: functionSchema.optional(),\n /* Callback when fallback is triggered /\n onFallback: functionSchema.optional(),\n /* Callback when primary succeeds /\n onSuccess: functionSchema.optional(),\n /* Logger instance */\n logger: loggerSchema,\n});\n\nexport type FallbackConfig = z.infer<typeof fallbackConfigSchema>;\n"]}

+9

-1

dist/index.d.cts

		@@ -215,2 +215,10 @@ import { z } from 'zod';
		/**
		* Throw if the given signal is aborted.
		* Useful for checking signal state early in operations to avoid unnecessary work.
		*
		* @param signal - AbortSignal to check
		* @throws {DOMException} If signal is aborted (AbortError)
		*/
		declare function throwIfAborted(signal: AbortSignal \| undefined): void;
		/**
		* Safely execute a callback, catching and logging any errors.
		@@ -393,2 +401,2 @@ * Used for user-provided callbacks to prevent them from breaking the pattern.

		export { type BackoffPolicy, BulkheadClosedError, type BulkheadConfig, BulkheadFullError, type CircuitBreakerConfig, type CircuitBreakerCounts, type CircuitBreakerState, CircuitOpenError, type Closeable, type ErrorCallback, type FallbackConfig, FortifyError, type FortifyLogger, MaxAttemptsReachedError, type Operation, type Pattern, type RateLimitCallback, type RateLimitConfig, RateLimitExceededError, type Resettable, type RetryCallback, type RetryConfig, type RetryableError, RetryableErrorWrapper, type StateChangeCallback, type TimeoutConfig, TimeoutError, type VoidCallback, addJitter, asNonRetryable, asRetryable, backoffPolicySchema, bulkheadConfigSchema, circuitBreakerConfigSchema, circuitBreakerCountsSchema, circuitBreakerStateSchema, clamp, combineSignals, consoleLogger, executeWithTimeout, fallbackConfigSchema, isAbortError, isRetryable, isRetryableError, loggerSchema, noopLogger, now, rateLimitConfigSchema, retryConfigSchema, safeCallback, sleep, timeoutConfigSchema, withTimeout };
		export { type BackoffPolicy, BulkheadClosedError, type BulkheadConfig, BulkheadFullError, type CircuitBreakerConfig, type CircuitBreakerCounts, type CircuitBreakerState, CircuitOpenError, type Closeable, type ErrorCallback, type FallbackConfig, FortifyError, type FortifyLogger, MaxAttemptsReachedError, type Operation, type Pattern, type RateLimitCallback, type RateLimitConfig, RateLimitExceededError, type Resettable, type RetryCallback, type RetryConfig, type RetryableError, RetryableErrorWrapper, type StateChangeCallback, type TimeoutConfig, TimeoutError, type VoidCallback, addJitter, asNonRetryable, asRetryable, backoffPolicySchema, bulkheadConfigSchema, circuitBreakerConfigSchema, circuitBreakerCountsSchema, circuitBreakerStateSchema, clamp, combineSignals, consoleLogger, executeWithTimeout, fallbackConfigSchema, isAbortError, isRetryable, isRetryableError, loggerSchema, noopLogger, now, rateLimitConfigSchema, retryConfigSchema, safeCallback, sleep, throwIfAborted, timeoutConfigSchema, withTimeout };

+9

-1

dist/index.d.ts

		@@ -215,2 +215,10 @@ import { z } from 'zod';
		/**
		* Throw if the given signal is aborted.
		* Useful for checking signal state early in operations to avoid unnecessary work.
		*
		* @param signal - AbortSignal to check
		* @throws {DOMException} If signal is aborted (AbortError)
		*/
		declare function throwIfAborted(signal: AbortSignal \| undefined): void;
		/**
		* Safely execute a callback, catching and logging any errors.
		@@ -393,2 +401,2 @@ * Used for user-provided callbacks to prevent them from breaking the pattern.

		export { type BackoffPolicy, BulkheadClosedError, type BulkheadConfig, BulkheadFullError, type CircuitBreakerConfig, type CircuitBreakerCounts, type CircuitBreakerState, CircuitOpenError, type Closeable, type ErrorCallback, type FallbackConfig, FortifyError, type FortifyLogger, MaxAttemptsReachedError, type Operation, type Pattern, type RateLimitCallback, type RateLimitConfig, RateLimitExceededError, type Resettable, type RetryCallback, type RetryConfig, type RetryableError, RetryableErrorWrapper, type StateChangeCallback, type TimeoutConfig, TimeoutError, type VoidCallback, addJitter, asNonRetryable, asRetryable, backoffPolicySchema, bulkheadConfigSchema, circuitBreakerConfigSchema, circuitBreakerCountsSchema, circuitBreakerStateSchema, clamp, combineSignals, consoleLogger, executeWithTimeout, fallbackConfigSchema, isAbortError, isRetryable, isRetryableError, loggerSchema, noopLogger, now, rateLimitConfigSchema, retryConfigSchema, safeCallback, sleep, timeoutConfigSchema, withTimeout };
		export { type BackoffPolicy, BulkheadClosedError, type BulkheadConfig, BulkheadFullError, type CircuitBreakerConfig, type CircuitBreakerCounts, type CircuitBreakerState, CircuitOpenError, type Closeable, type ErrorCallback, type FallbackConfig, FortifyError, type FortifyLogger, MaxAttemptsReachedError, type Operation, type Pattern, type RateLimitCallback, type RateLimitConfig, RateLimitExceededError, type Resettable, type RetryCallback, type RetryConfig, type RetryableError, RetryableErrorWrapper, type StateChangeCallback, type TimeoutConfig, TimeoutError, type VoidCallback, addJitter, asNonRetryable, asRetryable, backoffPolicySchema, bulkheadConfigSchema, circuitBreakerConfigSchema, circuitBreakerCountsSchema, circuitBreakerStateSchema, clamp, combineSignals, consoleLogger, executeWithTimeout, fallbackConfigSchema, isAbortError, isRetryable, isRetryableError, loggerSchema, noopLogger, now, rateLimitConfigSchema, retryConfigSchema, safeCallback, sleep, throwIfAborted, timeoutConfigSchema, withTimeout };

+6

-1

dist/index.js

		@@ -244,2 +244,7 @@ import { z } from 'zod';
		}
		function throwIfAborted(signal) {
		if (signal?.aborted) {
		throw signal.reason ?? new DOMException("Aborted", "AbortError");
		}
		}
		function safeCallback(callback, onError) {
		@@ -370,4 +375,4 @@ if (!callback) return void 0;

		export { BulkheadClosedError, BulkheadFullError, CircuitOpenError, FortifyError, MaxAttemptsReachedError, RateLimitExceededError, RetryableErrorWrapper, TimeoutError, addJitter, asNonRetryable, asRetryable, backoffPolicySchema, bulkheadConfigSchema, circuitBreakerConfigSchema, circuitBreakerCountsSchema, circuitBreakerStateSchema, clamp, combineSignals, consoleLogger, executeWithTimeout, fallbackConfigSchema, isAbortError, isRetryable, isRetryableError, loggerSchema, noopLogger, now, rateLimitConfigSchema, retryConfigSchema, safeCallback, sleep, timeoutConfigSchema, withTimeout };
		export { BulkheadClosedError, BulkheadFullError, CircuitOpenError, FortifyError, MaxAttemptsReachedError, RateLimitExceededError, RetryableErrorWrapper, TimeoutError, addJitter, asNonRetryable, asRetryable, backoffPolicySchema, bulkheadConfigSchema, circuitBreakerConfigSchema, circuitBreakerCountsSchema, circuitBreakerStateSchema, clamp, combineSignals, consoleLogger, executeWithTimeout, fallbackConfigSchema, isAbortError, isRetryable, isRetryableError, loggerSchema, noopLogger, now, rateLimitConfigSchema, retryConfigSchema, safeCallback, sleep, throwIfAborted, timeoutConfigSchema, withTimeout };
		//# sourceMappingURL=index.js.map
		//# sourceMappingURL=index.js.map

+1

-1

dist/index.js.map

		@@ -1,1 +0,1 @@
		{"version":3,"sources":["../src/errors.ts","../src/types.ts","../src/utils.ts","../src/schemas.ts"],"names":[],"mappings":";;;;;;;AAGO,IAAM,YAAA,GAAN,cAA2B,KAAA,CAAM;AAAA,EACtC,YAAY,OAAA,EAAiB;AAC3B,IAAA,KAAA,CAAM,OAAO,CAAA;AACb,IAAA,IAAA,CAAK,IAAA,GAAO,cAAA;AAGZ,IAAA,IAAI,OAAO,KAAA,CAAM,iBAAA,KAAsB,UAAA,EAAY;AACjD,MAAA,KAAA,CAAM,iBAAA,CAAkB,IAAA,EAAM,IAAA,CAAK,WAAW,CAAA;AAAA,IAChD;AAAA,EACF;AACF;AAKO,IAAM,gBAAA,GAAN,cAA+B,YAAA,CAAa;AAAA,EACjD,WAAA,CAAY,UAAU,yBAAA,EAA2B;AAC/C,IAAA,KAAA,CAAM,OAAO,CAAA;AACb,IAAA,IAAA,CAAK,IAAA,GAAO,kBAAA;AAAA,EACd;AACF;AAKO,IAAM,sBAAA,GAAN,cAAqC,YAAA,CAAa;AAAA,EAGvD,WAAA,CAAY,OAAA,GAAU,qBAAA,EAAuB,GAAA,EAAc;AACzD,IAAA,KAAA,CAAM,OAAO,CAAA;AAHf,IAAA,aAAA,CAAA,IAAA,EAAgB,KAAA,CAAA;AAId,IAAA,IAAA,CAAK,IAAA,GAAO,wBAAA;AACZ,IAAA,IAAA,CAAK,GAAA,GAAM,GAAA;AAAA,EACb;AACF;AAKO,IAAM,iBAAA,GAAN,cAAgC,YAAA,CAAa;AAAA,EAIlD,YACE,OAAA,GAAU,kBAAA,EACV,WAAA,GAAc,CAAA,EACd,cAAc,CAAA,EACd;AACA,IAAA,KAAA,CAAM,OAAO,CAAA;AARf,IAAA,aAAA,CAAA,IAAA,EAAgB,aAAA,CAAA;AAChB,IAAA,aAAA,CAAA,IAAA,EAAgB,aAAA,CAAA;AAQd,IAAA,IAAA,CAAK,IAAA,GAAO,mBAAA;AACZ,IAAA,IAAA,CAAK,WAAA,GAAc,WAAA;AACnB,IAAA,IAAA,CAAK,WAAA,GAAc,WAAA;AAAA,EACrB;AACF;AAKO,IAAM,YAAA,GAAN,cAA2B,YAAA,CAAa;AAAA,EAG7C,WAAA,CAAY,OAAA,GAAU,qBAAA,EAAuB,SAAA,GAAY,CAAA,EAAG;AAC1D,IAAA,KAAA,CAAM,OAAO,CAAA;AAHf,IAAA,aAAA,CAAA,IAAA,EAAgB,WAAA,CAAA;AAId,IAAA,IAAA,CAAK,IAAA,GAAO,cAAA;AACZ,IAAA,IAAA,CAAK,SAAA,GAAY,SAAA;AAAA,EACnB;AACF;AAKO,IAAM,uBAAA,GAAN,cAAsC,YAAA,CAAa;AAAA,EAIxD,WAAA,CACE,OAAA,GAAU,gCAAA,EACV,QAAA,GAAW,GACX,SAAA,EACA;AACA,IAAA,KAAA,CAAM,OAAO,CAAA;AARf,IAAA,aAAA,CAAA,IAAA,EAAgB,UAAA,CAAA;AAChB,IAAA,aAAA,CAAA,IAAA,EAAgB,WAAA,CAAA;AAQd,IAAA,IAAA,CAAK,IAAA,GAAO,yBAAA;AACZ,IAAA,IAAA,CAAK,QAAA,GAAW,QAAA;AAChB,IAAA,IAAA,CAAK,SAAA,GAAY,SAAA;AAAA,EACnB;AACF;AAKO,IAAM,mBAAA,GAAN,cAAkC,YAAA,CAAa;AAAA,EACpD,WAAA,CAAY,UAAU,oBAAA,EAAsB;AAC1C,IAAA,KAAA,CAAM,OAAO,CAAA;AACb,IAAA,IAAA,CAAK,IAAA,GAAO,qBAAA;AAAA,EACd;AACF;AAYO,SAAS,iBAAiB,KAAA,EAAiD;AAChF,EAAA,OACE,iBAAiB,KAAA,IACjB,WAAA,IAAe,KAAA,IACf,OAAQ,MAAyB,SAAA,KAAc,SAAA;AAEnD;AAKO,IAAM,qBAAA,GAAN,cAAoC,KAAA,CAAgC;AAAA,EAIzE,WAAA,CAAY,OAAc,SAAA,EAAoB;AAC5C,IAAA,KAAA,CAAM,KAAA,CAAM,OAAA,EAAS,EAAE,KAAA,EAAO,OAAO,CAAA;AAJvC,IAAA,aAAA,CAAA,IAAA,EAAgB,WAAA,CAAA;AAChB,IAAA,aAAA,CAAA,IAAA,EAAyB,OAAA,CAAA;AAIvB,IAAA,IAAA,CAAK,IAAA,GAAO,uBAAA;AACZ,IAAA,IAAA,CAAK,SAAA,GAAY,SAAA;AACjB,IAAA,IAAA,CAAK,KAAA,GAAQ,KAAA;AACb,IAAA,IAAI,MAAM,KAAA,EAAO;AACf,MAAA,IAAA,CAAK,QAAQ,KAAA,CAAM,KAAA;AAAA,IACrB;AAAA,EACF;AACF;AAKO,SAAS,WAAA,CAAY,KAAA,EAAc,SAAA,GAAY,IAAA,EAA6B;AACjF,EAAA,OAAO,IAAI,qBAAA,CAAsB,KAAA,EAAO,SAAS,CAAA;AACnD;AAKO,SAAS,eAAe,KAAA,EAAqC;AAClE,EAAA,OAAO,IAAI,qBAAA,CAAsB,KAAA,EAAO,KAAK,CAAA;AAC/C;AAOO,SAAS,YAAY,KAAA,EAAqC;AAC/D,EAAA,IAAI,gBAAA,CAAiB,KAAK,CAAA,EAAG;AAC3B,IAAA,OAAO,KAAA,CAAM,SAAA;AAAA,EACf;AACA,EAAA,OAAO,MAAA;AACT;;;AC7GO,IAAM,UAAA,GAA4B;AAAA,EACvC,OAAO,MAAM,MAAA;AAAA,EACb,MAAM,MAAM,MAAA;AAAA,EACZ,MAAM,MAAM,MAAA;AAAA,EACZ,OAAO,MAAM;AACf;AAMO,IAAM,aAAA,GAA+B;AAAA,EAC1C,KAAA,EAAO,CAAC,GAAA,EAAK,OAAA,KAAY;AACvB,IAAA,IAAI,OAAA,EAAS;AACX,MAAA,OAAA,CAAQ,KAAA,CAAM,CAAA,UAAA,EAAa,GAAG,CAAA,CAAA,EAAI,OAAO,CAAA;AAAA,IAC3C,CAAA,MAAO;AACL,MAAA,OAAA,CAAQ,KAAA,CAAM,CAAA,UAAA,EAAa,GAAG,CAAA,CAAE,CAAA;AAAA,IAClC;AAAA,EACF,CAAA;AAAA,EACA,IAAA,EAAM,CAAC,GAAA,EAAK,OAAA,KAAY;AACtB,IAAA,IAAI,OAAA,EAAS;AACX,MAAA,OAAA,CAAQ,IAAA,CAAK,CAAA,UAAA,EAAa,GAAG,CAAA,CAAA,EAAI,OAAO,CAAA;AAAA,IAC1C,CAAA,MAAO;AACL,MAAA,OAAA,CAAQ,IAAA,CAAK,CAAA,UAAA,EAAa,GAAG,CAAA,CAAE,CAAA;AAAA,IACjC;AAAA,EACF,CAAA;AAAA,EACA,IAAA,EAAM,CAAC,GAAA,EAAK,OAAA,KAAY;AACtB,IAAA,IAAI,OAAA,EAAS;AACX,MAAA,OAAA,CAAQ,IAAA,CAAK,CAAA,UAAA,EAAa,GAAG,CAAA,CAAA,EAAI,OAAO,CAAA;AAAA,IAC1C,CAAA,MAAO;AACL,MAAA,OAAA,CAAQ,IAAA,CAAK,CAAA,UAAA,EAAa,GAAG,CAAA,CAAE,CAAA;AAAA,IACjC;AAAA,EACF,CAAA;AAAA,EACA,KAAA,EAAO,CAAC,GAAA,EAAK,OAAA,KAAY;AACvB,IAAA,IAAI,OAAA,EAAS;AACX,MAAA,OAAA,CAAQ,KAAA,CAAM,CAAA,UAAA,EAAa,GAAG,CAAA,CAAA,EAAI,OAAO,CAAA;AAAA,IAC3C,CAAA,MAAO;AACL,MAAA,OAAA,CAAQ,KAAA,CAAM,CAAA,UAAA,EAAa,GAAG,CAAA,CAAE,CAAA;AAAA,IAClC;AAAA,EACF;AACF;;;ACjFO,SAAS,KAAA,CAAM,IAAY,MAAA,EAAqC;AACrE,EAAA,OAAO,IAAI,OAAA,CAAQ,CAAC,OAAA,EAAS,MAAA,KAAW;AACtC,IAAA,IAAI,QAAQ,OAAA,EAAS;AACnB,MAAA,MAAA,CAAO,WAAA,CAAY,MAAA,CAAO,MAAM,CAAC,CAAA;AACjC,MAAA;AAAA,IACF;AAEA,IAAA,MAAM,SAAA,GAAY,UAAA,CAAW,OAAA,EAAS,EAAE,CAAA;AAExC,IAAA,MAAA,EAAQ,gBAAA;AAAA,MACN,OAAA;AAAA,MACA,MAAM;AACJ,QAAA,YAAA,CAAa,SAAS,CAAA;AACtB,QAAA,MAAA,CAAO,WAAA,CAAY,MAAA,CAAO,MAAM,CAAC,CAAA;AAAA,MACnC,CAAA;AAAA,MACA,EAAE,MAAM,IAAA;AAAK,KACf;AAAA,EACF,CAAC,CAAA;AACH;AAOA,SAAS,YAAY,MAAA,EAAwB;AAC3C,EAAA,IAAI,kBAAkB,KAAA,EAAO;AAC3B,IAAA,OAAO,MAAA;AAAA,EACT;AACA,EAAA,IAAI,OAAO,WAAW,QAAA,EAAU;AAC9B,IAAA,OAAO,IAAI,MAAM,MAAM,CAAA;AAAA,EACzB;AACA,EAAA,IAAI,MAAA,KAAW,MAAA,IAAa,MAAA,KAAW,IAAA,EAAM;AAE3C,IAAA,IAAI;AACF,MAAA,OAAO,IAAI,KAAA,CAAM,IAAA,CAAK,SAAA,CAAU,MAAM,CAAC,CAAA;AAAA,IACzC,CAAA,CAAA,MAAQ;AACN,MAAA,OAAO,IAAI,MAAM,eAAe,CAAA;AAAA,IAClC;AAAA,EACF;AACA,EAAA,OAAO,IAAI,YAAA,CAAa,SAAA,EAAW,YAAY,CAAA;AACjD;AAWA,eAAsB,WAAA,CACpB,OAAA,EACA,EAAA,EACA,MAAA,EACY;AAEZ,EAAA,IAAI,QAAQ,OAAA,EAAS;AACnB,IAAA,MAAM,WAAA,CAAY,OAAO,MAAM,CAAA;AAAA,EACjC;AAEA,EAAA,IAAI,SAAA;AAEJ,EAAA,MAAM,cAAA,GAAiB,IAAI,OAAA,CAAe,CAAC,GAAG,MAAA,KAAW;AACvD,IAAA,SAAA,GAAY,WAAW,MAAM;AAC3B,MAAA,MAAA,CAAO,IAAI,aAAa,CAAA,0BAAA,EAA6B,MAAA,CAAO,EAAE,CAAC,CAAA,EAAA,CAAA,EAAM,EAAE,CAAC,CAAA;AAAA,IAC1E,GAAG,EAAE,CAAA;AAAA,EACP,CAAC,CAAA;AAGD,EAAA,MAAM,eAAe,MAAA,GACjB,IAAI,OAAA,CAAe,CAAC,GAAG,MAAA,KAAW;AAChC,IAAA,MAAA,CAAO,gBAAA;AAAA,MACL,OAAA;AAAA,MACA,MAAM,MAAA,CAAO,WAAA,CAAY,MAAA,CAAO,MAAM,CAAC,CAAA;AAAA,MACvC,EAAE,MAAM,IAAA;AAAK,KACf;AAAA,EACF,CAAC,CAAA,GACD,IAAA;AAEJ,EAAA,IAAI;AACF,IAAA,MAAM,MAAA,GAAuB,CAAC,OAAA,EAAS,cAAc,CAAA;AACrD,IAAA,IAAI,YAAA,EAAc;AAChB,MAAA,MAAA,CAAO,KAAK,YAAY,CAAA;AAAA,IAC1B;AACA,IAAA,OAAO,MAAM,OAAA,CAAQ,IAAA,CAAK,MAAM,CAAA;AAAA,EAClC,CAAA,SAAE;AACA,IAAA,IAAI,cAAc,MAAA,EAAW;AAC3B,MAAA,YAAA,CAAa,SAAS,CAAA;AAAA,IACxB;AAAA,EACF;AACF;AAWA,eAAsB,kBAAA,CACpB,SAAA,EACA,EAAA,EACA,MAAA,EACY;AACZ,EAAA,MAAM,UAAA,GAAa,IAAI,eAAA,EAAgB;AAGvC,EAAA,MAAM,cAAA,GAAiB,cAAA,CAAe,MAAA,EAAQ,UAAA,CAAW,MAAM,CAAA;AAE/D,EAAA,MAAM,SAAA,GAAY,WAAW,MAAM;AACjC,IAAA,UAAA,CAAW,KAAA,CAAM,IAAI,YAAA,CAAa,CAAA,0BAAA,EAA6B,OAAO,EAAE,CAAC,CAAA,EAAA,CAAA,EAAM,EAAE,CAAC,CAAA;AAAA,EACpF,GAAG,EAAE,CAAA;AAEL,EAAA,IAAI;AACF,IAAA,OAAO,MAAM,UAAU,cAAc,CAAA;AAAA,EACvC,CAAA,SAAE;AACA,IAAA,YAAA,CAAa,SAAS,CAAA;AAAA,EACxB;AACF;AAYO,SAAS,kBAAkB,OAAA,EAAmD;AACnF,EAAA,MAAM,eAAe,OAAA,CAAQ,MAAA,CAAO,CAAC,CAAA,KAAwB,MAAM,MAAS,CAAA;AAE5E,EAAA,IAAI,YAAA,CAAa,WAAW,CAAA,EAAG;AAC7B,IAAA,OAAO,IAAI,iBAAgB,CAAE,MAAA;AAAA,EAC/B;AAEA,EAAA,MAAM,WAAA,GAAc,aAAa,CAAC,CAAA;AAClC,EAAA,IAAI,YAAA,CAAa,MAAA,KAAW,CAAA,IAAK,WAAA,EAAa;AAC5C,IAAA,OAAO,WAAA;AAAA,EACT;AAGA,EAAA,IAAI,SAAS,WAAA,EAAa;AACxB,IAAA,OAAO,WAAA,CAAY,IAAI,YAAY,CAAA;AAAA,EACrC;AAIA,EAAA,MAAM,UAAA,GAAa,IAAI,eAAA,EAAgB;AACvC,EAAA,MAAM,YAA6D,EAAC;AAGpE,EAAA,MAAM,UAAU,MAAM;AACpB,IAAA,KAAA,MAAW,EAAE,MAAA,EAAQ,QAAA,EAAS,IAAK,SAAA,EAAW;AAC5C,MAAA,MAAA,CAAO,mBAAA,CAAoB,SAAS,QAAQ,CAAA;AAAA,IAC9C;AACA,IAAA,SAAA,CAAU,MAAA,GAAS,CAAA;AAAA,EACrB,CAAA;AAEA,EAAA,KAAA,MAAW,UAAU,YAAA,EAAc;AACjC,IAAA,IAAI,OAAO,OAAA,EAAS;AAClB,MAAA,UAAA,CAAW,KAAA,CAAM,OAAO,MAAM,CAAA;AAC9B,MAAA,OAAO,UAAA,CAAW,MAAA;AAAA,IACpB;AAEA,IAAA,MAAM,WAAW,MAAM;AACrB,MAAA,OAAA,EAAQ;AACR,MAAA,UAAA,CAAW,KAAA,CAAM,OAAO,MAAM,CAAA;AAAA,IAChC,CAAA;AAEA,IAAA,SAAA,CAAU,IAAA,CAAK,EAAE,MAAA,EAAQ,QAAA,EAAU,CAAA;AACnC,IAAA,MAAA,CAAO,iBAAiB,OAAA,EAAS,QAAA,EAAU,EAAE,IAAA,EAAM,MAAM,CAAA;AAAA,EAC3D;AAEA,EAAA,OAAO,UAAA,CAAW,MAAA;AACpB;AAQO,SAAS,aAAa,KAAA,EAAyB;AACpD,EAAA,OACE,KAAA,YAAiB,YAAA,IACjB,KAAA,CAAM,IAAA,KAAS,YAAA;AAEnB;AASO,SAAS,YAAA,CACd,UACA,OAAA,EACe;AACf,EAAA,IAAI,CAAC,UAAU,OAAO,MAAA;AAEtB,EAAA,QAAQ,IAAI,IAAA,KAAmD;AAC7D,IAAA,IAAI;AACF,MAAA,OAAO,QAAA,CAAS,GAAG,IAAI,CAAA;AAAA,IACzB,SAAS,KAAA,EAAO;AACd,MAAA,IAAI,OAAA,IAAW,iBAAiB,KAAA,EAAO;AACrC,QAAA,OAAA,CAAQ,KAAK,CAAA;AAAA,MACf;AACA,MAAA,OAAO,MAAA;AAAA,IACT;AAAA,EACF,CAAA;AACF;AASO,SAAS,UAAU,KAAA,EAAuB;AAC/C,EAAA,MAAM,YAAA,GAAe,CAAA,GAAI,IAAA,CAAK,MAAA,EAAO,GAAI,GAAA;AACzC,EAAA,OAAO,IAAA,CAAK,KAAA,CAAM,KAAA,GAAQ,YAAY,CAAA;AACxC;AAUO,SAAS,KAAA,CAAM,KAAA,EAAe,GAAA,EAAa,GAAA,EAAqB;AACrE,EAAA,OAAO,KAAK,GAAA,CAAI,IAAA,CAAK,IAAI,KAAA,EAAO,GAAG,GAAG,GAAG,CAAA;AAC3C;AAQO,SAAS,GAAA,GAAc;AAC5B,EAAA,IAAI,OAAO,WAAA,KAAgB,WAAA,IAAe,OAAO,WAAA,CAAY,QAAQ,UAAA,EAAY;AAC/E,IAAA,OAAO,YAAY,GAAA,EAAI;AAAA,EACzB;AACA,EAAA,OAAO,KAAK,GAAA,EAAI;AAClB;AClQA,IAAM,cAAA,GAAiB,EAAE,QAAA,EAAS;AAM3B,IAAM,YAAA,GAAe,EAAE,MAAA,CAAO;AAAA,EACnC,KAAA,EAAO,cAAA;AAAA,EACP,IAAA,EAAM,cAAA;AAAA,EACN,IAAA,EAAM,cAAA;AAAA,EACN,KAAA,EAAO;AACT,CAAC,EAAE,QAAA;AAKI,IAAM,mBAAA,GAAsB,EAAE,MAAA,CAAO;AAAA;AAAA,EAE1C,cAAA,EAAgB,EAAE,MAAA,EAAO,CAAE,KAAI,CAAE,QAAA,EAAS,CAAE,OAAA,CAAQ,GAAK,CAAA;AAAA;AAAA,EAEzD,SAAA,EAAW,eAAe,QAAA,EAAS;AAAA;AAAA,EAEnC,MAAA,EAAQ;AACV,CAAC;AAOM,IAAM,sBAAsB,CAAA,CAAE,IAAA,CAAK,CAAC,aAAA,EAAe,QAAA,EAAU,UAAU,CAAC;AAOxE,IAAM,iBAAA,GAAoB,EAAE,MAAA,CAAO;AAAA;AAAA,EAExC,WAAA,EAAa,EAAE,MAAA,EAAO,CAAE,KAAI,CAAE,QAAA,EAAS,CAAE,OAAA,CAAQ,CAAC,CAAA;AAAA;AAAA,EAElD,YAAA,EAAc,EAAE,MAAA,EAAO,CAAE,KAAI,CAAE,QAAA,EAAS,CAAE,OAAA,CAAQ,GAAG,CAAA;AAAA;AAAA,EAErD,QAAA,EAAU,EAAE,MAAA,EAAO,CAAE,KAAI,CAAE,QAAA,GAAW,QAAA,EAAS;AAAA;AAAA,EAE/C,aAAA,EAAe,mBAAA,CAAoB,OAAA,CAAQ,aAAa,CAAA;AAAA;AAAA,EAExD,YAAY,CAAA,CAAE,MAAA,GAAS,QAAA,EAAS,CAAE,QAAQ,CAAG,CAAA;AAAA;AAAA,EAE7C,MAAA,EAAQ,CAAA,CAAE,OAAA,EAAQ,CAAE,QAAQ,KAAK,CAAA;AAAA;AAAA,EAEjC,WAAA,EAAa,eAAe,QAAA,EAAS;AAAA;AAAA,EAErC,OAAA,EAAS,eAAe,QAAA,EAAS;AAAA;AAAA,EAEjC,MAAA,EAAQ;AACV,CAAC;AAOM,IAAM,4BAA4B,CAAA,CAAE,IAAA,CAAK,CAAC,QAAA,EAAU,MAAA,EAAQ,WAAW,CAAC;AAOxE,IAAM,0BAAA,GAA6B,EAAE,MAAA,CAAO;AAAA,EACjD,UAAU,CAAA,CAAE,MAAA,EAAO,CAAE,GAAA,GAAM,WAAA,EAAY;AAAA,EACvC,gBAAgB,CAAA,CAAE,MAAA,EAAO,CAAE,GAAA,GAAM,WAAA,EAAY;AAAA,EAC7C,eAAe,CAAA,CAAE,MAAA,EAAO,CAAE,GAAA,GAAM,WAAA,EAAY;AAAA,EAC5C,sBAAsB,CAAA,CAAE,MAAA,EAAO,CAAE,GAAA,GAAM,WAAA,EAAY;AAAA,EACnD,qBAAqB,CAAA,CAAE,MAAA,EAAO,CAAE,GAAA,GAAM,WAAA;AACxC,CAAC;AAOM,IAAM,0BAAA,GAA6B,EAAE,MAAA,CAAO;AAAA;AAAA,EAEjD,WAAA,EAAa,EAAE,MAAA,EAAO,CAAE,KAAI,CAAE,QAAA,EAAS,CAAE,OAAA,CAAQ,CAAC,CAAA;AAAA;AAAA,EAElD,OAAA,EAAS,EAAE,MAAA,EAAO,CAAE,KAAI,CAAE,QAAA,EAAS,CAAE,OAAA,CAAQ,GAAK,CAAA;AAAA;AAAA,EAElD,mBAAA,EAAqB,EAAE,MAAA,EAAO,CAAE,KAAI,CAAE,QAAA,EAAS,CAAE,OAAA,CAAQ,CAAC,CAAA;AAAA;AAAA,EAE1D,QAAA,EAAU,EAAE,MAAA,EAAO,CAAE,KAAI,CAAE,WAAA,EAAY,CAAE,OAAA,CAAQ,CAAC,CAAA;AAAA;AAAA,EAElD,WAAA,EAAa,eAAe,QAAA,EAAS;AAAA;AAAA,EAErC,YAAA,EAAc,eAAe,QAAA,EAAS;AAAA;AAAA,EAEtC,aAAA,EAAe,eAAe,QAAA,EAAS;AAAA;AAAA,EAEvC,MAAA,EAAQ;AACV,CAAC;AAOM,IAAM,qBAAA,GAAwB,EAAE,MAAA,CAAO;AAAA;AAAA,EAE5C,IAAA,EAAM,EAAE,MAAA,EAAO,CAAE,KAAI,CAAE,QAAA,EAAS,CAAE,OAAA,CAAQ,GAAG,CAAA;AAAA;AAAA,EAE7C,KAAA,EAAO,EAAE,MAAA,EAAO,CAAE,KAAI,CAAE,QAAA,GAAW,QAAA,EAAS;AAAA;AAAA,EAE5C,QAAA,EAAU,EAAE,MAAA,EAAO,CAAE,KAAI,CAAE,QAAA,EAAS,CAAE,OAAA,CAAQ,GAAI,CAAA;AAAA;AAAA,EAElD,OAAA,EAAS,eAAe,QAAA,EAAS;AAAA;AAAA,EAEjC,MAAA,EAAQ;AACV,CAAC;AAOM,IAAM,oBAAA,GAAuB,EAAE,MAAA,CAAO;AAAA;AAAA,EAE3C,aAAA,EAAe,EAAE,MAAA,EAAO,CAAE,KAAI,CAAE,QAAA,EAAS,CAAE,OAAA,CAAQ,EAAE,CAAA;AAAA;AAAA,EAErD,QAAA,EAAU,EAAE,MAAA,EAAO,CAAE,KAAI,CAAE,WAAA,EAAY,CAAE,OAAA,CAAQ,CAAC,CAAA;AAAA;AAAA,EAElD,YAAA,EAAc,EAAE,MAAA,EAAO,CAAE,KAAI,CAAE,QAAA,GAAW,QAAA,EAAS;AAAA;AAAA,EAEnD,UAAA,EAAY,eAAe,QAAA,EAAS;AAAA;AAAA,EAEpC,MAAA,EAAQ;AACV,CAAC;AAOM,IAAM,oBAAA,GAAuB,EAAE,MAAA,CAAO;AAAA;AAAA,EAE3C,QAAA,EAAU,cAAA;AAAA;AAAA,EAEV,cAAA,EAAgB,eAAe,QAAA,EAAS;AAAA;AAAA,EAExC,UAAA,EAAY,eAAe,QAAA,EAAS;AAAA;AAAA,EAEpC,SAAA,EAAW,eAAe,QAAA,EAAS;AAAA;AAAA,EAEnC,MAAA,EAAQ;AACV,CAAC","file":"index.js","sourcesContent":["/*\n Base error class for all Fortify errors.\n /\nexport class FortifyError extends Error {\n constructor(message: string) {\n super(message);\n this.name = 'FortifyError';\n // Maintains proper stack trace for where our error was thrown (only available on V8)\n // Use typeof check to avoid unnecessary-condition lint error\n if (typeof Error.captureStackTrace === 'function') {\n Error.captureStackTrace(this, this.constructor);\n }\n }\n}\n\n/\n Error thrown when circuit breaker is in open state and rejecting requests.\n /\nexport class CircuitOpenError extends FortifyError {\n constructor(message = 'Circuit breaker is open') {\n super(message);\n this.name = 'CircuitOpenError';\n }\n}\n\n/\n Error thrown when rate limit is exceeded.\n /\nexport class RateLimitExceededError extends FortifyError {\n public readonly key: string \| undefined;\n\n constructor(message = 'Rate limit exceeded', key?: string) {\n super(message);\n this.name = 'RateLimitExceededError';\n this.key = key;\n }\n}\n\n/\n Error thrown when bulkhead is at capacity.\n /\nexport class BulkheadFullError extends FortifyError {\n public readonly activeCount: number;\n public readonly queuedCount: number;\n\n constructor(\n message = 'Bulkhead is full',\n activeCount = 0,\n queuedCount = 0\n ) {\n super(message);\n this.name = 'BulkheadFullError';\n this.activeCount = activeCount;\n this.queuedCount = queuedCount;\n }\n}\n\n/\n Error thrown when operation times out.\n /\nexport class TimeoutError extends FortifyError {\n public readonly timeoutMs: number;\n\n constructor(message = 'Operation timed out', timeoutMs = 0) {\n super(message);\n this.name = 'TimeoutError';\n this.timeoutMs = timeoutMs;\n }\n}\n\n/\n Error thrown when maximum retry attempts are reached.\n /\nexport class MaxAttemptsReachedError extends FortifyError {\n public readonly attempts: number;\n public readonly lastError: Error \| undefined;\n\n constructor(\n message = 'Maximum retry attempts reached',\n attempts = 0,\n lastError?: Error\n ) {\n super(message);\n this.name = 'MaxAttemptsReachedError';\n this.attempts = attempts;\n this.lastError = lastError;\n }\n}\n\n/\n Error thrown when bulkhead is closed and no new operations accepted.\n /\nexport class BulkheadClosedError extends FortifyError {\n constructor(message = 'Bulkhead is closed') {\n super(message);\n this.name = 'BulkheadClosedError';\n }\n}\n\n/\n Interface for errors that can indicate whether they are retryable.\n /\nexport interface RetryableError {\n retryable: boolean;\n}\n\n/\n Type guard to check if an error implements RetryableError interface.\n /\nexport function isRetryableError(error: unknown): error is Error & RetryableError {\n return (\n error instanceof Error &&\n 'retryable' in error &&\n typeof (error as RetryableError).retryable === 'boolean'\n );\n}\n\n/\n Wrapper class to mark an error as retryable.\n /\nexport class RetryableErrorWrapper extends Error implements RetryableError {\n public readonly retryable: boolean;\n public override readonly cause: Error;\n\n constructor(error: Error, retryable: boolean) {\n super(error.message, { cause: error });\n this.name = 'RetryableErrorWrapper';\n this.retryable = retryable;\n this.cause = error;\n if (error.stack) {\n this.stack = error.stack;\n }\n }\n}\n\n/\n Wrap an error as retryable.\n /\nexport function asRetryable(error: Error, retryable = true): RetryableErrorWrapper {\n return new RetryableErrorWrapper(error, retryable);\n}\n\n/\n Wrap an error as non-retryable.\n /\nexport function asNonRetryable(error: Error): RetryableErrorWrapper {\n return new RetryableErrorWrapper(error, false);\n}\n\n/\n Check if an error is retryable.\n * Returns true if the error implements RetryableError and retryable is true.\n * Returns undefined if the error doesn't implement RetryableError (let caller decide).\n /\nexport function isRetryable(error: unknown): boolean \| undefined {\n if (isRetryableError(error)) {\n return error.retryable;\n }\n return undefined;\n}\n","/\n Represents an async operation that can be executed with cancellation support.\n * The signal parameter allows the operation to be cancelled via AbortController.\n \n @template T - The return type of the operation\n /\nexport type Operation<T> = (signal: AbortSignal) => Promise<T>;\n\n/\n Callback for state changes in stateful patterns (e.g., circuit breaker).\n \n @template S - The state type\n /\nexport type StateChangeCallback<S> = (from: S, to: S) => void;\n\n/\n Callback for error events.\n /\nexport type ErrorCallback = (error: Error) => void;\n\n/\n Simple void callback.\n /\nexport type VoidCallback = () => void;\n\n/\n Callback for retry events.\n /\nexport type RetryCallback = (attempt: number, error: Error) => void;\n\n/\n Callback for rate limit events.\n /\nexport type RateLimitCallback = (key: string) => void;\n\n/\n Logger interface for structured logging across all patterns.\n * Compatible with pino, winston, console, and custom implementations.\n /\nexport interface FortifyLogger {\n debug(msg: string, context?: Record<string, unknown>): void;\n info(msg: string, context?: Record<string, unknown>): void;\n warn(msg: string, context?: Record<string, unknown>): void;\n error(msg: string, context?: Record<string, unknown>): void;\n}\n\n/\n No-operation logger that discards all log messages.\n * Useful for testing or when logging is not needed.\n /\nexport const noopLogger: FortifyLogger = {\n debug: () => undefined,\n info: () => undefined,\n warn: () => undefined,\n error: () => undefined,\n};\n\n/\n Console-based logger implementation.\n * Browser-friendly and works in all environments.\n /\nexport const consoleLogger: FortifyLogger = {\n debug: (msg, context) => {\n if (context) {\n console.debug(`[fortify] ${msg}`, context);\n } else {\n console.debug(`[fortify] ${msg}`);\n }\n },\n info: (msg, context) => {\n if (context) {\n console.info(`[fortify] ${msg}`, context);\n } else {\n console.info(`[fortify] ${msg}`);\n }\n },\n warn: (msg, context) => {\n if (context) {\n console.warn(`[fortify] ${msg}`, context);\n } else {\n console.warn(`[fortify] ${msg}`);\n }\n },\n error: (msg, context) => {\n if (context) {\n console.error(`[fortify] ${msg}`, context);\n } else {\n console.error(`[fortify] ${msg}`);\n }\n },\n};\n\n/\n Generic pattern interface that all resilience patterns implement.\n \n @template T - The return type of the operation\n /\nexport interface Pattern<T> {\n /\n Execute an operation with the pattern's resilience logic.\n \n @param operation - The async operation to execute\n * @param signal - Optional AbortSignal for cancellation\n * @returns Promise resolving to the operation result\n /\n execute(operation: Operation<T>, signal?: AbortSignal): Promise<T>;\n}\n\n/\n Interface for patterns that support closing/cleanup.\n /\nexport interface Closeable {\n /\n Close the pattern and release resources.\n * May wait for in-flight operations to complete.\n /\n close(): Promise<void>;\n}\n\n/\n Interface for patterns that support resetting state.\n /\nexport interface Resettable {\n /\n Reset the pattern to its initial state.\n /\n reset(): void;\n}\n","import { TimeoutError } from './errors.js';\n\n/\n Sleep for a specified duration with optional cancellation support.\n \n @param ms - Duration in milliseconds\n * @param signal - Optional AbortSignal for cancellation\n * @returns Promise that resolves after the delay or rejects if cancelled\n /\nexport function sleep(ms: number, signal?: AbortSignal): Promise<void> {\n return new Promise((resolve, reject) => {\n if (signal?.aborted) {\n reject(ensureError(signal.reason));\n return;\n }\n\n const timeoutId = setTimeout(resolve, ms);\n\n signal?.addEventListener(\n 'abort',\n () => {\n clearTimeout(timeoutId);\n reject(ensureError(signal.reason));\n },\n { once: true }\n );\n });\n}\n\n/\n Ensure a value is an Error instance.\n * @param reason - The reason to convert to an Error\n * @returns An Error instance\n /\nfunction ensureError(reason: unknown): Error {\n if (reason instanceof Error) {\n return reason;\n }\n if (typeof reason === 'string') {\n return new Error(reason);\n }\n if (reason !== undefined && reason !== null) {\n // Handle objects and other types safely\n try {\n return new Error(JSON.stringify(reason));\n } catch {\n return new Error('Unknown error');\n }\n }\n return new DOMException('Aborted', 'AbortError');\n}\n\n/\n Wrap a promise with a timeout.\n \n @template T - The promise return type\n * @param promise - The promise to wrap\n * @param ms - Timeout duration in milliseconds\n * @param signal - Optional external AbortSignal for cancellation\n * @returns Promise that resolves with the result or rejects with TimeoutError\n /\nexport async function withTimeout<T>(\n promise: Promise<T>,\n ms: number,\n signal?: AbortSignal\n): Promise<T> {\n // Check if already aborted\n if (signal?.aborted) {\n throw ensureError(signal.reason);\n }\n\n let timeoutId: ReturnType<typeof setTimeout> \| undefined;\n\n const timeoutPromise = new Promise<never>((_, reject) => {\n timeoutId = setTimeout(() => {\n reject(new TimeoutError(`Operation timed out after ${String(ms)}ms`, ms));\n }, ms);\n });\n\n // Handle external signal\n const abortPromise = signal\n ? new Promise<never>((_, reject) => {\n signal.addEventListener(\n 'abort',\n () => reject(ensureError(signal.reason)),\n { once: true }\n );\n })\n : null;\n\n try {\n const racers: Promise<T>[] = [promise, timeoutPromise];\n if (abortPromise) {\n racers.push(abortPromise);\n }\n return await Promise.race(racers);\n } finally {\n if (timeoutId !== undefined) {\n clearTimeout(timeoutId);\n }\n }\n}\n\n/\n Execute an operation with a timeout, passing the combined signal to the operation.\n \n @template T - The operation return type\n * @param operation - The operation to execute\n * @param ms - Timeout duration in milliseconds\n * @param signal - Optional external AbortSignal for cancellation\n * @returns Promise that resolves with the result or rejects with TimeoutError\n /\nexport async function executeWithTimeout<T>(\n operation: (signal: AbortSignal) => Promise<T>,\n ms: number,\n signal?: AbortSignal\n): Promise<T> {\n const controller = new AbortController();\n\n // Combine signals\n const combinedSignal = combineSignals(signal, controller.signal);\n\n const timeoutId = setTimeout(() => {\n controller.abort(new TimeoutError(`Operation timed out after ${String(ms)}ms`, ms));\n }, ms);\n\n try {\n return await operation(combinedSignal);\n } finally {\n clearTimeout(timeoutId);\n }\n}\n\n/\n Combine multiple AbortSignals into one.\n * Returns a signal that aborts when any of the input signals abort.\n \n Uses AbortSignal.any() when available (Node 20+, modern browsers).\n * Falls back to a manual implementation that properly cleans up event listeners.\n \n @param signals - AbortSignals to combine (undefined values are filtered out)\n * @returns Combined AbortSignal\n /\nexport function combineSignals(...signals: (AbortSignal \| undefined)[]): AbortSignal {\n const validSignals = signals.filter((s): s is AbortSignal => s !== undefined);\n\n if (validSignals.length === 0) {\n return new AbortController().signal;\n }\n\n const firstSignal = validSignals[0];\n if (validSignals.length === 1 && firstSignal) {\n return firstSignal;\n }\n\n // Use AbortSignal.any if available (Node 20+, modern browsers)\n if ('any' in AbortSignal) {\n return AbortSignal.any(validSignals);\n }\n\n // Fallback: create a new controller and link it to all signals\n // Track listeners so we can clean them up to prevent memory leaks\n const controller = new AbortController();\n const listeners: { signal: AbortSignal; listener: () => void }[] = [];\n\n // Cleanup function to remove all listeners\n const cleanup = () => {\n for (const { signal, listener } of listeners) {\n signal.removeEventListener('abort', listener);\n }\n listeners.length = 0;\n };\n\n for (const signal of validSignals) {\n if (signal.aborted) {\n controller.abort(signal.reason);\n return controller.signal;\n }\n\n const listener = () => {\n cleanup(); // Clean up all listeners when any signal aborts\n controller.abort(signal.reason);\n };\n\n listeners.push({ signal, listener });\n signal.addEventListener('abort', listener, { once: true });\n }\n\n return controller.signal;\n}\n\n/\n Check if an error is an abort error (from AbortController).\n \n @param error - Error to check\n * @returns True if the error is an AbortError\n /\nexport function isAbortError(error: unknown): boolean {\n return (\n error instanceof DOMException &&\n error.name === 'AbortError'\n );\n}\n\n/\n Safely execute a callback, catching and logging any errors.\n * Used for user-provided callbacks to prevent them from breaking the pattern.\n \n @param callback - Callback to execute\n * @param onError - Optional error handler\n /\nexport function safeCallback<T extends (...args: unknown[]) => unknown>(\n callback: T \| undefined,\n onError?: (error: Error) => void\n): T \| undefined {\n if (!callback) return undefined;\n\n return ((...args: Parameters<T>): ReturnType<T> \| undefined => {\n try {\n return callback(...args) as ReturnType<T>;\n } catch (error) {\n if (onError && error instanceof Error) {\n onError(error);\n }\n return undefined;\n }\n }) as T;\n}\n\n/\n Calculate jittered delay.\n * Adds 0-10% random variance to prevent thundering herd.\n \n @param delay - Base delay in milliseconds\n * @returns Jittered delay\n /\nexport function addJitter(delay: number): number {\n const jitterFactor = 1 + Math.random() 0.1; // 0-10% jitter\n return Math.floor(delay * jitterFactor);\n}\n\n/*\n Clamp a number between min and max values.\n \n @param value - Value to clamp\n * @param min - Minimum value\n * @param max - Maximum value\n * @returns Clamped value\n /\nexport function clamp(value: number, min: number, max: number): number {\n return Math.min(Math.max(value, min), max);\n}\n\n/\n Get current timestamp in milliseconds.\n * Uses performance.now() if available for higher precision.\n \n @returns Current timestamp in milliseconds\n /\nexport function now(): number {\n if (typeof performance !== 'undefined' && typeof performance.now === 'function') {\n return performance.now();\n }\n return Date.now();\n}\n","import { z } from 'zod';\n\n/\n Schema for a function type (Zod 4 compatible).\n * Uses z.function() which validates that the value is a function.\n /\nconst functionSchema = z.function();\n\n/\n Base schema for logger configuration.\n * Validates that the logger has the required methods.\n /\nexport const loggerSchema = z.object({\n debug: functionSchema,\n info: functionSchema,\n warn: functionSchema,\n error: functionSchema,\n}).optional();\n\n/\n Schema for timeout configuration.\n /\nexport const timeoutConfigSchema = z.object({\n /* Default timeout in milliseconds (default: 30000) /\n defaultTimeout: z.number().int().positive().default(30000),\n /* Callback when timeout occurs /\n onTimeout: functionSchema.optional(),\n /* Logger instance /\n logger: loggerSchema,\n});\n\nexport type TimeoutConfig = z.infer<typeof timeoutConfigSchema>;\n\n/\n Schema for retry backoff policy.\n /\nexport const backoffPolicySchema = z.enum(['exponential', 'linear', 'constant']);\n\nexport type BackoffPolicy = z.infer<typeof backoffPolicySchema>;\n\n/\n Schema for retry configuration.\n /\nexport const retryConfigSchema = z.object({\n /* Maximum number of attempts including the first (default: 3) /\n maxAttempts: z.number().int().positive().default(3),\n /* Initial delay before first retry in milliseconds (default: 100) /\n initialDelay: z.number().int().positive().default(100),\n /* Maximum delay between retries in milliseconds /\n maxDelay: z.number().int().positive().optional(),\n /* Backoff strategy (default: 'exponential') /\n backoffPolicy: backoffPolicySchema.default('exponential'),\n /* Multiplier for exponential backoff (default: 2.0) /\n multiplier: z.number().positive().default(2.0),\n /* Add random jitter to delays (default: false) /\n jitter: z.boolean().default(false),\n /* Custom function to determine if error is retryable /\n isRetryable: functionSchema.optional(),\n /* Callback on each retry attempt /\n onRetry: functionSchema.optional(),\n /* Logger instance /\n logger: loggerSchema,\n});\n\nexport type RetryConfig = z.infer<typeof retryConfigSchema>;\n\n/\n Schema for circuit breaker state.\n /\nexport const circuitBreakerStateSchema = z.enum(['closed', 'open', 'half-open']);\n\nexport type CircuitBreakerState = z.infer<typeof circuitBreakerStateSchema>;\n\n/\n Schema for circuit breaker counts/metrics.\n /\nexport const circuitBreakerCountsSchema = z.object({\n requests: z.number().int().nonnegative(),\n totalSuccesses: z.number().int().nonnegative(),\n totalFailures: z.number().int().nonnegative(),\n consecutiveSuccesses: z.number().int().nonnegative(),\n consecutiveFailures: z.number().int().nonnegative(),\n});\n\nexport type CircuitBreakerCounts = z.infer<typeof circuitBreakerCountsSchema>;\n\n/\n Schema for circuit breaker configuration.\n /\nexport const circuitBreakerConfigSchema = z.object({\n /* Maximum consecutive failures before opening (default: 5) /\n maxFailures: z.number().int().positive().default(5),\n /* Duration in open state before transitioning to half-open in milliseconds (default: 60000) /\n timeout: z.number().int().positive().default(60000),\n /* Maximum requests allowed in half-open state (default: 1) /\n halfOpenMaxRequests: z.number().int().positive().default(1),\n /* Period to clear counts when closed, 0 means never (default: 0) /\n interval: z.number().int().nonnegative().default(0),\n /* Custom function to determine when to trip the breaker /\n readyToTrip: functionSchema.optional(),\n /* Custom function to determine if result is successful /\n isSuccessful: functionSchema.optional(),\n /* Callback on state change /\n onStateChange: functionSchema.optional(),\n /* Logger instance /\n logger: loggerSchema,\n});\n\nexport type CircuitBreakerConfig = z.infer<typeof circuitBreakerConfigSchema>;\n\n/\n Schema for rate limiter configuration.\n /\nexport const rateLimitConfigSchema = z.object({\n /* Number of tokens added per interval (default: 100) /\n rate: z.number().int().positive().default(100),\n /* Maximum bucket capacity (defaults to rate) /\n burst: z.number().int().positive().optional(),\n /* Interval for token refill in milliseconds (default: 1000) /\n interval: z.number().int().positive().default(1000),\n /* Callback when rate limit is hit /\n onLimit: functionSchema.optional(),\n /* Logger instance /\n logger: loggerSchema,\n});\n\nexport type RateLimitConfig = z.infer<typeof rateLimitConfigSchema>;\n\n/\n Schema for bulkhead configuration.\n /\nexport const bulkheadConfigSchema = z.object({\n /* Maximum concurrent executions (default: 10) /\n maxConcurrent: z.number().int().positive().default(10),\n /* Maximum queued requests, 0 means no queueing (default: 0) /\n maxQueue: z.number().int().nonnegative().default(0),\n /* Maximum time to wait in queue in milliseconds /\n queueTimeout: z.number().int().positive().optional(),\n /* Callback when request is rejected /\n onRejected: functionSchema.optional(),\n /* Logger instance /\n logger: loggerSchema,\n});\n\nexport type BulkheadConfig = z.infer<typeof bulkheadConfigSchema>;\n\n/\n Schema for fallback configuration.\n /\nexport const fallbackConfigSchema = z.object({\n /* Fallback function to execute when primary fails /\n fallback: functionSchema,\n /* Custom function to determine if fallback should be used /\n shouldFallback: functionSchema.optional(),\n /* Callback when fallback is triggered /\n onFallback: functionSchema.optional(),\n /* Callback when primary succeeds /\n onSuccess: functionSchema.optional(),\n /* Logger instance */\n logger: loggerSchema,\n});\n\nexport type FallbackConfig = z.infer<typeof fallbackConfigSchema>;\n"]}
		{"version":3,"sources":["../src/errors.ts","../src/types.ts","../src/utils.ts","../src/schemas.ts"],"names":[],"mappings":";;;;;;;AAGO,IAAM,YAAA,GAAN,cAA2B,KAAA,CAAM;AAAA,EACtC,YAAY,OAAA,EAAiB;AAC3B,IAAA,KAAA,CAAM,OAAO,CAAA;AACb,IAAA,IAAA,CAAK,IAAA,GAAO,cAAA;AAGZ,IAAA,IAAI,OAAO,KAAA,CAAM,iBAAA,KAAsB,UAAA,EAAY;AACjD,MAAA,KAAA,CAAM,iBAAA,CAAkB,IAAA,EAAM,IAAA,CAAK,WAAW,CAAA;AAAA,IAChD;AAAA,EACF;AACF;AAKO,IAAM,gBAAA,GAAN,cAA+B,YAAA,CAAa;AAAA,EACjD,WAAA,CAAY,UAAU,yBAAA,EAA2B;AAC/C,IAAA,KAAA,CAAM,OAAO,CAAA;AACb,IAAA,IAAA,CAAK,IAAA,GAAO,kBAAA;AAAA,EACd;AACF;AAKO,IAAM,sBAAA,GAAN,cAAqC,YAAA,CAAa;AAAA,EAGvD,WAAA,CAAY,OAAA,GAAU,qBAAA,EAAuB,GAAA,EAAc;AACzD,IAAA,KAAA,CAAM,OAAO,CAAA;AAHf,IAAA,aAAA,CAAA,IAAA,EAAgB,KAAA,CAAA;AAId,IAAA,IAAA,CAAK,IAAA,GAAO,wBAAA;AACZ,IAAA,IAAA,CAAK,GAAA,GAAM,GAAA;AAAA,EACb;AACF;AAKO,IAAM,iBAAA,GAAN,cAAgC,YAAA,CAAa;AAAA,EAIlD,YACE,OAAA,GAAU,kBAAA,EACV,WAAA,GAAc,CAAA,EACd,cAAc,CAAA,EACd;AACA,IAAA,KAAA,CAAM,OAAO,CAAA;AARf,IAAA,aAAA,CAAA,IAAA,EAAgB,aAAA,CAAA;AAChB,IAAA,aAAA,CAAA,IAAA,EAAgB,aAAA,CAAA;AAQd,IAAA,IAAA,CAAK,IAAA,GAAO,mBAAA;AACZ,IAAA,IAAA,CAAK,WAAA,GAAc,WAAA;AACnB,IAAA,IAAA,CAAK,WAAA,GAAc,WAAA;AAAA,EACrB;AACF;AAKO,IAAM,YAAA,GAAN,cAA2B,YAAA,CAAa;AAAA,EAG7C,WAAA,CAAY,OAAA,GAAU,qBAAA,EAAuB,SAAA,GAAY,CAAA,EAAG;AAC1D,IAAA,KAAA,CAAM,OAAO,CAAA;AAHf,IAAA,aAAA,CAAA,IAAA,EAAgB,WAAA,CAAA;AAId,IAAA,IAAA,CAAK,IAAA,GAAO,cAAA;AACZ,IAAA,IAAA,CAAK,SAAA,GAAY,SAAA;AAAA,EACnB;AACF;AAKO,IAAM,uBAAA,GAAN,cAAsC,YAAA,CAAa;AAAA,EAIxD,WAAA,CACE,OAAA,GAAU,gCAAA,EACV,QAAA,GAAW,GACX,SAAA,EACA;AACA,IAAA,KAAA,CAAM,OAAO,CAAA;AARf,IAAA,aAAA,CAAA,IAAA,EAAgB,UAAA,CAAA;AAChB,IAAA,aAAA,CAAA,IAAA,EAAgB,WAAA,CAAA;AAQd,IAAA,IAAA,CAAK,IAAA,GAAO,yBAAA;AACZ,IAAA,IAAA,CAAK,QAAA,GAAW,QAAA;AAChB,IAAA,IAAA,CAAK,SAAA,GAAY,SAAA;AAAA,EACnB;AACF;AAKO,IAAM,mBAAA,GAAN,cAAkC,YAAA,CAAa;AAAA,EACpD,WAAA,CAAY,UAAU,oBAAA,EAAsB;AAC1C,IAAA,KAAA,CAAM,OAAO,CAAA;AACb,IAAA,IAAA,CAAK,IAAA,GAAO,qBAAA;AAAA,EACd;AACF;AAYO,SAAS,iBAAiB,KAAA,EAAiD;AAChF,EAAA,OACE,iBAAiB,KAAA,IACjB,WAAA,IAAe,KAAA,IACf,OAAQ,MAAyB,SAAA,KAAc,SAAA;AAEnD;AAKO,IAAM,qBAAA,GAAN,cAAoC,KAAA,CAAgC;AAAA,EAIzE,WAAA,CAAY,OAAc,SAAA,EAAoB;AAC5C,IAAA,KAAA,CAAM,KAAA,CAAM,OAAA,EAAS,EAAE,KAAA,EAAO,OAAO,CAAA;AAJvC,IAAA,aAAA,CAAA,IAAA,EAAgB,WAAA,CAAA;AAChB,IAAA,aAAA,CAAA,IAAA,EAAyB,OAAA,CAAA;AAIvB,IAAA,IAAA,CAAK,IAAA,GAAO,uBAAA;AACZ,IAAA,IAAA,CAAK,SAAA,GAAY,SAAA;AACjB,IAAA,IAAA,CAAK,KAAA,GAAQ,KAAA;AACb,IAAA,IAAI,MAAM,KAAA,EAAO;AACf,MAAA,IAAA,CAAK,QAAQ,KAAA,CAAM,KAAA;AAAA,IACrB;AAAA,EACF;AACF;AAKO,SAAS,WAAA,CAAY,KAAA,EAAc,SAAA,GAAY,IAAA,EAA6B;AACjF,EAAA,OAAO,IAAI,qBAAA,CAAsB,KAAA,EAAO,SAAS,CAAA;AACnD;AAKO,SAAS,eAAe,KAAA,EAAqC;AAClE,EAAA,OAAO,IAAI,qBAAA,CAAsB,KAAA,EAAO,KAAK,CAAA;AAC/C;AAOO,SAAS,YAAY,KAAA,EAAqC;AAC/D,EAAA,IAAI,gBAAA,CAAiB,KAAK,CAAA,EAAG;AAC3B,IAAA,OAAO,KAAA,CAAM,SAAA;AAAA,EACf;AACA,EAAA,OAAO,MAAA;AACT;;;AC7GO,IAAM,UAAA,GAA4B;AAAA,EACvC,OAAO,MAAM,MAAA;AAAA,EACb,MAAM,MAAM,MAAA;AAAA,EACZ,MAAM,MAAM,MAAA;AAAA,EACZ,OAAO,MAAM;AACf;AAMO,IAAM,aAAA,GAA+B;AAAA,EAC1C,KAAA,EAAO,CAAC,GAAA,EAAK,OAAA,KAAY;AACvB,IAAA,IAAI,OAAA,EAAS;AACX,MAAA,OAAA,CAAQ,KAAA,CAAM,CAAA,UAAA,EAAa,GAAG,CAAA,CAAA,EAAI,OAAO,CAAA;AAAA,IAC3C,CAAA,MAAO;AACL,MAAA,OAAA,CAAQ,KAAA,CAAM,CAAA,UAAA,EAAa,GAAG,CAAA,CAAE,CAAA;AAAA,IAClC;AAAA,EACF,CAAA;AAAA,EACA,IAAA,EAAM,CAAC,GAAA,EAAK,OAAA,KAAY;AACtB,IAAA,IAAI,OAAA,EAAS;AACX,MAAA,OAAA,CAAQ,IAAA,CAAK,CAAA,UAAA,EAAa,GAAG,CAAA,CAAA,EAAI,OAAO,CAAA;AAAA,IAC1C,CAAA,MAAO;AACL,MAAA,OAAA,CAAQ,IAAA,CAAK,CAAA,UAAA,EAAa,GAAG,CAAA,CAAE,CAAA;AAAA,IACjC;AAAA,EACF,CAAA;AAAA,EACA,IAAA,EAAM,CAAC,GAAA,EAAK,OAAA,KAAY;AACtB,IAAA,IAAI,OAAA,EAAS;AACX,MAAA,OAAA,CAAQ,IAAA,CAAK,CAAA,UAAA,EAAa,GAAG,CAAA,CAAA,EAAI,OAAO,CAAA;AAAA,IAC1C,CAAA,MAAO;AACL,MAAA,OAAA,CAAQ,IAAA,CAAK,CAAA,UAAA,EAAa,GAAG,CAAA,CAAE,CAAA;AAAA,IACjC;AAAA,EACF,CAAA;AAAA,EACA,KAAA,EAAO,CAAC,GAAA,EAAK,OAAA,KAAY;AACvB,IAAA,IAAI,OAAA,EAAS;AACX,MAAA,OAAA,CAAQ,KAAA,CAAM,CAAA,UAAA,EAAa,GAAG,CAAA,CAAA,EAAI,OAAO,CAAA;AAAA,IAC3C,CAAA,MAAO;AACL,MAAA,OAAA,CAAQ,KAAA,CAAM,CAAA,UAAA,EAAa,GAAG,CAAA,CAAE,CAAA;AAAA,IAClC;AAAA,EACF;AACF;;;ACjFO,SAAS,KAAA,CAAM,IAAY,MAAA,EAAqC;AACrE,EAAA,OAAO,IAAI,OAAA,CAAQ,CAAC,OAAA,EAAS,MAAA,KAAW;AACtC,IAAA,IAAI,QAAQ,OAAA,EAAS;AACnB,MAAA,MAAA,CAAO,WAAA,CAAY,MAAA,CAAO,MAAM,CAAC,CAAA;AACjC,MAAA;AAAA,IACF;AAEA,IAAA,MAAM,SAAA,GAAY,UAAA,CAAW,OAAA,EAAS,EAAE,CAAA;AAExC,IAAA,MAAA,EAAQ,gBAAA;AAAA,MACN,OAAA;AAAA,MACA,MAAM;AACJ,QAAA,YAAA,CAAa,SAAS,CAAA;AACtB,QAAA,MAAA,CAAO,WAAA,CAAY,MAAA,CAAO,MAAM,CAAC,CAAA;AAAA,MACnC,CAAA;AAAA,MACA,EAAE,MAAM,IAAA;AAAK,KACf;AAAA,EACF,CAAC,CAAA;AACH;AAOA,SAAS,YAAY,MAAA,EAAwB;AAC3C,EAAA,IAAI,kBAAkB,KAAA,EAAO;AAC3B,IAAA,OAAO,MAAA;AAAA,EACT;AACA,EAAA,IAAI,OAAO,WAAW,QAAA,EAAU;AAC9B,IAAA,OAAO,IAAI,MAAM,MAAM,CAAA;AAAA,EACzB;AACA,EAAA,IAAI,MAAA,KAAW,MAAA,IAAa,MAAA,KAAW,IAAA,EAAM;AAE3C,IAAA,IAAI;AACF,MAAA,OAAO,IAAI,KAAA,CAAM,IAAA,CAAK,SAAA,CAAU,MAAM,CAAC,CAAA;AAAA,IACzC,CAAA,CAAA,MAAQ;AACN,MAAA,OAAO,IAAI,MAAM,eAAe,CAAA;AAAA,IAClC;AAAA,EACF;AACA,EAAA,OAAO,IAAI,YAAA,CAAa,SAAA,EAAW,YAAY,CAAA;AACjD;AAWA,eAAsB,WAAA,CACpB,OAAA,EACA,EAAA,EACA,MAAA,EACY;AAEZ,EAAA,IAAI,QAAQ,OAAA,EAAS;AACnB,IAAA,MAAM,WAAA,CAAY,OAAO,MAAM,CAAA;AAAA,EACjC;AAEA,EAAA,IAAI,SAAA;AAEJ,EAAA,MAAM,cAAA,GAAiB,IAAI,OAAA,CAAe,CAAC,GAAG,MAAA,KAAW;AACvD,IAAA,SAAA,GAAY,WAAW,MAAM;AAC3B,MAAA,MAAA,CAAO,IAAI,aAAa,CAAA,0BAAA,EAA6B,MAAA,CAAO,EAAE,CAAC,CAAA,EAAA,CAAA,EAAM,EAAE,CAAC,CAAA;AAAA,IAC1E,GAAG,EAAE,CAAA;AAAA,EACP,CAAC,CAAA;AAGD,EAAA,MAAM,eAAe,MAAA,GACjB,IAAI,OAAA,CAAe,CAAC,GAAG,MAAA,KAAW;AAChC,IAAA,MAAA,CAAO,gBAAA;AAAA,MACL,OAAA;AAAA,MACA,MAAM,MAAA,CAAO,WAAA,CAAY,MAAA,CAAO,MAAM,CAAC,CAAA;AAAA,MACvC,EAAE,MAAM,IAAA;AAAK,KACf;AAAA,EACF,CAAC,CAAA,GACD,IAAA;AAEJ,EAAA,IAAI;AACF,IAAA,MAAM,MAAA,GAAuB,CAAC,OAAA,EAAS,cAAc,CAAA;AACrD,IAAA,IAAI,YAAA,EAAc;AAChB,MAAA,MAAA,CAAO,KAAK,YAAY,CAAA;AAAA,IAC1B;AACA,IAAA,OAAO,MAAM,OAAA,CAAQ,IAAA,CAAK,MAAM,CAAA;AAAA,EAClC,CAAA,SAAE;AACA,IAAA,IAAI,cAAc,MAAA,EAAW;AAC3B,MAAA,YAAA,CAAa,SAAS,CAAA;AAAA,IACxB;AAAA,EACF;AACF;AAWA,eAAsB,kBAAA,CACpB,SAAA,EACA,EAAA,EACA,MAAA,EACY;AACZ,EAAA,MAAM,UAAA,GAAa,IAAI,eAAA,EAAgB;AAGvC,EAAA,MAAM,cAAA,GAAiB,cAAA,CAAe,MAAA,EAAQ,UAAA,CAAW,MAAM,CAAA;AAE/D,EAAA,MAAM,SAAA,GAAY,WAAW,MAAM;AACjC,IAAA,UAAA,CAAW,KAAA,CAAM,IAAI,YAAA,CAAa,CAAA,0BAAA,EAA6B,OAAO,EAAE,CAAC,CAAA,EAAA,CAAA,EAAM,EAAE,CAAC,CAAA;AAAA,EACpF,GAAG,EAAE,CAAA;AAEL,EAAA,IAAI;AACF,IAAA,OAAO,MAAM,UAAU,cAAc,CAAA;AAAA,EACvC,CAAA,SAAE;AACA,IAAA,YAAA,CAAa,SAAS,CAAA;AAAA,EACxB;AACF;AAYO,SAAS,kBAAkB,OAAA,EAAmD;AACnF,EAAA,MAAM,eAAe,OAAA,CAAQ,MAAA,CAAO,CAAC,CAAA,KAAwB,MAAM,MAAS,CAAA;AAE5E,EAAA,IAAI,YAAA,CAAa,WAAW,CAAA,EAAG;AAC7B,IAAA,OAAO,IAAI,iBAAgB,CAAE,MAAA;AAAA,EAC/B;AAEA,EAAA,MAAM,WAAA,GAAc,aAAa,CAAC,CAAA;AAClC,EAAA,IAAI,YAAA,CAAa,MAAA,KAAW,CAAA,IAAK,WAAA,EAAa;AAC5C,IAAA,OAAO,WAAA;AAAA,EACT;AAGA,EAAA,IAAI,SAAS,WAAA,EAAa;AACxB,IAAA,OAAO,WAAA,CAAY,IAAI,YAAY,CAAA;AAAA,EACrC;AAIA,EAAA,MAAM,UAAA,GAAa,IAAI,eAAA,EAAgB;AACvC,EAAA,MAAM,YAA6D,EAAC;AAGpE,EAAA,MAAM,UAAU,MAAM;AACpB,IAAA,KAAA,MAAW,EAAE,MAAA,EAAQ,QAAA,EAAS,IAAK,SAAA,EAAW;AAC5C,MAAA,MAAA,CAAO,mBAAA,CAAoB,SAAS,QAAQ,CAAA;AAAA,IAC9C;AACA,IAAA,SAAA,CAAU,MAAA,GAAS,CAAA;AAAA,EACrB,CAAA;AAEA,EAAA,KAAA,MAAW,UAAU,YAAA,EAAc;AACjC,IAAA,IAAI,OAAO,OAAA,EAAS;AAClB,MAAA,UAAA,CAAW,KAAA,CAAM,OAAO,MAAM,CAAA;AAC9B,MAAA,OAAO,UAAA,CAAW,MAAA;AAAA,IACpB;AAEA,IAAA,MAAM,WAAW,MAAM;AACrB,MAAA,OAAA,EAAQ;AACR,MAAA,UAAA,CAAW,KAAA,CAAM,OAAO,MAAM,CAAA;AAAA,IAChC,CAAA;AAEA,IAAA,SAAA,CAAU,IAAA,CAAK,EAAE,MAAA,EAAQ,QAAA,EAAU,CAAA;AACnC,IAAA,MAAA,CAAO,iBAAiB,OAAA,EAAS,QAAA,EAAU,EAAE,IAAA,EAAM,MAAM,CAAA;AAAA,EAC3D;AAEA,EAAA,OAAO,UAAA,CAAW,MAAA;AACpB;AAQO,SAAS,aAAa,KAAA,EAAyB;AACpD,EAAA,OACE,KAAA,YAAiB,YAAA,IACjB,KAAA,CAAM,IAAA,KAAS,YAAA;AAEnB;AASO,SAAS,eAAe,MAAA,EAAuC;AACpE,EAAA,IAAI,QAAQ,OAAA,EAAS;AACnB,IAAA,MAAM,MAAA,CAAO,MAAA,IAAU,IAAI,YAAA,CAAa,WAAW,YAAY,CAAA;AAAA,EACjE;AACF;AASO,SAAS,YAAA,CACd,UACA,OAAA,EACe;AACf,EAAA,IAAI,CAAC,UAAU,OAAO,MAAA;AAEtB,EAAA,QAAQ,IAAI,IAAA,KAAmD;AAC7D,IAAA,IAAI;AACF,MAAA,OAAO,QAAA,CAAS,GAAG,IAAI,CAAA;AAAA,IACzB,SAAS,KAAA,EAAO;AACd,MAAA,IAAI,OAAA,IAAW,iBAAiB,KAAA,EAAO;AACrC,QAAA,OAAA,CAAQ,KAAK,CAAA;AAAA,MACf;AACA,MAAA,OAAO,MAAA;AAAA,IACT;AAAA,EACF,CAAA;AACF;AASO,SAAS,UAAU,KAAA,EAAuB;AAC/C,EAAA,MAAM,YAAA,GAAe,CAAA,GAAI,IAAA,CAAK,MAAA,EAAO,GAAI,GAAA;AACzC,EAAA,OAAO,IAAA,CAAK,KAAA,CAAM,KAAA,GAAQ,YAAY,CAAA;AACxC;AAUO,SAAS,KAAA,CAAM,KAAA,EAAe,GAAA,EAAa,GAAA,EAAqB;AACrE,EAAA,OAAO,KAAK,GAAA,CAAI,IAAA,CAAK,IAAI,KAAA,EAAO,GAAG,GAAG,GAAG,CAAA;AAC3C;AAQO,SAAS,GAAA,GAAc;AAC5B,EAAA,IAAI,OAAO,WAAA,KAAgB,WAAA,IAAe,OAAO,WAAA,CAAY,QAAQ,UAAA,EAAY;AAC/E,IAAA,OAAO,YAAY,GAAA,EAAI;AAAA,EACzB;AACA,EAAA,OAAO,KAAK,GAAA,EAAI;AAClB;AC/QA,IAAM,cAAA,GAAiB,EAAE,QAAA,EAAS;AAM3B,IAAM,YAAA,GAAe,EAAE,MAAA,CAAO;AAAA,EACnC,KAAA,EAAO,cAAA;AAAA,EACP,IAAA,EAAM,cAAA;AAAA,EACN,IAAA,EAAM,cAAA;AAAA,EACN,KAAA,EAAO;AACT,CAAC,EAAE,QAAA;AAKI,IAAM,mBAAA,GAAsB,EAAE,MAAA,CAAO;AAAA;AAAA,EAE1C,cAAA,EAAgB,EAAE,MAAA,EAAO,CAAE,KAAI,CAAE,QAAA,EAAS,CAAE,OAAA,CAAQ,GAAK,CAAA;AAAA;AAAA,EAEzD,SAAA,EAAW,eAAe,QAAA,EAAS;AAAA;AAAA,EAEnC,MAAA,EAAQ;AACV,CAAC;AAOM,IAAM,sBAAsB,CAAA,CAAE,IAAA,CAAK,CAAC,aAAA,EAAe,QAAA,EAAU,UAAU,CAAC;AAOxE,IAAM,iBAAA,GAAoB,EAAE,MAAA,CAAO;AAAA;AAAA,EAExC,WAAA,EAAa,EAAE,MAAA,EAAO,CAAE,KAAI,CAAE,QAAA,EAAS,CAAE,OAAA,CAAQ,CAAC,CAAA;AAAA;AAAA,EAElD,YAAA,EAAc,EAAE,MAAA,EAAO,CAAE,KAAI,CAAE,QAAA,EAAS,CAAE,OAAA,CAAQ,GAAG,CAAA;AAAA;AAAA,EAErD,QAAA,EAAU,EAAE,MAAA,EAAO,CAAE,KAAI,CAAE,QAAA,GAAW,QAAA,EAAS;AAAA;AAAA,EAE/C,aAAA,EAAe,mBAAA,CAAoB,OAAA,CAAQ,aAAa,CAAA;AAAA;AAAA,EAExD,YAAY,CAAA,CAAE,MAAA,GAAS,QAAA,EAAS,CAAE,QAAQ,CAAG,CAAA;AAAA;AAAA,EAE7C,MAAA,EAAQ,CAAA,CAAE,OAAA,EAAQ,CAAE,QAAQ,KAAK,CAAA;AAAA;AAAA,EAEjC,WAAA,EAAa,eAAe,QAAA,EAAS;AAAA;AAAA,EAErC,OAAA,EAAS,eAAe,QAAA,EAAS;AAAA;AAAA,EAEjC,MAAA,EAAQ;AACV,CAAC;AAOM,IAAM,4BAA4B,CAAA,CAAE,IAAA,CAAK,CAAC,QAAA,EAAU,MAAA,EAAQ,WAAW,CAAC;AAOxE,IAAM,0BAAA,GAA6B,EAAE,MAAA,CAAO;AAAA,EACjD,UAAU,CAAA,CAAE,MAAA,EAAO,CAAE,GAAA,GAAM,WAAA,EAAY;AAAA,EACvC,gBAAgB,CAAA,CAAE,MAAA,EAAO,CAAE,GAAA,GAAM,WAAA,EAAY;AAAA,EAC7C,eAAe,CAAA,CAAE,MAAA,EAAO,CAAE,GAAA,GAAM,WAAA,EAAY;AAAA,EAC5C,sBAAsB,CAAA,CAAE,MAAA,EAAO,CAAE,GAAA,GAAM,WAAA,EAAY;AAAA,EACnD,qBAAqB,CAAA,CAAE,MAAA,EAAO,CAAE,GAAA,GAAM,WAAA;AACxC,CAAC;AAOM,IAAM,0BAAA,GAA6B,EAAE,MAAA,CAAO;AAAA;AAAA,EAEjD,WAAA,EAAa,EAAE,MAAA,EAAO,CAAE,KAAI,CAAE,QAAA,EAAS,CAAE,OAAA,CAAQ,CAAC,CAAA;AAAA;AAAA,EAElD,OAAA,EAAS,EAAE,MAAA,EAAO,CAAE,KAAI,CAAE,QAAA,EAAS,CAAE,OAAA,CAAQ,GAAK,CAAA;AAAA;AAAA,EAElD,mBAAA,EAAqB,EAAE,MAAA,EAAO,CAAE,KAAI,CAAE,QAAA,EAAS,CAAE,OAAA,CAAQ,CAAC,CAAA;AAAA;AAAA,EAE1D,QAAA,EAAU,EAAE,MAAA,EAAO,CAAE,KAAI,CAAE,WAAA,EAAY,CAAE,OAAA,CAAQ,CAAC,CAAA;AAAA;AAAA,EAElD,WAAA,EAAa,eAAe,QAAA,EAAS;AAAA;AAAA,EAErC,YAAA,EAAc,eAAe,QAAA,EAAS;AAAA;AAAA,EAEtC,aAAA,EAAe,eAAe,QAAA,EAAS;AAAA;AAAA,EAEvC,MAAA,EAAQ;AACV,CAAC;AAOM,IAAM,qBAAA,GAAwB,EAAE,MAAA,CAAO;AAAA;AAAA,EAE5C,IAAA,EAAM,EAAE,MAAA,EAAO,CAAE,KAAI,CAAE,QAAA,EAAS,CAAE,OAAA,CAAQ,GAAG,CAAA;AAAA;AAAA,EAE7C,KAAA,EAAO,EAAE,MAAA,EAAO,CAAE,KAAI,CAAE,QAAA,GAAW,QAAA,EAAS;AAAA;AAAA,EAE5C,QAAA,EAAU,EAAE,MAAA,EAAO,CAAE,KAAI,CAAE,QAAA,EAAS,CAAE,OAAA,CAAQ,GAAI,CAAA;AAAA;AAAA,EAElD,OAAA,EAAS,eAAe,QAAA,EAAS;AAAA;AAAA,EAEjC,MAAA,EAAQ;AACV,CAAC;AAOM,IAAM,oBAAA,GAAuB,EAAE,MAAA,CAAO;AAAA;AAAA,EAE3C,aAAA,EAAe,EAAE,MAAA,EAAO,CAAE,KAAI,CAAE,QAAA,EAAS,CAAE,OAAA,CAAQ,EAAE,CAAA;AAAA;AAAA,EAErD,QAAA,EAAU,EAAE,MAAA,EAAO,CAAE,KAAI,CAAE,WAAA,EAAY,CAAE,OAAA,CAAQ,CAAC,CAAA;AAAA;AAAA,EAElD,YAAA,EAAc,EAAE,MAAA,EAAO,CAAE,KAAI,CAAE,QAAA,GAAW,QAAA,EAAS;AAAA;AAAA,EAEnD,UAAA,EAAY,eAAe,QAAA,EAAS;AAAA;AAAA,EAEpC,MAAA,EAAQ;AACV,CAAC;AAOM,IAAM,oBAAA,GAAuB,EAAE,MAAA,CAAO;AAAA;AAAA,EAE3C,QAAA,EAAU,cAAA;AAAA;AAAA,EAEV,cAAA,EAAgB,eAAe,QAAA,EAAS;AAAA;AAAA,EAExC,UAAA,EAAY,eAAe,QAAA,EAAS;AAAA;AAAA,EAEpC,SAAA,EAAW,eAAe,QAAA,EAAS;AAAA;AAAA,EAEnC,MAAA,EAAQ;AACV,CAAC","file":"index.js","sourcesContent":["/*\n Base error class for all Fortify errors.\n /\nexport class FortifyError extends Error {\n constructor(message: string) {\n super(message);\n this.name = 'FortifyError';\n // Maintains proper stack trace for where our error was thrown (only available on V8)\n // Use typeof check to avoid unnecessary-condition lint error\n if (typeof Error.captureStackTrace === 'function') {\n Error.captureStackTrace(this, this.constructor);\n }\n }\n}\n\n/\n Error thrown when circuit breaker is in open state and rejecting requests.\n /\nexport class CircuitOpenError extends FortifyError {\n constructor(message = 'Circuit breaker is open') {\n super(message);\n this.name = 'CircuitOpenError';\n }\n}\n\n/\n Error thrown when rate limit is exceeded.\n /\nexport class RateLimitExceededError extends FortifyError {\n public readonly key: string \| undefined;\n\n constructor(message = 'Rate limit exceeded', key?: string) {\n super(message);\n this.name = 'RateLimitExceededError';\n this.key = key;\n }\n}\n\n/\n Error thrown when bulkhead is at capacity.\n /\nexport class BulkheadFullError extends FortifyError {\n public readonly activeCount: number;\n public readonly queuedCount: number;\n\n constructor(\n message = 'Bulkhead is full',\n activeCount = 0,\n queuedCount = 0\n ) {\n super(message);\n this.name = 'BulkheadFullError';\n this.activeCount = activeCount;\n this.queuedCount = queuedCount;\n }\n}\n\n/\n Error thrown when operation times out.\n /\nexport class TimeoutError extends FortifyError {\n public readonly timeoutMs: number;\n\n constructor(message = 'Operation timed out', timeoutMs = 0) {\n super(message);\n this.name = 'TimeoutError';\n this.timeoutMs = timeoutMs;\n }\n}\n\n/\n Error thrown when maximum retry attempts are reached.\n /\nexport class MaxAttemptsReachedError extends FortifyError {\n public readonly attempts: number;\n public readonly lastError: Error \| undefined;\n\n constructor(\n message = 'Maximum retry attempts reached',\n attempts = 0,\n lastError?: Error\n ) {\n super(message);\n this.name = 'MaxAttemptsReachedError';\n this.attempts = attempts;\n this.lastError = lastError;\n }\n}\n\n/\n Error thrown when bulkhead is closed and no new operations accepted.\n /\nexport class BulkheadClosedError extends FortifyError {\n constructor(message = 'Bulkhead is closed') {\n super(message);\n this.name = 'BulkheadClosedError';\n }\n}\n\n/\n Interface for errors that can indicate whether they are retryable.\n /\nexport interface RetryableError {\n retryable: boolean;\n}\n\n/\n Type guard to check if an error implements RetryableError interface.\n /\nexport function isRetryableError(error: unknown): error is Error & RetryableError {\n return (\n error instanceof Error &&\n 'retryable' in error &&\n typeof (error as RetryableError).retryable === 'boolean'\n );\n}\n\n/\n Wrapper class to mark an error as retryable.\n /\nexport class RetryableErrorWrapper extends Error implements RetryableError {\n public readonly retryable: boolean;\n public override readonly cause: Error;\n\n constructor(error: Error, retryable: boolean) {\n super(error.message, { cause: error });\n this.name = 'RetryableErrorWrapper';\n this.retryable = retryable;\n this.cause = error;\n if (error.stack) {\n this.stack = error.stack;\n }\n }\n}\n\n/\n Wrap an error as retryable.\n /\nexport function asRetryable(error: Error, retryable = true): RetryableErrorWrapper {\n return new RetryableErrorWrapper(error, retryable);\n}\n\n/\n Wrap an error as non-retryable.\n /\nexport function asNonRetryable(error: Error): RetryableErrorWrapper {\n return new RetryableErrorWrapper(error, false);\n}\n\n/\n Check if an error is retryable.\n * Returns true if the error implements RetryableError and retryable is true.\n * Returns undefined if the error doesn't implement RetryableError (let caller decide).\n /\nexport function isRetryable(error: unknown): boolean \| undefined {\n if (isRetryableError(error)) {\n return error.retryable;\n }\n return undefined;\n}\n","/\n Represents an async operation that can be executed with cancellation support.\n * The signal parameter allows the operation to be cancelled via AbortController.\n \n @template T - The return type of the operation\n /\nexport type Operation<T> = (signal: AbortSignal) => Promise<T>;\n\n/\n Callback for state changes in stateful patterns (e.g., circuit breaker).\n \n @template S - The state type\n /\nexport type StateChangeCallback<S> = (from: S, to: S) => void;\n\n/\n Callback for error events.\n /\nexport type ErrorCallback = (error: Error) => void;\n\n/\n Simple void callback.\n /\nexport type VoidCallback = () => void;\n\n/\n Callback for retry events.\n /\nexport type RetryCallback = (attempt: number, error: Error) => void;\n\n/\n Callback for rate limit events.\n /\nexport type RateLimitCallback = (key: string) => void;\n\n/\n Logger interface for structured logging across all patterns.\n * Compatible with pino, winston, console, and custom implementations.\n /\nexport interface FortifyLogger {\n debug(msg: string, context?: Record<string, unknown>): void;\n info(msg: string, context?: Record<string, unknown>): void;\n warn(msg: string, context?: Record<string, unknown>): void;\n error(msg: string, context?: Record<string, unknown>): void;\n}\n\n/\n No-operation logger that discards all log messages.\n * Useful for testing or when logging is not needed.\n /\nexport const noopLogger: FortifyLogger = {\n debug: () => undefined,\n info: () => undefined,\n warn: () => undefined,\n error: () => undefined,\n};\n\n/\n Console-based logger implementation.\n * Browser-friendly and works in all environments.\n /\nexport const consoleLogger: FortifyLogger = {\n debug: (msg, context) => {\n if (context) {\n console.debug(`[fortify] ${msg}`, context);\n } else {\n console.debug(`[fortify] ${msg}`);\n }\n },\n info: (msg, context) => {\n if (context) {\n console.info(`[fortify] ${msg}`, context);\n } else {\n console.info(`[fortify] ${msg}`);\n }\n },\n warn: (msg, context) => {\n if (context) {\n console.warn(`[fortify] ${msg}`, context);\n } else {\n console.warn(`[fortify] ${msg}`);\n }\n },\n error: (msg, context) => {\n if (context) {\n console.error(`[fortify] ${msg}`, context);\n } else {\n console.error(`[fortify] ${msg}`);\n }\n },\n};\n\n/\n Generic pattern interface that all resilience patterns implement.\n \n @template T - The return type of the operation\n /\nexport interface Pattern<T> {\n /\n Execute an operation with the pattern's resilience logic.\n \n @param operation - The async operation to execute\n * @param signal - Optional AbortSignal for cancellation\n * @returns Promise resolving to the operation result\n /\n execute(operation: Operation<T>, signal?: AbortSignal): Promise<T>;\n}\n\n/\n Interface for patterns that support closing/cleanup.\n /\nexport interface Closeable {\n /\n Close the pattern and release resources.\n * May wait for in-flight operations to complete.\n /\n close(): Promise<void>;\n}\n\n/\n Interface for patterns that support resetting state.\n /\nexport interface Resettable {\n /\n Reset the pattern to its initial state.\n /\n reset(): void;\n}\n","import { TimeoutError } from './errors.js';\n\n/\n Sleep for a specified duration with optional cancellation support.\n \n @param ms - Duration in milliseconds\n * @param signal - Optional AbortSignal for cancellation\n * @returns Promise that resolves after the delay or rejects if cancelled\n /\nexport function sleep(ms: number, signal?: AbortSignal): Promise<void> {\n return new Promise((resolve, reject) => {\n if (signal?.aborted) {\n reject(ensureError(signal.reason));\n return;\n }\n\n const timeoutId = setTimeout(resolve, ms);\n\n signal?.addEventListener(\n 'abort',\n () => {\n clearTimeout(timeoutId);\n reject(ensureError(signal.reason));\n },\n { once: true }\n );\n });\n}\n\n/\n Ensure a value is an Error instance.\n * @param reason - The reason to convert to an Error\n * @returns An Error instance\n /\nfunction ensureError(reason: unknown): Error {\n if (reason instanceof Error) {\n return reason;\n }\n if (typeof reason === 'string') {\n return new Error(reason);\n }\n if (reason !== undefined && reason !== null) {\n // Handle objects and other types safely\n try {\n return new Error(JSON.stringify(reason));\n } catch {\n return new Error('Unknown error');\n }\n }\n return new DOMException('Aborted', 'AbortError');\n}\n\n/\n Wrap a promise with a timeout.\n \n @template T - The promise return type\n * @param promise - The promise to wrap\n * @param ms - Timeout duration in milliseconds\n * @param signal - Optional external AbortSignal for cancellation\n * @returns Promise that resolves with the result or rejects with TimeoutError\n /\nexport async function withTimeout<T>(\n promise: Promise<T>,\n ms: number,\n signal?: AbortSignal\n): Promise<T> {\n // Check if already aborted\n if (signal?.aborted) {\n throw ensureError(signal.reason);\n }\n\n let timeoutId: ReturnType<typeof setTimeout> \| undefined;\n\n const timeoutPromise = new Promise<never>((_, reject) => {\n timeoutId = setTimeout(() => {\n reject(new TimeoutError(`Operation timed out after ${String(ms)}ms`, ms));\n }, ms);\n });\n\n // Handle external signal\n const abortPromise = signal\n ? new Promise<never>((_, reject) => {\n signal.addEventListener(\n 'abort',\n () => reject(ensureError(signal.reason)),\n { once: true }\n );\n })\n : null;\n\n try {\n const racers: Promise<T>[] = [promise, timeoutPromise];\n if (abortPromise) {\n racers.push(abortPromise);\n }\n return await Promise.race(racers);\n } finally {\n if (timeoutId !== undefined) {\n clearTimeout(timeoutId);\n }\n }\n}\n\n/\n Execute an operation with a timeout, passing the combined signal to the operation.\n \n @template T - The operation return type\n * @param operation - The operation to execute\n * @param ms - Timeout duration in milliseconds\n * @param signal - Optional external AbortSignal for cancellation\n * @returns Promise that resolves with the result or rejects with TimeoutError\n /\nexport async function executeWithTimeout<T>(\n operation: (signal: AbortSignal) => Promise<T>,\n ms: number,\n signal?: AbortSignal\n): Promise<T> {\n const controller = new AbortController();\n\n // Combine signals\n const combinedSignal = combineSignals(signal, controller.signal);\n\n const timeoutId = setTimeout(() => {\n controller.abort(new TimeoutError(`Operation timed out after ${String(ms)}ms`, ms));\n }, ms);\n\n try {\n return await operation(combinedSignal);\n } finally {\n clearTimeout(timeoutId);\n }\n}\n\n/\n Combine multiple AbortSignals into one.\n * Returns a signal that aborts when any of the input signals abort.\n \n Uses AbortSignal.any() when available (Node 20+, modern browsers).\n * Falls back to a manual implementation that properly cleans up event listeners.\n \n @param signals - AbortSignals to combine (undefined values are filtered out)\n * @returns Combined AbortSignal\n /\nexport function combineSignals(...signals: (AbortSignal \| undefined)[]): AbortSignal {\n const validSignals = signals.filter((s): s is AbortSignal => s !== undefined);\n\n if (validSignals.length === 0) {\n return new AbortController().signal;\n }\n\n const firstSignal = validSignals[0];\n if (validSignals.length === 1 && firstSignal) {\n return firstSignal;\n }\n\n // Use AbortSignal.any if available (Node 20+, modern browsers)\n if ('any' in AbortSignal) {\n return AbortSignal.any(validSignals);\n }\n\n // Fallback: create a new controller and link it to all signals\n // Track listeners so we can clean them up to prevent memory leaks\n const controller = new AbortController();\n const listeners: { signal: AbortSignal; listener: () => void }[] = [];\n\n // Cleanup function to remove all listeners\n const cleanup = () => {\n for (const { signal, listener } of listeners) {\n signal.removeEventListener('abort', listener);\n }\n listeners.length = 0;\n };\n\n for (const signal of validSignals) {\n if (signal.aborted) {\n controller.abort(signal.reason);\n return controller.signal;\n }\n\n const listener = () => {\n cleanup(); // Clean up all listeners when any signal aborts\n controller.abort(signal.reason);\n };\n\n listeners.push({ signal, listener });\n signal.addEventListener('abort', listener, { once: true });\n }\n\n return controller.signal;\n}\n\n/\n Check if an error is an abort error (from AbortController).\n \n @param error - Error to check\n * @returns True if the error is an AbortError\n /\nexport function isAbortError(error: unknown): boolean {\n return (\n error instanceof DOMException &&\n error.name === 'AbortError'\n );\n}\n\n/\n Throw if the given signal is aborted.\n * Useful for checking signal state early in operations to avoid unnecessary work.\n \n @param signal - AbortSignal to check\n * @throws {DOMException} If signal is aborted (AbortError)\n /\nexport function throwIfAborted(signal: AbortSignal \| undefined): void {\n if (signal?.aborted) {\n throw signal.reason ?? new DOMException('Aborted', 'AbortError');\n }\n}\n\n/\n Safely execute a callback, catching and logging any errors.\n * Used for user-provided callbacks to prevent them from breaking the pattern.\n \n @param callback - Callback to execute\n * @param onError - Optional error handler\n /\nexport function safeCallback<T extends (...args: unknown[]) => unknown>(\n callback: T \| undefined,\n onError?: (error: Error) => void\n): T \| undefined {\n if (!callback) return undefined;\n\n return ((...args: Parameters<T>): ReturnType<T> \| undefined => {\n try {\n return callback(...args) as ReturnType<T>;\n } catch (error) {\n if (onError && error instanceof Error) {\n onError(error);\n }\n return undefined;\n }\n }) as T;\n}\n\n/\n Calculate jittered delay.\n * Adds 0-10% random variance to prevent thundering herd.\n \n @param delay - Base delay in milliseconds\n * @returns Jittered delay\n /\nexport function addJitter(delay: number): number {\n const jitterFactor = 1 + Math.random() 0.1; // 0-10% jitter\n return Math.floor(delay * jitterFactor);\n}\n\n/*\n Clamp a number between min and max values.\n \n @param value - Value to clamp\n * @param min - Minimum value\n * @param max - Maximum value\n * @returns Clamped value\n /\nexport function clamp(value: number, min: number, max: number): number {\n return Math.min(Math.max(value, min), max);\n}\n\n/\n Get current timestamp in milliseconds.\n * Uses performance.now() if available for higher precision.\n \n @returns Current timestamp in milliseconds\n /\nexport function now(): number {\n if (typeof performance !== 'undefined' && typeof performance.now === 'function') {\n return performance.now();\n }\n return Date.now();\n}\n","import { z } from 'zod';\n\n/\n Schema for a function type (Zod 4 compatible).\n * Uses z.function() which validates that the value is a function.\n /\nconst functionSchema = z.function();\n\n/\n Base schema for logger configuration.\n * Validates that the logger has the required methods.\n /\nexport const loggerSchema = z.object({\n debug: functionSchema,\n info: functionSchema,\n warn: functionSchema,\n error: functionSchema,\n}).optional();\n\n/\n Schema for timeout configuration.\n /\nexport const timeoutConfigSchema = z.object({\n /* Default timeout in milliseconds (default: 30000) /\n defaultTimeout: z.number().int().positive().default(30000),\n /* Callback when timeout occurs /\n onTimeout: functionSchema.optional(),\n /* Logger instance /\n logger: loggerSchema,\n});\n\nexport type TimeoutConfig = z.infer<typeof timeoutConfigSchema>;\n\n/\n Schema for retry backoff policy.\n /\nexport const backoffPolicySchema = z.enum(['exponential', 'linear', 'constant']);\n\nexport type BackoffPolicy = z.infer<typeof backoffPolicySchema>;\n\n/\n Schema for retry configuration.\n /\nexport const retryConfigSchema = z.object({\n /* Maximum number of attempts including the first (default: 3) /\n maxAttempts: z.number().int().positive().default(3),\n /* Initial delay before first retry in milliseconds (default: 100) /\n initialDelay: z.number().int().positive().default(100),\n /* Maximum delay between retries in milliseconds /\n maxDelay: z.number().int().positive().optional(),\n /* Backoff strategy (default: 'exponential') /\n backoffPolicy: backoffPolicySchema.default('exponential'),\n /* Multiplier for exponential backoff (default: 2.0) /\n multiplier: z.number().positive().default(2.0),\n /* Add random jitter to delays (default: false) /\n jitter: z.boolean().default(false),\n /* Custom function to determine if error is retryable /\n isRetryable: functionSchema.optional(),\n /* Callback on each retry attempt /\n onRetry: functionSchema.optional(),\n /* Logger instance /\n logger: loggerSchema,\n});\n\nexport type RetryConfig = z.infer<typeof retryConfigSchema>;\n\n/\n Schema for circuit breaker state.\n /\nexport const circuitBreakerStateSchema = z.enum(['closed', 'open', 'half-open']);\n\nexport type CircuitBreakerState = z.infer<typeof circuitBreakerStateSchema>;\n\n/\n Schema for circuit breaker counts/metrics.\n /\nexport const circuitBreakerCountsSchema = z.object({\n requests: z.number().int().nonnegative(),\n totalSuccesses: z.number().int().nonnegative(),\n totalFailures: z.number().int().nonnegative(),\n consecutiveSuccesses: z.number().int().nonnegative(),\n consecutiveFailures: z.number().int().nonnegative(),\n});\n\nexport type CircuitBreakerCounts = z.infer<typeof circuitBreakerCountsSchema>;\n\n/\n Schema for circuit breaker configuration.\n /\nexport const circuitBreakerConfigSchema = z.object({\n /* Maximum consecutive failures before opening (default: 5) /\n maxFailures: z.number().int().positive().default(5),\n /* Duration in open state before transitioning to half-open in milliseconds (default: 60000) /\n timeout: z.number().int().positive().default(60000),\n /* Maximum requests allowed in half-open state (default: 1) /\n halfOpenMaxRequests: z.number().int().positive().default(1),\n /* Period to clear counts when closed, 0 means never (default: 0) /\n interval: z.number().int().nonnegative().default(0),\n /* Custom function to determine when to trip the breaker /\n readyToTrip: functionSchema.optional(),\n /* Custom function to determine if result is successful /\n isSuccessful: functionSchema.optional(),\n /* Callback on state change /\n onStateChange: functionSchema.optional(),\n /* Logger instance /\n logger: loggerSchema,\n});\n\nexport type CircuitBreakerConfig = z.infer<typeof circuitBreakerConfigSchema>;\n\n/\n Schema for rate limiter configuration.\n /\nexport const rateLimitConfigSchema = z.object({\n /* Number of tokens added per interval (default: 100) /\n rate: z.number().int().positive().default(100),\n /* Maximum bucket capacity (defaults to rate) /\n burst: z.number().int().positive().optional(),\n /* Interval for token refill in milliseconds (default: 1000) /\n interval: z.number().int().positive().default(1000),\n /* Callback when rate limit is hit /\n onLimit: functionSchema.optional(),\n /* Logger instance /\n logger: loggerSchema,\n});\n\nexport type RateLimitConfig = z.infer<typeof rateLimitConfigSchema>;\n\n/\n Schema for bulkhead configuration.\n /\nexport const bulkheadConfigSchema = z.object({\n /* Maximum concurrent executions (default: 10) /\n maxConcurrent: z.number().int().positive().default(10),\n /* Maximum queued requests, 0 means no queueing (default: 0) /\n maxQueue: z.number().int().nonnegative().default(0),\n /* Maximum time to wait in queue in milliseconds /\n queueTimeout: z.number().int().positive().optional(),\n /* Callback when request is rejected /\n onRejected: functionSchema.optional(),\n /* Logger instance /\n logger: loggerSchema,\n});\n\nexport type BulkheadConfig = z.infer<typeof bulkheadConfigSchema>;\n\n/\n Schema for fallback configuration.\n /\nexport const fallbackConfigSchema = z.object({\n /* Fallback function to execute when primary fails /\n fallback: functionSchema,\n /* Custom function to determine if fallback should be used /\n shouldFallback: functionSchema.optional(),\n /* Callback when fallback is triggered /\n onFallback: functionSchema.optional(),\n /* Callback when primary succeeds /\n onSuccess: functionSchema.optional(),\n /* Logger instance */\n logger: loggerSchema,\n});\n\nexport type FallbackConfig = z.infer<typeof fallbackConfigSchema>;\n"]}

+2

-2

package.json

		{
		"name": "@fortify-ts/core",
		"version": "0.1.1",
		"version": "0.1.2",
		"description": "Core types, errors, and utilities for Fortify TS resilience library",
		@@ -33,3 +33,3 @@ "type": "module",
		"peerDependencies": {
		"zod": "^3.24.0"
		"zod": "^4.0.0"
		},
		@@ -36,0 +36,0 @@ "keywords": [

@fortify-ts/core - npm Package Compare versions

Improved metrics