@peerbit/pubsub-interface - npm Package Compare versions

Comparing version 4.0.9 to 4.1.0

dist/src/index.js

@@ -1,9 +0,34 @@
-var __decorate = (this && this.__decorate) || function (decorators, target, key, desc) {
-    var c = arguments.length, r = c < 3 ? target : desc === null ? desc = Object.getOwnPropertyDescriptor(target, key) : desc, d;
-    if (typeof Reflect === "object" && typeof Reflect.decorate === "function") r = Reflect.decorate(decorators, target, key, desc);
-    else for (var i = decorators.length - 1; i >= 0; i--) if (d = decorators[i]) r = (c < 3 ? d(r) : c > 3 ? d(target, key, r) : d(target, key)) || r;
-    return c > 3 && r && Object.defineProperty(target, key, r), r;
+var __esDecorate = (this && this.__esDecorate) || function (ctor, descriptorIn, decorators, contextIn, initializers, extraInitializers) {
+    function accept(f) { if (f !== void 0 && typeof f !== "function") throw new TypeError("Function expected"); return f; }
+    var kind = contextIn.kind, key = kind === "getter" ? "get" : kind === "setter" ? "set" : "value";
+    var target = !descriptorIn && ctor ? contextIn["static"] ? ctor : ctor.prototype : null;
+    var descriptor = descriptorIn || (target ? Object.getOwnPropertyDescriptor(target, contextIn.name) : {});
+    var _, done = false;
+    for (var i = decorators.length - 1; i >= 0; i--) {
+        var context = {};
+        for (var p in contextIn) context[p] = p === "access" ? {} : contextIn[p];
+        for (var p in contextIn.access) context.access[p] = contextIn.access[p];
+        context.addInitializer = function (f) { if (done) throw new TypeError("Cannot add initializers after decoration has completed"); extraInitializers.push(accept(f || null)); };
+        var result = (0, decorators[i])(kind === "accessor" ? { get: descriptor.get, set: descriptor.set } : descriptor[key], context);
+        if (kind === "accessor") {
+            if (result === void 0) continue;
+            if (result === null || typeof result !== "object") throw new TypeError("Object expected");
+            if (_ = accept(result.get)) descriptor.get = _;
+            if (_ = accept(result.set)) descriptor.set = _;
+            if (_ = accept(result.init)) initializers.unshift(_);
+        }
+        else if (_ = accept(result)) {
+            if (kind === "field") initializers.unshift(_);
+            else descriptor[key] = _;
+        }
+    }
+    if (target) Object.defineProperty(target, contextIn.name, descriptor);
+    done = true;
 };
-var __metadata = (this && this.__metadata) || function (k, v) {
-    if (typeof Reflect === "object" && typeof Reflect.metadata === "function") return Reflect.metadata(k, v);
+var __runInitializers = (this && this.__runInitializers) || function (thisArg, initializers, value) {
+    var useValue = arguments.length > 2;
+    for (var i = 0; i < initializers.length; i++) {
+        value = useValue ? initializers[i].call(thisArg, value) : initializers[i].call(thisArg);
+    }
+    return useValue ? value : void 0;
 };
@@ -15,91 +40,141 @@ import { field, vec } from "@dao-xyz/borsh";
 import { PubSubData } from "./messages.js";
-export class SubscriptionEvent {
-    from;
-    topics;
-    constructor(from, topics) {
-        this.from = from;
-        this.topics = topics;
-    }
-}
-__decorate([
-    field({ type: PublicSignKey }),
-    __metadata("design:type", PublicSignKey)
-], SubscriptionEvent.prototype, "from", void 0);
-__decorate([
-    field({ type: vec("string") }),
-    __metadata("design:type", Array)
-], SubscriptionEvent.prototype, "topics", void 0);
-export class UnsubcriptionEvent {
-    from;
-    topics;
-    constructor(from, topics) {
-        this.from = from;
-        this.topics = topics;
-    }
-}
-__decorate([
-    field({ type: PublicSignKey }),
-    __metadata("design:type", PublicSignKey)
-], UnsubcriptionEvent.prototype, "from", void 0);
-__decorate([
-    field({ type: vec("string") }),
-    __metadata("design:type", Array)
-], UnsubcriptionEvent.prototype, "topics", void 0);
-export class PublishEvent {
-    data;
-    message;
-    client;
-    constructor(properties) {
-        this.client = properties.client;
-        this.data = properties.data;
-        this.message = properties.message;
-    }
-}
-__decorate([
-    field({ type: PubSubData }),
-    __metadata("design:type", PubSubData)
-], PublishEvent.prototype, "data", void 0);
-__decorate([
-    field({ type: DataMessage }),
-    __metadata("design:type", DataMessage)
-], PublishEvent.prototype, "message", void 0);
-export class DataEvent {
-    data;
-    message;
-    constructor(properties) {
-        this.data = properties.data;
-        this.message = properties.message;
-    }
-}
-__decorate([
-    field({ type: PubSubData }),
-    __metadata("design:type", PubSubData)
-], DataEvent.prototype, "data", void 0);
-__decorate([
-    field({ type: DataMessage }),
-    __metadata("design:type", DataMessage)
-], DataEvent.prototype, "message", void 0);
-export class SubscriptionData {
-    publicKey;
-    session;
-    timestamp;
-    constructor(properties) {
-        this.publicKey = properties.publicKey;
-        this.session = properties.session;
-        this.timestamp = properties.timestamp;
-    }
-}
-__decorate([
-    field({ type: PublicSignKey }),
-    __metadata("design:type", PublicSignKey)
-], SubscriptionData.prototype, "publicKey", void 0);
-__decorate([
-    field({ type: "u64" }),
-    __metadata("design:type", BigInt)
-], SubscriptionData.prototype, "session", void 0);
-__decorate([
-    field({ type: "u64" }),
-    __metadata("design:type", BigInt)
-], SubscriptionData.prototype, "timestamp", void 0);
+let SubscriptionEvent = (() => {
+    let _from_decorators;
+    let _from_initializers = [];
+    let _from_extraInitializers = [];
+    let _topics_decorators;
+    let _topics_initializers = [];
+    let _topics_extraInitializers = [];
+    return class SubscriptionEvent {
+        static {
+            const _metadata = typeof Symbol === "function" && Symbol.metadata ? Object.create(null) : void 0;
+            _from_decorators = [field({ type: PublicSignKey })];
+            _topics_decorators = [field({ type: vec("string") })];
+            __esDecorate(null, null, _from_decorators, { kind: "field", name: "from", static: false, private: false, access: { has: obj => "from" in obj, get: obj => obj.from, set: (obj, value) => { obj.from = value; } }, metadata: _metadata }, _from_initializers, _from_extraInitializers);
+            __esDecorate(null, null, _topics_decorators, { kind: "field", name: "topics", static: false, private: false, access: { has: obj => "topics" in obj, get: obj => obj.topics, set: (obj, value) => { obj.topics = value; } }, metadata: _metadata }, _topics_initializers, _topics_extraInitializers);
+            if (_metadata) Object.defineProperty(this, Symbol.metadata, { enumerable: true, configurable: true, writable: true, value: _metadata });
+        }
+        from = __runInitializers(this, _from_initializers, void 0);
+        topics = (__runInitializers(this, _from_extraInitializers), __runInitializers(this, _topics_initializers, void 0));
+        constructor(from, topics) {
+            __runInitializers(this, _topics_extraInitializers);
+            this.from = from;
+            this.topics = topics;
+        }
+    };
+})();
+export { SubscriptionEvent };
+let UnsubcriptionEvent = (() => {
+    let _from_decorators;
+    let _from_initializers = [];
+    let _from_extraInitializers = [];
+    let _topics_decorators;
+    let _topics_initializers = [];
+    let _topics_extraInitializers = [];
+    return class UnsubcriptionEvent {
+        static {
+            const _metadata = typeof Symbol === "function" && Symbol.metadata ? Object.create(null) : void 0;
+            _from_decorators = [field({ type: PublicSignKey })];
+            _topics_decorators = [field({ type: vec("string") })];
+            __esDecorate(null, null, _from_decorators, { kind: "field", name: "from", static: false, private: false, access: { has: obj => "from" in obj, get: obj => obj.from, set: (obj, value) => { obj.from = value; } }, metadata: _metadata }, _from_initializers, _from_extraInitializers);
+            __esDecorate(null, null, _topics_decorators, { kind: "field", name: "topics", static: false, private: false, access: { has: obj => "topics" in obj, get: obj => obj.topics, set: (obj, value) => { obj.topics = value; } }, metadata: _metadata }, _topics_initializers, _topics_extraInitializers);
+            if (_metadata) Object.defineProperty(this, Symbol.metadata, { enumerable: true, configurable: true, writable: true, value: _metadata });
+        }
+        from = __runInitializers(this, _from_initializers, void 0);
+        topics = (__runInitializers(this, _from_extraInitializers), __runInitializers(this, _topics_initializers, void 0));
+        constructor(from, topics) {
+            __runInitializers(this, _topics_extraInitializers);
+            this.from = from;
+            this.topics = topics;
+        }
+    };
+})();
+export { UnsubcriptionEvent };
+let PublishEvent = (() => {
+    let _data_decorators;
+    let _data_initializers = [];
+    let _data_extraInitializers = [];
+    let _message_decorators;
+    let _message_initializers = [];
+    let _message_extraInitializers = [];
+    return class PublishEvent {
+        static {
+            const _metadata = typeof Symbol === "function" && Symbol.metadata ? Object.create(null) : void 0;
+            _data_decorators = [field({ type: PubSubData })];
+            _message_decorators = [field({ type: DataMessage })];
+            __esDecorate(null, null, _data_decorators, { kind: "field", name: "data", static: false, private: false, access: { has: obj => "data" in obj, get: obj => obj.data, set: (obj, value) => { obj.data = value; } }, metadata: _metadata }, _data_initializers, _data_extraInitializers);
+            __esDecorate(null, null, _message_decorators, { kind: "field", name: "message", static: false, private: false, access: { has: obj => "message" in obj, get: obj => obj.message, set: (obj, value) => { obj.message = value; } }, metadata: _metadata }, _message_initializers, _message_extraInitializers);
+            if (_metadata) Object.defineProperty(this, Symbol.metadata, { enumerable: true, configurable: true, writable: true, value: _metadata });
+        }
+        data = __runInitializers(this, _data_initializers, void 0);
+        message = (__runInitializers(this, _data_extraInitializers), __runInitializers(this, _message_initializers, void 0));
+        client = __runInitializers(this, _message_extraInitializers);
+        constructor(properties) {
+            this.client = properties.client;
+            this.data = properties.data;
+            this.message = properties.message;
+        }
+    };
+})();
+export { PublishEvent };
+let DataEvent = (() => {
+    let _data_decorators;
+    let _data_initializers = [];
+    let _data_extraInitializers = [];
+    let _message_decorators;
+    let _message_initializers = [];
+    let _message_extraInitializers = [];
+    return class DataEvent {
+        static {
+            const _metadata = typeof Symbol === "function" && Symbol.metadata ? Object.create(null) : void 0;
+            _data_decorators = [field({ type: PubSubData })];
+            _message_decorators = [field({ type: DataMessage })];
+            __esDecorate(null, null, _data_decorators, { kind: "field", name: "data", static: false, private: false, access: { has: obj => "data" in obj, get: obj => obj.data, set: (obj, value) => { obj.data = value; } }, metadata: _metadata }, _data_initializers, _data_extraInitializers);
+            __esDecorate(null, null, _message_decorators, { kind: "field", name: "message", static: false, private: false, access: { has: obj => "message" in obj, get: obj => obj.message, set: (obj, value) => { obj.message = value; } }, metadata: _metadata }, _message_initializers, _message_extraInitializers);
+            if (_metadata) Object.defineProperty(this, Symbol.metadata, { enumerable: true, configurable: true, writable: true, value: _metadata });
+        }
+        data = __runInitializers(this, _data_initializers, void 0);
+        message = (__runInitializers(this, _data_extraInitializers), __runInitializers(this, _message_initializers, void 0));
+        constructor(properties) {
+            __runInitializers(this, _message_extraInitializers);
+            this.data = properties.data;
+            this.message = properties.message;
+        }
+    };
+})();
+export { DataEvent };
+let SubscriptionData = (() => {
+    let _publicKey_decorators;
+    let _publicKey_initializers = [];
+    let _publicKey_extraInitializers = [];
+    let _session_decorators;
+    let _session_initializers = [];
+    let _session_extraInitializers = [];
+    let _timestamp_decorators;
+    let _timestamp_initializers = [];
+    let _timestamp_extraInitializers = [];
+    return class SubscriptionData {
+        static {
+            const _metadata = typeof Symbol === "function" && Symbol.metadata ? Object.create(null) : void 0;
+            _publicKey_decorators = [field({ type: PublicSignKey })];
+            _session_decorators = [field({ type: "u64" })];
+            _timestamp_decorators = [field({ type: "u64" })];
+            __esDecorate(null, null, _publicKey_decorators, { kind: "field", name: "publicKey", static: false, private: false, access: { has: obj => "publicKey" in obj, get: obj => obj.publicKey, set: (obj, value) => { obj.publicKey = value; } }, metadata: _metadata }, _publicKey_initializers, _publicKey_extraInitializers);
+            __esDecorate(null, null, _session_decorators, { kind: "field", name: "session", static: false, private: false, access: { has: obj => "session" in obj, get: obj => obj.session, set: (obj, value) => { obj.session = value; } }, metadata: _metadata }, _session_initializers, _session_extraInitializers);
+            __esDecorate(null, null, _timestamp_decorators, { kind: "field", name: "timestamp", static: false, private: false, access: { has: obj => "timestamp" in obj, get: obj => obj.timestamp, set: (obj, value) => { obj.timestamp = value; } }, metadata: _metadata }, _timestamp_initializers, _timestamp_extraInitializers);
+            if (_metadata) Object.defineProperty(this, Symbol.metadata, { enumerable: true, configurable: true, writable: true, value: _metadata });
+        }
+        publicKey = __runInitializers(this, _publicKey_initializers, void 0);
+        session = (__runInitializers(this, _publicKey_extraInitializers), __runInitializers(this, _session_initializers, void 0));
+        timestamp = (__runInitializers(this, _session_extraInitializers), __runInitializers(this, _timestamp_initializers, void 0));
+        constructor(properties) {
+            __runInitializers(this, _timestamp_extraInitializers);
+            this.publicKey = properties.publicKey;
+            this.session = properties.session;
+            this.timestamp = properties.timestamp;
+        }
+    };
+})();
+export { SubscriptionData };
 export * from "./messages.js";
 //# sourceMappingURL=index.js.map

dist/src/index.js.map

@@ -1,1 +0,1 @@
-{"version":3,"file":"index.js","sourceRoot":"","sources":["../../src/index.ts"],"names":[],"mappings":";;;;;;;;;AAAA,OAAO,EAAE,KAAK,EAAE,GAAG,EAAE,MAAM,gBAAgB,CAAC;AAC5C,OAAO,EAAqB,MAAM,mBAAmB,CAAC;AACtD,OAAO,EAAE,aAAa,EAAE,MAAM,iBAAiB,CAAC;AAChD,OAAO,EACN,WAAW,EACX,YAAY,EAEZ,OAAO,GAMP,MAAM,2BAA2B,CAAC;AACnC,OAAO,EAAE,UAAU,EAAE,MAAM,eAAe,CAAC;AAE3C,MAAM,OAAO,iBAAiB;IAE7B,IAAI,CAAgB;IAGpB,MAAM,CAAW;IAEjB,YAAY,IAAmB,EAAE,MAAgB;QAChD,IAAI,CAAC,IAAI,GAAG,IAAI,CAAC;QACjB,IAAI,CAAC,MAAM,GAAG,MAAM,CAAC;IACtB,CAAC;CACD;AATA;IADC,KAAK,CAAC,EAAE,IAAI,EAAE,aAAa,EAAE,CAAC;8BACzB,aAAa;+CAAC;AAGpB;IADC,KAAK,CAAC,EAAE,IAAI,EAAE,GAAG,CAAC,QAAQ,CAAC,EAAE,CAAC;;iDACd;AAQlB,MAAM,OAAO,kBAAkB;IAE9B,IAAI,CAAgB;IAGpB,MAAM,CAAW;IAEjB,YAAY,IAAmB,EAAE,MAAgB;QAChD,IAAI,CAAC,IAAI,GAAG,IAAI,CAAC;QACjB,IAAI,CAAC,MAAM,GAAG,MAAM,CAAC;IACtB,CAAC;CACD;AATA;IADC,KAAK,CAAC,EAAE,IAAI,EAAE,aAAa,EAAE,CAAC;8BACzB,aAAa;gDAAC;AAGpB;IADC,KAAK,CAAC,EAAE,IAAI,EAAE,GAAG,CAAC,QAAQ,CAAC,EAAE,CAAC;;kDACd;AAQlB,MAAM,OAAO,YAAY;IAExB,IAAI,CAAa;IAGjB,OAAO,CAAc;IAErB,MAAM,CAAU;IAEhB,YAAY,UAIX;QACA,IAAI,CAAC,MAAM,GAAG,UAAU,CAAC,MAAM,CAAC;QAChC,IAAI,CAAC,IAAI,GAAG,UAAU,CAAC,IAAI,CAAC;QAC5B,IAAI,CAAC,OAAO,GAAG,UAAU,CAAC,OAAO,CAAC;IACnC,CAAC;CACD;AAhBA;IADC,KAAK,CAAC,EAAE,IAAI,EAAE,UAAU,EAAE,CAAC;8BACtB,UAAU;0CAAC;AAGjB;IADC,KAAK,CAAC,EAAE,IAAI,EAAE,WAAW,EAAE,CAAC;8BACpB,WAAW;6CAAC;AAetB,MAAM,OAAO,SAAS;IAErB,IAAI,CAAa;IAGjB,OAAO,CAAc;IAErB,YAAY,UAAsD;QACjE,IAAI,CAAC,IAAI,GAAG,UAAU,CAAC,IAAI,CAAC;QAC5B,IAAI,CAAC,OAAO,GAAG,UAAU,CAAC,OAAO,CAAC;IACnC,CAAC;CACD;AATA;IADC,KAAK,CAAC,EAAE,IAAI,EAAE,UAAU,EAAE,CAAC;8BACtB,UAAU;uCAAC;AAGjB;IADC,KAAK,CAAC,EAAE,IAAI,EAAE,WAAW,EAAE,CAAC;8BACpB,WAAW;0CAAC;AAQtB,MAAM,OAAO,gBAAgB;IAE5B,SAAS,CAAgB;IAGzB,OAAO,CAAS;IAGhB,SAAS,CAAS;IAElB,YAAY,UAIX;QACA,IAAI,CAAC,SAAS,GAAG,UAAU,CAAC,SAAS,CAAC;QACtC,IAAI,CAAC,OAAO,GAAG,UAAU,CAAC,OAAO,CAAC;QAClC,IAAI,CAAC,SAAS,GAAG,UAAU,CAAC,SAAS,CAAC;IACvC,CAAC;CACD;AAjBA;IADC,KAAK,CAAC,EAAE,IAAI,EAAE,aAAa,EAAE,CAAC;8BACpB,aAAa;mDAAC;AAGzB;IADC,KAAK,CAAC,EAAE,IAAI,EAAE,KAAK,EAAE,CAAC;;iDACP;AAGhB;IADC,KAAK,CAAC,EAAE,IAAI,EAAE,KAAK,EAAE,CAAC;;mDACL;AA0EnB,cAAc,eAAe,CAAC"}
+{"version":3,"file":"index.js","sourceRoot":"","sources":["../../src/index.ts"],"names":[],"mappings":";;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;AAAA,OAAO,EAAE,KAAK,EAAE,GAAG,EAAE,MAAM,gBAAgB,CAAC;AAC5C,OAAO,EAAqB,MAAM,mBAAmB,CAAC;AACtD,OAAO,EAAE,aAAa,EAAE,MAAM,iBAAiB,CAAC;AAChD,OAAO,EACN,WAAW,EACX,YAAY,EAEZ,OAAO,GAMP,MAAM,2BAA2B,CAAC;AACnC,OAAO,EAAE,UAAU,EAAE,MAAM,eAAe,CAAC;IAE9B,iBAAiB;;;;;;;iBAAjB,iBAAiB;;;gCAC5B,KAAK,CAAC,EAAE,IAAI,EAAE,aAAa,EAAE,CAAC;kCAG9B,KAAK,CAAC,EAAE,IAAI,EAAE,GAAG,CAAC,QAAQ,CAAC,EAAE,CAAC;YAF/B,8JAAA,IAAI,6BAAJ,IAAI,mFAAgB;YAGpB,oKAAA,MAAM,6BAAN,MAAM,uFAAW;;;QAHjB,IAAI,uDAAgB;QAGpB,MAAM,6GAAW;QAEjB,YAAY,IAAmB,EAAE,MAAgB;;YAChD,IAAI,CAAC,IAAI,GAAG,IAAI,CAAC;YACjB,IAAI,CAAC,MAAM,GAAG,MAAM,CAAC;SACrB;;;SAVW,iBAAiB;IAajB,kBAAkB;;;;;;;iBAAlB,kBAAkB;;;gCAC7B,KAAK,CAAC,EAAE,IAAI,EAAE,aAAa,EAAE,CAAC;kCAG9B,KAAK,CAAC,EAAE,IAAI,EAAE,GAAG,CAAC,QAAQ,CAAC,EAAE,CAAC;YAF/B,8JAAA,IAAI,6BAAJ,IAAI,mFAAgB;YAGpB,oKAAA,MAAM,6BAAN,MAAM,uFAAW;;;QAHjB,IAAI,uDAAgB;QAGpB,MAAM,6GAAW;QAEjB,YAAY,IAAmB,EAAE,MAAgB;;YAChD,IAAI,CAAC,IAAI,GAAG,IAAI,CAAC;YACjB,IAAI,CAAC,MAAM,GAAG,MAAM,CAAC;SACrB;;;SAVW,kBAAkB;IAalB,YAAY;;;;;;;iBAAZ,YAAY;;;gCACvB,KAAK,CAAC,EAAE,IAAI,EAAE,UAAU,EAAE,CAAC;mCAG3B,KAAK,CAAC,EAAE,IAAI,EAAE,WAAW,EAAE,CAAC;YAF7B,8JAAA,IAAI,6BAAJ,IAAI,mFAAa;YAGjB,uKAAA,OAAO,6BAAP,OAAO,yFAAc;;;QAHrB,IAAI,uDAAa;QAGjB,OAAO,8GAAc;QAErB,MAAM,uDAAU;QAEhB,YAAY,UAIX;YACA,IAAI,CAAC,MAAM,GAAG,UAAU,CAAC,MAAM,CAAC;YAChC,IAAI,CAAC,IAAI,GAAG,UAAU,CAAC,IAAI,CAAC;YAC5B,IAAI,CAAC,OAAO,GAAG,UAAU,CAAC,OAAO,CAAC;QACnC,CAAC;;;SAjBW,YAAY;IAoBZ,SAAS;;;;;;;iBAAT,SAAS;;;gCACpB,KAAK,CAAC,EAAE,IAAI,EAAE,UAAU,EAAE,CAAC;mCAG3B,KAAK,CAAC,EAAE,IAAI,EAAE,WAAW,EAAE,CAAC;YAF7B,8JAAA,IAAI,6BAAJ,IAAI,mFAAa;YAGjB,uKAAA,OAAO,6BAAP,OAAO,yFAAc;;;QAHrB,IAAI,uDAAa;QAGjB,OAAO,8GAAc;QAErB,YAAY,UAAsD;;YACjE,IAAI,CAAC,IAAI,GAAG,UAAU,CAAC,IAAI,CAAC;YAC5B,IAAI,CAAC,OAAO,GAAG,UAAU,CAAC,OAAO,CAAC;SAClC;;;SAVW,SAAS;IAaT,gBAAgB;;;;;;;;;;iBAAhB,gBAAgB;;;qCAC3B,KAAK,CAAC,EAAE,IAAI,EAAE,aAAa,EAAE,CAAC;mCAG9B,KAAK,CAAC,EAAE,IAAI,EAAE,KAAK,EAAE,CAAC;qCAGtB,KAAK,CAAC,EAAE,IAAI,EAAE,KAAK,EAAE,CAAC;YALvB,6KAAA,SAAS,6BAAT,SAAS,6FAAgB;YAGzB,uKAAA,OAAO,6BAAP,OAAO,yFAAS;YAGhB,6KAAA,SAAS,6BAAT,SAAS,6FAAS;;;QANlB,SAAS,4DAAgB;QAGzB,OAAO,mHAAS;QAGhB,SAAS,mHAAS;QAElB,YAAY,UAIX;;YACA,IAAI,CAAC,SAAS,GAAG,UAAU,CAAC,SAAS,CAAC;YACtC,IAAI,CAAC,OAAO,GAAG,UAAU,CAAC,OAAO,CAAC;YAClC,IAAI,CAAC,SAAS,GAAG,UAAU,CAAC,SAAS,CAAC;SACtC;;;SAlBW,gBAAgB;AAkF7B,cAAc,eAAe,CAAC"}

dist/src/messages.js

@@ -1,11 +0,35 @@
-var __decorate = (this && this.__decorate) || function (decorators, target, key, desc) {
-    var c = arguments.length, r = c < 3 ? target : desc === null ? desc = Object.getOwnPropertyDescriptor(target, key) : desc, d;
-    if (typeof Reflect === "object" && typeof Reflect.decorate === "function") r = Reflect.decorate(decorators, target, key, desc);
-    else for (var i = decorators.length - 1; i >= 0; i--) if (d = decorators[i]) r = (c < 3 ? d(r) : c > 3 ? d(target, key, r) : d(target, key)) || r;
-    return c > 3 && r && Object.defineProperty(target, key, r), r;
+var __esDecorate = (this && this.__esDecorate) || function (ctor, descriptorIn, decorators, contextIn, initializers, extraInitializers) {
+    function accept(f) { if (f !== void 0 && typeof f !== "function") throw new TypeError("Function expected"); return f; }
+    var kind = contextIn.kind, key = kind === "getter" ? "get" : kind === "setter" ? "set" : "value";
+    var target = !descriptorIn && ctor ? contextIn["static"] ? ctor : ctor.prototype : null;
+    var descriptor = descriptorIn || (target ? Object.getOwnPropertyDescriptor(target, contextIn.name) : {});
+    var _, done = false;
+    for (var i = decorators.length - 1; i >= 0; i--) {
+        var context = {};
+        for (var p in contextIn) context[p] = p === "access" ? {} : contextIn[p];
+        for (var p in contextIn.access) context.access[p] = contextIn.access[p];
+        context.addInitializer = function (f) { if (done) throw new TypeError("Cannot add initializers after decoration has completed"); extraInitializers.push(accept(f || null)); };
+        var result = (0, decorators[i])(kind === "accessor" ? { get: descriptor.get, set: descriptor.set } : descriptor[key], context);
+        if (kind === "accessor") {
+            if (result === void 0) continue;
+            if (result === null || typeof result !== "object") throw new TypeError("Object expected");
+            if (_ = accept(result.get)) descriptor.get = _;
+            if (_ = accept(result.set)) descriptor.set = _;
+            if (_ = accept(result.init)) initializers.unshift(_);
+        }
+        else if (_ = accept(result)) {
+            if (kind === "field") initializers.unshift(_);
+            else descriptor[key] = _;
+        }
+    }
+    if (target) Object.defineProperty(target, contextIn.name, descriptor);
+    done = true;
 };
-var __metadata = (this && this.__metadata) || function (k, v) {
-    if (typeof Reflect === "object" && typeof Reflect.metadata === "function") return Reflect.metadata(k, v);
+var __runInitializers = (this && this.__runInitializers) || function (thisArg, initializers, value) {
+    var useValue = arguments.length > 2;
+    for (var i = 0; i < initializers.length; i++) {
+        value = useValue ? initializers[i].call(thisArg, value) : initializers[i].call(thisArg);
+    }
+    return useValue ? value : void 0;
 };
-var PubSubData_1, Subscribe_1, Unsubscribe_1, GetSubscribers_1;
 import { deserialize, field, serialize, variant, vec } from "@dao-xyz/borsh";
@@ -31,144 +55,199 @@ import { Uint8ArrayList } from "uint8arraylist";
 }
-let PubSubData = PubSubData_1 = class PubSubData extends PubSubMessage {
-    topics;
-    strict; // only deliver message to initial to receivers
-    data;
-    constructor(options) {
-        super();
-        this.data =
-            options.data instanceof Uint8Array
-                ? options.data
-                : options.data.subarray();
-        this.topics = options.topics;
-        this.strict = options.strict ?? false;
-    }
-    _serialized;
-    bytes() {
-        if (this._serialized) {
-            return this._serialized;
+let PubSubData = (() => {
+    let _classDecorators = [variant(0)];
+    let _classDescriptor;
+    let _classExtraInitializers = [];
+    let _classThis;
+    let _classSuper = PubSubMessage;
+    let _topics_decorators;
+    let _topics_initializers = [];
+    let _topics_extraInitializers = [];
+    let _strict_decorators;
+    let _strict_initializers = [];
+    let _strict_extraInitializers = [];
+    let _data_decorators;
+    let _data_initializers = [];
+    let _data_extraInitializers = [];
+    var PubSubData = class extends _classSuper {
+        static { _classThis = this; }
+        static {
+            const _metadata = typeof Symbol === "function" && Symbol.metadata ? Object.create(_classSuper[Symbol.metadata] ?? null) : void 0;
+            _topics_decorators = [field({ type: vec("string") })];
+            _strict_decorators = [field({ type: "bool" })];
+            _data_decorators = [field({ type: Uint8Array })];
+            __esDecorate(null, null, _topics_decorators, { kind: "field", name: "topics", static: false, private: false, access: { has: obj => "topics" in obj, get: obj => obj.topics, set: (obj, value) => { obj.topics = value; } }, metadata: _metadata }, _topics_initializers, _topics_extraInitializers);
+            __esDecorate(null, null, _strict_decorators, { kind: "field", name: "strict", static: false, private: false, access: { has: obj => "strict" in obj, get: obj => obj.strict, set: (obj, value) => { obj.strict = value; } }, metadata: _metadata }, _strict_initializers, _strict_extraInitializers);
+            __esDecorate(null, null, _data_decorators, { kind: "field", name: "data", static: false, private: false, access: { has: obj => "data" in obj, get: obj => obj.data, set: (obj, value) => { obj.data = value; } }, metadata: _metadata }, _data_initializers, _data_extraInitializers);
+            __esDecorate(null, _classDescriptor = { value: _classThis }, _classDecorators, { kind: "class", name: _classThis.name, metadata: _metadata }, null, _classExtraInitializers);
+            PubSubData = _classThis = _classDescriptor.value;
+            if (_metadata) Object.defineProperty(_classThis, Symbol.metadata, { enumerable: true, configurable: true, writable: true, value: _metadata });
+            __runInitializers(_classThis, _classExtraInitializers);
         }
-        return serialize(this);
-    }
-    static from(bytes) {
-        const ret = deserialize(bytes instanceof Uint8Array ? bytes : bytes.subarray(), PubSubData_1);
-        if (bytes instanceof Uint8ArrayList) {
-            ret._serialized = bytes;
+        topics = __runInitializers(this, _topics_initializers, void 0);
+        strict = (__runInitializers(this, _topics_extraInitializers), __runInitializers(this, _strict_initializers, void 0)); // only deliver message to initial to receivers
+        data = (__runInitializers(this, _strict_extraInitializers), __runInitializers(this, _data_initializers, void 0));
+        constructor(options) {
+            super();
+            this.data =
+                options.data instanceof Uint8Array
+                    ? options.data
+                    : options.data.subarray();
+            this.topics = options.topics;
+            this.strict = options.strict ?? false;
         }
-        return ret;
-    }
-};
-__decorate([
-    field({ type: vec("string") }),
-    __metadata("design:type", Array)
-], PubSubData.prototype, "topics", void 0);
-__decorate([
-    field({ type: "bool" }),
-    __metadata("design:type", Boolean)
-], PubSubData.prototype, "strict", void 0);
-__decorate([
-    field({ type: Uint8Array }),
-    __metadata("design:type", Uint8Array)
-], PubSubData.prototype, "data", void 0);
-PubSubData = PubSubData_1 = __decorate([
-    variant(0),
-    __metadata("design:paramtypes", [Object])
-], PubSubData);
+        _serialized = __runInitializers(this, _data_extraInitializers);
+        bytes() {
+            if (this._serialized) {
+                return this._serialized;
+            }
+            return serialize(this);
+        }
+        static from(bytes) {
+            const ret = deserialize(bytes instanceof Uint8Array ? bytes : bytes.subarray(), PubSubData);
+            if (bytes instanceof Uint8ArrayList) {
+                ret._serialized = bytes;
+            }
+            return ret;
+        }
+    };
+    return PubSubData = _classThis;
+})();
 export { PubSubData };
-let Subscribe = Subscribe_1 = class Subscribe extends PubSubMessage {
-    topics;
-    requestSubscribers;
-    constructor(options) {
-        super();
-        this.topics = options.topics;
-        this.requestSubscribers = options.requestSubscribers;
-    }
-    _serialized;
-    bytes() {
-        if (this._serialized) {
-            return this._serialized;
+let Subscribe = (() => {
+    let _classDecorators = [variant(1)];
+    let _classDescriptor;
+    let _classExtraInitializers = [];
+    let _classThis;
+    let _classSuper = PubSubMessage;
+    let _topics_decorators;
+    let _topics_initializers = [];
+    let _topics_extraInitializers = [];
+    let _requestSubscribers_decorators;
+    let _requestSubscribers_initializers = [];
+    let _requestSubscribers_extraInitializers = [];
+    var Subscribe = class extends _classSuper {
+        static { _classThis = this; }
+        static {
+            const _metadata = typeof Symbol === "function" && Symbol.metadata ? Object.create(_classSuper[Symbol.metadata] ?? null) : void 0;
+            _topics_decorators = [field({ type: vec("string") })];
+            _requestSubscribers_decorators = [field({ type: "bool" })];
+            __esDecorate(null, null, _topics_decorators, { kind: "field", name: "topics", static: false, private: false, access: { has: obj => "topics" in obj, get: obj => obj.topics, set: (obj, value) => { obj.topics = value; } }, metadata: _metadata }, _topics_initializers, _topics_extraInitializers);
+            __esDecorate(null, null, _requestSubscribers_decorators, { kind: "field", name: "requestSubscribers", static: false, private: false, access: { has: obj => "requestSubscribers" in obj, get: obj => obj.requestSubscribers, set: (obj, value) => { obj.requestSubscribers = value; } }, metadata: _metadata }, _requestSubscribers_initializers, _requestSubscribers_extraInitializers);
+            __esDecorate(null, _classDescriptor = { value: _classThis }, _classDecorators, { kind: "class", name: _classThis.name, metadata: _metadata }, null, _classExtraInitializers);
+            Subscribe = _classThis = _classDescriptor.value;
+            if (_metadata) Object.defineProperty(_classThis, Symbol.metadata, { enumerable: true, configurable: true, writable: true, value: _metadata });
+            __runInitializers(_classThis, _classExtraInitializers);
         }
-        return serialize(this);
-    }
-    static from(bytes) {
-        const ret = deserialize(bytes instanceof Uint8Array ? bytes : bytes.subarray(), Subscribe_1);
-        if (bytes instanceof Uint8ArrayList) {
-            ret._serialized = bytes;
+        topics = __runInitializers(this, _topics_initializers, void 0);
+        requestSubscribers = (__runInitializers(this, _topics_extraInitializers), __runInitializers(this, _requestSubscribers_initializers, void 0));
+        constructor(options) {
+            super();
+            this.topics = options.topics;
+            this.requestSubscribers = options.requestSubscribers;
         }
-        return ret;
-    }
-};
-__decorate([
-    field({ type: vec("string") }),
-    __metadata("design:type", Array)
-], Subscribe.prototype, "topics", void 0);
-__decorate([
-    field({ type: "bool" }),
-    __metadata("design:type", Boolean)
-], Subscribe.prototype, "requestSubscribers", void 0);
-Subscribe = Subscribe_1 = __decorate([
-    variant(1),
-    __metadata("design:paramtypes", [Object])
-], Subscribe);
+        _serialized = __runInitializers(this, _requestSubscribers_extraInitializers);
+        bytes() {
+            if (this._serialized) {
+                return this._serialized;
+            }
+            return serialize(this);
+        }
+        static from(bytes) {
+            const ret = deserialize(bytes instanceof Uint8Array ? bytes : bytes.subarray(), Subscribe);
+            if (bytes instanceof Uint8ArrayList) {
+                ret._serialized = bytes;
+            }
+            return ret;
+        }
+    };
+    return Subscribe = _classThis;
+})();
 export { Subscribe };
-let Unsubscribe = Unsubscribe_1 = class Unsubscribe extends PubSubMessage {
-    topics;
-    constructor(options) {
-        super();
-        this.topics = options.topics;
-    }
-    _serialized;
-    bytes() {
-        if (this._serialized) {
-            return this._serialized;
+let Unsubscribe = (() => {
+    let _classDecorators = [variant(2)];
+    let _classDescriptor;
+    let _classExtraInitializers = [];
+    let _classThis;
+    let _classSuper = PubSubMessage;
+    let _topics_decorators;
+    let _topics_initializers = [];
+    let _topics_extraInitializers = [];
+    var Unsubscribe = class extends _classSuper {
+        static { _classThis = this; }
+        static {
+            const _metadata = typeof Symbol === "function" && Symbol.metadata ? Object.create(_classSuper[Symbol.metadata] ?? null) : void 0;
+            _topics_decorators = [field({ type: vec("string") })];
+            __esDecorate(null, null, _topics_decorators, { kind: "field", name: "topics", static: false, private: false, access: { has: obj => "topics" in obj, get: obj => obj.topics, set: (obj, value) => { obj.topics = value; } }, metadata: _metadata }, _topics_initializers, _topics_extraInitializers);
+            __esDecorate(null, _classDescriptor = { value: _classThis }, _classDecorators, { kind: "class", name: _classThis.name, metadata: _metadata }, null, _classExtraInitializers);
+            Unsubscribe = _classThis = _classDescriptor.value;
+            if (_metadata) Object.defineProperty(_classThis, Symbol.metadata, { enumerable: true, configurable: true, writable: true, value: _metadata });
+            __runInitializers(_classThis, _classExtraInitializers);
         }
-        return serialize(this);
-    }
-    static from(bytes) {
-        const ret = deserialize(bytes instanceof Uint8Array ? bytes : bytes.subarray(), Unsubscribe_1);
-        if (bytes instanceof Uint8ArrayList) {
-            ret._serialized = bytes;
+        topics = __runInitializers(this, _topics_initializers, void 0);
+        constructor(options) {
+            super();
+            this.topics = options.topics;
         }
-        return ret;
-    }
-};
-__decorate([
-    field({ type: vec("string") }),
-    __metadata("design:type", Array)
-], Unsubscribe.prototype, "topics", void 0);
-Unsubscribe = Unsubscribe_1 = __decorate([
-    variant(2),
-    __metadata("design:paramtypes", [Object])
-], Unsubscribe);
+        _serialized = __runInitializers(this, _topics_extraInitializers);
+        bytes() {
+            if (this._serialized) {
+                return this._serialized;
+            }
+            return serialize(this);
+        }
+        static from(bytes) {
+            const ret = deserialize(bytes instanceof Uint8Array ? bytes : bytes.subarray(), Unsubscribe);
+            if (bytes instanceof Uint8ArrayList) {
+                ret._serialized = bytes;
+            }
+            return ret;
+        }
+    };
+    return Unsubscribe = _classThis;
+})();
 export { Unsubscribe };
-let GetSubscribers = GetSubscribers_1 = class GetSubscribers extends PubSubMessage {
-    topics;
-    // add stop filter list to prvent this message from propgating to unecessary peers
-    constructor(options) {
-        super();
-        this.topics = options.topics;
-    }
-    _serialized;
-    bytes() {
-        if (this._serialized) {
-            return this._serialized;
+let GetSubscribers = (() => {
+    let _classDecorators = [variant(3)];
+    let _classDescriptor;
+    let _classExtraInitializers = [];
+    let _classThis;
+    let _classSuper = PubSubMessage;
+    let _topics_decorators;
+    let _topics_initializers = [];
+    let _topics_extraInitializers = [];
+    var GetSubscribers = class extends _classSuper {
+        static { _classThis = this; }
+        static {
+            const _metadata = typeof Symbol === "function" && Symbol.metadata ? Object.create(_classSuper[Symbol.metadata] ?? null) : void 0;
+            _topics_decorators = [field({ type: vec("string") })];
+            __esDecorate(null, null, _topics_decorators, { kind: "field", name: "topics", static: false, private: false, access: { has: obj => "topics" in obj, get: obj => obj.topics, set: (obj, value) => { obj.topics = value; } }, metadata: _metadata }, _topics_initializers, _topics_extraInitializers);
+            __esDecorate(null, _classDescriptor = { value: _classThis }, _classDecorators, { kind: "class", name: _classThis.name, metadata: _metadata }, null, _classExtraInitializers);
+            GetSubscribers = _classThis = _classDescriptor.value;
+            if (_metadata) Object.defineProperty(_classThis, Symbol.metadata, { enumerable: true, configurable: true, writable: true, value: _metadata });
+            __runInitializers(_classThis, _classExtraInitializers);
         }
-        return serialize(this);
-    }
-    static from(bytes) {
-        const ret = deserialize(bytes instanceof Uint8Array ? bytes : bytes.subarray(), GetSubscribers_1);
-        if (bytes instanceof Uint8ArrayList) {
-            ret._serialized = bytes;
+        topics = __runInitializers(this, _topics_initializers, void 0);
+        // add stop filter list to prvent this message from propgating to unecessary peers
+        constructor(options) {
+            super();
+            this.topics = options.topics;
         }
-        return ret;
-    }
-};
-__decorate([
-    field({ type: vec("string") }),
-    __metadata("design:type", Array)
-], GetSubscribers.prototype, "topics", void 0);
-GetSubscribers = GetSubscribers_1 = __decorate([
-    variant(3),
-    __metadata("design:paramtypes", [Object])
-], GetSubscribers);
+        _serialized = __runInitializers(this, _topics_extraInitializers);
+        bytes() {
+            if (this._serialized) {
+                return this._serialized;
+            }
+            return serialize(this);
+        }
+        static from(bytes) {
+            const ret = deserialize(bytes instanceof Uint8Array ? bytes : bytes.subarray(), GetSubscribers);
+            if (bytes instanceof Uint8ArrayList) {
+                ret._serialized = bytes;
+            }
+            return ret;
+        }
+    };
+    return GetSubscribers = _classThis;
+})();
 export { GetSubscribers };
 //# sourceMappingURL=messages.js.map

dist/src/messages.js.map

@@ -1,1 +0,1 @@
-{"version":3,"file":"messages.js","sourceRoot":"","sources":["../../src/messages.ts"],"names":[],"mappings":";;;;;;;;;;AAAA,OAAO,EAAE,WAAW,EAAE,KAAK,EAAE,SAAS,EAAE,OAAO,EAAE,GAAG,EAAE,MAAM,gBAAgB,CAAC;AAC7E,OAAO,EAAE,cAAc,EAAE,MAAM,gBAAgB,CAAC;AAEhD,MAAM,OAAgB,aAAa;IAElC,MAAM,CAAC,IAAI,CAAC,KAAiB;QAC5B,MAAM,KAAK,GAAG,KAAK,CAAC,CAAC,CAAC,CAAC;QACvB,IAAI,KAAK,KAAK,CAAC,EAAE,CAAC;YACjB,OAAO,UAAU,CAAC,IAAI,CAAC,KAAK,CAAC,CAAC;QAC/B,CAAC;QACD,IAAI,KAAK,KAAK,CAAC,EAAE,CAAC;YACjB,OAAO,SAAS,CAAC,IAAI,CAAC,KAAK,CAAC,CAAC;QAC9B,CAAC;QACD,IAAI,KAAK,KAAK,CAAC,EAAE,CAAC;YACjB,OAAO,WAAW,CAAC,IAAI,CAAC,KAAK,CAAC,CAAC;QAChC,CAAC;QAED,IAAI,KAAK,KAAK,CAAC,EAAE,CAAC;YACjB,OAAO,cAAc,CAAC,IAAI,CAAC,KAAK,CAAC,CAAC;QACnC,CAAC;QAED,MAAM,IAAI,KAAK,CAAC,aAAa,CAAC,CAAC;IAChC,CAAC;CACD;AAGM,IAAM,UAAU,kBAAhB,MAAM,UAAW,SAAQ,aAAa;IAE5C,MAAM,CAAW;IAGjB,MAAM,CAAU,CAAC,+CAA+C;IAGhE,IAAI,CAAa;IAEjB,YAAY,OAIX;QACA,KAAK,EAAE,CAAC;QACR,IAAI,CAAC,IAAI;YACR,OAAO,CAAC,IAAI,YAAY,UAAU;gBACjC,CAAC,CAAC,OAAO,CAAC,IAAI;gBACd,CAAC,CAAC,OAAO,CAAC,IAAI,CAAC,QAAQ,EAAE,CAAC;QAC5B,IAAI,CAAC,MAAM,GAAG,OAAO,CAAC,MAAM,CAAC;QAC7B,IAAI,CAAC,MAAM,GAAG,OAAO,CAAC,MAAM,IAAI,KAAK,CAAC;IACvC,CAAC;IAEO,WAAW,CAAkB;IAErC,KAAK;QACJ,IAAI,IAAI,CAAC,WAAW,EAAE,CAAC;YACtB,OAAO,IAAI,CAAC,WAAW,CAAC;QACzB,CAAC;QAED,OAAO,SAAS,CAAC,IAAI,CAAC,CAAC;IACxB,CAAC;IACD,MAAM,CAAC,IAAI,CAAC,KAAkC;QAC7C,MAAM,GAAG,GAAG,WAAW,CACtB,KAAK,YAAY,UAAU,CAAC,CAAC,CAAC,KAAK,CAAC,CAAC,CAAC,KAAK,CAAC,QAAQ,EAAE,EACtD,YAAU,CACV,CAAC;QACF,IAAI,KAAK,YAAY,cAAc,EAAE,CAAC;YACrC,GAAG,CAAC,WAAW,GAAG,KAAK,CAAC;QACzB,CAAC;QACD,OAAO,GAAG,CAAC;IACZ,CAAC;CACD,CAAA;AAzCA;IADC,KAAK,CAAC,EAAE,IAAI,EAAE,GAAG,CAAC,QAAQ,CAAC,EAAE,CAAC;;0CACd;AAGjB;IADC,KAAK,CAAC,EAAE,IAAI,EAAE,MAAM,EAAE,CAAC;;0CACR;AAGhB;IADC,KAAK,CAAC,EAAE,IAAI,EAAE,UAAU,EAAE,CAAC;8BACtB,UAAU;wCAAC;AARL,UAAU;IADtB,OAAO,CAAC,CAAC,CAAC;;GACE,UAAU,CA2CtB;;AAGM,IAAM,SAAS,iBAAf,MAAM,SAAU,SAAQ,aAAa;IAE3C,MAAM,CAAW;IAGjB,kBAAkB,CAAU;IAE5B,YAAY,OAA0D;QACrE,KAAK,EAAE,CAAC;QACR,IAAI,CAAC,MAAM,GAAG,OAAO,CAAC,MAAM,CAAC;QAC7B,IAAI,CAAC,kBAAkB,GAAG,OAAO,CAAC,kBAAkB,CAAC;IACtD,CAAC;IAEO,WAAW,CAAkB;IAErC,KAAK;QACJ,IAAI,IAAI,CAAC,WAAW,EAAE,CAAC;YACtB,OAAO,IAAI,CAAC,WAAW,CAAC;QACzB,CAAC;QACD,OAAO,SAAS,CAAC,IAAI,CAAC,CAAC;IACxB,CAAC;IACD,MAAM,CAAC,IAAI,CAAC,KAAkC;QAC7C,MAAM,GAAG,GAAG,WAAW,CACtB,KAAK,YAAY,UAAU,CAAC,CAAC,CAAC,KAAK,CAAC,CAAC,CAAC,KAAK,CAAC,QAAQ,EAAE,EACtD,WAAS,CACT,CAAC;QACF,IAAI,KAAK,YAAY,cAAc,EAAE,CAAC;YACrC,GAAG,CAAC,WAAW,GAAG,KAAK,CAAC;QACzB,CAAC;QACD,OAAO,GAAG,CAAC;IACZ,CAAC;CACD,CAAA;AA7BA;IADC,KAAK,CAAC,EAAE,IAAI,EAAE,GAAG,CAAC,QAAQ,CAAC,EAAE,CAAC;;yCACd;AAGjB;IADC,KAAK,CAAC,EAAE,IAAI,EAAE,MAAM,EAAE,CAAC;;qDACI;AALhB,SAAS;IADrB,OAAO,CAAC,CAAC,CAAC;;GACE,SAAS,CA+BrB;;AAGM,IAAM,WAAW,mBAAjB,MAAM,WAAY,SAAQ,aAAa;IAE7C,MAAM,CAAW;IAEjB,YAAY,OAA6B;QACxC,KAAK,EAAE,CAAC;QACR,IAAI,CAAC,MAAM,GAAG,OAAO,CAAC,MAAM,CAAC;IAC9B,CAAC;IAEO,WAAW,CAAkB;IAErC,KAAK;QACJ,IAAI,IAAI,CAAC,WAAW,EAAE,CAAC;YACtB,OAAO,IAAI,CAAC,WAAW,CAAC;QACzB,CAAC;QACD,OAAO,SAAS,CAAC,IAAI,CAAC,CAAC;IACxB,CAAC;IAED,MAAM,CAAC,IAAI,CAAC,KAAkC;QAC7C,MAAM,GAAG,GAAG,WAAW,CACtB,KAAK,YAAY,UAAU,CAAC,CAAC,CAAC,KAAK,CAAC,CAAC,CAAC,KAAK,CAAC,QAAQ,EAAE,EACtD,aAAW,CACX,CAAC;QACF,IAAI,KAAK,YAAY,cAAc,EAAE,CAAC;YACrC,GAAG,CAAC,WAAW,GAAG,KAAK,CAAC;QACzB,CAAC;QACD,OAAO,GAAG,CAAC;IACZ,CAAC;CACD,CAAA;AA1BA;IADC,KAAK,CAAC,EAAE,IAAI,EAAE,GAAG,CAAC,QAAQ,CAAC,EAAE,CAAC;;2CACd;AAFL,WAAW;IADvB,OAAO,CAAC,CAAC,CAAC;;GACE,WAAW,CA4BvB;;AAGM,IAAM,cAAc,sBAApB,MAAM,cAAe,SAAQ,aAAa;IAEhD,MAAM,CAAW;IAEjB,kFAAkF;IAElF,YAAY,OAA6B;QACxC,KAAK,EAAE,CAAC;QACR,IAAI,CAAC,MAAM,GAAG,OAAO,CAAC,MAAM,CAAC;IAC9B,CAAC;IAED,WAAW,CAAkB;IAE7B,KAAK;QACJ,IAAI,IAAI,CAAC,WAAW,EAAE,CAAC;YACtB,OAAO,IAAI,CAAC,WAAW,CAAC;QACzB,CAAC;QACD,OAAO,SAAS,CAAC,IAAI,CAAC,CAAC;IACxB,CAAC;IAED,MAAM,CAAC,IAAI,CAAC,KAAkC;QAC7C,MAAM,GAAG,GAAG,WAAW,CACtB,KAAK,YAAY,UAAU,CAAC,CAAC,CAAC,KAAK,CAAC,CAAC,CAAC,KAAK,CAAC,QAAQ,EAAE,EACtD,gBAAc,CACd,CAAC;QACF,IAAI,KAAK,YAAY,cAAc,EAAE,CAAC;YACrC,GAAG,CAAC,WAAW,GAAG,KAAK,CAAC;QACzB,CAAC;QACD,OAAO,GAAG,CAAC;IACZ,CAAC;CACD,CAAA;AA5BA;IADC,KAAK,CAAC,EAAE,IAAI,EAAE,GAAG,CAAC,QAAQ,CAAC,EAAE,CAAC;;8CACd;AAFL,cAAc;IAD1B,OAAO,CAAC,CAAC,CAAC;;GACE,cAAc,CA8B1B"}
+{"version":3,"file":"messages.js","sourceRoot":"","sources":["../../src/messages.ts"],"names":[],"mappings":";;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;AAAA,OAAO,EAAE,WAAW,EAAE,KAAK,EAAE,SAAS,EAAE,OAAO,EAAE,GAAG,EAAE,MAAM,gBAAgB,CAAC;AAC7E,OAAO,EAAE,cAAc,EAAE,MAAM,gBAAgB,CAAC;AAEhD,MAAM,OAAgB,aAAa;IAElC,MAAM,CAAC,IAAI,CAAC,KAAiB;QAC5B,MAAM,KAAK,GAAG,KAAK,CAAC,CAAC,CAAC,CAAC;QACvB,IAAI,KAAK,KAAK,CAAC,EAAE,CAAC;YACjB,OAAO,UAAU,CAAC,IAAI,CAAC,KAAK,CAAC,CAAC;QAC/B,CAAC;QACD,IAAI,KAAK,KAAK,CAAC,EAAE,CAAC;YACjB,OAAO,SAAS,CAAC,IAAI,CAAC,KAAK,CAAC,CAAC;QAC9B,CAAC;QACD,IAAI,KAAK,KAAK,CAAC,EAAE,CAAC;YACjB,OAAO,WAAW,CAAC,IAAI,CAAC,KAAK,CAAC,CAAC;QAChC,CAAC;QAED,IAAI,KAAK,KAAK,CAAC,EAAE,CAAC;YACjB,OAAO,cAAc,CAAC,IAAI,CAAC,KAAK,CAAC,CAAC;QACnC,CAAC;QAED,MAAM,IAAI,KAAK,CAAC,aAAa,CAAC,CAAC;IAChC,CAAC;CACD;IAGY,UAAU;4BADtB,OAAO,CAAC,CAAC,CAAC;;;;sBACqB,aAAa;;;;;;;;;;0BAArB,SAAQ,WAAa;;;;kCAC3C,KAAK,CAAC,EAAE,IAAI,EAAE,GAAG,CAAC,QAAQ,CAAC,EAAE,CAAC;kCAG9B,KAAK,CAAC,EAAE,IAAI,EAAE,MAAM,EAAE,CAAC;gCAGvB,KAAK,CAAC,EAAE,IAAI,EAAE,UAAU,EAAE,CAAC;YAL5B,oKAAA,MAAM,6BAAN,MAAM,uFAAW;YAGjB,oKAAA,MAAM,6BAAN,MAAM,uFAAU;YAGhB,8JAAA,IAAI,6BAAJ,IAAI,mFAAa;YARlB,6KA2CC;;;YA3CY,uDAAU;;QAEtB,MAAM,yDAAW;QAGjB,MAAM,+GAAU,CAAC,+CAA+C;QAGhE,IAAI,6GAAa;QAEjB,YAAY,OAIX;YACA,KAAK,EAAE,CAAC;YACR,IAAI,CAAC,IAAI;gBACR,OAAO,CAAC,IAAI,YAAY,UAAU;oBACjC,CAAC,CAAC,OAAO,CAAC,IAAI;oBACd,CAAC,CAAC,OAAO,CAAC,IAAI,CAAC,QAAQ,EAAE,CAAC;YAC5B,IAAI,CAAC,MAAM,GAAG,OAAO,CAAC,MAAM,CAAC;YAC7B,IAAI,CAAC,MAAM,GAAG,OAAO,CAAC,MAAM,IAAI,KAAK,CAAC;QACvC,CAAC;QAEO,WAAW,oDAAkB;QAErC,KAAK;YACJ,IAAI,IAAI,CAAC,WAAW,EAAE,CAAC;gBACtB,OAAO,IAAI,CAAC,WAAW,CAAC;YACzB,CAAC;YAED,OAAO,SAAS,CAAC,IAAI,CAAC,CAAC;QACxB,CAAC;QACD,MAAM,CAAC,IAAI,CAAC,KAAkC;YAC7C,MAAM,GAAG,GAAG,WAAW,CACtB,KAAK,YAAY,UAAU,CAAC,CAAC,CAAC,KAAK,CAAC,CAAC,CAAC,KAAK,CAAC,QAAQ,EAAE,EACtD,UAAU,CACV,CAAC;YACF,IAAI,KAAK,YAAY,cAAc,EAAE,CAAC;gBACrC,GAAG,CAAC,WAAW,GAAG,KAAK,CAAC;YACzB,CAAC;YACD,OAAO,GAAG,CAAC;QACZ,CAAC;;;;SA1CW,UAAU;IA8CV,SAAS;4BADrB,OAAO,CAAC,CAAC,CAAC;;;;sBACoB,aAAa;;;;;;;yBAArB,SAAQ,WAAa;;;;kCAC1C,KAAK,CAAC,EAAE,IAAI,EAAE,GAAG,CAAC,QAAQ,CAAC,EAAE,CAAC;8CAG9B,KAAK,CAAC,EAAE,IAAI,EAAE,MAAM,EAAE,CAAC;YAFxB,oKAAA,MAAM,6BAAN,MAAM,uFAAW;YAGjB,wMAAA,kBAAkB,6BAAlB,kBAAkB,+GAAU;YAL7B,6KA+BC;;;YA/BY,uDAAS;;QAErB,MAAM,yDAAW;QAGjB,kBAAkB,2HAAU;QAE5B,YAAY,OAA0D;YACrE,KAAK,EAAE,CAAC;YACR,IAAI,CAAC,MAAM,GAAG,OAAO,CAAC,MAAM,CAAC;YAC7B,IAAI,CAAC,kBAAkB,GAAG,OAAO,CAAC,kBAAkB,CAAC;QACtD,CAAC;QAEO,WAAW,kEAAkB;QAErC,KAAK;YACJ,IAAI,IAAI,CAAC,WAAW,EAAE,CAAC;gBACtB,OAAO,IAAI,CAAC,WAAW,CAAC;YACzB,CAAC;YACD,OAAO,SAAS,CAAC,IAAI,CAAC,CAAC;QACxB,CAAC;QACD,MAAM,CAAC,IAAI,CAAC,KAAkC;YAC7C,MAAM,GAAG,GAAG,WAAW,CACtB,KAAK,YAAY,UAAU,CAAC,CAAC,CAAC,KAAK,CAAC,CAAC,CAAC,KAAK,CAAC,QAAQ,EAAE,EACtD,SAAS,CACT,CAAC;YACF,IAAI,KAAK,YAAY,cAAc,EAAE,CAAC;gBACrC,GAAG,CAAC,WAAW,GAAG,KAAK,CAAC;YACzB,CAAC;YACD,OAAO,GAAG,CAAC;QACZ,CAAC;;;;SA9BW,SAAS;IAkCT,WAAW;4BADvB,OAAO,CAAC,CAAC,CAAC;;;;sBACsB,aAAa;;;;2BAArB,SAAQ,WAAa;;;;kCAC5C,KAAK,CAAC,EAAE,IAAI,EAAE,GAAG,CAAC,QAAQ,CAAC,EAAE,CAAC;YAC/B,oKAAA,MAAM,6BAAN,MAAM,uFAAW;YAFlB,6KA4BC;;;YA5BY,uDAAW;;QAEvB,MAAM,yDAAW;QAEjB,YAAY,OAA6B;YACxC,KAAK,EAAE,CAAC;YACR,IAAI,CAAC,MAAM,GAAG,OAAO,CAAC,MAAM,CAAC;QAC9B,CAAC;QAEO,WAAW,sDAAkB;QAErC,KAAK;YACJ,IAAI,IAAI,CAAC,WAAW,EAAE,CAAC;gBACtB,OAAO,IAAI,CAAC,WAAW,CAAC;YACzB,CAAC;YACD,OAAO,SAAS,CAAC,IAAI,CAAC,CAAC;QACxB,CAAC;QAED,MAAM,CAAC,IAAI,CAAC,KAAkC;YAC7C,MAAM,GAAG,GAAG,WAAW,CACtB,KAAK,YAAY,UAAU,CAAC,CAAC,CAAC,KAAK,CAAC,CAAC,CAAC,KAAK,CAAC,QAAQ,EAAE,EACtD,WAAW,CACX,CAAC;YACF,IAAI,KAAK,YAAY,cAAc,EAAE,CAAC;gBACrC,GAAG,CAAC,WAAW,GAAG,KAAK,CAAC;YACzB,CAAC;YACD,OAAO,GAAG,CAAC;QACZ,CAAC;;;;SA3BW,WAAW;IA+BX,cAAc;4BAD1B,OAAO,CAAC,CAAC,CAAC;;;;sBACyB,aAAa;;;;8BAArB,SAAQ,WAAa;;;;kCAC/C,KAAK,CAAC,EAAE,IAAI,EAAE,GAAG,CAAC,QAAQ,CAAC,EAAE,CAAC;YAC/B,oKAAA,MAAM,6BAAN,MAAM,uFAAW;YAFlB,6KA8BC;;;YA9BY,uDAAc;;QAE1B,MAAM,yDAAW;QAEjB,kFAAkF;QAElF,YAAY,OAA6B;YACxC,KAAK,EAAE,CAAC;YACR,IAAI,CAAC,MAAM,GAAG,OAAO,CAAC,MAAM,CAAC;QAC9B,CAAC;QAED,WAAW,sDAAkB;QAE7B,KAAK;YACJ,IAAI,IAAI,CAAC,WAAW,EAAE,CAAC;gBACtB,OAAO,IAAI,CAAC,WAAW,CAAC;YACzB,CAAC;YACD,OAAO,SAAS,CAAC,IAAI,CAAC,CAAC;QACxB,CAAC;QAED,MAAM,CAAC,IAAI,CAAC,KAAkC;YAC7C,MAAM,GAAG,GAAG,WAAW,CACtB,KAAK,YAAY,UAAU,CAAC,CAAC,CAAC,KAAK,CAAC,CAAC,CAAC,KAAK,CAAC,QAAQ,EAAE,EACtD,cAAc,CACd,CAAC;YACF,IAAI,KAAK,YAAY,cAAc,EAAE,CAAC;gBACrC,GAAG,CAAC,WAAW,GAAG,KAAK,CAAC;YACzB,CAAC;YACD,OAAO,GAAG,CAAC;QACZ,CAAC;;;;SA7BW,cAAc"}

package.json

 {
   "name": "@peerbit/pubsub-interface",
-  "version": "4.0.9",
+  "version": "4.1.0",
   "description": "Block store streaming",
@@ -71,7 +71,7 @@ "type": "module",
   "dependencies": {
-    "@dao-xyz/borsh": "^5.2.3",
-    "@libp2p/interface": "^3.0.0",
+    "@dao-xyz/borsh": "^6.0.0",
+    "@libp2p/interface": "^3.1.0",
     "uint8arraylist": "^2.4.8",
-    "@peerbit/crypto": "2.3.13",
-    "@peerbit/stream-interface": "5.2.10"
+    "@peerbit/crypto": "2.4.0",
+    "@peerbit/stream-interface": "5.3.0"
   },
@@ -78,0 +78,0 @@ "scripts": {

No alert changes

Improved metrics

Total package byte prevSize

61076

38.01%

Lines of code

834

23.74%

Dependency changes

• + Added

  @dao-xyz/borsh@6.0.1
  (transitive)

• + Added

  @peerbit/cache@2.2.0
  (transitive)

• + Added

  @peerbit/crypto@2.4.0
  (transitive)

• + Added

  @peerbit/stream-interface@5.3.0
  (transitive)

• - Removed

  @dao-xyz/borsh@5.2.4
  (transitive)

• - Removed

  @peerbit/cache@2.1.5
  (transitive)

• - Removed

  @peerbit/crypto@2.3.13
  (transitive)

• - Removed

  @peerbit/stream-interface@5.2.10
  (transitive)

• Updated

  @dao-xyz/borsh@^6.0.0

• Updated

  @libp2p/interface@^3.1.0

• Updated

  @peerbit/crypto@2.4.0

• Updated

  @peerbit/stream-interface@5.3.0