From 446a66cae81bd6d287efc71a2cc81b74cb301b51 Mon Sep 17 00:00:00 2001 From: acolytec3 <17355484+acolytec3@users.noreply.github.com> Date: Mon, 17 Feb 2025 17:12:34 -0500 Subject: [PATCH] Set RESET packet version number correctly (#735) --- .../src/wire/utp/PortalNetworkUtp/index.ts | 15 ++++++++++----- 1 file changed, 10 insertions(+), 5 deletions(-) diff --git a/packages/portalnetwork/src/wire/utp/PortalNetworkUtp/index.ts b/packages/portalnetwork/src/wire/utp/PortalNetworkUtp/index.ts index b9a56ba60..2dba6778d 100644 --- a/packages/portalnetwork/src/wire/utp/PortalNetworkUtp/index.ts +++ b/packages/portalnetwork/src/wire/utp/PortalNetworkUtp/index.ts @@ -33,12 +33,15 @@ export class PortalNetworkUTP { this.requestManagers = {} } - closeAllPeerRequests(nodeId: string) { - this.requestManagers[nodeId].closeAllRequests() + closeAllPeerRequests(nodeId: string) { + this.requestManagers[nodeId].closeAllRequests() } hasRequests(nodeId: string): boolean { - return this.requestManagers[nodeId] !== undefined && Object.keys(this.requestManagers[nodeId].requestMap).length > 0 + return ( + this.requestManagers[nodeId] !== undefined && + Object.keys(this.requestManagers[nodeId].requestMap).length > 0 + ) } openRequests(): number { @@ -115,7 +118,9 @@ export class PortalNetworkUTP { contentKeys, }) await this.requestManagers[enr.nodeId].handleNewRequest(connectionId, newRequest) - this.logger.extend('utpRequest')(`New ${RequestCode[requestCode]} Request with ${enr.nodeId} -- ConnectionId: ${connectionId}`) + this.logger.extend('utpRequest')( + `New ${RequestCode[requestCode]} Request with ${enr.nodeId} -- ConnectionId: ${connectionId}`, + ) this.logger.extend('utpRequest')(`Open Requests: ${this.openRequests()}`) return newRequest } @@ -137,7 +142,7 @@ export class PortalNetworkUTP { pType: PacketType.ST_RESET, ackNr: 0, extension: 0, - version: 0, + version: 1, timestampMicroseconds: 0, timestampDifferenceMicroseconds: 0, seqNr: 0,