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

fix test

Browse Source
This commit is contained in:
Marin Petrunić 2020-03-04 08:56:53 +01:00
parent 8f8e104191
commit 409bfd2150
No known key found for this signature in database
GPG Key ID: 834D07135E110DA5
1 changed files with 6 additions and 11 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

17
test/noise.test.ts
View File

@ -1,18 +1,13 @@
import { expect, assert } from "chai"; import {assert, expect} from "chai";
import DuplexPair from 'it-pair/duplex'; import DuplexPair from 'it-pair/duplex';
import { Noise } from "../src"; import {Noise} from "../src";
import {createPeerIdsFromFixtures} from "./fixtures/peer"; import {createPeerIdsFromFixtures} from "./fixtures/peer";
import Wrap from "it-pb-rpc"; import Wrap from "it-pb-rpc";
import { random } from "bcrypto"; import {random} from "bcrypto";
import sinon from "sinon"; import sinon from "sinon";
import {XXHandshake} from "../src/handshake-xx"; import {XXHandshake} from "../src/handshake-xx";
import { import {createHandshakePayload, generateKeypair, getHandshakePayload, getPayload, signPayload} from "../src/utils";
createHandshakePayload, import {decode0, decode2, encode1, uint16BEDecode, uint16BEEncode} from "../src/encoder";
generateKeypair,
getHandshakePayload, getPayload,
signPayload
} from "../src/utils";
import {decode0, decode1, encode1, uint16BEDecode, uint16BEEncode} from "../src/encoder";
import {XX} from "../src/handshakes/xx"; import {XX} from "../src/handshakes/xx";
import {Buffer} from "buffer"; import {Buffer} from "buffer";
import {getKeyPairFromPeerId} from "./utils"; import {getKeyPairFromPeerId} from "./utils";
@ -89,7 +84,7 @@ describe("Noise", () => {
wrapped.writeLP(encode1(messageBuffer)); wrapped.writeLP(encode1(messageBuffer));
// Stage 2 - finish handshake // Stage 2 - finish handshake
receivedMessageBuffer = decode1((await wrapped.readLP()).slice()); receivedMessageBuffer = decode2((await wrapped.readLP()).slice());
xx.recvMessage(handshake.session, receivedMessageBuffer); xx.recvMessage(handshake.session, receivedMessageBuffer);
return {wrapped, handshake}; return {wrapped, handshake};
})(), })(),