ataraxia - npm Package Compare versions

Comparing version 0.9.0 to 0.9.1

dist/cjs/auth/AnonymousAuth.js

 "use strict";
 Object.defineProperty(exports, "__esModule", { value: true });
+exports.AnonymousAuth = void 0;
 var AuthServerFlow_1 = require("./AuthServerFlow");
@@ -4,0 +5,0 @@ /**

dist/cjs/auth/AuthClientFlow.js

 "use strict";
 Object.defineProperty(exports, "__esModule", { value: true });
+exports.AuthClientReplyType = void 0;
 /**
@@ -4,0 +5,0 @@ * Type of reply to send to the server.

dist/cjs/auth/Authentication.js

@@ -14,2 +14,3 @@ "use strict";
 Object.defineProperty(exports, "__esModule", { value: true });
+exports.Authentication = void 0;
 /**
@@ -31,3 +32,3 @@ * Collection of authentication providers.
         },
-        enumerable: true,
+        enumerable: false,
         configurable: true
@@ -34,0 +35,0 @@ });

dist/cjs/auth/AuthServerFlow.js

 "use strict";
 Object.defineProperty(exports, "__esModule", { value: true });
+exports.AuthServerReplyType = void 0;
 /**
@@ -4,0 +5,0 @@ * Type of reply to send to the client.

dist/cjs/auth/index.js

 "use strict";
-function __export(m) {
-    for (var p in m) if (!exports.hasOwnProperty(p)) exports[p] = m[p];
-}
+var __createBinding = (this && this.__createBinding) || (Object.create ? (function(o, m, k, k2) {
+    if (k2 === undefined) k2 = k;
+    Object.defineProperty(o, k2, { enumerable: true, get: function() { return m[k]; } });
+}) : (function(o, m, k, k2) {
+    if (k2 === undefined) k2 = k;
+    o[k2] = m[k];
+}));
+var __exportStar = (this && this.__exportStar) || function(m, exports) {
+    for (var p in m) if (p !== "default" && !Object.prototype.hasOwnProperty.call(exports, p)) __createBinding(exports, m, p);
+};
 Object.defineProperty(exports, "__esModule", { value: true });
-__export(require("./AuthClientFlow"));
-__export(require("./AuthServerFlow"));
-__export(require("./Authentication"));
-__export(require("./AnonymousAuth"));
-__export(require("./SharedSecretAuth"));
+__exportStar(require("./AuthContext"), exports);
+__exportStar(require("./AuthClientFlow"), exports);
+__exportStar(require("./AuthServerFlow"), exports);
+__exportStar(require("./AuthProvider"), exports);
+__exportStar(require("./AuthProvider"), exports);
+__exportStar(require("./Authentication"), exports);
+__exportStar(require("./AnonymousAuth"), exports);
+__exportStar(require("./SharedSecretAuth"), exports);
 //# sourceMappingURL=index.js.map

dist/cjs/auth/SharedSecretAuth.js

@@ -39,2 +39,3 @@ "use strict";
 Object.defineProperty(exports, "__esModule", { value: true });
+exports.SharedSecretAuth = void 0;
 var cbor_1 = require("@stablelib/cbor");
@@ -41,0 +42,0 @@ var fast_sha256_1 = require("fast-sha256");

dist/cjs/BackOff.js

 "use strict";
 Object.defineProperty(exports, "__esModule", { value: true });
+exports.BackOff = void 0;
 /**
@@ -4,0 +5,0 @@ * BackOff implementation to help delaying actions such as resending data or

dist/cjs/exchange/ExchangeImpl.js

 "use strict";
 Object.defineProperty(exports, "__esModule", { value: true });
+exports.ExchangeImpl = void 0;
 var atvik_1 = require("atvik");
@@ -24,3 +25,3 @@ var ExchangeImpl = /** @class */ (function () {
         },
-        enumerable: true,
+        enumerable: false,
         configurable: true
@@ -32,3 +33,3 @@ });
         },
-        enumerable: true,
+        enumerable: false,
         configurable: true
@@ -40,3 +41,3 @@ });
         },
-        enumerable: true,
+        enumerable: false,
         configurable: true
@@ -43,0 +44,0 @@ });

dist/cjs/exchange/Exchanges.js

@@ -53,2 +53,3 @@ "use strict";
 Object.defineProperty(exports, "__esModule", { value: true });
+exports.Exchanges = void 0;
 var debug_1 = __importDefault(require("debug"));
@@ -55,0 +56,0 @@ var SharedExchange_1 = require("./SharedExchange");

dist/cjs/exchange/SharedExchange.js

@@ -53,2 +53,3 @@ "use strict";
 Object.defineProperty(exports, "__esModule", { value: true });
