fluencelabs/js-libp2p-noise
1
0
Fork 0
mirror of https://github.com/fluencelabs/js-libp2p-noise synced 2025-04-25 08:22:35 +00:00
Code Issues Projects Releases Wiki Activity

Finish all handshake stages

Browse Source
This commit is contained in:
morrigan 2019-11-06 15:49:20 +01:00
parent 87d7ed9c41
commit 051f0765f9
2 changed files with 15 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
src/xx.ts
View File

@ -375,7 +375,7 @@ export class XXHandshake {
return messageBuffer;
}
public async RecvMessage(session: NoiseSession, message: MessageBuffer) : Promise<bytes> {
public async recvMessage(session: NoiseSession, message: MessageBuffer) : Promise<bytes> {
let plaintext: bytes;
if (session.mc.eqn(0)) {
plaintext = await this.readMessageA(session.hs, message);

17
test/xx.test.ts
View File

@ -73,7 +73,8 @@ describe("Index", () => {
expect(messageBuffer.ne.length).not.equal(0);
// responder receives message
const plaintext = await xx.RecvMessage(nsResp, messageBuffer);
const plaintext = await xx.recvMessage(nsResp, messageBuffer);
console.log("Stage 0 responder payload: ", plaintext);
/* STAGE 1 */
@ -91,8 +92,18 @@ describe("Index", () => {
expect(messageBuffer2.ns.length).not.equal(0);
// initiator receive payload
const plaintext2 = await xx.RecvMessage(nsInit, messageBuffer2);
console.log(plaintext2);
const plaintext2 = await xx.recvMessage(nsInit, messageBuffer2);
console.log("Stage 1 responder payload: ", plaintext2);
/* STAGE 2 */
// initiator send message
const messageBuffer3 = await xx.sendMessage(nsInit, Buffer.alloc(0));
// responder receive message
const plaintext3 = await xx.recvMessage(nsResp, messageBuffer3);
console.log("Stage 2 responder payload: ", plaintext3);
return { nsInit, nsResp };
}
it("Test handshake", async () => {