ipfs-bitswap - npm Package Compare versions

Comparing version 17.0.0 to 17.0.1

dist/src/bitswap.d.ts

@@ -9,3 +9,3 @@ import { WantManager } from './want-manager/index.js';
 import type { Libp2p } from '@libp2p/interface-libp2p';
-import type { Blockstore, Options, Pair } from 'interface-blockstore';
+import type { Blockstore, Pair } from 'interface-blockstore';
 import type { PeerId } from '@libp2p/interface-peer-id';
@@ -15,2 +15,3 @@ import type { BitswapMessage } from './message/index.js';
 import type { ProgressOptions } from 'progress-events';
+import type { AwaitIterable } from 'interface-store';
 /**
@@ -91,3 +92,3 @@ * JavaScript implementation of the Bitswap 'data exchange' protocol
      */
-    putMany(source: Iterable<Pair> | AsyncIterable<Pair>, options?: Options): AsyncGenerator<Pair>;
+    putMany(source: Iterable<Pair> | AsyncIterable<Pair>, options?: AbortOptions): AwaitIterable<CID>;
     /**
@@ -94,0 +95,0 @@ * Sends notifications about the arrival of a block

dist/src/bitswap.js

@@ -9,2 +9,3 @@ import { WantManager } from './want-manager/index.js';
 import { CID } from 'multiformats/cid';
+import forEach from 'it-foreach';
 const hashLoader = {
@@ -253,6 +254,5 @@ async getHasher() {
     async *putMany(source, options) {
-        for await (const { cid, block } of this.blockstore.putMany(source, options)) {
+        yield* this.blockstore.putMany(forEach(source, ({ cid, block }) => {
             this.notify(cid, block);
-            yield { cid, block };
-        }
+        }), options);
     }
@@ -259,0 +259,0 @@ /**

dist/src/network.js

@@ -89,3 +89,3 @@ import * as lp from 'it-length-prefixed';
             this._log('incoming new bitswap %s connection from %p', stream.stat.protocol, connection.remotePeer);
-            await pipe(abortableSource(stream.source, controller.signal), lp.decode(), async (source) => {
+            await pipe(abortableSource(stream.source, controller.signal), (source) => lp.decode(source), async (source) => {
                 for await (const data of source) {
@@ -195,3 +195,3 @@ try {
             }
-            await pipe([serialized], lp.encode(), stream);
+            await pipe([serialized], (source) => lp.encode(source), stream);
         }
@@ -198,0 +198,0 @@ catch (err) {

package.json

 {
   "name": "ipfs-bitswap",
-  "version": "17.0.0",
+  "version": "17.0.1",
   "description": "JavaScript implementation of the Bitswap data exchange protocol used by IPFS",
@@ -175,3 +175,3 @@ "license": "Apache-2.0 OR MIT",
     "@libp2p/tracked-map": "^3.0.0",
-    "@multiformats/multiaddr": "^11.0.0",
+    "@multiformats/multiaddr": "^12.1.0",
     "@vascosantos/moving-average": "^1.1.0",
@@ -181,7 +181,10 @@ "abortable-iterator": "^4.0.2",
     "blockstore-core": "^4.0.0",
+    "events": "^3.3.0",
     "interface-blockstore": "^5.0.0",
-    "it-length-prefixed": "^8.0.2",
-    "it-map": "^2.0.1",
-    "it-pipe": "^2.0.4",
-    "it-take": "^2.0.1",
+    "interface-store": "^5.1.0",
+    "it-foreach": "^2.0.2",
+    "it-length-prefixed": "^9.0.0",
+    "it-map": "^3.0.2",
+    "it-pipe": "^3.0.1",
+    "it-take": "^3.0.1",
     "just-debounce-it": "^3.0.1",
@@ -199,3 +202,3 @@ "multiformats": "^11.0.0",
     "@chainsafe/libp2p-noise": "^11.0.0",
-    "@libp2p/kad-dht": "^7.0.0",
+    "@libp2p/kad-dht": "^8.0.6",
     "@libp2p/mplex": "^7.0.0",
@@ -212,5 +215,5 @@ "@libp2p/peer-id": "^2.0.0",
     "iso-random-stream": "^2.0.0",
-    "it-all": "^2.0.0",
-    "it-drain": "^2.0.0",
-    "libp2p": "^0.42.0",
+    "it-all": "^3.0.1",
+    "it-drain": "^3.0.1",
+    "libp2p": "^0.43.3",
     "lodash.difference": "^4.5.0",
@@ -217,0 +220,0 @@ "lodash.flatten": "^4.4.0",

src/bitswap.ts

@@ -9,5 +9,6 @@ import { WantManager } from './want-manager/index.js'
 import { CID } from 'multiformats/cid'
+import forEach from 'it-foreach'
 import type { BitswapOptions, Bitswap, MultihashHasherLoader, WantListEntry, BitswapWantProgressEvents, BitswapNotifyProgressEvents } from './index.js'
 import type { Libp2p } from '@libp2p/interface-libp2p'
-import type { Blockstore, Options, Pair } from 'interface-blockstore'
+import type { Blockstore, Pair } from 'interface-blockstore'
 import type { Logger } from '@libp2p/logger'
@@ -18,2 +19,3 @@ import type { PeerId } from '@libp2p/interface-peer-id'
 import type { ProgressOptions } from 'progress-events'
+import type { AwaitIterable } from 'interface-store'
 
@@ -323,8 +325,6 @@ const hashLoader: MultihashHasherLoader = {
    */
