const HyperswarmProxyServer = require('hyperswarm-proxy/server')
 
const server = new HyperswarmProxyServer({
  // The bootstrap nodes to pass to hyperswarm (optional)
  bootstrap,
 
  // Whether your server will be sort lived (ephemeral: true)
  ephemeral,
 
  // Pass in an existing hyperswarm instance instead of creating a new one (optional)
  network,
 
  // Function that takes incoming connections to decide what to do with them
  // Can be used to notify clients about peers
  // Disconnect incoming by default
  handleIncoming: (socket) => socket.end(),
})
 
const somestream = getStreamForClient()
 
// Get the server to handle streams from clients
server.handleStream(somestream)
 
// Tell all clients about a peer for a particular topic
// This is useful in conjunction with `handleIncoming`
// Use handleIncoming to figure out which topic the connection is from
// Then tell clients to connect to them using `socket.address()`
server.connectClientsTo(SOME_TOPIC, port, hostname)
 
// Close connections to clients and any connected peers
server.destroy(() => {
  // Done!
})

const HyperswarmProxyClient = require('hyperswarm-proxy/client')
 
const somestream = getStreamForServer()
 
const swarm = new HyperswarmProxyClient({
  // Pass in the stream which connects to the server
  // If this isn't passed in, invoke `.reconnect(somestream)` to start connecting
  connection: somestream,
 
  // Whether you should autoconnect to peers
  autoconnect: true,
 
  // The max number of peers to connect to before stopping to autoconnect
  maxPeers: 24,
})
 
// When we disconnect, reconnect to the server
swarm.on('disconnected', () => {
  swarm.reconnect(getStreamForServer())
})
 
// Same as hyperswarm
swarm.on('connection', (connection, info) => {
 
  const stream = getSomeStream(info.topic)
  // Pipe the data from the connection into something to process it
  // E.G. `hyperdrive.replicate()`
  connection.pipe(stream).pipe(connection)
})
 
swarm.join(topic)
 
swarm.leave(topic)
 
// Listen for peers manually
swarm.on('peer', (peer) => {
  // If autoconnect is `false` you can connect manually here
  swarm.connect(peer, (err, connection) => {
    // Wow
  })
})
 
// Destroy the swarm
swarm.destroy()