@pioneer-platform/pioneer-events - npm Package Compare versions

Comparing version 8.1.29 to 8.1.30

lib/index.js

 "use strict";
-var __awaiter = (this && this.__awaiter) || function (thisArg, _arguments, P, generator) {
-    function adopt(value) { return value instanceof P ? value : new P(function (resolve) { resolve(value); }); }
-    return new (P || (P = Promise))(function (resolve, reject) {
-        function fulfilled(value) { try { step(generator.next(value)); } catch (e) { reject(e); } }
-        function rejected(value) { try { step(generator["throw"](value)); } catch (e) { reject(e); } }
-        function step(result) { result.done ? resolve(result.value) : adopt(result.value).then(fulfilled, rejected); }
-        step((generator = generator.apply(thisArg, _arguments || [])).next());
-    });
-};
-var __generator = (this && this.__generator) || function (thisArg, body) {
-    var _ = { label: 0, sent: function() { if (t[0] & 1) throw t[1]; return t[1]; }, trys: [], ops: [] }, f, y, t, g;
-    return g = { next: verb(0), "throw": verb(1), "return": verb(2) }, typeof Symbol === "function" && (g[Symbol.iterator] = function() { return this; }), g;
-    function verb(n) { return function (v) { return step([n, v]); }; }
-    function step(op) {
-        if (f) throw new TypeError("Generator is already executing.");
-        while (_) try {
-            if (f = 1, y && (t = op[0] & 2 ? y["return"] : op[0] ? y["throw"] || ((t = y["return"]) && t.call(y), 0) : y.next) && !(t = t.call(y, op[1])).done) return t;
-            if (y = 0, t) op = [op[0] & 2, t.value];
-            switch (op[0]) {
-                case 0: case 1: t = op; break;
-                case 4: _.label++; return { value: op[1], done: false };
-                case 5: _.label++; y = op[1]; op = [0]; continue;
-                case 7: op = _.ops.pop(); _.trys.pop(); continue;
-                default:
-                    if (!(t = _.trys, t = t.length > 0 && t[t.length - 1]) && (op[0] === 6 || op[0] === 2)) { _ = 0; continue; }
-                    if (op[0] === 3 && (!t || (op[1] > t[0] && op[1] < t[3]))) { _.label = op[1]; break; }
-                    if (op[0] === 6 && _.label < t[1]) { _.label = t[1]; t = op; break; }
-                    if (t && _.label < t[2]) { _.label = t[2]; _.ops.push(op); break; }
-                    if (t[2]) _.ops.pop();
-                    _.trys.pop(); continue;
-            }
-            op = body.call(thisArg, _);
-        } catch (e) { op = [6, e]; y = 0; } finally { f = t = 0; }
-        if (op[0] & 5) throw op[1]; return { value: op[0] ? op[1] : void 0, done: true };
-    }
-};
 Object.defineProperty(exports, "__esModule", { value: true });
 exports.Events = void 0;
