@electrum-cash/network - npm Package Compare versions

Comparing version 4.2.1 to 4.2.2-development.12944155577

dist/index.d.mts

@@ -0,1 +1,2 @@
+import { ElectrumWebSocketReconnectionOptions } from "@electrum-cash/web-socket";
 import { EventEmitter } from "eventemitter3";
@@ -63,3 +64,3 @@
  */
-interface ElectrumNetworkOptions {
+interface ElectrumNetworkOptions extends Partial<ElectrumWebSocketReconnectionOptions> {
   /** If set to true, numbers that can safely be parsed as integers will be `BigInt` rather than `Number`. */
@@ -73,6 +74,2 @@ useBigInt?: boolean;
   verifyConnectionTimeoutInMilliSeconds?: number;
-  /** Turn off automatic handling of browser visibility, which disconnects when application is not visible to be consistent across browsers.  */
-  disableBrowserVisibilityHandling?: boolean;
-  /** Turn off automatic handling of browser connectivity. */
-  disableBrowserConnectivityHandling?: boolean;
 }
@@ -79,0 +76,0 @@ /**

dist/index.d.mts.map

@@ -1,1 +0,1 @@
-{"version":3,"file":"index.d.mts","names":[],"sources":["../source/enums.ts","../source/rpc-interfaces.ts","../source/interfaces.ts","../source/electrum-client.ts"],"sourcesContent":[],"mappings":";;;;;;;AASA;;;;ACRA;AAGA;AAGiB,aDEL,gBAAA;ECIK,YAAA,GAAA,CAAA;EAOA,SAAA,GAAA,CAAW;EAEvB,aAAA,GAAA,CAAA;EAEK,UAAA,GAAA,CAAA;EAJ0B,YAAA,GAAA,CAAA;;;;KAnBxB,YAAA;KAGA,aAAA;UAGK,OAAA;EDEL,OAAA,EAAA,MAAA;;UCIK,eAAA,SAAwB;;EAZ7B,MAAA,CAAA,EAeF,YAfc,EAAA;AAGxB;AAGiB,UAaA,UAAA,SAAmB,OAbZ,CAAA;EAMP,EAAA,EASZ,aATY;EAOA,MAAA,EAAA,MAAW;EAEvB,MAAA,CAAA,EAEK,YAFL,EAAA;;AAF+B,UAQnB,YAAA,SAAqB,OARF,CAAA;EAAO,EAAA,EAUtC,aAVsC;EAQ1B,MAAA,EAAA,MAAA;AAMjB;AAQiB,UARA,QAAA,CAQiB;EAE7B,IAAA,EAAA,MAAA;EACG,OAAA,EAAA,MAAA;EAHkC,IAAA,CAAA,EAAA,OAAA;;AAO9B,UAPK,gBAAA,SAAyB,OAOnB,CAAA;EAAG,EAAA,EALrB,aAKqB;EAAmB,KAAA,EAJrC,QAIqC;;AAA8B,KAA/D,WAAA,GAAc,gBAAiD,GAA9B,YAA8B,GAAf,eAAe;AAG/D,KAAA,UAAA,GAAa,eAAH,GAAqB,UAArB,GAAkC,WAAlC;AAAG,KAGb,gBAAA,GAAmB,WAHN,EAAA;AAAkB,KAI/B,eAAA,GAAkB,UAJa,EAAA;AAAa,cAM3C,kBAN2C,EAAA,CAAA,OAAA,EAMJ,OANI,EAAA,GAAA,OAAA,IAMiB,gBANjB;AAAW,cAWtD,cAXsD,EAAA,CAAA,OAAA,EAWnB,OAXmB,EAAA,GAAA,OAAA,IAWE,YAXF;AAGvD,cAaC,iBAbkB,EAAA,CAAA,OAAW,EAaS,OAbT,EAAA,GAAA,OAAA,IAa8B,eAb9B;AAC9B,cAiBC,YAjBc,EAAG,CAAA,OAAA,EAiBgB,OAjBN,EAAA,GAAA,OAAA,IAiB2B,UAjB3B;;;;AD/CxC;;UEHiB,sBAAA;;EDLL,SAAA,CAAA,EAAA,OAAY;EAGZ;EAGK,mCAAO,CAAA,EAAA,MAAA;EAMP;EAOA,0BAAW,CAAA,EAAA,MAAA;EAEvB;EAEK,qCAAA,CAAA,EAAA,MAAA;EAJ0B;EAAO,gCAAA,CAAA,EAAA,OAAA;EAQ1B;EAMA,kCAAQ,CAAA,EAAA,OAAA;AAQzB;;;;;AAOA;AAA0B,UCjBT,oBAAA,CDiBS;EAAmB;;;AAG7C;EAAyB,MAAA,EAAA,CAAA,MAAA,CAAA;EAAkB;;;AAG3C;EACY,WAAA,EAAA,EAAA;EAEC;AAKb;AAKA;AAKA;;;;ACnEA;AA0BA;EA8BiB,OAAA,EAAA,CANL,KAMK,CAAA;;;;;AAA2D,UAA3D,cAAA,SAAuB,YAAoC,CAAvB,oBAAuB,CAAA,EAAA,oBAAA,CAAA;EAAoB;AAiDhG;AAQA;EASY,IAAA,cAAA,EAAA,EAAA,MAAA;EAOK;;;EAsDL,IAAA,EAAA,MAAA;EAAK;AAQjB;AAiDA;EAOY,IAAA,EAAA,MAAA;EAMA;;;EAAiC,SAAA,EAAA,OAAA;EAAW;AAMxD;AAKA;EAQa,OAAA,EAAA,MAAA;;;;ECxQP,OAAA,EAAA,EAAA,IAAA;EAAsC;;;EA4DjB,UAAA,EAAA,EAAA,IAAA;EACT;;;;;;EAyG4B,KAAA,CAAA,IAAA,ED3EjC,UC2EiC,GAAA,MAAA,EAAA,QAAA,CAAA,EAAA,CAAA,GAAA,CAAA,ED3EM,KC2EN,EAAA,GAAA,IAAA,CAAA,EAAA,OAAA;;;;;AA2DmB,UDhIhD,eAAA,CCgIgD;EAqDf,KAAA,EDnL1C,QCmL0C;;;;;AAkMZ,UD/WrB,iBAAA,CC+WqB;EAYqB,QAAA,EAAA,MAAA;EAgBL,QAAA,EAAA,MAAA;;;;;AApfmF,KDkH7H,0BAAA,GAA6B,iBClHgG,GDkH5E,eClH4E;;;;;;UDyHxH,wBAAA;;;;;;;;;;eAYF;;;;;cAMD;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;YAoCF;;;;;;;UAQK,oBAAA;;;;;mBAME;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;YAoCP;;;;;;KAOA,eAAA,GAAkB,eAAe;;;;;;KAOjC,eAAA,YAA2B;;;;;KAM3B,6BAA6B,IAAI,YAAY;;;;;KAM7C,cAAA;;;;cAKC,4BAAqC,yCAAuC;;;;cAQ5E,8BAAuC,yCAAuC;;;;;;ADrR3F,cEaM,cFbkB,CAAA,uBEaoB,oBFbpB,CAAA,SEakD,YFblD,CEa+D,oBFb/D,GEasF,cFbtF,CAAA,YEaiH,oBFbjH,CAAA;EAGZ,WAAA,EAAA,MAAa;EAGR,OAAA,EAAA,MAAO;EAMP,gBAAA,EE6DU,cF1DjB,GAAA,MAAA;EAIO,OAAA,EEuDC,sBFvDU;EAEvB;;;EAFsC,QAAA,EAAA,MAAA;EAQ1B;AAMjB;AAQA;;EAGQ,WAAA,EAAA,MAAA;EAHkC;;AAO1C;;EAA6C,WAAA,EAAA,MAAA;EAAe;;AAG5D;EAAyB,qBAAA,EAAA,MAAA;EAAkB;;;EAG/B,IAAA,MAAA,CAAA,CAAA,EEdU,gBFcM;EAChB,QAAA,UAAe;EAEd,QAAA,mBAGZ;EAEY,QAAA,SAGZ;EAEY,QAAA,gBAGZ;EAEY,QAAA,cAGZ;;;;ACtED;AA0BA;AA8BA;;;;;EAA4E,WAAA,CAAA,WAAA,EAAA,MAAA,EAAA,OAAA,EAAA,MAAA,EAAA,gBAAA,ECYjD,cDZiD,GAAA,MAAA,EAAA,OAAA,CAAA,ECa1D,sBDb0D;EAAoB,IAAA,cAAA,CAAA,CAAA,EAAA,MAAA;EAiD/E,IAAA,SAAA,CAAA,CAAA,EAAA,OAAe;EAQf;AASjB;AAOA;;;;EAsDiB,OAAA,CAAA,CAAA,ECnFC,ODmFD,CAAA,IAAA,CAAA;EAQA;AAiDjB;AAOA;AAMA;;;;;EAMY,UAAA,CAAA,KAAc,CAAA,EAAA,OAAA,EAAA,mBAAA,CAAA,EAAA,OAAA,CAAA,EC7GuD,OD6GvD,CAAA,OAAA,CAAA;EAKb;AAQb;;;;AC7QuJ;;;;EAiE5H,OAAA,CAAA,MAAA,EAAA,MAAA,EAAA,GAAA,UAAA,EA0GmB,YA1GnB,EAAA,CAAA,EA0GoC,OA1GpC,CA0G4C,KA1G5C,GA0GoD,eA1GpD,CAAA;EACT;;;;;;;;;;;EAoK+C,SAAA,CAAA,MAAA,EAAA,MAAA,EAAA,GAAA,UAAA,EAAjB,YAAiB,EAAA,CAAA,EAAA,OAAA,CAAA,IAAA,CAAA;EAqDf;;;;;;;;;;;EAtRwB,WAAA,CAAA,MAAA,EAAA,MAAA,EAAA,GAAA,UAAA,EAsRxB,YAtRwB,EAAA,CAAA,EAsRP,OAtRO,CAAA,IAAA,CAAA;EAA+D;;;;;;;;;;;;;;;;;;oBA8WtH;;;;;;;4BAgEc;;;;;;+CAwBc;;;;;;iCAkBT;;;;;;;2DAYqB;;;;;;;sDAgBL;;;;iDAoBL;;;;;;0BAYhB;mBACP"}
+{"version":3,"file":"index.d.mts","names":[],"sources":["../source/enums.ts","../source/rpc-interfaces.ts","../source/interfaces.ts","../source/electrum-client.ts"],"sourcesContent":[],"mappings":";;;;;;;;;AASA;;;;ACRA;AAGY,aDKA,gBAAA;ECFK,YAAO,GAAA,CAAA;EAMP,SAAA,GAAA,CAAA;EAOA,aAAW,GAAA,CAAA;EAEvB,UAAA,GAAA,CAAA;EAEK,YAAA,GAAA,CAAA;;;;KAvBE,YAAA;KAGA,aAAA;UAGK,OAAA;;ADEjB;UCIiB,eAAA,SAAwB;;WAG/B;AAfV;AAGY,UAgBK,UAAA,SAAmB,OAhBX,CAAA;EAGR,EAAA,EAeZ,aAfmB;EAMP,MAAA,EAAA,MAAA;EAOA,MAAA,CAAA,EAIP,YAJkB,EAAA;;AAIlB,UAIO,YAAA,SAAqB,OAJ5B,CAAA;EAJ0B,EAAA,EAU/B,aAV+B;EAAO,MAAA,EAAA,MAAA;AAQ3C;AAMiB,UAAA,QAAA,CAAQ;EAQR,IAAA,EAAA,MAAA;EAEZ,OAAA,EAAA,MAAA;EACG,IAAA,CAAA,EAAA,OAAA;;AAHyC,UAAhC,gBAAA,SAAyB,OAAO,CAAA;EAOrC,EAAA,EALP,aAKkB;EAAG,KAAA,EAJlB,QAIkB;;AAAkC,KAAhD,WAAA,GAAc,gBAAkC,GAAf,YAAe,GAAA,eAAA;AAAe,KAG/D,UAAA,GAAa,eAHkD,GAGhC,UAHgC,GAGnB,WAHmB;AAG/D,KAGA,gBAAA,GAAmB,WAHT,EAAA;AAAG,KAIb,eAAA,GAAkB,UAJL,EAAA;AAAkB,cAM9B,kBAN8B,EAAA,CAAA,OAAA,EAMS,OANT,EAAA,GAAA,OAAA,IAM8B,gBAN9B;AAAa,cAW3C,cAX2C,EAAA,CAAA,OAAA,EAWR,OAXQ,EAAA,GAAA,OAAA,IAWa,YAXb;AAAW,cAgBtD,iBAhBsD,EAAA,CAAA,OAAA,EAgBhB,OAhBgB,EAAA,GAAA,OAAA,IAgBK,eAhBL;AAGvD,cAkBC,YAlBe,EAAG,CAAA,OAAA,EAkBe,OAlBJ,EAAA,GAAA,OAAA,IAkByB,UAlBzB;;;;AD9C1C;;UEFiB,sBAAA,SAA+B,QAAQ;;EDN5C,SAAA,CAAA,EAAA,OAAY;EAGZ;EAGK,mCAAO,CAAA,EAAA,MAAA;EAMP;EAOA,0BAAW,CAAA,EAAA,MAAA;EAEvB;EAEK,qCAAA,CAAA,EAAA,MAAA;;;AAIV;AAMA;AAQA;;AAGQ,UClBS,oBAAA,CDkBT;EAHkC;;AAO1C;;EAA6C,MAAA,EAAA,CAAA,MAAA,CAAA;EAAe;;AAG5D;;EAA2C,WAAA,EAAA,EAAA;EAAa;;AAGxD;AACA;EAEa,cAAA,EAAA,EAAA;EAKA;AAKb;AAKA;;YCtBY;;AA5CZ;AAoBA;AA8BA;AAAqD,UAApC,cAAA,SAAuB,YAAa,CAAA,oBAAA,CAAA,EAAuB,oBAAvB,CAAA;EA2CxC;;;EA3C+D,IAAA,cAAA,EAAA,EAAA,MAAA;EAAoB;AAiDhG;AAQA;EASY,IAAA,EAAA,MAAA;EAOK;;;EAsDL,IAAA,EAAA,MAAA;EAAK;AAQjB;AAiDA;EAOY,SAAA,EAAA,OAAe;EAMf;;;EAAiC,OAAA,EAAA,MAAA;EAAW;AAMxD;AAKA;EAQa,OAAA,EAAA,EAAA,IAAA;;;;ECnQP,UAAA,EAAA,EAAA,IAAc;EAAwB;;;;;;EA4DjB,KAAA,CAAA,IAAA,ED0Bd,UC1Bc,GAAA,MAAA,EAAA,QAAA,CAAA,EAAA,CAAA,GAAA,CAAA,ED0ByB,KC1BzB,EAAA,GAAA,IAAA,CAAA,EAAA,OAAA;;;;;AA0G4C,UD1EtD,eAAA,CC0EsD;EAAQ,KAAA,EDxEvE,QCwEuE;;;;;AAgHZ,UDlLlD,iBAAA,CCkLkD;EAwFhD,QAAA,EAAA,MAAA;EAgEc,QAAA,EAAA,MAAA;;;;;AA0FgB,KD3ZrC,0BAAA,GAA6B,iBC2ZQ,GD3ZY,eC2ZZ;;;;;;UDpZhC,wBAAA;;;;;;;;;;eAYF;;;;;cAMD;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;YAoCF;;;;;;;UAQK,oBAAA;;;;;mBAME;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;YAoCP;;;;;;KAOA,eAAA,GAAkB,eAAe;;;;;;KAOjC,eAAA,YAA2B;;;;;KAM3B,6BAA6B,IAAI,YAAY;;;;;KAM7C,cAAA;;;;cAKC,4BAAqC,yCAAuC;;;;cAQ5E,8BAAuC,yCAAuC;;;AFxQ3F;;;cGKM,sCAAsC,8BAA8B,aAAa,uBAAuB,2BAA2B;EFb7H,WAAA,EAAA,MAAY;EAGZ,OAAA,EAAA,MAAA;EAGK,gBAAO,EEmEG,cFnEH,GAAA,MAAA;EAMP,OAAA,EE8DC,sBF3DR;EAIO;;;EAAmB,QAAA,EAAA,MAAA;EAAO;AAQ3C;AAMA;AAQA;EAEK,WAAA,EAAA,MAAA;EACG;;;AAIR;EAA0B,WAAA,EAAA,MAAA;EAAmB;;;EAGjC,qBAAU,EAAA,MAAA;EAAG;;;EAA0C,IAAA,MAAA,CAAA,CAAA,EEX7C,gBFW6C;EAGvD,QAAA,UAAA;EACA,QAAA,mBAAe;EAEd,QAAA,SAAA;EAKA,QAAA,gBAGZ;EAEY,QAAA,cAGZ;EAEY;;;;AClEb;AAoBA;AA8BA;;;;EAAwC,WAAA,CAAA,WAAA,EAAA,MAAA,EAAA,OAAA,EAAA,MAAA,EAAA,gBAAA,ECiBb,cDjBa,GAAA,MAAA,EAAA,OAAA,CAAA,ECkBtB,sBDlBsB;EAAoC,IAAA,cAAA,CAAA,CAAA,EAAA,MAAA;EAAoB,IAAA,SAAA,CAAA,CAAA,EAAA,OAAA;EAiD/E;AAQjB;AASA;AAOA;;;EAsDY,OAAA,CAAA,CAAA,EC9EM,OD8EN,CAAA,IAAA,CAAA;EAAK;AAQjB;AAiDA;AAOA;AAMA;;;;EAAwD,UAAA,CAAA,KAAA,CAAA,EAAA,OAAA,EAAA,mBAAA,CAAA,EAAA,OAAA,CAAA,EClGyB,ODkGzB,CAAA,OAAA,CAAA;EAM5C;AAKZ;AAQA;;;;ACxQuJ;;;EAKzC,OAAA,CAAA,MAAA,EAAA,MAAA,EAAA,GAAA,UAAA,EAsKhE,YAtKgE,EAAA,CAAA,EAsK/C,OAtK+C,CAsKvC,KAtKuC,GAsK/B,eAtK+B,CAAA;EA4DnF;;;;;;;;;;;EAqKqB,SAAA,CAAA,MAAA,EAAA,MAAA,EAAA,GAAA,UAAA,EAAA,YAAA,EAAA,CAAA,EAAiB,OAAjB,CAAA,IAAA,CAAA;EAAiB;;;;;;;;;;;EAoTvC,WAAA,CAAA,MAAA,EAAA,MAAA,EAAA,GAAA,UAAA,EA/PwB,YA+PxB,EAAA,CAAA,EA/PyC,OA+PzC,CAAA,IAAA,CAAA;EArhBgD;;;;;;;;;;;;;;;;;;oBA8WvD;;;;;;;4BAgEc;;;;;;+CAwBc;;;;;;iCAkBT;;;;;;;2DAYqB;;;;;;;sDAgBL;;;;iDAoBL;;;;;;0BAYhB;mBACP"}

dist/index.mjs

@@ -128,3 +128,3 @@ import debug from "@electrum-cash/debug-logs";
 		if (!ElectrumProtocol.versionRegexp.test(version)) throw /* @__PURE__ */ new Error(`Provided version string (${version}) is not a valid protocol version number.`);
-		if (typeof socketOrHostname === "string") this.socket = new ElectrumWebSocket(socketOrHostname);
+		if (typeof socketOrHostname === "string") this.socket = new ElectrumWebSocket(socketOrHostname, void 0, void 0, void 0, this.options);
 		else this.socket = socketOrHostname;
@@ -134,7 +134,2 @@ this.socket.on("connected", this.onSocketConnect.bind(this));
 		this.socket.on("data", this.parseMessageChunk.bind(this));
-		if (typeof document !== "undefined" && !this.options.disableBrowserVisibilityHandling) document.addEventListener("visibilitychange", this.handleVisibilityChange.bind(this));
-		if (typeof window !== "undefined" && !this.options.disableBrowserConnectivityHandling) {
-			window.addEventListener("online", this.handleNetworkChange.bind(this));
-			window.addEventListener("offline", this.handleNetworkChange.bind(this));
-		}
 	}
