mirror of
https://github.com/fluencelabs/js-libp2p
synced 2025-03-30 06:11:05 +00:00
1e869717ff
* fix: replace node buffers with uint8arrays Upgrades all deps and replaces all use of node Buffers with Uint8Arrays BREAKING CHANGES: - All deps used by this module now use Uint8Arrays in place of node Buffers * chore: browser fixes * chore: remove .only * chore: stringify uint8array before parsing * chore: update interop suite * chore: remove ts from build command * chore: update deps * fix: update records to use uint8array * chore: fix lint * chore: update deps Co-authored-by: Jacob Heun <jacobheun@gmail.com>
91 lines
2.5 KiB
JavaScript
91 lines
2.5 KiB
JavaScript
'use strict'
|
|
/* eslint-env mocha */
|
|
|
|
const chai = require('chai')
|
|
chai.use(require('dirty-chai'))
|
|
chai.use(require('chai-bytes'))
|
|
chai.use(require('chai-as-promised'))
|
|
const { expect } = chai
|
|
|
|
const Envelope = require('../../src/record/envelope')
|
|
const Record = require('libp2p-interfaces/src/record')
|
|
const { codes: ErrorCodes } = require('../../src/errors')
|
|
|
|
const peerUtils = require('../utils/creators/peer')
|
|
|
|
const domain = 'libp2p-testing'
|
|
const codec = '/libp2p/testdata'
|
|
|
|
class TestRecord extends Record {
|
|
constructor (data) {
|
|
super(domain, codec)
|
|
this.data = data
|
|
}
|
|
|
|
marshal () {
|
|
return Buffer.from(this.data)
|
|
}
|
|
|
|
equals (other) {
|
|
return Buffer.compare(this.data, other.data)
|
|
}
|
|
}
|
|
|
|
describe('Envelope', () => {
|
|
const payloadType = Buffer.from(codec)
|
|
let peerId
|
|
let testRecord
|
|
|
|
before(async () => {
|
|
[peerId] = await peerUtils.createPeerId()
|
|
testRecord = new TestRecord('test-data')
|
|
})
|
|
|
|
it('creates an envelope with a random key', () => {
|
|
const payload = testRecord.marshal()
|
|
const signature = Buffer.from(Math.random().toString(36).substring(7))
|
|
|
|
const envelope = new Envelope({
|
|
peerId,
|
|
payloadType,
|
|
payload,
|
|
signature
|
|
})
|
|
|
|
expect(envelope).to.exist()
|
|
expect(envelope.peerId.equals(peerId)).to.eql(true)
|
|
expect(envelope.payloadType).to.equalBytes(payloadType)
|
|
expect(envelope.payload).to.equalBytes(payload)
|
|
expect(envelope.signature).to.equalBytes(signature)
|
|
})
|
|
|
|
it('can seal a record', async () => {
|
|
const envelope = await Envelope.seal(testRecord, peerId)
|
|
expect(envelope).to.exist()
|
|
expect(envelope.peerId.equals(peerId)).to.eql(true)
|
|
expect(envelope.payloadType).to.equalBytes(payloadType)
|
|
expect(envelope.payload).to.exist()
|
|
expect(envelope.signature).to.exist()
|
|
})
|
|
|
|
it('can open and verify a sealed record', async () => {
|
|
const envelope = await Envelope.seal(testRecord, peerId)
|
|
const rawEnvelope = envelope.marshal()
|
|
|
|
const unmarshalledEnvelope = await Envelope.openAndCertify(rawEnvelope, testRecord.domain)
|
|
expect(unmarshalledEnvelope).to.exist()
|
|
|
|
const equals = envelope.equals(unmarshalledEnvelope)
|
|
expect(equals).to.eql(true)
|
|
})
|
|
|
|
it('throw on open and verify when a different domain is used', async () => {
|
|
const envelope = await Envelope.seal(testRecord, peerId)
|
|
const rawEnvelope = envelope.marshal()
|
|
|
|
await expect(Envelope.openAndCertify(rawEnvelope, '/bad-domain'))
|
|
.to.eventually.be.rejected()
|
|
.and.to.have.property('code', ErrorCodes.ERR_SIGNATURE_NOT_VALID)
|
|
})
|
|
})
|