Patch package

Author: giurgiur99

package-lock.json

@@ -45,7 +45,8 @@
     "test:stress": "npm run test:k6-common k6 run -e TEST_TYPE=stress \"./dist/test/performance/perf_test.js\"",
     "test:request:rate": "npm run test:k6-common && k6 run -e RATE=true \"./dist/test/performance/perf_test.js\"",
     "release": "release-it --non-interactive",
-    "changelog": "auto-changelog -p"
+    "changelog": "auto-changelog -p",
+    "postinstall": "patch-package"
   },
   "dependencies": {
     "@chainsafe/libp2p-noise": "^17.0.0",
@@ -126,6 +127,8 @@
     "eslint-plugin-promise": "^6.1.1",
     "mocha": "^11.1.0",
     "nyc": "^17.1.0",
+    "patch-package": "^8.0.1",
+    "postinstall-postinstall": "^2.1.0",
     "prettier": "^3.7.4",
     "release-it": "^19.0.6",
     "sinon": "^19.0.2",

package.json

@@ -0,0 +1,26 @@
+diff --git a/node_modules/@libp2p/http-utils/dist/src/index.js b/node_modules/@libp2p/http-utils/dist/src/index.js
+index f1f98d5..2ad6be6 100644
+--- a/node_modules/@libp2p/http-utils/dist/src/index.js
++++ b/node_modules/@libp2p/http-utils/dist/src/index.js
+@@ -213,7 +213,7 @@ export function getHost(addresses, headers) {
+     let protocol = 'http:';
+     if (addresses instanceof URL) {
+         host = addresses.hostname;
+-        port = parseInt(addresses.port, 10);
++        port = parseInt(addresses.port === '' ? (addresses.protocol === 'https:' ? '443' : '80') : addresses.port, 10);
+         protocol = addresses.protocol;
+     }
+     if (!isValidHost(host)) {
+diff --git a/node_modules/@libp2p/http-utils/src/index.ts b/node_modules/@libp2p/http-utils/src/index.ts
+index 5a73139..a5e0dc5 100644
+--- a/node_modules/@libp2p/http-utils/src/index.ts
++++ b/node_modules/@libp2p/http-utils/src/index.ts
+@@ -301,7 +301,7 @@ export function getHost (addresses: URL | Multiaddr[], headers: Headers): string
+ 
+   if (addresses instanceof URL) {
+     host = addresses.hostname
+-    port = parseInt(addresses.port, 10)
++    port = parseInt(addresses.port === '' ? (addresses.protocol === 'https:' ? '443' : '80') : addresses.port, 10)
+     protocol = addresses.protocol
+   }
+ 

patches/@libp2p+http-utils+2.0.1.patch

@@ -117,11 +117,11 @@ export class OceanP2P extends EventEmitter {
     this._libp2p.addEventListener('peer:discovery', (details: any) => {
       this.handlePeerDiscovery(details)
     })
-    this._libp2p.addEventListener('certificate:provision', (details: any) => {
-      this.handleCertificateProvision(details)
+    this._libp2p.addEventListener('certificate:provision', () => {
+      this.handleCertificateProvision()
     })
-    this._libp2p.addEventListener('certificate:renew', (details: any) => {
-      this.handleCertificateProvision(details)
+    this._libp2p.addEventListener('certificate:renew', () => {
+      this.handleCertificateRenew()
     })
     this._options = Object.assign(
       {},
@@ -198,22 +198,26 @@ export class OceanP2P extends EventEmitter {
     }
   }
 
-  handleCertificateProvision(details: any) {
-    console.log('A TLS certificate was provisioned')
-    console.log('Details: ' + JSON.stringify(details))
+  handleCertificateProvision() {
+    console.log('----- A TLS certificate was provisioned -----')
     const interval = setInterval(() => {
       const mas = this._libp2p
         .getMultiaddrs()
         .filter((ma: any) => ma.toString().includes('/sni/'))
         .map((ma: any) => ma.toString())
       if (mas.length > 0) {
-        console.log('addresses:')
+        console.log('----- TLS addresses: -----')
         console.log(mas.join('\n'))
+        console.log('----- End of TLS addresses -----')
       }
       clearInterval(interval)
     }, 1_000)
   }
 
+  handleCertificateRenew() {
+    console.log('----- A TLS certificate was renewed -----')
+  }
+
   handlePeerJoined(details: any) {
     P2P_LOGGER.debug('New peer joined us:' + details)
   }
@@ -316,7 +320,7 @@ export class OceanP2P extends EventEmitter {
           listen: bindInterfaces,
           announceFilter: (multiaddrs: any[]) =>
             multiaddrs.filter((m) => this.shouldAnnounce(m)),
-          appendAnnounce: config.p2pConfig.announceAddresses
+          announce: config.p2pConfig.announceAddresses
         }
       } else {
         addresses = {