+exports.SharedExchange = void 0;
 var debug_1 = __importDefault(require("debug"));
@@ -55,0 +56,0 @@ /**

dist/cjs/id/IdMap.js

 "use strict";
 Object.defineProperty(exports, "__esModule", { value: true });
+exports.IdMap = void 0;
 var ids_1 = require("./ids");
@@ -4,0 +5,0 @@ var IdMap = /** @class */ (function () {

dist/cjs/id/ids.js

 "use strict";
 Object.defineProperty(exports, "__esModule", { value: true });
+exports.compareId = exports.sameId = exports.noId = exports.generateId = exports.decodeId = exports.encodeId = void 0;
 /*
@@ -4,0 +5,0 @@ * Simple encoding to custom characters.

dist/cjs/id/IdSet.js

@@ -14,2 +14,3 @@ "use strict";
 Object.defineProperty(exports, "__esModule", { value: true });
+exports.IdSet = void 0;
 var ids_1 = require("./ids");
@@ -49,3 +50,3 @@ var IdSet = /** @class */ (function () {
         },
-        enumerable: true,
+        enumerable: false,
         configurable: true
@@ -52,0 +53,0 @@ });

dist/cjs/id/index.js

 "use strict";
-function __export(m) {
-    for (var p in m) if (!exports.hasOwnProperty(p)) exports[p] = m[p];
-}
+var __createBinding = (this && this.__createBinding) || (Object.create ? (function(o, m, k, k2) {
+    if (k2 === undefined) k2 = k;
+    Object.defineProperty(o, k2, { enumerable: true, get: function() { return m[k]; } });
+}) : (function(o, m, k, k2) {
+    if (k2 === undefined) k2 = k;
+    o[k2] = m[k];
+}));
+var __exportStar = (this && this.__exportStar) || function(m, exports) {
+    for (var p in m) if (p !== "default" && !Object.prototype.hasOwnProperty.call(exports, p)) __createBinding(exports, m, p);
+};
 Object.defineProperty(exports, "__esModule", { value: true });
-__export(require("./ids"));
-__export(require("./IdMap"));
-__export(require("./IdSet"));
+__exportStar(require("./ids"), exports);
+__exportStar(require("./IdMap"), exports);
+__exportStar(require("./IdSet"), exports);
 //# sourceMappingURL=index.js.map

dist/cjs/index.js

 "use strict";
-function __export(m) {
-    for (var p in m) if (!exports.hasOwnProperty(p)) exports[p] = m[p];
-}
+var __createBinding = (this && this.__createBinding) || (Object.create ? (function(o, m, k, k2) {
+    if (k2 === undefined) k2 = k;
+    Object.defineProperty(o, k2, { enumerable: true, get: function() { return m[k]; } });
+}) : (function(o, m, k, k2) {
+    if (k2 === undefined) k2 = k;
+    o[k2] = m[k];
+}));
+var __exportStar = (this && this.__exportStar) || function(m, exports) {
+    for (var p in m) if (p !== "default" && !Object.prototype.hasOwnProperty.call(exports, p)) __createBinding(exports, m, p);
+};
 Object.defineProperty(exports, "__esModule", { value: true });
-__export(require("./auth"));
-__export(require("./Network"));
-__export(require("./RequestReplyHelper"));
-__export(require("./BackOff"));
+__exportStar(require("./auth"), exports);
+__exportStar(require("./Network"), exports);
+__exportStar(require("./Node"), exports);
+__exportStar(require("./Message"), exports);
+__exportStar(require("./MessageData"), exports);
+__exportStar(require("./MessageType"), exports);
+__exportStar(require("./MessageUnion"), exports);
+__exportStar(require("./WithNetwork"), exports);
+__exportStar(require("./exchange/Exchange"), exports);
+__exportStar(require("./RequestReplyHelper"), exports);
+__exportStar(require("./BackOff"), exports);
 //# sourceMappingURL=index.js.map

dist/cjs/Network.js

@@ -53,2 +53,3 @@ "use strict";
 Object.defineProperty(exports, "__esModule", { value: true });
+exports.Network = void 0;
 var debug_1 = __importDefault(require("debug"));
@@ -138,3 +139,3 @@ var atvik_1 = require("atvik");
         },
-        enumerable: true,
+        enumerable: false,
         configurable: true
@@ -146,3 +147,3 @@ });
         },
-        enumerable: true,
+        enumerable: false,
         configurable: true
@@ -154,3 +155,3 @@ });
         },
-        enumerable: true,
+        enumerable: false,
         configurable: true
@@ -162,3 +163,3 @@ });
         },
-        enumerable: true,
+        enumerable: false,
         configurable: true
