pubs.js

var pull = require('pull-stream')
var paramap = require('pull-paramap')
var createClient = require('ssb-client')

function toAddress (peer) {
  return [peer.host, peer.port, peer.key].join(':')
}

createClient(function (err, sbot) {
  if(err) throw err
  var found = {}, c = 0
  sbot.gossip.peers(function (err, peers) {
    if(err) throw err
    console.log(peers.length)
    pull(
      pull.values(peers),
      paramap(function (peer, cb) {
        console.error('attempt', toAddress(peer))
        createClient(null, {key:peer.key, host: peer.host, port: peer.port, timeout: 1000}, function (err, sbot) {
          if(err) {
            console.error('-', toAddress(peer))
            cb()
          }
          else {
            console.error('+', c++, toAddress(peer))
            sbot.close(true, function () {
              found[sbot.id] = toAddress(peer)
              cb(null, sbot.id)
            })
          }
        })
      }),
      pull.filter(),
      pull.drain(console.log, function () {
        console.log(found)
        sbot.close(true)
      })
    )
  })
})