mirror of
https://github.com/fluencelabs/js-libp2p-interfaces
synced 2025-03-31 03:01:29 +00:00
ba15a48dd9
* feat: interface pubsub * chore: pubsub router tests * chore: move pubsub abstractions from gossipsub * chore: address review * chore: revamp docs * chore: add emit self tests to interface * chore: refactor base tests * chore: publish should only accept one topic per api call * chore: normalize msg before emit * chore: do not reset inbound stream * chore: apply suggestions from code review Co-authored-by: Jacob Heun <jacobheun@gmail.com> * chore: address review * fix: remove subscribe handler * chore: remove bits from create peerId Co-authored-by: Jacob Heun <jacobheun@gmail.com> * chore: remove delay from topic validators tests * chore: add event emitter information * fix: topic validator docs Co-authored-by: Jacob Heun <jacobheun@gmail.com>
94 lines
2.8 KiB
JavaScript
94 lines
2.8 KiB
JavaScript
/* eslint-env mocha */
|
|
/* eslint max-nested-callbacks: ["error", 5] */
|
|
'use strict'
|
|
|
|
const { expect } = require('aegir/utils/chai')
|
|
const uint8ArrayConcat = require('uint8arrays/concat')
|
|
const uint8ArrayFromString = require('uint8arrays/from-string')
|
|
|
|
const { Message } = require('../../src/pubsub/message')
|
|
const {
|
|
signMessage,
|
|
SignPrefix,
|
|
verifySignature
|
|
} = require('../../src/pubsub/message/sign')
|
|
const PeerId = require('peer-id')
|
|
const { randomSeqno } = require('../../src/pubsub/utils')
|
|
|
|
describe('message signing', () => {
|
|
let peerId
|
|
before(async () => {
|
|
peerId = await PeerId.create({
|
|
bits: 1024
|
|
})
|
|
})
|
|
|
|
it('should be able to sign and verify a message', async () => {
|
|
const message = {
|
|
from: peerId.id,
|
|
data: uint8ArrayFromString('hello'),
|
|
seqno: randomSeqno(),
|
|
topicIDs: ['test-topic']
|
|
}
|
|
|
|
const bytesToSign = uint8ArrayConcat([SignPrefix, Message.encode(message)])
|
|
const expectedSignature = await peerId.privKey.sign(bytesToSign)
|
|
|
|
const signedMessage = await signMessage(peerId, message)
|
|
|
|
// Check the signature and public key
|
|
expect(signedMessage.signature).to.eql(expectedSignature)
|
|
expect(signedMessage.key).to.eql(peerId.pubKey.bytes)
|
|
|
|
// Verify the signature
|
|
const verified = await verifySignature(signedMessage)
|
|
expect(verified).to.eql(true)
|
|
})
|
|
|
|
it('should be able to extract the public key from an inlined key', async () => {
|
|
const secPeerId = await PeerId.create({ keyType: 'secp256k1' })
|
|
|
|
const message = {
|
|
from: secPeerId.id,
|
|
data: uint8ArrayFromString('hello'),
|
|
seqno: randomSeqno(),
|
|
topicIDs: ['test-topic']
|
|
}
|
|
|
|
const bytesToSign = uint8ArrayConcat([SignPrefix, Message.encode(message)])
|
|
const expectedSignature = await secPeerId.privKey.sign(bytesToSign)
|
|
|
|
const signedMessage = await signMessage(secPeerId, message)
|
|
|
|
// Check the signature and public key
|
|
expect(signedMessage.signature).to.eql(expectedSignature)
|
|
signedMessage.key = undefined
|
|
|
|
// Verify the signature
|
|
const verified = await verifySignature(signedMessage)
|
|
expect(verified).to.eql(true)
|
|
})
|
|
|
|
it('should be able to extract the public key from the message', async () => {
|
|
const message = {
|
|
from: peerId.id,
|
|
data: uint8ArrayFromString('hello'),
|
|
seqno: randomSeqno(),
|
|
topicIDs: ['test-topic']
|
|
}
|
|
|
|
const bytesToSign = uint8ArrayConcat([SignPrefix, Message.encode(message)])
|
|
const expectedSignature = await peerId.privKey.sign(bytesToSign)
|
|
|
|
const signedMessage = await signMessage(peerId, message)
|
|
|
|
// Check the signature and public key
|
|
expect(signedMessage.signature).to.eql(expectedSignature)
|
|
expect(signedMessage.key).to.eql(peerId.pubKey.bytes)
|
|
|
|
// Verify the signature
|
|
const verified = await verifySignature(signedMessage)
|
|
expect(verified).to.eql(true)
|
|
})
|
|
})
|