Replicating hyperbees over hyperswarm

replicate-hyperbees.js

// Uses hypercore-next and hyperswarm V4 

// Server

const Hyperswarm = require('hyperswarm')
const Hypercore = require("hypercore")
const Hyperbee = require("hyperbee")
const ram = require("random-access-memory")

async function runServer(){
  const core = new Hypercore(ram)
  const bee = new Hyperbee(core, {keyEncoding: "utf-8", valueEncoding: "json"})

  await core.ready()
  while (core.length < 25) {
      await bee.put('block #' + core.length, "value " + core.length)
  }
  
  const swarm = new Hyperswarm()
  swarm.on('connection', socket => core.replicate(socket))
  swarm.join(core.discoveryKey, { server: true, client: false })
  await swarm.flush()

  console.log('Serving core:', core.key.toString('hex'))    
}

runServer()



// Client

const Hyperswarm = require('hyperswarm')
const Hypercore = require("hypercore")
const Hyperbee = require("hyperbee")
const ram = require("random-access-memory")
const { once } = require("events");

const KEY = // Insert the key served by your server here (as string)

async function runClient(){
  const core = new Hypercore(ram, Buffer.from(KEY, "hex"))
  const bee = new Hyperbee(core, {keyEncoding: "utf-8", valueEncoding: "json"})
  await core.ready()

  const swarm = new Hyperswarm()
  swarm.on('connection', socket => core.replicate(socket))
  swarm.join(core.discoveryKey, { server: false, client: true })
  
  console.log('Requesting core:', core.key.toString('hex'))
  await swarm.flush()

  // Ensure we are connected to at least 1 peer (else getting simply returns null)
  if (bee.feed.writable || bee.feed.peers.length) {
    console.log("Writable or already found peers for core");
  } else {
    console.log("Waiting for peers to connect");
    const [peer] = await once(bee.feed, "peer-add");
    console.log("Connected to peer", peer.remotePublicKey);
  }
  console.log((await bee.get("block #10")))    

  const readStream = await bee.createReadStream()
  for await (const entry of readStream){
    console.log(entry)
  }

  console.log("finished")
}

runClient()