0.2.2 • Published 11 years ago
peer-connection-pool v0.2.2
peer-connection-pool
Pool of peer connections
Example
var WriteStream = require("write-stream")
, uuid = require("node-uuid")
, assert = require("assert")
, connect = require("./connect")
// connect to the signal channel
connect({
uri: "//signalchannel.co/sock"
, namespace: "unique name for app"
}, function (peers, pool) {
// You are given a peers and pool object. peers is a
// distributed list of all peers connected to your signal
// channel server on your namespace.
// pool is a peer connection pooling abstraction giving you
// a dead simple API for connecting to peers and listening
// on incoming requests from peers
// You need a unique id to distinguish yourself. Probably
// best to use a unique user name instead.
var id = uuid()
// Listen to the pool on your own identifier.
// For each new incoming connection just echo back their data
pool.listen(id).on("connection", function (stream) {
stream.pipe(stream)
stream.pipe(WriteStream(function onecho(message) {
console.log("echo got message", message)
}))
})
// For each new peer, open a connection to them and see
// whether they echo it back
peers.on("join", function (peer) {
if (peer.id <= id) {
// OTHER SIDE HANDLES IT. PEER TO PEER IS SYMETTRIC
return
}
var stream = pool.connect(peer.id)
stream.pipe(WriteStream(function onwrite(message) {
console.log("got message", message)
assert.equal(message, "hello world")
}))
stream.write("hello world")
})
peers.join({ id: id })
})
Installation
npm install peer-connection-pool
Contributors
- Raynos