Big News: Socket raises $60M Series C at a $1B valuation to secure software supply chains for AI-driven development.Announcement
Sign In

ontologic

Package Overview
Dependencies
Maintainers
1
Versions
13
Alerts
File Explorer

Advanced tools

Socket logo

Install Socket

Detect and block malicious and high-risk dependencies

Install

ontologic - npm Package Compare versions

Comparing version
1.2.0
to
1.2.1
+1
-1
dist/domainEntity.d.ts.map

@@ -1,1 +0,1 @@

{"version":3,"file":"domainEntity.d.ts","sourceRoot":"","sources":["../src/domainEntity.ts"],"names":[],"mappings":"AAAA,OAAO,EAAE,eAAe,EAAE,MAAM,8BAA8B,CAAC;AAE/D,MAAM,WAAW,aAAa;IAC5B,EAAE,IAAI,MAAM,CAAC;IACb,SAAS,IAAI,OAAO,CAAC;IACrB,YAAY,CAAC,SAAS,EAAE,eAAe,CAAC,OAAO,CAAC,GAAG,IAAI,CAAA;CACxD;AAED,qBAAa,YAAY,CAAC,KAAK,CAAE,YAAW,aAAa;;IAGvD,SAAS,CAAC,KAAK,EAAE,KAAK,CAAC;gBAEX,EAAE,EAAE,MAAM,EAAE,KAAK,EAAE,KAAK,EAAE,UAAU,CAAC,EAAE,eAAe,CAAC,KAAK,CAAC,EAAE;IAO3E,EAAE,IAAI,MAAM;IAIZ,SAAS,IAAI,KAAK;IAKlB,YAAY,CAAC,SAAS,EAAE,eAAe,CAAC,KAAK,CAAC;IAI9C,OAAO,CAAC,eAAe;CASxB"}
{"version":3,"file":"domainEntity.d.ts","sourceRoot":"","sources":["../src/domainEntity.ts"],"names":[],"mappings":"AAAA,OAAO,EAAE,eAAe,EAAE,MAAM,8BAA8B,CAAC;AAE/D,MAAM,WAAW,aAAa;IAC5B,EAAE,IAAI,MAAM,CAAC;IACb,SAAS,IAAI,OAAO,CAAC;IACrB,YAAY,CAAC,SAAS,EAAE,eAAe,CAAC,OAAO,CAAC,GAAG,IAAI,CAAC;CACzD;AAED,qBAAa,YAAY,CAAC,KAAK,CAAE,YAAW,aAAa;;IAGvD,SAAS,CAAC,KAAK,EAAE,KAAK,CAAC;gBAEX,EAAE,EAAE,MAAM,EAAE,KAAK,EAAE,KAAK,EAAE,UAAU,CAAC,EAAE,eAAe,CAAC,KAAK,CAAC,EAAE;IAO3E,EAAE,IAAI,MAAM;IAIZ,SAAS,IAAI,KAAK;IAKlB,YAAY,CAAC,SAAS,EAAE,eAAe,CAAC,KAAK,CAAC;IAI9C,OAAO,CAAC,eAAe;CAWxB"}

@@ -25,6 +25,6 @@ "use strict";

