Make the Networker a Nanoresource

Author: andrewosh

index.js

@@ -2,6 +2,7 @@ const crypto = require('crypto')
 const { EventEmitter } = require('events')
 const { promisify } = require('util')
 
+const { NanoresourcePromise: Nanoresource } = require('nanoresource-promise/emitter')
 const HypercoreProtocol = require('hypercore-protocol')
 const hyperswarm = require('hyperswarm')
 const codecs = require('codecs')
@@ -13,7 +14,7 @@ const log = require('debug')('corestore:network')
 const OUTER_STREAM = Symbol('networker-outer-stream')
 const STREAM_PEER = Symbol('networker-stream-peer')
 
-class CorestoreNetworker extends EventEmitter {
+class CorestoreNetworker extends Nanoresource {
   constructor (corestore, opts = {}) {
     super()
     this.corestore = corestore
@@ -145,7 +146,7 @@ class CorestoreNetworker extends EventEmitter {
     }
   }
 
-  listen () {
+  _open () {
     const self = this
     if (this.swarm) return
 
@@ -196,6 +197,10 @@ class CorestoreNetworker extends EventEmitter {
     })
   }
 
+  listen () {
+    return this.open()
+  }
+
   status (discoveryKey) {
     if (Buffer.isBuffer(discoveryKey)) discoveryKey = discoveryKey.toString('hex')
     return this._configurations.get(discoveryKey)
@@ -250,12 +255,9 @@ class CorestoreNetworker extends EventEmitter {
     return ext
   }
 
-  async close () {
+  async _close () {
     if (!this.swarm) return null
 
-    const leaving = [...this._joined].map(dkey => this._leave(dkey))
-    await Promise.all(leaving)
-
     for (const ext of this._extensions) {
       ext.destroy()
     }

package.json

@@ -8,6 +8,7 @@
     "end-of-stream": "^1.4.4",
     "hypercore-protocol": "^8.0.0",
     "hyperswarm": "^2.14.1",
+    "nanoresource-promise": "^1.2.2",
     "pump": "^3.0.0"
   },
   "devDependencies": {