-  async * putMany (source: Iterable<Pair> | AsyncIterable<Pair>, options?: Options): AsyncGenerator<Pair> {
-    for await (const { cid, block } of this.blockstore.putMany(source, options)) {
+  async * putMany (source: Iterable<Pair> | AsyncIterable<Pair>, options?: AbortOptions): AwaitIterable<CID> {
+    yield * this.blockstore.putMany(forEach(source, ({ cid, block }) => {
       this.notify(cid, block)
-
-      yield { cid, block }
-    }
+    }), options)
   }
@@ -331,0 +331,0 @@

src/network.ts

@@ -160,3 +160,3 @@ import * as lp from 'it-length-prefixed'
         abortableSource(stream.source, controller.signal),
-        lp.decode(),
+        (source) => lp.decode(source),
         async (source) => {
@@ -291,3 +291,3 @@ for await (const data of source) {
         [serialized],
-        lp.encode(),
+        (source) => lp.encode(source),
         stream
@@ -294,0 +294,0 @@ )

No alert changes

Improved metrics

Total package byte prevSize

471132

0.53%

Lines of code

7099

0.14%

Worsened metrics

Dependency count

31

10.71%

Dependency changes

• + Added

  events@^3.3.0

• + Added

  interface-store@^5.1.0

• + Added

  it-foreach@^2.0.2

• + Added

  events@3.3.0
  (transitive)

• + Added

  it-foreach@2.1.4
  (transitive)

• + Added

  it-length-prefixed@9.1.1
  (transitive)

• + Added

  it-map@3.1.4
  (transitive)

• + Added

  it-pipe@3.0.1
  (transitive)

• + Added

  it-reader@6.0.4
  (transitive)

• + Added

  it-take@3.0.9
  (transitive)

• - Removed

  @fastify/busboy@2.1.1
  (transitive)

• - Removed

  @multiformats/multiaddr@11.6.1
  (transitive)

• - Removed

  byte-access@1.0.1
  (transitive)

• - Removed

  dns-over-http-resolver@2.1.3
  (transitive)

• - Removed

  it-length-prefixed@8.0.4
  (transitive)

• - Removed

  it-map@2.0.1
  (transitive)

• - Removed

  it-merge@2.0.1
  (transitive)

• - Removed

  it-pipe@2.0.5
  (transitive)

• - Removed

  it-take@2.0.1
  (transitive)

• - Removed

  longbits@1.1.0
  (transitive)

• - Removed

  native-fetch@4.0.2
  (transitive)

• - Removed

  receptacle@1.3.2
  (transitive)

• - Removed

  uint8-varint@1.0.8
  (transitive)

• - Removed

  undici@5.29.0
  (transitive)

• Updated

  @multiformats/multiaddr@^12.1.0

• Updated

  it-length-prefixed@^9.0.0

• Updated

  it-map@^3.0.2

• Updated

  it-pipe@^3.0.1

• Updated

  it-take@^3.0.1