ipfs-pubsub-peer-monitor - npm Package Compare versions

Comparing version 0.0.1 to 0.0.2

package.json

 {
   "name": "ipfs-pubsub-peer-monitor",
-  "version": "0.0.1",
+  "version": "0.0.2",
   "description": "Monitor peers joining and leaving an IPFS PubSub topic",
   "main": "src/ipfs-pubsub-peer-monitor.js",
   "scripts": {
-    "test": "echo \"Error: no test specified\" && exit 1"
+    "test": "mocha --exit"
   },
@@ -13,3 +13,6 @@ "author": "Haad",
     "hyperdiff": "^2.0.4"
+  },
+  "devDependencies": {
+    "mocha": "^5.0.5"
   }
 }

src/ipfs-pubsub-peer-monitor.js

@@ -24,3 +24,9 @@ 'use strict'
   start () {
-    this._interval = setInterval(this._pollPeers.bind(this), this._options.pollInterval)
+    if (this._interval)
+      this.stop()
+
+    this._interval = setInterval(
+      this._pollPeers.bind(this), 
+      this._options.pollInterval
+    )
   }
@@ -30,5 +36,7 @@
     clearInterval(this._interval)
+    this._interval = null
   }
 
-  getPeers () {
+  async getPeers () {
+    this._peers = await this._pubsub.peers(this._topic)
     return this._peers.slice()
@@ -41,11 +49,10 @@ }
 
-  _pollPeers () {
-    this._pubsub.peers(this._topic, (err, peers) => {
-      if (err) {
-        this.emit('error', err)
-        return // early
-      }
+  async _pollPeers () {
+    try {
+      const peers = await this._pubsub.peers(this._topic)
       this._emitChanges(this._peers, peers)
       this._peers = peers
-    })
+    } catch (err) {
+        this.emit('error', err)
+    }
   }
@@ -52,0 +59,0 @@

New alerts

License Policy Violation

License

This package is not allowed per your license policy. Review the package's license to ensure compliance.

Found 1 instance in 1 package

Fixed alerts

License Policy Violation

License

This package is not allowed per your license policy. Review the package's license to ensure compliance.

Found 1 instance in 1 package

No tests

Quality

Package does not have any tests. This is a strong signal of a poorly maintained or low quality package.

Found 1 instance in 1 package

Improved metrics

Total package byte prevSize

7012

increased by78.56%

Number of package files

6

increased by50%

Lines of code

147

increased by206.25%

Number of low quality alerts

2

decreased by-33.33%

Worsened metrics

Dev dependency count

1

increased byInfinity%

No dependency changes