libp2p-pubsub - npm Package Compare versions

Comparing version 0.0.1 to 0.0.2

CHANGELOG.md

@@ -0,1 +1,11 @@
+<a name="0.0.2"></a>
+## [0.0.2](https://github.com/libp2p/js-libp2p-pubsub/compare/v0.0.1...v0.0.2) (2019-02-08)
+
+
+### Features
+
+* added a time cache and a mapping of topics to peers ([13a56a4](https://github.com/libp2p/js-libp2p-pubsub/commit/13a56a4))
+
+
+
 <a name="0.0.1"></a>
@@ -2,0 +12,0 @@ ## 0.0.1 (2019-01-25)

package.json

 {
   "name": "libp2p-pubsub",
-  "version": "0.0.1",
+  "version": "0.0.2",
   "description": "Pubsub base protocol for libp2p pubsub routers",
@@ -63,7 +63,9 @@ "leadMaintainer": "Vasco Santos <[e-mail]>",
     "protons": "^1.0.1",
-    "pull-pushable": "^2.2.0"
+    "pull-pushable": "^2.2.0",
+    "time-cache": "~0.3.0"
   },
   "contributors": [
+    "Mikerah <[e-mail]>",
     "Vasco Santos <[e-mail]>"
   ]
 }

src/index.js

@@ -7,3 +7,3 @@ 'use strict'
 const asyncEach = require('async/each')
-
+const TimeCache = require('time-cache')
 const debug = require('debug')
@@ -37,2 +37,16 @@ const errcode = require('err-code')
     /**
+     * Map of topics to which peers are subscribed to
+     *
+     * @type {Map<string, Peer>}
+     */
+    this.topics = new Map()
+
+    /**
+     * Cache of seen messages
+     *
+     * @type {TimeCache}
+     */
+    this.seenCache = new TimeCache()
+
+    /**
      * Map of peers.
@@ -39,0 +53,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

Improved metrics

Total package byte prevSize

1143023

increased by5.34%

Lines of code

9217

increased by5.54%

Worsened metrics

Dependency count

7

increased by16.67%

Dependency changes

• + Addedtime-cache@~0.3.0

• + Addedlodash.throttle@4.1.1(transitive)

• + Addedtime-cache@0.3.0(transitive)