fluencelabs/js-libp2p-noise
1
0
Fork 0
mirror of https://github.com/fluencelabs/js-libp2p-noise synced 2025-06-12 18:41:38 +00:00
Code Issues Projects Releases Wiki Activity

Test negative output

Browse Source
This commit is contained in:
Belma Gutlic
2020-01-15 11:40:32 +01:00
parent eeaaa8cc84
commit 26cb0c5a17
2 changed files with 27 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
src/handshake-ik.ts
View File

@ -51,7 +51,7 @@ export class IKHandshake implements IHandshake {
try { try {
await verifySignedPayload(receivedMessageBuffer.ns, plaintext, this.remotePeer.id); await verifySignedPayload(receivedMessageBuffer.ns, plaintext, this.remotePeer.id);
} catch (e) { } catch (e) {
throw new Error(`Error occurred while verifying signed payload: ${e.message}`); throw new Error(`Error occurred while verifying initiator's signed payload: ${e.message}`);
} }
} }
} }
@ -64,7 +64,7 @@ export class IKHandshake implements IHandshake {
try { try {
await verifySignedPayload(receivedMessageBuffer.ns, plaintext, this.remotePeer.id); await verifySignedPayload(receivedMessageBuffer.ns, plaintext, this.remotePeer.id);
} catch (e) { } catch (e) {
throw new Error(`Error occurred while verifying signed payload: ${e.message}`); throw new Error(`Error occurred while verifying responder's signed payload: ${e.message}`);
} }
} else { } else {
const messageBuffer = this.ik.sendMessage(this.session, this.payload); const messageBuffer = this.ik.sendMessage(this.session, this.payload);

26
test/ik-handshake.test.ts
View File

@ -1,11 +1,11 @@
import Wrap from "it-pb-rpc"; import Wrap from "it-pb-rpc";
import Duplex from 'it-pair/duplex'; import Duplex from 'it-pair/duplex';
import {Buffer} from "buffer"; import {Buffer} from "buffer";
import {assert, expect} from "chai";
import {createPeerIdsFromFixtures} from "./fixtures/peer"; import {createPeerIdsFromFixtures} from "./fixtures/peer";
import {generateKeypair, getPayload} from "../src/utils"; import {generateKeypair, getPayload} from "../src/utils";
import {IKHandshake} from "../src/handshake-ik"; import {IKHandshake} from "../src/handshake-ik";
import {assert} from "chai";
describe("IK Handshake", () => { describe("IK Handshake", () => {
let peerA, peerB, fakePeer; let peerA, peerB, fakePeer;
@ -53,4 +53,28 @@ describe("IK Handshake", () => {
assert(false, e.message); assert(false, e.message);
} }
}); });
it("should throw error if responder's static key changed", async() => {
try {
const duplex = Duplex();
const connectionFrom = Wrap(duplex[0]);
const connectionTo = Wrap(duplex[1]);
const prologue = Buffer.from('/noise');
const staticKeysInitiator = generateKeypair();
const staticKeysResponder = generateKeypair();
const oldScammyKeys = generateKeypair();
const initPayload = await getPayload(peerA, staticKeysInitiator.publicKey);
const handshakeInit = new IKHandshake(true, initPayload, prologue, staticKeysInitiator, connectionFrom, peerB, oldScammyKeys.publicKey);
const respPayload = await getPayload(peerB, staticKeysResponder.publicKey);
const handshakeResp = new IKHandshake(false, respPayload, prologue, staticKeysResponder, connectionTo, peerA, staticKeysInitiator.publicKey);
await handshakeInit.stage0();
await handshakeResp.stage0();
} catch (e) {
expect(e.message).to.include("Error occurred while verifying initiator's signed payload");
}
});
}); });