@libp2p/peer-store - npm Package Compare versions

Comparing version 11.0.21-4939ef7ae to 11.0.21-52a46ecad

dist/src/utils/bytes-to-peer.js

 import { publicKeyFromProtobuf } from '@libp2p/crypto/keys';
 import { peerIdFromPublicKey } from '@libp2p/peer-id';
 import { multiaddr } from '@multiformats/multiaddr';
+import { base58btc } from 'multiformats/bases/base58';
+import * as Digest from 'multiformats/hashes/digest';
 import { Peer as PeerPB } from '../pb/peer.js';
+function populatePublicKey(peerId, protobuf) {
+    if (peerId.publicKey != null || protobuf.publicKey == null) {
+        return peerId;
+    }
+    let digest;
+    if (peerId.type === 'RSA') {
+        // avoid hashing public key
+        const multihash = base58btc.decode(`z${peerId}`);
+        digest = Digest.decode(multihash);
+    }
+    const publicKey = publicKeyFromProtobuf(protobuf.publicKey, digest);
+    return peerIdFromPublicKey(publicKey);
+}
 export function bytesToPeer(peerId, buf) {
     const peer = PeerPB.decode(buf);
-    if (peer.publicKey != null && peerId.publicKey == null) {
-        const publicKey = publicKeyFromProtobuf(peer.publicKey);
-        peerId = peerIdFromPublicKey(publicKey);
-    }
     const tags = new Map();
@@ -22,3 +33,3 @@ // remove any expired tags
         ...peer,
-        id: peerId,
+        id: populatePublicKey(peerId, peer),
         addresses: peer.addresses.map(({ multiaddr: ma, isCertified }) => {
@@ -25,0 +36,0 @@ return {

package.json

 {
   "name": "@libp2p/peer-store",
-  "version": "11.0.21-4939ef7ae",
+  "version": "11.0.21-52a46ecad",
   "description": "Stores information about peers libp2p knows on the network",
@@ -31,3 +31,3 @@ "license": "Apache-2.0 OR MIT",
     ".": {
-      "types": "./src/index.d.ts",
+      "types": "./dist/src/index.d.ts",
       "import": "./dist/src/index.js"
@@ -63,6 +63,6 @@ }
   "dependencies": {
-    "@libp2p/crypto": "5.0.13-4939ef7ae",
-    "@libp2p/interface": "2.6.1-4939ef7ae",
-    "@libp2p/peer-id": "5.0.14-4939ef7ae",
-    "@libp2p/peer-record": "8.0.21-4939ef7ae",
+    "@libp2p/crypto": "5.0.13-52a46ecad",
+    "@libp2p/interface": "2.6.1-52a46ecad",
+    "@libp2p/peer-id": "5.0.14-52a46ecad",
+    "@libp2p/peer-record": "8.0.21-52a46ecad",
     "@multiformats/multiaddr": "^12.3.3",
@@ -78,5 +78,6 @@ "interface-datastore": "^8.3.1",
   "devDependencies": {
-    "@libp2p/logger": "5.1.10-4939ef7ae",
+    "@libp2p/logger": "5.1.10-52a46ecad",
     "@types/sinon": "^17.0.3",
     "aegir": "^45.1.1",
+    "benchmark": "^2.1.4",
     "datastore-core": "^10.0.2",
@@ -83,0 +84,0 @@ "delay": "^6.0.0",

src/utils/bytes-to-peer.ts

 import { publicKeyFromProtobuf } from '@libp2p/crypto/keys'
 import { peerIdFromPublicKey } from '@libp2p/peer-id'
 import { multiaddr } from '@multiformats/multiaddr'
+import { base58btc } from 'multiformats/bases/base58'
+import * as Digest from 'multiformats/hashes/digest'
 import { Peer as PeerPB } from '../pb/peer.js'
 import type { PeerId, Peer, Tag } from '@libp2p/interface'
 
-export function bytesToPeer (peerId: PeerId, buf: Uint8Array): Peer {
-  const peer = PeerPB.decode(buf)
+function populatePublicKey (peerId: PeerId, protobuf: PeerPB): PeerId {
+  if (peerId.publicKey != null || protobuf.publicKey == null) {
+    return peerId
+  }
 
-  if (peer.publicKey != null && peerId.publicKey == null) {
-    const publicKey = publicKeyFromProtobuf(peer.publicKey)
-    peerId = peerIdFromPublicKey(publicKey)
+  let digest: any
+
+  if (peerId.type === 'RSA') {
+    // avoid hashing public key
+    const multihash = base58btc.decode(`z${peerId}`)
+    digest = Digest.decode(multihash)
   }
 
+  const publicKey = publicKeyFromProtobuf(protobuf.publicKey, digest)
+  return peerIdFromPublicKey(publicKey)
+}
+
+export function bytesToPeer (peerId: PeerId, buf: Uint8Array): Peer {
+  const peer = PeerPB.decode(buf)
   const tags = new Map<string, Tag>()
@@ -30,3 +43,3 @@
     ...peer,
-    id: peerId,
+    id: populatePublicKey(peerId, peer),
     addresses: peer.addresses.map(({ multiaddr: ma, isCertified }) => {
@@ -33,0 +46,0 @@ return {

No alert changes

Worsened metrics

Total package byte prevSize

269391

decreased by-15.72%

Dev dependency count

10

increased by11.11%

Lines of code

2765

decreased by-7.62%

Dependency changes

• + Added@libp2p/crypto@5.0.13-52a46ecad(transitive)

• + Added@libp2p/interface@2.6.1-52a46ecad(transitive)

• + Added@libp2p/logger@5.1.10-52a46ecad(transitive)

• + Added@libp2p/peer-id@5.0.14-52a46ecad(transitive)

• + Added@libp2p/peer-record@8.0.21-52a46ecad(transitive)

• + Added@libp2p/utils@6.5.5-52a46ecad(transitive)

• - Removed@libp2p/crypto@5.0.13-4939ef7ae(transitive)

• - Removed@libp2p/interface@2.6.1-4939ef7ae(transitive)

• - Removed@libp2p/logger@5.1.10-4939ef7ae(transitive)

• - Removed@libp2p/peer-id@5.0.14-4939ef7ae(transitive)

• - Removed@libp2p/peer-record@8.0.21-4939ef7ae(transitive)

• - Removed@libp2p/utils@6.5.5-4939ef7ae(transitive)

• - Removedasn1js@3.0.5(transitive)

• - Removedpvtsutils@1.3.6(transitive)

• - Removedpvutils@1.1.3(transitive)

• - Removedtslib@2.8.1(transitive)

• Updated@libp2p/crypto@5.0.13-52a46ecad

• Updated@libp2p/interface@2.6.1-52a46ecad

• Updated@libp2p/peer-id@5.0.14-52a46ecad

• Updated@libp2p/peer-record@8.0.21-52a46ecad