@@ -211,36 +206,10 @@ get hostIdentifier() {
 		const connectionResolver = (resolve, reject) => {
-			const rejector = (error) => {
-				this.status = ConnectionStatus.DISCONNECTED;
-				this.emit("disconnected");
-				reject(error);
-			};
-			this.socket.removeAllListeners("error");
-			this.socket.once("error", rejector);
-			const versionNegotiator = () => {
-				debug.network(`Requesting protocol version ${this.version} with '${this.hostIdentifier}'.`);
-				this.socket.removeListener("error", rejector);
-				const versionMessage = ElectrumProtocol.buildRequestObject("server.version", [this.application, this.version], "versionNegotiation");
-				const versionValidator = (version) => {
-					if (isVersionRejected(version)) {
-						this.disconnect(true);
-						const errorMessage = "unsupported protocol version.";
-						debug.errors(`Failed to connect with ${this.hostIdentifier} due to ${errorMessage}`);
-						reject(errorMessage);
-					} else if (version.protocol !== this.version && `${version.protocol}.0` !== this.version && `${version.protocol}.0.0` !== this.version) {
-						this.disconnect(true);
-						const errorMessage = `incompatible protocol version negotiated (${version.protocol} !== ${this.version}).`;
-						debug.errors(`Failed to connect with ${this.hostIdentifier} due to ${errorMessage}`);
-						reject(errorMessage);
-					} else {
-						debug.network(`Negotiated protocol version ${version.protocol} with '${this.hostIdentifier}', powered by ${version.software}.`);
-						this.status = ConnectionStatus.CONNECTED;
-						this.emit("connected");
-						resolve();
-					}
-				};
-				this.once("version", versionValidator);
-				this.send(versionMessage);
-			};
-			this.socket.once("connected", versionNegotiator);
-			this.socket.on("error", this.onSocketError.bind(this));
+			this.once("connected", () => {
+				this.removeListener("disconnected", reject);
+				resolve();
+			});
+			this.once("disconnected", () => {
+				this.removeListener("connected", resolve);
+				reject();
+			});
 			this.socket.connect();
@@ -304,31 +273,2 @@ };
 	/**
-	* Updates the connection state based on browser reported connectivity.
-	*
-	* Most modern browsers are able to provide information on the connection state
-	* which allows for significantly faster response times to network changes compared
-	* to waiting for network requests to fail.
-	*
-	* When available, we make use of this to fail early to provide a better user experience.
-	*/
-	async handleNetworkChange() {
-		if (typeof window.navigator === "undefined") return;
-		if (window.navigator.onLine === true) this.reconnect();
-		if (window.navigator.onLine !== true) this.disconnect(true, true);
-	}
-	/**
-	* Updates connection state based on application visibility.
-	*
-	* Some browsers will disconnect network connections when the browser is out of focus,
-	* which would normally cause our reconnect-on-timeout routines to trigger, but that
-	* results in a poor user experience since the events are not handled consistently
-	* and sometimes it can take some time after restoring focus to the browser.
-	*
-	* By manually disconnecting when this happens we prevent the default reconnection routines
-	* and make the behavior consistent across browsers.
-	*/
-	async handleVisibilityChange() {
-		if (document.visibilityState === "hidden") this.disconnect(true, true);
-		if (document.visibilityState === "visible") this.reconnect();
-	}
-	/**
 	* Sends an arbitrary message to the server.
@@ -364,6 +304,8 @@ *
 	*/
-	onSocketConnect() {
+	async onSocketConnect() {
 		this.clearReconnectTimer();
 		this.lastReceivedTimestamp = Date.now();
 		this.setupKeepAliveTimer();
+		await new Promise(this.negotiateVersion.bind(this));
+		this.emit("connected");
 		this.socket.removeAllListeners("error");
@@ -397,2 +339,37 @@ this.socket.on("error", this.onSocketError.bind(this));
 	}
+	/**
+	* Negotiate the protocol version with the server.
+	* Disconnect the connection if the version negotiation fails.
+	* @param resolve 
+	* @param reject 
+	*/
+	async negotiateVersion(resolve, reject) {
+		const rejector = (error) => {
+			this.status = ConnectionStatus.DISCONNECTED;
+			this.emit("disconnected");
+			reject(error);
+		};
+		debug.network(`Requesting protocol version ${this.version} with '${this.hostIdentifier}'.`);
+		this.socket.once("error", rejector);
+		const versionMessage = ElectrumProtocol.buildRequestObject("server.version", [this.application, this.version], "versionNegotiation");
+		const versionValidator = (version) => {
+			if (isVersionRejected(version)) {
+				this.disconnect(true);
+				const errorMessage = "unsupported protocol version.";
+				debug.errors(`Failed to connect with ${this.hostIdentifier} due to ${errorMessage}`);
+				reject(errorMessage);
+			} else if (version.protocol !== this.version && `${version.protocol}.0` !== this.version && `${version.protocol}.0.0` !== this.version) {
+				this.disconnect(true);
+				const errorMessage = `incompatible protocol version negotiated (${version.protocol} !== ${this.version}).`;
+				debug.errors(`Failed to connect with ${this.hostIdentifier} due to ${errorMessage}`);
+				reject(errorMessage);
+			} else {
+				debug.network(`Negotiated protocol version ${version.protocol} with '${this.hostIdentifier}', powered by ${version.software}.`);
+				this.status = ConnectionStatus.CONNECTED;
+				resolve();
+			}
+		};
+		this.once("version", versionValidator);
+		this.send(versionMessage);
+	}
 };
@@ -399,0 +376,0 @@

package.json

 {
   "name": "@electrum-cash/network",
-  "version": "4.2.1",
+  "version": "4.2.2-development.12944155577",
   "description": "@electrum-cash/network is a lightweight JavaScript library that lets you connect with one or more Electrum servers.",
@@ -42,3 +42,3 @@ "keywords": [
     "docs": "typedoc --hideGenerator --categorizeByGroup",
-    "lint": "eslint",
+    "style": "eslint",
     "syntax": "tsc --noEmit",
@@ -70,3 +70,3 @@ "spellcheck": "cspell 'source/**' 'test/**' 'examples/**'",
     "@electrum-cash/debug-logs": "^1.0.0",
-    "@electrum-cash/web-socket": "^1.0.3-development.12700367632",
+    "@electrum-cash/web-socket": "^1.2.3",
     "async-mutex": "^0.5.0",
@@ -73,0 +73,0 @@ "debug": "^4.3.2",

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

Worsened metrics

Total package byte prevSize

112787

-4%

Lines of code

666

-3.34%

Number of low quality alerts

1

Infinity%

Dependency changes

• Updated

  @electrum-cash/web-socket@^1.2.3