checkInvariants() {
const isValid = this.#invariants.every(invariant => invariant.complyWith(this.state).isCompliant);
const isValid = this.#invariants.every((invariant) => invariant.complyWith(this.state).isCompliant);
if (!isValid) {
throw new Error('Corrupted state detected', {
cause: this.state
throw new Error("Corrupted state detected", {
cause: this.state,
});

@@ -31,0 +31,0 @@ }

@@ -1,1 +0,1 @@

{"version":3,"file":"domainEntity.js","sourceRoot":"","sources":["../src/domainEntity.ts"],"names":[],"mappings":";;;AAQA,MAAa,YAAY;IACvB,GAAG,CAAS;IACZ,WAAW,CAA2B;IAC5B,KAAK,CAAQ;IAEvB,YAAY,EAAU,EAAE,KAAY,EAAE,UAAqC;QACzE,IAAI,CAAC,GAAG,GAAG,EAAE,CAAC;QACd,IAAI,CAAC,KAAK,GAAG,eAAe,CAAC,KAAK,CAAC,CAAC,CAAC,uCAAuC;QAC5E,IAAI,CAAC,WAAW,GAAG,UAAU,IAAI,EAAE,CAAC;QACpC,IAAI,CAAC,eAAe,EAAE,CAAC;IACzB,CAAC;IAED,EAAE;QACA,OAAO,IAAI,CAAC,GAAG,CAAC;IAClB,CAAC;IAED,SAAS;QACP,IAAI,CAAC,eAAe,EAAE,CAAC;QACvB,OAAO,eAAe,CAAC,IAAI,CAAC,KAAK,CAAC,CAAC;IACrC,CAAC;IAED,YAAY,CAAC,SAAiC;QAC5C,IAAI,CAAC,WAAW,CAAC,IAAI,CAAC,SAAS,CAAC,CAAC;IACnC,CAAC;IAEO,eAAe;QACrB,MAAM,OAAO,GAAG,IAAI,CAAC,WAAW,CAAC,KAAK,CAAC,SAAS,CAAC,EAAE,CAAC,SAAS,CAAC,UAAU,CAAC,IAAI,CAAC,KAAK,CAAC,CAAC,WAAW,CAAC,CAAC;QAElG,IAAI,CAAC,OAAO,EAAE,CAAC;YACb,MAAM,IAAI,KAAK,CAAC,0BAA0B,EAAC;gBACzC,KAAK,EAAC,IAAI,CAAC,KAAK;aACjB,CAAC,CAAA;QACJ,CAAC;IACH,CAAC;CACF;AAlCD,oCAkCC"}
{"version":3,"file":"domainEntity.js","sourceRoot":"","sources":["../src/domainEntity.ts"],"names":[],"mappings":";;;AAQA,MAAa,YAAY;IACvB,GAAG,CAAS;IACZ,WAAW,CAA2B;IAC5B,KAAK,CAAQ;IAEvB,YAAY,EAAU,EAAE,KAAY,EAAE,UAAqC;QACzE,IAAI,CAAC,GAAG,GAAG,EAAE,CAAC;QACd,IAAI,CAAC,KAAK,GAAG,eAAe,CAAC,KAAK,CAAC,CAAC,CAAC,uCAAuC;QAC5E,IAAI,CAAC,WAAW,GAAG,UAAU,IAAI,EAAE,CAAC;QACpC,IAAI,CAAC,eAAe,EAAE,CAAC;IACzB,CAAC;IAED,EAAE;QACA,OAAO,IAAI,CAAC,GAAG,CAAC;IAClB,CAAC;IAED,SAAS;QACP,IAAI,CAAC,eAAe,EAAE,CAAC;QACvB,OAAO,eAAe,CAAC,IAAI,CAAC,KAAK,CAAC,CAAC;IACrC,CAAC;IAED,YAAY,CAAC,SAAiC;QAC5C,IAAI,CAAC,WAAW,CAAC,IAAI,CAAC,SAAS,CAAC,CAAC;IACnC,CAAC;IAEO,eAAe;QACrB,MAAM,OAAO,GAAG,IAAI,CAAC,WAAW,CAAC,KAAK,CACpC,CAAC,SAAS,EAAE,EAAE,CAAC,SAAS,CAAC,UAAU,CAAC,IAAI,CAAC,KAAK,CAAC,CAAC,WAAW,CAC5D,CAAC;QAEF,IAAI,CAAC,OAAO,EAAE,CAAC;YACb,MAAM,IAAI,KAAK,CAAC,0BAA0B,EAAE;gBAC1C,KAAK,EAAE,IAAI,CAAC,KAAK;aAClB,CAAC,CAAC;QACL,CAAC;IACH,CAAC;CACF;AApCD,oCAoCC"}

@@ -1,1 +0,1 @@

{"version":3,"file":"domainEvent.d.ts","sourceRoot":"","sources":["../src/domainEvent.ts"],"names":[],"mappings":"AAAA,MAAM,WAAW,oBAAoB;IACnC,IAAI,EAAE,MAAM,CAAC;IACb,OAAO,EAAE,MAAM,CAAC;IAChB,QAAQ,EAAE,MAAM,CAAC;IACjB,OAAO,EAAE,OAAO,CAAC;CAClB;AAED,qBAAa,WAAW,CAAC,IAAI,SAAS,MAAM,EAAE,OAAO,SAAS,MAAM,EAAE,OAAO,CAAE,YAAW,oBAAoB;;gBAMhG,MAAM,EAAE;QAAE,QAAQ,EAAE,MAAM,CAAC;QAAC,IAAI,EAAE,IAAI,CAAC;QAAC,OAAO,EAAE,OAAO,CAAC;QAAC,OAAO,EAAE,OAAO,CAAA;KAAE;IAQxF,IAAI,QAAQ,IAAI,MAAM,CAErB;IAED,IAAI,IAAI,IAAI,IAAI,CAEf;IAED,IAAI,OAAO,IAAI,OAAO,CAErB;IAED,IAAI,OAAO,IAAI,OAAO,CAErB;IAED,MAAM,IAAI;QAAE,QAAQ,EAAE,MAAM,CAAC;QAAC,IAAI,EAAE,IAAI,CAAC;QAAC,OAAO,EAAE,OAAO,CAAC;QAAC,OAAO,EAAE,OAAO,CAAA;KAAE;CAQ/E"}
{"version":3,"file":"domainEvent.d.ts","sourceRoot":"","sources":["../src/domainEvent.ts"],"names":[],"mappings":"AAAA,MAAM,WAAW,oBAAoB;IACnC,IAAI,EAAE,MAAM,CAAC;IACb,OAAO,EAAE,MAAM,CAAC;IAChB,QAAQ,EAAE,MAAM,CAAC;IACjB,OAAO,EAAE,OAAO,CAAC;CAClB;AAED,qBAAa,WAAW,CACtB,IAAI,SAAS,MAAM,EACnB,OAAO,SAAS,MAAM,EACtB,OAAO,CACP,YAAW,oBAAoB;;gBAMnB,MAAM,EAAE;QAClB,QAAQ,EAAE,MAAM,CAAC;QACjB,IAAI,EAAE,IAAI,CAAC;QACX,OAAO,EAAE,OAAO,CAAC;QACjB,OAAO,EAAE,OAAO,CAAC;KAClB;IAQD,IAAI,QAAQ,IAAI,MAAM,CAErB;IAED,IAAI,IAAI,IAAI,IAAI,CAEf;IAED,IAAI,OAAO,IAAI,OAAO,CAErB;IAED,IAAI,OAAO,IAAI,OAAO,CAErB;IAED,MAAM,IAAI;QACR,QAAQ,EAAE,MAAM,CAAC;QACjB,IAAI,EAAE,IAAI,CAAC;QACX,OAAO,EAAE,OAAO,CAAC;QACjB,OAAO,EAAE,OAAO,CAAC;KAClB;CAQF"}

@@ -1,1 +0,1 @@

{"version":3,"file":"domainEvent.js","sourceRoot":"","sources":["../src/domainEvent.ts"],"names":[],"mappings":";;;AAOA,MAAa,WAAW;IACtB,SAAS,CAAS;IAClB,KAAK,CAAO;IACZ,QAAQ,CAAU;IAClB,QAAQ,CAAU;IAElB,YAAY,MAA4E;QACtF,MAAM,EAAE,IAAI,EAAE,OAAO,EAAE,OAAO,EAAE,QAAQ,EAAE,GAAG,MAAM,CAAC;QACpD,IAAI,CAAC,SAAS,GAAG,QAAQ,CAAC;QAC1B,IAAI,CAAC,KAAK,GAAG,IAAI,CAAC;QAClB,IAAI,CAAC,QAAQ,GAAG,OAAO,CAAC;QACxB,IAAI,CAAC,QAAQ,GAAG,eAAe,CAAC,OAAO,CAAC,CAAC,CAAC,uCAAuC;IACnF,CAAC;IAED,IAAI,QAAQ;QACV,OAAO,IAAI,CAAC,SAAS,CAAC;IACxB,CAAC;IAED,IAAI,IAAI;QACN,OAAO,IAAI,CAAC,KAAK,CAAC;IACpB,CAAC;IAED,IAAI,OAAO;QACT,OAAO,IAAI,CAAC,QAAQ,CAAC;IACvB,CAAC;IAED,IAAI,OAAO;QACT,OAAO,eAAe,CAAC,IAAI,CAAC,QAAQ,CAAC,CAAC;IACxC,CAAC;IAED,MAAM;QACJ,OAAO;YACL,QAAQ,EAAE,IAAI,CAAC,SAAS;YACxB,IAAI,EAAE,IAAI,CAAC,KAAK;YAChB,OAAO,EAAE,IAAI,CAAC,QAAQ;YACtB,OAAO,EAAE,IAAI,CAAC,OAAO;SACtB,CAAC;IACJ,CAAC;CACF;AAtCD,kCAsCC"}
{"version":3,"file":"domainEvent.js","sourceRoot":"","sources":["../src/domainEvent.ts"],"names":[],"mappings":";;;AAOA,MAAa,WAAW;IAKtB,SAAS,CAAS;IAClB,KAAK,CAAO;IACZ,QAAQ,CAAU;IAClB,QAAQ,CAAU;IAElB,YAAY,MAKX;QACC,MAAM,EAAE,IAAI,EAAE,OAAO,EAAE,OAAO,EAAE,QAAQ,EAAE,GAAG,MAAM,CAAC;QACpD,IAAI,CAAC,SAAS,GAAG,QAAQ,CAAC;QAC1B,IAAI,CAAC,KAAK,GAAG,IAAI,CAAC;QAClB,IAAI,CAAC,QAAQ,GAAG,OAAO,CAAC;QACxB,IAAI,CAAC,QAAQ,GAAG,eAAe,CAAC,OAAO,CAAC,CAAC,CAAC,uCAAuC;IACnF,CAAC;IAED,IAAI,QAAQ;QACV,OAAO,IAAI,CAAC,SAAS,CAAC;IACxB,CAAC;IAED,IAAI,IAAI;QACN,OAAO,IAAI,CAAC,KAAK,CAAC;IACpB,CAAC;IAED,IAAI,OAAO;QACT,OAAO,IAAI,CAAC,QAAQ,CAAC;IACvB,CAAC;IAED,IAAI,OAAO;QACT,OAAO,eAAe,CAAC,IAAI,CAAC,QAAQ,CAAC,CAAC;IACxC,CAAC;IAED,MAAM;QAMJ,OAAO;YACL,QAAQ,EAAE,IAAI,CAAC,SAAS;YACxB,IAAI,EAAE,IAAI,CAAC,KAAK;YAChB,OAAO,EAAE,IAAI,CAAC,QAAQ;YACtB,OAAO,EAAE,IAAI,CAAC,OAAO;SACtB,CAAC;IACJ,CAAC;CACF;AApDD,kCAoDC"}

@@ -1,1 +0,1 @@

{"version":3,"file":"composedDomainInvariant.d.ts","sourceRoot":"","sources":["../../src/domainInvariant/composedDomainInvariant.ts"],"names":[],"mappings":"AACA,OAAO,EAAE,eAAe,EAAE,oBAAoB,EAAE,MAAM,cAAc,CAAC;AAOrE,qBAAa,uBAAuB,CAAC,KAAK,CAAE,YAAW,eAAe,CAAC,KAAK,CAAC;;gBAG/D,UAAU,EAAE,CAAC,KAAK,EAAE,KAAK,KAAK,oBAAoB;IAI9D,UAAU,CAAC,KAAK,EAAE,KAAK,GAAG,oBAAoB;IAI9C,GAAG,CAAC,SAAS,EAAE,eAAe,CAAC,KAAK,CAAC,GAAG,eAAe,CAAC,KAAK,CAAC;IAI9D,EAAE,CAAC,SAAS,EAAE,eAAe,CAAC,KAAK,CAAC,GAAG,eAAe,CAAC,KAAK,CAAC;IAI7D,GAAG,IAAI,eAAe,CAAC,KAAK,CAAC;IAI7B,GAAG,CAAC,SAAS,EAAE,eAAe,CAAC,KAAK,CAAC,GAAG,eAAe,CAAC,KAAK,CAAC;IAI9D,MAAM,CAAC,SAAS,EAAE,eAAe,CAAC,KAAK,CAAC,GAAG,eAAe,CAAC,KAAK,CAAC;CAGlE"}
{"version":3,"file":"composedDomainInvariant.d.ts","sourceRoot":"","sources":["../../src/domainInvariant/composedDomainInvariant.ts"],"names":[],"mappings":"AAAA,OAAO,EAAE,eAAe,EAAE,oBAAoB,EAAE,MAAM,cAAc,CAAC;AAOrE,qBAAa,uBAAuB,CAAC,KAAK,CAAE,YAAW,eAAe,CAAC,KAAK,CAAC;;gBAG/D,UAAU,EAAE,CAAC,KAAK,EAAE,KAAK,KAAK,oBAAoB;IAI9D,UAAU,CAAC,KAAK,EAAE,KAAK,GAAG,oBAAoB;IAI9C,GAAG,CAAC,SAAS,EAAE,eAAe,CAAC,KAAK,CAAC,GAAG,eAAe,CAAC,KAAK,CAAC;IAI9D,EAAE,CAAC,SAAS,EAAE,eAAe,CAAC,KAAK,CAAC,GAAG,eAAe,CAAC,KAAK,CAAC;IAI7D,GAAG,IAAI,eAAe,CAAC,KAAK,CAAC;IAI7B,GAAG,CAAC,SAAS,EAAE,eAAe,CAAC,KAAK,CAAC,GAAG,eAAe,CAAC,KAAK,CAAC;IAI9D,MAAM,CAAC,SAAS,EAAE,eAAe,CAAC,KAAK,CAAC,GAAG,eAAe,CAAC,KAAK,CAAC;CAGlE"}

@@ -1,1 +0,1 @@

{"version":3,"file":"composedDomainInvariant.js","sourceRoot":"","sources":["../../src/domainInvariant/composedDomainInvariant.ts"],"names":[],"mappings":";;;AAEA,yCAAsC;AACtC,uCAAoC;AACpC,yCAAsC;AACtC,yCAAsC;AACtC,+CAA4C;AAE5C,MAAa,uBAAuB;IAClC,UAAU,CAA0C;IAEpD,YAAY,UAAkD;QAC5D,IAAI,CAAC,UAAU,GAAG,UAAU,CAAC;IAC/B,CAAC;IAED,UAAU,CAAC,KAAY;QACrB,OAAO,IAAI,CAAC,UAAU,CAAC,KAAK,CAAC,CAAC;IAChC,CAAC;IAED,GAAG,CAAC,SAAiC;QACnC,OAAO,IAAA,SAAG,EAAC,IAAI,EAAE,SAAS,CAAC,CAAC;IAC9B,CAAC;IAED,EAAE,CAAC,SAAiC;QAClC,OAAO,IAAA,OAAE,EAAC,IAAI,EAAE,SAAS,CAAC,CAAC;IAC7B,CAAC;IAED,GAAG;QACD,OAAO,IAAA,SAAG,EAAC,IAAI,CAAC,CAAC;IACnB,CAAC;IAED,GAAG,CAAC,SAAiC;QACnC,OAAO,IAAA,SAAG,EAAC,IAAI,EAAE,SAAS,CAAC,CAAC;IAC9B,CAAC;IAED,MAAM,CAAC,SAAiC;QACtC,OAAO,IAAA,eAAM,EAAC,IAAI,EAAE,SAAS,CAAC,CAAC;IACjC,CAAC;CACF;AA9BD,0DA8BC"}
{"version":3,"file":"composedDomainInvariant.js","sourceRoot":"","sources":["../../src/domainInvariant/composedDomainInvariant.ts"],"names":[],"mappings":";;;AACA,yCAAsC;AACtC,uCAAoC;AACpC,yCAAsC;AACtC,yCAAsC;AACtC,+CAA4C;AAE5C,MAAa,uBAAuB;IAClC,UAAU,CAAyC;IAEnD,YAAY,UAAkD;QAC5D,IAAI,CAAC,UAAU,GAAG,UAAU,CAAC;IAC/B,CAAC;IAED,UAAU,CAAC,KAAY;QACrB,OAAO,IAAI,CAAC,UAAU,CAAC,KAAK,CAAC,CAAC;IAChC,CAAC;IAED,GAAG,CAAC,SAAiC;QACnC,OAAO,IAAA,SAAG,EAAC,IAAI,EAAE,SAAS,CAAC,CAAC;IAC9B,CAAC;IAED,EAAE,CAAC,SAAiC;QAClC,OAAO,IAAA,OAAE,EAAC,IAAI,EAAE,SAAS,CAAC,CAAC;IAC7B,CAAC;IAED,GAAG;QACD,OAAO,IAAA,SAAG,EAAC,IAAI,CAAC,CAAC;IACnB,CAAC;IAED,GAAG,CAAC,SAAiC;QACnC,OAAO,IAAA,SAAG,EAAC,IAAI,EAAE,SAAS,CAAC,CAAC;IAC9B,CAAC;IAED,MAAM,CAAC,SAAiC;QACtC,OAAO,IAAA,eAAM,EAAC,IAAI,EAAE,SAAS,CAAC,CAAC;IACjC,CAAC;CACF;AA9BD,0DA8BC"}

@@ -1,2 +0,2 @@

import { InvariantCheckResult, DomainInvariant } from './interfaces';
import { InvariantCheckResult, DomainInvariant } from "./interfaces";
export declare class BaseDomainInvariant<State> implements DomainInvariant<State> {

@@ -3,0 +3,0 @@ #private;

@@ -1,1 +0,1 @@

{"version":3,"file":"index.d.ts","sourceRoot":"","sources":["../../src/domainInvariant/index.ts"],"names":[],"mappings":"AAAA,OAAO,EAAC,oBAAoB,EAAE,eAAe,EAAC,MAAM,cAAc,CAAC;AAQnE,qBAAa,mBAAmB,CAAC,KAAK,CAAE,YAAW,eAAe,CAAC,KAAK,CAAC;;gBAG3D,WAAW,EAAE,MAAM,EAAE,UAAU,EAAE,CAAC,KAAK,EAAE,KAAK,KAAK,OAAO;IAYtE,UAAU,CAAC,KAAK,EAAE,KAAK,GAAG,oBAAoB;IAI9C,GAAG,CAAC,SAAS,EAAE,eAAe,CAAC,KAAK,CAAC,GAAG,eAAe,CAAC,KAAK,CAAC;IAI9D,EAAE,CAAC,SAAS,EAAE,eAAe,CAAC,KAAK,CAAC,GAAG,eAAe,CAAC,KAAK,CAAC;IAI7D,GAAG,IAAI,eAAe,CAAC,KAAK,CAAC;IAI7B,GAAG,CAAC,SAAS,EAAE,eAAe,CAAC,KAAK,CAAC,GAAG,eAAe,CAAC,KAAK,CAAC;IAI9D,MAAM,CAAC,SAAS,EAAE,eAAe,CAAC,KAAK,CAAC,GAAG,eAAe,CAAC,KAAK,CAAC;CAGlE"}
{"version":3,"file":"index.d.ts","sourceRoot":"","sources":["../../src/domainInvariant/index.ts"],"names":[],"mappings":"AAAA,OAAO,EAAE,oBAAoB,EAAE,eAAe,EAAE,MAAM,cAAc,CAAC;AAQrE,qBAAa,mBAAmB,CAAC,KAAK,CAAE,YAAW,eAAe,CAAC,KAAK,CAAC;;gBAG3D,WAAW,EAAE,MAAM,EAAE,UAAU,EAAE,CAAC,KAAK,EAAE,KAAK,KAAK,OAAO;IAWtE,UAAU,CAAC,KAAK,EAAE,KAAK,GAAG,oBAAoB;IAI9C,GAAG,CAAC,SAAS,EAAE,eAAe,CAAC,KAAK,CAAC,GAAG,eAAe,CAAC,KAAK,CAAC;IAI9D,EAAE,CAAC,SAAS,EAAE,eAAe,CAAC,KAAK,CAAC,GAAG,eAAe,CAAC,KAAK,CAAC;IAI7D,GAAG,IAAI,eAAe,CAAC,KAAK,CAAC;IAI7B,GAAG,CAAC,SAAS,EAAE,eAAe,CAAC,KAAK,CAAC,GAAG,eAAe,CAAC,KAAK,CAAC;IAI9D,MAAM,CAAC,SAAS,EAAE,eAAe,CAAC,KAAK,CAAC,GAAG,eAAe,CAAC,KAAK,CAAC;CAGlE"}

@@ -1,1 +0,1 @@

{"version":3,"file":"index.js","sourceRoot":"","sources":["../../src/domainInvariant/index.ts"],"names":[],"mappings":";;;AAEA,yCAAoC;AACpC,uCAAkC;AAClC,yCAAoC;AACpC,yCAAoC;AACpC,+CAA0C;AAE1C,MAAa,mBAAmB;IAC9B,UAAU,CAA0C;IAEpD,YAAY,WAAmB,EAAE,UAAqC;QACpE,IAAI,CAAC,UAAU,GAAG,CAAC,KAAY,EAAE,EAAE;YAEjC,MAAM,WAAW,GAAG,UAAU,CAAC,KAAK,CAAC,CAAC;YAEtC,OAAO;gBACL,WAAW;gBACX,WAAW;aACZ,CAAC;QACJ,CAAC,CAAC;IACJ,CAAC;IAED,UAAU,CAAC,KAAY;QACrB,OAAO,IAAI,CAAC,UAAU,CAAC,KAAK,CAAC,CAAC;IAChC,CAAC;IAED,GAAG,CAAC,SAAiC;QACnC,OAAO,IAAA,SAAG,EAAC,IAAI,EAAE,SAAS,CAAC,CAAC;IAC9B,CAAC;IAED,EAAE,CAAC,SAAiC;QAClC,OAAO,IAAA,OAAE,EAAC,IAAI,EAAE,SAAS,CAAC,CAAC;IAC7B,CAAC;IAED,GAAG;QACD,OAAO,IAAA,SAAG,EAAC,IAAI,CAAC,CAAC;IACnB,CAAC;IAED,GAAG,CAAC,SAAiC;QACnC,OAAO,IAAA,SAAG,EAAC,IAAI,EAAE,SAAS,CAAC,CAAC;IAC9B,CAAC;IAED,MAAM,CAAC,SAAiC;QACtC,OAAO,IAAA,eAAM,EAAC,IAAI,EAAE,SAAS,CAAC,CAAC;IACjC,CAAC;CACF;AAtCD,kDAsCC"}
{"version":3,"file":"index.js","sourceRoot":"","sources":["../../src/domainInvariant/index.ts"],"names":[],"mappings":";;;AAEA,yCAAsC;AACtC,uCAAoC;AACpC,yCAAsC;AACtC,yCAAsC;AACtC,+CAA4C;AAE5C,MAAa,mBAAmB;IAC9B,UAAU,CAAyC;IAEnD,YAAY,WAAmB,EAAE,UAAqC;QACpE,IAAI,CAAC,UAAU,GAAG,CAAC,KAAY,EAAE,EAAE;YACjC,MAAM,WAAW,GAAG,UAAU,CAAC,KAAK,CAAC,CAAC;YAEtC,OAAO;gBACL,WAAW;gBACX,WAAW;aACZ,CAAC;QACJ,CAAC,CAAC;IACJ,CAAC;IAED,UAAU,CAAC,KAAY;QACrB,OAAO,IAAI,CAAC,UAAU,CAAC,KAAK,CAAC,CAAC;IAChC,CAAC;IAED,GAAG,CAAC,SAAiC;QACnC,OAAO,IAAA,SAAG,EAAC,IAAI,EAAE,SAAS,CAAC,CAAC;IAC9B,CAAC;IAED,EAAE,CAAC,SAAiC;QAClC,OAAO,IAAA,OAAE,EAAC,IAAI,EAAE,SAAS,CAAC,CAAC;IAC7B,CAAC;IAED,GAAG;QACD,OAAO,IAAA,SAAG,EAAC,IAAI,CAAC,CAAC;IACnB,CAAC;IAED,GAAG,CAAC,SAAiC;QACnC,OAAO,IAAA,SAAG,EAAC,IAAI,EAAE,SAAS,CAAC,CAAC;IAC9B,CAAC;IAED,MAAM,CAAC,SAAiC;QACtC,OAAO,IAAA,eAAM,EAAC,IAAI,EAAE,SAAS,CAAC,CAAC;IACjC,CAAC;CACF;AArCD,kDAqCC"}

@@ -1,1 +0,1 @@

{"version":3,"file":"interfaces.d.ts","sourceRoot":"","sources":["../../src/domainInvariant/interfaces.ts"],"names":[],"mappings":"AAAA,MAAM,WAAW,eAAe,CAAC,KAAK;IACpC,UAAU,CAAC,KAAK,EAAE,KAAK,GAAG,oBAAoB,CAAA;IAC9C,GAAG,CAAC,SAAS,EAAE,eAAe,CAAC,KAAK,CAAC,GAAG,eAAe,CAAC,KAAK,CAAC,CAAC;IAC/D,EAAE,CAAC,SAAS,EAAE,eAAe,CAAC,KAAK,CAAC,GAAG,eAAe,CAAC,KAAK,CAAC,CAAC;IAC9D,GAAG,IAAI,eAAe,CAAC,KAAK,CAAC,CAAC;IAC9B,GAAG,CAAC,SAAS,EAAE,eAAe,CAAC,KAAK,CAAC,GAAG,eAAe,CAAC,KAAK,CAAC,CAAC;IAC/D,MAAM,CAAC,SAAS,EAAE,eAAe,CAAC,KAAK,CAAC,GAAG,eAAe,CAAC,KAAK,CAAC,CAAC;CACnE;AAED,MAAM,WAAW,oBAAoB;IACnC,QAAQ,CAAC,EAAE,MAAM,CAAC;IAClB,WAAW,EAAE,OAAO,CAAC;IACrB,WAAW,EAAE,MAAM,CAAC;CACrB"}
{"version":3,"file":"interfaces.d.ts","sourceRoot":"","sources":["../../src/domainInvariant/interfaces.ts"],"names":[],"mappings":"AAAA,MAAM,WAAW,eAAe,CAAC,KAAK;IACpC,UAAU,CAAC,KAAK,EAAE,KAAK,GAAG,oBAAoB,CAAC;IAC/C,GAAG,CAAC,SAAS,EAAE,eAAe,CAAC,KAAK,CAAC,GAAG,eAAe,CAAC,KAAK,CAAC,CAAC;IAC/D,EAAE,CAAC,SAAS,EAAE,eAAe,CAAC,KAAK,CAAC,GAAG,eAAe,CAAC,KAAK,CAAC,CAAC;IAC9D,GAAG,IAAI,eAAe,CAAC,KAAK,CAAC,CAAC;IAC9B,GAAG,CAAC,SAAS,EAAE,eAAe,CAAC,KAAK,CAAC,GAAG,eAAe,CAAC,KAAK,CAAC,CAAC;IAC/D,MAAM,CAAC,SAAS,EAAE,eAAe,CAAC,KAAK,CAAC,GAAG,eAAe,CAAC,KAAK,CAAC,CAAC;CACnE;AAED,MAAM,WAAW,oBAAoB;IACnC,QAAQ,CAAC,EAAE,MAAM,CAAC;IAClB,WAAW,EAAE,OAAO,CAAC;IACrB,WAAW,EAAE,MAAM,CAAC;CACrB"}

@@ -1,1 +0,1 @@

{"version":3,"file":"and.d.ts","sourceRoot":"","sources":["../../../src/domainInvariant/operators/and.ts"],"names":[],"mappings":"AAAA,OAAO,EAAE,eAAe,EAAwB,MAAM,eAAe,CAAC;AAGtE,wBAAgB,GAAG,CAAC,KAAK,EAAE,UAAU,EAAE,eAAe,CAAC,KAAK,CAAC,EAAE,UAAU,EAAE,eAAe,CAAC,KAAK,CAAC,GAAG,eAAe,CAAC,KAAK,CAAC,CAazH"}
{"version":3,"file":"and.d.ts","sourceRoot":"","sources":["../../../src/domainInvariant/operators/and.ts"],"names":[],"mappings":"AAAA,OAAO,EAAE,eAAe,EAAwB,MAAM,eAAe,CAAC;AAGtE,wBAAgB,GAAG,CAAC,KAAK,EACvB,UAAU,EAAE,eAAe,CAAC,KAAK,CAAC,EAClC,UAAU,EAAE,eAAe,CAAC,KAAK,CAAC,GACjC,eAAe,CAAC,KAAK,CAAC,CAaxB"}

@@ -11,3 +11,3 @@ "use strict";

isCompliant: AResult.isCompliant && BResult.isCompliant,
operator: 'AND',
operator: "AND",
description: `${AResult.description} AND (${BResult.description})`,

@@ -14,0 +14,0 @@ };

@@ -1,1 +0,1 @@

{"version":3,"file":"and.js","sourceRoot":"","sources":["../../../src/domainInvariant/operators/and.ts"],"names":[],"mappings":";;AAGA,kBAaC;AAfD,wEAAqE;AAErE,SAAgB,GAAG,CAAQ,UAAkC,EAAE,UAAkC;IAC/F,MAAM,kBAAkB,GAAG,CAAC,KAAY,EAAwB,EAAE;QAChE,MAAM,OAAO,GAAG,UAAU,CAAC,UAAU,CAAC,KAAK,CAAC,CAAC;QAC7C,MAAM,OAAO,GAAG,UAAU,CAAC,UAAU,CAAC,KAAK,CAAC,CAAC;QAE7C,OAAO;YACL,WAAW,EAAE,OAAO,CAAC,WAAW,IAAI,OAAO,CAAC,WAAW;YACvD,QAAQ,EAAE,KAAK;YACf,WAAW,EAAE,GAAG,OAAO,CAAC,WAAW,SAAS,OAAO,CAAC,WAAW,GAAG;SACnE,CAAA;IACH,CAAC,CAAA;IAED,OAAO,IAAI,iDAAuB,CAAQ,kBAAkB,CAAC,CAAC;AAChE,CAAC"}
{"version":3,"file":"and.js","sourceRoot":"","sources":["../../../src/domainInvariant/operators/and.ts"],"names":[],"mappings":";;AAGA,kBAgBC;AAlBD,wEAAqE;AAErE,SAAgB,GAAG,CACjB,UAAkC,EAClC,UAAkC;IAElC,MAAM,kBAAkB,GAAG,CAAC,KAAY,EAAwB,EAAE;QAChE,MAAM,OAAO,GAAG,UAAU,CAAC,UAAU,CAAC,KAAK,CAAC,CAAC;QAC7C,MAAM,OAAO,GAAG,UAAU,CAAC,UAAU,CAAC,KAAK,CAAC,CAAC;QAE7C,OAAO;YACL,WAAW,EAAE,OAAO,CAAC,WAAW,IAAI,OAAO,CAAC,WAAW;YACvD,QAAQ,EAAE,KAAK;YACf,WAAW,EAAE,GAAG,OAAO,CAAC,WAAW,SAAS,OAAO,CAAC,WAAW,GAAG;SACnE,CAAC;IACJ,CAAC,CAAC;IAEF,OAAO,IAAI,iDAAuB,CAAQ,kBAAkB,CAAC,CAAC;AAChE,CAAC"}

@@ -1,1 +0,1 @@

{"version":3,"file":"andNot.d.ts","sourceRoot":"","sources":["../../../src/domainInvariant/operators/andNot.ts"],"names":[],"mappings":"AAAA,OAAO,EAAE,eAAe,EAAwB,MAAM,eAAe,CAAC;AAGtE,wBAAgB,MAAM,CAAC,KAAK,EAAE,UAAU,EAAE,eAAe,CAAC,KAAK,CAAC,EAAE,UAAU,EAAE,eAAe,CAAC,KAAK,CAAC,GAAG,eAAe,CAAC,KAAK,CAAC,CAa5H"}
{"version":3,"file":"andNot.d.ts","sourceRoot":"","sources":["../../../src/domainInvariant/operators/andNot.ts"],"names":[],"mappings":"AAAA,OAAO,EAAE,eAAe,EAAwB,MAAM,eAAe,CAAC;AAGtE,wBAAgB,MAAM,CAAC,KAAK,EAC1B,UAAU,EAAE,eAAe,CAAC,KAAK,CAAC,EAClC,UAAU,EAAE,eAAe,CAAC,KAAK,CAAC,GACjC,eAAe,CAAC,KAAK,CAAC,CAaxB"}

@@ -11,3 +11,3 @@ "use strict";

isCompliant: AResult.isCompliant && !BResult.isCompliant,
operator: 'AND NOT',
operator: "AND NOT",
description: `${AResult.description} AND NOT (${BResult.description})`,

@@ -14,0 +14,0 @@ };

@@ -1,1 +0,1 @@

{"version":3,"file":"andNot.js","sourceRoot":"","sources":["../../../src/domainInvariant/operators/andNot.ts"],"names":[],"mappings":";;AAGA,wBAaC;AAfD,wEAAqE;AAErE,SAAgB,MAAM,CAAQ,UAAkC,EAAE,UAAkC;IAClG,MAAM,kBAAkB,GAAG,CAAC,KAAY,EAAwB,EAAE;QAChE,MAAM,OAAO,GAAG,UAAU,CAAC,UAAU,CAAC,KAAK,CAAC,CAAC;QAC7C,MAAM,OAAO,GAAG,UAAU,CAAC,UAAU,CAAC,KAAK,CAAC,CAAC;QAE7C,OAAO;YACL,WAAW,EAAE,OAAO,CAAC,WAAW,IAAI,CAAC,OAAO,CAAC,WAAW;YACxD,QAAQ,EAAE,SAAS;YACnB,WAAW,EAAE,GAAG,OAAO,CAAC,WAAW,aAAa,OAAO,CAAC,WAAW,GAAG;SACvE,CAAA;IACH,CAAC,CAAA;IAED,OAAO,IAAI,iDAAuB,CAAQ,kBAAkB,CAAC,CAAC;AAChE,CAAC"}
{"version":3,"file":"andNot.js","sourceRoot":"","sources":["../../../src/domainInvariant/operators/andNot.ts"],"names":[],"mappings":";;AAGA,wBAgBC;AAlBD,wEAAqE;AAErE,SAAgB,MAAM,CACpB,UAAkC,EAClC,UAAkC;IAElC,MAAM,kBAAkB,GAAG,CAAC,KAAY,EAAwB,EAAE;QAChE,MAAM,OAAO,GAAG,UAAU,CAAC,UAAU,CAAC,KAAK,CAAC,CAAC;QAC7C,MAAM,OAAO,GAAG,UAAU,CAAC,UAAU,CAAC,KAAK,CAAC,CAAC;QAE7C,OAAO;YACL,WAAW,EAAE,OAAO,CAAC,WAAW,IAAI,CAAC,OAAO,CAAC,WAAW;YACxD,QAAQ,EAAE,SAAS;YACnB,WAAW,EAAE,GAAG,OAAO,CAAC,WAAW,aAAa,OAAO,CAAC,WAAW,GAAG;SACvE,CAAC;IACJ,CAAC,CAAC;IAEF,OAAO,IAAI,iDAAuB,CAAQ,kBAAkB,CAAC,CAAC;AAChE,CAAC"}

@@ -1,1 +0,1 @@

{"version":3,"file":"not.d.ts","sourceRoot":"","sources":["../../../src/domainInvariant/operators/not.ts"],"names":[],"mappings":"AAAA,OAAO,EAAE,eAAe,EAAwB,MAAM,eAAe,CAAC;AAGtE,wBAAgB,GAAG,CAAC,KAAK,EAAE,SAAS,EAAE,eAAe,CAAC,KAAK,CAAC,GAAG,eAAe,CAAC,KAAK,CAAC,CAapF"}
{"version":3,"file":"not.d.ts","sourceRoot":"","sources":["../../../src/domainInvariant/operators/not.ts"],"names":[],"mappings":"AAAA,OAAO,EAAE,eAAe,EAAwB,MAAM,eAAe,CAAC;AAGtE,wBAAgB,GAAG,CAAC,KAAK,EACvB,SAAS,EAAE,eAAe,CAAC,KAAK,CAAC,GAChC,eAAe,CAAC,KAAK,CAAC,CAYxB"}

@@ -9,3 +9,3 @@ "use strict";

return {
operator: 'NOT',
operator: "NOT",
isCompliant: !result.isCompliant,

@@ -12,0 +12,0 @@ description: `NOT (${result.description})`,

@@ -1,1 +0,1 @@

{"version":3,"file":"not.js","sourceRoot":"","sources":["../../../src/domainInvariant/operators/not.ts"],"names":[],"mappings":";;AAGA,kBAaC;AAfD,wEAAqE;AAErE,SAAgB,GAAG,CAAQ,SAAiC;IAC1D,MAAM,kBAAkB,GAAG,CAAC,KAAY,EAAwB,EAAE;QAChE,MAAM,MAAM,GAAG,SAAS,CAAC,UAAU,CAAC,KAAK,CAAC,CAAC;QAE3C,OAAO;YACL,QAAQ,EAAE,KAAK;YACf,WAAW,EAAE,CAAC,MAAM,CAAC,WAAW;YAChC,WAAW,EAAE,QAAQ,MAAM,CAAC,WAAW,GAAG;SAC3C,CAAA;IAEH,CAAC,CAAA;IAED,OAAO,IAAI,iDAAuB,CAAQ,kBAAkB,CAAC,CAAC;AAChE,CAAC"}
{"version":3,"file":"not.js","sourceRoot":"","sources":["../../../src/domainInvariant/operators/not.ts"],"names":[],"mappings":";;AAGA,kBAcC;AAhBD,wEAAqE;AAErE,SAAgB,GAAG,CACjB,SAAiC;IAEjC,MAAM,kBAAkB,GAAG,CAAC,KAAY,EAAwB,EAAE;QAChE,MAAM,MAAM,GAAG,SAAS,CAAC,UAAU,CAAC,KAAK,CAAC,CAAC;QAE3C,OAAO;YACL,QAAQ,EAAE,KAAK;YACf,WAAW,EAAE,CAAC,MAAM,CAAC,WAAW;YAChC,WAAW,EAAE,QAAQ,MAAM,CAAC,WAAW,GAAG;SAC3C,CAAC;IACJ,CAAC,CAAC;IAEF,OAAO,IAAI,iDAAuB,CAAQ,kBAAkB,CAAC,CAAC;AAChE,CAAC"}

@@ -1,1 +0,1 @@

{"version":3,"file":"or.d.ts","sourceRoot":"","sources":["../../../src/domainInvariant/operators/or.ts"],"names":[],"mappings":"AAAA,OAAO,EAAE,eAAe,EAAwB,MAAM,eAAe,CAAC;AAGtE,wBAAgB,EAAE,CAAC,KAAK,EAAE,UAAU,EAAE,eAAe,CAAC,KAAK,CAAC,EAAE,UAAU,EAAE,eAAe,CAAC,KAAK,CAAC,GAAG,eAAe,CAAC,KAAK,CAAC,CAaxH"}
{"version":3,"file":"or.d.ts","sourceRoot":"","sources":["../../../src/domainInvariant/operators/or.ts"],"names":[],"mappings":"AAAA,OAAO,EAAE,eAAe,EAAwB,MAAM,eAAe,CAAC;AAGtE,wBAAgB,EAAE,CAAC,KAAK,EACtB,UAAU,EAAE,eAAe,CAAC,KAAK,CAAC,EAClC,UAAU,EAAE,eAAe,CAAC,KAAK,CAAC,GACjC,eAAe,CAAC,KAAK,CAAC,CAaxB"}

@@ -11,3 +11,3 @@ "use strict";

isCompliant: AResult.isCompliant || BResult.isCompliant,
operator: 'OR',
operator: "OR",
description: `${AResult.description} OR (${BResult.description})`,

@@ -14,0 +14,0 @@ };

@@ -1,1 +0,1 @@

{"version":3,"file":"or.js","sourceRoot":"","sources":["../../../src/domainInvariant/operators/or.ts"],"names":[],"mappings":";;AAGA,gBAaC;AAfD,wEAAqE;AAErE,SAAgB,EAAE,CAAQ,UAAkC,EAAE,UAAkC;IAC9F,MAAM,kBAAkB,GAAG,CAAC,KAAY,EAAwB,EAAE;QAChE,MAAM,OAAO,GAAG,UAAU,CAAC,UAAU,CAAC,KAAK,CAAC,CAAC;QAC7C,MAAM,OAAO,GAAG,UAAU,CAAC,UAAU,CAAC,KAAK,CAAC,CAAC;QAE7C,OAAO;YACL,WAAW,EAAE,OAAO,CAAC,WAAW,IAAI,OAAO,CAAC,WAAW;YACvD,QAAQ,EAAE,IAAI;YACd,WAAW,EAAE,GAAG,OAAO,CAAC,WAAW,QAAQ,OAAO,CAAC,WAAW,GAAG;SAClE,CAAA;IACH,CAAC,CAAA;IAED,OAAO,IAAI,iDAAuB,CAAQ,kBAAkB,CAAC,CAAC;AAChE,CAAC"}
{"version":3,"file":"or.js","sourceRoot":"","sources":["../../../src/domainInvariant/operators/or.ts"],"names":[],"mappings":";;AAGA,gBAgBC;AAlBD,wEAAqE;AAErE,SAAgB,EAAE,CAChB,UAAkC,EAClC,UAAkC;IAElC,MAAM,kBAAkB,GAAG,CAAC,KAAY,EAAwB,EAAE;QAChE,MAAM,OAAO,GAAG,UAAU,CAAC,UAAU,CAAC,KAAK,CAAC,CAAC;QAC7C,MAAM,OAAO,GAAG,UAAU,CAAC,UAAU,CAAC,KAAK,CAAC,CAAC;QAE7C,OAAO;YACL,WAAW,EAAE,OAAO,CAAC,WAAW,IAAI,OAAO,CAAC,WAAW;YACvD,QAAQ,EAAE,IAAI;YACd,WAAW,EAAE,GAAG,OAAO,CAAC,WAAW,QAAQ,OAAO,CAAC,WAAW,GAAG;SAClE,CAAC;IACJ,CAAC,CAAC;IAEF,OAAO,IAAI,iDAAuB,CAAQ,kBAAkB,CAAC,CAAC;AAChE,CAAC"}

@@ -1,1 +0,1 @@

{"version":3,"file":"xor.d.ts","sourceRoot":"","sources":["../../../src/domainInvariant/operators/xor.ts"],"names":[],"mappings":"AAAA,OAAO,EAAE,eAAe,EAAwB,MAAM,eAAe,CAAC;AAGtE,wBAAgB,GAAG,CAAC,KAAK,EAAE,UAAU,EAAE,eAAe,CAAC,KAAK,CAAC,EAAE,UAAU,EAAE,eAAe,CAAC,KAAK,CAAC,GAAG,eAAe,CAAC,KAAK,CAAC,CAczH"}
{"version":3,"file":"xor.d.ts","sourceRoot":"","sources":["../../../src/domainInvariant/operators/xor.ts"],"names":[],"mappings":"AAAA,OAAO,EAAE,eAAe,EAAwB,MAAM,eAAe,CAAC;AAGtE,wBAAgB,GAAG,CAAC,KAAK,EACvB,UAAU,EAAE,eAAe,CAAC,KAAK,CAAC,EAClC,UAAU,EAAE,eAAe,CAAC,KAAK,CAAC,GACjC,eAAe,CAAC,KAAK,CAAC,CAaxB"}

@@ -11,3 +11,3 @@ "use strict";

isCompliant: AResult.isCompliant !== BResult.isCompliant,
operator: 'XOR',
operator: "XOR",
description: `${AResult.description} XOR (${BResult.description})`,

@@ -14,0 +14,0 @@ };

@@ -1,1 +0,1 @@

{"version":3,"file":"xor.js","sourceRoot":"","sources":["../../../src/domainInvariant/operators/xor.ts"],"names":[],"mappings":";;AAGA,kBAcC;AAhBD,wEAAqE;AAErE,SAAgB,GAAG,CAAQ,UAAkC,EAAE,UAAkC;IAC/F,MAAM,kBAAkB,GAAG,CAAC,KAAY,EAAwB,EAAE;QAChE,MAAM,OAAO,GAAG,UAAU,CAAC,UAAU,CAAC,KAAK,CAAC,CAAC;QAC7C,MAAM,OAAO,GAAG,UAAU,CAAC,UAAU,CAAC,KAAK,CAAC,CAAC;QAE7C,OAAO;YACL,WAAW,EAAE,OAAO,CAAC,WAAW,KAAK,OAAO,CAAC,WAAW;YACxD,QAAQ,EAAE,KAAK;YACf,WAAW,EAAE,GAAG,OAAO,CAAC,WAAW,SAAS,OAAO,CAAC,WAAW,GAAG;SACnE,CAAA;IAEH,CAAC,CAAA;IAED,OAAO,IAAI,iDAAuB,CAAQ,kBAAkB,CAAC,CAAC;AAChE,CAAC"}
{"version":3,"file":"xor.js","sourceRoot":"","sources":["../../../src/domainInvariant/operators/xor.ts"],"names":[],"mappings":";;AAGA,kBAgBC;AAlBD,wEAAqE;AAErE,SAAgB,GAAG,CACjB,UAAkC,EAClC,UAAkC;IAElC,MAAM,kBAAkB,GAAG,CAAC,KAAY,EAAwB,EAAE;QAChE,MAAM,OAAO,GAAG,UAAU,CAAC,UAAU,CAAC,KAAK,CAAC,CAAC;QAC7C,MAAM,OAAO,GAAG,UAAU,CAAC,UAAU,CAAC,KAAK,CAAC,CAAC;QAE7C,OAAO;YACL,WAAW,EAAE,OAAO,CAAC,WAAW,KAAK,OAAO,CAAC,WAAW;YACxD,QAAQ,EAAE,KAAK;YACf,WAAW,EAAE,GAAG,OAAO,CAAC,WAAW,SAAS,OAAO,CAAC,WAAW,GAAG;SACnE,CAAC;IACJ,CAAC,CAAC;IAEF,OAAO,IAAI,iDAAuB,CAAQ,kBAAkB,CAAC,CAAC;AAChE,CAAC"}

@@ -1,1 +0,1 @@

{"version":3,"file":"index.d.ts","sourceRoot":"","sources":["../../../../src/event-bus/connectors/in-memory/index.ts"],"names":[],"mappings":"AAGA,OAAO,EAAE,kBAAkB,EAAE,mBAAmB,EAAE,MAAM,eAAe,CAAC;AAExE,cAAc,YAAY,CAAC;AAC3B,cAAc,aAAa,CAAC;AAE5B,qBAAa,kBAAkB;IAC7B,QAAQ,EAAE,kBAAkB,CAAC;IAC7B,SAAS,EAAE,mBAAmB,CAAC;;CAOhC"}
{"version":3,"file":"index.d.ts","sourceRoot":"","sources":["../../../../src/event-bus/connectors/in-memory/index.ts"],"names":[],"mappings":"AAGA,OAAO,EAAE,kBAAkB,EAAE,mBAAmB,EAAE,MAAM,eAAe,CAAC;AAExE,cAAc,YAAY,CAAC;AAC3B,cAAc,aAAa,CAAC;AAE5B,qBAAa,kBAAkB;IAC7B,QAAQ,EAAE,kBAAkB,CAAC;IAC7B,SAAS,EAAE,mBAAmB,CAAC;;CAShC"}

@@ -27,3 +27,5 @@ "use strict";

constructor() {
const eventEmitter = new node_events_1.EventEmitter({ captureRejections: true });
const eventEmitter = new node_events_1.EventEmitter({
captureRejections: true,
});
this.listener = new listener_1.InMemoryListenerConnector(eventEmitter);

@@ -30,0 +32,0 @@ this.publisher = new publisher_1.InMemoryPublisherConnector(eventEmitter);

@@ -1,1 +0,1 @@

{"version":3,"file":"index.js","sourceRoot":"","sources":["../../../../src/event-bus/connectors/in-memory/index.ts"],"names":[],"mappings":";;;;;;;;;;;;;;;;;AAAA,6CAA2C;AAC3C,yCAAuD;AACvD,2CAAyD;AAGzD,6CAA2B;AAC3B,8CAA4B;AAE5B,MAAa,kBAAkB;IAC7B,QAAQ,CAAqB;IAC7B,SAAS,CAAsB;IAE/B;QACE,MAAM,YAAY,GAAiB,IAAI,0BAAY,CAAC,EAAE,iBAAiB,EAAE,IAAI,EAAE,CAAC,CAAC;QACjF,IAAI,CAAC,QAAQ,GAAG,IAAI,oCAAyB,CAAC,YAAY,CAAC,CAAC;QAC5D,IAAI,CAAC,SAAS,GAAG,IAAI,sCAA0B,CAAC,YAAY,CAAC,CAAC;IAChE,CAAC;CACF;AATD,gDASC"}
{"version":3,"file":"index.js","sourceRoot":"","sources":["../../../../src/event-bus/connectors/in-memory/index.ts"],"names":[],"mappings":";;;;;;;;;;;;;;;;;AAAA,6CAA2C;AAC3C,yCAAuD;AACvD,2CAAyD;AAGzD,6CAA2B;AAC3B,8CAA4B;AAE5B,MAAa,kBAAkB;IAC7B,QAAQ,CAAqB;IAC7B,SAAS,CAAsB;IAE/B;QACE,MAAM,YAAY,GAAiB,IAAI,0BAAY,CAAC;YAClD,iBAAiB,EAAE,IAAI;SACxB,CAAC,CAAC;QACH,IAAI,CAAC,QAAQ,GAAG,IAAI,oCAAyB,CAAC,YAAY,CAAC,CAAC;QAC5D,IAAI,CAAC,SAAS,GAAG,IAAI,sCAA0B,CAAC,YAAY,CAAC,CAAC;IAChE,CAAC;CACF;AAXD,gDAWC"}

@@ -1,1 +0,1 @@

{"version":3,"file":"listener.d.ts","sourceRoot":"","sources":["../../../../src/event-bus/connectors/in-memory/listener.ts"],"names":[],"mappings":"AAAA,OAAO,EAAE,YAAY,EAAE,MAAM,aAAa,CAAC;AAC3C,OAAO,EAAE,kBAAkB,EAAE,eAAe,EAAE,MAAM,eAAe,CAAC;AAEpE,qBAAa,yBAA0B,YAAW,kBAAkB;;gBAMtD,YAAY,EAAE,YAAY;IAKtC,SAAS,CAAC,OAAO,EAAE,CAAC,OAAO,EAAE,eAAe,KAAK,OAAO,CAAC,IAAI,CAAC;IAI9D,IAAI,MAAM,IAAG,SAAS,GAAC,SAAS,CAE/B;IAED,KAAK;IAyBL,IAAI;IAMJ,OAAO,CAAC,OAAO,EAAE,CAAC,KAAK,EAAC,OAAO,KAAK,IAAI,GAAG,IAAI;CAIhD"}
{"version":3,"file":"listener.d.ts","sourceRoot":"","sources":["../../../../src/event-bus/connectors/in-memory/listener.ts"],"names":[],"mappings":"AAAA,OAAO,EAAE,YAAY,EAAE,MAAM,aAAa,CAAC;AAC3C,OAAO,EAAE,kBAAkB,EAAE,eAAe,EAAE,MAAM,eAAe,CAAC;AAEpE,qBAAa,yBAA0B,YAAW,kBAAkB;;gBAKtD,YAAY,EAAE,YAAY;IAKtC,SAAS,CAAC,OAAO,EAAE,CAAC,OAAO,EAAE,eAAe,KAAK,OAAO,CAAC,IAAI,CAAC;IAI9D,IAAI,MAAM,IAAI,SAAS,GAAG,SAAS,CAElC;IAED,KAAK;IA8BL,IAAI;IAMJ,OAAO,CAAC,OAAO,EAAE,CAAC,KAAK,EAAE,OAAO,KAAK,IAAI,GAAG,IAAI;CAGjD"}

@@ -19,3 +19,3 @@ "use strict";

start() {
if (this.#status === 'STARTED') {
if (this.#status === "STARTED") {
return Promise.resolve();

@@ -44,3 +44,3 @@ }

onError(handler) {
this.#eventEmitter.on('error', handler);
this.#eventEmitter.on("error", handler);
}

@@ -47,0 +47,0 @@ }

@@ -1,1 +0,1 @@

{"version":3,"file":"listener.js","sourceRoot":"","sources":["../../../../src/event-bus/connectors/in-memory/listener.ts"],"names":[],"mappings":";;;AAGA,MAAa,yBAAyB;IAEpC,OAAO,CAAsB;IAC7B,aAAa,CAAe;IAC5B,QAAQ,CAAgD;IAExD,YAAY,YAA0B;QACpC,IAAI,CAAC,OAAO,GAAG,SAAS,CAAC;QACzB,IAAI,CAAC,aAAa,GAAG,YAAY,CAAC;IACpC,CAAC;IAED,SAAS,CAAC,OAAoD;QAC5D,IAAI,CAAC,QAAQ,GAAE,OAAO,CAAA;IACxB,CAAC;IAED,IAAI,MAAM;QACR,OAAO,IAAI,CAAC,OAAO,CAAC;IACtB,CAAC;IAED,KAAK;QACH,IAAG,IAAI,CAAC,OAAO,KAAK,SAAS,EAAE,CAAC;YAC9B,OAAO,OAAO,CAAC,OAAO,EAAE,CAAC;QAC3B,CAAC;QAED,IAAI,CAAC,IAAI,CAAC,QAAQ,EAAE,CAAC;YACnB,MAAM,IAAI,KAAK,CAAC,6GAA6G,CAAC,CAAA;QAChI,CAAC;QAED,MAAM,OAAO,GAAG,IAAI,CAAC,QAAQ,CAAC;QAE9B,IAAI,CAAC,aAAa,CAAC,EAAE,CAAC,SAAS,EAAE,KAAK,EAAE,OAAwC,EAAE,EAAE;YAClF,MAAM,OAAO,CAAC;gBACZ,OAAO,EAAE,OAAO,CAAC,OAAO;gBACxB,IAAI,EAAE,OAAO,CAAC,IAAI;gBAClB,GAAG,EAAC,KAAK,IAAI,EAAE,GAAE,CAAC;gBAClB,IAAI,EAAC,KAAK,IAAI,EAAE,GAAE,CAAC;aACpB,CAAC,CAAC;QACL,CAAC,CAAC,CAAC;QAEH,IAAI,CAAC,OAAO,GAAG,SAAS,CAAA;QAExB,OAAO,OAAO,CAAC,OAAO,EAAE,CAAC;IAC3B,CAAC;IAED,IAAI;QACF,IAAI,CAAC,OAAO,GAAG,SAAS,CAAC;QACzB,IAAI,CAAC,aAAa,CAAC,kBAAkB,CAAC,SAAS,CAAC,CAAC;QACjD,OAAO,OAAO,CAAC,OAAO,EAAE,CAAC;IAC3B,CAAC;IAED,OAAO,CAAC,OAAgC;QACtC,IAAI,CAAC,aAAa,CAAC,EAAE,CAAC,OAAO,EAAE,OAAO,CAAC,CAAC;IAC1C,CAAC;CAEF;AAtDD,8DAsDC"}
{"version":3,"file":"listener.js","sourceRoot":"","sources":["../../../../src/event-bus/connectors/in-memory/listener.ts"],"names":[],"mappings":";;;AAGA,MAAa,yBAAyB;IACpC,OAAO,CAAwB;IAC/B,aAAa,CAAe;IAC5B,QAAQ,CAA+C;IAEvD,YAAY,YAA0B;QACpC,IAAI,CAAC,OAAO,GAAG,SAAS,CAAC;QACzB,IAAI,CAAC,aAAa,GAAG,YAAY,CAAC;IACpC,CAAC;IAED,SAAS,CAAC,OAAoD;QAC5D,IAAI,CAAC,QAAQ,GAAG,OAAO,CAAC;IAC1B,CAAC;IAED,IAAI,MAAM;QACR,OAAO,IAAI,CAAC,OAAO,CAAC;IACtB,CAAC;IAED,KAAK;QACH,IAAI,IAAI,CAAC,OAAO,KAAK,SAAS,EAAE,CAAC;YAC/B,OAAO,OAAO,CAAC,OAAO,EAAE,CAAC;QAC3B,CAAC;QAED,IAAI,CAAC,IAAI,CAAC,QAAQ,EAAE,CAAC;YACnB,MAAM,IAAI,KAAK,CACb,6GAA6G,CAC9G,CAAC;QACJ,CAAC;QAED,MAAM,OAAO,GAAG,IAAI,CAAC,QAAQ,CAAC;QAE9B,IAAI,CAAC,aAAa,CAAC,EAAE,CACnB,SAAS,EACT,KAAK,EAAE,OAA0C,EAAE,EAAE;YACnD,MAAM,OAAO,CAAC;gBACZ,OAAO,EAAE,OAAO,CAAC,OAAO;gBACxB,IAAI,EAAE,OAAO,CAAC,IAAI;gBAClB,GAAG,EAAE,KAAK,IAAI,EAAE,GAAE,CAAC;gBACnB,IAAI,EAAE,KAAK,IAAI,EAAE,GAAE,CAAC;aACrB,CAAC,CAAC;QACL,CAAC,CACF,CAAC;QAEF,IAAI,CAAC,OAAO,GAAG,SAAS,CAAC;QAEzB,OAAO,OAAO,CAAC,OAAO,EAAE,CAAC;IAC3B,CAAC;IAED,IAAI;QACF,IAAI,CAAC,OAAO,GAAG,SAAS,CAAC;QACzB,IAAI,CAAC,aAAa,CAAC,kBAAkB,CAAC,SAAS,CAAC,CAAC;QACjD,OAAO,OAAO,CAAC,OAAO,EAAE,CAAC;IAC3B,CAAC;IAED,OAAO,CAAC,OAAiC;QACvC,IAAI,CAAC,aAAa,CAAC,EAAE,CAAC,OAAO,EAAE,OAAO,CAAC,CAAC;IAC1C,CAAC;CACF;AAzDD,8DAyDC"}

@@ -1,1 +0,1 @@

{"version":3,"file":"publisher.d.ts","sourceRoot":"","sources":["../../../../src/event-bus/connectors/in-memory/publisher.ts"],"names":[],"mappings":"AACA,OAAO,EAAE,YAAY,EAAE,MAAM,aAAa,CAAC;AAC3C,OAAO,EAAE,mBAAmB,EAAE,MAAM,eAAe,CAAC;AAEpD,qBAAa,0BAA2B,YAAW,mBAAmB;;gBAKxD,YAAY,EAAE,YAAY;IAKtC,OAAO,CAAC,IAAI,EAAE,MAAM,EAAE,OAAO,EAAE,MAAM,GAAG,OAAO,CAAC,IAAI,CAAC;IAKrD,IAAI,MAAM,IAAG,SAAS,GAAC,SAAS,CAE/B;IAED,KAAK;IAKL,IAAI;IAKJ,OAAO,CAAC,OAAO,EAAE,CAAC,KAAK,EAAC,OAAO,KAAK,IAAI,GAAG,IAAI;CAIhD"}
{"version":3,"file":"publisher.d.ts","sourceRoot":"","sources":["../../../../src/event-bus/connectors/in-memory/publisher.ts"],"names":[],"mappings":"AAAA,OAAO,EAAE,YAAY,EAAE,MAAM,aAAa,CAAC;AAC3C,OAAO,EAAE,mBAAmB,EAAE,MAAM,eAAe,CAAC;AAEpD,qBAAa,0BAA2B,YAAW,mBAAmB;;gBAIxD,YAAY,EAAE,YAAY;IAKtC,OAAO,CAAC,IAAI,EAAE,MAAM,EAAE,OAAO,EAAE,MAAM,GAAG,OAAO,CAAC,IAAI,CAAC;IAKrD,IAAI,MAAM,IAAI,SAAS,GAAG,SAAS,CAElC;IAED,KAAK;IAKL,IAAI;IAKJ,OAAO,CAAC,OAAO,EAAE,CAAC,KAAK,EAAE,OAAO,KAAK,IAAI,GAAG,IAAI;CAGjD"}

@@ -12,3 +12,3 @@ "use strict";

publish(name, message) {
this.#eventEmitter.emit('message', { name, content: message });
this.#eventEmitter.emit("message", { name, content: message });
return Promise.resolve();

@@ -28,3 +28,3 @@ }

onError(handler) {
this.#eventEmitter.on('error', handler);
this.#eventEmitter.on("error", handler);
}

@@ -31,0 +31,0 @@ }

@@ -1,1 +0,1 @@

{"version":3,"file":"publisher.js","sourceRoot":"","sources":["../../../../src/event-bus/connectors/in-memory/publisher.ts"],"names":[],"mappings":";;;AAIA,MAAa,0BAA0B;IAErC,OAAO,CAAsB;IAC7B,aAAa,CAAe;IAE5B,YAAY,YAA0B;QACpC,IAAI,CAAC,OAAO,GAAG,SAAS,CAAC;QACzB,IAAI,CAAC,aAAa,GAAG,YAAY,CAAC;IACpC,CAAC;IAED,OAAO,CAAC,IAAY,EAAE,OAAe;QACnC,IAAI,CAAC,aAAa,CAAC,IAAI,CAAC,SAAS,EAAE,EAAE,IAAI,EAAE,OAAO,EAAC,OAAO,EAAE,CAAC,CAAC;QAC9D,OAAO,OAAO,CAAC,OAAO,EAAE,CAAC;IAC3B,CAAC;IAED,IAAI,MAAM;QACR,OAAO,IAAI,CAAC,OAAO,CAAC;IACtB,CAAC;IAED,KAAK;QACH,IAAI,CAAC,OAAO,GAAG,SAAS,CAAA;QACxB,OAAO,OAAO,CAAC,OAAO,EAAE,CAAC;IAC3B,CAAC;IAED,IAAI;QACF,IAAI,CAAC,OAAO,GAAG,SAAS,CAAA;QACxB,OAAO,OAAO,CAAC,OAAO,EAAE,CAAC;IAC3B,CAAC;IAED,OAAO,CAAC,OAAgC;QACtC,IAAI,CAAC,aAAa,CAAC,EAAE,CAAC,OAAO,EAAE,OAAO,CAAC,CAAC;IAC1C,CAAC;CAEF;AAjCD,gEAiCC"}
{"version":3,"file":"publisher.js","sourceRoot":"","sources":["../../../../src/event-bus/connectors/in-memory/publisher.ts"],"names":[],"mappings":";;;AAGA,MAAa,0BAA0B;IACrC,OAAO,CAAwB;IAC/B,aAAa,CAAe;IAE5B,YAAY,YAA0B;QACpC,IAAI,CAAC,OAAO,GAAG,SAAS,CAAC;QACzB,IAAI,CAAC,aAAa,GAAG,YAAY,CAAC;IACpC,CAAC;IAED,OAAO,CAAC,IAAY,EAAE,OAAe;QACnC,IAAI,CAAC,aAAa,CAAC,IAAI,CAAC,SAAS,EAAE,EAAE,IAAI,EAAE,OAAO,EAAE,OAAO,EAAE,CAAC,CAAC;QAC/D,OAAO,OAAO,CAAC,OAAO,EAAE,CAAC;IAC3B,CAAC;IAED,IAAI,MAAM;QACR,OAAO,IAAI,CAAC,OAAO,CAAC;IACtB,CAAC;IAED,KAAK;QACH,IAAI,CAAC,OAAO,GAAG,SAAS,CAAC;QACzB,OAAO,OAAO,CAAC,OAAO,EAAE,CAAC;IAC3B,CAAC;IAED,IAAI;QACF,IAAI,CAAC,OAAO,GAAG,SAAS,CAAC;QACzB,OAAO,OAAO,CAAC,OAAO,EAAE,CAAC;IAC3B,CAAC;IAED,OAAO,CAAC,OAAiC;QACvC,IAAI,CAAC,aAAa,CAAC,EAAE,CAAC,OAAO,EAAE,OAAO,CAAC,CAAC;IAC1C,CAAC;CACF;AA/BD,gEA+BC"}

@@ -1,1 +0,1 @@

{"version":3,"file":"interfaces.d.ts","sourceRoot":"","sources":["../../../src/event-bus/connectors/interfaces.ts"],"names":[],"mappings":"AAAA,MAAM,WAAW,kBAAkB;IACjC,SAAS,CAAC,OAAO,EAAE,CAAC,OAAO,EAAE,eAAe,KAAK,OAAO,CAAC,IAAI,CAAC,GAAG,IAAI,CAAA;IACrE,MAAM,EAAE,SAAS,GAAG,SAAS,CAAA;IAC7B,KAAK,IAAI,OAAO,CAAC,IAAI,CAAC,CAAA;IACtB,IAAI,IAAI,OAAO,CAAC,IAAI,CAAC,CAAA;IACrB,OAAO,CAAC,OAAO,EAAE,CAAC,KAAK,EAAC,OAAO,KAAK,IAAI,GAAG,IAAI,CAAA;CAChD;AAED,MAAM,WAAW,mBAAmB;IAClC,OAAO,CAAC,IAAI,EAAE,MAAM,EAAE,OAAO,EAAE,MAAM,EAAE,OAAO,CAAC,EAAE;QAAE,WAAW,CAAC,EAAE,MAAM,CAAA;KAAE,GAAG,OAAO,CAAC,IAAI,CAAC,CAAA;IACzF,MAAM,EAAE,SAAS,GAAG,SAAS,CAAA;IAC7B,KAAK,IAAI,OAAO,CAAC,IAAI,CAAC,CAAA;IACtB,IAAI,IAAI,OAAO,CAAC,IAAI,CAAC,CAAA;IACrB,OAAO,CAAC,OAAO,EAAE,CAAC,KAAK,EAAC,OAAO,KAAK,IAAI,GAAG,IAAI,CAAA;CAChD;AAED,MAAM,WAAW,eAAe;IAC9B,IAAI,EAAE,MAAM,CAAC;IACb,OAAO,EAAE,MAAM,CAAC;IAChB,GAAG,IAAI,OAAO,CAAC,IAAI,CAAC,CAAC;IACrB,IAAI,IAAI,OAAO,CAAC,IAAI,CAAC,CAAC;CACvB"}
{"version":3,"file":"interfaces.d.ts","sourceRoot":"","sources":["../../../src/event-bus/connectors/interfaces.ts"],"names":[],"mappings":"AAAA,MAAM,WAAW,kBAAkB;IACjC,SAAS,CAAC,OAAO,EAAE,CAAC,OAAO,EAAE,eAAe,KAAK,OAAO,CAAC,IAAI,CAAC,GAAG,IAAI,CAAC;IACtE,MAAM,EAAE,SAAS,GAAG,SAAS,CAAC;IAC9B,KAAK,IAAI,OAAO,CAAC,IAAI,CAAC,CAAC;IACvB,IAAI,IAAI,OAAO,CAAC,IAAI,CAAC,CAAC;IACtB,OAAO,CAAC,OAAO,EAAE,CAAC,KAAK,EAAE,OAAO,KAAK,IAAI,GAAG,IAAI,CAAC;CAClD;AAED,MAAM,WAAW,mBAAmB;IAClC,OAAO,CACL,IAAI,EAAE,MAAM,EACZ,OAAO,EAAE,MAAM,EACf,OAAO,CAAC,EAAE;QAAE,WAAW,CAAC,EAAE,MAAM,CAAA;KAAE,GACjC,OAAO,CAAC,IAAI,CAAC,CAAC;IACjB,MAAM,EAAE,SAAS,GAAG,SAAS,CAAC;IAC9B,KAAK,IAAI,OAAO,CAAC,IAAI,CAAC,CAAC;IACvB,IAAI,IAAI,OAAO,CAAC,IAAI,CAAC,CAAC;IACtB,OAAO,CAAC,OAAO,EAAE,CAAC,KAAK,EAAE,OAAO,KAAK,IAAI,GAAG,IAAI,CAAC;CAClD;AAED,MAAM,WAAW,eAAe;IAC9B,IAAI,EAAE,MAAM,CAAC;IACb,OAAO,EAAE,MAAM,CAAC;IAChB,GAAG,IAAI,OAAO,CAAC,IAAI,CAAC,CAAC;IACrB,IAAI,IAAI,OAAO,CAAC,IAAI,CAAC,CAAC;CACvB"}

@@ -11,3 +11,3 @@ import { DomainEventInterface } from "../domainEvent";

stop(): void | Promise<void>;
listenTo<EventName extends Event["name"]>(eventName: EventName | '*', handler: EventHandler<Extract<Event, {
listenTo<EventName extends Event["name"]>(eventName: EventName | "*", handler: EventHandler<Extract<Event, {
name: EventName;

@@ -14,0 +14,0 @@ }>>): void;

@@ -1,1 +0,1 @@

{"version":3,"file":"interfaces.d.ts","sourceRoot":"","sources":["../../src/event-bus/interfaces.ts"],"names":[],"mappings":"AAAA,OAAO,EAAE,oBAAoB,EAAE,MAAM,gBAAgB,CAAC;AACtD,OAAO,EAAE,aAAa,EAAE,MAAM,eAAe,CAAC;AAE9C,MAAM,WAAW,wBAAwB,CAAC,KAAK,SAAS,oBAAoB;IAC1E,KAAK,IAAI,IAAI,GAAG,OAAO,CAAC,IAAI,CAAC,CAAA;IAC7B,IAAI,IAAI,IAAI,GAAG,OAAO,CAAC,IAAI,CAAC,CAAA;IAC5B,OAAO,CAAC,KAAK,EAAE,KAAK,EAAE,QAAQ,EAAE,aAAa,GAAG,OAAO,CAAC,IAAI,CAAC,CAAA;CAC9D;AAED,MAAM,WAAW,uBAAuB,CAAC,KAAK,SAAS,oBAAoB;IACzE,KAAK,IAAI,IAAI,GAAG,OAAO,CAAC,IAAI,CAAC,CAAA;IAC7B,IAAI,IAAI,IAAI,GAAG,OAAO,CAAC,IAAI,CAAC,CAAA;IAC5B,QAAQ,CAAC,SAAS,SAAS,KAAK,CAAC,MAAM,CAAC,EAAE,SAAS,EAAC,SAAS,GAAG,GAAG,EAAE,OAAO,EAAE,YAAY,CAAC,OAAO,CAAC,KAAK,EAAE;QAAE,IAAI,EAAE,SAAS,CAAA;KAAE,CAAC,CAAC,GAAG,IAAI,CAAA;CACvI;AAED,MAAM,MAAM,YAAY,CAAC,KAAK,SAAS,oBAAoB,IAAI,CAC7D,KAAK,EAAE,KAAK,EACZ,QAAQ,EAAE,aAAa,KACpB,IAAI,GAAG,OAAO,CAAC,IAAI,CAAC,CAAC"}
{"version":3,"file":"interfaces.d.ts","sourceRoot":"","sources":["../../src/event-bus/interfaces.ts"],"names":[],"mappings":"AAAA,OAAO,EAAE,oBAAoB,EAAE,MAAM,gBAAgB,CAAC;AACtD,OAAO,EAAE,aAAa,EAAE,MAAM,eAAe,CAAC;AAE9C,MAAM,WAAW,wBAAwB,CAAC,KAAK,SAAS,oBAAoB;IAC1E,KAAK,IAAI,IAAI,GAAG,OAAO,CAAC,IAAI,CAAC,CAAC;IAC9B,IAAI,IAAI,IAAI,GAAG,OAAO,CAAC,IAAI,CAAC,CAAC;IAC7B,OAAO,CAAC,KAAK,EAAE,KAAK,EAAE,QAAQ,EAAE,aAAa,GAAG,OAAO,CAAC,IAAI,CAAC,CAAC;CAC/D;AAED,MAAM,WAAW,uBAAuB,CAAC,KAAK,SAAS,oBAAoB;IACzE,KAAK,IAAI,IAAI,GAAG,OAAO,CAAC,IAAI,CAAC,CAAC;IAC9B,IAAI,IAAI,IAAI,GAAG,OAAO,CAAC,IAAI,CAAC,CAAC;IAC7B,QAAQ,CAAC,SAAS,SAAS,KAAK,CAAC,MAAM,CAAC,EACtC,SAAS,EAAE,SAAS,GAAG,GAAG,EAC1B,OAAO,EAAE,YAAY,CAAC,OAAO,CAAC,KAAK,EAAE;QAAE,IAAI,EAAE,SAAS,CAAA;KAAE,CAAC,CAAC,GACzD,IAAI,CAAC;CACT;AAED,MAAM,MAAM,YAAY,CAAC,KAAK,SAAS,oBAAoB,IAAI,CAC7D,KAAK,EAAE,KAAK,EACZ,QAAQ,EAAE,aAAa,KACpB,IAAI,GAAG,OAAO,CAAC,IAAI,CAAC,CAAC"}

@@ -12,3 +12,3 @@ import { IListenerConnector } from "./connectors/interfaces";

});
listenTo<EventName extends Event["name"]>(eventName: EventName | '*', handler: EventHandler<Extract<Event, {
listenTo<EventName extends Event["name"]>(eventName: EventName | "*", handler: EventHandler<Extract<Event, {
name: EventName;

@@ -15,0 +15,0 @@ }>>): void;

@@ -1,1 +0,1 @@

{"version":3,"file":"listener.d.ts","sourceRoot":"","sources":["../../src/event-bus/listener.ts"],"names":[],"mappings":"AAAA,OAAO,EAAC,kBAAkB,EAAkB,MAAM,yBAAyB,CAAC;AAC5E,OAAO,EAAE,YAAY,EAAE,uBAAuB,EAAE,MAAM,cAAc,CAAC;AACrE,OAAO,EAAE,oBAAoB,EAAE,MAAM,gBAAgB,CAAC;AAItD,qBAAa,sBAAsB,CAAC,KAAK,SAAS,oBAAoB,CACpE,YAAW,uBAAuB,CAAC,KAAK,CAAC;;gBAM7B,MAAM,EAAE;QAClB,iBAAiB,EAAE,kBAAkB,CAAC;QACtC,OAAO,EAAE;YAAE,SAAS,EAAE,CAAC,KAAK,EAAE,OAAO,KAAK,KAAK,CAAC;SAAE,CAAA;KACnD;IAkBD,QAAQ,CAAC,SAAS,SAAS,KAAK,CAAC,MAAM,CAAC,EAAE,SAAS,EAAC,SAAS,GAAG,GAAG,EAAE,OAAO,EAAE,YAAY,CAAC,OAAO,CAAC,KAAK,EAAE;QAAE,IAAI,EAAE,SAAS,CAAA;KAAE,CAAC,CAAC,GAAG,IAAI;IAIhI,KAAK;IAoCL,IAAI;IAIV,MAAM;IAIN,OAAO,CAAC,OAAO,EAAE,CAAC,KAAK,EAAE,OAAO,KAAK,IAAI,GAAG,IAAI;CAIjD"}
{"version":3,"file":"listener.d.ts","sourceRoot":"","sources":["../../src/event-bus/listener.ts"],"names":[],"mappings":"AAAA,OAAO,EAAE,kBAAkB,EAAmB,MAAM,yBAAyB,CAAC;AAC9E,OAAO,EAAE,YAAY,EAAE,uBAAuB,EAAE,MAAM,cAAc,CAAC;AACrE,OAAO,EAAE,oBAAoB,EAAE,MAAM,gBAAgB,CAAC;AAItD,qBAAa,sBAAsB,CACjC,KAAK,SAAS,oBAAoB,CAClC,YAAW,uBAAuB,CAAC,KAAK,CAAC;;gBAM7B,MAAM,EAAE;QAClB,iBAAiB,EAAE,kBAAkB,CAAC;QACtC,OAAO,EAAE;YAAE,SAAS,EAAE,CAAC,KAAK,EAAE,OAAO,KAAK,KAAK,CAAA;SAAE,CAAC;KACnD;IAqBD,QAAQ,CAAC,SAAS,SAAS,KAAK,CAAC,MAAM,CAAC,EACtC,SAAS,EAAE,SAAS,GAAG,GAAG,EAC1B,OAAO,EAAE,YAAY,CAAC,OAAO,CAAC,KAAK,EAAE;QAAE,IAAI,EAAE,SAAS,CAAA;KAAE,CAAC,CAAC,GACzD,IAAI;IAID,KAAK;IAyCL,IAAI;IAIV,MAAM;IAIN,OAAO,CAAC,OAAO,EAAE,CAAC,KAAK,EAAE,OAAO,KAAK,IAAI,GAAG,IAAI;CAIjD"}

@@ -19,3 +19,3 @@ "use strict";

this.#eventEmitter = new node_events_1.EventEmitter({
captureRejections: true
captureRejections: true,
});

@@ -22,0 +22,0 @@ this.#validator = options.validator;

@@ -1,1 +0,1 @@

{"version":3,"file":"listener.js","sourceRoot":"","sources":["../../src/event-bus/listener.ts"],"names":[],"mappings":";;;AAGA,6CAA2C;AAC3C,yDAAsD;AAEtD,MAAa,sBAAsB;IAEjC,kBAAkB,CAAoB;IACtC,iBAAiB,CAAgD;IACjE,aAAa,CAAe;IAC5B,UAAU,CAA6B;IAEvC,YAAY,MAGX;QACC,MAAM,EAAE,iBAAiB,EAAE,OAAO,EAAE,GAAG,MAAM,CAAC;QAE9C,IAAI,CAAC,iBAAiB,EAAE,CAAC;YACvB,MAAM,IAAI,KAAK,CACb,yDAAyD,CAC1D,CAAC;QACJ,CAAC;QAED,IAAI,CAAC,kBAAkB,GAAG,iBAAiB,CAAC;QAC5C,IAAI,CAAC,iBAAiB,GAAG,IAAI,GAAG,EAA4C,CAAA;QAC5E,IAAI,CAAC,aAAa,GAAG,IAAI,0BAAY,CAAC;YACpC,iBAAiB,EAAE,IAAI;SACxB,CAAC,CAAA;QAEF,IAAI,CAAC,UAAU,GAAG,OAAO,CAAC,SAAS,CAAA;IACrC,CAAC;IAED,QAAQ,CAAkC,SAAyB,EAAE,OAA0D;QAC7H,IAAI,CAAC,iBAAiB,CAAC,GAAG,CAAC,SAAS,EAAE,OAA8B,CAAC,CAAC;IACxE,CAAC;IAED,KAAK,CAAC,KAAK;QACT,IAAG,IAAI,CAAC,iBAAiB,CAAC,IAAI,KAAK,CAAC,EAAE,CAAC;YACrC,MAAM,IAAI,KAAK,CAAC,uHAAuH,CAAC,CAAA;QAC1I,CAAC;QAED,IAAI,CAAC,kBAAkB,CAAC,SAAS,CAAC,KAAK,EAAE,OAAwB,EAAC,EAAE;YAClE,MAAM,YAAY,GAChB,IAAI,CAAC,iBAAiB,CAAC,GAAG,CAAC,OAAO,CAAC,IAAI,CAAC;gBACxC,IAAI,CAAC,iBAAiB,CAAC,GAAG,CAAC,GAAG,CAAC,CAAC;YAElC,IAAI,CAAC,YAAY,EAAE,CAAC;gBAClB,IAAI,CAAC,aAAa,CAAC,IAAI,CAAC,OAAO,EAAE,IAAI,KAAK,CAAC,kDAAkD,CAAC,CAAC,CAAC;gBAChG,MAAM,OAAO,CAAC,IAAI,EAAE,CAAC;gBACrB,OAAM;YACR,CAAC;YAED,MAAM,aAAa,GAAG,IAAI,CAAC,KAAK,CAAC,OAAO,CAAC,OAAO,CAAC,CAAC;YAClD,MAAM,EAAE,KAAK,EAAE,QAAQ,EAAE,GAAG,aAAa,CAAC;YAE1C,IAAI,aAAa,GAAG,KAAK,CAAC;YAExB,aAAa,GAAG,IAAI,CAAC,UAAU,CAAC,KAAK,CAAC,CAAC;YAEzC,MAAM,iBAAiB,GAAG,IAAA,mCAAgB,EAAC,QAAQ,CAAC,CAAA;YAEpD,IAAI,CAAC;gBACH,MAAM,YAAY,CAAC,aAAa,EAAE,iBAAiB,CAAC,CAAC;gBACrD,MAAM,OAAO,CAAC,GAAG,EAAE,CAAC;YACtB,CAAC;YAAC,MAAM,CAAC;gBACP,MAAM,OAAO,CAAC,IAAI,EAAE,CAAC;YACvB,CAAC;QACH,CAAC,CAAC,CAAC;QAEH,MAAM,IAAI,CAAC,kBAAkB,CAAC,KAAK,EAAE,CAAC;IACxC,CAAC;IAED,KAAK,CAAC,IAAI;QACR,MAAM,IAAI,CAAC,kBAAkB,CAAC,IAAI,EAAE,CAAC;IACvC,CAAC;IAED,MAAM;QACJ,OAAO,IAAI,CAAC,kBAAkB,CAAC,MAAM,CAAC;IACxC,CAAC;IAED,OAAO,CAAC,OAAiC;QACvC,IAAI,CAAC,kBAAkB,CAAC,OAAO,CAAC,OAAO,CAAC,CAAC;QACzC,IAAI,CAAC,aAAa,CAAC,EAAE,CAAC,OAAO,EAAE,OAAO,CAAC,CAAA;IACzC,CAAC;CACF;AAhFD,wDAgFC"}
{"version":3,"file":"listener.js","sourceRoot":"","sources":["../../src/event-bus/listener.ts"],"names":[],"mappings":";;;AAGA,6CAA2C;AAC3C,yDAAsD;AAEtD,MAAa,sBAAsB;IAGjC,kBAAkB,CAAqB;IACvC,iBAAiB,CAAgD;IACjE,aAAa,CAAe;IAC5B,UAAU,CAA4B;IAEtC,YAAY,MAGX;QACC,MAAM,EAAE,iBAAiB,EAAE,OAAO,EAAE,GAAG,MAAM,CAAC;QAE9C,IAAI,CAAC,iBAAiB,EAAE,CAAC;YACvB,MAAM,IAAI,KAAK,CACb,yDAAyD,CAC1D,CAAC;QACJ,CAAC;QAED,IAAI,CAAC,kBAAkB,GAAG,iBAAiB,CAAC;QAC5C,IAAI,CAAC,iBAAiB,GAAG,IAAI,GAAG,EAG7B,CAAC;QACJ,IAAI,CAAC,aAAa,GAAG,IAAI,0BAAY,CAAC;YACpC,iBAAiB,EAAE,IAAI;SACxB,CAAC,CAAC;QAEH,IAAI,CAAC,UAAU,GAAG,OAAO,CAAC,SAAS,CAAC;IACtC,CAAC;IAED,QAAQ,CACN,SAA0B,EAC1B,OAA0D;QAE1D,IAAI,CAAC,iBAAiB,CAAC,GAAG,CAAC,SAAS,EAAE,OAA8B,CAAC,CAAC;IACxE,CAAC;IAED,KAAK,CAAC,KAAK;QACT,IAAI,IAAI,CAAC,iBAAiB,CAAC,IAAI,KAAK,CAAC,EAAE,CAAC;YACtC,MAAM,IAAI,KAAK,CACb,uHAAuH,CACxH,CAAC;QACJ,CAAC;QAED,IAAI,CAAC,kBAAkB,CAAC,SAAS,CAAC,KAAK,EAAE,OAAwB,EAAE,EAAE;YACnE,MAAM,YAAY,GAChB,IAAI,CAAC,iBAAiB,CAAC,GAAG,CAAC,OAAO,CAAC,IAAI,CAAC;gBACxC,IAAI,CAAC,iBAAiB,CAAC,GAAG,CAAC,GAAG,CAAC,CAAC;YAElC,IAAI,CAAC,YAAY,EAAE,CAAC;gBAClB,IAAI,CAAC,aAAa,CAAC,IAAI,CACrB,OAAO,EACP,IAAI,KAAK,CAAC,kDAAkD,CAAC,CAC9D,CAAC;gBACF,MAAM,OAAO,CAAC,IAAI,EAAE,CAAC;gBACrB,OAAO;YACT,CAAC;YAED,MAAM,aAAa,GAAG,IAAI,CAAC,KAAK,CAAC,OAAO,CAAC,OAAO,CAAC,CAAC;YAClD,MAAM,EAAE,KAAK,EAAE,QAAQ,EAAE,GAAG,aAAa,CAAC;YAE1C,IAAI,aAAa,GAAG,KAAK,CAAC;YAE1B,aAAa,GAAG,IAAI,CAAC,UAAU,CAAC,KAAK,CAAC,CAAC;YAEvC,MAAM,iBAAiB,GAAG,IAAA,mCAAgB,EAAC,QAAQ,CAAC,CAAC;YAErD,IAAI,CAAC;gBACH,MAAM,YAAY,CAAC,aAAa,EAAE,iBAAiB,CAAC,CAAC;gBACrD,MAAM,OAAO,CAAC,GAAG,EAAE,CAAC;YACtB,CAAC;YAAC,MAAM,CAAC;gBACP,MAAM,OAAO,CAAC,IAAI,EAAE,CAAC;YACvB,CAAC;QACH,CAAC,CAAC,CAAC;QAEH,MAAM,IAAI,CAAC,kBAAkB,CAAC,KAAK,EAAE,CAAC;IACxC,CAAC;IAED,KAAK,CAAC,IAAI;QACR,MAAM,IAAI,CAAC,kBAAkB,CAAC,IAAI,EAAE,CAAC;IACvC,CAAC;IAED,MAAM;QACJ,OAAO,IAAI,CAAC,kBAAkB,CAAC,MAAM,CAAC;IACxC,CAAC;IAED,OAAO,CAAC,OAAiC;QACvC,IAAI,CAAC,kBAAkB,CAAC,OAAO,CAAC,OAAO,CAAC,CAAC;QACzC,IAAI,CAAC,aAAa,CAAC,EAAE,CAAC,OAAO,EAAE,OAAO,CAAC,CAAC;IAC1C,CAAC;CACF;AA5FD,wDA4FC"}

@@ -1,1 +0,1 @@

{"version":3,"file":"publisher.d.ts","sourceRoot":"","sources":["../../src/event-bus/publisher.ts"],"names":[],"mappings":"AAAA,OAAO,EAAE,mBAAmB,EAAE,MAAM,yBAAyB,CAAC;AAC9D,OAAO,EAAE,wBAAwB,EAAE,MAAM,cAAc,CAAC;AACxD,OAAO,EAAE,oBAAoB,EAAE,MAAM,gBAAgB,CAAC;AAGtD,qBAAa,uBAAuB,CAAC,KAAK,SAAS,oBAAoB,CACrE,YAAW,wBAAwB,CAAC,KAAK,CAAC;;gBAK9B,MAAM,EAAE;QAClB,kBAAkB,EAAE,mBAAmB,CAAC;QACxC,OAAO,CAAC,EAAE;YAAE,SAAS,CAAC,EAAE,CAAC,KAAK,EAAE,OAAO,KAAK,KAAK,CAAC;SAAE,CAAA;KACrD;IAgBK,OAAO,CAAC,KAAK,EAAE,KAAK,EAAE,QAAQ,EAAE;QACpC,EAAE,EAAC,MAAM,CAAC;QACV,MAAM,CAAC,EAAE,MAAM,CAAC;QAChB,SAAS,EAAE,MAAM,CAAC;KACnB,EAAE,OAAO,CAAC,EAAE;QACT,WAAW,CAAC,EAAE,MAAM,CAAA;KACrB;IAkBG,KAAK;IAIL,IAAI;IAIV,MAAM;IAIN,OAAO,CAAC,OAAO,EAAE,CAAC,KAAK,EAAE,OAAO,KAAK,IAAI,GAAG,IAAI;CAGjD"}
{"version":3,"file":"publisher.d.ts","sourceRoot":"","sources":["../../src/event-bus/publisher.ts"],"names":[],"mappings":"AAAA,OAAO,EAAE,mBAAmB,EAAE,MAAM,yBAAyB,CAAC;AAC9D,OAAO,EAAE,wBAAwB,EAAE,MAAM,cAAc,CAAC;AACxD,OAAO,EAAE,oBAAoB,EAAE,MAAM,gBAAgB,CAAC;AAGtD,qBAAa,uBAAuB,CAClC,KAAK,SAAS,oBAAoB,CAClC,YAAW,wBAAwB,CAAC,KAAK,CAAC;;gBAI9B,MAAM,EAAE;QAClB,kBAAkB,EAAE,mBAAmB,CAAC;QACxC,OAAO,CAAC,EAAE;YAAE,SAAS,CAAC,EAAE,CAAC,KAAK,EAAE,OAAO,KAAK,KAAK,CAAA;SAAE,CAAC;KACrD;IAgBK,OAAO,CACX,KAAK,EAAE,KAAK,EACZ,QAAQ,EAAE;QACR,EAAE,EAAE,MAAM,CAAC;QACX,MAAM,CAAC,EAAE,MAAM,CAAC;QAChB,SAAS,EAAE,MAAM,CAAC;KACnB,EACD,OAAO,CAAC,EAAE;QACR,WAAW,CAAC,EAAE,MAAM,CAAC;KACtB;IAsBG,KAAK;IAIL,IAAI;IAIV,MAAM;IAIN,OAAO,CAAC,OAAO,EAAE,CAAC,KAAK,EAAE,OAAO,KAAK,IAAI,GAAG,IAAI;CAGjD"}

@@ -1,1 +0,1 @@

{"version":3,"file":"publisher.js","sourceRoot":"","sources":["../../src/event-bus/publisher.ts"],"names":[],"mappings":";;;AAGA,yDAAsD;AAEtD,MAAa,uBAAuB;IAGlC,mBAAmB,CAAsB;IACzC,UAAU,CAA8B;IAExC,YAAY,MAGX;QACC,MAAM,EAAE,kBAAkB,EAAE,OAAO,EAAE,GAAG,MAAM,CAAC;QAE/C,IAAI,CAAC,kBAAkB,EAAE,CAAC;YACxB,MAAM,IAAI,KAAK,CACb,2DAA2D,CAC5D,CAAC;QACJ,CAAC;QAED,IAAI,CAAC,mBAAmB,GAAG,kBAAkB,CAAC;QAE9C,IAAG,OAAO,EAAE,SAAS,EAAC,CAAC;YACrB,IAAI,CAAC,UAAU,GAAG,OAAO,CAAC,SAAS,CAAA;QACrC,CAAC;IACH,CAAC;IAED,KAAK,CAAC,OAAO,CAAC,KAAY,EAAE,QAI3B,EAAE,OAEA;QAED,MAAM,iBAAiB,GAAG,IAAA,mCAAgB,EAAC,QAAQ,CAAC,CAAC;QAErD,IAAI,cAAc,GAAG,KAAK,CAAC;QAE3B,IAAG,IAAI,CAAC,UAAU,EAAE,CAAC;YACnB,cAAc,GAAG,IAAI,CAAC,UAAU,CAAC,KAAK,CAAC,CAAA;QACzC,CAAC;QAED,MAAM,OAAO,GAAG;YACd,KAAK,EAAE,cAAc;YACrB,QAAQ,EAAE,iBAAiB;SAC5B,CAAA;QAED,MAAM,IAAI,CAAC,mBAAmB,CAAC,OAAO,CAAC,KAAK,CAAC,IAAI,EAAE,IAAI,CAAC,SAAS,CAAC,OAAO,CAAC,EAAE,OAAO,CAAC,CAAC;IACvF,CAAC;IAED,KAAK,CAAC,KAAK;QACT,MAAM,IAAI,CAAC,mBAAmB,CAAC,KAAK,EAAE,CAAC;IACzC,CAAC;IAED,KAAK,CAAC,IAAI;QACR,MAAM,IAAI,CAAC,mBAAmB,CAAC,IAAI,EAAE,CAAC;IACxC,CAAC;IAED,MAAM;QACJ,OAAO,IAAI,CAAC,mBAAmB,CAAC,MAAM,CAAC;IACzC,CAAC;IAED,OAAO,CAAC,OAAiC;QACvC,IAAI,CAAC,mBAAmB,CAAC,OAAO,CAAC,OAAO,CAAC,CAAC;IAC5C,CAAC;CACF;AAhED,0DAgEC"}
{"version":3,"file":"publisher.js","sourceRoot":"","sources":["../../src/event-bus/publisher.ts"],"names":[],"mappings":";;;AAGA,yDAAsD;AAEtD,MAAa,uBAAuB;IAGlC,mBAAmB,CAAsB;IACzC,UAAU,CAA6B;IAEvC,YAAY,MAGX;QACC,MAAM,EAAE,kBAAkB,EAAE,OAAO,EAAE,GAAG,MAAM,CAAC;QAE/C,IAAI,CAAC,kBAAkB,EAAE,CAAC;YACxB,MAAM,IAAI,KAAK,CACb,2DAA2D,CAC5D,CAAC;QACJ,CAAC;QAED,IAAI,CAAC,mBAAmB,GAAG,kBAAkB,CAAC;QAE9C,IAAI,OAAO,EAAE,SAAS,EAAE,CAAC;YACvB,IAAI,CAAC,UAAU,GAAG,OAAO,CAAC,SAAS,CAAC;QACtC,CAAC;IACH,CAAC;IAED,KAAK,CAAC,OAAO,CACX,KAAY,EACZ,QAIC,EACD,OAEC;QAED,MAAM,iBAAiB,GAAG,IAAA,mCAAgB,EAAC,QAAQ,CAAC,CAAC;QAErD,IAAI,cAAc,GAAG,KAAK,CAAC;QAE3B,IAAI,IAAI,CAAC,UAAU,EAAE,CAAC;YACpB,cAAc,GAAG,IAAI,CAAC,UAAU,CAAC,KAAK,CAAC,CAAC;QAC1C,CAAC;QAED,MAAM,OAAO,GAAG;YACd,KAAK,EAAE,cAAc;YACrB,QAAQ,EAAE,iBAAiB;SAC5B,CAAC;QAEF,MAAM,IAAI,CAAC,mBAAmB,CAAC,OAAO,CACpC,KAAK,CAAC,IAAI,EACV,IAAI,CAAC,SAAS,CAAC,OAAO,CAAC,EACvB,OAAO,CACR,CAAC;IACJ,CAAC;IAED,KAAK,CAAC,KAAK;QACT,MAAM,IAAI,CAAC,mBAAmB,CAAC,KAAK,EAAE,CAAC;IACzC,CAAC;IAED,KAAK,CAAC,IAAI;QACR,MAAM,IAAI,CAAC,mBAAmB,CAAC,IAAI,EAAE,CAAC;IACxC,CAAC;IAED,MAAM;QACJ,OAAO,IAAI,CAAC,mBAAmB,CAAC,MAAM,CAAC;IACzC,CAAC;IAED,OAAO,CAAC,OAAiC;QACvC,IAAI,CAAC,mBAAmB,CAAC,OAAO,CAAC,OAAO,CAAC,CAAC;IAC5C,CAAC;CACF;AAvED,0DAuEC"}

@@ -1,1 +0,1 @@

{"version":3,"file":"validateMetadata.d.ts","sourceRoot":"","sources":["../../src/event-bus/validateMetadata.ts"],"names":[],"mappings":"AAAA,OAAO,EAAE,aAAa,EAAE,MAAM,eAAe,CAAC;AAE9C,wBAAgB,gBAAgB,CAAC,QAAQ,EAAE,OAAO,GAAG,aAAa,CAqCjE"}
{"version":3,"file":"validateMetadata.d.ts","sourceRoot":"","sources":["../../src/event-bus/validateMetadata.ts"],"names":[],"mappings":"AAAA,OAAO,EAAE,aAAa,EAAE,MAAM,eAAe,CAAC;AAE9C,wBAAgB,gBAAgB,CAAC,QAAQ,EAAE,OAAO,GAAG,aAAa,CAyCjE"}

@@ -8,7 +8,7 @@ "use strict";

}
if (typeof metadata !== 'object') {
if (typeof metadata !== "object") {
throw new Error("Invalid Metadata");
}
const typedMetadata = metadata;
if (typeof typedMetadata.id !== 'string') {
if (typeof typedMetadata.id !== "string") {
throw new Error("Invalid Metadata: id is not a string");

@@ -15,0 +15,0 @@ }

@@ -1,1 +0,1 @@

{"version":3,"file":"validateMetadata.js","sourceRoot":"","sources":["../../src/event-bus/validateMetadata.ts"],"names":[],"mappings":";;AAEA,4CAqCC;AArCD,SAAgB,gBAAgB,CAAC,QAAiB;IAChD,IAAG,CAAC,QAAQ,EAAE,CAAC;QACb,MAAM,IAAI,KAAK,CAAC,kCAAkC,CAAC,CAAC;IACtD,CAAC;IAED,IAAG,OAAO,QAAQ,KAAK,QAAQ,EAAE,CAAC;QAChC,MAAM,IAAI,KAAK,CAAC,kBAAkB,CAAC,CAAC;IACtC,CAAC;IAED,MAAM,aAAa,GAAG,QAAyB,CAAC;IAEhD,IAAI,OAAO,aAAa,CAAC,EAAE,KAAK,QAAQ,EAAE,CAAC;QACzC,MAAM,IAAI,KAAK,CAAC,sCAAsC,CAAC,CAAC;IAC1D,CAAC;IAED,IAAI,aAAa,CAAC,EAAE,CAAC,MAAM,KAAK,CAAC,EAAE,CAAC;QAClC,MAAM,IAAI,KAAK,CAAC,yCAAyC,CAAC,CAAC;IAC7D,CAAC;IAED,IAAI,OAAO,aAAa,CAAC,SAAS,KAAK,QAAQ,EAAE,CAAC;QAChD,MAAM,IAAI,KAAK,CAAC,6CAA6C,CAAC,CAAC;IACjE,CAAC;IAED,IAAI,CAAC,kBAAkB,CAAC,aAAa,CAAC,SAAS,CAAC,EAAE,CAAC;QACjD,MAAM,IAAI,KAAK,CAAC,iEAAiE,CAAC,CAAC;IACrF,CAAC;IAED,IAAI,aAAa,CAAC,MAAM,KAAK,SAAS,EAAE,CAAC;QACvC,IAAI,OAAO,aAAa,CAAC,MAAM,KAAK,QAAQ,EAAE,CAAC;YAC7C,MAAM,IAAI,KAAK,CAAC,2DAA2D,CAAC,CAAC;QAC/E,CAAC;QACD,IAAI,CAAC,MAAM,CAAC,QAAQ,CAAC,aAAa,CAAC,MAAM,CAAC,EAAE,CAAC;YAC3C,MAAM,IAAI,KAAK,CAAC,kDAAkD,CAAC,CAAC;QACtE,CAAC;IACH,CAAC;IAED,OAAO,aAAa,CAAC;AACvB,CAAC;AAGD,SAAS,kBAAkB,CAAC,KAAa;IACvC,MAAM,KAAK,GAAG,KAAK,CAAC,KAAK,CACvB,gFAAgF,CACjF,CAAC;IACF,IAAI,CAAC,KAAK;QAAE,OAAO,KAAK,CAAC;IAEzB,MAAM,CAAC,CAAC,EAAE,CAAC,EAAE,CAAC,EAAE,CAAC,EAAE,CAAC,EAAE,GAAG,EAAE,CAAC,CAAC,GAAG,KAAK,CAAC;IAEtC,MAAM,IAAI,GAAG,IAAI,IAAI,CAAC,KAAK,CAAC,CAAC;IAE7B,OAAO,CACL,CAAC,KAAK,CAAC,IAAI,CAAC,OAAO,EAAE,CAAC;QACtB,IAAI,CAAC,cAAc,EAAE,KAAK,MAAM,CAAC,CAAC,CAAC;QACnC,IAAI,CAAC,WAAW,EAAE,GAAG,CAAC,KAAK,MAAM,CAAC,CAAC,CAAC;QACpC,IAAI,CAAC,UAAU,EAAE,KAAK,MAAM,CAAC,CAAC,CAAC;QAC/B,IAAI,CAAC,WAAW,EAAE,KAAK,MAAM,CAAC,CAAC,CAAC;QAChC,IAAI,CAAC,aAAa,EAAE,KAAK,MAAM,CAAC,GAAG,CAAC;QACpC,IAAI,CAAC,aAAa,EAAE,KAAK,MAAM,CAAC,CAAC,CAAC,CACnC,CAAC;AACJ,CAAC"}
{"version":3,"file":"validateMetadata.js","sourceRoot":"","sources":["../../src/event-bus/validateMetadata.ts"],"names":[],"mappings":";;AAEA,4CAyCC;AAzCD,SAAgB,gBAAgB,CAAC,QAAiB;IAChD,IAAI,CAAC,QAAQ,EAAE,CAAC;QACd,MAAM,IAAI,KAAK,CAAC,kCAAkC,CAAC,CAAC;IACtD,CAAC;IAED,IAAI,OAAO,QAAQ,KAAK,QAAQ,EAAE,CAAC;QACjC,MAAM,IAAI,KAAK,CAAC,kBAAkB,CAAC,CAAC;IACtC,CAAC;IAED,MAAM,aAAa,GAAG,QAAyB,CAAC;IAEhD,IAAI,OAAO,aAAa,CAAC,EAAE,KAAK,QAAQ,EAAE,CAAC;QACzC,MAAM,IAAI,KAAK,CAAC,sCAAsC,CAAC,CAAC;IAC1D,CAAC;IAED,IAAI,aAAa,CAAC,EAAE,CAAC,MAAM,KAAK,CAAC,EAAE,CAAC;QAClC,MAAM,IAAI,KAAK,CAAC,yCAAyC,CAAC,CAAC;IAC7D,CAAC;IAED,IAAI,OAAO,aAAa,CAAC,SAAS,KAAK,QAAQ,EAAE,CAAC;QAChD,MAAM,IAAI,KAAK,CAAC,6CAA6C,CAAC,CAAC;IACjE,CAAC;IAED,IAAI,CAAC,kBAAkB,CAAC,aAAa,CAAC,SAAS,CAAC,EAAE,CAAC;QACjD,MAAM,IAAI,KAAK,CACb,iEAAiE,CAClE,CAAC;IACJ,CAAC;IAED,IAAI,aAAa,CAAC,MAAM,KAAK,SAAS,EAAE,CAAC;QACvC,IAAI,OAAO,aAAa,CAAC,MAAM,KAAK,QAAQ,EAAE,CAAC;YAC7C,MAAM,IAAI,KAAK,CACb,2DAA2D,CAC5D,CAAC;QACJ,CAAC;QACD,IAAI,CAAC,MAAM,CAAC,QAAQ,CAAC,aAAa,CAAC,MAAM,CAAC,EAAE,CAAC;YAC3C,MAAM,IAAI,KAAK,CAAC,kDAAkD,CAAC,CAAC;QACtE,CAAC;IACH,CAAC;IAED,OAAO,aAAa,CAAC;AACvB,CAAC;AAED,SAAS,kBAAkB,CAAC,KAAa;IACvC,MAAM,KAAK,GAAG,KAAK,CAAC,KAAK,CACvB,gFAAgF,CACjF,CAAC;IACF,IAAI,CAAC,KAAK;QAAE,OAAO,KAAK,CAAC;IAEzB,MAAM,CAAC,CAAC,EAAE,CAAC,EAAE,CAAC,EAAE,CAAC,EAAE,CAAC,EAAE,GAAG,EAAE,CAAC,CAAC,GAAG,KAAK,CAAC;IAEtC,MAAM,IAAI,GAAG,IAAI,IAAI,CAAC,KAAK,CAAC,CAAC;IAE7B,OAAO,CACL,CAAC,KAAK,CAAC,IAAI,CAAC,OAAO,EAAE,CAAC;QACtB,IAAI,CAAC,cAAc,EAAE,KAAK,MAAM,CAAC,CAAC,CAAC;QACnC,IAAI,CAAC,WAAW,EAAE,GAAG,CAAC,KAAK,MAAM,CAAC,CAAC,CAAC;QACpC,IAAI,CAAC,UAAU,EAAE,KAAK,MAAM,CAAC,CAAC,CAAC;QAC/B,IAAI,CAAC,WAAW,EAAE,KAAK,MAAM,CAAC,CAAC,CAAC;QAChC,IAAI,CAAC,aAAa,EAAE,KAAK,MAAM,CAAC,GAAG,CAAC;QACpC,IAAI,CAAC,aAAa,EAAE,KAAK,MAAM,CAAC,CAAC,CAAC,CACnC,CAAC;AACJ,CAAC"}

@@ -5,9 +5,9 @@ import { Result } from "../result";

import { EventWithMetadata, Repository } from "../repository";
export declare class InMemoryRepository<Entity extends DomainEntity<ReturnType<Entity["readState"]>>> implements Repository<Entity> {
export declare class InMemoryRepository<Entity extends DomainEntity<ReturnType<Entity["readState"]>>, Event extends DomainEventInterface> implements Repository<Entity, Event> {
#private;
constructor(mapper: (id: string, state: ReturnType<Entity["readState"]>) => Entity);
protected readonly store: Map<string, ReturnType<Entity["readState"]>>;
protected readonly eventStore: Map<string, EventWithMetadata[]>;
protected readonly eventStore: Map<string, EventWithMetadata<Event>[]>;
save(entity: Entity): Promise<Result<void, Error>>;
saveWithEvents(entity: Entity, domainEvents: DomainEventInterface | DomainEventInterface[]): Promise<Result<void, Error>>;
saveWithEvents(entity: Entity, domainEvents: Event | Event[]): Promise<Result<void, Error>>;
getById(id: string): Promise<Result<Entity | undefined, Error>>;

@@ -25,6 +25,6 @@ list(params: {

offset: number;
}): Promise<Result<EventWithMetadata[], Error>>;
getEventsAfter(entityId: string, eventId: string, limit?: number): Promise<Result<EventWithMetadata[], Error>>;
on(handler: (entityId: string) => void): void;
}): Promise<Result<EventWithMetadata<Event>[], Error>>;
getEventsAfter(entityId: string, eventId: string, limit?: number): Promise<Result<EventWithMetadata<Event>[], Error>>;
onChanges(handler: (entityId: string) => void): void;
}
//# sourceMappingURL=index.d.ts.map

@@ -1,1 +0,1 @@

{"version":3,"file":"index.d.ts","sourceRoot":"","sources":["../../src/inMemoryRepository/index.ts"],"names":[],"mappings":"AACA,OAAO,EAAM,MAAM,EAAE,MAAM,WAAW,CAAC;AACvC,OAAO,EAAE,YAAY,EAAE,MAAM,iBAAiB,CAAC;AAC/C,OAAO,EAAE,oBAAoB,EAAE,MAAM,gBAAgB,CAAC;AACtD,OAAO,EAAE,iBAAiB,EAAE,UAAU,EAAE,MAAM,eAAe,CAAC;AAG9D,qBAAa,kBAAkB,CAC7B,MAAM,SAAS,YAAY,CAAC,UAAU,CAAC,MAAM,CAAC,WAAW,CAAC,CAAC,CAAC,CAC5D,YAAW,UAAU,CAAC,MAAM,CAAC;;gBAO3B,MAAM,EAAE,CAAC,EAAE,EAAE,MAAM,EAAE,KAAK,EAAE,UAAU,CAAC,MAAM,CAAC,WAAW,CAAC,CAAC,KAAK,MAAM;IAKxE,SAAS,CAAC,QAAQ,CAAC,KAAK,+CAAsD;IAC9E,SAAS,CAAC,QAAQ,CAAC,UAAU,mCAA0C;IAEjE,IAAI,CAAC,MAAM,EAAE,MAAM,GAAG,OAAO,CAAC,MAAM,CAAC,IAAI,EAAE,KAAK,CAAC,CAAC;IAKlD,cAAc,CAClB,MAAM,EAAE,MAAM,EACd,YAAY,EAAE,oBAAoB,GAAG,oBAAoB,EAAE,GAC1D,OAAO,CAAC,MAAM,CAAC,IAAI,EAAE,KAAK,CAAC,CAAC;IA+B/B,OAAO,CAAC,EAAE,EAAE,MAAM,GAAG,OAAO,CAAC,MAAM,CAAC,MAAM,GAAG,SAAS,EAAE,KAAK,CAAC,CAAC;IAU/D,IAAI,CAAC,MAAM,EAAE;QACX,KAAK,EAAE,MAAM,CAAC;QACd,MAAM,EAAE,MAAM,CAAC;KAChB,GAAG,OAAO,CACT,MAAM,CAAC;QAAE,KAAK,EAAE,MAAM,CAAC;QAAC,MAAM,EAAE,MAAM,CAAC;QAAC,IAAI,EAAE,MAAM,EAAE,CAAA;KAAE,EAAE,KAAK,CAAC,CACjE;IAqBD,SAAS,CACP,QAAQ,EAAE,MAAM,EAChB,OAAO,CAAC,EAAE;QAAE,KAAK,EAAE,MAAM,CAAC;QAAC,MAAM,EAAE,MAAM,CAAA;KAAE,GAC1C,OAAO,CAAC,MAAM,CAAC,iBAAiB,EAAE,EAAE,KAAK,CAAC,CAAC;IAa9C,cAAc,CACZ,QAAQ,EAAE,MAAM,EAChB,OAAO,EAAE,MAAM,EACf,KAAK,GAAE,MAAW,GACjB,OAAO,CAAC,MAAM,CAAC,iBAAiB,EAAE,EAAE,KAAK,CAAC,CAAC;IAiB9C,EAAE,CAAC,OAAO,EAAE,CAAC,QAAQ,EAAE,MAAM,KAAK,IAAI,GAAG,IAAI;CAG9C"}
{"version":3,"file":"index.d.ts","sourceRoot":"","sources":["../../src/inMemoryRepository/index.ts"],"names":[],"mappings":"AACA,OAAO,EAAM,MAAM,EAAE,MAAM,WAAW,CAAC;AACvC,OAAO,EAAE,YAAY,EAAE,MAAM,iBAAiB,CAAC;AAC/C,OAAO,EAAE,oBAAoB,EAAE,MAAM,gBAAgB,CAAC;AACtD,OAAO,EAAE,iBAAiB,EAAE,UAAU,EAAE,MAAM,eAAe,CAAC;AAG9D,qBAAa,kBAAkB,CAC7B,MAAM,SAAS,YAAY,CAAC,UAAU,CAAC,MAAM,CAAC,WAAW,CAAC,CAAC,CAAC,EAC5D,KAAK,SAAS,oBAAoB,CAClC,YAAW,UAAU,CAAC,MAAM,EAAE,KAAK,CAAC;;gBAOlC,MAAM,EAAE,CAAC,EAAE,EAAE,MAAM,EAAE,KAAK,EAAE,UAAU,CAAC,MAAM,CAAC,WAAW,CAAC,CAAC,KAAK,MAAM;IAKxE,SAAS,CAAC,QAAQ,CAAC,KAAK,+CAAsD;IAC9E,SAAS,CAAC,QAAQ,CAAC,UAAU,0CAAiD;IAExE,IAAI,CAAC,MAAM,EAAE,MAAM,GAAG,OAAO,CAAC,MAAM,CAAC,IAAI,EAAE,KAAK,CAAC,CAAC;IAKlD,cAAc,CAClB,MAAM,EAAE,MAAM,EACd,YAAY,EAAE,KAAK,GAAG,KAAK,EAAE,GAC5B,OAAO,CAAC,MAAM,CAAC,IAAI,EAAE,KAAK,CAAC,CAAC;IA6B/B,OAAO,CAAC,EAAE,EAAE,MAAM,GAAG,OAAO,CAAC,MAAM,CAAC,MAAM,GAAG,SAAS,EAAE,KAAK,CAAC,CAAC;IAU/D,IAAI,CAAC,MAAM,EAAE;QACX,KAAK,EAAE,MAAM,CAAC;QACd,MAAM,EAAE,MAAM,CAAC;KAChB,GAAG,OAAO,CACT,MAAM,CAAC;QAAE,KAAK,EAAE,MAAM,CAAC;QAAC,MAAM,EAAE,MAAM,CAAC;QAAC,IAAI,EAAE,MAAM,EAAE,CAAA;KAAE,EAAE,KAAK,CAAC,CACjE;IAqBD,SAAS,CACP,QAAQ,EAAE,MAAM,EAChB,OAAO,CAAC,EAAE;QAAE,KAAK,EAAE,MAAM,CAAC;QAAC,MAAM,EAAE,MAAM,CAAA;KAAE,GAC1C,OAAO,CAAC,MAAM,CAAC,iBAAiB,CAAC,KAAK,CAAC,EAAE,EAAE,KAAK,CAAC,CAAC;IAarD,cAAc,CACZ,QAAQ,EAAE,MAAM,EAChB,OAAO,EAAE,MAAM,EACf,KAAK,GAAE,MAAW,GACjB,OAAO,CAAC,MAAM,CAAC,iBAAiB,CAAC,KAAK,CAAC,EAAE,EAAE,KAAK,CAAC,CAAC;IAmBrD,SAAS,CAAC,OAAO,EAAE,CAAC,QAAQ,EAAE,MAAM,KAAK,IAAI,GAAG,IAAI;CAGrD"}

@@ -10,3 +10,3 @@ "use strict";

#emitter = new node_events_1.EventEmitter({
captureRejections: true
captureRejections: true,
});

