+9
-1
@@ -48,6 +48,8 @@ const safetyCatch = require('safety-catch') | ||
| async suspend () { | ||
| async suspend ({ log = noop } = {}) { | ||
| if (this.suspended) return | ||
| this.suspended = true | ||
| log('Suspending announcer') | ||
| // Suspend has its own sleep logic | ||
@@ -61,5 +63,9 @@ // so we don't want to hang on this one | ||
| if (this._updating) await this._updating | ||
| log('Suspending announcer (post update)') | ||
| if (this.suspended === false || this.stopped) return | ||
| log('Suspending announcer (pre unannounce)') | ||
| await this._unannounceCurrent() | ||
| log('Suspending announcer (post unannounce)') | ||
| } | ||
@@ -289,1 +295,3 @@ | ||
| } | ||
| function noop () {} |
+4
-2
@@ -62,7 +62,9 @@ const { EventEmitter } = require('events') | ||
| async suspend () { | ||
| async suspend ({ log = noop } = {}) { | ||
| log('Suspending hyperdht server') | ||
| if (this._listening !== null) await this._listening | ||
| log('Suspending hyperdht server (post listening)') | ||
| this.suspended = true | ||
| this._clearAll() | ||
| return this._announcer ? this._announcer.suspend() : Promise.resolve() | ||
| return this._announcer ? this._announcer.suspend({ log }) : Promise.resolve() | ||
| } | ||
@@ -69,0 +71,0 @@ |
+1
-1
| { | ||
| "name": "hyperdht", | ||
| "version": "6.20.2", | ||
| "version": "6.20.3", | ||
| "description": "The DHT powering Hyperswarm", | ||
@@ -5,0 +5,0 @@ "main": "index.js", |
Long strings
Supply chain riskContains long string literals, which may be a sign of obfuscated or packed code.
Found 1 instance in 1 package
Long strings
Supply chain riskContains long string literals, which may be a sign of obfuscated or packed code.
Found 1 instance in 1 package
142938
0.24%3947
0.18%