@0x/mesh-rpc-client - npm Package Compare versions

Comparing version 9.4.0 to 10.0.0-unstable

lib/src/index.js

 "use strict";
 Object.defineProperty(exports, "__esModule", { value: true });
 var ws_client_1 = require("./ws_client");
-exports.WSClient = ws_client_1.WSClient;
+Object.defineProperty(exports, "WSClient", { enumerable: true, get: function () { return ws_client_1.WSClient; } });
 var types_1 = require("./types");
-exports.OrderEventEndState = types_1.OrderEventEndState;
-exports.RejectedKind = types_1.RejectedKind;
-exports.RejectedCode = types_1.RejectedCode;
+Object.defineProperty(exports, "OrderEventEndState", { enumerable: true, get: function () { return types_1.OrderEventEndState; } });
+Object.defineProperty(exports, "RejectedKind", { enumerable: true, get: function () { return types_1.RejectedKind; } });
+Object.defineProperty(exports, "RejectedCode", { enumerable: true, get: function () { return types_1.RejectedCode; } });
 var utils_1 = require("@0x/utils");
-exports.BigNumber = utils_1.BigNumber;
+Object.defineProperty(exports, "BigNumber", { enumerable: true, get: function () { return utils_1.BigNumber; } });
 //# sourceMappingURL=index.js.map

lib/src/types.d.ts

@@ -329,9 +329,7 @@ import { SignedOrder } from '@0x/types';
 export interface RawGetOrdersResponse {
-    snapshotID: string;
-    snapshotTimestamp: string;
+    timestamp: string;
     ordersInfos: RawAcceptedOrderInfo[];
 }
 export interface GetOrdersResponse {
-    snapshotID: string;
-    snapshotTimestamp: number;
+    timestamp: number;
     ordersInfos: OrderInfo[];
@@ -338,0 +336,0 @@ }

lib/src/types.js

 "use strict";
 Object.defineProperty(exports, "__esModule", { value: true });
+exports.RejectedCode = exports.RejectedKind = exports.OrderEventEndState = exports.ContractEventKind = void 0;
 var utils_1 = require("@0x/utils");
-exports.BigNumber = utils_1.BigNumber;
+Object.defineProperty(exports, "BigNumber", { enumerable: true, get: function () { return utils_1.BigNumber; } });
 var ContractEventKind;
