rpc.cjs , rpc.d.ts, rpc.js -> rpc.ts

.gitignore

@@ -5,4 +5,5 @@ dist/
 docs/
 .nyc_output/coverage-final.json
 .vscode/settings.json
+.vscode/launch.json
 benchmark_data/

CHANGELOG.md

@@ -15,6 +15,18 @@
 * chore: update cd action by @mpetrunic in https://github.com/ChainSafe/js-libp2p-gossipsub/pull/245
 
 
+## [5.1.0](https://github.com/ChainSafe/js-libp2p-gossipsub/compare/v5.0.0...v5.1.0) (2022-10-28)
+
+
+### Features
+
+* Add stream option to limit inbound message size ([#349](https://github.com/ChainSafe/js-libp2p-gossipsub/issues/349)) ([3475242](https://github.com/ChainSafe/js-libp2p-gossipsub/commit/3475242ed254f7647798ab7f36b21909f6cb61da))
+
+
+### Bug Fixes
+
+* mark import as type ([#365](https://github.com/ChainSafe/js-libp2p-gossipsub/issues/365)) ([19507d9](https://github.com/ChainSafe/js-libp2p-gossipsub/commit/19507d9da5e11702182cfc97300642c5fb78f964))
+
 ## [5.0.0](https://github.com/ChainSafe/js-libp2p-gossipsub/compare/v4.2.0...v5.0.0) (2022-10-22)
 
 

package.json

@@ -1,6 +1,6 @@
 {
   "name": "@chainsafe/libp2p-gossipsub",
-  "version": "5.0.0",
+  "version": "5.1.0",
   "description": "A typescript implementation of gossipsub",
   "leadMaintainer": "Cayman Nava <caymannava@gmail.com>",
   "files": [
@@ -152,4 +152,4 @@
     "Franck Royer <franck@royer.one>",
     "ChainSafe <superadmin@chainsafe.io>"
   ]
-}
+}

src/index.ts

@@ -8,7 +8,7 @@ import type { PeerId } from '@libp2p/interface-peer-id'
 import { CustomEvent, EventEmitter } from '@libp2p/interfaces/events'
 
 import { MessageCache } from './message-cache.js'
-import { RPC, IRPC } from './message/rpc.js'
+import { IRPC, RPC } from './message/rpc.js'
 import * as constants from './constants.js'
 import { shuffle, messageIdToString } from './utils/index.js'
 import {
@@ -196,14 +196,14 @@ enum GossipStatusCode {
 
 type GossipStatus =
   | {
-      code: GossipStatusCode.started
-      registrarTopologyIds: string[]
-      heartbeatTimeout: ReturnType<typeof setTimeout>
-      hearbeatStartMs: number
-    }
+    code: GossipStatusCode.started
+    registrarTopologyIds: string[]
+    heartbeatTimeout: ReturnType<typeof setTimeout>
+    hearbeatStartMs: number
+  }
   | {
-      code: GossipStatusCode.stopped
-    }
+    code: GossipStatusCode.stopped
+  }
 
 interface GossipOptions extends GossipsubOpts {
   scoreParams: PeerScoreParams

src/message/decodeRpc.ts

@@ -1,4 +1,5 @@
-import type { IRPC, RPC } from './rpc'
+import { IRPC, RPC } from './rpc.js'
+
 import protobuf from 'protobufjs/minimal.js'
 
 export type DecodeRPCLimits = {
@@ -244,4 +245,4 @@ function decodePeerInfo(r: protobuf.Reader, l: number) {
     }
   }
   return m
-}
+}