Skip to content
This repository was archived by the owner on Feb 12, 2024. It is now read-only.

Commit 8eeba69

Browse files
committed
fix: pad seqno if needed
1 parent 38e78cc commit 8eeba69

File tree

1 file changed

+13
-1
lines changed
  • packages/ipfs-http-server/src/api/resources

1 file changed

+13
-1
lines changed

packages/ipfs-http-server/src/api/resources/pubsub.js

Lines changed: 13 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -77,10 +77,22 @@ export const subscribeResource = {
7777
* @type {import('@libp2p/interfaces/events').EventHandler<Message>}
7878
*/
7979
const handler = (msg) => {
80+
let sequenceNumber
81+
82+
if (msg.sequenceNumber != null) {
83+
let numberString = msg.sequenceNumber.toString(16)
84+
85+
if (numberString.length % 2 !== 0) {
86+
numberString = `0${numberString}`
87+
}
88+
89+
sequenceNumber = uint8ArrayFromString(numberString, 'base16')
90+
}
91+
8092
output.push({
8193
from: msg.from, // TODO: switch to peerIdFromString(msg.from).toString() when go-ipfs defaults to CIDv1
8294
data: base64url.encode(msg.data),
83-
seqno: msg.sequenceNumber != null ? base64url.encode(uint8ArrayFromString(msg.sequenceNumber.toString(16), 'base16')) : undefined,
95+
seqno: sequenceNumber,
8496
topicIDs: [base64url.encode(uint8ArrayFromString(msg.topic))]
8597
})
8698
}

0 commit comments

Comments
 (0)