@@ -6,0 +7,0 @@ (function (ContractEventKind) {

lib/src/ws_client.d.ts

@@ -48,3 +48,3 @@ import { SignedOrder } from '@0x/types';
      */
-    getOrdersForPageAsync(page: number, perPage?: number, snapshotID?: string): Promise<GetOrdersResponse>;
+    getOrdersForPageAsync(perPage?: number, minOrderHash?: string): Promise<GetOrdersResponse>;
     /**
@@ -51,0 +51,0 @@ * Subscribe to the 'orders' topic and receive order events from Mesh. This method returns a

lib/src/ws_client.js

@@ -14,6 +14,7 @@ "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) : new P(function (resolve) { resolve(result.value); }).then(fulfilled, rejected); }
+        function step(result) { result.done ? resolve(result.value) : adopt(result.value).then(fulfilled, rejected); }
         step((generator = generator.apply(thisArg, _arguments || [])).next());
@@ -70,2 +71,3 @@ });
 Object.defineProperty(exports, "__esModule", { value: true });
+exports.WSClient = void 0;
 var assert_1 = require("@0x/assert");
@@ -158,5 +160,4 @@ var utils_1 = require("@0x/utils");
         return {
-            snapshotID: rawGetOrdersResponse.snapshotID,
             // tslint:disable-next-line:custom-no-magic-numbers
-            snapshotTimestamp: Math.round(new Date(rawGetOrdersResponse.snapshotTimestamp).getTime() / 1000),
+            timestamp: Math.round(new Date(rawGetOrdersResponse.timestamp).getTime() / 1000),
             ordersInfos: WSClient._convertRawOrderInfos(rawGetOrdersResponse.ordersInfos),
@@ -361,12 +362,8 @@ };
         return __awaiter(this, void 0, void 0, function () {
-            var snapshotID, page, getOrdersResponse, ordersInfos, allOrderInfos;
+            var getOrdersResponse, ordersInfos, allOrderInfos, minOrderHash;
             return __generator(this, function (_a) {
                 switch (_a.label) {
-                    case 0:
-                        snapshotID = '';
-                        page = 0;
-                        return [4 /*yield*/, this.getOrdersForPageAsync(page, perPage, snapshotID)];
+                    case 0: return [4 /*yield*/, this.getOrdersForPageAsync(perPage)];
                     case 1:
                         getOrdersResponse = _a.sent();
-                        snapshotID = getOrdersResponse.snapshotID;
                         ordersInfos = getOrdersResponse.ordersInfos;
@@ -377,4 +374,4 @@ allOrderInfos = [];
                         allOrderInfos = __spread(allOrderInfos, ordersInfos);
-                        page++;
-                        return [4 /*yield*/, this.getOrdersForPageAsync(page, perPage, snapshotID)];
+                        minOrderHash = ordersInfos[ordersInfos.length - 1].orderHash;
+                        return [4 /*yield*/, this.getOrdersForPageAsync(perPage, minOrderHash)];
                     case 3:
@@ -389,4 +386,3 @@ getOrdersResponse = _a.sent();
                         getOrdersResponse = {
-                            snapshotID: snapshotID,
-                            snapshotTimestamp: getOrdersResponse.snapshotTimestamp,
+                            timestamp: getOrdersResponse.timestamp,
                             ordersInfos: allOrderInfos,
@@ -406,15 +402,13 @@ };
      */
-    WSClient.prototype.getOrdersForPageAsync = function (page, perPage, snapshotID) {
+    WSClient.prototype.getOrdersForPageAsync = function (perPage, minOrderHash) {
         if (perPage === void 0) { perPage = 200; }
+        if (minOrderHash === void 0) { minOrderHash = ''; }
         return __awaiter(this, void 0, void 0, function () {
-            var finalSnapshotID, rawGetOrdersResponse, getOrdersResponse;
+            var rawGetOrdersResponse, getOrdersResponse;
             return __generator(this, function (_a) {
                 switch (_a.label) {
-                    case 0:
-                        finalSnapshotID = snapshotID === undefined ? '' : snapshotID;
-                        return [4 /*yield*/, this._wsProvider.send('mesh_getOrders', [
-                                page,
-                                perPage,
-                                finalSnapshotID,
-                            ])];
+                    case 0: return [4 /*yield*/, this._wsProvider.send('mesh_getOrders', [
+                            perPage,
+                            minOrderHash,
+                        ])];
                     case 1:
@@ -421,0 +415,0 @@ rawGetOrdersResponse = _a.sent();

lib/test/utils/chai_setup.d.ts

 export declare const chaiSetup: {
     configure(): void;
 };
-//# sourceMappingURL=chai_setup.d.ts.map
+//# sourceMappingURL=chai_setup.d.ts.map

lib/test/utils/chai_setup.js

 "use strict";
 Object.defineProperty(exports, "__esModule", { value: true });
+exports.chaiSetup = void 0;
 var chai = require("chai");
@@ -4,0 +5,0 @@ var chaiAsPromised = require("chai-as-promised");

lib/test/utils/mock_ws_server.d.ts

@@ -12,2 +12,2 @@ import * as WebSocket from 'websocket';
 export declare function stopServer(): void;
-//# sourceMappingURL=mock_ws_server.d.ts.map
+//# sourceMappingURL=mock_ws_server.d.ts.map

lib/test/utils/mock_ws_server.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) : new P(function (resolve) { resolve(result.value); }).then(fulfilled, rejected); }
+        function step(result) { result.done ? resolve(result.value) : adopt(result.value).then(fulfilled, rejected); }
         step((generator = generator.apply(thisArg, _arguments || [])).next());
@@ -38,2 +39,3 @@ });
 Object.defineProperty(exports, "__esModule", { value: true });
+exports.stopServer = exports.setupServerAsync = exports.SERVER_PORT = void 0;
 var http = require("http");
@@ -40,0 +42,0 @@ var WebSocket = require("websocket");

lib/test/utils/ws_server.d.ts

@@ -14,3 +14,3 @@ import { WSClient } from '../../src';
 export declare class MeshHarness {
-    static readonly DEFAULT_TIMEOUT: number;
+    static readonly DEFAULT_TIMEOUT = 1000;
     protected static _serverPort: number;
@@ -17,0 +17,0 @@ readonly wsPort: number;

lib/test/utils/ws_server.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) : new P(function (resolve) { resolve(result.value); }).then(fulfilled, rejected); }
+        function step(result) { result.done ? resolve(result.value) : adopt(result.value).then(fulfilled, rejected); }
         step((generator = generator.apply(thisArg, _arguments || [])).next());
@@ -38,2 +39,3 @@ });
 Object.defineProperty(exports, "__esModule", { value: true });
+exports.MeshHarness = exports.startServerAndClientAsync = void 0;
 var child_process_1 = require("child_process");
@@ -40,0 +42,0 @@ var jsonstream = require("jsonstream");

lib/test/ws_client_test.js

@@ -14,6 +14,7 @@ "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) : new P(function (resolve) { resolve(result.value); }).then(fulfilled, rejected); }
+        function step(result) { result.done ? resolve(result.value) : adopt(result.value).then(fulfilled, rejected); }
         step((generator = generator.apply(thisArg, _arguments || [])).next());
@@ -69,6 +70,6 @@ });
 };