@@ -35,3 +35,3 @@ constructor(mapper) {

offset: events.length + index,
}
},
};

@@ -71,3 +71,3 @@ });

const events = this.eventStore.get(entityId) || [];
const foundPrecedingEventIndex = events.findIndex(event => event.metadata.id === eventId);
const foundPrecedingEventIndex = events.findIndex((event) => event.metadata.id === eventId);
if (foundPrecedingEventIndex === -1) {

@@ -79,3 +79,3 @@ throw new Error("Unknown event id");

}
on(handler) {
onChanges(handler) {
this.#emitter.on("domainEventsSaved", handler);

@@ -82,0 +82,0 @@ }

@@ -1,1 +0,1 @@

{"version":3,"file":"index.js","sourceRoot":"","sources":["../../src/inMemoryRepository/index.ts"],"names":[],"mappings":";;;AAAA,6CAA2C;AAC3C,sCAAuC;AAIvC,6CAAyC;AAEzC,MAAa,kBAAkB;IAG7B,OAAO,CAAiE;IACxE,QAAQ,GAAG,IAAI,0BAAY,CAAC;QAC1B,iBAAiB,EAAE,IAAI;KACxB,CAAC,CAAC;IAEH,YACE,MAAsE;QAEtE,IAAI,CAAC,OAAO,GAAG,MAAM,CAAC;IACxB,CAAC;IAEkB,KAAK,GAAG,IAAI,GAAG,EAA2C,CAAC;IAC3D,UAAU,GAAG,IAAI,GAAG,EAA+B,CAAC;IAEvE,KAAK,CAAC,IAAI,CAAC,MAAc;QACvB,IAAI,CAAC,KAAK,CAAC,GAAG,CAAC,MAAM,CAAC,EAAE,EAAE,EAAE,MAAM,CAAC,SAAS,EAAE,CAAC,CAAC;QAChD,OAAO,OAAO,CAAC,OAAO,CAAC,IAAA,WAAE,GAAE,CAAC,CAAC;IAC/B,CAAC;IAED,KAAK,CAAC,cAAc,CAClB,MAAc,EACd,YAA2D;QAE3D,IAAI,CAAC,KAAK,CAAC,GAAG,CAAC,MAAM,CAAC,EAAE,EAAE,EAAE,MAAM,CAAC,SAAS,EAAE,CAAC,CAAC;QAEhD,MAAM,MAAM,GAAG,IAAI,CAAC,UAAU,CAAC,GAAG,CAAC,MAAM,CAAC,EAAE,EAAE,CAAC,IAAI,EAAE,CAAC;QAEtD,IAAG,CAAC,KAAK,CAAC,OAAO,CAAC,YAAY,CAAC,EAAE,CAAC;YAChC,YAAY,GAAE,CAAC,YAAY,CAAC,CAAA;QAC9B,CAAC;QAED,MAAM,kBAAkB,GAAG,YAAY,CAAC,GAAG,CAAC,CAAC,KAAK,EAAE,KAAK,EAAE,EAAE;YAC3D,OAAO;gBACL,KAAK;gBACL,QAAQ,EAAE;oBACR,EAAE,EAAE,IAAA,wBAAU,GAAE;oBAChB,SAAS,EAAE,IAAI,IAAI,EAAE,CAAC,WAAW,EAAE;oBACnC,MAAM,EAAE,MAAM,CAAC,MAAM,GAAG,KAAK;iBAC9B;aACF,CAAA;QACH,CAAC,CAAC,CAAA;QAEF,MAAM,CAAC,IAAI,CACT,GAAG,kBAAkB,CACtB,CAAC;QAEF,IAAI,CAAC,UAAU,CAAC,GAAG,CAAC,MAAM,CAAC,EAAE,EAAE,EAAE,MAAM,CAAC,CAAC;QAEzC,IAAI,CAAC,QAAQ,CAAC,IAAI,CAAC,mBAAmB,EAAE,MAAM,CAAC,EAAE,EAAE,CAAC,CAAC;QAErD,OAAO,OAAO,CAAC,OAAO,CAAC,IAAA,WAAE,GAAE,CAAC,CAAC;IAC/B,CAAC;IAED,OAAO,CAAC,EAAU;QAChB,MAAM,KAAK,GAAG,IAAI,CAAC,KAAK,CAAC,GAAG,CAAC,EAAE,CAAC,CAAC;QAEjC,IAAI,KAAK,KAAK,SAAS,EAAE,CAAC;YACxB,OAAO,OAAO,CAAC,OAAO,CAAC,IAAA,WAAE,EAAC,SAAS,CAAC,CAAC,CAAC;QACxC,CAAC;QAED,OAAO,OAAO,CAAC,OAAO,CAAC,IAAA,WAAE,EAAC,IAAI,CAAC,OAAO,CAAC,EAAE,EAAE,KAAK,CAAC,CAAC,CAAC,CAAC;IACtD,CAAC;IAED,IAAI,CAAC,MAGJ;QAGC,MAAM,QAAQ,GAAa,EAAE,CAAC;QAE9B,IAAI,CAAC,KAAK,CAAC,OAAO,CAAC,CAAC,KAAK,EAAE,EAAE,EAAE,EAAE;YAC/B,QAAQ,CAAC,IAAI,CAAC,IAAI,CAAC,OAAO,CAAC,EAAE,EAAE,KAAK,CAAC,CAAC,CAAC;QACzC,CAAC,CAAC,CAAC;QAEH,MAAM,iBAAiB,GAAG,QAAQ,CAAC,KAAK,CACtC,MAAM,CAAC,MAAM,EACb,MAAM,CAAC,MAAM,GAAG,MAAM,CAAC,KAAK,CAC7B,CAAC;QAEF,OAAO,OAAO,CAAC,OAAO,CACpB,IAAA,WAAE,EAAC;YACD,KAAK,EAAE,MAAM,CAAC,KAAK;YACnB,MAAM,EAAE,MAAM,CAAC,MAAM;YACrB,IAAI,EAAE,iBAAiB;SACxB,CAAC,CACH,CAAC;IACJ,CAAC;IAED,SAAS,CACP,QAAgB,EAChB,OAA2C;QAE3C,MAAM,iBAAiB,GAAG,OAAO,IAAI,EAAE,KAAK,EAAE,GAAG,EAAE,MAAM,EAAE,CAAC,EAAE,CAAC;QAE/D,MAAM,MAAM,GAAG,IAAI,CAAC,UAAU,CAAC,GAAG,CAAC,QAAQ,CAAC,IAAI,EAAE,CAAC;QAEnD,MAAM,eAAe,GAAG,MAAM,CAAC,KAAK,CAClC,iBAAiB,CAAC,MAAM,EACxB,iBAAiB,CAAC,MAAM,GAAG,iBAAiB,CAAC,KAAK,CACnD,CAAC;QAEF,OAAO,OAAO,CAAC,OAAO,CAAC,IAAA,WAAE,EAAC,eAAe,CAAC,CAAC,CAAC;IAC9C,CAAC;IAED,cAAc,CACZ,QAAgB,EAChB,OAAe,EACf,QAAgB,EAAE;QAGlB,MAAM,MAAM,GAAG,IAAI,CAAC,UAAU,CAAC,GAAG,CAAC,QAAQ,CAAC,IAAI,EAAE,CAAC;QAEnD,MAAM,wBAAwB,GAAG,MAAM,CAAC,SAAS,CAAC,KAAK,CAAC,EAAE,CAAC,KAAK,CAAC,QAAQ,CAAC,EAAE,KAAK,OAAO,CAAC,CAAA;QAEzF,IAAG,wBAAwB,KAAK,CAAC,CAAC,EAAE,CAAC;YACnC,MAAM,IAAI,KAAK,CAAC,kBAAkB,CAAC,CAAC;QACtC,CAAC;QAED,MAAM,eAAe,GAAG,MAAM,CAAC,KAAK,CAClC,wBAAwB,EACxB,wBAAwB,GAAG,KAAK,CACjC,CAAC;QAEF,OAAO,OAAO,CAAC,OAAO,CAAC,IAAA,WAAE,EAAC,eAAe,CAAC,CAAC,CAAC;IAC9C,CAAC;IACD,EAAE,CAAC,OAAmC;QACpC,IAAI,CAAC,QAAQ,CAAC,EAAE,CAAC,mBAAmB,EAAE,OAAO,CAAC,CAAC;IACjD,CAAC;CACF;AApID,gDAoIC"}
{"version":3,"file":"index.js","sourceRoot":"","sources":["../../src/inMemoryRepository/index.ts"],"names":[],"mappings":";;;AAAA,6CAA2C;AAC3C,sCAAuC;AAIvC,6CAAyC;AAEzC,MAAa,kBAAkB;IAI7B,OAAO,CAAiE;IACxE,QAAQ,GAAG,IAAI,0BAAY,CAAC;QAC1B,iBAAiB,EAAE,IAAI;KACxB,CAAC,CAAC;IAEH,YACE,MAAsE;QAEtE,IAAI,CAAC,OAAO,GAAG,MAAM,CAAC;IACxB,CAAC;IAEkB,KAAK,GAAG,IAAI,GAAG,EAA2C,CAAC;IAC3D,UAAU,GAAG,IAAI,GAAG,EAAsC,CAAC;IAE9E,KAAK,CAAC,IAAI,CAAC,MAAc;QACvB,IAAI,CAAC,KAAK,CAAC,GAAG,CAAC,MAAM,CAAC,EAAE,EAAE,EAAE,MAAM,CAAC,SAAS,EAAE,CAAC,CAAC;QAChD,OAAO,OAAO,CAAC,OAAO,CAAC,IAAA,WAAE,GAAE,CAAC,CAAC;IAC/B,CAAC;IAED,KAAK,CAAC,cAAc,CAClB,MAAc,EACd,YAA6B;QAE7B,IAAI,CAAC,KAAK,CAAC,GAAG,CAAC,MAAM,CAAC,EAAE,EAAE,EAAE,MAAM,CAAC,SAAS,EAAE,CAAC,CAAC;QAEhD,MAAM,MAAM,GAAG,IAAI,CAAC,UAAU,CAAC,GAAG,CAAC,MAAM,CAAC,EAAE,EAAE,CAAC,IAAI,EAAE,CAAC;QAEtD,IAAI,CAAC,KAAK,CAAC,OAAO,CAAC,YAAY,CAAC,EAAE,CAAC;YACjC,YAAY,GAAG,CAAC,YAAY,CAAC,CAAC;QAChC,CAAC;QAED,MAAM,kBAAkB,GAAG,YAAY,CAAC,GAAG,CAAC,CAAC,KAAK,EAAE,KAAK,EAAE,EAAE;YAC3D,OAAO;gBACL,KAAK;gBACL,QAAQ,EAAE;oBACR,EAAE,EAAE,IAAA,wBAAU,GAAY;oBAC1B,SAAS,EAAE,IAAI,IAAI,EAAE,CAAC,WAAW,EAAE;oBACnC,MAAM,EAAE,MAAM,CAAC,MAAM,GAAG,KAAK;iBAC9B;aACF,CAAC;QACJ,CAAC,CAAC,CAAC;QAEH,MAAM,CAAC,IAAI,CAAC,GAAG,kBAAkB,CAAC,CAAC;QAEnC,IAAI,CAAC,UAAU,CAAC,GAAG,CAAC,MAAM,CAAC,EAAE,EAAE,EAAE,MAAM,CAAC,CAAC;QAEzC,IAAI,CAAC,QAAQ,CAAC,IAAI,CAAC,mBAAmB,EAAE,MAAM,CAAC,EAAE,EAAE,CAAC,CAAC;QAErD,OAAO,OAAO,CAAC,OAAO,CAAC,IAAA,WAAE,GAAE,CAAC,CAAC;IAC/B,CAAC;IAED,OAAO,CAAC,EAAU;QAChB,MAAM,KAAK,GAAG,IAAI,CAAC,KAAK,CAAC,GAAG,CAAC,EAAE,CAAC,CAAC;QAEjC,IAAI,KAAK,KAAK,SAAS,EAAE,CAAC;YACxB,OAAO,OAAO,CAAC,OAAO,CAAC,IAAA,WAAE,EAAC,SAAS,CAAC,CAAC,CAAC;QACxC,CAAC;QAED,OAAO,OAAO,CAAC,OAAO,CAAC,IAAA,WAAE,EAAC,IAAI,CAAC,OAAO,CAAC,EAAE,EAAE,KAAK,CAAC,CAAC,CAAC,CAAC;IACtD,CAAC;IAED,IAAI,CAAC,MAGJ;QAGC,MAAM,QAAQ,GAAa,EAAE,CAAC;QAE9B,IAAI,CAAC,KAAK,CAAC,OAAO,CAAC,CAAC,KAAK,EAAE,EAAE,EAAE,EAAE;YAC/B,QAAQ,CAAC,IAAI,CAAC,IAAI,CAAC,OAAO,CAAC,EAAE,EAAE,KAAK,CAAC,CAAC,CAAC;QACzC,CAAC,CAAC,CAAC;QAEH,MAAM,iBAAiB,GAAG,QAAQ,CAAC,KAAK,CACtC,MAAM,CAAC,MAAM,EACb,MAAM,CAAC,MAAM,GAAG,MAAM,CAAC,KAAK,CAC7B,CAAC;QAEF,OAAO,OAAO,CAAC,OAAO,CACpB,IAAA,WAAE,EAAC;YACD,KAAK,EAAE,MAAM,CAAC,KAAK;YACnB,MAAM,EAAE,MAAM,CAAC,MAAM;YACrB,IAAI,EAAE,iBAAiB;SACxB,CAAC,CACH,CAAC;IACJ,CAAC;IAED,SAAS,CACP,QAAgB,EAChB,OAA2C;QAE3C,MAAM,iBAAiB,GAAG,OAAO,IAAI,EAAE,KAAK,EAAE,GAAG,EAAE,MAAM,EAAE,CAAC,EAAE,CAAC;QAE/D,MAAM,MAAM,GAAG,IAAI,CAAC,UAAU,CAAC,GAAG,CAAC,QAAQ,CAAC,IAAI,EAAE,CAAC;QAEnD,MAAM,eAAe,GAAG,MAAM,CAAC,KAAK,CAClC,iBAAiB,CAAC,MAAM,EACxB,iBAAiB,CAAC,MAAM,GAAG,iBAAiB,CAAC,KAAK,CACnD,CAAC;QAEF,OAAO,OAAO,CAAC,OAAO,CAAC,IAAA,WAAE,EAAC,eAAe,CAAC,CAAC,CAAC;IAC9C,CAAC;IAED,cAAc,CACZ,QAAgB,EAChB,OAAe,EACf,QAAgB,EAAE;QAElB,MAAM,MAAM,GAAG,IAAI,CAAC,UAAU,CAAC,GAAG,CAAC,QAAQ,CAAC,IAAI,EAAE,CAAC;QAEnD,MAAM,wBAAwB,GAAG,MAAM,CAAC,SAAS,CAC/C,CAAC,KAAK,EAAE,EAAE,CAAC,KAAK,CAAC,QAAQ,CAAC,EAAE,KAAK,OAAO,CACzC,CAAC;QAEF,IAAI,wBAAwB,KAAK,CAAC,CAAC,EAAE,CAAC;YACpC,MAAM,IAAI,KAAK,CAAC,kBAAkB,CAAC,CAAC;QACtC,CAAC;QAED,MAAM,eAAe,GAAG,MAAM,CAAC,KAAK,CAClC,wBAAwB,EACxB,wBAAwB,GAAG,KAAK,CACjC,CAAC;QAEF,OAAO,OAAO,CAAC,OAAO,CAAC,IAAA,WAAE,EAAC,eAAe,CAAC,CAAC,CAAC;IAC9C,CAAC;IAED,SAAS,CAAC,OAAmC;QAC3C,IAAI,CAAC,QAAQ,CAAC,EAAE,CAAC,mBAAmB,EAAE,OAAO,CAAC,CAAC;IACjD,CAAC;CACF;AArID,gDAqIC"}
import { Result } from "./result/index";
import { DomainEntity } from "./domainEntity";
import { DomainEventInterface } from "./domainEvent";
export interface EventWithMetadata {
event: DomainEventInterface;
export interface EventWithMetadata<Event extends DomainEventInterface> {
event: Event;
metadata: EventMetadata;

@@ -13,3 +13,3 @@ }

}
export interface Repository<Entity extends DomainEntity<ReturnType<Entity["readState"]>>> {
export interface Repository<Entity extends DomainEntity<ReturnType<Entity["readState"]>>, Event extends DomainEventInterface> {
save(entity: Entity): Promise<Result<void, Error>>;

@@ -29,6 +29,6 @@ saveWithEvents(entity: Entity, domainEvents: DomainEventInterface | DomainEventInterface[]): Promise<Result<void, Error>>;

offset: number;
}): Promise<Result<EventWithMetadata[], Error>>;
getEventsAfter(entityId: string, eventId: string, limit: number): Promise<Result<EventWithMetadata[], Error>>;
on(handler: (entityId: string) => void): void;
}): Promise<Result<EventWithMetadata<Event>[], Error>>;
getEventsAfter(entityId: string, eventId: string, limit: number): Promise<Result<EventWithMetadata<Event>[], Error>>;
onChanges(handler: (entityId: string) => void): void;
}
//# sourceMappingURL=repository.d.ts.map