-var TAG = " | ws-client | ";
-var log = require("@pioneer-platform/loggerdog")();
-var EventEmitter = require('events');
-var io = require('socket.io-client');
-var wait = require('wait-promise');
-var sleep = wait.sleep;
-var Events = /** @class */ (function () {
-    function Events(config) {
+const TAG = " | ws-client | ";
+const log = require("@pioneer-platform/loggerdog")();
+const EventEmitter = require('events');
+const io = require('socket.io-client');
+const wait = require('wait-promise');
+const sleep = wait.sleep;
+class Events {
+    constructor(config) {
         this.wss = config.wss;
@@ -55,170 +19,125 @@ this.isConnected = false;
         this.events = new EventEmitter();
-        this.init = function () {
-            return __awaiter(this, void 0, void 0, function () {
-                var tag, e_1;
-                var _this = this;
-                return __generator(this, function (_a) {
-                    switch (_a.label) {
-                        case 0:
-                            tag = TAG + " | init_events | ";
-                            _a.label = 1;
-                        case 1:
-                            _a.trys.push([1, 5, , 6]);
-                            this.socket = io.connect(this.wss, {
-                                reconnect: true,
-                                rejectUnauthorized: false
-                            });
-                            //sub
-                            this.socket.on('connect', function () {
-                                log.debug(tag, 'Connected to ' + _this.wss);
-                                _this.isConnected = true;
-                                //rejoin
-                                if (_this.username) {
-                                    _this.pair();
-                                }
-                                else {
-                                    _this.subscribeToKey();
-                                }
-                            });
-                            this.socket.on('subscribedToUsername', function (event) {
-                                log.debug(tag, 'subscribed to ' + event.username, " id: " + event.socketId);
-                                _this.isPaired = true;
-                                _this.username = event.username;
-                            });
-                            this.socket.on('message', function (message) {
-                                //TODO only emit expected messages?
-                                //if(message.type === "payment_request"){}
-                                _this.events.emit('message', message);
-                            });
-                            this.socket.on('blocks', function (message) {
-                                //TODO only emit expected messages?
-                                //if(message.type === "payment_request"){}
-                                _this.events.emit('message', message);
-                            });
-                            //sub to errors
-                            this.socket.on('errorMessage', function (message) {
-                                log.error(tag, "error: ", message);
-                                if (message.code && message.code === 6)
-                                    throw Error(" Failed to connect!");
-                            });
-                            this.socket.on('invocation', function (message) {
-                                log.debug('invocation: ', message);
-                                _this.events.emit('message', message);
-                            });
-                            _a.label = 2;
-                        case 2:
-                            if (!!this.isConnected) return [3 /*break*/, 4];
-                            return [4 /*yield*/, sleep(300)];
-                        case 3:
-                            _a.sent();
-                            return [3 /*break*/, 2];
-                        case 4: return [2 /*return*/, true];
-                        case 5:
-                            e_1 = _a.sent();
-                            log.error(tag, e_1);
-                            throw e_1;
-                        case 6: return [2 /*return*/];
-                    }
+        this.init = async function () {
+            let tag = TAG + " | init_events | ";
+            try {
+                this.socket = io.connect(this.wss, {
+                    reconnect: true,
+                    rejectUnauthorized: false
                 });
-            });
-        };
-        this.setUsername = function (username) {
-            return __awaiter(this, void 0, void 0, function () {
-                var tag;
-                return __generator(this, function (_a) {
-                    tag = TAG + " | startSocket | ";
-                    try {
-                        this.username = username;
+                //sub
+                this.socket.on('connect', () => {
+                    log.debug(tag, 'Connected to ' + this.wss);
+                    this.isConnected = true;
+                    //rejoin
+                    if (this.username) {
+                        this.pair();
                     }
-                    catch (e) {
-                        log.error(tag, "e: ", e);
+                    else {
+                        this.subscribeToKey();
                     }
-                    return [2 /*return*/];
                 });
-            });
-        };
-        this.subscribeToInvocation = function (invocationId) {
-            return __awaiter(this, void 0, void 0, function () {
-                var tag;
-                return __generator(this, function (_a) {
-                    tag = TAG + " | subscribeToInvocation | ";
-                    try {
-                        //attempt join
-                        this.socket.emit('join', {
-                            invocationId: invocationId
-                        });
-                        return [2 /*return*/, true];
-                    }
-                    catch (e) {
-                        log.error(tag, "e: ", e);
-                        throw e;
-                    }
-                    return [2 /*return*/];
+                this.socket.on('subscribedToUsername', (event) => {
+                    log.debug(tag, 'subscribed to ' + event.username, " id: " + event.socketId);
+                    this.isPaired = true;
+                    this.username = event.username;
                 });
-            });
+                this.socket.on('message', (message) => {
+                    //TODO only emit expected messages?
+                    //if(message.type === "payment_request"){}
+                    this.events.emit('message', message);
+                });
+                this.socket.on('blocks', (message) => {
+                    //TODO only emit expected messages?
+                    //if(message.type === "payment_request"){}
+                    this.events.emit('blocks', message);
+                });
+                //sub to errors
+                this.socket.on('errorMessage', function (message) {
+                    log.error(tag, "error: ", message);
+                    if (message.code && message.code === 6)
+                        throw Error(" Failed to connect!");
+                });
+                this.socket.on('invocations', (message) => {
+                    log.debug('invocation: ', message);
+                    this.events.emit('invocations', message);
+                });
+                //dont release to connect
+                while (!this.isConnected) {
+                    await sleep(300);
+                }
+                return true;
+            }
+            catch (e) {
+                log.error(tag, e);
+                throw e;
+            }
         };
-        this.subscribeToKey = function () {
-            return __awaiter(this, void 0, void 0, function () {
-                var tag;
-                return __generator(this, function (_a) {
-                    tag = TAG + " | subscribeToKey | ";
-                    try {
-                        //attempt join
-                        this.socket.emit('join', {
-                            queryKey: config.queryKey
-                        });
-                        return [2 /*return*/, true];
-                    }
-                    catch (e) {
-                        log.error(tag, "e: ", e);
-                        throw e;
-                    }
-                    return [2 /*return*/];
+        this.setUsername = async function (username) {
+            let tag = TAG + " | startSocket | ";
+            try {
+                this.username = username;
+            }
+            catch (e) {
+                log.error(tag, "e: ", e);
+            }
+        };
+        this.subscribeToInvocation = async function (invocationId) {
+            let tag = TAG + " | subscribeToInvocation | ";
+            try {
+                //attempt join
+                this.socket.emit('join', {
+                    invocationId
                 });
-            });
+                return true;
+            }
+            catch (e) {
+                log.error(tag, "e: ", e);
+                throw e;
+            }
         };
-        this.pair = function (username) {
-            return __awaiter(this, void 0, void 0, function () {
-                var tag;
-                return __generator(this, function (_a) {
-                    tag = TAG + " | startSocket | ";
-                    try {
-                        if (username)
-                            this.username = username;
-                        if (!this.username)
-                            throw Error("103: can not pair without username!");
-                        //attempt join
-                        this.socket.emit('join', {
-                            username: this.username,
-                            queryKey: config.queryKey
-                        });
-                        //TODO validate paired?
-                        return [2 /*return*/, true];
-                    }
-                    catch (e) {
-                        log.error(tag, "e: ", e);
-                        throw e;
-                    }
-                    return [2 /*return*/];
+        this.subscribeToKey = async function () {
+            let tag = TAG + " | subscribeToKey | ";
+            try {
+                //attempt join
+                this.socket.emit('join', {
+                    queryKey: config.queryKey
                 });
-            });
+                return true;
+            }
+            catch (e) {
+                log.error(tag, "e: ", e);
+                throw e;
+            }
         };
-        this.disconnect = function () {
-            return __awaiter(this, void 0, void 0, function () {
-                var tag;
-                return __generator(this, function (_a) {
-                    tag = TAG + " | disconnect | ";
-                    try {
-                        return [2 /*return*/, this.socket.disconnect()];
-                    }
-                    catch (e) {
-                        log.error(tag, "e: ", e);
-                    }
-                    return [2 /*return*/];
+        this.pair = async function (username) {
+            let tag = TAG + " | startSocket | ";
+            try {
+                if (username)
+                    this.username = username;
+                if (!this.username)
+                    throw Error("103: can not pair without username!");
+                //attempt join
+                this.socket.emit('join', {
+                    username: this.username,
+                    queryKey: config.queryKey
                 });
-            });
+                //TODO validate paired?
+                return true;
+            }
+            catch (e) {
+                log.error(tag, "e: ", e);
+                throw e;
+            }
         };
+        this.disconnect = async function () {
+            let tag = TAG + " | disconnect | ";
+            try {
+                return this.socket.disconnect();
+            }
+            catch (e) {
+                log.error(tag, "e: ", e);
+            }
+        };
     }
-    return Events;
-}());
+}
 exports.Events = Events;

package.json

 {
   "name": "@pioneer-platform/pioneer-events",
-  "version": "8.1.29",
+  "version": "8.1.30",
   "main": "./lib/index.js",
@@ -31,3 +31,3 @@ "types": "./lib/main.d.ts",
   },
-  "gitHead": "54c5830a9aebf63dc437dd0cdd4bd3ea3edb253f"
+  "gitHead": "d0e74ea447175d6d7e9697793093f9155f0dab38"
 }

tsconfig.json

 {
   "compilerOptions": {
-    "target": "es5",
+    "target": "es2018",
     "module": "commonjs",
@@ -5,0 +5,0 @@ "lib": ["es6", "es2015", "dom"],

New alerts

No License Found

License

(Experimental) License information could not be found.

Found 1 instance in 1 package

Fixed alerts

Copyleft License

License

(Experimental) Copyleft license information was found.

Found 1 instance in 1 package

Non-permissive License

License

(Experimental) A license not known to be considered permissive was found.

Found 1 instance in 1 package

Improved metrics

Number of low license alerts

1

decreased by-50%

License quality

100

increased by42.86%

Worsened metrics

Total package byte prevSize

6742

decreased by-85.75%

Number of package files

4

decreased by-20%

Lines of code

174

decreased by-31.76%

No dependency changes