@segment/analytics-core - npm Package Compare versions

Comparing version 1.4.1 to 1.5.0

dist/cjs/events/index.js

@@ -9,2 +9,6 @@ "use strict";
 var assertions_1 = require("../validation/assertions");
+/**
+ * This is currently only used by node.js, but the original idea was to have something that could be shared between browser and node.
+ * Unfortunately, there are some differences in the way the two environments handle events, so this is not currently shared.
+ */
 var EventFactory = /** @class */ (function () {
@@ -104,2 +108,3 @@ function EventFactory(settings) {
             'timestamp',
+            'messageId',
         ];
@@ -144,3 +149,3 @@ delete options['integrations'];
         var body = tslib_1.__assign(tslib_1.__assign(tslib_1.__assign({ timestamp: new Date() }, rest), { integrations: allIntegrations, context: context }), overrides);
-        var evt = tslib_1.__assign(tslib_1.__assign({}, body), { messageId: this.createMessageId() });
+        var evt = tslib_1.__assign(tslib_1.__assign({}, body), { messageId: options.messageId || this.createMessageId() });
         (0, assertions_1.validateEvent)(evt);
@@ -147,0 +152,0 @@ return evt;

dist/cjs/events/index.js.map

@@ -1,1 +0,1 @@
-{"version":3,"file":"index.js","sourceRoot":"","sources":["../../../src/events/index.ts"],"names":[],"mappings":";;;;AAAA,uDAA4B;AAC5B,6BAA2B;AAW3B,sCAAsC;AACtC,uDAAwD;AAQxD;IAIE,sBAAY,QAA8B;QACxC,IAAI,CAAC,IAAI,GAAG,QAAQ,CAAC,IAAI,CAAA;QACzB,IAAI,CAAC,eAAe,GAAG,QAAQ,CAAC,eAAe,CAAA;IACjD,CAAC;IAED,4BAAK,GAAL,UACE,KAAa,EACb,UAA4B,EAC5B,OAAqB,EACrB,kBAAiC;QAEjC,OAAO,IAAI,CAAC,SAAS,uCAChB,IAAI,CAAC,SAAS,EAAE,KACnB,KAAK,OAAA,EACL,IAAI,EAAE,OAAO,EACb,UAAU,EAAE,UAAU,aAAV,UAAU,cAAV,UAAU,GAAI,EAAE,EAC5B,OAAO,uBAAO,OAAO,GACrB,YAAY,uBAAO,kBAAkB,KACrC,CAAA;IACJ,CAAC;IAED,2BAAI,GAAJ,UACE,QAAuB,EACvB,IAAmB,EACnB,UAA4B,EAC5B,OAAqB,EACrB,kBAAiC;;QAEjC,IAAM,KAAK,GAAqB;YAC9B,IAAI,EAAE,MAAM;YACZ,UAAU,uBAAO,UAAU,CAAE;YAC7B,OAAO,uBAAO,OAAO,CAAE;YACvB,YAAY,uBAAO,kBAAkB,CAAE;SACxC,CAAA;QAED,IAAI,QAAQ,KAAK,IAAI,EAAE;YACrB,KAAK,CAAC,QAAQ,GAAG,QAAQ,CAAA;YACzB,KAAK,CAAC,UAAU,GAAG,MAAA,KAAK,CAAC,UAAU,mCAAI,EAAE,CAAA;YACzC,KAAK,CAAC,UAAU,CAAC,QAAQ,GAAG,QAAQ,CAAA;SACrC;QAED,IAAI,IAAI,KAAK,IAAI,EAAE;YACjB,KAAK,CAAC,IAAI,GAAG,IAAI,CAAA;SAClB;QAED,OAAO,IAAI,CAAC,SAAS,uCAChB,IAAI,CAAC,SAAS,EAAE,GAChB,KAAK,EACR,CAAA;IACJ,CAAC;IAED,6BAAM,GAAN,UACE,QAAuB,EACvB,MAAqB,EACrB,UAA4B,EAC5B,OAAqB,EACrB,kBAAiC;QAEjC,IAAM,KAAK,GAAqB;YAC9B,IAAI,EAAE,QAAQ;YACd,UAAU,uBAAO,UAAU,CAAE;YAC7B,OAAO,uBAAO,OAAO,CAAE;YACvB,YAAY,uBAAO,kBAAkB,CAAE;SACxC,CAAA;QAED,IAAI,QAAQ,KAAK,IAAI,EAAE;YACrB,KAAK,CAAC,QAAQ,GAAG,QAAQ,CAAA;SAC1B;QAED,IAAI,MAAM,KAAK,IAAI,EAAE;YACnB,KAAK,CAAC,IAAI,GAAG,MAAM,CAAA;SACpB;QAED,OAAO,IAAI,CAAC,SAAS,uCAChB,IAAI,CAAC,SAAS,EAAE,GAChB,KAAK,EACR,CAAA;IACJ,CAAC;IAED,+BAAQ,GAAR,UACE,MAAU,EACV,MAAmB,EACnB,OAAqB,EACrB,kBAAiC;QAEjC,OAAO,IAAI,CAAC,SAAS,uCAChB,IAAI,CAAC,SAAS,EAAE,KACnB,IAAI,EAAE,UAAU,EAChB,MAAM,QAAA,EACN,MAAM,EAAE,MAAM,aAAN,MAAM,cAAN,MAAM,GAAI,EAAE,EACpB,OAAO,uBAAO,OAAO,GACrB,YAAY,EAAE,kBAAkB,IAChC,CAAA;IACJ,CAAC;IAED,4BAAK,GAAL,UACE,OAAW,EACX,MAAoB,EACpB,OAAqB,EACrB,kBAAiC;QAEjC,OAAO,IAAI,CAAC,SAAS,uCAChB,IAAI,CAAC,SAAS,EAAE,KACnB,IAAI,EAAE,OAAO,EACb,MAAM,EAAE,MAAM,aAAN,MAAM,cAAN,MAAM,GAAI,EAAE,EACpB,OAAO,uBAAO,OAAO,GACrB,YAAY,uBAAO,kBAAkB,GAAI,EAAE;YAC3C,OAAO,SAAA,IACP,CAAA;IACJ,CAAC;IAED,4BAAK,GAAL,UACE,EAAU,EACV,IAAmB,EAAE,oCAAoC;IACzD,OAAqB,EACrB,kBAAiC;QAEjC,IAAM,IAAI,GAAqB;YAC7B,MAAM,EAAE,EAAE;YACV,IAAI,EAAE,OAAO;YACb,OAAO,uBAAO,OAAO,CAAE;YACvB,YAAY,uBAAO,kBAAkB,CAAE;SACxC,CAAA;QAED,IAAI,IAAI,KAAK,IAAI,EAAE;YACjB,IAAI,CAAC,UAAU,GAAG,IAAI,CAAA;SACvB;QAED,IAAI,EAAE,KAAK,SAAS,EAAE;YACpB,OAAO,IAAI,CAAC,SAAS,uCAChB,IAAI,GACJ,IAAI,CAAC,SAAS,EAAE,EACnB,CAAA;SACH;QAED,OAAO,IAAI,CAAC,SAAS,uCAChB,IAAI,CAAC,SAAS,EAAE,GAChB,IAAI,EACP,CAAA;IACJ,CAAC;IAEO,gCAAS,GAAjB;QACE,IAAM,IAAI,GAA8B;YACtC,YAAY,EAAE,EAAE;YAChB,OAAO,EAAE,EAAE;SACZ,CAAA;QAED,IAAI,CAAC,IAAI,CAAC,IAAI;YAAE,OAAO,IAAI,CAAA;QAE3B,IAAM,IAAI,GAAG,IAAI,CAAC,IAAI,CAAA;QAEtB,IAAI,IAAI,CAAC,EAAE,EAAE,EAAE;YACb,IAAI,CAAC,MAAM,GAAG,IAAI,CAAC,EAAE,EAAE,CAAA;SACxB;QAED,IAAI,IAAI,CAAC,WAAW,EAAE,EAAE;YACtB,IAAI,CAAC,WAAW,GAAG,IAAI,CAAC,WAAW,EAAE,CAAA;SACtC;QAED,OAAO,IAAI,CAAA;IACb,CAAC;IAED;;;OAGG;IACK,8BAAO,GAAf,UACE,OAAoB;;QAGpB;;;WAGG;QACH,IAAM,iBAAiB,GAAqB;YAC1C,QAAQ;YACR,aAAa;YACb,WAAW;SACZ,CAAA;QAED,OAAO,OAAO,CAAC,cAAc,CAAC,CAAA;QAC9B,IAAM,mBAAmB,GAAG,MAAM,CAAC,IAAI,CAAC,OAAO,CAG5C,CAAA;QAEH,IAAM,OAAO,GAAG,MAAA,OAAO,CAAC,OAAO,mCAAI,EAAE,CAAA;QACrC,IAAM,cAAc,GAAG,EAAE,CAAA;QAEzB,mBAAmB,CAAC,OAAO,CAAC,UAAC,GAAG;YAC9B,IAAI,GAAG,KAAK,SAAS,EAAE;gBACrB,OAAM;aACP;YAED,IAAI,iBAAiB,CAAC,QAAQ,CAAC,GAAG,CAAC,EAAE;gBACnC,IAAA,WAAI,EAAC,cAAc,EAAE,GAAG,EAAE,OAAO,CAAC,GAAG,CAAC,CAAC,CAAA;aACxC;iBAAM;gBACL,IAAA,WAAI,EAAC,OAAO,EAAE,GAAG,EAAE,OAAO,CAAC,GAAG,CAAC,CAAC,CAAA;aACjC;QACH,CAAC,CAAC,CAAA;QAEF,OAAO,CAAC,OAAO,EAAE,cAAc,CAAC,CAAA;IAClC,CAAC;IAEM,gCAAS,GAAhB,UAAiB,KAAuB;;QACtC,IAAM,mBAAmB,GAAG,MAAM,CAAC,IAAI,CAAC,MAAA,KAAK,CAAC,YAAY,mCAAI,EAAE,CAAC,CAAC,MAAM,CACtE,UAAC,gBAAgB,EAAE,IAAI;;;YACrB,6CACK,gBAAgB,gBAClB,IAAI,IAAG,OAAO,CAAC,MAAA,KAAK,CAAC,YAAY,0CAAG,IAAI,CAAC,CAAC,OAC5C;QACH,CAAC,EACD,EAA6B,CAC9B,CAAA;QAED,mCAAmC;QACnC,KAAK,CAAC,OAAO,GAAG,IAAA,aAAM,EAAC,KAAK,CAAC,OAAO,IAAI,EAAE,EAAE,UAAC,CAAC,EAAE,KAAK;YACnD,OAAO,KAAK,KAAK,SAAS,CAAA;QAC5B,CAAC,CAAC,CAAA;QAEF,qDAAqD;QACrD,qGAAqG;QACrG,yGAAyG;QACzG,+GAA+G;QAC/G,IAAM,eAAe,yCAEhB,mBAAmB,GAGnB,MAAA,KAAK,CAAC,OAAO,0CAAE,YAAY,CAC/B,CAAA;QAEK,IAAA,KAAuB,KAAK,CAAC,OAAO;YACxC,CAAC,CAAC,IAAI,CAAC,OAAO,CAAC,KAAK,CAAC,OAAO,CAAC;YAC7B,CAAC,CAAC,EAAE,EAFC,OAAO,QAAA,EAAE,SAAS,QAEnB,CAAA;QAEE,IAAA,OAAO,GAAc,KAAK,QAAnB,EAAK,IAAI,kBAAK,KAAK,EAA5B,WAAoB,CAAF,CAAU;QAElC,IAAM,IAAI,wDACR,SAAS,EAAE,IAAI,IAAI,EAAE,IAClB,IAAI,KACP,YAAY,EAAE,eAAe,EAC7B,OAAO,SAAA,KACJ,SAAS,CACb,CAAA;QAED,IAAM,GAAG,yCACJ,IAAI,KACP,SAAS,EAAE,IAAI,CAAC,eAAe,EAAE,GAClC,CAAA;QAED,IAAA,0BAAa,EAAC,GAAG,CAAC,CAAA;QAClB,OAAO,GAAG,CAAA;IACZ,CAAC;IACH,mBAAC;AAAD,CAAC,AAlQD,IAkQC;AAlQY,oCAAY"}
+{"version":3,"file":"index.js","sourceRoot":"","sources":["../../../src/events/index.ts"],"names":[],"mappings":";;;;AAAA,uDAA4B;AAC5B,6BAA2B;AAW3B,sCAAsC;AACtC,uDAAwD;AAQxD;;;GAGG;AACH;IAIE,sBAAY,QAA8B;QACxC,IAAI,CAAC,IAAI,GAAG,QAAQ,CAAC,IAAI,CAAA;QACzB,IAAI,CAAC,eAAe,GAAG,QAAQ,CAAC,eAAe,CAAA;IACjD,CAAC;IAED,4BAAK,GAAL,UACE,KAAa,EACb,UAA4B,EAC5B,OAAqB,EACrB,kBAAiC;QAEjC,OAAO,IAAI,CAAC,SAAS,uCAChB,IAAI,CAAC,SAAS,EAAE,KACnB,KAAK,OAAA,EACL,IAAI,EAAE,OAAO,EACb,UAAU,EAAE,UAAU,aAAV,UAAU,cAAV,UAAU,GAAI,EAAE,EAC5B,OAAO,uBAAO,OAAO,GACrB,YAAY,uBAAO,kBAAkB,KACrC,CAAA;IACJ,CAAC;IAED,2BAAI,GAAJ,UACE,QAAuB,EACvB,IAAmB,EACnB,UAA4B,EAC5B,OAAqB,EACrB,kBAAiC;;QAEjC,IAAM,KAAK,GAAqB;YAC9B,IAAI,EAAE,MAAM;YACZ,UAAU,uBAAO,UAAU,CAAE;YAC7B,OAAO,uBAAO,OAAO,CAAE;YACvB,YAAY,uBAAO,kBAAkB,CAAE;SACxC,CAAA;QAED,IAAI,QAAQ,KAAK,IAAI,EAAE;YACrB,KAAK,CAAC,QAAQ,GAAG,QAAQ,CAAA;YACzB,KAAK,CAAC,UAAU,GAAG,MAAA,KAAK,CAAC,UAAU,mCAAI,EAAE,CAAA;YACzC,KAAK,CAAC,UAAU,CAAC,QAAQ,GAAG,QAAQ,CAAA;SACrC;QAED,IAAI,IAAI,KAAK,IAAI,EAAE;YACjB,KAAK,CAAC,IAAI,GAAG,IAAI,CAAA;SAClB;QAED,OAAO,IAAI,CAAC,SAAS,uCAChB,IAAI,CAAC,SAAS,EAAE,GAChB,KAAK,EACR,CAAA;IACJ,CAAC;IAED,6BAAM,GAAN,UACE,QAAuB,EACvB,MAAqB,EACrB,UAA4B,EAC5B,OAAqB,EACrB,kBAAiC;QAEjC,IAAM,KAAK,GAAqB;YAC9B,IAAI,EAAE,QAAQ;YACd,UAAU,uBAAO,UAAU,CAAE;YAC7B,OAAO,uBAAO,OAAO,CAAE;YACvB,YAAY,uBAAO,kBAAkB,CAAE;SACxC,CAAA;QAED,IAAI,QAAQ,KAAK,IAAI,EAAE;YACrB,KAAK,CAAC,QAAQ,GAAG,QAAQ,CAAA;SAC1B;QAED,IAAI,MAAM,KAAK,IAAI,EAAE;YACnB,KAAK,CAAC,IAAI,GAAG,MAAM,CAAA;SACpB;QAED,OAAO,IAAI,CAAC,SAAS,uCAChB,IAAI,CAAC,SAAS,EAAE,GAChB,KAAK,EACR,CAAA;IACJ,CAAC;IAED,+BAAQ,GAAR,UACE,MAAU,EACV,MAAmB,EACnB,OAAqB,EACrB,kBAAiC;QAEjC,OAAO,IAAI,CAAC,SAAS,uCAChB,IAAI,CAAC,SAAS,EAAE,KACnB,IAAI,EAAE,UAAU,EAChB,MAAM,QAAA,EACN,MAAM,EAAE,MAAM,aAAN,MAAM,cAAN,MAAM,GAAI,EAAE,EACpB,OAAO,uBAAO,OAAO,GACrB,YAAY,EAAE,kBAAkB,IAChC,CAAA;IACJ,CAAC;IAED,4BAAK,GAAL,UACE,OAAW,EACX,MAAoB,EACpB,OAAqB,EACrB,kBAAiC;QAEjC,OAAO,IAAI,CAAC,SAAS,uCAChB,IAAI,CAAC,SAAS,EAAE,KACnB,IAAI,EAAE,OAAO,EACb,MAAM,EAAE,MAAM,aAAN,MAAM,cAAN,MAAM,GAAI,EAAE,EACpB,OAAO,uBAAO,OAAO,GACrB,YAAY,uBAAO,kBAAkB,GAAI,EAAE;YAC3C,OAAO,SAAA,IACP,CAAA;IACJ,CAAC;IAED,4BAAK,GAAL,UACE,EAAU,EACV,IAAmB,EAAE,oCAAoC;IACzD,OAAqB,EACrB,kBAAiC;QAEjC,IAAM,IAAI,GAAqB;YAC7B,MAAM,EAAE,EAAE;YACV,IAAI,EAAE,OAAO;YACb,OAAO,uBAAO,OAAO,CAAE;YACvB,YAAY,uBAAO,kBAAkB,CAAE;SACxC,CAAA;QAED,IAAI,IAAI,KAAK,IAAI,EAAE;YACjB,IAAI,CAAC,UAAU,GAAG,IAAI,CAAA;SACvB;QAED,IAAI,EAAE,KAAK,SAAS,EAAE;YACpB,OAAO,IAAI,CAAC,SAAS,uCAChB,IAAI,GACJ,IAAI,CAAC,SAAS,EAAE,EACnB,CAAA;SACH;QAED,OAAO,IAAI,CAAC,SAAS,uCAChB,IAAI,CAAC,SAAS,EAAE,GAChB,IAAI,EACP,CAAA;IACJ,CAAC;IAEO,gCAAS,GAAjB;QACE,IAAM,IAAI,GAA8B;YACtC,YAAY,EAAE,EAAE;YAChB,OAAO,EAAE,EAAE;SACZ,CAAA;QAED,IAAI,CAAC,IAAI,CAAC,IAAI;YAAE,OAAO,IAAI,CAAA;QAE3B,IAAM,IAAI,GAAG,IAAI,CAAC,IAAI,CAAA;QAEtB,IAAI,IAAI,CAAC,EAAE,EAAE,EAAE;YACb,IAAI,CAAC,MAAM,GAAG,IAAI,CAAC,EAAE,EAAE,CAAA;SACxB;QAED,IAAI,IAAI,CAAC,WAAW,EAAE,EAAE;YACtB,IAAI,CAAC,WAAW,GAAG,IAAI,CAAC,WAAW,EAAE,CAAA;SACtC;QAED,OAAO,IAAI,CAAA;IACb,CAAC;IAED;;;OAGG;IACK,8BAAO,GAAf,UACE,OAAoB;;QAGpB;;;WAGG;QACH,IAAM,iBAAiB,GAAqB;YAC1C,QAAQ;YACR,aAAa;YACb,WAAW;YACX,WAAW;SACZ,CAAA;QAED,OAAO,OAAO,CAAC,cAAc,CAAC,CAAA;QAC9B,IAAM,mBAAmB,GAAG,MAAM,CAAC,IAAI,CAAC,OAAO,CAG5C,CAAA;QAEH,IAAM,OAAO,GAAG,MAAA,OAAO,CAAC,OAAO,mCAAI,EAAE,CAAA;QACrC,IAAM,cAAc,GAAG,EAAE,CAAA;QAEzB,mBAAmB,CAAC,OAAO,CAAC,UAAC,GAAG;YAC9B,IAAI,GAAG,KAAK,SAAS,EAAE;gBACrB,OAAM;aACP;YAED,IAAI,iBAAiB,CAAC,QAAQ,CAAC,GAAG,CAAC,EAAE;gBACnC,IAAA,WAAI,EAAC,cAAc,EAAE,GAAG,EAAE,OAAO,CAAC,GAAG,CAAC,CAAC,CAAA;aACxC;iBAAM;gBACL,IAAA,WAAI,EAAC,OAAO,EAAE,GAAG,EAAE,OAAO,CAAC,GAAG,CAAC,CAAC,CAAA;aACjC;QACH,CAAC,CAAC,CAAA;QAEF,OAAO,CAAC,OAAO,EAAE,cAAc,CAAC,CAAA;IAClC,CAAC;IAEM,gCAAS,GAAhB,UAAiB,KAAuB;;QACtC,IAAM,mBAAmB,GAAG,MAAM,CAAC,IAAI,CAAC,MAAA,KAAK,CAAC,YAAY,mCAAI,EAAE,CAAC,CAAC,MAAM,CACtE,UAAC,gBAAgB,EAAE,IAAI;;;YACrB,6CACK,gBAAgB,gBAClB,IAAI,IAAG,OAAO,CAAC,MAAA,KAAK,CAAC,YAAY,0CAAG,IAAI,CAAC,CAAC,OAC5C;QACH,CAAC,EACD,EAA6B,CAC9B,CAAA;QAED,mCAAmC;QACnC,KAAK,CAAC,OAAO,GAAG,IAAA,aAAM,EAAC,KAAK,CAAC,OAAO,IAAI,EAAE,EAAE,UAAC,CAAC,EAAE,KAAK;YACnD,OAAO,KAAK,KAAK,SAAS,CAAA;QAC5B,CAAC,CAAC,CAAA;QAEF,qDAAqD;QACrD,qGAAqG;QACrG,yGAAyG;QACzG,+GAA+G;QAC/G,IAAM,eAAe,yCAEhB,mBAAmB,GAGnB,MAAA,KAAK,CAAC,OAAO,0CAAE,YAAY,CAC/B,CAAA;QAEK,IAAA,KAAuB,KAAK,CAAC,OAAO;YACxC,CAAC,CAAC,IAAI,CAAC,OAAO,CAAC,KAAK,CAAC,OAAO,CAAC;YAC7B,CAAC,CAAC,EAAE,EAFC,OAAO,QAAA,EAAE,SAAS,QAEnB,CAAA;QAEE,IAAA,OAAO,GAAc,KAAK,QAAnB,EAAK,IAAI,kBAAK,KAAK,EAA5B,WAAoB,CAAF,CAAU;QAElC,IAAM,IAAI,wDACR,SAAS,EAAE,IAAI,IAAI,EAAE,IAClB,IAAI,KACP,YAAY,EAAE,eAAe,EAC7B,OAAO,SAAA,KACJ,SAAS,CACb,CAAA;QAED,IAAM,GAAG,yCACJ,IAAI,KACP,SAAS,EAAE,OAAO,CAAC,SAAS,IAAI,IAAI,CAAC,eAAe,EAAE,GACvD,CAAA;QAED,IAAA,0BAAa,EAAC,GAAG,CAAC,CAAA;QAClB,OAAO,GAAG,CAAA;IACZ,CAAC;IACH,mBAAC;AAAD,CAAC,AAnQD,IAmQC;AAnQY,oCAAY"}

dist/cjs/queue/event-queue.js

@@ -37,20 +37,21 @@ "use strict";
                 switch (_a.label) {
-                    case 0: return [4 /*yield*/, Promise.resolve(plugin.load(ctx, instance))
-                            .then(function () {
-                            _this.plugins.push(plugin);
-                        })
-                            .catch(function (err) {
-                            if (plugin.type === 'destination') {
-                                _this.failedInitializations.push(plugin.name);
-                                console.warn(plugin.name, err);
-                                ctx.log('warn', 'Failed to load destination', {
-                                    plugin: plugin.name,
-                                    error: err,
-                                });
-                                return;
-                            }
-                            throw err;
-                        })];
-                    case 1:
+                    case 0:
+                        if (!(plugin.type === 'destination' && plugin.name !== 'Segment.io')) return [3 /*break*/, 1];
+                        plugin.load(ctx, instance).catch(function (err) {
+                            _this.failedInitializations.push(plugin.name);
+                            _this.emit('initialization_failure', plugin);
+                            console.warn(plugin.name, err);
+                            ctx.log('warn', 'Failed to load destination', {
+                                plugin: plugin.name,
+                                error: err,
+                            });
+                            _this.plugins = _this.plugins.filter(function (p) { return p === plugin; });
+                        });
+                        return [3 /*break*/, 3];
+                    case 1: return [4 /*yield*/, plugin.load(ctx, instance)];
+                    case 2:
                         _a.sent();
+                        _a.label = 3;
+                    case 3:
+                        this.plugins.push(plugin);
                         return [2 /*return*/];
@@ -57,0 +58,0 @@ }

dist/cjs/queue/event-queue.js.map

@@ -1,1 +0,1 @@
-{"version":3,"file":"event-queue.js","sourceRoot":"","sources":["../../../src/queue/event-queue.ts"],"names":[],"mappings":";;;;AACA,8CAA2C;AAC3C,oDAAwE;AAExE,sCAA4D;AAC5D,4EAA0D;AAG1D,iDAA+D;AAC/D,uCAA4C;AAW5C;IAGU,0CAAuC;IAc/C,wBAAY,aAAiC;QAA7C,YACE,iBAAO,SAMR;QApBD;;;;;;WAMG;QACH,mBAAa,GAAc,IAAA,4BAAe,GAAE,CAAA;QAE5C,aAAO,GAAa,EAAE,CAAA;QACtB,2BAAqB,GAAa,EAAE,CAAA;QAC5B,cAAQ,GAAG,KAAK,CAAA;QAKtB,KAAI,CAAC,KAAK,GAAG,aAAa,CAAA;QAC1B,KAAI,CAAC,KAAK,CAAC,EAAE,CAAC,sCAAqB,EAAE;YACnC,KAAI,CAAC,aAAa,CAAC,CAAC,CAAC,CAAA;QACvB,CAAC,CAAC,CAAA;;IACJ,CAAC;IAEK,iCAAQ,GAAd,UACE,GAAQ,EACR,MAAc,EACd,QAAuB;;;;;4BAEvB,qBAAM,OAAO,CAAC,OAAO,CAAC,MAAM,CAAC,IAAI,CAAC,GAAG,EAAE,QAAQ,CAAC,CAAC;6BAC9C,IAAI,CAAC;4BACJ,KAAI,CAAC,OAAO,CAAC,IAAI,CAAC,MAAM,CAAC,CAAA;wBAC3B,CAAC,CAAC;6BACD,KAAK,CAAC,UAAC,GAAG;4BACT,IAAI,MAAM,CAAC,IAAI,KAAK,aAAa,EAAE;gCACjC,KAAI,CAAC,qBAAqB,CAAC,IAAI,CAAC,MAAM,CAAC,IAAI,CAAC,CAAA;gCAC5C,OAAO,CAAC,IAAI,CAAC,MAAM,CAAC,IAAI,EAAE,GAAG,CAAC,CAAA;gCAE9B,GAAG,CAAC,GAAG,CAAC,MAAM,EAAE,4BAA4B,EAAE;oCAC5C,MAAM,EAAE,MAAM,CAAC,IAAI;oCACnB,KAAK,EAAE,GAAG;iCACX,CAAC,CAAA;gCAEF,OAAM;6BACP;4BAED,MAAM,GAAG,CAAA;wBACX,CAAC,CAAC,EAAA;;wBAlBJ,SAkBI,CAAA;;;;;KACL;IAEK,mCAAU,GAAhB,UACE,GAAQ,EACR,MAAuB,EACvB,QAAuB;;;;;;;6BAGjB,MAAM,CAAC,MAAM,EAAb,wBAAa;wBACf,qBAAM,OAAO,CAAC,OAAO,CAAC,MAAM,CAAC,MAAM,CAAC,GAAG,EAAE,QAAQ,CAAC,CAAC,EAAA;;wBAAnD,SAAmD,CAAA;;;wBAGrD,IAAI,CAAC,OAAO,GAAG,IAAI,CAAC,OAAO,CAAC,MAAM,CAAC,UAAC,CAAC,IAAK,OAAA,CAAC,CAAC,IAAI,KAAK,MAAM,CAAC,IAAI,EAAtB,CAAsB,CAAC,CAAA;;;;wBAEjE,GAAG,CAAC,GAAG,CAAC,MAAM,EAAE,8BAA8B,EAAE;4BAC9C,MAAM,EAAE,MAAM,CAAC,IAAI;4BACnB,KAAK,EAAE,GAAC;yBACT,CAAC,CAAA;;;;;;KAEL;IAEK,iCAAQ,GAAd,UAAe,GAAQ;;;;gBACrB,GAAG,CAAC,GAAG,CAAC,OAAO,EAAE,aAAa,CAAC,CAAA;gBAC/B,GAAG,CAAC,KAAK,CAAC,SAAS,CAAC,oBAAoB,CAAC,CAAA;gBAEzC,IAAI,CAAC,KAAK,CAAC,IAAI,CAAC,GAAG,CAAC,CAAA;gBACd,WAAW,GAAG,IAAI,CAAC,mBAAmB,CAAC,GAAG,CAAC,CAAA;gBACjD,IAAI,CAAC,aAAa,CAAC,CAAC,CAAC,CAAA;gBACrB,sBAAO,WAAW,EAAA;;;KACnB;IAEa,4CAAmB,GAAjC,UAAkC,GAAQ;;;;gBACxC,sBAAO,IAAI,OAAO,CAAC,UAAC,OAAO;wBACzB,IAAM,SAAS,GAAG,UAAC,OAAY,EAAE,SAAkB;4BACjD,IAAI,OAAO,CAAC,MAAM,CAAC,GAAG,CAAC,EAAE;gCACvB,KAAI,CAAC,GAAG,CAAC,OAAO,EAAE,SAAS,CAAC,CAAA;gCAC5B,IAAI,SAAS,EAAE;oCACb,OAAO,CAAC,OAAO,CAAC,CAAA;iCACjB;qCAAM;oCACL,OAAO,CAAC,OAAO,CAAC,CAAA;iCACjB;6BACF;wBACH,CAAC,CAAA;wBAED,KAAI,CAAC,EAAE,CAAC,OAAO,EAAE,SAAS,CAAC,CAAA;oBAC7B,CAAC,CAAC,EAAA;;;KACH;IAEK,uCAAc,GAApB,UAAqB,GAAQ;;;;gBAC3B,GAAG,CAAC,GAAG,CAAC,OAAO,EAAE,aAAa,CAAC,CAAA;gBAC/B,GAAG,CAAC,KAAK,CAAC,SAAS,CAAC,oBAAoB,CAAC,CAAA;gBAEzC,IAAI,CAAC,KAAK,CAAC,cAAc,CAAC,GAAG,CAAC,CAAA;gBAC9B,GAAG,CAAC,QAAQ,GAAG,CAAC,CAAA;gBAEhB,sBAAO,IAAI,CAAC,OAAO,CAAC,GAAG,CAAC,CAAC,KAAK,CAAC,UAAC,GAAG;wBACjC,IAAM,QAAQ,GAAG,KAAI,CAAC,WAAW,CAAC,GAAG,EAAE,GAAG,CAAC,CAAA;wBAC3C,IAAI,CAAC,QAAQ,EAAE;4BACb,GAAG,CAAC,iBAAiB,CAAC,EAAE,MAAM,EAAE,GAAG,EAAE,CAAC,CAAA;4BACtC,OAAO,GAAG,CAAA;yBACX;wBAED,OAAO,KAAI,CAAC,mBAAmB,CAAC,GAAG,CAAC,CAAA;oBACtC,CAAC,CAAC,EAAA;;;KACH;IAED,gCAAO,GAAP;QACE,OAAO,IAAI,CAAC,KAAK,CAAC,MAAM,KAAK,CAAC,CAAA;IAChC,CAAC;IAEO,sCAAa,GAArB,UAAsB,OAAa;QAAnC,iBAmBC;QAnBqB,wBAAA,EAAA,aAAa;QACjC,IAAI,IAAI,CAAC,QAAQ,EAAE;YACjB,OAAM;SACP;QAED,IAAI,CAAC,QAAQ,GAAG,IAAI,CAAA;QAEpB,UAAU,CAAC;YACT,mEAAmE;YACnE,KAAI,CAAC,KAAK,EAAE,CAAC,IAAI,CAAC;gBAChB,UAAU,CAAC;oBACT,KAAI,CAAC,QAAQ,GAAG,KAAK,CAAA;oBAErB,IAAI,KAAI,CAAC,KAAK,CAAC,MAAM,EAAE;wBACrB,KAAI,CAAC,aAAa,CAAC,CAAC,CAAC,CAAA;qBACtB;gBACH,CAAC,EAAE,CAAC,CAAC,CAAA;YACP,CAAC,CAAC,CAAA;QACJ,CAAC,EAAE,OAAO,CAAC,CAAA;IACb,CAAC;IAEa,gCAAO,GAArB,UAAsB,GAAQ;;;;;4BAC5B,qBAAM,IAAI,CAAC,aAAa,CAAC,IAAI,EAAE,EAAA;;wBAA/B,SAA+B,CAAA;wBAEzB,KAAK,GAAG,IAAI,CAAC,GAAG,EAAE,CAAA;;;;wBAEhB,qBAAM,IAAI,CAAC,QAAQ,CAAC,GAAG,CAAC,EAAA;;wBAA9B,GAAG,GAAG,SAAwB,CAAA;wBACxB,IAAI,GAAG,IAAI,CAAC,GAAG,EAAE,GAAG,KAAK,CAAA;wBAC/B,IAAI,CAAC,IAAI,CAAC,kBAAkB,EAAE,GAAG,CAAC,CAAA;wBAClC,GAAG,CAAC,KAAK,CAAC,KAAK,CAAC,WAAW,EAAE,IAAI,CAAC,CAAA;wBAClC,GAAG,CAAC,GAAG,CAAC,OAAO,EAAE,WAAW,EAAE,GAAG,CAAC,KAAK,CAAC,CAAA;wBACxC,sBAAO,GAAG,EAAA;;;wBAEJ,KAAK,GAAG,KAAuC,CAAA;wBACrD,GAAG,CAAC,GAAG,CAAC,OAAO,EAAE,mBAAmB,EAAE,KAAK,CAAC,CAAA;wBAC5C,IAAI,CAAC,IAAI,CAAC,kBAAkB,EAAE,GAAG,EAAE,KAAK,CAAC,CAAA;wBACzC,GAAG,CAAC,KAAK,CAAC,SAAS,CAAC,iBAAiB,CAAC,CAAA;wBACtC,MAAM,KAAG,CAAA;;;;;KAEZ;IAEO,oCAAW,GAAnB,UAAoB,GAAU,EAAE,GAAQ;QACtC,IAAM,SAAS,GAAG,CAAC,CAAC,GAAG,YAAY,4BAAkB,CAAC,IAAI,GAAG,CAAC,KAAK,CAAA;QACnE,IAAI,CAAC,SAAS,EAAE;YACd,OAAO,KAAK,CAAA;SACb;QAED,OAAO,IAAI,CAAC,KAAK,CAAC,eAAe,CAAC,GAAG,CAAC,CAAA;IACxC,CAAC;IAEK,8BAAK,GAAX;;;;;;wBACE,IAAI,IAAI,CAAC,KAAK,CAAC,MAAM,KAAK,CAAC,EAAE;4BAC3B,sBAAO,EAAE,EAAA;yBACV;wBAEG,GAAG,GAAG,IAAI,CAAC,KAAK,CAAC,GAAG,EAAE,CAAA;wBAC1B,IAAI,CAAC,GAAG,EAAE;4BACR,sBAAO,EAAE,EAAA;yBACV;wBAED,GAAG,CAAC,QAAQ,GAAG,IAAI,CAAC,KAAK,CAAC,WAAW,CAAC,GAAG,CAAC,CAAA;;;;wBAGlC,qBAAM,IAAI,CAAC,OAAO,CAAC,GAAG,CAAC,EAAA;;wBAA7B,GAAG,GAAG,SAAuB,CAAA;wBAC7B,IAAI,CAAC,IAAI,CAAC,OAAO,EAAE,GAAG,EAAE,IAAI,CAAC,CAAA;;;;wBAEvB,QAAQ,GAAG,IAAI,CAAC,WAAW,CAAC,KAAG,EAAE,GAAG,CAAC,CAAA;wBAE3C,IAAI,CAAC,QAAQ,EAAE;4BACb,GAAG,CAAC,iBAAiB,CAAC,EAAE,MAAM,EAAE,KAAG,EAAE,CAAC,CAAA;4BACtC,IAAI,CAAC,IAAI,CAAC,OAAO,EAAE,GAAG,EAAE,KAAK,CAAC,CAAA;yBAC/B;wBAED,sBAAO,EAAE,EAAA;4BAGX,sBAAO,CAAC,GAAG,CAAC,EAAA;;;;KACb;IAEO,gCAAO,GAAf;QACE,iDAAiD;QACjD,2CAA2C;QAC3C,OAAO,IAAI,CAAA;IACb,CAAC;IAEO,4CAAmB,GAA3B,UAA4B,QAAsB;QAChD,IAAM,SAAS,GAAG,IAAI,CAAC,OAAO,CAAC,MAAM,CAAC,UAAC,CAAC;;YACtC,+DAA+D;YAC/D,IAAI,CAAC,CAAC,IAAI,KAAK,aAAa,IAAI,CAAC,CAAC,IAAI,KAAK,YAAY,EAAE;gBACvD,OAAO,IAAI,CAAA;aACZ;YAED,IAAI,oBAAoB,GAAqC,SAAS,CAAA;YACtE,MAAA,CAAC,CAAC,gBAAgB,0CAAE,OAAO,CAAC,UAAC,IAAI;gBAC/B,IAAI,QAAQ,CAAC,IAAI,CAAC,KAAK,SAAS,EAAE;oBAChC,oBAAoB,GAAG,QAAQ,CAAC,IAAI,CAAC,CAAA;iBACtC;YACH,CAAC,CAAC,CAAA;YAEF,0FAA0F;YAC1F,OAAO,CACL,MAAA,MAAA,QAAQ,CAAC,CAAC,CAAC,IAAI,CAAC,mCAChB,oBAAoB,mCACpB,CAAC,CAAC,CAAC,IAAI,KAAK,YAAY,CAAC,CAAC,CAAC,IAAI,CAAC,CAAC,CAAC,QAAQ,CAAC,GAAG,CAAC,KAAK,KAAK,CAC1D,CAAA;QACH,CAAC,CAAC,CAAA;QAEI,IAAA,KAKF,IAAA,kBAAO,EAAC,SAAS,EAAE,MAAM,CAAC,EAJ5B,cAAW,EAAX,MAAM,mBAAG,EAAE,KAAA,EACX,kBAAe,EAAf,UAAU,mBAAG,EAAE,KAAA,EACf,mBAAgB,EAAhB,WAAW,mBAAG,EAAE,KAAA,EAChB,aAAU,EAAV,KAAK,mBAAG,EAAE,KACkB,CAAA;QAE9B,OAAO;YACL,MAAM,QAAA;YACN,UAAU,YAAA;YACV,YAAY,EAAE,WAAW;YACzB,KAAK,OAAA;SACN,CAAA;IACH,CAAC;IAEa,iCAAQ,GAAtB,UAAuB,GAAQ;;;;;;;wBAC7B,IAAI,CAAC,IAAI,CAAC,OAAO,EAAE,EAAE;4BACnB,MAAM,IAAI,KAAK,CAAC,WAAW,CAAC,CAAA;yBAC7B;wBAED,IAAI,GAAG,CAAC,QAAQ,GAAG,CAAC,EAAE;4BACpB,IAAI,CAAC,IAAI,CAAC,gBAAgB,EAAE,GAAG,CAAC,CAAA;yBACjC;wBAEK,KAAyB,IAAI,CAAC,mBAAmB,CACrD,MAAA,GAAG,CAAC,KAAK,CAAC,YAAY,mCAAI,EAAE,CAC7B,EAFO,MAAM,YAAA,EAAE,UAAU,gBAAA,CAEzB;8BAE8B,EAAN,iBAAM;;;6BAAN,CAAA,oBAAM,CAAA;wBAApB,UAAU;wBACN,qBAAM,IAAA,iBAAM,EAAC,GAAG,EAAE,UAAU,CAAC,EAAA;;wBAApC,IAAI,GAAG,SAA6B;wBAC1C,IAAI,IAAI,YAAY,qBAAW,EAAE;4BAC/B,GAAG,GAAG,IAAI,CAAA;yBACX;wBAED,IAAI,CAAC,IAAI,CAAC,kBAAkB,EAAE,GAAG,EAAE,UAAU,CAAC,CAAA;;;wBANvB,IAAM,CAAA;;;8BASQ,EAAV,yBAAU;;;6BAAV,CAAA,wBAAU,CAAA;wBAA5B,cAAc;wBACV,qBAAM,IAAA,kBAAO,EAAC,GAAG,EAAE,cAAc,CAAC,EAAA;;wBAAzC,IAAI,GAAG,SAAkC;wBAC/C,IAAI,IAAI,YAAY,qBAAW,EAAE;4BAC/B,GAAG,GAAG,IAAI,CAAA;yBACX;wBAED,IAAI,CAAC,IAAI,CAAC,kBAAkB,EAAE,GAAG,EAAE,cAAc,CAAC,CAAA;;;wBANvB,IAAU,CAAA;;;wBAWjC,KAA0B,IAAI,CAAC,mBAAmB,CACtD,MAAA,GAAG,CAAC,KAAK,CAAC,YAAY,mCAAI,EAAE,CAC7B,EAFO,YAAY,kBAAA,EAAE,KAAK,WAAA,CAE1B;wBAED,qBAAM,IAAI,OAAO,CAAC,UAAC,OAAO,EAAE,MAAM;gCAChC,UAAU,CAAC;oCACT,IAAM,QAAQ,GAAG,YAAY,CAAC,GAAG,CAAC,UAAC,WAAW;wCAC5C,OAAA,IAAA,kBAAO,EAAC,GAAG,EAAE,WAAW,CAAC;oCAAzB,CAAyB,CAC1B,CAAA;oCACD,OAAO,CAAC,GAAG,CAAC,QAAQ,CAAC,CAAC,IAAI,CAAC,OAAO,CAAC,CAAC,KAAK,CAAC,MAAM,CAAC,CAAA;gCACnD,CAAC,EAAE,CAAC,CAAC,CAAA;4BACP,CAAC,CAAC,EAAA;;wBAPF,SAOE,CAAA;wBAEF,GAAG,CAAC,KAAK,CAAC,SAAS,CAAC,mBAAmB,CAAC,CAAA;wBAExC,IAAI,CAAC,IAAI,CAAC,mBAAmB,EAAE,GAAG,CAAC,CAAA;wBAE7B,UAAU,GAAG,KAAK,CAAC,GAAG,CAAC,UAAC,KAAK,IAAK,OAAA,IAAA,kBAAO,EAAC,GAAG,EAAE,KAAK,CAAC,EAAnB,CAAmB,CAAC,CAAA;wBAC5D,qBAAM,OAAO,CAAC,GAAG,CAAC,UAAU,CAAC,EAAA;;wBAA7B,SAA6B,CAAA;wBAE7B,sBAAO,GAAG,EAAA;;;;KACX;IACH,qBAAC;AAAD,CAAC,AAzSD,CAGU,iCAAO,GAsShB;AAzSqB,wCAAc"}
+{"version":3,"file":"event-queue.js","sourceRoot":"","sources":["../../../src/queue/event-queue.ts"],"names":[],"mappings":";;;;AACA,8CAA2C;AAC3C,oDAAwE;AAExE,sCAA4D;AAC5D,4EAA0D;AAG1D,iDAA+D;AAC/D,uCAA4C;AAY5C;IAGU,0CAAuC;IAc/C,wBAAY,aAAiC;QAA7C,YACE,iBAAO,SAMR;QApBD;;;;;;WAMG;QACH,mBAAa,GAAc,IAAA,4BAAe,GAAE,CAAA;QAE5C,aAAO,GAAa,EAAE,CAAA;QACtB,2BAAqB,GAAa,EAAE,CAAA;QAC5B,cAAQ,GAAG,KAAK,CAAA;QAKtB,KAAI,CAAC,KAAK,GAAG,aAAa,CAAA;QAC1B,KAAI,CAAC,KAAK,CAAC,EAAE,CAAC,sCAAqB,EAAE;YACnC,KAAI,CAAC,aAAa,CAAC,CAAC,CAAC,CAAA;QACvB,CAAC,CAAC,CAAA;;IACJ,CAAC;IAEK,iCAAQ,GAAd,UACE,GAAQ,EACR,MAAc,EACd,QAAuB;;;;;;6BAEnB,CAAA,MAAM,CAAC,IAAI,KAAK,aAAa,IAAI,MAAM,CAAC,IAAI,KAAK,YAAY,CAAA,EAA7D,wBAA6D;wBAC/D,MAAM,CAAC,IAAI,CAAC,GAAG,EAAE,QAAQ,CAAC,CAAC,KAAK,CAAC,UAAC,GAAG;4BACnC,KAAI,CAAC,qBAAqB,CAAC,IAAI,CAAC,MAAM,CAAC,IAAI,CAAC,CAAA;4BAC5C,KAAI,CAAC,IAAI,CAAC,wBAAwB,EAAE,MAAM,CAAC,CAAA;4BAC3C,OAAO,CAAC,IAAI,CAAC,MAAM,CAAC,IAAI,EAAE,GAAG,CAAC,CAAA;4BAE9B,GAAG,CAAC,GAAG,CAAC,MAAM,EAAE,4BAA4B,EAAE;gCAC5C,MAAM,EAAE,MAAM,CAAC,IAAI;gCACnB,KAAK,EAAE,GAAG;6BACX,CAAC,CAAA;4BAEF,KAAI,CAAC,OAAO,GAAG,KAAI,CAAC,OAAO,CAAC,MAAM,CAAC,UAAC,CAAC,IAAK,OAAA,CAAC,KAAK,MAAM,EAAZ,CAAY,CAAC,CAAA;wBACzD,CAAC,CAAC,CAAA;;4BAEF,qBAAM,MAAM,CAAC,IAAI,CAAC,GAAG,EAAE,QAAQ,CAAC,EAAA;;wBAAhC,SAAgC,CAAA;;;wBAGlC,IAAI,CAAC,OAAO,CAAC,IAAI,CAAC,MAAM,CAAC,CAAA;;;;;KAC1B;IAEK,mCAAU,GAAhB,UACE,GAAQ,EACR,MAAuB,EACvB,QAAuB;;;;;;;6BAGjB,MAAM,CAAC,MAAM,EAAb,wBAAa;wBACf,qBAAM,OAAO,CAAC,OAAO,CAAC,MAAM,CAAC,MAAM,CAAC,GAAG,EAAE,QAAQ,CAAC,CAAC,EAAA;;wBAAnD,SAAmD,CAAA;;;wBAGrD,IAAI,CAAC,OAAO,GAAG,IAAI,CAAC,OAAO,CAAC,MAAM,CAAC,UAAC,CAAC,IAAK,OAAA,CAAC,CAAC,IAAI,KAAK,MAAM,CAAC,IAAI,EAAtB,CAAsB,CAAC,CAAA;;;;wBAEjE,GAAG,CAAC,GAAG,CAAC,MAAM,EAAE,8BAA8B,EAAE;4BAC9C,MAAM,EAAE,MAAM,CAAC,IAAI;4BACnB,KAAK,EAAE,GAAC;yBACT,CAAC,CAAA;;;;;;KAEL;IAEK,iCAAQ,GAAd,UAAe,GAAQ;;;;gBACrB,GAAG,CAAC,GAAG,CAAC,OAAO,EAAE,aAAa,CAAC,CAAA;gBAC/B,GAAG,CAAC,KAAK,CAAC,SAAS,CAAC,oBAAoB,CAAC,CAAA;gBAEzC,IAAI,CAAC,KAAK,CAAC,IAAI,CAAC,GAAG,CAAC,CAAA;gBACd,WAAW,GAAG,IAAI,CAAC,mBAAmB,CAAC,GAAG,CAAC,CAAA;gBACjD,IAAI,CAAC,aAAa,CAAC,CAAC,CAAC,CAAA;gBACrB,sBAAO,WAAW,EAAA;;;KACnB;IAEa,4CAAmB,GAAjC,UAAkC,GAAQ;;;;gBACxC,sBAAO,IAAI,OAAO,CAAC,UAAC,OAAO;wBACzB,IAAM,SAAS,GAAG,UAAC,OAAY,EAAE,SAAkB;4BACjD,IAAI,OAAO,CAAC,MAAM,CAAC,GAAG,CAAC,EAAE;gCACvB,KAAI,CAAC,GAAG,CAAC,OAAO,EAAE,SAAS,CAAC,CAAA;gCAC5B,IAAI,SAAS,EAAE;oCACb,OAAO,CAAC,OAAO,CAAC,CAAA;iCACjB;qCAAM;oCACL,OAAO,CAAC,OAAO,CAAC,CAAA;iCACjB;6BACF;wBACH,CAAC,CAAA;wBAED,KAAI,CAAC,EAAE,CAAC,OAAO,EAAE,SAAS,CAAC,CAAA;oBAC7B,CAAC,CAAC,EAAA;;;KACH;IAEK,uCAAc,GAApB,UAAqB,GAAQ;;;;gBAC3B,GAAG,CAAC,GAAG,CAAC,OAAO,EAAE,aAAa,CAAC,CAAA;gBAC/B,GAAG,CAAC,KAAK,CAAC,SAAS,CAAC,oBAAoB,CAAC,CAAA;gBAEzC,IAAI,CAAC,KAAK,CAAC,cAAc,CAAC,GAAG,CAAC,CAAA;gBAC9B,GAAG,CAAC,QAAQ,GAAG,CAAC,CAAA;gBAEhB,sBAAO,IAAI,CAAC,OAAO,CAAC,GAAG,CAAC,CAAC,KAAK,CAAC,UAAC,GAAG;wBACjC,IAAM,QAAQ,GAAG,KAAI,CAAC,WAAW,CAAC,GAAG,EAAE,GAAG,CAAC,CAAA;wBAC3C,IAAI,CAAC,QAAQ,EAAE;4BACb,GAAG,CAAC,iBAAiB,CAAC,EAAE,MAAM,EAAE,GAAG,EAAE,CAAC,CAAA;4BACtC,OAAO,GAAG,CAAA;yBACX;wBAED,OAAO,KAAI,CAAC,mBAAmB,CAAC,GAAG,CAAC,CAAA;oBACtC,CAAC,CAAC,EAAA;;;KACH;IAED,gCAAO,GAAP;QACE,OAAO,IAAI,CAAC,KAAK,CAAC,MAAM,KAAK,CAAC,CAAA;IAChC,CAAC;IAEO,sCAAa,GAArB,UAAsB,OAAa;QAAnC,iBAmBC;QAnBqB,wBAAA,EAAA,aAAa;QACjC,IAAI,IAAI,CAAC,QAAQ,EAAE;YACjB,OAAM;SACP;QAED,IAAI,CAAC,QAAQ,GAAG,IAAI,CAAA;QAEpB,UAAU,CAAC;YACT,mEAAmE;YACnE,KAAI,CAAC,KAAK,EAAE,CAAC,IAAI,CAAC;gBAChB,UAAU,CAAC;oBACT,KAAI,CAAC,QAAQ,GAAG,KAAK,CAAA;oBAErB,IAAI,KAAI,CAAC,KAAK,CAAC,MAAM,EAAE;wBACrB,KAAI,CAAC,aAAa,CAAC,CAAC,CAAC,CAAA;qBACtB;gBACH,CAAC,EAAE,CAAC,CAAC,CAAA;YACP,CAAC,CAAC,CAAA;QACJ,CAAC,EAAE,OAAO,CAAC,CAAA;IACb,CAAC;IAEa,gCAAO,GAArB,UAAsB,GAAQ;;;;;4BAC5B,qBAAM,IAAI,CAAC,aAAa,CAAC,IAAI,EAAE,EAAA;;wBAA/B,SAA+B,CAAA;wBAEzB,KAAK,GAAG,IAAI,CAAC,GAAG,EAAE,CAAA;;;;wBAEhB,qBAAM,IAAI,CAAC,QAAQ,CAAC,GAAG,CAAC,EAAA;;wBAA9B,GAAG,GAAG,SAAwB,CAAA;wBACxB,IAAI,GAAG,IAAI,CAAC,GAAG,EAAE,GAAG,KAAK,CAAA;wBAC/B,IAAI,CAAC,IAAI,CAAC,kBAAkB,EAAE,GAAG,CAAC,CAAA;wBAClC,GAAG,CAAC,KAAK,CAAC,KAAK,CAAC,WAAW,EAAE,IAAI,CAAC,CAAA;wBAClC,GAAG,CAAC,GAAG,CAAC,OAAO,EAAE,WAAW,EAAE,GAAG,CAAC,KAAK,CAAC,CAAA;wBACxC,sBAAO,GAAG,EAAA;;;wBAEJ,KAAK,GAAG,KAAuC,CAAA;wBACrD,GAAG,CAAC,GAAG,CAAC,OAAO,EAAE,mBAAmB,EAAE,KAAK,CAAC,CAAA;wBAC5C,IAAI,CAAC,IAAI,CAAC,kBAAkB,EAAE,GAAG,EAAE,KAAK,CAAC,CAAA;wBACzC,GAAG,CAAC,KAAK,CAAC,SAAS,CAAC,iBAAiB,CAAC,CAAA;wBACtC,MAAM,KAAG,CAAA;;;;;KAEZ;IAEO,oCAAW,GAAnB,UAAoB,GAAU,EAAE,GAAQ;QACtC,IAAM,SAAS,GAAG,CAAC,CAAC,GAAG,YAAY,4BAAkB,CAAC,IAAI,GAAG,CAAC,KAAK,CAAA;QACnE,IAAI,CAAC,SAAS,EAAE;YACd,OAAO,KAAK,CAAA;SACb;QAED,OAAO,IAAI,CAAC,KAAK,CAAC,eAAe,CAAC,GAAG,CAAC,CAAA;IACxC,CAAC;IAEK,8BAAK,GAAX;;;;;;wBACE,IAAI,IAAI,CAAC,KAAK,CAAC,MAAM,KAAK,CAAC,EAAE;4BAC3B,sBAAO,EAAE,EAAA;yBACV;wBAEG,GAAG,GAAG,IAAI,CAAC,KAAK,CAAC,GAAG,EAAE,CAAA;wBAC1B,IAAI,CAAC,GAAG,EAAE;4BACR,sBAAO,EAAE,EAAA;yBACV;wBAED,GAAG,CAAC,QAAQ,GAAG,IAAI,CAAC,KAAK,CAAC,WAAW,CAAC,GAAG,CAAC,CAAA;;;;wBAGlC,qBAAM,IAAI,CAAC,OAAO,CAAC,GAAG,CAAC,EAAA;;wBAA7B,GAAG,GAAG,SAAuB,CAAA;wBAC7B,IAAI,CAAC,IAAI,CAAC,OAAO,EAAE,GAAG,EAAE,IAAI,CAAC,CAAA;;;;wBAEvB,QAAQ,GAAG,IAAI,CAAC,WAAW,CAAC,KAAG,EAAE,GAAG,CAAC,CAAA;wBAE3C,IAAI,CAAC,QAAQ,EAAE;4BACb,GAAG,CAAC,iBAAiB,CAAC,EAAE,MAAM,EAAE,KAAG,EAAE,CAAC,CAAA;4BACtC,IAAI,CAAC,IAAI,CAAC,OAAO,EAAE,GAAG,EAAE,KAAK,CAAC,CAAA;yBAC/B;wBAED,sBAAO,EAAE,EAAA;4BAGX,sBAAO,CAAC,GAAG,CAAC,EAAA;;;;KACb;IAEO,gCAAO,GAAf;QACE,iDAAiD;QACjD,2CAA2C;QAC3C,OAAO,IAAI,CAAA;IACb,CAAC;IAEO,4CAAmB,GAA3B,UAA4B,QAAsB;QAChD,IAAM,SAAS,GAAG,IAAI,CAAC,OAAO,CAAC,MAAM,CAAC,UAAC,CAAC;;YACtC,+DAA+D;YAC/D,IAAI,CAAC,CAAC,IAAI,KAAK,aAAa,IAAI,CAAC,CAAC,IAAI,KAAK,YAAY,EAAE;gBACvD,OAAO,IAAI,CAAA;aACZ;YAED,IAAI,oBAAoB,GAAqC,SAAS,CAAA;YACtE,MAAA,CAAC,CAAC,gBAAgB,0CAAE,OAAO,CAAC,UAAC,IAAI;gBAC/B,IAAI,QAAQ,CAAC,IAAI,CAAC,KAAK,SAAS,EAAE;oBAChC,oBAAoB,GAAG,QAAQ,CAAC,IAAI,CAAC,CAAA;iBACtC;YACH,CAAC,CAAC,CAAA;YAEF,0FAA0F;YAC1F,OAAO,CACL,MAAA,MAAA,QAAQ,CAAC,CAAC,CAAC,IAAI,CAAC,mCAChB,oBAAoB,mCACpB,CAAC,CAAC,CAAC,IAAI,KAAK,YAAY,CAAC,CAAC,CAAC,IAAI,CAAC,CAAC,CAAC,QAAQ,CAAC,GAAG,CAAC,KAAK,KAAK,CAC1D,CAAA;QACH,CAAC,CAAC,CAAA;QAEI,IAAA,KAKF,IAAA,kBAAO,EAAC,SAAS,EAAE,MAAM,CAAC,EAJ5B,cAAW,EAAX,MAAM,mBAAG,EAAE,KAAA,EACX,kBAAe,EAAf,UAAU,mBAAG,EAAE,KAAA,EACf,mBAAgB,EAAhB,WAAW,mBAAG,EAAE,KAAA,EAChB,aAAU,EAAV,KAAK,mBAAG,EAAE,KACkB,CAAA;QAE9B,OAAO;YACL,MAAM,QAAA;YACN,UAAU,YAAA;YACV,YAAY,EAAE,WAAW;YACzB,KAAK,OAAA;SACN,CAAA;IACH,CAAC;IAEa,iCAAQ,GAAtB,UAAuB,GAAQ;;;;;;;wBAC7B,IAAI,CAAC,IAAI,CAAC,OAAO,EAAE,EAAE;4BACnB,MAAM,IAAI,KAAK,CAAC,WAAW,CAAC,CAAA;yBAC7B;wBAED,IAAI,GAAG,CAAC,QAAQ,GAAG,CAAC,EAAE;4BACpB,IAAI,CAAC,IAAI,CAAC,gBAAgB,EAAE,GAAG,CAAC,CAAA;yBACjC;wBAEK,KAAyB,IAAI,CAAC,mBAAmB,CACrD,MAAA,GAAG,CAAC,KAAK,CAAC,YAAY,mCAAI,EAAE,CAC7B,EAFO,MAAM,YAAA,EAAE,UAAU,gBAAA,CAEzB;8BAE8B,EAAN,iBAAM;;;6BAAN,CAAA,oBAAM,CAAA;wBAApB,UAAU;wBACN,qBAAM,IAAA,iBAAM,EAAC,GAAG,EAAE,UAAU,CAAC,EAAA;;wBAApC,IAAI,GAAG,SAA6B;wBAC1C,IAAI,IAAI,YAAY,qBAAW,EAAE;4BAC/B,GAAG,GAAG,IAAI,CAAA;yBACX;wBAED,IAAI,CAAC,IAAI,CAAC,kBAAkB,EAAE,GAAG,EAAE,UAAU,CAAC,CAAA;;;wBANvB,IAAM,CAAA;;;8BASQ,EAAV,yBAAU;;;6BAAV,CAAA,wBAAU,CAAA;wBAA5B,cAAc;wBACV,qBAAM,IAAA,kBAAO,EAAC,GAAG,EAAE,cAAc,CAAC,EAAA;;wBAAzC,IAAI,GAAG,SAAkC;wBAC/C,IAAI,IAAI,YAAY,qBAAW,EAAE;4BAC/B,GAAG,GAAG,IAAI,CAAA;yBACX;wBAED,IAAI,CAAC,IAAI,CAAC,kBAAkB,EAAE,GAAG,EAAE,cAAc,CAAC,CAAA;;;wBANvB,IAAU,CAAA;;;wBAWjC,KAA0B,IAAI,CAAC,mBAAmB,CACtD,MAAA,GAAG,CAAC,KAAK,CAAC,YAAY,mCAAI,EAAE,CAC7B,EAFO,YAAY,kBAAA,EAAE,KAAK,WAAA,CAE1B;wBAED,qBAAM,IAAI,OAAO,CAAC,UAAC,OAAO,EAAE,MAAM;gCAChC,UAAU,CAAC;oCACT,IAAM,QAAQ,GAAG,YAAY,CAAC,GAAG,CAAC,UAAC,WAAW;wCAC5C,OAAA,IAAA,kBAAO,EAAC,GAAG,EAAE,WAAW,CAAC;oCAAzB,CAAyB,CAC1B,CAAA;oCACD,OAAO,CAAC,GAAG,CAAC,QAAQ,CAAC,CAAC,IAAI,CAAC,OAAO,CAAC,CAAC,KAAK,CAAC,MAAM,CAAC,CAAA;gCACnD,CAAC,EAAE,CAAC,CAAC,CAAA;4BACP,CAAC,CAAC,EAAA;;wBAPF,SAOE,CAAA;wBAEF,GAAG,CAAC,KAAK,CAAC,SAAS,CAAC,mBAAmB,CAAC,CAAA;wBAExC,IAAI,CAAC,IAAI,CAAC,mBAAmB,EAAE,GAAG,CAAC,CAAA;wBAE7B,UAAU,GAAG,KAAK,CAAC,GAAG,CAAC,UAAC,KAAK,IAAK,OAAA,IAAA,kBAAO,EAAC,GAAG,EAAE,KAAK,CAAC,EAAnB,CAAmB,CAAC,CAAA;wBAC5D,qBAAM,OAAO,CAAC,GAAG,CAAC,UAAU,CAAC,EAAA;;wBAA7B,SAA6B,CAAA;wBAE7B,sBAAO,GAAG,EAAA;;;;KACX;IACH,qBAAC;AAAD,CAAC,AAxSD,CAGU,iCAAO,GAqShB;AAxSqB,wCAAc"}

dist/cjs/validation/assertions.js

 "use strict";
 Object.defineProperty(exports, "__esModule", { value: true });
-exports.validateEvent = exports.assertTraits = exports.assertTrackEventProperties = exports.assertTrackEventName = exports.assertEventType = exports.assertEventExists = exports.assertUserIdentity = void 0;
+exports.validateEvent = exports.assertMessageId = exports.assertTraits = exports.assertTrackEventProperties = exports.assertTrackEventName = exports.assertEventType = exports.assertEventExists = exports.assertUserIdentity = void 0;
 var errors_1 = require("./errors");
@@ -54,5 +54,12 @@ var helpers_1 = require("./helpers");
 exports.assertTraits = assertTraits;
+function assertMessageId(event) {
+    if (!(0, helpers_1.isString)(event.messageId)) {
+        throw new errors_1.ValidationError('.messageId', stringError);
+    }
+}
+exports.assertMessageId = assertMessageId;
 function validateEvent(event) {
     assertEventExists(event);
     assertEventType(event);
+    assertMessageId(event);
     if (event.type === 'track') {
@@ -59,0 +66,0 @@ assertTrackEventName(event);

dist/cjs/validation/assertions.js.map

@@ -1,1 +0,1 @@
-{"version":3,"file":"assertions.js","sourceRoot":"","sources":["../../../src/validation/assertions.ts"],"names":[],"mappings":";;;AACA,mCAA0C;AAC1C,qCAA2D;AAE3D,IAAM,WAAW,GAAG,iBAAiB,CAAA;AACrC,IAAM,QAAQ,GAAG,kBAAkB,CAAA;AACnC,IAAM,QAAQ,GAAG,QAAQ,CAAA;AAEzB,SAAgB,kBAAkB,CAAC,KAAuB;IACxD,IAAM,eAAe,GAAG,wCAAwC,CAAA;IAEhE,IAAM,YAAY,GAAG,UAAC,KAAuB,oBAC3C,OAAA,MAAA,MAAA,MAAA,KAAK,CAAC,MAAM,mCAAI,KAAK,CAAC,WAAW,mCAAI,KAAK,CAAC,OAAO,mCAAI,KAAK,CAAC,UAAU,CAAA,EAAA,CAAA;IAExE,IAAM,EAAE,GAAG,YAAY,CAAC,KAAK,CAAC,CAAA;IAC9B,IAAI,CAAC,IAAA,gBAAM,EAAC,EAAE,CAAC,EAAE;QACf,MAAM,IAAI,wBAAe,CAAC,eAAe,EAAE,QAAQ,CAAC,CAAA;KACrD;SAAM,IAAI,CAAC,IAAA,kBAAQ,EAAC,EAAE,CAAC,EAAE;QACxB,MAAM,IAAI,wBAAe,CAAC,eAAe,EAAE,WAAW,CAAC,CAAA;KACxD;AACH,CAAC;AAZD,gDAYC;AAED,SAAgB,iBAAiB,CAC/B,KAA+B;IAE/B,IAAI,CAAC,IAAA,gBAAM,EAAC,KAAK,CAAC,EAAE;QAClB,MAAM,IAAI,wBAAe,CAAC,OAAO,EAAE,QAAQ,CAAC,CAAA;KAC7C;IACD,IAAI,OAAO,KAAK,KAAK,QAAQ,EAAE;QAC7B,MAAM,IAAI,wBAAe,CAAC,OAAO,EAAE,QAAQ,CAAC,CAAA;KAC7C;AACH,CAAC;AATD,8CASC;AAED,SAAgB,eAAe,CAAC,KAAuB;IACrD,IAAI,CAAC,IAAA,kBAAQ,EAAC,KAAK,CAAC,IAAI,CAAC,EAAE;QACzB,MAAM,IAAI,wBAAe,CAAC,OAAO,EAAE,WAAW,CAAC,CAAA;KAChD;AACH,CAAC;AAJD,0CAIC;AAED,SAAgB,oBAAoB,CAAC,KAAuB;IAC1D,IAAI,CAAC,IAAA,kBAAQ,EAAC,KAAK,CAAC,KAAK,CAAC,EAAE;QAC1B,MAAM,IAAI,wBAAe,CAAC,QAAQ,EAAE,WAAW,CAAC,CAAA;KACjD;AACH,CAAC;AAJD,oDAIC;AAED,SAAgB,0BAA0B,CAAC,KAAuB;IAChE,IAAI,CAAC,IAAA,uBAAa,EAAC,KAAK,CAAC,UAAU,CAAC,EAAE;QACpC,MAAM,IAAI,wBAAe,CAAC,aAAa,EAAE,QAAQ,CAAC,CAAA;KACnD;AACH,CAAC;AAJD,gEAIC;AAED,SAAgB,YAAY,CAAC,KAAuB;IAClD,IAAI,CAAC,IAAA,uBAAa,EAAC,KAAK,CAAC,MAAM,CAAC,EAAE;QAChC,MAAM,IAAI,wBAAe,CAAC,SAAS,EAAE,QAAQ,CAAC,CAAA;KAC/C;AACH,CAAC;AAJD,oCAIC;AAED,SAAgB,aAAa,CAAC,KAA+B;IAC3D,iBAAiB,CAAC,KAAK,CAAC,CAAA;IACxB,eAAe,CAAC,KAAK,CAAC,CAAA;IAEtB,IAAI,KAAK,CAAC,IAAI,KAAK,OAAO,EAAE;QAC1B,oBAAoB,CAAC,KAAK,CAAC,CAAA;QAC3B,0BAA0B,CAAC,KAAK,CAAC,CAAA;KAClC;IAED,IAAI,CAAC,OAAO,EAAE,UAAU,CAAC,CAAC,QAAQ,CAAC,KAAK,CAAC,IAAI,CAAC,EAAE;QAC9C,YAAY,CAAC,KAAK,CAAC,CAAA;KACpB;IAED,kBAAkB,CAAC,KAAK,CAAC,CAAA;AAC3B,CAAC;AAdD,sCAcC"}
+{"version":3,"file":"assertions.js","sourceRoot":"","sources":["../../../src/validation/assertions.ts"],"names":[],"mappings":";;;AACA,mCAA0C;AAC1C,qCAA2D;AAE3D,IAAM,WAAW,GAAG,iBAAiB,CAAA;AACrC,IAAM,QAAQ,GAAG,kBAAkB,CAAA;AACnC,IAAM,QAAQ,GAAG,QAAQ,CAAA;AAEzB,SAAgB,kBAAkB,CAAC,KAAuB;IACxD,IAAM,eAAe,GAAG,wCAAwC,CAAA;IAEhE,IAAM,YAAY,GAAG,UAAC,KAAuB,oBAC3C,OAAA,MAAA,MAAA,MAAA,KAAK,CAAC,MAAM,mCAAI,KAAK,CAAC,WAAW,mCAAI,KAAK,CAAC,OAAO,mCAAI,KAAK,CAAC,UAAU,CAAA,EAAA,CAAA;IAExE,IAAM,EAAE,GAAG,YAAY,CAAC,KAAK,CAAC,CAAA;IAC9B,IAAI,CAAC,IAAA,gBAAM,EAAC,EAAE,CAAC,EAAE;QACf,MAAM,IAAI,wBAAe,CAAC,eAAe,EAAE,QAAQ,CAAC,CAAA;KACrD;SAAM,IAAI,CAAC,IAAA,kBAAQ,EAAC,EAAE,CAAC,EAAE;QACxB,MAAM,IAAI,wBAAe,CAAC,eAAe,EAAE,WAAW,CAAC,CAAA;KACxD;AACH,CAAC;AAZD,gDAYC;AAED,SAAgB,iBAAiB,CAC/B,KAA+B;IAE/B,IAAI,CAAC,IAAA,gBAAM,EAAC,KAAK,CAAC,EAAE;QAClB,MAAM,IAAI,wBAAe,CAAC,OAAO,EAAE,QAAQ,CAAC,CAAA;KAC7C;IACD,IAAI,OAAO,KAAK,KAAK,QAAQ,EAAE;QAC7B,MAAM,IAAI,wBAAe,CAAC,OAAO,EAAE,QAAQ,CAAC,CAAA;KAC7C;AACH,CAAC;AATD,8CASC;AAED,SAAgB,eAAe,CAAC,KAAuB;IACrD,IAAI,CAAC,IAAA,kBAAQ,EAAC,KAAK,CAAC,IAAI,CAAC,EAAE;QACzB,MAAM,IAAI,wBAAe,CAAC,OAAO,EAAE,WAAW,CAAC,CAAA;KAChD;AACH,CAAC;AAJD,0CAIC;AAED,SAAgB,oBAAoB,CAAC,KAAuB;IAC1D,IAAI,CAAC,IAAA,kBAAQ,EAAC,KAAK,CAAC,KAAK,CAAC,EAAE;QAC1B,MAAM,IAAI,wBAAe,CAAC,QAAQ,EAAE,WAAW,CAAC,CAAA;KACjD;AACH,CAAC;AAJD,oDAIC;AAED,SAAgB,0BAA0B,CAAC,KAAuB;IAChE,IAAI,CAAC,IAAA,uBAAa,EAAC,KAAK,CAAC,UAAU,CAAC,EAAE;QACpC,MAAM,IAAI,wBAAe,CAAC,aAAa,EAAE,QAAQ,CAAC,CAAA;KACnD;AACH,CAAC;AAJD,gEAIC;AAED,SAAgB,YAAY,CAAC,KAAuB;IAClD,IAAI,CAAC,IAAA,uBAAa,EAAC,KAAK,CAAC,MAAM,CAAC,EAAE;QAChC,MAAM,IAAI,wBAAe,CAAC,SAAS,EAAE,QAAQ,CAAC,CAAA;KAC/C;AACH,CAAC;AAJD,oCAIC;AAED,SAAgB,eAAe,CAAC,KAAuB;IACrD,IAAI,CAAC,IAAA,kBAAQ,EAAC,KAAK,CAAC,SAAS,CAAC,EAAE;QAC9B,MAAM,IAAI,wBAAe,CAAC,YAAY,EAAE,WAAW,CAAC,CAAA;KACrD;AACH,CAAC;AAJD,0CAIC;AAED,SAAgB,aAAa,CAAC,KAA+B;IAC3D,iBAAiB,CAAC,KAAK,CAAC,CAAA;IACxB,eAAe,CAAC,KAAK,CAAC,CAAA;IACtB,eAAe,CAAC,KAAK,CAAC,CAAA;IAEtB,IAAI,KAAK,CAAC,IAAI,KAAK,OAAO,EAAE;QAC1B,oBAAoB,CAAC,KAAK,CAAC,CAAA;QAC3B,0BAA0B,CAAC,KAAK,CAAC,CAAA;KAClC;IAED,IAAI,CAAC,OAAO,EAAE,UAAU,CAAC,CAAC,QAAQ,CAAC,KAAK,CAAC,IAAI,CAAC,EAAE;QAC9C,YAAY,CAAC,KAAK,CAAC,CAAA;KACpB;IAED,kBAAkB,CAAC,KAAK,CAAC,CAAA;AAC3B,CAAC;AAfD,sCAeC"}

dist/esm/events/index.js

@@ -6,2 +6,6 @@ import { __assign, __rest } from "tslib";
 import { validateEvent } from '../validation/assertions';
+/**
+ * This is currently only used by node.js, but the original idea was to have something that could be shared between browser and node.
+ * Unfortunately, there are some differences in the way the two environments handle events, so this is not currently shared.
+ */
 var EventFactory = /** @class */ (function () {
@@ -101,2 +105,3 @@ function EventFactory(settings) {
             'timestamp',
+            'messageId',
         ];
@@ -141,3 +146,3 @@ delete options['integrations'];
         var body = __assign(__assign(__assign({ timestamp: new Date() }, rest), { integrations: allIntegrations, context: context }), overrides);
-        var evt = __assign(__assign({}, body), { messageId: this.createMessageId() });
+        var evt = __assign(__assign({}, body), { messageId: options.messageId || this.createMessageId() });
         validateEvent(evt);
@@ -144,0 +149,0 @@ return evt;

dist/esm/events/index.js.map

@@ -1,1 +0,1 @@
-{"version":3,"file":"index.js","sourceRoot":"","sources":["../../../src/events/index.ts"],"names":[],"mappings":";AAAA,cAAc,cAAc,CAAA;AAC5B,OAAO,EAAE,IAAI,EAAE,MAAM,MAAM,CAAA;AAW3B,OAAO,EAAE,MAAM,EAAE,MAAM,eAAe,CAAA;AACtC,OAAO,EAAE,aAAa,EAAE,MAAM,0BAA0B,CAAA;AAQxD;IAIE,sBAAY,QAA8B;QACxC,IAAI,CAAC,IAAI,GAAG,QAAQ,CAAC,IAAI,CAAA;QACzB,IAAI,CAAC,eAAe,GAAG,QAAQ,CAAC,eAAe,CAAA;IACjD,CAAC;IAED,4BAAK,GAAL,UACE,KAAa,EACb,UAA4B,EAC5B,OAAqB,EACrB,kBAAiC;QAEjC,OAAO,IAAI,CAAC,SAAS,uBAChB,IAAI,CAAC,SAAS,EAAE,KACnB,KAAK,OAAA,EACL,IAAI,EAAE,OAAO,EACb,UAAU,EAAE,UAAU,aAAV,UAAU,cAAV,UAAU,GAAI,EAAE,EAC5B,OAAO,eAAO,OAAO,GACrB,YAAY,eAAO,kBAAkB,KACrC,CAAA;IACJ,CAAC;IAED,2BAAI,GAAJ,UACE,QAAuB,EACvB,IAAmB,EACnB,UAA4B,EAC5B,OAAqB,EACrB,kBAAiC;;QAEjC,IAAM,KAAK,GAAqB;YAC9B,IAAI,EAAE,MAAM;YACZ,UAAU,eAAO,UAAU,CAAE;YAC7B,OAAO,eAAO,OAAO,CAAE;YACvB,YAAY,eAAO,kBAAkB,CAAE;SACxC,CAAA;QAED,IAAI,QAAQ,KAAK,IAAI,EAAE;YACrB,KAAK,CAAC,QAAQ,GAAG,QAAQ,CAAA;YACzB,KAAK,CAAC,UAAU,GAAG,MAAA,KAAK,CAAC,UAAU,mCAAI,EAAE,CAAA;YACzC,KAAK,CAAC,UAAU,CAAC,QAAQ,GAAG,QAAQ,CAAA;SACrC;QAED,IAAI,IAAI,KAAK,IAAI,EAAE;YACjB,KAAK,CAAC,IAAI,GAAG,IAAI,CAAA;SAClB;QAED,OAAO,IAAI,CAAC,SAAS,uBAChB,IAAI,CAAC,SAAS,EAAE,GAChB,KAAK,EACR,CAAA;IACJ,CAAC;IAED,6BAAM,GAAN,UACE,QAAuB,EACvB,MAAqB,EACrB,UAA4B,EAC5B,OAAqB,EACrB,kBAAiC;QAEjC,IAAM,KAAK,GAAqB;YAC9B,IAAI,EAAE,QAAQ;YACd,UAAU,eAAO,UAAU,CAAE;YAC7B,OAAO,eAAO,OAAO,CAAE;YACvB,YAAY,eAAO,kBAAkB,CAAE;SACxC,CAAA;QAED,IAAI,QAAQ,KAAK,IAAI,EAAE;YACrB,KAAK,CAAC,QAAQ,GAAG,QAAQ,CAAA;SAC1B;QAED,IAAI,MAAM,KAAK,IAAI,EAAE;YACnB,KAAK,CAAC,IAAI,GAAG,MAAM,CAAA;SACpB;QAED,OAAO,IAAI,CAAC,SAAS,uBAChB,IAAI,CAAC,SAAS,EAAE,GAChB,KAAK,EACR,CAAA;IACJ,CAAC;IAED,+BAAQ,GAAR,UACE,MAAU,EACV,MAAmB,EACnB,OAAqB,EACrB,kBAAiC;QAEjC,OAAO,IAAI,CAAC,SAAS,uBAChB,IAAI,CAAC,SAAS,EAAE,KACnB,IAAI,EAAE,UAAU,EAChB,MAAM,QAAA,EACN,MAAM,EAAE,MAAM,aAAN,MAAM,cAAN,MAAM,GAAI,EAAE,EACpB,OAAO,eAAO,OAAO,GACrB,YAAY,EAAE,kBAAkB,IAChC,CAAA;IACJ,CAAC;IAED,4BAAK,GAAL,UACE,OAAW,EACX,MAAoB,EACpB,OAAqB,EACrB,kBAAiC;QAEjC,OAAO,IAAI,CAAC,SAAS,uBAChB,IAAI,CAAC,SAAS,EAAE,KACnB,IAAI,EAAE,OAAO,EACb,MAAM,EAAE,MAAM,aAAN,MAAM,cAAN,MAAM,GAAI,EAAE,EACpB,OAAO,eAAO,OAAO,GACrB,YAAY,eAAO,kBAAkB,GAAI,EAAE;YAC3C,OAAO,SAAA,IACP,CAAA;IACJ,CAAC;IAED,4BAAK,GAAL,UACE,EAAU,EACV,IAAmB,EAAE,oCAAoC;IACzD,OAAqB,EACrB,kBAAiC;QAEjC,IAAM,IAAI,GAAqB;YAC7B,MAAM,EAAE,EAAE;YACV,IAAI,EAAE,OAAO;YACb,OAAO,eAAO,OAAO,CAAE;YACvB,YAAY,eAAO,kBAAkB,CAAE;SACxC,CAAA;QAED,IAAI,IAAI,KAAK,IAAI,EAAE;YACjB,IAAI,CAAC,UAAU,GAAG,IAAI,CAAA;SACvB;QAED,IAAI,EAAE,KAAK,SAAS,EAAE;YACpB,OAAO,IAAI,CAAC,SAAS,uBAChB,IAAI,GACJ,IAAI,CAAC,SAAS,EAAE,EACnB,CAAA;SACH;QAED,OAAO,IAAI,CAAC,SAAS,uBAChB,IAAI,CAAC,SAAS,EAAE,GAChB,IAAI,EACP,CAAA;IACJ,CAAC;IAEO,gCAAS,GAAjB;QACE,IAAM,IAAI,GAA8B;YACtC,YAAY,EAAE,EAAE;YAChB,OAAO,EAAE,EAAE;SACZ,CAAA;QAED,IAAI,CAAC,IAAI,CAAC,IAAI;YAAE,OAAO,IAAI,CAAA;QAE3B,IAAM,IAAI,GAAG,IAAI,CAAC,IAAI,CAAA;QAEtB,IAAI,IAAI,CAAC,EAAE,EAAE,EAAE;YACb,IAAI,CAAC,MAAM,GAAG,IAAI,CAAC,EAAE,EAAE,CAAA;SACxB;QAED,IAAI,IAAI,CAAC,WAAW,EAAE,EAAE;YACtB,IAAI,CAAC,WAAW,GAAG,IAAI,CAAC,WAAW,EAAE,CAAA;SACtC;QAED,OAAO,IAAI,CAAA;IACb,CAAC;IAED;;;OAGG;IACK,8BAAO,GAAf,UACE,OAAoB;;QAGpB;;;WAGG;QACH,IAAM,iBAAiB,GAAqB;YAC1C,QAAQ;YACR,aAAa;YACb,WAAW;SACZ,CAAA;QAED,OAAO,OAAO,CAAC,cAAc,CAAC,CAAA;QAC9B,IAAM,mBAAmB,GAAG,MAAM,CAAC,IAAI,CAAC,OAAO,CAG5C,CAAA;QAEH,IAAM,OAAO,GAAG,MAAA,OAAO,CAAC,OAAO,mCAAI,EAAE,CAAA;QACrC,IAAM,cAAc,GAAG,EAAE,CAAA;QAEzB,mBAAmB,CAAC,OAAO,CAAC,UAAC,GAAG;YAC9B,IAAI,GAAG,KAAK,SAAS,EAAE;gBACrB,OAAM;aACP;YAED,IAAI,iBAAiB,CAAC,QAAQ,CAAC,GAAG,CAAC,EAAE;gBACnC,IAAI,CAAC,cAAc,EAAE,GAAG,EAAE,OAAO,CAAC,GAAG,CAAC,CAAC,CAAA;aACxC;iBAAM;gBACL,IAAI,CAAC,OAAO,EAAE,GAAG,EAAE,OAAO,CAAC,GAAG,CAAC,CAAC,CAAA;aACjC;QACH,CAAC,CAAC,CAAA;QAEF,OAAO,CAAC,OAAO,EAAE,cAAc,CAAC,CAAA;IAClC,CAAC;IAEM,gCAAS,GAAhB,UAAiB,KAAuB;;QACtC,IAAM,mBAAmB,GAAG,MAAM,CAAC,IAAI,CAAC,MAAA,KAAK,CAAC,YAAY,mCAAI,EAAE,CAAC,CAAC,MAAM,CACtE,UAAC,gBAAgB,EAAE,IAAI;;;YACrB,6BACK,gBAAgB,gBAClB,IAAI,IAAG,OAAO,CAAC,MAAA,KAAK,CAAC,YAAY,0CAAG,IAAI,CAAC,CAAC,OAC5C;QACH,CAAC,EACD,EAA6B,CAC9B,CAAA;QAED,mCAAmC;QACnC,KAAK,CAAC,OAAO,GAAG,MAAM,CAAC,KAAK,CAAC,OAAO,IAAI,EAAE,EAAE,UAAC,CAAC,EAAE,KAAK;YACnD,OAAO,KAAK,KAAK,SAAS,CAAA;QAC5B,CAAC,CAAC,CAAA;QAEF,qDAAqD;QACrD,qGAAqG;QACrG,yGAAyG;QACzG,+GAA+G;QAC/G,IAAM,eAAe,yBAEhB,mBAAmB,GAGnB,MAAA,KAAK,CAAC,OAAO,0CAAE,YAAY,CAC/B,CAAA;QAEK,IAAA,KAAuB,KAAK,CAAC,OAAO;YACxC,CAAC,CAAC,IAAI,CAAC,OAAO,CAAC,KAAK,CAAC,OAAO,CAAC;YAC7B,CAAC,CAAC,EAAE,EAFC,OAAO,QAAA,EAAE,SAAS,QAEnB,CAAA;QAEE,IAAA,OAAO,GAAc,KAAK,QAAnB,EAAK,IAAI,UAAK,KAAK,EAA5B,WAAoB,CAAF,CAAU;QAElC,IAAM,IAAI,gCACR,SAAS,EAAE,IAAI,IAAI,EAAE,IAClB,IAAI,KACP,YAAY,EAAE,eAAe,EAC7B,OAAO,SAAA,KACJ,SAAS,CACb,CAAA;QAED,IAAM,GAAG,yBACJ,IAAI,KACP,SAAS,EAAE,IAAI,CAAC,eAAe,EAAE,GAClC,CAAA;QAED,aAAa,CAAC,GAAG,CAAC,CAAA;QAClB,OAAO,GAAG,CAAA;IACZ,CAAC;IACH,mBAAC;AAAD,CAAC,AAlQD,IAkQC"}
+{"version":3,"file":"index.js","sourceRoot":"","sources":["../../../src/events/index.ts"],"names":[],"mappings":";AAAA,cAAc,cAAc,CAAA;AAC5B,OAAO,EAAE,IAAI,EAAE,MAAM,MAAM,CAAA;AAW3B,OAAO,EAAE,MAAM,EAAE,MAAM,eAAe,CAAA;AACtC,OAAO,EAAE,aAAa,EAAE,MAAM,0BAA0B,CAAA;AAQxD;;;GAGG;AACH;IAIE,sBAAY,QAA8B;QACxC,IAAI,CAAC,IAAI,GAAG,QAAQ,CAAC,IAAI,CAAA;QACzB,IAAI,CAAC,eAAe,GAAG,QAAQ,CAAC,eAAe,CAAA;IACjD,CAAC;IAED,4BAAK,GAAL,UACE,KAAa,EACb,UAA4B,EAC5B,OAAqB,EACrB,kBAAiC;QAEjC,OAAO,IAAI,CAAC,SAAS,uBAChB,IAAI,CAAC,SAAS,EAAE,KACnB,KAAK,OAAA,EACL,IAAI,EAAE,OAAO,EACb,UAAU,EAAE,UAAU,aAAV,UAAU,cAAV,UAAU,GAAI,EAAE,EAC5B,OAAO,eAAO,OAAO,GACrB,YAAY,eAAO,kBAAkB,KACrC,CAAA;IACJ,CAAC;IAED,2BAAI,GAAJ,UACE,QAAuB,EACvB,IAAmB,EACnB,UAA4B,EAC5B,OAAqB,EACrB,kBAAiC;;QAEjC,IAAM,KAAK,GAAqB;YAC9B,IAAI,EAAE,MAAM;YACZ,UAAU,eAAO,UAAU,CAAE;YAC7B,OAAO,eAAO,OAAO,CAAE;YACvB,YAAY,eAAO,kBAAkB,CAAE;SACxC,CAAA;QAED,IAAI,QAAQ,KAAK,IAAI,EAAE;YACrB,KAAK,CAAC,QAAQ,GAAG,QAAQ,CAAA;YACzB,KAAK,CAAC,UAAU,GAAG,MAAA,KAAK,CAAC,UAAU,mCAAI,EAAE,CAAA;YACzC,KAAK,CAAC,UAAU,CAAC,QAAQ,GAAG,QAAQ,CAAA;SACrC;QAED,IAAI,IAAI,KAAK,IAAI,EAAE;YACjB,KAAK,CAAC,IAAI,GAAG,IAAI,CAAA;SAClB;QAED,OAAO,IAAI,CAAC,SAAS,uBAChB,IAAI,CAAC,SAAS,EAAE,GAChB,KAAK,EACR,CAAA;IACJ,CAAC;IAED,6BAAM,GAAN,UACE,QAAuB,EACvB,MAAqB,EACrB,UAA4B,EAC5B,OAAqB,EACrB,kBAAiC;QAEjC,IAAM,KAAK,GAAqB;YAC9B,IAAI,EAAE,QAAQ;YACd,UAAU,eAAO,UAAU,CAAE;YAC7B,OAAO,eAAO,OAAO,CAAE;YACvB,YAAY,eAAO,kBAAkB,CAAE;SACxC,CAAA;QAED,IAAI,QAAQ,KAAK,IAAI,EAAE;YACrB,KAAK,CAAC,QAAQ,GAAG,QAAQ,CAAA;SAC1B;QAED,IAAI,MAAM,KAAK,IAAI,EAAE;YACnB,KAAK,CAAC,IAAI,GAAG,MAAM,CAAA;SACpB;QAED,OAAO,IAAI,CAAC,SAAS,uBAChB,IAAI,CAAC,SAAS,EAAE,GAChB,KAAK,EACR,CAAA;IACJ,CAAC;IAED,+BAAQ,GAAR,UACE,MAAU,EACV,MAAmB,EACnB,OAAqB,EACrB,kBAAiC;QAEjC,OAAO,IAAI,CAAC,SAAS,uBAChB,IAAI,CAAC,SAAS,EAAE,KACnB,IAAI,EAAE,UAAU,EAChB,MAAM,QAAA,EACN,MAAM,EAAE,MAAM,aAAN,MAAM,cAAN,MAAM,GAAI,EAAE,EACpB,OAAO,eAAO,OAAO,GACrB,YAAY,EAAE,kBAAkB,IAChC,CAAA;IACJ,CAAC;IAED,4BAAK,GAAL,UACE,OAAW,EACX,MAAoB,EACpB,OAAqB,EACrB,kBAAiC;QAEjC,OAAO,IAAI,CAAC,SAAS,uBAChB,IAAI,CAAC,SAAS,EAAE,KACnB,IAAI,EAAE,OAAO,EACb,MAAM,EAAE,MAAM,aAAN,MAAM,cAAN,MAAM,GAAI,EAAE,EACpB,OAAO,eAAO,OAAO,GACrB,YAAY,eAAO,kBAAkB,GAAI,EAAE;YAC3C,OAAO,SAAA,IACP,CAAA;IACJ,CAAC;IAED,4BAAK,GAAL,UACE,EAAU,EACV,IAAmB,EAAE,oCAAoC;IACzD,OAAqB,EACrB,kBAAiC;QAEjC,IAAM,IAAI,GAAqB;YAC7B,MAAM,EAAE,EAAE;YACV,IAAI,EAAE,OAAO;YACb,OAAO,eAAO,OAAO,CAAE;YACvB,YAAY,eAAO,kBAAkB,CAAE;SACxC,CAAA;QAED,IAAI,IAAI,KAAK,IAAI,EAAE;YACjB,IAAI,CAAC,UAAU,GAAG,IAAI,CAAA;SACvB;QAED,IAAI,EAAE,KAAK,SAAS,EAAE;YACpB,OAAO,IAAI,CAAC,SAAS,uBAChB,IAAI,GACJ,IAAI,CAAC,SAAS,EAAE,EACnB,CAAA;SACH;QAED,OAAO,IAAI,CAAC,SAAS,uBAChB,IAAI,CAAC,SAAS,EAAE,GAChB,IAAI,EACP,CAAA;IACJ,CAAC;IAEO,gCAAS,GAAjB;QACE,IAAM,IAAI,GAA8B;YACtC,YAAY,EAAE,EAAE;YAChB,OAAO,EAAE,EAAE;SACZ,CAAA;QAED,IAAI,CAAC,IAAI,CAAC,IAAI;YAAE,OAAO,IAAI,CAAA;QAE3B,IAAM,IAAI,GAAG,IAAI,CAAC,IAAI,CAAA;QAEtB,IAAI,IAAI,CAAC,EAAE,EAAE,EAAE;YACb,IAAI,CAAC,MAAM,GAAG,IAAI,CAAC,EAAE,EAAE,CAAA;SACxB;QAED,IAAI,IAAI,CAAC,WAAW,EAAE,EAAE;YACtB,IAAI,CAAC,WAAW,GAAG,IAAI,CAAC,WAAW,EAAE,CAAA;SACtC;QAED,OAAO,IAAI,CAAA;IACb,CAAC;IAED;;;OAGG;IACK,8BAAO,GAAf,UACE,OAAoB;;QAGpB;;;WAGG;QACH,IAAM,iBAAiB,GAAqB;YAC1C,QAAQ;YACR,aAAa;YACb,WAAW;YACX,WAAW;SACZ,CAAA;QAED,OAAO,OAAO,CAAC,cAAc,CAAC,CAAA;QAC9B,IAAM,mBAAmB,GAAG,MAAM,CAAC,IAAI,CAAC,OAAO,CAG5C,CAAA;QAEH,IAAM,OAAO,GAAG,MAAA,OAAO,CAAC,OAAO,mCAAI,EAAE,CAAA;QACrC,IAAM,cAAc,GAAG,EAAE,CAAA;QAEzB,mBAAmB,CAAC,OAAO,CAAC,UAAC,GAAG;YAC9B,IAAI,GAAG,KAAK,SAAS,EAAE;gBACrB,OAAM;aACP;YAED,IAAI,iBAAiB,CAAC,QAAQ,CAAC,GAAG,CAAC,EAAE;gBACnC,IAAI,CAAC,cAAc,EAAE,GAAG,EAAE,OAAO,CAAC,GAAG,CAAC,CAAC,CAAA;aACxC;iBAAM;gBACL,IAAI,CAAC,OAAO,EAAE,GAAG,EAAE,OAAO,CAAC,GAAG,CAAC,CAAC,CAAA;aACjC;QACH,CAAC,CAAC,CAAA;QAEF,OAAO,CAAC,OAAO,EAAE,cAAc,CAAC,CAAA;IAClC,CAAC;IAEM,gCAAS,GAAhB,UAAiB,KAAuB;;QACtC,IAAM,mBAAmB,GAAG,MAAM,CAAC,IAAI,CAAC,MAAA,KAAK,CAAC,YAAY,mCAAI,EAAE,CAAC,CAAC,MAAM,CACtE,UAAC,gBAAgB,EAAE,IAAI;;;YACrB,6BACK,gBAAgB,gBAClB,IAAI,IAAG,OAAO,CAAC,MAAA,KAAK,CAAC,YAAY,0CAAG,IAAI,CAAC,CAAC,OAC5C;QACH,CAAC,EACD,EAA6B,CAC9B,CAAA;QAED,mCAAmC;QACnC,KAAK,CAAC,OAAO,GAAG,MAAM,CAAC,KAAK,CAAC,OAAO,IAAI,EAAE,EAAE,UAAC,CAAC,EAAE,KAAK;YACnD,OAAO,KAAK,KAAK,SAAS,CAAA;QAC5B,CAAC,CAAC,CAAA;QAEF,qDAAqD;QACrD,qGAAqG;QACrG,yGAAyG;QACzG,+GAA+G;QAC/G,IAAM,eAAe,yBAEhB,mBAAmB,GAGnB,MAAA,KAAK,CAAC,OAAO,0CAAE,YAAY,CAC/B,CAAA;QAEK,IAAA,KAAuB,KAAK,CAAC,OAAO;YACxC,CAAC,CAAC,IAAI,CAAC,OAAO,CAAC,KAAK,CAAC,OAAO,CAAC;YAC7B,CAAC,CAAC,EAAE,EAFC,OAAO,QAAA,EAAE,SAAS,QAEnB,CAAA;QAEE,IAAA,OAAO,GAAc,KAAK,QAAnB,EAAK,IAAI,UAAK,KAAK,EAA5B,WAAoB,CAAF,CAAU;QAElC,IAAM,IAAI,gCACR,SAAS,EAAE,IAAI,IAAI,EAAE,IAClB,IAAI,KACP,YAAY,EAAE,eAAe,EAC7B,OAAO,SAAA,KACJ,SAAS,CACb,CAAA;QAED,IAAM,GAAG,yBACJ,IAAI,KACP,SAAS,EAAE,OAAO,CAAC,SAAS,IAAI,IAAI,CAAC,eAAe,EAAE,GACvD,CAAA;QAED,aAAa,CAAC,GAAG,CAAC,CAAA;QAClB,OAAO,GAAG,CAAA;IACZ,CAAC;IACH,mBAAC;AAAD,CAAC,AAnQD,IAmQC"}

dist/esm/queue/event-queue.js

@@ -34,20 +34,21 @@ import { __awaiter, __extends, __generator } from "tslib";
                 switch (_a.label) {
-                    case 0: return [4 /*yield*/, Promise.resolve(plugin.load(ctx, instance))
-                            .then(function () {
-                            _this.plugins.push(plugin);
-                        })
-                            .catch(function (err) {
-                            if (plugin.type === 'destination') {
-                                _this.failedInitializations.push(plugin.name);
-                                console.warn(plugin.name, err);
-                                ctx.log('warn', 'Failed to load destination', {
-                                    plugin: plugin.name,
-                                    error: err,
-                                });
-                                return;
-                            }
-                            throw err;
-                        })];
-                    case 1:
+                    case 0:
+                        if (!(plugin.type === 'destination' && plugin.name !== 'Segment.io')) return [3 /*break*/, 1];
+                        plugin.load(ctx, instance).catch(function (err) {
+                            _this.failedInitializations.push(plugin.name);
+                            _this.emit('initialization_failure', plugin);
+                            console.warn(plugin.name, err);
+                            ctx.log('warn', 'Failed to load destination', {
+                                plugin: plugin.name,
+                                error: err,
+                            });
+                            _this.plugins = _this.plugins.filter(function (p) { return p === plugin; });
+                        });
+                        return [3 /*break*/, 3];
+                    case 1: return [4 /*yield*/, plugin.load(ctx, instance)];
+                    case 2:
                         _a.sent();
+                        _a.label = 3;
+                    case 3:
+                        this.plugins.push(plugin);
                         return [2 /*return*/];
@@ -54,0 +55,0 @@ }

dist/esm/queue/event-queue.js.map

@@ -1,1 +0,1 @@
-{"version":3,"file":"event-queue.js","sourceRoot":"","sources":["../../../src/queue/event-queue.ts"],"names":[],"mappings":";AACA,OAAO,EAAE,OAAO,EAAE,MAAM,mBAAmB,CAAA;AAC3C,OAAO,EAAE,qBAAqB,EAAiB,MAAM,mBAAmB,CAAA;AAExE,OAAO,EAAE,WAAW,EAAE,kBAAkB,EAAE,MAAM,YAAY,CAAA;AAC5D,OAAO,EAAE,OAAO,EAAE,MAAM,kCAAkC,CAAA;AAG1D,OAAO,EAAE,eAAe,EAAa,MAAM,oBAAoB,CAAA;AAC/D,OAAO,EAAE,OAAO,EAAE,MAAM,EAAE,MAAM,YAAY,CAAA;AAW5C;IAGU,kCAAuC;IAc/C,wBAAY,aAAiC;QAA7C,YACE,iBAAO,SAMR;QApBD;;;;;;WAMG;QACH,mBAAa,GAAc,eAAe,EAAE,CAAA;QAE5C,aAAO,GAAa,EAAE,CAAA;QACtB,2BAAqB,GAAa,EAAE,CAAA;QAC5B,cAAQ,GAAG,KAAK,CAAA;QAKtB,KAAI,CAAC,KAAK,GAAG,aAAa,CAAA;QAC1B,KAAI,CAAC,KAAK,CAAC,EAAE,CAAC,qBAAqB,EAAE;YACnC,KAAI,CAAC,aAAa,CAAC,CAAC,CAAC,CAAA;QACvB,CAAC,CAAC,CAAA;;IACJ,CAAC;IAEK,iCAAQ,GAAd,UACE,GAAQ,EACR,MAAc,EACd,QAAuB;;;;;4BAEvB,qBAAM,OAAO,CAAC,OAAO,CAAC,MAAM,CAAC,IAAI,CAAC,GAAG,EAAE,QAAQ,CAAC,CAAC;6BAC9C,IAAI,CAAC;4BACJ,KAAI,CAAC,OAAO,CAAC,IAAI,CAAC,MAAM,CAAC,CAAA;wBAC3B,CAAC,CAAC;6BACD,KAAK,CAAC,UAAC,GAAG;4BACT,IAAI,MAAM,CAAC,IAAI,KAAK,aAAa,EAAE;gCACjC,KAAI,CAAC,qBAAqB,CAAC,IAAI,CAAC,MAAM,CAAC,IAAI,CAAC,CAAA;gCAC5C,OAAO,CAAC,IAAI,CAAC,MAAM,CAAC,IAAI,EAAE,GAAG,CAAC,CAAA;gCAE9B,GAAG,CAAC,GAAG,CAAC,MAAM,EAAE,4BAA4B,EAAE;oCAC5C,MAAM,EAAE,MAAM,CAAC,IAAI;oCACnB,KAAK,EAAE,GAAG;iCACX,CAAC,CAAA;gCAEF,OAAM;6BACP;4BAED,MAAM,GAAG,CAAA;wBACX,CAAC,CAAC,EAAA;;wBAlBJ,SAkBI,CAAA;;;;;KACL;IAEK,mCAAU,GAAhB,UACE,GAAQ,EACR,MAAuB,EACvB,QAAuB;;;;;;;6BAGjB,MAAM,CAAC,MAAM,EAAb,wBAAa;wBACf,qBAAM,OAAO,CAAC,OAAO,CAAC,MAAM,CAAC,MAAM,CAAC,GAAG,EAAE,QAAQ,CAAC,CAAC,EAAA;;wBAAnD,SAAmD,CAAA;;;wBAGrD,IAAI,CAAC,OAAO,GAAG,IAAI,CAAC,OAAO,CAAC,MAAM,CAAC,UAAC,CAAC,IAAK,OAAA,CAAC,CAAC,IAAI,KAAK,MAAM,CAAC,IAAI,EAAtB,CAAsB,CAAC,CAAA;;;;wBAEjE,GAAG,CAAC,GAAG,CAAC,MAAM,EAAE,8BAA8B,EAAE;4BAC9C,MAAM,EAAE,MAAM,CAAC,IAAI;4BACnB,KAAK,EAAE,GAAC;yBACT,CAAC,CAAA;;;;;;KAEL;IAEK,iCAAQ,GAAd,UAAe,GAAQ;;;;gBACrB,GAAG,CAAC,GAAG,CAAC,OAAO,EAAE,aAAa,CAAC,CAAA;gBAC/B,GAAG,CAAC,KAAK,CAAC,SAAS,CAAC,oBAAoB,CAAC,CAAA;gBAEzC,IAAI,CAAC,KAAK,CAAC,IAAI,CAAC,GAAG,CAAC,CAAA;gBACd,WAAW,GAAG,IAAI,CAAC,mBAAmB,CAAC,GAAG,CAAC,CAAA;gBACjD,IAAI,CAAC,aAAa,CAAC,CAAC,CAAC,CAAA;gBACrB,sBAAO,WAAW,EAAA;;;KACnB;IAEa,4CAAmB,GAAjC,UAAkC,GAAQ;;;;gBACxC,sBAAO,IAAI,OAAO,CAAC,UAAC,OAAO;wBACzB,IAAM,SAAS,GAAG,UAAC,OAAY,EAAE,SAAkB;4BACjD,IAAI,OAAO,CAAC,MAAM,CAAC,GAAG,CAAC,EAAE;gCACvB,KAAI,CAAC,GAAG,CAAC,OAAO,EAAE,SAAS,CAAC,CAAA;gCAC5B,IAAI,SAAS,EAAE;oCACb,OAAO,CAAC,OAAO,CAAC,CAAA;iCACjB;qCAAM;oCACL,OAAO,CAAC,OAAO,CAAC,CAAA;iCACjB;6BACF;wBACH,CAAC,CAAA;wBAED,KAAI,CAAC,EAAE,CAAC,OAAO,EAAE,SAAS,CAAC,CAAA;oBAC7B,CAAC,CAAC,EAAA;;;KACH;IAEK,uCAAc,GAApB,UAAqB,GAAQ;;;;gBAC3B,GAAG,CAAC,GAAG,CAAC,OAAO,EAAE,aAAa,CAAC,CAAA;gBAC/B,GAAG,CAAC,KAAK,CAAC,SAAS,CAAC,oBAAoB,CAAC,CAAA;gBAEzC,IAAI,CAAC,KAAK,CAAC,cAAc,CAAC,GAAG,CAAC,CAAA;gBAC9B,GAAG,CAAC,QAAQ,GAAG,CAAC,CAAA;gBAEhB,sBAAO,IAAI,CAAC,OAAO,CAAC,GAAG,CAAC,CAAC,KAAK,CAAC,UAAC,GAAG;wBACjC,IAAM,QAAQ,GAAG,KAAI,CAAC,WAAW,CAAC,GAAG,EAAE,GAAG,CAAC,CAAA;wBAC3C,IAAI,CAAC,QAAQ,EAAE;4BACb,GAAG,CAAC,iBAAiB,CAAC,EAAE,MAAM,EAAE,GAAG,EAAE,CAAC,CAAA;4BACtC,OAAO,GAAG,CAAA;yBACX;wBAED,OAAO,KAAI,CAAC,mBAAmB,CAAC,GAAG,CAAC,CAAA;oBACtC,CAAC,CAAC,EAAA;;;KACH;IAED,gCAAO,GAAP;QACE,OAAO,IAAI,CAAC,KAAK,CAAC,MAAM,KAAK,CAAC,CAAA;IAChC,CAAC;IAEO,sCAAa,GAArB,UAAsB,OAAa;QAAnC,iBAmBC;QAnBqB,wBAAA,EAAA,aAAa;QACjC,IAAI,IAAI,CAAC,QAAQ,EAAE;YACjB,OAAM;SACP;QAED,IAAI,CAAC,QAAQ,GAAG,IAAI,CAAA;QAEpB,UAAU,CAAC;YACT,mEAAmE;YACnE,KAAI,CAAC,KAAK,EAAE,CAAC,IAAI,CAAC;gBAChB,UAAU,CAAC;oBACT,KAAI,CAAC,QAAQ,GAAG,KAAK,CAAA;oBAErB,IAAI,KAAI,CAAC,KAAK,CAAC,MAAM,EAAE;wBACrB,KAAI,CAAC,aAAa,CAAC,CAAC,CAAC,CAAA;qBACtB;gBACH,CAAC,EAAE,CAAC,CAAC,CAAA;YACP,CAAC,CAAC,CAAA;QACJ,CAAC,EAAE,OAAO,CAAC,CAAA;IACb,CAAC;IAEa,gCAAO,GAArB,UAAsB,GAAQ;;;;;4BAC5B,qBAAM,IAAI,CAAC,aAAa,CAAC,IAAI,EAAE,EAAA;;wBAA/B,SAA+B,CAAA;wBAEzB,KAAK,GAAG,IAAI,CAAC,GAAG,EAAE,CAAA;;;;wBAEhB,qBAAM,IAAI,CAAC,QAAQ,CAAC,GAAG,CAAC,EAAA;;wBAA9B,GAAG,GAAG,SAAwB,CAAA;wBACxB,IAAI,GAAG,IAAI,CAAC,GAAG,EAAE,GAAG,KAAK,CAAA;wBAC/B,IAAI,CAAC,IAAI,CAAC,kBAAkB,EAAE,GAAG,CAAC,CAAA;wBAClC,GAAG,CAAC,KAAK,CAAC,KAAK,CAAC,WAAW,EAAE,IAAI,CAAC,CAAA;wBAClC,GAAG,CAAC,GAAG,CAAC,OAAO,EAAE,WAAW,EAAE,GAAG,CAAC,KAAK,CAAC,CAAA;wBACxC,sBAAO,GAAG,EAAA;;;wBAEJ,KAAK,GAAG,KAAuC,CAAA;wBACrD,GAAG,CAAC,GAAG,CAAC,OAAO,EAAE,mBAAmB,EAAE,KAAK,CAAC,CAAA;wBAC5C,IAAI,CAAC,IAAI,CAAC,kBAAkB,EAAE,GAAG,EAAE,KAAK,CAAC,CAAA;wBACzC,GAAG,CAAC,KAAK,CAAC,SAAS,CAAC,iBAAiB,CAAC,CAAA;wBACtC,MAAM,KAAG,CAAA;;;;;KAEZ;IAEO,oCAAW,GAAnB,UAAoB,GAAU,EAAE,GAAQ;QACtC,IAAM,SAAS,GAAG,CAAC,CAAC,GAAG,YAAY,kBAAkB,CAAC,IAAI,GAAG,CAAC,KAAK,CAAA;QACnE,IAAI,CAAC,SAAS,EAAE;YACd,OAAO,KAAK,CAAA;SACb;QAED,OAAO,IAAI,CAAC,KAAK,CAAC,eAAe,CAAC,GAAG,CAAC,CAAA;IACxC,CAAC;IAEK,8BAAK,GAAX;;;;;;wBACE,IAAI,IAAI,CAAC,KAAK,CAAC,MAAM,KAAK,CAAC,EAAE;4BAC3B,sBAAO,EAAE,EAAA;yBACV;wBAEG,GAAG,GAAG,IAAI,CAAC,KAAK,CAAC,GAAG,EAAE,CAAA;wBAC1B,IAAI,CAAC,GAAG,EAAE;4BACR,sBAAO,EAAE,EAAA;yBACV;wBAED,GAAG,CAAC,QAAQ,GAAG,IAAI,CAAC,KAAK,CAAC,WAAW,CAAC,GAAG,CAAC,CAAA;;;;wBAGlC,qBAAM,IAAI,CAAC,OAAO,CAAC,GAAG,CAAC,EAAA;;wBAA7B,GAAG,GAAG,SAAuB,CAAA;wBAC7B,IAAI,CAAC,IAAI,CAAC,OAAO,EAAE,GAAG,EAAE,IAAI,CAAC,CAAA;;;;wBAEvB,QAAQ,GAAG,IAAI,CAAC,WAAW,CAAC,KAAG,EAAE,GAAG,CAAC,CAAA;wBAE3C,IAAI,CAAC,QAAQ,EAAE;4BACb,GAAG,CAAC,iBAAiB,CAAC,EAAE,MAAM,EAAE,KAAG,EAAE,CAAC,CAAA;4BACtC,IAAI,CAAC,IAAI,CAAC,OAAO,EAAE,GAAG,EAAE,KAAK,CAAC,CAAA;yBAC/B;wBAED,sBAAO,EAAE,EAAA;4BAGX,sBAAO,CAAC,GAAG,CAAC,EAAA;;;;KACb;IAEO,gCAAO,GAAf;QACE,iDAAiD;QACjD,2CAA2C;QAC3C,OAAO,IAAI,CAAA;IACb,CAAC;IAEO,4CAAmB,GAA3B,UAA4B,QAAsB;QAChD,IAAM,SAAS,GAAG,IAAI,CAAC,OAAO,CAAC,MAAM,CAAC,UAAC,CAAC;;YACtC,+DAA+D;YAC/D,IAAI,CAAC,CAAC,IAAI,KAAK,aAAa,IAAI,CAAC,CAAC,IAAI,KAAK,YAAY,EAAE;gBACvD,OAAO,IAAI,CAAA;aACZ;YAED,IAAI,oBAAoB,GAAqC,SAAS,CAAA;YACtE,MAAA,CAAC,CAAC,gBAAgB,0CAAE,OAAO,CAAC,UAAC,IAAI;gBAC/B,IAAI,QAAQ,CAAC,IAAI,CAAC,KAAK,SAAS,EAAE;oBAChC,oBAAoB,GAAG,QAAQ,CAAC,IAAI,CAAC,CAAA;iBACtC;YACH,CAAC,CAAC,CAAA;YAEF,0FAA0F;YAC1F,OAAO,CACL,MAAA,MAAA,QAAQ,CAAC,CAAC,CAAC,IAAI,CAAC,mCAChB,oBAAoB,mCACpB,CAAC,CAAC,CAAC,IAAI,KAAK,YAAY,CAAC,CAAC,CAAC,IAAI,CAAC,CAAC,CAAC,QAAQ,CAAC,GAAG,CAAC,KAAK,KAAK,CAC1D,CAAA;QACH,CAAC,CAAC,CAAA;QAEI,IAAA,KAKF,OAAO,CAAC,SAAS,EAAE,MAAM,CAAC,EAJ5B,cAAW,EAAX,MAAM,mBAAG,EAAE,KAAA,EACX,kBAAe,EAAf,UAAU,mBAAG,EAAE,KAAA,EACf,mBAAgB,EAAhB,WAAW,mBAAG,EAAE,KAAA,EAChB,aAAU,EAAV,KAAK,mBAAG,EAAE,KACkB,CAAA;QAE9B,OAAO;YACL,MAAM,QAAA;YACN,UAAU,YAAA;YACV,YAAY,EAAE,WAAW;YACzB,KAAK,OAAA;SACN,CAAA;IACH,CAAC;IAEa,iCAAQ,GAAtB,UAAuB,GAAQ;;;;;;;wBAC7B,IAAI,CAAC,IAAI,CAAC,OAAO,EAAE,EAAE;4BACnB,MAAM,IAAI,KAAK,CAAC,WAAW,CAAC,CAAA;yBAC7B;wBAED,IAAI,GAAG,CAAC,QAAQ,GAAG,CAAC,EAAE;4BACpB,IAAI,CAAC,IAAI,CAAC,gBAAgB,EAAE,GAAG,CAAC,CAAA;yBACjC;wBAEK,KAAyB,IAAI,CAAC,mBAAmB,CACrD,MAAA,GAAG,CAAC,KAAK,CAAC,YAAY,mCAAI,EAAE,CAC7B,EAFO,MAAM,YAAA,EAAE,UAAU,gBAAA,CAEzB;8BAE8B,EAAN,iBAAM;;;6BAAN,CAAA,oBAAM,CAAA;wBAApB,UAAU;wBACN,qBAAM,MAAM,CAAC,GAAG,EAAE,UAAU,CAAC,EAAA;;wBAApC,IAAI,GAAG,SAA6B;wBAC1C,IAAI,IAAI,YAAY,WAAW,EAAE;4BAC/B,GAAG,GAAG,IAAI,CAAA;yBACX;wBAED,IAAI,CAAC,IAAI,CAAC,kBAAkB,EAAE,GAAG,EAAE,UAAU,CAAC,CAAA;;;wBANvB,IAAM,CAAA;;;8BASQ,EAAV,yBAAU;;;6BAAV,CAAA,wBAAU,CAAA;wBAA5B,cAAc;wBACV,qBAAM,OAAO,CAAC,GAAG,EAAE,cAAc,CAAC,EAAA;;wBAAzC,IAAI,GAAG,SAAkC;wBAC/C,IAAI,IAAI,YAAY,WAAW,EAAE;4BAC/B,GAAG,GAAG,IAAI,CAAA;yBACX;wBAED,IAAI,CAAC,IAAI,CAAC,kBAAkB,EAAE,GAAG,EAAE,cAAc,CAAC,CAAA;;;wBANvB,IAAU,CAAA;;;wBAWjC,KAA0B,IAAI,CAAC,mBAAmB,CACtD,MAAA,GAAG,CAAC,KAAK,CAAC,YAAY,mCAAI,EAAE,CAC7B,EAFO,YAAY,kBAAA,EAAE,KAAK,WAAA,CAE1B;wBAED,qBAAM,IAAI,OAAO,CAAC,UAAC,OAAO,EAAE,MAAM;gCAChC,UAAU,CAAC;oCACT,IAAM,QAAQ,GAAG,YAAY,CAAC,GAAG,CAAC,UAAC,WAAW;wCAC5C,OAAA,OAAO,CAAC,GAAG,EAAE,WAAW,CAAC;oCAAzB,CAAyB,CAC1B,CAAA;oCACD,OAAO,CAAC,GAAG,CAAC,QAAQ,CAAC,CAAC,IAAI,CAAC,OAAO,CAAC,CAAC,KAAK,CAAC,MAAM,CAAC,CAAA;gCACnD,CAAC,EAAE,CAAC,CAAC,CAAA;4BACP,CAAC,CAAC,EAAA;;wBAPF,SAOE,CAAA;wBAEF,GAAG,CAAC,KAAK,CAAC,SAAS,CAAC,mBAAmB,CAAC,CAAA;wBAExC,IAAI,CAAC,IAAI,CAAC,mBAAmB,EAAE,GAAG,CAAC,CAAA;wBAE7B,UAAU,GAAG,KAAK,CAAC,GAAG,CAAC,UAAC,KAAK,IAAK,OAAA,OAAO,CAAC,GAAG,EAAE,KAAK,CAAC,EAAnB,CAAmB,CAAC,CAAA;wBAC5D,qBAAM,OAAO,CAAC,GAAG,CAAC,UAAU,CAAC,EAAA;;wBAA7B,SAA6B,CAAA;wBAE7B,sBAAO,GAAG,EAAA;;;;KACX;IACH,qBAAC;AAAD,CAAC,AAzSD,CAGU,OAAO,GAsShB"}
+{"version":3,"file":"event-queue.js","sourceRoot":"","sources":["../../../src/queue/event-queue.ts"],"names":[],"mappings":";AACA,OAAO,EAAE,OAAO,EAAE,MAAM,mBAAmB,CAAA;AAC3C,OAAO,EAAE,qBAAqB,EAAiB,MAAM,mBAAmB,CAAA;AAExE,OAAO,EAAE,WAAW,EAAE,kBAAkB,EAAE,MAAM,YAAY,CAAA;AAC5D,OAAO,EAAE,OAAO,EAAE,MAAM,kCAAkC,CAAA;AAG1D,OAAO,EAAE,eAAe,EAAa,MAAM,oBAAoB,CAAA;AAC/D,OAAO,EAAE,OAAO,EAAE,MAAM,EAAE,MAAM,YAAY,CAAA;AAY5C;IAGU,kCAAuC;IAc/C,wBAAY,aAAiC;QAA7C,YACE,iBAAO,SAMR;QApBD;;;;;;WAMG;QACH,mBAAa,GAAc,eAAe,EAAE,CAAA;QAE5C,aAAO,GAAa,EAAE,CAAA;QACtB,2BAAqB,GAAa,EAAE,CAAA;QAC5B,cAAQ,GAAG,KAAK,CAAA;QAKtB,KAAI,CAAC,KAAK,GAAG,aAAa,CAAA;QAC1B,KAAI,CAAC,KAAK,CAAC,EAAE,CAAC,qBAAqB,EAAE;YACnC,KAAI,CAAC,aAAa,CAAC,CAAC,CAAC,CAAA;QACvB,CAAC,CAAC,CAAA;;IACJ,CAAC;IAEK,iCAAQ,GAAd,UACE,GAAQ,EACR,MAAc,EACd,QAAuB;;;;;;6BAEnB,CAAA,MAAM,CAAC,IAAI,KAAK,aAAa,IAAI,MAAM,CAAC,IAAI,KAAK,YAAY,CAAA,EAA7D,wBAA6D;wBAC/D,MAAM,CAAC,IAAI,CAAC,GAAG,EAAE,QAAQ,CAAC,CAAC,KAAK,CAAC,UAAC,GAAG;4BACnC,KAAI,CAAC,qBAAqB,CAAC,IAAI,CAAC,MAAM,CAAC,IAAI,CAAC,CAAA;4BAC5C,KAAI,CAAC,IAAI,CAAC,wBAAwB,EAAE,MAAM,CAAC,CAAA;4BAC3C,OAAO,CAAC,IAAI,CAAC,MAAM,CAAC,IAAI,EAAE,GAAG,CAAC,CAAA;4BAE9B,GAAG,CAAC,GAAG,CAAC,MAAM,EAAE,4BAA4B,EAAE;gCAC5C,MAAM,EAAE,MAAM,CAAC,IAAI;gCACnB,KAAK,EAAE,GAAG;6BACX,CAAC,CAAA;4BAEF,KAAI,CAAC,OAAO,GAAG,KAAI,CAAC,OAAO,CAAC,MAAM,CAAC,UAAC,CAAC,IAAK,OAAA,CAAC,KAAK,MAAM,EAAZ,CAAY,CAAC,CAAA;wBACzD,CAAC,CAAC,CAAA;;4BAEF,qBAAM,MAAM,CAAC,IAAI,CAAC,GAAG,EAAE,QAAQ,CAAC,EAAA;;wBAAhC,SAAgC,CAAA;;;wBAGlC,IAAI,CAAC,OAAO,CAAC,IAAI,CAAC,MAAM,CAAC,CAAA;;;;;KAC1B;IAEK,mCAAU,GAAhB,UACE,GAAQ,EACR,MAAuB,EACvB,QAAuB;;;;;;;6BAGjB,MAAM,CAAC,MAAM,EAAb,wBAAa;wBACf,qBAAM,OAAO,CAAC,OAAO,CAAC,MAAM,CAAC,MAAM,CAAC,GAAG,EAAE,QAAQ,CAAC,CAAC,EAAA;;wBAAnD,SAAmD,CAAA;;;wBAGrD,IAAI,CAAC,OAAO,GAAG,IAAI,CAAC,OAAO,CAAC,MAAM,CAAC,UAAC,CAAC,IAAK,OAAA,CAAC,CAAC,IAAI,KAAK,MAAM,CAAC,IAAI,EAAtB,CAAsB,CAAC,CAAA;;;;wBAEjE,GAAG,CAAC,GAAG,CAAC,MAAM,EAAE,8BAA8B,EAAE;4BAC9C,MAAM,EAAE,MAAM,CAAC,IAAI;4BACnB,KAAK,EAAE,GAAC;yBACT,CAAC,CAAA;;;;;;KAEL;IAEK,iCAAQ,GAAd,UAAe,GAAQ;;;;gBACrB,GAAG,CAAC,GAAG,CAAC,OAAO,EAAE,aAAa,CAAC,CAAA;gBAC/B,GAAG,CAAC,KAAK,CAAC,SAAS,CAAC,oBAAoB,CAAC,CAAA;gBAEzC,IAAI,CAAC,KAAK,CAAC,IAAI,CAAC,GAAG,CAAC,CAAA;gBACd,WAAW,GAAG,IAAI,CAAC,mBAAmB,CAAC,GAAG,CAAC,CAAA;gBACjD,IAAI,CAAC,aAAa,CAAC,CAAC,CAAC,CAAA;gBACrB,sBAAO,WAAW,EAAA;;;KACnB;IAEa,4CAAmB,GAAjC,UAAkC,GAAQ;;;;gBACxC,sBAAO,IAAI,OAAO,CAAC,UAAC,OAAO;wBACzB,IAAM,SAAS,GAAG,UAAC,OAAY,EAAE,SAAkB;4BACjD,IAAI,OAAO,CAAC,MAAM,CAAC,GAAG,CAAC,EAAE;gCACvB,KAAI,CAAC,GAAG,CAAC,OAAO,EAAE,SAAS,CAAC,CAAA;gCAC5B,IAAI,SAAS,EAAE;oCACb,OAAO,CAAC,OAAO,CAAC,CAAA;iCACjB;qCAAM;oCACL,OAAO,CAAC,OAAO,CAAC,CAAA;iCACjB;6BACF;wBACH,CAAC,CAAA;wBAED,KAAI,CAAC,EAAE,CAAC,OAAO,EAAE,SAAS,CAAC,CAAA;oBAC7B,CAAC,CAAC,EAAA;;;KACH;IAEK,uCAAc,GAApB,UAAqB,GAAQ;;;;gBAC3B,GAAG,CAAC,GAAG,CAAC,OAAO,EAAE,aAAa,CAAC,CAAA;gBAC/B,GAAG,CAAC,KAAK,CAAC,SAAS,CAAC,oBAAoB,CAAC,CAAA;gBAEzC,IAAI,CAAC,KAAK,CAAC,cAAc,CAAC,GAAG,CAAC,CAAA;gBAC9B,GAAG,CAAC,QAAQ,GAAG,CAAC,CAAA;gBAEhB,sBAAO,IAAI,CAAC,OAAO,CAAC,GAAG,CAAC,CAAC,KAAK,CAAC,UAAC,GAAG;wBACjC,IAAM,QAAQ,GAAG,KAAI,CAAC,WAAW,CAAC,GAAG,EAAE,GAAG,CAAC,CAAA;wBAC3C,IAAI,CAAC,QAAQ,EAAE;4BACb,GAAG,CAAC,iBAAiB,CAAC,EAAE,MAAM,EAAE,GAAG,EAAE,CAAC,CAAA;4BACtC,OAAO,GAAG,CAAA;yBACX;wBAED,OAAO,KAAI,CAAC,mBAAmB,CAAC,GAAG,CAAC,CAAA;oBACtC,CAAC,CAAC,EAAA;;;KACH;IAED,gCAAO,GAAP;QACE,OAAO,IAAI,CAAC,KAAK,CAAC,MAAM,KAAK,CAAC,CAAA;IAChC,CAAC;IAEO,sCAAa,GAArB,UAAsB,OAAa;QAAnC,iBAmBC;QAnBqB,wBAAA,EAAA,aAAa;QACjC,IAAI,IAAI,CAAC,QAAQ,EAAE;YACjB,OAAM;SACP;QAED,IAAI,CAAC,QAAQ,GAAG,IAAI,CAAA;QAEpB,UAAU,CAAC;YACT,mEAAmE;YACnE,KAAI,CAAC,KAAK,EAAE,CAAC,IAAI,CAAC;gBAChB,UAAU,CAAC;oBACT,KAAI,CAAC,QAAQ,GAAG,KAAK,CAAA;oBAErB,IAAI,KAAI,CAAC,KAAK,CAAC,MAAM,EAAE;wBACrB,KAAI,CAAC,aAAa,CAAC,CAAC,CAAC,CAAA;qBACtB;gBACH,CAAC,EAAE,CAAC,CAAC,CAAA;YACP,CAAC,CAAC,CAAA;QACJ,CAAC,EAAE,OAAO,CAAC,CAAA;IACb,CAAC;IAEa,gCAAO,GAArB,UAAsB,GAAQ;;;;;4BAC5B,qBAAM,IAAI,CAAC,aAAa,CAAC,IAAI,EAAE,EAAA;;wBAA/B,SAA+B,CAAA;wBAEzB,KAAK,GAAG,IAAI,CAAC,GAAG,EAAE,CAAA;;;;wBAEhB,qBAAM,IAAI,CAAC,QAAQ,CAAC,GAAG,CAAC,EAAA;;wBAA9B,GAAG,GAAG,SAAwB,CAAA;wBACxB,IAAI,GAAG,IAAI,CAAC,GAAG,EAAE,GAAG,KAAK,CAAA;wBAC/B,IAAI,CAAC,IAAI,CAAC,kBAAkB,EAAE,GAAG,CAAC,CAAA;wBAClC,GAAG,CAAC,KAAK,CAAC,KAAK,CAAC,WAAW,EAAE,IAAI,CAAC,CAAA;wBAClC,GAAG,CAAC,GAAG,CAAC,OAAO,EAAE,WAAW,EAAE,GAAG,CAAC,KAAK,CAAC,CAAA;wBACxC,sBAAO,GAAG,EAAA;;;wBAEJ,KAAK,GAAG,KAAuC,CAAA;wBACrD,GAAG,CAAC,GAAG,CAAC,OAAO,EAAE,mBAAmB,EAAE,KAAK,CAAC,CAAA;wBAC5C,IAAI,CAAC,IAAI,CAAC,kBAAkB,EAAE,GAAG,EAAE,KAAK,CAAC,CAAA;wBACzC,GAAG,CAAC,KAAK,CAAC,SAAS,CAAC,iBAAiB,CAAC,CAAA;wBACtC,MAAM,KAAG,CAAA;;;;;KAEZ;IAEO,oCAAW,GAAnB,UAAoB,GAAU,EAAE,GAAQ;QACtC,IAAM,SAAS,GAAG,CAAC,CAAC,GAAG,YAAY,kBAAkB,CAAC,IAAI,GAAG,CAAC,KAAK,CAAA;QACnE,IAAI,CAAC,SAAS,EAAE;YACd,OAAO,KAAK,CAAA;SACb;QAED,OAAO,IAAI,CAAC,KAAK,CAAC,eAAe,CAAC,GAAG,CAAC,CAAA;IACxC,CAAC;IAEK,8BAAK,GAAX;;;;;;wBACE,IAAI,IAAI,CAAC,KAAK,CAAC,MAAM,KAAK,CAAC,EAAE;4BAC3B,sBAAO,EAAE,EAAA;yBACV;wBAEG,GAAG,GAAG,IAAI,CAAC,KAAK,CAAC,GAAG,EAAE,CAAA;wBAC1B,IAAI,CAAC,GAAG,EAAE;4BACR,sBAAO,EAAE,EAAA;yBACV;wBAED,GAAG,CAAC,QAAQ,GAAG,IAAI,CAAC,KAAK,CAAC,WAAW,CAAC,GAAG,CAAC,CAAA;;;;wBAGlC,qBAAM,IAAI,CAAC,OAAO,CAAC,GAAG,CAAC,EAAA;;wBAA7B,GAAG,GAAG,SAAuB,CAAA;wBAC7B,IAAI,CAAC,IAAI,CAAC,OAAO,EAAE,GAAG,EAAE,IAAI,CAAC,CAAA;;;;wBAEvB,QAAQ,GAAG,IAAI,CAAC,WAAW,CAAC,KAAG,EAAE,GAAG,CAAC,CAAA;wBAE3C,IAAI,CAAC,QAAQ,EAAE;4BACb,GAAG,CAAC,iBAAiB,CAAC,EAAE,MAAM,EAAE,KAAG,EAAE,CAAC,CAAA;4BACtC,IAAI,CAAC,IAAI,CAAC,OAAO,EAAE,GAAG,EAAE,KAAK,CAAC,CAAA;yBAC/B;wBAED,sBAAO,EAAE,EAAA;4BAGX,sBAAO,CAAC,GAAG,CAAC,EAAA;;;;KACb;IAEO,gCAAO,GAAf;QACE,iDAAiD;QACjD,2CAA2C;QAC3C,OAAO,IAAI,CAAA;IACb,CAAC;IAEO,4CAAmB,GAA3B,UAA4B,QAAsB;QAChD,IAAM,SAAS,GAAG,IAAI,CAAC,OAAO,CAAC,MAAM,CAAC,UAAC,CAAC;;YACtC,+DAA+D;YAC/D,IAAI,CAAC,CAAC,IAAI,KAAK,aAAa,IAAI,CAAC,CAAC,IAAI,KAAK,YAAY,EAAE;gBACvD,OAAO,IAAI,CAAA;aACZ;YAED,IAAI,oBAAoB,GAAqC,SAAS,CAAA;YACtE,MAAA,CAAC,CAAC,gBAAgB,0CAAE,OAAO,CAAC,UAAC,IAAI;gBAC/B,IAAI,QAAQ,CAAC,IAAI,CAAC,KAAK,SAAS,EAAE;oBAChC,oBAAoB,GAAG,QAAQ,CAAC,IAAI,CAAC,CAAA;iBACtC;YACH,CAAC,CAAC,CAAA;YAEF,0FAA0F;YAC1F,OAAO,CACL,MAAA,MAAA,QAAQ,CAAC,CAAC,CAAC,IAAI,CAAC,mCAChB,oBAAoB,mCACpB,CAAC,CAAC,CAAC,IAAI,KAAK,YAAY,CAAC,CAAC,CAAC,IAAI,CAAC,CAAC,CAAC,QAAQ,CAAC,GAAG,CAAC,KAAK,KAAK,CAC1D,CAAA;QACH,CAAC,CAAC,CAAA;QAEI,IAAA,KAKF,OAAO,CAAC,SAAS,EAAE,MAAM,CAAC,EAJ5B,cAAW,EAAX,MAAM,mBAAG,EAAE,KAAA,EACX,kBAAe,EAAf,UAAU,mBAAG,EAAE,KAAA,EACf,mBAAgB,EAAhB,WAAW,mBAAG,EAAE,KAAA,EAChB,aAAU,EAAV,KAAK,mBAAG,EAAE,KACkB,CAAA;QAE9B,OAAO;YACL,MAAM,QAAA;YACN,UAAU,YAAA;YACV,YAAY,EAAE,WAAW;YACzB,KAAK,OAAA;SACN,CAAA;IACH,CAAC;IAEa,iCAAQ,GAAtB,UAAuB,GAAQ;;;;;;;wBAC7B,IAAI,CAAC,IAAI,CAAC,OAAO,EAAE,EAAE;4BACnB,MAAM,IAAI,KAAK,CAAC,WAAW,CAAC,CAAA;yBAC7B;wBAED,IAAI,GAAG,CAAC,QAAQ,GAAG,CAAC,EAAE;4BACpB,IAAI,CAAC,IAAI,CAAC,gBAAgB,EAAE,GAAG,CAAC,CAAA;yBACjC;wBAEK,KAAyB,IAAI,CAAC,mBAAmB,CACrD,MAAA,GAAG,CAAC,KAAK,CAAC,YAAY,mCAAI,EAAE,CAC7B,EAFO,MAAM,YAAA,EAAE,UAAU,gBAAA,CAEzB;8BAE8B,EAAN,iBAAM;;;6BAAN,CAAA,oBAAM,CAAA;wBAApB,UAAU;wBACN,qBAAM,MAAM,CAAC,GAAG,EAAE,UAAU,CAAC,EAAA;;wBAApC,IAAI,GAAG,SAA6B;wBAC1C,IAAI,IAAI,YAAY,WAAW,EAAE;4BAC/B,GAAG,GAAG,IAAI,CAAA;yBACX;wBAED,IAAI,CAAC,IAAI,CAAC,kBAAkB,EAAE,GAAG,EAAE,UAAU,CAAC,CAAA;;;wBANvB,IAAM,CAAA;;;8BASQ,EAAV,yBAAU;;;6BAAV,CAAA,wBAAU,CAAA;wBAA5B,cAAc;wBACV,qBAAM,OAAO,CAAC,GAAG,EAAE,cAAc,CAAC,EAAA;;wBAAzC,IAAI,GAAG,SAAkC;wBAC/C,IAAI,IAAI,YAAY,WAAW,EAAE;4BAC/B,GAAG,GAAG,IAAI,CAAA;yBACX;wBAED,IAAI,CAAC,IAAI,CAAC,kBAAkB,EAAE,GAAG,EAAE,cAAc,CAAC,CAAA;;;wBANvB,IAAU,CAAA;;;wBAWjC,KAA0B,IAAI,CAAC,mBAAmB,CACtD,MAAA,GAAG,CAAC,KAAK,CAAC,YAAY,mCAAI,EAAE,CAC7B,EAFO,YAAY,kBAAA,EAAE,KAAK,WAAA,CAE1B;wBAED,qBAAM,IAAI,OAAO,CAAC,UAAC,OAAO,EAAE,MAAM;gCAChC,UAAU,CAAC;oCACT,IAAM,QAAQ,GAAG,YAAY,CAAC,GAAG,CAAC,UAAC,WAAW;wCAC5C,OAAA,OAAO,CAAC,GAAG,EAAE,WAAW,CAAC;oCAAzB,CAAyB,CAC1B,CAAA;oCACD,OAAO,CAAC,GAAG,CAAC,QAAQ,CAAC,CAAC,IAAI,CAAC,OAAO,CAAC,CAAC,KAAK,CAAC,MAAM,CAAC,CAAA;gCACnD,CAAC,EAAE,CAAC,CAAC,CAAA;4BACP,CAAC,CAAC,EAAA;;wBAPF,SAOE,CAAA;wBAEF,GAAG,CAAC,KAAK,CAAC,SAAS,CAAC,mBAAmB,CAAC,CAAA;wBAExC,IAAI,CAAC,IAAI,CAAC,mBAAmB,EAAE,GAAG,CAAC,CAAA;wBAE7B,UAAU,GAAG,KAAK,CAAC,GAAG,CAAC,UAAC,KAAK,IAAK,OAAA,OAAO,CAAC,GAAG,EAAE,KAAK,CAAC,EAAnB,CAAmB,CAAC,CAAA;wBAC5D,qBAAM,OAAO,CAAC,GAAG,CAAC,UAAU,CAAC,EAAA;;wBAA7B,SAA6B,CAAA;wBAE7B,sBAAO,GAAG,EAAA;;;;KACX;IACH,qBAAC;AAAD,CAAC,AAxSD,CAGU,OAAO,GAqShB"}

dist/esm/validation/assertions.js

@@ -45,5 +45,11 @@ import { ValidationError } from './errors';
 }
+export function assertMessageId(event) {
+    if (!isString(event.messageId)) {
+        throw new ValidationError('.messageId', stringError);
+    }
+}
 export function validateEvent(event) {
     assertEventExists(event);
     assertEventType(event);
+    assertMessageId(event);
     if (event.type === 'track') {
@@ -50,0 +56,0 @@ assertTrackEventName(event);

dist/esm/validation/assertions.js.map

@@ -1,1 +0,1 @@
-{"version":3,"file":"assertions.js","sourceRoot":"","sources":["../../../src/validation/assertions.ts"],"names":[],"mappings":"AACA,OAAO,EAAE,eAAe,EAAE,MAAM,UAAU,CAAA;AAC1C,OAAO,EAAE,QAAQ,EAAE,aAAa,EAAE,MAAM,EAAE,MAAM,WAAW,CAAA;AAE3D,IAAM,WAAW,GAAG,iBAAiB,CAAA;AACrC,IAAM,QAAQ,GAAG,kBAAkB,CAAA;AACnC,IAAM,QAAQ,GAAG,QAAQ,CAAA;AAEzB,MAAM,UAAU,kBAAkB,CAAC,KAAuB;IACxD,IAAM,eAAe,GAAG,wCAAwC,CAAA;IAEhE,IAAM,YAAY,GAAG,UAAC,KAAuB,oBAC3C,OAAA,MAAA,MAAA,MAAA,KAAK,CAAC,MAAM,mCAAI,KAAK,CAAC,WAAW,mCAAI,KAAK,CAAC,OAAO,mCAAI,KAAK,CAAC,UAAU,CAAA,EAAA,CAAA;IAExE,IAAM,EAAE,GAAG,YAAY,CAAC,KAAK,CAAC,CAAA;IAC9B,IAAI,CAAC,MAAM,CAAC,EAAE,CAAC,EAAE;QACf,MAAM,IAAI,eAAe,CAAC,eAAe,EAAE,QAAQ,CAAC,CAAA;KACrD;SAAM,IAAI,CAAC,QAAQ,CAAC,EAAE,CAAC,EAAE;QACxB,MAAM,IAAI,eAAe,CAAC,eAAe,EAAE,WAAW,CAAC,CAAA;KACxD;AACH,CAAC;AAED,MAAM,UAAU,iBAAiB,CAC/B,KAA+B;IAE/B,IAAI,CAAC,MAAM,CAAC,KAAK,CAAC,EAAE;QAClB,MAAM,IAAI,eAAe,CAAC,OAAO,EAAE,QAAQ,CAAC,CAAA;KAC7C;IACD,IAAI,OAAO,KAAK,KAAK,QAAQ,EAAE;QAC7B,MAAM,IAAI,eAAe,CAAC,OAAO,EAAE,QAAQ,CAAC,CAAA;KAC7C;AACH,CAAC;AAED,MAAM,UAAU,eAAe,CAAC,KAAuB;IACrD,IAAI,CAAC,QAAQ,CAAC,KAAK,CAAC,IAAI,CAAC,EAAE;QACzB,MAAM,IAAI,eAAe,CAAC,OAAO,EAAE,WAAW,CAAC,CAAA;KAChD;AACH,CAAC;AAED,MAAM,UAAU,oBAAoB,CAAC,KAAuB;IAC1D,IAAI,CAAC,QAAQ,CAAC,KAAK,CAAC,KAAK,CAAC,EAAE;QAC1B,MAAM,IAAI,eAAe,CAAC,QAAQ,EAAE,WAAW,CAAC,CAAA;KACjD;AACH,CAAC;AAED,MAAM,UAAU,0BAA0B,CAAC,KAAuB;IAChE,IAAI,CAAC,aAAa,CAAC,KAAK,CAAC,UAAU,CAAC,EAAE;QACpC,MAAM,IAAI,eAAe,CAAC,aAAa,EAAE,QAAQ,CAAC,CAAA;KACnD;AACH,CAAC;AAED,MAAM,UAAU,YAAY,CAAC,KAAuB;IAClD,IAAI,CAAC,aAAa,CAAC,KAAK,CAAC,MAAM,CAAC,EAAE;QAChC,MAAM,IAAI,eAAe,CAAC,SAAS,EAAE,QAAQ,CAAC,CAAA;KAC/C;AACH,CAAC;AAED,MAAM,UAAU,aAAa,CAAC,KAA+B;IAC3D,iBAAiB,CAAC,KAAK,CAAC,CAAA;IACxB,eAAe,CAAC,KAAK,CAAC,CAAA;IAEtB,IAAI,KAAK,CAAC,IAAI,KAAK,OAAO,EAAE;QAC1B,oBAAoB,CAAC,KAAK,CAAC,CAAA;QAC3B,0BAA0B,CAAC,KAAK,CAAC,CAAA;KAClC;IAED,IAAI,CAAC,OAAO,EAAE,UAAU,CAAC,CAAC,QAAQ,CAAC,KAAK,CAAC,IAAI,CAAC,EAAE;QAC9C,YAAY,CAAC,KAAK,CAAC,CAAA;KACpB;IAED,kBAAkB,CAAC,KAAK,CAAC,CAAA;AAC3B,CAAC"}
+{"version":3,"file":"assertions.js","sourceRoot":"","sources":["../../../src/validation/assertions.ts"],"names":[],"mappings":"AACA,OAAO,EAAE,eAAe,EAAE,MAAM,UAAU,CAAA;AAC1C,OAAO,EAAE,QAAQ,EAAE,aAAa,EAAE,MAAM,EAAE,MAAM,WAAW,CAAA;AAE3D,IAAM,WAAW,GAAG,iBAAiB,CAAA;AACrC,IAAM,QAAQ,GAAG,kBAAkB,CAAA;AACnC,IAAM,QAAQ,GAAG,QAAQ,CAAA;AAEzB,MAAM,UAAU,kBAAkB,CAAC,KAAuB;IACxD,IAAM,eAAe,GAAG,wCAAwC,CAAA;IAEhE,IAAM,YAAY,GAAG,UAAC,KAAuB,oBAC3C,OAAA,MAAA,MAAA,MAAA,KAAK,CAAC,MAAM,mCAAI,KAAK,CAAC,WAAW,mCAAI,KAAK,CAAC,OAAO,mCAAI,KAAK,CAAC,UAAU,CAAA,EAAA,CAAA;IAExE,IAAM,EAAE,GAAG,YAAY,CAAC,KAAK,CAAC,CAAA;IAC9B,IAAI,CAAC,MAAM,CAAC,EAAE,CAAC,EAAE;QACf,MAAM,IAAI,eAAe,CAAC,eAAe,EAAE,QAAQ,CAAC,CAAA;KACrD;SAAM,IAAI,CAAC,QAAQ,CAAC,EAAE,CAAC,EAAE;QACxB,MAAM,IAAI,eAAe,CAAC,eAAe,EAAE,WAAW,CAAC,CAAA;KACxD;AACH,CAAC;AAED,MAAM,UAAU,iBAAiB,CAC/B,KAA+B;IAE/B,IAAI,CAAC,MAAM,CAAC,KAAK,CAAC,EAAE;QAClB,MAAM,IAAI,eAAe,CAAC,OAAO,EAAE,QAAQ,CAAC,CAAA;KAC7C;IACD,IAAI,OAAO,KAAK,KAAK,QAAQ,EAAE;QAC7B,MAAM,IAAI,eAAe,CAAC,OAAO,EAAE,QAAQ,CAAC,CAAA;KAC7C;AACH,CAAC;AAED,MAAM,UAAU,eAAe,CAAC,KAAuB;IACrD,IAAI,CAAC,QAAQ,CAAC,KAAK,CAAC,IAAI,CAAC,EAAE;QACzB,MAAM,IAAI,eAAe,CAAC,OAAO,EAAE,WAAW,CAAC,CAAA;KAChD;AACH,CAAC;AAED,MAAM,UAAU,oBAAoB,CAAC,KAAuB;IAC1D,IAAI,CAAC,QAAQ,CAAC,KAAK,CAAC,KAAK,CAAC,EAAE;QAC1B,MAAM,IAAI,eAAe,CAAC,QAAQ,EAAE,WAAW,CAAC,CAAA;KACjD;AACH,CAAC;AAED,MAAM,UAAU,0BAA0B,CAAC,KAAuB;IAChE,IAAI,CAAC,aAAa,CAAC,KAAK,CAAC,UAAU,CAAC,EAAE;QACpC,MAAM,IAAI,eAAe,CAAC,aAAa,EAAE,QAAQ,CAAC,CAAA;KACnD;AACH,CAAC;AAED,MAAM,UAAU,YAAY,CAAC,KAAuB;IAClD,IAAI,CAAC,aAAa,CAAC,KAAK,CAAC,MAAM,CAAC,EAAE;QAChC,MAAM,IAAI,eAAe,CAAC,SAAS,EAAE,QAAQ,CAAC,CAAA;KAC/C;AACH,CAAC;AAED,MAAM,UAAU,eAAe,CAAC,KAAuB;IACrD,IAAI,CAAC,QAAQ,CAAC,KAAK,CAAC,SAAS,CAAC,EAAE;QAC9B,MAAM,IAAI,eAAe,CAAC,YAAY,EAAE,WAAW,CAAC,CAAA;KACrD;AACH,CAAC;AAED,MAAM,UAAU,aAAa,CAAC,KAA+B;IAC3D,iBAAiB,CAAC,KAAK,CAAC,CAAA;IACxB,eAAe,CAAC,KAAK,CAAC,CAAA;IACtB,eAAe,CAAC,KAAK,CAAC,CAAA;IAEtB,IAAI,KAAK,CAAC,IAAI,KAAK,OAAO,EAAE;QAC1B,oBAAoB,CAAC,KAAK,CAAC,CAAA;QAC3B,0BAA0B,CAAC,KAAK,CAAC,CAAA;KAClC;IAED,IAAI,CAAC,OAAO,EAAE,UAAU,CAAC,CAAC,QAAQ,CAAC,KAAK,CAAC,IAAI,CAAC,EAAE;QAC9C,YAAY,CAAC,KAAK,CAAC,CAAA;KACpB;IAED,kBAAkB,CAAC,KAAK,CAAC,CAAA;AAC3B,CAAC"}

dist/types/events/index.d.ts

@@ -8,2 +8,6 @@ export * from './interfaces';
 }
+/**
+ * This is currently only used by node.js, but the original idea was to have something that could be shared between browser and node.
+ * Unfortunately, there are some differences in the way the two environments handle events, so this is not currently shared.
+ */
 export declare class EventFactory {
@@ -10,0 +14,0 @@ createMessageId: EventFactorySettings['createMessageId'];

dist/types/events/index.d.ts.map

@@ -1,1 +0,1 @@
-{"version":3,"file":"index.d.ts","sourceRoot":"","sources":["../../../src/events/index.ts"],"names":[],"mappings":"AAAA,cAAc,cAAc,CAAA;AAE5B,OAAO,EAAE,EAAE,EAAE,IAAI,EAAE,MAAM,SAAS,CAAA;AAClC,OAAO,EACL,YAAY,EACZ,eAAe,EACf,gBAAgB,EAChB,WAAW,EAEX,UAAU,EACV,WAAW,EACZ,MAAM,cAAc,CAAA;AAKrB,UAAU,oBAAoB;IAC5B,eAAe,EAAE,MAAM,MAAM,CAAA;IAC7B,IAAI,CAAC,EAAE,IAAI,CAAA;CACZ;AAED,qBAAa,YAAY;IACvB,eAAe,EAAE,oBAAoB,CAAC,iBAAiB,CAAC,CAAA;IACxD,IAAI,CAAC,EAAE,IAAI,CAAA;gBAEC,QAAQ,EAAE,oBAAoB;IAK1C,KAAK,CACH,KAAK,EAAE,MAAM,EACb,UAAU,CAAC,EAAE,eAAe,EAC5B,OAAO,CAAC,EAAE,WAAW,EACrB,kBAAkB,CAAC,EAAE,YAAY;IAYnC,IAAI,CACF,QAAQ,EAAE,MAAM,GAAG,IAAI,EACvB,IAAI,EAAE,MAAM,GAAG,IAAI,EACnB,UAAU,CAAC,EAAE,eAAe,EAC5B,OAAO,CAAC,EAAE,WAAW,EACrB,kBAAkB,CAAC,EAAE,YAAY,GAChC,gBAAgB;IAwBnB,MAAM,CACJ,QAAQ,EAAE,MAAM,GAAG,IAAI,EACvB,MAAM,EAAE,MAAM,GAAG,IAAI,EACrB,UAAU,CAAC,EAAE,eAAe,EAC5B,OAAO,CAAC,EAAE,WAAW,EACrB,kBAAkB,CAAC,EAAE,YAAY,GAChC,gBAAgB;IAsBnB,QAAQ,CACN,MAAM,EAAE,EAAE,EACV,MAAM,CAAC,EAAE,UAAU,EACnB,OAAO,CAAC,EAAE,WAAW,EACrB,kBAAkB,CAAC,EAAE,YAAY,GAChC,gBAAgB;IAWnB,KAAK,CACH,OAAO,EAAE,EAAE,EACX,MAAM,CAAC,EAAE,WAAW,EACpB,OAAO,CAAC,EAAE,WAAW,EACrB,kBAAkB,CAAC,EAAE,YAAY,GAChC,gBAAgB;IAWnB,KAAK,CACH,EAAE,EAAE,MAAM,EACV,IAAI,EAAE,MAAM,GAAG,IAAI,EAAE,oCAAoC;IACzD,OAAO,CAAC,EAAE,WAAW,EACrB,kBAAkB,CAAC,EAAE,YAAY,GAChC,gBAAgB;IAyBnB,OAAO,CAAC,SAAS;IAqBjB;;;OAGG;IACH,OAAO,CAAC,OAAO;IAsCR,SAAS,CAAC,KAAK,EAAE,gBAAgB,GAAG,gBAAgB;CAkD5D"}
+{"version":3,"file":"index.d.ts","sourceRoot":"","sources":["../../../src/events/index.ts"],"names":[],"mappings":"AAAA,cAAc,cAAc,CAAA;AAE5B,OAAO,EAAE,EAAE,EAAE,IAAI,EAAE,MAAM,SAAS,CAAA;AAClC,OAAO,EACL,YAAY,EACZ,eAAe,EACf,gBAAgB,EAChB,WAAW,EAEX,UAAU,EACV,WAAW,EACZ,MAAM,cAAc,CAAA;AAKrB,UAAU,oBAAoB;IAC5B,eAAe,EAAE,MAAM,MAAM,CAAA;IAC7B,IAAI,CAAC,EAAE,IAAI,CAAA;CACZ;AAED;;;GAGG;AACH,qBAAa,YAAY;IACvB,eAAe,EAAE,oBAAoB,CAAC,iBAAiB,CAAC,CAAA;IACxD,IAAI,CAAC,EAAE,IAAI,CAAA;gBAEC,QAAQ,EAAE,oBAAoB;IAK1C,KAAK,CACH,KAAK,EAAE,MAAM,EACb,UAAU,CAAC,EAAE,eAAe,EAC5B,OAAO,CAAC,EAAE,WAAW,EACrB,kBAAkB,CAAC,EAAE,YAAY;IAYnC,IAAI,CACF,QAAQ,EAAE,MAAM,GAAG,IAAI,EACvB,IAAI,EAAE,MAAM,GAAG,IAAI,EACnB,UAAU,CAAC,EAAE,eAAe,EAC5B,OAAO,CAAC,EAAE,WAAW,EACrB,kBAAkB,CAAC,EAAE,YAAY,GAChC,gBAAgB;IAwBnB,MAAM,CACJ,QAAQ,EAAE,MAAM,GAAG,IAAI,EACvB,MAAM,EAAE,MAAM,GAAG,IAAI,EACrB,UAAU,CAAC,EAAE,eAAe,EAC5B,OAAO,CAAC,EAAE,WAAW,EACrB,kBAAkB,CAAC,EAAE,YAAY,GAChC,gBAAgB;IAsBnB,QAAQ,CACN,MAAM,EAAE,EAAE,EACV,MAAM,CAAC,EAAE,UAAU,EACnB,OAAO,CAAC,EAAE,WAAW,EACrB,kBAAkB,CAAC,EAAE,YAAY,GAChC,gBAAgB;IAWnB,KAAK,CACH,OAAO,EAAE,EAAE,EACX,MAAM,CAAC,EAAE,WAAW,EACpB,OAAO,CAAC,EAAE,WAAW,EACrB,kBAAkB,CAAC,EAAE,YAAY,GAChC,gBAAgB;IAWnB,KAAK,CACH,EAAE,EAAE,MAAM,EACV,IAAI,EAAE,MAAM,GAAG,IAAI,EAAE,oCAAoC;IACzD,OAAO,CAAC,EAAE,WAAW,EACrB,kBAAkB,CAAC,EAAE,YAAY,GAChC,gBAAgB;IAyBnB,OAAO,CAAC,SAAS;IAqBjB;;;OAGG;IACH,OAAO,CAAC,OAAO;IAuCR,SAAS,CAAC,KAAK,EAAE,gBAAgB,GAAG,gBAAgB;CAkD5D"}

dist/types/events/interfaces.d.ts

@@ -24,2 +24,8 @@ import { CoreContext } from '../context';
     traits?: Traits;
+    /**
+     * Override the messageId. Under normal circumstances, this is not recommended -- but neccessary for deduping events.
+     *
+     * **Currently, This option only works in `@segment/analytics-node`.**
+     */
+    messageId?: string;
     [key: string]: any;
@@ -26,0 +32,0 @@ }

dist/types/events/interfaces.d.ts.map

@@ -1,1 +0,1 @@
-{"version":3,"file":"interfaces.d.ts","sourceRoot":"","sources":["../../../src/events/interfaces.ts"],"names":[],"mappings":"AAAA,OAAO,EAAE,WAAW,EAAE,MAAM,YAAY,CAAA;AACxC,OAAO,EAAE,EAAE,EAAE,MAAM,SAAS,CAAA;AAC5B,OAAO,EAAE,YAAY,EAAE,MAAM,qBAAqB,CAAA;AAElD,MAAM,MAAM,QAAQ,CAAC,GAAG,SAAS,WAAW,GAAG,WAAW,IAAI,CAC5D,GAAG,EAAE,GAAG,KACL,OAAO,CAAC,OAAO,CAAC,GAAG,OAAO,CAAA;AAE/B,MAAM,MAAM,gBAAgB,GACxB,OAAO,GACP,MAAM,GACN,UAAU,GACV,OAAO,GACP,OAAO,GACP,QAAQ,CAAA;AAEZ,MAAM,MAAM,aAAa,GAAG,MAAM,GAAG,MAAM,GAAG,OAAO,GAAG,IAAI,CAAA;AAC5D,MAAM,MAAM,SAAS,GAAG,aAAa,GAAG,UAAU,GAAG,SAAS,CAAA;AAC9D,MAAM,MAAM,UAAU,GAAG;IAAE,CAAC,MAAM,EAAE,MAAM,GAAG,SAAS,CAAA;CAAE,CAAA;AACxD,MAAM,MAAM,SAAS,GAAG,SAAS,EAAE,CAAA;AAEnC,MAAM,MAAM,eAAe,GAAG,MAAM,CAAC,MAAM,EAAE,GAAG,CAAC,CAAA;AAEjD,MAAM,MAAM,YAAY,GAAG;IACzB,GAAG,CAAC,EAAE,OAAO,CAAA;IACb,CAAC,WAAW,EAAE,MAAM,GAAG,OAAO,GAAG,UAAU,GAAG,SAAS,CAAA;CACxD,CAAA;AAED,MAAM,WAAW,WAAW;IAC1B,YAAY,CAAC,EAAE,YAAY,CAAA;IAC3B,SAAS,CAAC,EAAE,SAAS,CAAA;IACrB,OAAO,CAAC,EAAE,gBAAgB,CAAA;IAC1B,WAAW,CAAC,EAAE,MAAM,CAAA;IACpB,MAAM,CAAC,EAAE,MAAM,CAAA;IACf,MAAM,CAAC,EAAE,MAAM,CAAA;IAEf,CAAC,GAAG,EAAE,MAAM,GAAG,GAAG,CAAA;CACnB;AAED;;;GAGG;AACH,MAAM,WAAW,gBAAgB;IAC/B;;OAEG;IACH,MAAM,CAAC,EAAE,OAAO,CAAA;IAEhB;;OAEG;IACH,EAAE,CAAC,EAAE,MAAM,CAAA;IAEX;;;OAGG;IACH,MAAM,CAAC,EAAE,MAAM,CAAA;IACf;;OAEG;IACH,QAAQ,CAAC,EAAE;QACT;;WAEG;QACH,IAAI,CAAC,EAAE,MAAM,CAAA;QACb;;WAEG;QACH,OAAO,CAAC,EAAE,MAAM,CAAA;QAChB;;WAEG;QACH,QAAQ,CAAC,EAAE,MAAM,CAAA;QACjB;;WAEG;QACH,SAAS,CAAC,EAAE,MAAM,CAAA;QAClB;;WAEG;QACH,MAAM,CAAC,EAAE,MAAM,CAAA;QACf;;WAEG;QACH,KAAK,CAAC,EAAE,MAAM,CAAA;KACf,CAAA;IAED;;OAEG;IACH,IAAI,CAAC,EAAE;QACL;;WAEG;QACH,IAAI,CAAC,EAAE,MAAM,CAAA;QACb;;WAEG;QACH,QAAQ,CAAC,EAAE,MAAM,CAAA;QACjB;;WAEG;QACH,MAAM,CAAC,EAAE,MAAM,CAAA;QACf;;WAEG;QACH,KAAK,CAAC,EAAE,MAAM,CAAA;QACd;;WAEG;QACH,GAAG,CAAC,EAAE,MAAM,CAAA;KACb,CAAA;IAED;;OAEG;IACH,SAAS,CAAC,EAAE,MAAM,CAAA;IAElB;;OAEG;IACH,aAAa,CAAC,EAAE;QACd,MAAM,CAAC,EAAE;YACP,KAAK,EAAE,MAAM,CAAA;YACb,OAAO,EAAE,MAAM,CAAA;SAChB,EAAE,CAAA;QACH,MAAM,CAAC,EAAE,OAAO,CAAA;QAChB,QAAQ,CAAC,EAAE,MAAM,CAAA;QACjB,YAAY,CAAC,EAAE,MAAM,CAAA;QACrB,OAAO,CAAC,EAAE,MAAM,CAAA;QAChB,KAAK,CAAC,EAAE,MAAM,CAAA;QACd,eAAe,CAAC,EAAE,MAAM,CAAA;QACxB,+CAA+C;QAC/C,aAAa,CAAC,EAAE,MAAM,CAAA;QACtB,eAAe,CAAC,EAAE;YAChB,KAAK,EAAE,MAAM,CAAA;YACb,OAAO,EAAE,MAAM,CAAA;SAChB,EAAE,CAAA;QACH,KAAK,CAAC,EAAE,OAAO,CAAA;KAChB,CAAA;IAED;;;;;;OAMG;IACH,OAAO,CAAC,EAAE;QACR;;WAEG;QACH,IAAI,EAAE,MAAM,CAAA;QACZ;;WAEG;QACH,OAAO,EAAE,MAAM,CAAA;KAChB,CAAA;IAED;;;;OAIG;IACH,MAAM,CAAC,EAAE,MAAM,CAAA;IAEf;;OAEG;IACH,QAAQ,CAAC,EAAE,QAAQ,CAAA;IAEnB;;OAEG;IACH,QAAQ,CAAC,EAAE;QACT,IAAI,CAAC,EAAE,MAAM,CAAA;QACb,IAAI,CAAC,EAAE,MAAM,CAAA;QACb,GAAG,CAAC,EAAE,MAAM,CAAA;QACZ,IAAI,CAAC,EAAE,MAAM,CAAA;QAEb,EAAE,CAAC,EAAE,MAAM,CAAA;QACX,IAAI,CAAC,EAAE,MAAM,CAAA;QACb,IAAI,CAAC,EAAE,MAAM,CAAA;KACd,CAAA;IAED,GAAG,CAAC,EAAE;QAEJ,EAAE,EAAE,MAAM,CAAA;KACX,CAAA;IAED,CAAC,GAAG,EAAE,MAAM,GAAG,GAAG,CAAA;CACnB;AAED,MAAM,WAAW,gBAAgB;IAC/B,SAAS,CAAC,EAAE,MAAM,CAAA;IAClB,IAAI,EAAE,gBAAgB,CAAA;IAGtB,QAAQ,CAAC,EAAE,MAAM,CAAA;IACjB,IAAI,CAAC,EAAE,MAAM,CAAA;IAEb,UAAU,CAAC,EAAE,eAAe,CAAA;IAE5B,MAAM,CAAC,EAAE,MAAM,CAAA;IAEf,YAAY,CAAC,EAAE,YAAY,CAAA;IAC3B,OAAO,CAAC,EAAE,gBAAgB,CAAA;IAC1B,OAAO,CAAC,EAAE,WAAW,CAAA;IAErB,MAAM,CAAC,EAAE,EAAE,CAAA;IACX,WAAW,CAAC,EAAE,EAAE,CAAA;IAChB,OAAO,CAAC,EAAE,EAAE,CAAA;IACZ,UAAU,CAAC,EAAE,EAAE,CAAA;IAEf,KAAK,CAAC,EAAE,MAAM,CAAA;IAEd,QAAQ,CAAC,EAAE,MAAM,CAAA;IAEjB,MAAM,CAAC,EAAE,IAAI,CAAA;IAEb,SAAS,CAAC,EAAE,oBAAoB,CAAA;IAEhC,SAAS,CAAC,EAAE,SAAS,CAAA;CACtB;AAED,MAAM,WAAW,oBAAoB;IACnC,qBAAqB,CAAC,EAAE,OAAO,EAAE,CAAA;IACjC,OAAO,CAAC,EAAE,MAAM,EAAE,CAAA;IAClB,SAAS,CAAC,EAAE,MAAM,EAAE,CAAA;IACpB,WAAW,CAAC,EAAE,MAAM,CAAA;IACpB,gBAAgB,CAAC,EAAE,MAAM,EAAE,CAAA;IAC3B,kBAAkB,CAAC,EAAE,MAAM,EAAE,CAAA;IAC7B,UAAU,CAAC,EAAE,MAAM,EAAE,CAAA;CACtB;AAED,MAAM,MAAM,SAAS,GAAG,IAAI,GAAG,MAAM,CAAA;AAErC;;GAEG;AACH,MAAM,WAAW,IAAI;IACnB,KAAK,CAAC,EAAE,SAAS,CAAA;IACjB,QAAQ,CAAC,EAAE,SAAS,CAAA;IACpB,KAAK,CAAC,EAAE,SAAS,CAAA;CAClB;AAED,MAAM,WAAW,SAAS;IACxB,CAAC,GAAG,EAAE,MAAM,GAAG,SAAS,GAAG,SAAS,CAAA;IAEpC,SAAS,CAAC,EAAE,SAAS,CAAA;CACtB;AAED,MAAM,WAAW,SAAS;IACxB;;OAEG;IACH,OAAO,EAAE,OAAO,CAAA;IAChB;;OAEG;IACH,YAAY,CAAC,EAAE;QACb,CAAC,GAAG,EAAE,MAAM,GAAG,OAAO,CAAA;KACvB,CAAA;CACF;AAED,KAAK,IAAI,GAAG,MAAM,GAAG,MAAM,CAAA;AAC3B,KAAK,WAAW,GAAG,MAAM,GAAG,MAAM,CAAA;AAElC;;;;GAIG;AACH,KAAK,eAAe,GAAG,YAAY,CAAC;IAClC;;OAEG;IACH,OAAO,CAAC,EAAE,cAAc,CAAC,SAAS,CAAC,CAAA;IAEnC;;OAEG;IACH,MAAM,CAAC,EAAE,cAAc,CAAC,QAAQ,CAAC,CAAA;IAEjC;;OAEG;IACH,SAAS,CAAC,EAAE,cAAc,CAAC,WAAW,CAAC,CAAA;IAEvC;;OAEG;IACH,WAAW,CAAC,EAAE,cAAc,CAAC,aAAa,CAAC,CAAA;IAC3C;;OAEG;IACH,KAAK,CAAC,EAAE,cAAc,CAAC,OAAO,CAAC,CAAA;IAC/B;;OAEG;IACH,SAAS,CAAC,EAAE,MAAM,GAAG,MAAM,CAAA;IAE3B;;OAEG;IACH,EAAE,CAAC,EAAE,cAAc,CAAC,IAAI,CAAC,CAAA;IAEzB;;OAEG;IACH,QAAQ,CAAC,EAAE,cAAc,CAAC,UAAU,CAAC,CAAA;IAErC;;OAEG;IACH,IAAI,CAAC,EAAE,cAAc,CAAC,MAAM,CAAC,CAAA;IAE7B;;OAEG;IACH,KAAK,CAAC,EAAE,cAAc,CAAC,OAAO,CAAC,CAAA;IAE/B;;OAEG;IACH,OAAO,CAAC,EAAE,cAAc,CAAC,SAAS,CAAC,CAAA;IAEnC;;OAEG;IACH,IAAI,CAAC,EAAE,cAAc,CAAC,MAAM,CAAC,CAAA;CAC9B,CAAC,CAAA;AAEF;;;;GAIG;AACH,KAAK,cAAc,GAAG,YAAY,CAAC;IACjC;;OAEG;IACH,EAAE,CAAC,EAAE,IAAI,CAAA;IAET;;OAEG;IACH,QAAQ,CAAC,EAAE,MAAM,CAAA;IAEjB;;OAEG;IACH,SAAS,CAAC,EAAE,MAAM,CAAA;IAElB;;OAEG;IACH,QAAQ,CAAC,EAAE,MAAM,CAAA;IAEjB;;OAEG;IACH,IAAI,CAAC,EAAE,MAAM,CAAA;IAEb;;OAEG;IACH,KAAK,CAAC,EAAE,WAAW,CAAA;IAEnB;;;OAGG;IACH,KAAK,CAAC,EAAE,MAAM,CAAA;IAEd;;OAEG;IACH,QAAQ,CAAC,EAAE,MAAM,CAAA;IAEjB;;OAEG;IACH,OAAO,CAAC,EAAE,MAAM,CAAA;IAEhB;;OAEG;IACH,OAAO,CAAC,EAAE;QACR,IAAI,CAAC,EAAE,MAAM,CAAA;QACb,OAAO,CAAC,EAAE,MAAM,CAAA;QAChB,UAAU,CAAC,EAAE,MAAM,CAAA;QACnB,KAAK,CAAC,EAAE,MAAM,CAAA;QACd,MAAM,CAAC,EAAE,MAAM,CAAA;KAChB,CAAA;IACD;;OAEG;IACH,GAAG,CAAC,EAAE,MAAM,CAAA;IAEZ;;OAEG;IACH,MAAM,CAAC,EAAE,MAAM,CAAA;IAEf;;OAEG;IACH,QAAQ,CAAC,EAAE,SAAS,CAAA;IAEpB;;OAEG;IACH,OAAO,CAAC,EAAE;QACR,IAAI,CAAC,EAAE,MAAM,CAAA;QACb,EAAE,CAAC,EAAE,IAAI,CAAA;QACT,QAAQ,CAAC,EAAE,cAAc,CAAC,UAAU,CAAC,CAAA;QACrC,cAAc,CAAC,EAAE,MAAM,CAAA;QACvB,IAAI,CAAC,EAAE,cAAc,CAAC,MAAM,CAAC,CAAA;KAC9B,CAAA;IAED;;;;OAIG;IACH,IAAI,CAAC,EAAE,MAAM,CAAA;IAEb;;OAEG;IACH,SAAS,CAAC,EAAE,SAAS,CAAA;IAErB;;OAEG;IACH,WAAW,CAAC,EAAE,MAAM,CAAA;IAEpB;;OAEG;IACH,KAAK,CAAC,EAAE,MAAM,CAAA;IAEd;;OAEG;IACH,MAAM,CAAC,EAAE,MAAM,CAAA;CAChB,CAAC,CAAA;AAEF;;;;GAIG;AACH,MAAM,MAAM,WAAW,GAAG,eAAe,GAAG;IAC1C,CAAC,WAAW,EAAE,MAAM,GAAG,GAAG,CAAA;CAC3B,CAAA;AAED;;;;GAIG;AACH,MAAM,MAAM,UAAU,GAAG,cAAc,GAAG;IACxC,CAAC,WAAW,EAAE,MAAM,GAAG,GAAG,CAAA;CAC3B,CAAA;AAED;;GAEG;AACH,MAAM,MAAM,MAAM,GAAG,UAAU,GAAG,WAAW,CAAA;AAE7C,MAAM,MAAM,QAAQ,GAAG;IACrB,IAAI,EAAE,MAAM,CAAA;IACZ,MAAM,EAAE,MAAM,CAAA;IACd,MAAM,EAAE,MAAM,CAAA;IACd,CAAC,GAAG,EAAE,MAAM,GAAG,MAAM,CAAA;CACtB,CAAA"}
+{"version":3,"file":"interfaces.d.ts","sourceRoot":"","sources":["../../../src/events/interfaces.ts"],"names":[],"mappings":"AAAA,OAAO,EAAE,WAAW,EAAE,MAAM,YAAY,CAAA;AACxC,OAAO,EAAE,EAAE,EAAE,MAAM,SAAS,CAAA;AAC5B,OAAO,EAAE,YAAY,EAAE,MAAM,qBAAqB,CAAA;AAElD,MAAM,MAAM,QAAQ,CAAC,GAAG,SAAS,WAAW,GAAG,WAAW,IAAI,CAC5D,GAAG,EAAE,GAAG,KACL,OAAO,CAAC,OAAO,CAAC,GAAG,OAAO,CAAA;AAE/B,MAAM,MAAM,gBAAgB,GACxB,OAAO,GACP,MAAM,GACN,UAAU,GACV,OAAO,GACP,OAAO,GACP,QAAQ,CAAA;AAEZ,MAAM,MAAM,aAAa,GAAG,MAAM,GAAG,MAAM,GAAG,OAAO,GAAG,IAAI,CAAA;AAC5D,MAAM,MAAM,SAAS,GAAG,aAAa,GAAG,UAAU,GAAG,SAAS,CAAA;AAC9D,MAAM,MAAM,UAAU,GAAG;IAAE,CAAC,MAAM,EAAE,MAAM,GAAG,SAAS,CAAA;CAAE,CAAA;AACxD,MAAM,MAAM,SAAS,GAAG,SAAS,EAAE,CAAA;AAEnC,MAAM,MAAM,eAAe,GAAG,MAAM,CAAC,MAAM,EAAE,GAAG,CAAC,CAAA;AAEjD,MAAM,MAAM,YAAY,GAAG;IACzB,GAAG,CAAC,EAAE,OAAO,CAAA;IACb,CAAC,WAAW,EAAE,MAAM,GAAG,OAAO,GAAG,UAAU,GAAG,SAAS,CAAA;CACxD,CAAA;AAED,MAAM,WAAW,WAAW;IAC1B,YAAY,CAAC,EAAE,YAAY,CAAA;IAC3B,SAAS,CAAC,EAAE,SAAS,CAAA;IACrB,OAAO,CAAC,EAAE,gBAAgB,CAAA;IAC1B,WAAW,CAAC,EAAE,MAAM,CAAA;IACpB,MAAM,CAAC,EAAE,MAAM,CAAA;IACf,MAAM,CAAC,EAAE,MAAM,CAAA;IACf;;;;OAIG;IACH,SAAS,CAAC,EAAE,MAAM,CAAA;IAElB,CAAC,GAAG,EAAE,MAAM,GAAG,GAAG,CAAA;CACnB;AAED;;;GAGG;AACH,MAAM,WAAW,gBAAgB;IAC/B;;OAEG;IACH,MAAM,CAAC,EAAE,OAAO,CAAA;IAEhB;;OAEG;IACH,EAAE,CAAC,EAAE,MAAM,CAAA;IAEX;;;OAGG;IACH,MAAM,CAAC,EAAE,MAAM,CAAA;IACf;;OAEG;IACH,QAAQ,CAAC,EAAE;QACT;;WAEG;QACH,IAAI,CAAC,EAAE,MAAM,CAAA;QACb;;WAEG;QACH,OAAO,CAAC,EAAE,MAAM,CAAA;QAChB;;WAEG;QACH,QAAQ,CAAC,EAAE,MAAM,CAAA;QACjB;;WAEG;QACH,SAAS,CAAC,EAAE,MAAM,CAAA;QAClB;;WAEG;QACH,MAAM,CAAC,EAAE,MAAM,CAAA;QACf;;WAEG;QACH,KAAK,CAAC,EAAE,MAAM,CAAA;KACf,CAAA;IAED;;OAEG;IACH,IAAI,CAAC,EAAE;QACL;;WAEG;QACH,IAAI,CAAC,EAAE,MAAM,CAAA;QACb;;WAEG;QACH,QAAQ,CAAC,EAAE,MAAM,CAAA;QACjB;;WAEG;QACH,MAAM,CAAC,EAAE,MAAM,CAAA;QACf;;WAEG;QACH,KAAK,CAAC,EAAE,MAAM,CAAA;QACd;;WAEG;QACH,GAAG,CAAC,EAAE,MAAM,CAAA;KACb,CAAA;IAED;;OAEG;IACH,SAAS,CAAC,EAAE,MAAM,CAAA;IAElB;;OAEG;IACH,aAAa,CAAC,EAAE;QACd,MAAM,CAAC,EAAE;YACP,KAAK,EAAE,MAAM,CAAA;YACb,OAAO,EAAE,MAAM,CAAA;SAChB,EAAE,CAAA;QACH,MAAM,CAAC,EAAE,OAAO,CAAA;QAChB,QAAQ,CAAC,EAAE,MAAM,CAAA;QACjB,YAAY,CAAC,EAAE,MAAM,CAAA;QACrB,OAAO,CAAC,EAAE,MAAM,CAAA;QAChB,KAAK,CAAC,EAAE,MAAM,CAAA;QACd,eAAe,CAAC,EAAE,MAAM,CAAA;QACxB,+CAA+C;QAC/C,aAAa,CAAC,EAAE,MAAM,CAAA;QACtB,eAAe,CAAC,EAAE;YAChB,KAAK,EAAE,MAAM,CAAA;YACb,OAAO,EAAE,MAAM,CAAA;SAChB,EAAE,CAAA;QACH,KAAK,CAAC,EAAE,OAAO,CAAA;KAChB,CAAA;IAED;;;;;;OAMG;IACH,OAAO,CAAC,EAAE;QACR;;WAEG;QACH,IAAI,EAAE,MAAM,CAAA;QACZ;;WAEG;QACH,OAAO,EAAE,MAAM,CAAA;KAChB,CAAA;IAED;;;;OAIG;IACH,MAAM,CAAC,EAAE,MAAM,CAAA;IAEf;;OAEG;IACH,QAAQ,CAAC,EAAE,QAAQ,CAAA;IAEnB;;OAEG;IACH,QAAQ,CAAC,EAAE;QACT,IAAI,CAAC,EAAE,MAAM,CAAA;QACb,IAAI,CAAC,EAAE,MAAM,CAAA;QACb,GAAG,CAAC,EAAE,MAAM,CAAA;QACZ,IAAI,CAAC,EAAE,MAAM,CAAA;QAEb,EAAE,CAAC,EAAE,MAAM,CAAA;QACX,IAAI,CAAC,EAAE,MAAM,CAAA;QACb,IAAI,CAAC,EAAE,MAAM,CAAA;KACd,CAAA;IAED,GAAG,CAAC,EAAE;QAEJ,EAAE,EAAE,MAAM,CAAA;KACX,CAAA;IAED,CAAC,GAAG,EAAE,MAAM,GAAG,GAAG,CAAA;CACnB;AAED,MAAM,WAAW,gBAAgB;IAC/B,SAAS,CAAC,EAAE,MAAM,CAAA;IAClB,IAAI,EAAE,gBAAgB,CAAA;IAGtB,QAAQ,CAAC,EAAE,MAAM,CAAA;IACjB,IAAI,CAAC,EAAE,MAAM,CAAA;IAEb,UAAU,CAAC,EAAE,eAAe,CAAA;IAE5B,MAAM,CAAC,EAAE,MAAM,CAAA;IAEf,YAAY,CAAC,EAAE,YAAY,CAAA;IAC3B,OAAO,CAAC,EAAE,gBAAgB,CAAA;IAC1B,OAAO,CAAC,EAAE,WAAW,CAAA;IAErB,MAAM,CAAC,EAAE,EAAE,CAAA;IACX,WAAW,CAAC,EAAE,EAAE,CAAA;IAChB,OAAO,CAAC,EAAE,EAAE,CAAA;IACZ,UAAU,CAAC,EAAE,EAAE,CAAA;IAEf,KAAK,CAAC,EAAE,MAAM,CAAA;IAEd,QAAQ,CAAC,EAAE,MAAM,CAAA;IAEjB,MAAM,CAAC,EAAE,IAAI,CAAA;IAEb,SAAS,CAAC,EAAE,oBAAoB,CAAA;IAEhC,SAAS,CAAC,EAAE,SAAS,CAAA;CACtB;AAED,MAAM,WAAW,oBAAoB;IACnC,qBAAqB,CAAC,EAAE,OAAO,EAAE,CAAA;IACjC,OAAO,CAAC,EAAE,MAAM,EAAE,CAAA;IAClB,SAAS,CAAC,EAAE,MAAM,EAAE,CAAA;IACpB,WAAW,CAAC,EAAE,MAAM,CAAA;IACpB,gBAAgB,CAAC,EAAE,MAAM,EAAE,CAAA;IAC3B,kBAAkB,CAAC,EAAE,MAAM,EAAE,CAAA;IAC7B,UAAU,CAAC,EAAE,MAAM,EAAE,CAAA;CACtB;AAED,MAAM,MAAM,SAAS,GAAG,IAAI,GAAG,MAAM,CAAA;AAErC;;GAEG;AACH,MAAM,WAAW,IAAI;IACnB,KAAK,CAAC,EAAE,SAAS,CAAA;IACjB,QAAQ,CAAC,EAAE,SAAS,CAAA;IACpB,KAAK,CAAC,EAAE,SAAS,CAAA;CAClB;AAED,MAAM,WAAW,SAAS;IACxB,CAAC,GAAG,EAAE,MAAM,GAAG,SAAS,GAAG,SAAS,CAAA;IAEpC,SAAS,CAAC,EAAE,SAAS,CAAA;CACtB;AAED,MAAM,WAAW,SAAS;IACxB;;OAEG;IACH,OAAO,EAAE,OAAO,CAAA;IAChB;;OAEG;IACH,YAAY,CAAC,EAAE;QACb,CAAC,GAAG,EAAE,MAAM,GAAG,OAAO,CAAA;KACvB,CAAA;CACF;AAED,KAAK,IAAI,GAAG,MAAM,GAAG,MAAM,CAAA;AAC3B,KAAK,WAAW,GAAG,MAAM,GAAG,MAAM,CAAA;AAElC;;;;GAIG;AACH,KAAK,eAAe,GAAG,YAAY,CAAC;IAClC;;OAEG;IACH,OAAO,CAAC,EAAE,cAAc,CAAC,SAAS,CAAC,CAAA;IAEnC;;OAEG;IACH,MAAM,CAAC,EAAE,cAAc,CAAC,QAAQ,CAAC,CAAA;IAEjC;;OAEG;IACH,SAAS,CAAC,EAAE,cAAc,CAAC,WAAW,CAAC,CAAA;IAEvC;;OAEG;IACH,WAAW,CAAC,EAAE,cAAc,CAAC,aAAa,CAAC,CAAA;IAC3C;;OAEG;IACH,KAAK,CAAC,EAAE,cAAc,CAAC,OAAO,CAAC,CAAA;IAC/B;;OAEG;IACH,SAAS,CAAC,EAAE,MAAM,GAAG,MAAM,CAAA;IAE3B;;OAEG;IACH,EAAE,CAAC,EAAE,cAAc,CAAC,IAAI,CAAC,CAAA;IAEzB;;OAEG;IACH,QAAQ,CAAC,EAAE,cAAc,CAAC,UAAU,CAAC,CAAA;IAErC;;OAEG;IACH,IAAI,CAAC,EAAE,cAAc,CAAC,MAAM,CAAC,CAAA;IAE7B;;OAEG;IACH,KAAK,CAAC,EAAE,cAAc,CAAC,OAAO,CAAC,CAAA;IAE/B;;OAEG;IACH,OAAO,CAAC,EAAE,cAAc,CAAC,SAAS,CAAC,CAAA;IAEnC;;OAEG;IACH,IAAI,CAAC,EAAE,cAAc,CAAC,MAAM,CAAC,CAAA;CAC9B,CAAC,CAAA;AAEF;;;;GAIG;AACH,KAAK,cAAc,GAAG,YAAY,CAAC;IACjC;;OAEG;IACH,EAAE,CAAC,EAAE,IAAI,CAAA;IAET;;OAEG;IACH,QAAQ,CAAC,EAAE,MAAM,CAAA;IAEjB;;OAEG;IACH,SAAS,CAAC,EAAE,MAAM,CAAA;IAElB;;OAEG;IACH,QAAQ,CAAC,EAAE,MAAM,CAAA;IAEjB;;OAEG;IACH,IAAI,CAAC,EAAE,MAAM,CAAA;IAEb;;OAEG;IACH,KAAK,CAAC,EAAE,WAAW,CAAA;IAEnB;;;OAGG;IACH,KAAK,CAAC,EAAE,MAAM,CAAA;IAEd;;OAEG;IACH,QAAQ,CAAC,EAAE,MAAM,CAAA;IAEjB;;OAEG;IACH,OAAO,CAAC,EAAE,MAAM,CAAA;IAEhB;;OAEG;IACH,OAAO,CAAC,EAAE;QACR,IAAI,CAAC,EAAE,MAAM,CAAA;QACb,OAAO,CAAC,EAAE,MAAM,CAAA;QAChB,UAAU,CAAC,EAAE,MAAM,CAAA;QACnB,KAAK,CAAC,EAAE,MAAM,CAAA;QACd,MAAM,CAAC,EAAE,MAAM,CAAA;KAChB,CAAA;IACD;;OAEG;IACH,GAAG,CAAC,EAAE,MAAM,CAAA;IAEZ;;OAEG;IACH,MAAM,CAAC,EAAE,MAAM,CAAA;IAEf;;OAEG;IACH,QAAQ,CAAC,EAAE,SAAS,CAAA;IAEpB;;OAEG;IACH,OAAO,CAAC,EAAE;QACR,IAAI,CAAC,EAAE,MAAM,CAAA;QACb,EAAE,CAAC,EAAE,IAAI,CAAA;QACT,QAAQ,CAAC,EAAE,cAAc,CAAC,UAAU,CAAC,CAAA;QACrC,cAAc,CAAC,EAAE,MAAM,CAAA;QACvB,IAAI,CAAC,EAAE,cAAc,CAAC,MAAM,CAAC,CAAA;KAC9B,CAAA;IAED;;;;OAIG;IACH,IAAI,CAAC,EAAE,MAAM,CAAA;IAEb;;OAEG;IACH,SAAS,CAAC,EAAE,SAAS,CAAA;IAErB;;OAEG;IACH,WAAW,CAAC,EAAE,MAAM,CAAA;IAEpB;;OAEG;IACH,KAAK,CAAC,EAAE,MAAM,CAAA;IAEd;;OAEG;IACH,MAAM,CAAC,EAAE,MAAM,CAAA;CAChB,CAAC,CAAA;AAEF;;;;GAIG;AACH,MAAM,MAAM,WAAW,GAAG,eAAe,GAAG;IAC1C,CAAC,WAAW,EAAE,MAAM,GAAG,GAAG,CAAA;CAC3B,CAAA;AAED;;;;GAIG;AACH,MAAM,MAAM,UAAU,GAAG,cAAc,GAAG;IACxC,CAAC,WAAW,EAAE,MAAM,GAAG,GAAG,CAAA;CAC3B,CAAA;AAED;;GAEG;AACH,MAAM,MAAM,MAAM,GAAG,UAAU,GAAG,WAAW,CAAA;AAE7C,MAAM,MAAM,QAAQ,GAAG;IACrB,IAAI,EAAE,MAAM,CAAA;IACZ,MAAM,EAAE,MAAM,CAAA;IACd,MAAM,EAAE,MAAM,CAAA;IACd,CAAC,GAAG,EAAE,MAAM,GAAG,MAAM,CAAA;CACtB,CAAA"}

dist/types/queue/event-queue.d.ts

@@ -14,2 +14,3 @@ import { CoreAnalytics } from '../analytics';
     flush: [ctx: Ctx, delivered: boolean];
+    initialization_failure: [CorePlugin<Ctx>];
 };
@@ -16,0 +17,0 @@ export declare abstract class CoreEventQueue<Ctx extends CoreContext = CoreContext, Plugin extends CorePlugin<Ctx> = CorePlugin<Ctx>> extends Emitter<EventQueueEmitterContract<Ctx>> {

dist/types/queue/event-queue.d.ts.map

@@ -1,1 +0,1 @@
-{"version":3,"file":"event-queue.d.ts","sourceRoot":"","sources":["../../../src/queue/event-queue.ts"],"names":[],"mappings":"AAAA,OAAO,EAAE,aAAa,EAAE,MAAM,cAAc,CAAA;AAE5C,OAAO,EAAyB,aAAa,EAAE,MAAM,mBAAmB,CAAA;AAExE,OAAO,EAAE,WAAW,EAAE,kBAAkB,EAAE,MAAM,YAAY,CAAA;AAC5D,OAAO,EAAE,OAAO,EAAE,MAAM,kCAAkC,CAAA;AAE1D,OAAO,EAAE,UAAU,EAAE,MAAM,YAAY,CAAA;AACvC,OAAO,EAAmB,SAAS,EAAE,MAAM,oBAAoB,CAAA;AAG/D,MAAM,MAAM,yBAAyB,CAAC,GAAG,SAAS,WAAW,IAAI;IAC/D,iBAAiB,EAAE,CAAC,GAAG,EAAE,GAAG,CAAC,CAAA;IAC7B,gBAAgB,EAAE,CAAC,GAAG,EAAE,GAAG,EAAE,MAAM,EAAE,UAAU,CAAC,GAAG,CAAC,CAAC,CAAA;IACrD,gBAAgB,EAAE,CAAC,GAAG,EAAE,GAAG,CAAC,CAAA;IAC5B,cAAc,EAAE,CAAC,GAAG,EAAE,GAAG,CAAC,CAAA;IAC1B,gBAAgB,EAAE,CAAC,GAAG,EAAE,GAAG,EAAE,GAAG,EAAE,GAAG,GAAG,KAAK,GAAG,kBAAkB,CAAC,CAAA;IACnE,KAAK,EAAE,CAAC,GAAG,EAAE,GAAG,EAAE,SAAS,EAAE,OAAO,CAAC,CAAA;CACtC,CAAA;AAED,8BAAsB,cAAc,CAClC,GAAG,SAAS,WAAW,GAAG,WAAW,EACrC,MAAM,SAAS,UAAU,CAAC,GAAG,CAAC,GAAG,UAAU,CAAC,GAAG,CAAC,CAChD,SAAQ,OAAO,CAAC,yBAAyB,CAAC,GAAG,CAAC,CAAC;IAC/C;;;;;;OAMG;IACH,aAAa,EAAE,SAAS,CAAoB;IAC5C,KAAK,EAAE,aAAa,CAAC,GAAG,CAAC,CAAA;IACzB,OAAO,EAAE,MAAM,EAAE,CAAK;IACtB,qBAAqB,EAAE,MAAM,EAAE,CAAK;IACpC,OAAO,CAAC,QAAQ,CAAQ;gBAEZ,aAAa,EAAE,aAAa,CAAC,GAAG,CAAC;IASvC,QAAQ,CACZ,GAAG,EAAE,GAAG,EACR,MAAM,EAAE,MAAM,EACd,QAAQ,EAAE,aAAa,GACtB,OAAO,CAAC,IAAI,CAAC;IAsBV,UAAU,CACd,GAAG,EAAE,GAAG,EACR,MAAM,EAAE,UAAU,CAAC,GAAG,CAAC,EACvB,QAAQ,EAAE,aAAa,GACtB,OAAO,CAAC,IAAI,CAAC;IAeV,QAAQ,CAAC,GAAG,EAAE,GAAG,GAAG,OAAO,CAAC,GAAG,CAAC;YAUxB,mBAAmB;IAiB3B,cAAc,CAAC,GAAG,EAAE,GAAG,GAAG,OAAO,CAAC,GAAG,CAAC;IAkB5C,OAAO,IAAI,OAAO;IAIlB,OAAO,CAAC,aAAa;YAqBP,OAAO;IAoBrB,OAAO,CAAC,WAAW;IASb,KAAK,IAAI,OAAO,CAAC,GAAG,EAAE,CAAC;IA6B7B,OAAO,CAAC,OAAO;IAMf,OAAO,CAAC,mBAAmB;YAqCb,QAAQ;CAuDvB"}
+{"version":3,"file":"event-queue.d.ts","sourceRoot":"","sources":["../../../src/queue/event-queue.ts"],"names":[],"mappings":"AAAA,OAAO,EAAE,aAAa,EAAE,MAAM,cAAc,CAAA;AAE5C,OAAO,EAAyB,aAAa,EAAE,MAAM,mBAAmB,CAAA;AAExE,OAAO,EAAE,WAAW,EAAE,kBAAkB,EAAE,MAAM,YAAY,CAAA;AAC5D,OAAO,EAAE,OAAO,EAAE,MAAM,kCAAkC,CAAA;AAE1D,OAAO,EAAE,UAAU,EAAE,MAAM,YAAY,CAAA;AACvC,OAAO,EAAmB,SAAS,EAAE,MAAM,oBAAoB,CAAA;AAG/D,MAAM,MAAM,yBAAyB,CAAC,GAAG,SAAS,WAAW,IAAI;IAC/D,iBAAiB,EAAE,CAAC,GAAG,EAAE,GAAG,CAAC,CAAA;IAC7B,gBAAgB,EAAE,CAAC,GAAG,EAAE,GAAG,EAAE,MAAM,EAAE,UAAU,CAAC,GAAG,CAAC,CAAC,CAAA;IACrD,gBAAgB,EAAE,CAAC,GAAG,EAAE,GAAG,CAAC,CAAA;IAC5B,cAAc,EAAE,CAAC,GAAG,EAAE,GAAG,CAAC,CAAA;IAC1B,gBAAgB,EAAE,CAAC,GAAG,EAAE,GAAG,EAAE,GAAG,EAAE,GAAG,GAAG,KAAK,GAAG,kBAAkB,CAAC,CAAA;IACnE,KAAK,EAAE,CAAC,GAAG,EAAE,GAAG,EAAE,SAAS,EAAE,OAAO,CAAC,CAAA;IACrC,sBAAsB,EAAE,CAAC,UAAU,CAAC,GAAG,CAAC,CAAC,CAAA;CAC1C,CAAA;AAED,8BAAsB,cAAc,CAClC,GAAG,SAAS,WAAW,GAAG,WAAW,EACrC,MAAM,SAAS,UAAU,CAAC,GAAG,CAAC,GAAG,UAAU,CAAC,GAAG,CAAC,CAChD,SAAQ,OAAO,CAAC,yBAAyB,CAAC,GAAG,CAAC,CAAC;IAC/C;;;;;;OAMG;IACH,aAAa,EAAE,SAAS,CAAoB;IAC5C,KAAK,EAAE,aAAa,CAAC,GAAG,CAAC,CAAA;IACzB,OAAO,EAAE,MAAM,EAAE,CAAK;IACtB,qBAAqB,EAAE,MAAM,EAAE,CAAK;IACpC,OAAO,CAAC,QAAQ,CAAQ;gBAEZ,aAAa,EAAE,aAAa,CAAC,GAAG,CAAC;IASvC,QAAQ,CACZ,GAAG,EAAE,GAAG,EACR,MAAM,EAAE,MAAM,EACd,QAAQ,EAAE,aAAa,GACtB,OAAO,CAAC,IAAI,CAAC;IAqBV,UAAU,CACd,GAAG,EAAE,GAAG,EACR,MAAM,EAAE,UAAU,CAAC,GAAG,CAAC,EACvB,QAAQ,EAAE,aAAa,GACtB,OAAO,CAAC,IAAI,CAAC;IAeV,QAAQ,CAAC,GAAG,EAAE,GAAG,GAAG,OAAO,CAAC,GAAG,CAAC;YAUxB,mBAAmB;IAiB3B,cAAc,CAAC,GAAG,EAAE,GAAG,GAAG,OAAO,CAAC,GAAG,CAAC;IAkB5C,OAAO,IAAI,OAAO;IAIlB,OAAO,CAAC,aAAa;YAqBP,OAAO;IAoBrB,OAAO,CAAC,WAAW;IASb,KAAK,IAAI,OAAO,CAAC,GAAG,EAAE,CAAC;IA6B7B,OAAO,CAAC,OAAO;IAMf,OAAO,CAAC,mBAAmB;YAqCb,QAAQ;CAuDvB"}

dist/types/validation/assertions.d.ts

@@ -8,3 +8,4 @@ import { CoreSegmentEvent } from '../events';
 export declare function assertTraits(event: CoreSegmentEvent): void;
+export declare function assertMessageId(event: CoreSegmentEvent): void;
 export declare function validateEvent(event?: CoreSegmentEvent | null): void;
 //# sourceMappingURL=assertions.d.ts.map

dist/types/validation/assertions.d.ts.map

@@ -1,1 +0,1 @@
-{"version":3,"file":"assertions.d.ts","sourceRoot":"","sources":["../../../src/validation/assertions.ts"],"names":[],"mappings":"AAAA,OAAO,EAAE,gBAAgB,EAAE,MAAM,WAAW,CAAA;AAQ5C,wBAAgB,kBAAkB,CAAC,KAAK,EAAE,gBAAgB,GAAG,IAAI,CAYhE;AAED,wBAAgB,iBAAiB,CAC/B,KAAK,CAAC,EAAE,gBAAgB,GAAG,IAAI,GAC9B,OAAO,CAAC,KAAK,IAAI,gBAAgB,CAOnC;AAED,wBAAgB,eAAe,CAAC,KAAK,EAAE,gBAAgB,GAAG,IAAI,CAI7D;AAED,wBAAgB,oBAAoB,CAAC,KAAK,EAAE,gBAAgB,GAAG,IAAI,CAIlE;AAED,wBAAgB,0BAA0B,CAAC,KAAK,EAAE,gBAAgB,GAAG,IAAI,CAIxE;AAED,wBAAgB,YAAY,CAAC,KAAK,EAAE,gBAAgB,GAAG,IAAI,CAI1D;AAED,wBAAgB,aAAa,CAAC,KAAK,CAAC,EAAE,gBAAgB,GAAG,IAAI,QAc5D"}
+{"version":3,"file":"assertions.d.ts","sourceRoot":"","sources":["../../../src/validation/assertions.ts"],"names":[],"mappings":"AAAA,OAAO,EAAE,gBAAgB,EAAE,MAAM,WAAW,CAAA;AAQ5C,wBAAgB,kBAAkB,CAAC,KAAK,EAAE,gBAAgB,GAAG,IAAI,CAYhE;AAED,wBAAgB,iBAAiB,CAC/B,KAAK,CAAC,EAAE,gBAAgB,GAAG,IAAI,GAC9B,OAAO,CAAC,KAAK,IAAI,gBAAgB,CAOnC;AAED,wBAAgB,eAAe,CAAC,KAAK,EAAE,gBAAgB,GAAG,IAAI,CAI7D;AAED,wBAAgB,oBAAoB,CAAC,KAAK,EAAE,gBAAgB,GAAG,IAAI,CAIlE;AAED,wBAAgB,0BAA0B,CAAC,KAAK,EAAE,gBAAgB,GAAG,IAAI,CAIxE;AAED,wBAAgB,YAAY,CAAC,KAAK,EAAE,gBAAgB,GAAG,IAAI,CAI1D;AAED,wBAAgB,eAAe,CAAC,KAAK,EAAE,gBAAgB,GAAG,IAAI,CAI7D;AAED,wBAAgB,aAAa,CAAC,KAAK,CAAC,EAAE,gBAAgB,GAAG,IAAI,QAe5D"}

package.json

 {
   "name": "@segment/analytics-core",
-  "version": "1.4.1",
+  "version": "1.5.0",
   "repository": {
@@ -37,3 +37,3 @@ "type": "git",
     "@lukeed/uuid": "^2.0.0",
-    "@segment/analytics-generic-utils": "1.1.1",
+    "@segment/analytics-generic-utils": "1.2.0",
     "dset": "^3.1.2",
@@ -40,0 +40,0 @@ "tslib": "^2.4.1"

src/events/index.ts

@@ -22,2 +22,6 @@ export * from './interfaces'
 
+/**
+ * This is currently only used by node.js, but the original idea was to have something that could be shared between browser and node.
+ * Unfortunately, there are some differences in the way the two environments handle events, so this is not currently shared.
+ */
 export class EventFactory {
@@ -205,2 +209,3 @@ createMessageId: EventFactorySettings['createMessageId']
       'timestamp',
+      'messageId',
     ]
@@ -276,3 +281,3 @@
       ...body,
-      messageId: this.createMessageId(),
+      messageId: options.messageId || this.createMessageId(),
     }
@@ -279,0 +284,0 @@

src/events/interfaces.ts

@@ -36,2 +36,8 @@ import { CoreContext } from '../context'
   traits?: Traits
+  /**
+   * Override the messageId. Under normal circumstances, this is not recommended -- but neccessary for deduping events.
+   *
+   * **Currently, This option only works in `@segment/analytics-node`.**
+   */
+  messageId?: string
   // ugh, this is ugly, but we allow literally any property to be passed to options (which get spread onto the event)
@@ -38,0 +44,0 @@ [key: string]: any

src/queue/event-queue.ts

@@ -19,2 +19,3 @@ import { CoreAnalytics } from '../analytics'
   flush: [ctx: Ctx, delivered: boolean]
+  initialization_failure: [CorePlugin<Ctx>]
 }
@@ -53,21 +54,20 @@
   ): Promise<void> {
-    await Promise.resolve(plugin.load(ctx, instance))
-      .then(() => {
-        this.plugins.push(plugin)
-      })
-      .catch((err) => {
-        if (plugin.type === 'destination') {
-          this.failedInitializations.push(plugin.name)
-          console.warn(plugin.name, err)
+    if (plugin.type === 'destination' && plugin.name !== 'Segment.io') {
+      plugin.load(ctx, instance).catch((err) => {
+        this.failedInitializations.push(plugin.name)
+        this.emit('initialization_failure', plugin)
+        console.warn(plugin.name, err)
 
-          ctx.log('warn', 'Failed to load destination', {
-            plugin: plugin.name,
-            error: err,
-          })
+        ctx.log('warn', 'Failed to load destination', {
+          plugin: plugin.name,
+          error: err,
+        })
 
-          return
-        }
+        this.plugins = this.plugins.filter((p) => p === plugin)
+      })
+    } else {
+      await plugin.load(ctx, instance)
+    }
 
-        throw err
-      })
+    this.plugins.push(plugin)
   }
@@ -74,0 +74,0 @@

src/validation/assertions.ts

@@ -58,5 +58,12 @@ import { CoreSegmentEvent } from '../events'
 
+export function assertMessageId(event: CoreSegmentEvent): void {
+  if (!isString(event.messageId)) {
+    throw new ValidationError('.messageId', stringError)
+  }
+}
+
 export function validateEvent(event?: CoreSegmentEvent | null) {
   assertEventExists(event)
   assertEventType(event)
+  assertMessageId(event)
 
@@ -63,0 +70,0 @@ if (event.type === 'track') {

New alerts

Long strings

Supply chain risk

Contains long string literals, which may be a sign of obfuscated or packed code.

Found 1 instance in 1 package

Fixed alerts

AI-detected potential code anomaly

Supply chain risk

AI has identified unusual behaviors that may pose a security risk.

Found 1 instance in 1 package

Long strings

Supply chain risk

Contains long string literals, which may be a sign of obfuscated or packed code.

Found 1 instance in 1 package

Improved metrics

Total package byte prevSize

278864

1.4%

Lines of code

5087

1.07%

Number of low supply chain risk alerts

4

-20%

Dependency changes

• + Added

  @segment/analytics-generic-utils@1.2.0
  (transitive)

• - Removed

  @segment/analytics-generic-utils@1.1.1
  (transitive)

• Updated

  @segment/analytics-generic-utils@1.2.0