@@ -1,1 +0,1 @@

{"version":3,"file":"repository.d.ts","sourceRoot":"","sources":["../src/repository.ts"],"names":[],"mappings":"AAAA,OAAO,EAAE,MAAM,EAAE,MAAM,gBAAgB,CAAC;AAExC,OAAO,EAAE,YAAY,EAAE,MAAM,gBAAgB,CAAC;AAC9C,OAAO,EAAE,oBAAoB,EAAE,MAAM,eAAe,CAAC;AAErD,MAAM,WAAW,iBAAiB;IAChC,KAAK,EAAE,oBAAoB,CAAC;IAC5B,QAAQ,EAAE,aAAa,CAAA;CACxB;AAED,MAAM,WAAW,aAAa;IAC5B,EAAE,EAAE,MAAM,CAAC;IACX,MAAM,CAAC,EAAE,MAAM,CAAC;IAChB,SAAS,EAAE,MAAM,CAAC;CACnB;AACD,MAAM,WAAW,UAAU,CACzB,MAAM,SAAS,YAAY,CAAC,UAAU,CAAC,MAAM,CAAC,WAAW,CAAC,CAAC,CAAC;IAE5D,IAAI,CAAC,MAAM,EAAE,MAAM,GAAG,OAAO,CAAC,MAAM,CAAC,IAAI,EAAE,KAAK,CAAC,CAAC,CAAC;IAEnD,cAAc,CACZ,MAAM,EAAE,MAAM,EACd,YAAY,EAAE,oBAAoB,GAAG,oBAAoB,EAAE,GAC1D,OAAO,CAAC,MAAM,CAAC,IAAI,EAAE,KAAK,CAAC,CAAC,CAAC;IAEhC,OAAO,CAAC,EAAE,EAAE,MAAM,GAAG,OAAO,CAAC,MAAM,CAAC,MAAM,GAAG,SAAS,EAAE,KAAK,CAAC,CAAC,CAAC;IAEhE,IAAI,CAAC,MAAM,EAAE;QACX,KAAK,EAAE,MAAM,CAAC;QACd,MAAM,EAAE,MAAM,CAAC;KAChB,GAAG,OAAO,CAAC,MAAM,CAAC;QAAE,KAAK,EAAE,MAAM,CAAC;QAAC,MAAM,EAAE,MAAM,CAAC;QAAC,IAAI,EAAE,MAAM,EAAE,CAAA;KAAE,EAAE,KAAK,CAAC,CAAC,CAAC;IAE9E,SAAS,CACP,QAAQ,EAAE,MAAM,EAChB,OAAO,CAAC,EAAE;QAAE,KAAK,EAAE,MAAM,CAAC;QAAC,MAAM,EAAE,MAAM,CAAA;KAAE,GAC1C,OAAO,CAAC,MAAM,CAAC,iBAAiB,EAAE,EAAE,KAAK,CAAC,CAAC,CAAC;IAE/C,cAAc,CAAC,QAAQ,EAAE,MAAM,EAAE,OAAO,EAAE,MAAM,EAAE,KAAK,EAAE,MAAM,GAAG,OAAO,CAAC,MAAM,CAAC,iBAAiB,EAAE,EAAC,KAAK,CAAC,CAAC,CAAC;IAE7G,EAAE,CAAC,OAAO,EAAE,CAAC,QAAQ,EAAE,MAAM,KAAK,IAAI,GAAG,IAAI,CAAC;CAC/C"}
{"version":3,"file":"repository.d.ts","sourceRoot":"","sources":["../src/repository.ts"],"names":[],"mappings":"AAAA,OAAO,EAAE,MAAM,EAAE,MAAM,gBAAgB,CAAC;AAExC,OAAO,EAAE,YAAY,EAAE,MAAM,gBAAgB,CAAC;AAC9C,OAAO,EAAE,oBAAoB,EAAE,MAAM,eAAe,CAAC;AAErD,MAAM,WAAW,iBAAiB,CAAC,KAAK,SAAS,oBAAoB;IACnE,KAAK,EAAE,KAAK,CAAC;IACb,QAAQ,EAAE,aAAa,CAAC;CACzB;AAED,MAAM,WAAW,aAAa;IAC5B,EAAE,EAAE,MAAM,CAAC;IACX,MAAM,CAAC,EAAE,MAAM,CAAC;IAChB,SAAS,EAAE,MAAM,CAAC;CACnB;AACD,MAAM,WAAW,UAAU,CACzB,MAAM,SAAS,YAAY,CAAC,UAAU,CAAC,MAAM,CAAC,WAAW,CAAC,CAAC,CAAC,EAC5D,KAAK,SAAS,oBAAoB;IAElC,IAAI,CAAC,MAAM,EAAE,MAAM,GAAG,OAAO,CAAC,MAAM,CAAC,IAAI,EAAE,KAAK,CAAC,CAAC,CAAC;IAEnD,cAAc,CACZ,MAAM,EAAE,MAAM,EACd,YAAY,EAAE,oBAAoB,GAAG,oBAAoB,EAAE,GAC1D,OAAO,CAAC,MAAM,CAAC,IAAI,EAAE,KAAK,CAAC,CAAC,CAAC;IAEhC,OAAO,CAAC,EAAE,EAAE,MAAM,GAAG,OAAO,CAAC,MAAM,CAAC,MAAM,GAAG,SAAS,EAAE,KAAK,CAAC,CAAC,CAAC;IAEhE,IAAI,CAAC,MAAM,EAAE;QACX,KAAK,EAAE,MAAM,CAAC;QACd,MAAM,EAAE,MAAM,CAAC;KAChB,GAAG,OAAO,CAAC,MAAM,CAAC;QAAE,KAAK,EAAE,MAAM,CAAC;QAAC,MAAM,EAAE,MAAM,CAAC;QAAC,IAAI,EAAE,MAAM,EAAE,CAAA;KAAE,EAAE,KAAK,CAAC,CAAC,CAAC;IAE9E,SAAS,CACP,QAAQ,EAAE,MAAM,EAChB,OAAO,CAAC,EAAE;QAAE,KAAK,EAAE,MAAM,CAAC;QAAC,MAAM,EAAE,MAAM,CAAA;KAAE,GAC1C,OAAO,CAAC,MAAM,CAAC,iBAAiB,CAAC,KAAK,CAAC,EAAE,EAAE,KAAK,CAAC,CAAC,CAAC;IAEtD,cAAc,CACZ,QAAQ,EAAE,MAAM,EAChB,OAAO,EAAE,MAAM,EACf,KAAK,EAAE,MAAM,GACZ,OAAO,CAAC,MAAM,CAAC,iBAAiB,CAAC,KAAK,CAAC,EAAE,EAAE,KAAK,CAAC,CAAC,CAAC;IAEtD,SAAS,CAAC,OAAO,EAAE,CAAC,QAAQ,EAAE,MAAM,KAAK,IAAI,GAAG,IAAI,CAAC;CACtD"}

