example-fail.js

const DHT = require("@hyperswarm/dht");
var pump = require("pump");
var fs = require("fs");
const crypto = require("hypercore-crypto");
//const keyPair = crypto.keyPair();
(async () => {
  const node = new DHT();
  const keyPair = DHT.keyPair();
  await node.ready();
  const hash = crypto.data(Buffer.from("test", "utf-8"));
  node.announce(hash, keyPair);
  const server = node.createServer();
  console.log("announcing", hash.toString("hex"));
  server.on("connection", function(noiseSocket) {
    var source = fs.createReadStream("package.json");
    pump(source, noiseSocket);
  });
  console.log("starting server");
  server.listen(keyPair);

  setTimeout(async ()=>{
    const anotherNode = new DHT();
    await anotherNode.ready();
    console.log("finding", hash.toString("hex"));
    for await (const n of await anotherNode.lookup(hash)) {
      console.log("found");
      const noiseSocket = await anotherNode.connect(n.id);
      pump(noiseSocket, process.stdout);
    }
    console.log("done finding");
  },10000)
})();