-var __values = (this && this.__values) || function (o) {
-    var m = typeof Symbol === "function" && o[Symbol.iterator], i = 0;
+var __values = (this && this.__values) || function(o) {
+    var s = typeof Symbol === "function" && Symbol.iterator, m = s && o[s], i = 0;
     if (m) return m.call(o);
-    return {
+    if (o && typeof o.length === "number") return {
         next: function () {
@@ -79,4 +80,4 @@ if (o && i >= o.length) o = void 0;
     };
+    throw new TypeError(s ? "Object is not iterable." : "Symbol.iterator is not defined.");
 };
-var _this = this;
 Object.defineProperty(exports, "__esModule", { value: true });
@@ -92,3 +93,2 @@ var contract_addresses_1 = require("@0x/contract-addresses");
 require("mocha");
-var uuidValidate = require("uuid-validate");
 var WebSocket = require("websocket");
@@ -107,3 +107,3 @@ var index_1 = require("../src/index");
         var provider;
-        beforeEach(function () { return __awaiter(_this, void 0, void 0, function () {
+        beforeEach(function () { return __awaiter(void 0, void 0, void 0, function () {
             return __generator(this, function (_a) {
@@ -118,3 +118,3 @@ switch (_a.label) {
         }); });
-        afterEach(function () { return __awaiter(_this, void 0, void 0, function () {
+        afterEach(function () { return __awaiter(void 0, void 0, void 0, function () {
             return __generator(this, function (_a) {
@@ -125,4 +125,5 @@ deployment.mesh.stopMesh();
         }); });
-        before(function () { return __awaiter(_this, void 0, void 0, function () {
-            var _a, chainId, accounts, providerConfigs, erc20ProxyAddress, makerToken, feeToken, mintAmount;
+        before(function () { return __awaiter(void 0, void 0, void 0, function () {
+            var chainId, accounts, providerConfigs, erc20ProxyAddress, makerToken, feeToken, mintAmount;
+            var _a;
             return __generator(this, function (_b) {
@@ -169,3 +170,3 @@ switch (_b.label) {
                         _b.sent();
-                        orderFactory = new contracts_test_utils_1.OrderFactory(contracts_test_utils_1.constants.TESTRPC_PRIVATE_KEYS[accounts.indexOf(makerAddress)], __assign({}, contracts_test_utils_1.constants.STATIC_ORDER_PARAMS, { feeRecipientAddress: contracts_test_utils_1.constants.NULL_ADDRESS, makerAddress: makerAddress,
+                        orderFactory = new contracts_test_utils_1.OrderFactory(contracts_test_utils_1.constants.TESTRPC_PRIVATE_KEYS[accounts.indexOf(makerAddress)], __assign(__assign({}, contracts_test_utils_1.constants.STATIC_ORDER_PARAMS), { feeRecipientAddress: contracts_test_utils_1.constants.NULL_ADDRESS, makerAddress: makerAddress,
                             exchangeAddress: exchangeAddress, chainId: 1337, makerAssetData: order_utils_1.assetDataUtils.encodeERC20AssetData(makerToken.address), takerAssetData: order_utils_1.assetDataUtils.encodeERC20AssetData(makerToken.address), makerFeeAssetData: order_utils_1.assetDataUtils.encodeERC20AssetData(feeToken.address), takerFeeAssetData: order_utils_1.assetDataUtils.encodeERC20AssetData(feeToken.address) }));
@@ -176,6 +177,5 @@ return [2 /*return*/];
         }); });
-        describe('#addOrdersAsync', function () { return __awaiter(_this, void 0, void 0, function () {
-            var _this = this;
+        describe('#addOrdersAsync', function () { return __awaiter(void 0, void 0, void 0, function () {
             return __generator(this, function (_a) {
-                it('accepts valid order', function () { return __awaiter(_this, void 0, void 0, function () {
+                it('accepts valid order', function () { return __awaiter(void 0, void 0, void 0, function () {
                     var order, validationResults;
@@ -205,3 +205,3 @@ return __generator(this, function (_a) {
                 }); });
-                it('rejects order with invalid signature', function () { return __awaiter(_this, void 0, void 0, function () {
+                it('rejects order with invalid signature', function () { return __awaiter(void 0, void 0, void 0, function () {
                     var invalidOrder, _a, validationResults;
@@ -214,3 +214,3 @@ return __generator(this, function (_b) {
                             case 1:
-                                invalidOrder = __assign.apply(void 0, _a.concat([(_b.sent()), { signature: utils_1.hexUtils.hash('0x0') }]));
+                                invalidOrder = __assign.apply(void 0, [__assign.apply(void 0, _a.concat([(_b.sent())])), { signature: utils_1.hexUtils.hash('0x0') }]);
                                 return [4 /*yield*/, deployment.client.addOrdersAsync([invalidOrder])];
@@ -241,3 +241,3 @@ case 2:
         describe('#getStats', function () {
-            it('Ensure that the stats are correct when no orders have been added', function () { return __awaiter(_this, void 0, void 0, function () {
+            it('Ensure that the stats are correct when no orders have been added', function () { return __awaiter(void 0, void 0, void 0, function () {
                 var stats, now, expectedStartOfCurrentUTCDay, expectedStats;
@@ -287,6 +287,5 @@ return __generator(this, function (_a) {
         });
-        describe('#getOrdersAsync', function () { return __awaiter(_this, void 0, void 0, function () {
-            var _this = this;
+        describe('#getOrdersAsync', function () { return __awaiter(void 0, void 0, void 0, function () {
             return __generator(this, function (_a) {
-                it('properly makes multiple paginated requests under-the-hood and returns all signedOrders', function () { return __awaiter(_this, void 0, void 0, function () {
+                it('properly makes multiple paginated requests under-the-hood and returns all signedOrders', function () { return __awaiter(void 0, void 0, void 0, function () {
                     var ordersLength, orders, i, _a, _b, validationResults, now, perPage, response;
@@ -320,5 +319,3 @@ return __generator(this, function (_c) {
                                 response = _c.sent();
-                                assertRoughlyEquals(now, response.snapshotTimestamp * secondsToMs(1), secondsToMs(2));
-                                // Verify that snapshot ID in the response meets the expected schema.
-                                contracts_test_utils_1.expect(uuidValidate(response.snapshotID)).to.be.true();
+                                assertRoughlyEquals(now, response.timestamp * secondsToMs(1), secondsToMs(2));
                                 // Verify that all of the orders that were added to the mesh node
@@ -334,7 +331,6 @@ // were returned in the `getOrders` rpc response
         }); });
-        describe('#getOrdersForPageAsync', function () { return __awaiter(_this, void 0, void 0, function () {
-            var _this = this;
+        describe('#getOrdersForPageAsync', function () { return __awaiter(void 0, void 0, void 0, function () {
             return __generator(this, function (_a) {
-                it('properly makes paginated request and returns signedOrders', function () { return __awaiter(_this, void 0, void 0, function () {
-                    var ordersLength, orders, i, _a, _b, validationResults, now, page, perPage, response, responseOrders;
+                it('properly makes paginated request and returns signedOrders', function () { return __awaiter(void 0, void 0, void 0, function () {
+                    var ordersLength, orders, i, _a, _b, validationResults, now, perPage, response, responseOrders, nextMinOrderHash;
                     return __generator(this, function (_c) {
@@ -363,16 +359,14 @@ switch (_c.label) {
                                 now = new Date(Date.now()).getTime();
-                                page = 0;
                                 perPage = 5;
-                                return [4 /*yield*/, deployment.client.getOrdersForPageAsync(page, perPage)];
+                                return [4 /*yield*/, deployment.client.getOrdersForPageAsync(perPage)];
                             case 6:
                                 response = _c.sent();
-                                assertRoughlyEquals(now, response.snapshotTimestamp * secondsToMs(1), secondsToMs(2));
-                                contracts_test_utils_1.expect(uuidValidate(response.snapshotID)).to.be.true();
+                                assertRoughlyEquals(now, response.timestamp * secondsToMs(1), secondsToMs(2));
                                 responseOrders = response.ordersInfos;
+                                contracts_test_utils_1.expect(responseOrders.length).to.be.eq(perPage);
+                                nextMinOrderHash = responseOrders[responseOrders.length - 1].orderHash;
+                                return [4 /*yield*/, deployment.client.getOrdersForPageAsync(perPage, nextMinOrderHash)];
+                            case 7:
                                 // Second request for page index 1
-                                page = 1;
-                                return [4 /*yield*/, deployment.client.getOrdersForPageAsync(page, perPage, response.snapshotID)];
-                            case 7:
                                 response = _c.sent();
-                                contracts_test_utils_1.expect(uuidValidate(response.snapshotID)).to.be.true();
                                 // Combine orders found in first and second paginated requests
@@ -390,9 +384,7 @@ responseOrders = __spread(responseOrders, response.ordersInfos);
         }); });
-        describe('#_subscribeToHeartbeatAsync', function () { return __awaiter(_this, void 0, void 0, function () {
-            var _this = this;
+        describe('#_subscribeToHeartbeatAsync', function () { return __awaiter(void 0, void 0, void 0, function () {
             return __generator(this, function (_a) {
                 it('should receive subscription updates', function (done) {
-                    (function () { return __awaiter(_this, void 0, void 0, function () {
+                    (function () { return __awaiter(void 0, void 0, void 0, function () {
                         var expectToBeCalledOnce, callback;
-                        var _this = this;
                         return __generator(this, function (_a) {
@@ -402,3 +394,3 @@ switch (_a.label) {
                                     expectToBeCalledOnce = true;
-                                    callback = dev_utils_1.callbackErrorReporter.reportNoErrorCallbackErrors(done, expectToBeCalledOnce)(function (ack) { return __awaiter(_this, void 0, void 0, function () {
+                                    callback = dev_utils_1.callbackErrorReporter.reportNoErrorCallbackErrors(done, expectToBeCalledOnce)(function (ack) { return __awaiter(void 0, void 0, void 0, function () {
                                         return __generator(this, function (_a) {
@@ -432,7 +424,6 @@ contracts_test_utils_1.expect(ack).to.be.equal('tick');
         }); });
-        describe('#subscribeToOrdersAsync', function () { return __awaiter(_this, void 0, void 0, function () {
-            var _this = this;
+        describe('#subscribeToOrdersAsync', function () { return __awaiter(void 0, void 0, void 0, function () {
             return __generator(this, function (_a) {
                 it('should receive subscription updates about added orders', function (done) {
-                    (function () { return __awaiter(_this, void 0, void 0, function () {
+                    (function () { return __awaiter(void 0, void 0, void 0, function () {
                         var ordersLength, orders, i, _a, _b, now, subscription, validationResults;
@@ -483,3 +474,3 @@ return __generator(this, function (_c) {
                                                 try {
-                                                    for (var orderEvents_2 = __values(orderEvents), orderEvents_2_1 = orderEvents_2.next(); !orderEvents_2_1.done; orderEvents_2_1 = orderEvents_2.next()) {
+                                                    for (var orderEvents_2 = (e_3 = void 0, __values(orderEvents)), orderEvents_2_1 = orderEvents_2.next(); !orderEvents_2_1.done; orderEvents_2_1 = orderEvents_2.next()) {
                                                         var orderEvent = orderEvents_2_1.value;
@@ -527,3 +518,3 @@ if (orderHash === orderEvent.orderHash) {
                 it('should receive subscription updates about cancelled orders', function (done) {
-                    (function () { return __awaiter(_this, void 0, void 0, function () {
+                    (function () { return __awaiter(void 0, void 0, void 0, function () {
                         var order, validationResults, now, subscription;
@@ -587,6 +578,5 @@ return __generator(this, function (_a) {
         }); });
-        describe('#unsubscribeAsync', function () { return __awaiter(_this, void 0, void 0, function () {
-            var _this = this;
+        describe('#unsubscribeAsync', function () { return __awaiter(void 0, void 0, void 0, function () {
             return __generator(this, function (_a) {
-                it('should unsubscribe successfully', function () { return __awaiter(_this, void 0, void 0, function () {
+                it('should unsubscribe successfully', function () { return __awaiter(void 0, void 0, void 0, function () {
                     var subscriptionID;
@@ -605,3 +595,3 @@ return __generator(this, function (_a) {
                 }); });
-                it('should throw an error after unsubscribing redundantly', function () { return __awaiter(_this, void 0, void 0, function () {
+                it('should throw an error after unsubscribing redundantly', function () { return __awaiter(void 0, void 0, void 0, function () {
                     var subscriptionID, thrownError, error_1;
@@ -643,5 +633,4 @@ return __generator(this, function (_a) {
                 // tslint:disable-next-line:no-floating-promises
-                (function () { return __awaiter(_this, void 0, void 0, function () {
+                (function () { return __awaiter(void 0, void 0, void 0, function () {
                     var wsServer, client;
-                    var _this = this;
                     return __generator(this, function (_a) {
@@ -652,3 +641,3 @@ switch (_a.label) {
                                 wsServer = _a.sent();
-                                wsServer.on('connect', function (connection) { return __awaiter(_this, void 0, void 0, function () {
+                                wsServer.on('connect', function (connection) { return __awaiter(void 0, void 0, void 0, function () {
                                     return __generator(this, function (_a) {
@@ -679,10 +668,8 @@ switch (_a.label) {
         });
-        describe('#onReconnected', function () { return __awaiter(_this, void 0, void 0, function () {
-            var _this = this;
+        describe('#onReconnected', function () { return __awaiter(void 0, void 0, void 0, function () {
             return __generator(this, function (_a) {
                 it('should trigger the callback when reconnected', function (done) {
                     // tslint:disable-next-line:no-floating-promises
-                    (function () { return __awaiter(_this, void 0, void 0, function () {
+                    (function () { return __awaiter(void 0, void 0, void 0, function () {
                         var wsServer, connectionNum, client;
-                        var _this = this;
                         return __generator(this, function (_a) {
@@ -694,9 +681,8 @@ switch (_a.label) {
                                     connectionNum = 0;
-                                    wsServer.on('connect', function (connection) { return __awaiter(_this, void 0, void 0, function () {
+                                    wsServer.on('connect', function (connection) { return __awaiter(void 0, void 0, void 0, function () {
                                         var requestNum;
-                                        var _this = this;
                                         return __generator(this, function (_a) {
                                             requestNum = 0;
                                             connectionNum++;
-                                            connection.on('message', (function (message) { return __awaiter(_this, void 0, void 0, function () {
+                                            connection.on('message', (function (message) { return __awaiter(void 0, void 0, void 0, function () {
                                                 var jsonRpcRequest, response, reasonCode, description;
@@ -730,3 +716,3 @@ return __generator(this, function (_a) {
                                     client = new index_1.WSClient("ws://localhost:" + mock_ws_server_1.SERVER_PORT, { reconnectDelay: 100 });
-                                    client.onReconnected(function () { return __awaiter(_this, void 0, void 0, function () {
+                                    client.onReconnected(function () { return __awaiter(void 0, void 0, void 0, function () {
                                         return __generator(this, function (_a) {
@@ -759,10 +745,8 @@ switch (_a.label) {
         }); });
-        describe('#destroy', function () { return __awaiter(_this, void 0, void 0, function () {
-            var _this = this;
+        describe('#destroy', function () { return __awaiter(void 0, void 0, void 0, function () {
             return __generator(this, function (_a) {
                 it('should unsubscribe and trigger onClose when close() is called', function (done) {
                     // tslint:disable-next-line:no-floating-promises
-                    (function () { return __awaiter(_this, void 0, void 0, function () {
+                    (function () { return __awaiter(void 0, void 0, void 0, function () {
                         var wsServer, hasReceivedUnsubscribeMessage, client;
-                        var _this = this;
                         return __generator(this, function (_a) {
@@ -775,3 +759,3 @@ switch (_a.label) {
                                     wsServer.on('connect', function (connection) {
-                                        connection.on('message', function (message) { return __awaiter(_this, void 0, void 0, function () {
+                                        connection.on('message', function (message) { return __awaiter(void 0, void 0, void 0, function () {
                                             var wsMessage, jsonRpcRequest, response;
@@ -844,3 +828,3 @@ return __generator(this, function (_a) {
             try {
-                for (var ordersInfos_1 = __values(ordersInfos), ordersInfos_1_1 = ordersInfos_1.next(); !ordersInfos_1_1.done; ordersInfos_1_1 = ordersInfos_1.next()) {
+                for (var ordersInfos_1 = (e_5 = void 0, __values(ordersInfos)), ordersInfos_1_1 = ordersInfos_1.next(); !ordersInfos_1_1.done; ordersInfos_1_1 = ordersInfos_1.next()) {
                     var responseOrder = ordersInfos_1_1.value;
@@ -847,0 +831,0 @@ if (contracts_test_utils_1.orderHashUtils.getOrderHashHex(order) === responseOrder.orderHash) {

package.json

 {
     "name": "@0x/mesh-rpc-client",
-    "version": "9.4.0",
+    "version": "10.0.0-unstable",
     "engines": {
@@ -76,3 +76,3 @@ "node": ">=6.12"
         "typedoc": "^0.15.0",
-        "typescript": "3.0.1",
+        "typescript": "3.9.3",
         "uuid-validate": "^0.0.3"
@@ -79,0 +79,0 @@ },

New alerts

No v1

Quality

Package is not semver >=1. This means it is not stable and does not support ^ ranges.

Found 1 instance in 1 package

Improved metrics

Total package byte prevSize

636175

increased by278.41%

Number of package files

32

increased by3.23%

Worsened metrics

Lines of code

2241

decreased by-0.71%

Number of low quality alerts

2

increased by100%

No dependency changes