@@ -1,2 +0,2 @@

import { ErrorConfig } from './resultError';
import { ErrorConfig } from "./resultError";
export declare function ok<T, E = never>(value: T): Ok<T, E>;

@@ -3,0 +3,0 @@ export declare function ok<T extends void = void, E = never>(value: void): Ok<void, E>;

@@ -1,1 +0,1 @@

{"version":3,"file":"index.d.ts","sourceRoot":"","sources":["../../src/result/index.ts"],"names":[],"mappings":"AAAA,OAAO,EAAE,WAAW,EAAe,MAAM,eAAe,CAAC;AAEzD,wBAAgB,EAAE,CAAC,CAAC,EAAE,CAAC,GAAG,KAAK,EAAE,KAAK,EAAE,CAAC,GAAG,EAAE,CAAC,CAAC,EAAE,CAAC,CAAC,CAAA;AACpD,wBAAgB,EAAE,CAAC,CAAC,SAAS,IAAI,GAAG,IAAI,EAAE,CAAC,GAAG,KAAK,EAAE,KAAK,EAAE,IAAI,GAAG,EAAE,CAAC,IAAI,EAAE,CAAC,CAAC,CAAA;AAK9E,wBAAgB,GAAG,CAAC,CAAC,GAAG,KAAK,EAAE,CAAC,SAAS,MAAM,GAAG,MAAM,EAAE,GAAG,EAAE,CAAC,GAAG,GAAG,CAAC,CAAC,EAAE,CAAC,CAAC,CAAA;AAC5E,wBAAgB,GAAG,CAAC,CAAC,GAAG,KAAK,EAAE,CAAC,GAAG,OAAO,EAAE,GAAG,EAAE,CAAC,GAAG,GAAG,CAAC,CAAC,EAAE,CAAC,CAAC,CAAA;AAC9D,wBAAgB,GAAG,CAAC,CAAC,GAAG,KAAK,EAAE,CAAC,SAAS,IAAI,GAAG,IAAI,EAAE,GAAG,EAAE,IAAI,GAAG,GAAG,CAAC,CAAC,EAAE,IAAI,CAAC,CAAA;AAK9E,MAAM,MAAM,MAAM,CAAC,CAAC,EAAE,CAAC,IAAI,EAAE,CAAC,CAAC,EAAE,CAAC,CAAC,GAAG,GAAG,CAAC,CAAC,EAAE,CAAC,CAAC,CAAA;AAE/C,MAAM,WAAW,OAAO,CAAC,CAAC,EAAE,CAAC;IAC3B;;;;OAIG;IACH,IAAI,IAAI,IAAI,IAAI,EAAE,CAAC,CAAC,EAAE,CAAC,CAAC,CAAA;IAExB;;;;OAIG;IACH,KAAK,IAAI,IAAI,IAAI,GAAG,CAAC,CAAC,EAAE,CAAC,CAAC,CAAA;IAE1B;;;;;;OAMG;IACH,aAAa,CAAC,MAAM,CAAC,EAAE,WAAW,GAAG,CAAC,CAAA;IAEtC;;;;;;;OAOG;IACH,gBAAgB,CAAC,MAAM,CAAC,EAAE,WAAW,GAAG,CAAC,CAAA;CAC1C;AAED,qBAAa,EAAE,CAAC,CAAC,EAAE,CAAC,CAAE,YAAW,OAAO,CAAC,CAAC,EAAE,CAAC,CAAC;IAChC,QAAQ,CAAC,KAAK,EAAE,CAAC;gBAAR,KAAK,EAAE,CAAC;IAE7B,IAAI,IAAI,IAAI,IAAI,EAAE,CAAC,CAAC,EAAE,CAAC,CAAC;IAIxB,KAAK,IAAI,IAAI,IAAI,GAAG,CAAC,CAAC,EAAE,CAAC,CAAC;IAI1B,aAAa,CAAC,CAAC,CAAC,EAAE,WAAW,GAAG,CAAC;IAIjC,gBAAgB,CAAC,MAAM,CAAC,EAAE,WAAW,GAAG,CAAC;CAG1C;AAED,qBAAa,GAAG,CAAC,CAAC,EAAE,CAAC,CAAE,YAAW,OAAO,CAAC,CAAC,EAAE,CAAC,CAAC;IACjC,QAAQ,CAAC,KAAK,EAAE,CAAC;gBAAR,KAAK,EAAE,CAAC;IAE7B,IAAI,IAAI,IAAI,IAAI,EAAE,CAAC,CAAC,EAAE,CAAC,CAAC;IAIxB,KAAK,IAAI,IAAI,IAAI,GAAG,CAAC,CAAC,EAAE,CAAC,CAAC;IAI1B,aAAa,CAAC,MAAM,CAAC,EAAE,WAAW,GAAG,CAAC;IAItC,gBAAgB,CAAC,CAAC,CAAC,EAAE,WAAW,GAAG,CAAC;CAGrC"}
{"version":3,"file":"index.d.ts","sourceRoot":"","sources":["../../src/result/index.ts"],"names":[],"mappings":"AAAA,OAAO,EAAE,WAAW,EAAe,MAAM,eAAe,CAAC;AAEzD,wBAAgB,EAAE,CAAC,CAAC,EAAE,CAAC,GAAG,KAAK,EAAE,KAAK,EAAE,CAAC,GAAG,EAAE,CAAC,CAAC,EAAE,CAAC,CAAC,CAAC;AACrD,wBAAgB,EAAE,CAAC,CAAC,SAAS,IAAI,GAAG,IAAI,EAAE,CAAC,GAAG,KAAK,EAAE,KAAK,EAAE,IAAI,GAAG,EAAE,CAAC,IAAI,EAAE,CAAC,CAAC,CAAC;AAK/E,wBAAgB,GAAG,CAAC,CAAC,GAAG,KAAK,EAAE,CAAC,SAAS,MAAM,GAAG,MAAM,EAAE,GAAG,EAAE,CAAC,GAAG,GAAG,CAAC,CAAC,EAAE,CAAC,CAAC,CAAC;AAC7E,wBAAgB,GAAG,CAAC,CAAC,GAAG,KAAK,EAAE,CAAC,GAAG,OAAO,EAAE,GAAG,EAAE,CAAC,GAAG,GAAG,CAAC,CAAC,EAAE,CAAC,CAAC,CAAC;AAC/D,wBAAgB,GAAG,CAAC,CAAC,GAAG,KAAK,EAAE,CAAC,SAAS,IAAI,GAAG,IAAI,EAAE,GAAG,EAAE,IAAI,GAAG,GAAG,CAAC,CAAC,EAAE,IAAI,CAAC,CAAC;AAK/E,MAAM,MAAM,MAAM,CAAC,CAAC,EAAE,CAAC,IAAI,EAAE,CAAC,CAAC,EAAE,CAAC,CAAC,GAAG,GAAG,CAAC,CAAC,EAAE,CAAC,CAAC,CAAC;AAEhD,MAAM,WAAW,OAAO,CAAC,CAAC,EAAE,CAAC;IAC3B;;;;OAIG;IACH,IAAI,IAAI,IAAI,IAAI,EAAE,CAAC,CAAC,EAAE,CAAC,CAAC,CAAC;IAEzB;;;;OAIG;IACH,KAAK,IAAI,IAAI,IAAI,GAAG,CAAC,CAAC,EAAE,CAAC,CAAC,CAAC;IAE3B;;;;;;OAMG;IACH,aAAa,CAAC,MAAM,CAAC,EAAE,WAAW,GAAG,CAAC,CAAC;IAEvC;;;;;;;OAOG;IACH,gBAAgB,CAAC,MAAM,CAAC,EAAE,WAAW,GAAG,CAAC,CAAC;CAC3C;AAED,qBAAa,EAAE,CAAC,CAAC,EAAE,CAAC,CAAE,YAAW,OAAO,CAAC,CAAC,EAAE,CAAC,CAAC;IAChC,QAAQ,CAAC,KAAK,EAAE,CAAC;gBAAR,KAAK,EAAE,CAAC;IAE7B,IAAI,IAAI,IAAI,IAAI,EAAE,CAAC,CAAC,EAAE,CAAC,CAAC;IAIxB,KAAK,IAAI,IAAI,IAAI,GAAG,CAAC,CAAC,EAAE,CAAC,CAAC;IAI1B,aAAa,CAAC,CAAC,CAAC,EAAE,WAAW,GAAG,CAAC;IAIjC,gBAAgB,CAAC,MAAM,CAAC,EAAE,WAAW,GAAG,CAAC;CAG1C;AAED,qBAAa,GAAG,CAAC,CAAC,EAAE,CAAC,CAAE,YAAW,OAAO,CAAC,CAAC,EAAE,CAAC,CAAC;IACjC,QAAQ,CAAC,KAAK,EAAE,CAAC;gBAAR,KAAK,EAAE,CAAC;IAE7B,IAAI,IAAI,IAAI,IAAI,EAAE,CAAC,CAAC,EAAE,CAAC,CAAC;IAIxB,KAAK,IAAI,IAAI,IAAI,GAAG,CAAC,CAAC,EAAE,CAAC,CAAC;IAI1B,aAAa,CAAC,MAAM,CAAC,EAAE,WAAW,GAAG,CAAC;IAItC,gBAAgB,CAAC,CAAC,CAAC,EAAE,WAAW,GAAG,CAAC;CAGrC"}

