fluencelabs/js-libp2p-noise
1
0
Fork 0
mirror of https://github.com/fluencelabs/js-libp2p-noise synced 2025-06-26 21:31:57 +00:00
Code Issues Projects Releases Wiki Activity

Fix eslint

Browse Source
This commit is contained in:
morrigan
2019-12-02 15:28:59 +01:00
parent 6bb36f1663
commit bb303a568e
2 changed files with 4 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
src/crypto.ts
View File

@ -1,4 +1,3 @@
import { Duplex } from "it-pair";
import { Handshake } from "./handshake"; import { Handshake } from "./handshake";
import { Buffer } from "buffer"; import { Buffer } from "buffer";
@ -7,7 +6,7 @@ interface ReturnEncryptionWrapper {
} }
// Returns generator that encrypts payload from the user // Returns generator that encrypts payload from the user
export function encryptStream(handshake: Handshake): ReturnEncryptionWrapper { export function encryptStream(handshake: Handshake): ReturnEncryptionWrapper {
return async function * (source) { return async function * (source) {
for await (const chunk of source) { for await (const chunk of source) {
const chunkBuffer = Buffer.from(chunk); const chunkBuffer = Buffer.from(chunk);

6
test/noise.test.ts
View File

@ -2,7 +2,7 @@ import { expect, assert } from "chai";
import DuplexPair from 'it-pair/duplex'; import DuplexPair from 'it-pair/duplex';
import { Noise } from "../src"; import { Noise } from "../src";
import {createPeerIds, createPeerIdsFromFixtures} from "./fixtures/peer"; import {createPeerIdsFromFixtures} from "./fixtures/peer";
import Wrap from "it-pb-rpc"; import Wrap from "it-pb-rpc";
import {Handshake} from "../src/handshake"; import {Handshake} from "../src/handshake";
import { import {
@ -10,7 +10,7 @@ import {
decodeMessageBuffer, decodeMessageBuffer,
encodeMessageBuffer, encodeMessageBuffer,
generateKeypair, generateKeypair,
getHandshakePayload, signEarlyDataPayload, getHandshakePayload,
signPayload signPayload
} from "../src/utils"; } from "../src/utils";
import {XXHandshake} from "../src/xx"; import {XXHandshake} from "../src/xx";
@ -20,7 +20,7 @@ describe("Noise", () => {
let remotePeer, localPeer; let remotePeer, localPeer;
before(async () => { before(async () => {
[localPeer, remotePeer] = await createPeerIds(2); [localPeer, remotePeer] = await createPeerIdsFromFixtures(2);
}); });
it("should communicate through encrypted streams", async() => { it("should communicate through encrypted streams", async() => {