@@ -165,0 +166,0 @@ });

dist/cjs/NetworkNode.js

 "use strict";
 Object.defineProperty(exports, "__esModule", { value: true });
+exports.NetworkNode = void 0;
 var debug_1 = require("debug");
@@ -30,3 +31,3 @@ var util_1 = require("util");
         },
-        enumerable: true,
+        enumerable: false,
         configurable: true
@@ -38,3 +39,3 @@ });
         },
-        enumerable: true,
+        enumerable: false,
         configurable: true
@@ -41,0 +42,0 @@ });

dist/cjs/RequestReplyHelper.js

 "use strict";
 Object.defineProperty(exports, "__esModule", { value: true });
+exports.RequestReplyHelper = void 0;
 /**
@@ -4,0 +5,0 @@ * Helper for managing requests and replies that are identified via a

dist/cjs/test/index.js

 "use strict";
-function __export(m) {
-    for (var p in m) if (!exports.hasOwnProperty(p)) exports[p] = m[p];
-}
+var __createBinding = (this && this.__createBinding) || (Object.create ? (function(o, m, k, k2) {
+    if (k2 === undefined) k2 = k;
+    Object.defineProperty(o, k2, { enumerable: true, get: function() { return m[k]; } });
+}) : (function(o, m, k, k2) {
+    if (k2 === undefined) k2 = k;
+    o[k2] = m[k];
+}));
+var __exportStar = (this && this.__exportStar) || function(m, exports) {
+    for (var p in m) if (p !== "default" && !Object.prototype.hasOwnProperty.call(exports, p)) __createBinding(exports, m, p);
+};
 Object.defineProperty(exports, "__esModule", { value: true });
-__export(require("./TestNetwork"));
-__export(require("./TestPeer"));
-__export(require("./TestTransport"));
+__exportStar(require("./TestNetwork"), exports);
+__exportStar(require("./TestPeer"), exports);
+__exportStar(require("./TestTransport"), exports);
 //# sourceMappingURL=index.js.map

dist/cjs/test/TestNetwork.js

@@ -66,2 +66,3 @@ "use strict";
 Object.defineProperty(exports, "__esModule", { value: true });
+exports.TestNetwork = void 0;
 var Network_1 = require("../Network");
@@ -68,0 +69,0 @@ var TestPeer_1 = require("./TestPeer");

dist/cjs/test/TestPeer.js

@@ -6,6 +6,8 @@ "use strict";
             ({ __proto__: [] } instanceof Array && function (d, b) { d.__proto__ = b; }) ||
-            function (d, b) { for (var p in b) if (b.hasOwnProperty(p)) d[p] = b[p]; };
+            function (d, b) { for (var p in b) if (Object.prototype.hasOwnProperty.call(b, p)) d[p] = b[p]; };
         return extendStatics(d, b);
     };
     return function (d, b) {
+        if (typeof b !== "function" && b !== null)
+            throw new TypeError("Class extends value " + String(b) + " is not a constructor or null");
         extendStatics(d, b);
@@ -17,2 +19,3 @@ function __() { this.constructor = d; }
 Object.defineProperty(exports, "__esModule", { value: true });
+exports.peersBetween = void 0;
 var AbstractPeer_1 = require("../transport/AbstractPeer");
@@ -19,0 +22,0 @@ var DisconnectReason_1 = require("../transport/DisconnectReason");

dist/cjs/test/TestTransport.js

@@ -6,6 +6,8 @@ "use strict";
             ({ __proto__: [] } instanceof Array && function (d, b) { d.__proto__ = b; }) ||
-            function (d, b) { for (var p in b) if (b.hasOwnProperty(p)) d[p] = b[p]; };
+            function (d, b) { for (var p in b) if (Object.prototype.hasOwnProperty.call(b, p)) d[p] = b[p]; };
         return extendStatics(d, b);
     };
     return function (d, b) {
+        if (typeof b !== "function" && b !== null)
+            throw new TypeError("Class extends value " + String(b) + " is not a constructor or null");
         extendStatics(d, b);
@@ -17,2 +19,3 @@ function __() { this.constructor = d; }
 Object.defineProperty(exports, "__esModule", { value: true });
+exports.TestTransport = void 0;
 var transport_1 = require("../transport");
@@ -19,0 +22,0 @@ /**

dist/cjs/topology/index.js

 "use strict";
-function __export(m) {
-    for (var p in m) if (!exports.hasOwnProperty(p)) exports[p] = m[p];
-}
+var __createBinding = (this && this.__createBinding) || (Object.create ? (function(o, m, k, k2) {
+    if (k2 === undefined) k2 = k;
+    Object.defineProperty(o, k2, { enumerable: true, get: function() { return m[k]; } });
+}) : (function(o, m, k, k2) {
+    if (k2 === undefined) k2 = k;
+    o[k2] = m[k];
+}));
+var __exportStar = (this && this.__exportStar) || function(m, exports) {
+    for (var p in m) if (p !== "default" && !Object.prototype.hasOwnProperty.call(exports, p)) __createBinding(exports, m, p);
+};
 Object.defineProperty(exports, "__esModule", { value: true });
-__export(require("./TopologyNode"));
-__export(require("./Topology"));
+__exportStar(require("./TopologyNode"), exports);
+__exportStar(require("./Topology"), exports);
 //# sourceMappingURL=index.js.map

dist/cjs/topology/Messaging.js

@@ -18,5 +18,6 @@ "use strict";
 };
-var __spread = (this && this.__spread) || function () {
-    for (var ar = [], i = 0; i < arguments.length; i++) ar = ar.concat(__read(arguments[i]));
-    return ar;
+var __spreadArray = (this && this.__spreadArray) || function (to, from) {
+    for (var i = 0, il = from.length, j = to.length; i < il; i++, j++)
+        to[j] = from[i];
+    return to;
 };
@@ -38,2 +39,3 @@ var __values = (this && this.__values) || function(o) {
 Object.defineProperty(exports, "__esModule", { value: true });
+exports.Messaging = void 0;
 var debug_1 = __importDefault(require("debug"));
@@ -143,3 +145,3 @@ var id_1 = require("../id");
             var message = {
-                path: __spread(data.path, [
+                path: __spreadArray(__spreadArray([], __read(data.path)), [
                     {
@@ -146,0 +148,0 @@ node: this.routing.self.id,

dist/cjs/topology/Routing.js

@@ -17,2 +17,3 @@ "use strict";
 Object.defineProperty(exports, "__esModule", { value: true });
+exports.Routing = void 0;
 var debug_1 = __importDefault(require("debug"));
@@ -19,0 +20,0 @@ var fibonacci_heap_1 = require("@tyriar/fibonacci-heap");

dist/cjs/topology/Topology.js

@@ -53,2 +53,3 @@ "use strict";
 Object.defineProperty(exports, "__esModule", { value: true });
+exports.Topology = void 0;
 var debug_1 = __importDefault(require("debug"));
@@ -127,3 +128,3 @@ var atvik_1 = require("atvik");
         },
-        enumerable: true,
+        enumerable: false,
         configurable: true
@@ -135,3 +136,3 @@ });
         },
-        enumerable: true,
+        enumerable: false,
         configurable: true
@@ -143,3 +144,3 @@ });
         },
-        enumerable: true,
+        enumerable: false,
         configurable: true
@@ -166,3 +167,3 @@ });
         },
-        enumerable: true,
+        enumerable: false,
         configurable: true
@@ -611,3 +612,3 @@ });
         },
-        enumerable: true,
+        enumerable: false,
         configurable: true
@@ -614,0 +615,0 @@ });

dist/cjs/topology/TopologyNode.js

@@ -14,2 +14,3 @@ "use strict";
 Object.defineProperty(exports, "__esModule", { value: true });
+exports.TopologyNode = void 0;
 var id_1 = require("../id");
@@ -39,3 +40,3 @@ /**
         },
-        enumerable: true,
+        enumerable: false,
         configurable: true
@@ -168,3 +169,3 @@ });
         },
-        enumerable: true,
+        enumerable: false,
         configurable: true
@@ -176,3 +177,3 @@ });
         },
-        enumerable: true,
+        enumerable: false,
         configurable: true
@@ -179,0 +180,0 @@ });

dist/cjs/transport/AbstractPeer.js

@@ -50,2 +50,3 @@ "use strict";
 Object.defineProperty(exports, "__esModule", { value: true });
+exports.AbstractPeer = void 0;
 var debug_1 = require("debug");
@@ -98,3 +99,3 @@ var adaptive_accrual_failure_detector_1 = require("adaptive-accrual-failure-detector");
         },
-        enumerable: true,
+        enumerable: false,
         configurable: true
@@ -106,3 +107,3 @@ });
         },
-        enumerable: true,
+        enumerable: false,
         configurable: true
@@ -114,3 +115,3 @@ });
         },
-        enumerable: true,
+        enumerable: false,
         configurable: true
@@ -122,3 +123,3 @@ });
         },
-        enumerable: true,
+        enumerable: false,
         configurable: true
@@ -753,3 +754,3 @@ });
         },
-        enumerable: true,
+        enumerable: false,
         configurable: true
@@ -756,0 +757,0 @@ });

dist/cjs/transport/AbstractTransport.js

@@ -53,2 +53,3 @@ "use strict";
 Object.defineProperty(exports, "__esModule", { value: true });
+exports.AbstractTransport = void 0;
 var debug_1 = __importDefault(require("debug"));
@@ -77,3 +78,3 @@ var atvik_1 = require("atvik");
         },
-        enumerable: true,
+        enumerable: false,
         configurable: true
@@ -88,3 +89,3 @@ });
         },
-        enumerable: true,
+        enumerable: false,
         configurable: true
@@ -99,3 +100,3 @@ });
         },
-        enumerable: true,
+        enumerable: false,
         configurable: true
@@ -113,3 +114,3 @@ });
         },
-        enumerable: true,
+        enumerable: false,
         configurable: true
@@ -116,0 +117,0 @@ });

dist/cjs/transport/binary/binaryStreams.js

@@ -6,6 +6,8 @@ "use strict";
             ({ __proto__: [] } instanceof Array && function (d, b) { d.__proto__ = b; }) ||
-            function (d, b) { for (var p in b) if (b.hasOwnProperty(p)) d[p] = b[p]; };
+            function (d, b) { for (var p in b) if (Object.prototype.hasOwnProperty.call(b, p)) d[p] = b[p]; };
         return extendStatics(d, b);
     };
     return function (d, b) {
+        if (typeof b !== "function" && b !== null)
+            throw new TypeError("Class extends value " + String(b) + " is not a constructor or null");
         extendStatics(d, b);
@@ -17,2 +19,3 @@ function __() { this.constructor = d; }
 Object.defineProperty(exports, "__esModule", { value: true });
+exports.encodePeerPacket = exports.PeerPacketDecodingStream = void 0;
 var stream_1 = require("stream");
@@ -19,0 +22,0 @@ var decodeBinaryPeerMessage_1 = require("./decodeBinaryPeerMessage");

dist/cjs/transport/binary/decodeBinaryPeerMessage.js

 "use strict";
 Object.defineProperty(exports, "__esModule", { value: true });
+exports.decodeBinaryPeerMessage = void 0;
 var cbor_1 = require("@stablelib/cbor");
@@ -4,0 +5,0 @@ var messages_1 = require("../messages");

dist/cjs/transport/binary/encodeBinaryPeerMessage.js

@@ -18,5 +18,6 @@ "use strict";
 };
-var __spread = (this && this.__spread) || function () {
-    for (var ar = [], i = 0; i < arguments.length; i++) ar = ar.concat(__read(arguments[i]));
-    return ar;
+var __spreadArray = (this && this.__spreadArray) || function (to, from) {
+    for (var i = 0, il = from.length, j = to.length; i < il; i++, j++)
+        to[j] = from[i];
+    return to;
 };
@@ -35,2 +36,3 @@ var __values = (this && this.__values) || function(o) {
 Object.defineProperty(exports, "__esModule", { value: true });
+exports.encodeBinaryPeerMessage = void 0;
 var cbor_1 = require("@stablelib/cbor");
@@ -65,3 +67,3 @@ var messages_1 = require("../messages");
             encoder.encodeBytes(new Uint8Array(helloMessage.id));
-            encoder.encodeArray(__spread(helloMessage.capabilities));
+            encoder.encodeArray(__spreadArray([], __read(helloMessage.capabilities)));
             break;
@@ -72,3 +74,3 @@ case messages_1.PeerMessageType.Select:
             encoder.encodeBytes(new Uint8Array(selectMessage.id));
-            encoder.encodeArray(__spread(selectMessage.capabilities));
+            encoder.encodeArray(__spreadArray([], __read(selectMessage.capabilities)));
             break;
@@ -75,0 +77,0 @@ case messages_1.PeerMessageType.Auth:

dist/cjs/transport/binary/index.js

 "use strict";
-function __export(m) {
-    for (var p in m) if (!exports.hasOwnProperty(p)) exports[p] = m[p];
-}
+var __createBinding = (this && this.__createBinding) || (Object.create ? (function(o, m, k, k2) {
+    if (k2 === undefined) k2 = k;
+    Object.defineProperty(o, k2, { enumerable: true, get: function() { return m[k]; } });
+}) : (function(o, m, k, k2) {
+    if (k2 === undefined) k2 = k;
+    o[k2] = m[k];
+}));
+var __exportStar = (this && this.__exportStar) || function(m, exports) {
+    for (var p in m) if (p !== "default" && !Object.prototype.hasOwnProperty.call(exports, p)) __createBinding(exports, m, p);
+};
 Object.defineProperty(exports, "__esModule", { value: true });
-__export(require("./decodeBinaryPeerMessage"));
-__export(require("./encodeBinaryPeerMessage"));
-__export(require("./binaryStreams"));
+__exportStar(require("./decodeBinaryPeerMessage"), exports);
+__exportStar(require("./encodeBinaryPeerMessage"), exports);
+__exportStar(require("./binaryStreams"), exports);
 //# sourceMappingURL=index.js.map

dist/cjs/transport/binary/tags.js

 "use strict";
 Object.defineProperty(exports, "__esModule", { value: true });
+exports.TAG_NODE_DETAILS = exports.TAG_NODE_REQUEST = exports.TAG_NODE_SUMMARY = exports.TAG_BYE = exports.TAG_BEGIN = exports.TAG_AUTH_DATA = exports.TAG_AUTH = exports.TAG_SELECT = exports.TAG_HELLO = exports.TAG_REJECT = exports.TAG_OK = exports.TAG_DATA_REJECT = exports.TAG_DATA_ACK = exports.TAG_DATA = exports.TAG_PONG = exports.TAG_PING = void 0;
 exports.TAG_PING = 0;
@@ -4,0 +5,0 @@ exports.TAG_PONG = 1;

dist/cjs/transport/DisconnectReason.js

 "use strict";
 Object.defineProperty(exports, "__esModule", { value: true });
+exports.DisconnectReason = void 0;
 /**
@@ -4,0 +5,0 @@ * Reason for a disconnect. Used to flag why a peer was disconnected so a

dist/cjs/transport/index.js

 "use strict";
-function __export(m) {
-    for (var p in m) if (!exports.hasOwnProperty(p)) exports[p] = m[p];
-}
+var __createBinding = (this && this.__createBinding) || (Object.create ? (function(o, m, k, k2) {
+    if (k2 === undefined) k2 = k;
+    Object.defineProperty(o, k2, { enumerable: true, get: function() { return m[k]; } });
+}) : (function(o, m, k, k2) {
+    if (k2 === undefined) k2 = k;
+    o[k2] = m[k];
+}));
+var __exportStar = (this && this.__exportStar) || function(m, exports) {
+    for (var p in m) if (p !== "default" && !Object.prototype.hasOwnProperty.call(exports, p)) __createBinding(exports, m, p);
+};
 Object.defineProperty(exports, "__esModule", { value: true });
-__export(require("./AbstractTransport"));
-__export(require("./messages"));
-__export(require("./binary"));
-__export(require("./DisconnectReason"));
-__export(require("./AbstractPeer"));
-__export(require("./StreamingPeer"));
-__export(require("./MergeablePeer"));
+__exportStar(require("./Transport"), exports);
+__exportStar(require("./AbstractTransport"), exports);
+__exportStar(require("./TransportOptions"), exports);
+__exportStar(require("./messages"), exports);
+__exportStar(require("./binary"), exports);
+__exportStar(require("./DisconnectReason"), exports);
+__exportStar(require("./Peer"), exports);
+__exportStar(require("./AbstractPeer"), exports);
+__exportStar(require("./StreamingPeer"), exports);
+__exportStar(require("./MergeablePeer"), exports);
 //# sourceMappingURL=index.js.map

dist/cjs/transport/MergeablePeer.js

 "use strict";
 Object.defineProperty(exports, "__esModule", { value: true });
+exports.isMergeablePeer = void 0;
 /**
@@ -4,0 +5,0 @@ * Get if we can treat the peer as mergeable.

dist/cjs/transport/messages/index.js

 "use strict";
-function __export(m) {
-    for (var p in m) if (!exports.hasOwnProperty(p)) exports[p] = m[p];
-}
+var __createBinding = (this && this.__createBinding) || (Object.create ? (function(o, m, k, k2) {
+    if (k2 === undefined) k2 = k;
+    Object.defineProperty(o, k2, { enumerable: true, get: function() { return m[k]; } });
+}) : (function(o, m, k, k2) {
+    if (k2 === undefined) k2 = k;
+    o[k2] = m[k];
+}));
+var __exportStar = (this && this.__exportStar) || function(m, exports) {
+    for (var p in m) if (p !== "default" && !Object.prototype.hasOwnProperty.call(exports, p)) __createBinding(exports, m, p);
+};
 Object.defineProperty(exports, "__esModule", { value: true });
-__export(require("./PeerMessageType"));
+__exportStar(require("./PeerMessageType"), exports);
+__exportStar(require("./PeerMessage"), exports);
+__exportStar(require("./HelloMessage"), exports);
+__exportStar(require("./SelectMessage"), exports);
+__exportStar(require("./AuthMessage"), exports);
+__exportStar(require("./AuthDataMessage"), exports);
+__exportStar(require("./NodeSummaryMessage"), exports);
+__exportStar(require("./NodeRequestMessage"), exports);
+__exportStar(require("./NodeDetailsMessage"), exports);
+__exportStar(require("./DataMessage"), exports);
 //# sourceMappingURL=index.js.map

dist/cjs/transport/messages/PeerMessageType.js

 "use strict";
 Object.defineProperty(exports, "__esModule", { value: true });
+exports.PeerMessageType = void 0;
 /**
@@ -4,0 +5,0 @@ * The types of data that a peer can send and receive.

dist/cjs/transport/StreamingPeer.js

@@ -6,6 +6,8 @@ "use strict";
             ({ __proto__: [] } instanceof Array && function (d, b) { d.__proto__ = b; }) ||
-            function (d, b) { for (var p in b) if (b.hasOwnProperty(p)) d[p] = b[p]; };
+            function (d, b) { for (var p in b) if (Object.prototype.hasOwnProperty.call(b, p)) d[p] = b[p]; };
         return extendStatics(d, b);
     };
     return function (d, b) {
+        if (typeof b !== "function" && b !== null)
+            throw new TypeError("Class extends value " + String(b) + " is not a constructor or null");
         extendStatics(d, b);
@@ -17,2 +19,3 @@ function __() { this.constructor = d; }
 Object.defineProperty(exports, "__esModule", { value: true });
+exports.StreamingPeer = void 0;
 var AbstractPeer_1 = require("./AbstractPeer");
@@ -19,0 +22,0 @@ var PeerMessageType_1 = require("./messages/PeerMessageType");

dist/esm/auth/AuthContext.js

@@ -0,1 +1,2 @@
+export {};
 //# sourceMappingURL=AuthContext.js.map

dist/esm/auth/AuthProvider.js

@@ -0,1 +1,2 @@
+export {};
 //# sourceMappingURL=AuthProvider.js.map

dist/esm/auth/index.js

@@ -0,3 +1,6 @@
+export * from './AuthContext';
 export * from './AuthClientFlow';
 export * from './AuthServerFlow';
+export * from './AuthProvider';
+export * from './AuthProvider';
 export * from './Authentication';
@@ -4,0 +7,0 @@ export * from './AnonymousAuth';

dist/esm/exchange/Exchange.js

@@ -0,1 +1,2 @@
+export {};
 //# sourceMappingURL=Exchange.js.map

dist/esm/exchange/ExchangeJoin.js

@@ -0,1 +1,2 @@
+export {};
 //# sourceMappingURL=ExchangeJoin.js.map

dist/esm/exchange/ExchangeLeave.js

@@ -0,1 +1,2 @@
+export {};
 //# sourceMappingURL=ExchangeLeave.js.map

dist/esm/exchange/ExchangeList.js

@@ -0,1 +1,2 @@
+export {};
 //# sourceMappingURL=ExchangeList.js.map

dist/esm/exchange/ExchangeMessages.js

@@ -0,1 +1,2 @@
+export {};
 //# sourceMappingURL=ExchangeMessages.js.map

dist/esm/index.js

 export * from './auth';
 export * from './Network';
+export * from './Node';
+export * from './Message';
+export * from './MessageData';
+export * from './MessageType';
+export * from './MessageUnion';
+export * from './WithNetwork';
+export * from './exchange/Exchange';
 export * from './RequestReplyHelper';
 export * from './BackOff';
 //# sourceMappingURL=index.js.map

dist/esm/Message.js

@@ -0,1 +1,2 @@
+export {};
 //# sourceMappingURL=Message.js.map

dist/esm/MessageData.js

@@ -0,1 +1,2 @@
+export {};
 //# sourceMappingURL=MessageData.js.map

dist/esm/MessageType.js

@@ -0,1 +1,2 @@
+export {};
 //# sourceMappingURL=MessageType.js.map

dist/esm/MessageUnion.js

@@ -0,1 +1,2 @@
+export {};
 //# sourceMappingURL=MessageUnion.js.map

dist/esm/Node.js

@@ -0,1 +1,2 @@
+export {};
 //# sourceMappingURL=Node.js.map

dist/esm/transport/index.js

@@ -0,5 +1,8 @@
+export * from './Transport';
 export * from './AbstractTransport';
+export * from './TransportOptions';
 export * from './messages';
 export * from './binary';
 export * from './DisconnectReason';
+export * from './Peer';
 export * from './AbstractPeer';
@@ -6,0 +9,0 @@ export * from './StreamingPeer';

dist/esm/transport/messages/AuthDataMessage.js

@@ -0,1 +1,2 @@
+export {};
 //# sourceMappingURL=AuthDataMessage.js.map

dist/esm/transport/messages/AuthMessage.js

@@ -0,1 +1,2 @@
+export {};
 //# sourceMappingURL=AuthMessage.js.map

dist/esm/transport/messages/DataMessage.js

@@ -0,1 +1,2 @@
+export {};
 //# sourceMappingURL=DataMessage.js.map

dist/esm/transport/messages/HelloMessage.js

@@ -0,1 +1,2 @@
+export {};
 //# sourceMappingURL=HelloMessage.js.map

dist/esm/transport/messages/index.js

 export * from './PeerMessageType';
+export * from './PeerMessage';
+export * from './HelloMessage';
+export * from './SelectMessage';
+export * from './AuthMessage';
+export * from './AuthDataMessage';
+export * from './NodeSummaryMessage';
+export * from './NodeRequestMessage';
+export * from './NodeDetailsMessage';
+export * from './DataMessage';
 //# sourceMappingURL=index.js.map

dist/esm/transport/messages/NodeDetailsMessage.js

@@ -0,1 +1,2 @@
+export {};
 //# sourceMappingURL=NodeDetailsMessage.js.map

dist/esm/transport/messages/NodeRequestMessage.js

@@ -0,1 +1,2 @@
+export {};
 //# sourceMappingURL=NodeRequestMessage.js.map

dist/esm/transport/messages/NodeSummaryMessage.js

@@ -0,1 +1,2 @@
+export {};
 //# sourceMappingURL=NodeSummaryMessage.js.map

dist/esm/transport/messages/SelectMessage.js

@@ -0,1 +1,2 @@
+export {};
 //# sourceMappingURL=SelectMessage.js.map

dist/esm/transport/Peer.js

@@ -0,1 +1,2 @@
+export {};
 //# sourceMappingURL=Peer.js.map

dist/esm/transport/Transport.js

@@ -0,1 +1,2 @@
+export {};
 //# sourceMappingURL=Transport.js.map

dist/esm/transport/TransportOptions.js

@@ -0,1 +1,2 @@
+export {};
 //# sourceMappingURL=TransportOptions.js.map

dist/esm/WithNetwork.js

@@ -0,1 +1,2 @@
+export {};
 //# sourceMappingURL=WithNetwork.js.map

dist/types/exchange/ExchangeImpl.d.ts

@@ -5,2 +5,3 @@ import { Node } from '../Node';
 import { MessageType } from '../MessageType';
+import { MessageUnion } from '../MessageUnion';
 import { Exchange } from './Exchange';
@@ -35,3 +36,3 @@ import { SharedExchange } from './SharedExchange';
     get onNodeUnavailable(): import("atvik").Subscribable<this, [Node<MessageTypes>]>;
-    get onMessage(): import("atvik").Subscribable<this, [{ [P in keyof MessageTypes]: P extends string ? Message<MessageTypes, P> : never; }[keyof MessageTypes]]>;
+    get onMessage(): import("atvik").Subscribable<this, [MessageUnion<MessageTypes>]>;
     broadcast<T extends MessageType<MessageTypes>>(type: T, payload: MessageData<MessageTypes, T>): Promise<void>;
@@ -38,0 +39,0 @@ join(): Promise<void>;

dist/types/Network.d.ts

 import { Transport } from './transport';
 import { Node } from './Node';
+import { MessageUnion } from './MessageUnion';
 import { MessageType } from './MessageType';
@@ -87,3 +88,3 @@ import { MessageData } from './MessageData';
     get onNodeUnavailable(): import("atvik").Subscribable<this, [Node<MessageTypes>]>;
-    get onMessage(): import("atvik").Subscribable<this, [{ [P in keyof MessageTypes]: P extends string ? import("./Message").Message<MessageTypes, P> : never; }[keyof MessageTypes]]>;
+    get onMessage(): import("atvik").Subscribable<this, [MessageUnion<MessageTypes>]>;
     get networkId(): string;
@@ -90,0 +91,0 @@ /**

package.json

 {
   "name": "ataraxia",
-  "version": "0.9.0",
+  "version": "0.9.1",
   "description": "P2P messaging over mesh networks",
@@ -43,3 +43,3 @@ "license": "MIT",
   },
-  "gitHead": "05cd2a79c8b45c1695eeb9a189c005f66e920266"
+  "gitHead": "1a70dd05579c4c0a380d28e9686d8125ac6cdc68"
 }

New alerts

License Policy Violation

License

This package is not allowed per your license policy. Review the package's license to ensure compliance.

Found 1 instance in 1 package

Fixed alerts

License Policy Violation

License

This package is not allowed per your license policy. Review the package's license to ensure compliance.

Found 1 instance in 1 package

Improved metrics

Lines of code

15756

increased by1.08%

Worsened metrics

Total package byte prevSize

822065

decreased by-13.35%

Number of package files

469

decreased by-0.21%

No dependency changes