@@ -28,3 +28,3 @@ "use strict";

_unsafeUnwrapErr(config) {
throw new resultError_1.ResultError('Called `_unsafeUnwrapErr` on an Ok', this, config);
throw new resultError_1.ResultError("Called `_unsafeUnwrapErr` on an Ok", this, config);
}

@@ -45,3 +45,3 @@ }

_unsafeUnwrap(config) {
throw new resultError_1.ResultError('Called `_unsafeUnwrap` on an Err', this, config);
throw new resultError_1.ResultError("Called `_unsafeUnwrap` on an Err", this, config);
}

@@ -48,0 +48,0 @@ _unsafeUnwrapErr(_) {

@@ -1,1 +0,1 @@

{"version":3,"file":"index.js","sourceRoot":"","sources":["../../src/result/index.ts"],"names":[],"mappings":";;;AAIA,gBAEC;AAKD,kBAEC;AAbD,+CAAyD;AAIzD,SAAgB,EAAE,CAAe,KAAQ;IACvC,OAAO,IAAI,EAAE,CAAC,KAAK,CAAC,CAAA;AACtB,CAAC;AAKD,SAAgB,GAAG,CAAyB,GAAM;IAChD,OAAO,IAAI,GAAG,CAAC,GAAG,CAAC,CAAA;AACrB,CAAC;AAuCD,MAAa,EAAE;IACQ;IAArB,YAAqB,KAAQ;QAAR,UAAK,GAAL,KAAK,CAAG;IAAI,CAAC;IAElC,IAAI;QACF,OAAO,IAAI,CAAA;IACb,CAAC;IAED,KAAK;QACH,OAAO,CAAC,IAAI,CAAC,IAAI,EAAE,CAAA;IACrB,CAAC;IAED,aAAa,CAAC,CAAe;QAC3B,OAAO,IAAI,CAAC,KAAK,CAAA;IACnB,CAAC;IAED,gBAAgB,CAAC,MAAoB;QACnC,MAAM,IAAI,yBAAW,CAAC,oCAAoC,EAAE,IAAI,EAAE,MAAM,CAAC,CAAA;IAC3E,CAAC;CACF;AAlBD,gBAkBC;AAED,MAAa,GAAG;IACO;IAArB,YAAqB,KAAQ;QAAR,UAAK,GAAL,KAAK,CAAG;IAAI,CAAC;IAElC,IAAI;QACF,OAAO,KAAK,CAAA;IACd,CAAC;IAED,KAAK;QACH,OAAO,CAAC,IAAI,CAAC,IAAI,EAAE,CAAA;IACrB,CAAC;IAED,aAAa,CAAC,MAAoB;QAChC,MAAM,IAAI,yBAAW,CAAC,kCAAkC,EAAE,IAAI,EAAE,MAAM,CAAC,CAAA;IACzE,CAAC;IAED,gBAAgB,CAAC,CAAe;QAC9B,OAAO,IAAI,CAAC,KAAK,CAAA;IACnB,CAAC;CACF;AAlBD,kBAkBC"}
{"version":3,"file":"index.js","sourceRoot":"","sources":["../../src/result/index.ts"],"names":[],"mappings":";;;AAIA,gBAEC;AAKD,kBAEC;AAbD,+CAAyD;AAIzD,SAAgB,EAAE,CAAe,KAAQ;IACvC,OAAO,IAAI,EAAE,CAAC,KAAK,CAAC,CAAC;AACvB,CAAC;AAKD,SAAgB,GAAG,CAAyB,GAAM;IAChD,OAAO,IAAI,GAAG,CAAC,GAAG,CAAC,CAAC;AACtB,CAAC;AAuCD,MAAa,EAAE;IACQ;IAArB,YAAqB,KAAQ;QAAR,UAAK,GAAL,KAAK,CAAG;IAAG,CAAC;IAEjC,IAAI;QACF,OAAO,IAAI,CAAC;IACd,CAAC;IAED,KAAK;QACH,OAAO,CAAC,IAAI,CAAC,IAAI,EAAE,CAAC;IACtB,CAAC;IAED,aAAa,CAAC,CAAe;QAC3B,OAAO,IAAI,CAAC,KAAK,CAAC;IACpB,CAAC;IAED,gBAAgB,CAAC,MAAoB;QACnC,MAAM,IAAI,yBAAW,CAAC,oCAAoC,EAAE,IAAI,EAAE,MAAM,CAAC,CAAC;IAC5E,CAAC;CACF;AAlBD,gBAkBC;AAED,MAAa,GAAG;IACO;IAArB,YAAqB,KAAQ;QAAR,UAAK,GAAL,KAAK,CAAG;IAAG,CAAC;IAEjC,IAAI;QACF,OAAO,KAAK,CAAC;IACf,CAAC;IAED,KAAK;QACH,OAAO,CAAC,IAAI,CAAC,IAAI,EAAE,CAAC;IACtB,CAAC;IAED,aAAa,CAAC,MAAoB;QAChC,MAAM,IAAI,yBAAW,CAAC,kCAAkC,EAAE,IAAI,EAAE,MAAM,CAAC,CAAC;IAC1E,CAAC;IAED,gBAAgB,CAAC,CAAe;QAC9B,OAAO,IAAI,CAAC,KAAK,CAAC;IACpB,CAAC;CACF;AAlBD,kBAkBC"}

@@ -1,2 +0,2 @@

import { Result } from '.';
import { Result } from ".";
export interface ErrorConfig {

@@ -7,6 +7,6 @@ withStackTrace: boolean;

data: {
type: 'Ok';
type: "Ok";
value: T;
} | {
type: 'Err';
type: "Err";
value: E;

@@ -13,0 +13,0 @@ };

@@ -1,1 +0,1 @@

{"version":3,"file":"resultError.d.ts","sourceRoot":"","sources":["../../src/result/resultError.ts"],"names":[],"mappings":"AAAA,OAAO,EAAE,MAAM,EAAE,MAAM,GAAG,CAAC;AAE3B,MAAM,WAAW,WAAW;IAC1B,cAAc,EAAE,OAAO,CAAA;CACxB;AAMD,qBAAa,WAAW,CAAC,CAAC,EAAE,CAAC,CAAE,SAAQ,KAAK;IACnC,IAAI,EACP;QACA,IAAI,EAAE,IAAI,CAAC;QACX,KAAK,EAAE,CAAC,CAAC;KACV,GACC;QACA,IAAI,EAAE,KAAK,CAAC;QACZ,KAAK,EAAE,CAAC,CAAC;KACV,CAAA;gBAES,OAAO,EAAE,MAAM,EAAE,MAAM,EAAE,MAAM,CAAC,CAAC,EAAE,CAAC,CAAC,EAAE,MAAM,GAAE,WAAgC;CAgB5F"}
{"version":3,"file":"resultError.d.ts","sourceRoot":"","sources":["../../src/result/resultError.ts"],"names":[],"mappings":"AAAA,OAAO,EAAE,MAAM,EAAE,MAAM,GAAG,CAAC;AAE3B,MAAM,WAAW,WAAW;IAC1B,cAAc,EAAE,OAAO,CAAC;CACzB;AAMD,qBAAa,WAAW,CAAC,CAAC,EAAE,CAAC,CAAE,SAAQ,KAAK;IACnC,IAAI,EACP;QACE,IAAI,EAAE,IAAI,CAAC;QACX,KAAK,EAAE,CAAC,CAAC;KACV,GACD;QACE,IAAI,EAAE,KAAK,CAAC;QACZ,KAAK,EAAE,CAAC,CAAC;KACV,CAAC;gBAGJ,OAAO,EAAE,MAAM,EACf,MAAM,EAAE,MAAM,CAAC,CAAC,EAAE,CAAC,CAAC,EACpB,MAAM,GAAE,WAAgC;CAgB3C"}

@@ -11,8 +11,8 @@ "use strict";

super(message);
this.name = 'UnsafeUnwrapError';
this.name = "UnsafeUnwrapError";
this.data = result.isOk()
? { type: 'Ok', value: result.value }
: { type: 'Err', value: result.error };
? { type: "Ok", value: result.value }
: { type: "Err", value: result.error };
if (config.withStackTrace) {
this.stack = new Error().stack || 'No stack found';
this.stack = new Error().stack || "No stack found";
}

@@ -19,0 +19,0 @@ Object.setPrototypeOf(this, ResultError.prototype);

@@ -1,1 +0,1 @@

{"version":3,"file":"resultError.js","sourceRoot":"","sources":["../../src/result/resultError.ts"],"names":[],"mappings":";;;AAMA,MAAM,kBAAkB,GAAgB;IACtC,cAAc,EAAE,IAAI;CACrB,CAAA;AAED,MAAa,WAAkB,SAAQ,KAAK;IACnC,IAAI,CAQR;IAEH,YAAY,OAAe,EAAE,MAAoB,EAAE,SAAsB,kBAAkB;QACzF,KAAK,CAAC,OAAO,CAAC,CAAC;QAEf,IAAI,CAAC,IAAI,GAAG,mBAAmB,CAAC;QAEhC,IAAI,CAAC,IAAI,GAAG,MAAM,CAAC,IAAI,EAAE;YACvB,CAAC,CAAC,EAAE,IAAI,EAAE,IAAI,EAAE,KAAK,EAAE,MAAM,CAAC,KAAK,EAAE;YACrC,CAAC,CAAC,EAAE,IAAI,EAAE,KAAK,EAAE,KAAK,EAAE,MAAM,CAAC,KAAK,EAAE,CAAA;QAGxC,IAAG,MAAM,CAAC,cAAc,EAAE,CAAC;YACzB,IAAI,CAAC,KAAK,GAAG,IAAI,KAAK,EAAE,CAAC,KAAK,IAAI,gBAAgB,CAAA;QACpD,CAAC;QAED,MAAM,CAAC,cAAc,CAAC,IAAI,EAAE,WAAW,CAAC,SAAS,CAAC,CAAC;IACrD,CAAC;CACF;AA3BD,kCA2BC"}
{"version":3,"file":"resultError.js","sourceRoot":"","sources":["../../src/result/resultError.ts"],"names":[],"mappings":";;;AAMA,MAAM,kBAAkB,GAAgB;IACtC,cAAc,EAAE,IAAI;CACrB,CAAC;AAEF,MAAa,WAAkB,SAAQ,KAAK;IACnC,IAAI,CAQL;IAEN,YACE,OAAe,EACf,MAAoB,EACpB,SAAsB,kBAAkB;QAExC,KAAK,CAAC,OAAO,CAAC,CAAC;QAEf,IAAI,CAAC,IAAI,GAAG,mBAAmB,CAAC;QAEhC,IAAI,CAAC,IAAI,GAAG,MAAM,CAAC,IAAI,EAAE;YACvB,CAAC,CAAC,EAAE,IAAI,EAAE,IAAI,EAAE,KAAK,EAAE,MAAM,CAAC,KAAK,EAAE;YACrC,CAAC,CAAC,EAAE,IAAI,EAAE,KAAK,EAAE,KAAK,EAAE,MAAM,CAAC,KAAK,EAAE,CAAC;QAEzC,IAAI,MAAM,CAAC,cAAc,EAAE,CAAC;YAC1B,IAAI,CAAC,KAAK,GAAG,IAAI,KAAK,EAAE,CAAC,KAAK,IAAI,gBAAgB,CAAC;QACrD,CAAC;QAED,MAAM,CAAC,cAAc,CAAC,IAAI,EAAE,WAAW,CAAC,SAAS,CAAC,CAAC;IACrD,CAAC;CACF;AA9BD,kCA8BC"}
{
"name": "ontologic",
"version": "1.2.0",
"version": "1.2.1",
"description": "",

@@ -5,0 +5,0 @@ "main": "dist/index.js",

@@ -25,2 +25,3 @@ # Ontologic

- **Repository** — Persistence interface that saves entity state and events atomically
- **Event Bus** — Types event bus that allows to publish and listen to your domain events

@@ -27,0 +28,0 @@ ## Examples