From bebdc7d0d4546dca54ad1026987254263ad50e90 Mon Sep 17 00:00:00 2001 From: Derrick Hammer Date: Sun, 27 Nov 2022 03:37:02 -0500 Subject: [PATCH] *Reformat --- test.js | 94 ++++++++++++++++++++++++++++----------------------------- 1 file changed, 47 insertions(+), 47 deletions(-) diff --git a/test.js b/test.js index efa8e21..f9ab4e2 100644 --- a/test.js +++ b/test.js @@ -1,61 +1,61 @@ -const test = require('tape') -const Hyperswarm = require('hyperswarm') -const sodium = require('sodium-universal') -const b4a = require('b4a') -const { default: DHTFlood } = require('./') -const crypto = require('crypto') +const test = require("tape"); +const Hyperswarm = require("hyperswarm"); +const sodium = require("sodium-universal"); +const b4a = require("b4a"); +const { default: DHTFlood } = require("./"); +const crypto = require("crypto"); -const topicName = crypto.randomBytes(10) +const topicName = crypto.randomBytes(10); -test('Broadcast through several peers', (t) => { - const peer1 = createPeer() - const peer2 = createPeer() - const peer3 = createPeer() - t.plan(2) +test("Broadcast through several peers", (t) => { + const peer1 = createPeer(); + const peer2 = createPeer(); + const peer3 = createPeer(); + t.plan(2); - Promise.all([peer1, peer2, peer3]).then((peers) => { - const peer1 = peers.shift() - const peer2 = peers.shift() - const peer3 = peers.shift() + Promise.all([peer1, peer2, peer3]).then((peers) => { + const peer1 = peers.shift(); + const peer2 = peers.shift(); + const peer3 = peers.shift(); - const flood1 = new DHTFlood({ swarm: peer1 }) - const flood2 = new DHTFlood({ swarm: peer2 }) - const flood3 = new DHTFlood({ swarm: peer3 }) - const data = Buffer.from('Hello World') + const flood1 = new DHTFlood({ swarm: peer1 }); + const flood2 = new DHTFlood({ swarm: peer2 }); + const flood3 = new DHTFlood({ swarm: peer3 }); + const data = Buffer.from("Hello World"); - flood1.on('message', () => t.error('Got own message')) + flood1.on("message", () => t.error("Got own message")); - flood2.on('message', (message) => { - t.deepEquals(message, data, 'Data got broadcast') - }) - flood3.on('message', (message) => { - t.deepEquals(message, data, 'Data got broadcast') - }) + flood2.on("message", (message) => { + t.deepEquals(message, data, "Data got broadcast"); + }); + flood3.on("message", (message) => { + t.deepEquals(message, data, "Data got broadcast"); + }); - function maybeFlood() { - if (peer1.peers.size === 2) { - flood1.broadcast(data); - peer1.removeListener("connection", maybeFlood); - } - } + function maybeFlood() { + if (peer1.peers.size === 2) { + flood1.broadcast(data); + peer1.removeListener("connection", maybeFlood); + } + } - peer1.on("connection", maybeFlood); + peer1.on("connection", maybeFlood); - t.teardown(() => { - [peer1, peer2, peer3].forEach((item) => item.destroy()) - }) - }) -}) + t.teardown(() => { + [peer1, peer2, peer3].forEach((item) => item.destroy()); + }); + }); +}); -async function createPeer () { - const swarm = new Hyperswarm() - await swarm.dht.ready() - await swarm.listen() +async function createPeer() { + const swarm = new Hyperswarm(); + await swarm.dht.ready(); + await swarm.listen(); - const topic = b4a.allocUnsafe(32) - sodium.crypto_generichash(topic, b4a.from(topicName)) + const topic = b4a.allocUnsafe(32); + sodium.crypto_generichash(topic, b4a.from(topicName)); - swarm.join(topic) + swarm.join(topic); - return swarm + return swarm; }