Skip to content

Instantly share code, notes, and snippets.

@emschwartz
Last active June 12, 2019 07:37
  • Star 0 You must be signed in to star a gist
  • Fork 1 You must be signed in to fork a gist
Star You must be signed in to star a gist
Save emschwartz/b90bb8818d8281edab82e48435f61d04 to your computer and use it in GitHub Desktop.
STREAM Example
const IlpStream = require('ilp-protocol-stream')
const createPlugin = require('ilp-plugin')
// Note this requires a local moneyd instance to work
// See https://github.com/interledgerjs/moneyd for instructions
async function run () {
const serverPlugin = createPlugin()
const server = await IlpStream.createServer({
plugin: serverPlugin
})
server.on('connection', (connection) => {
console.log('server got connection')
connection.on('stream', (stream) => {
console.log(`server got a new stream: ${stream.id}`)
// Set the maximum amount of money this stream can receive
stream.setReceiveMax(10000)
// Handle incoming money
stream.on('money', (amount) => {
console.log(`server stream ${stream.id} got incoming payment for: ${amount}`)
})
// Handle incoming data
stream.on('data', (chunk) => {
console.log(`server stream ${stream.id} got data: ${chunk.toString('utf8')}`)
})
})
})
// These would need to be passed from the server to the client using
// some encrypted communication channel (not provided by STREAM)
const { destinationAccount, sharedSecret } = server.generateAddressAndSecret()
console.log(`server generated ILP address (${destinationAccount}) and shared secret (${sharedSecret.toString('hex')}) for client`)
const clientPlugin = createPlugin()
const clientConn = await IlpStream.createConnection({
plugin: clientPlugin,
destinationAccount,
sharedSecret
})
// Streams are automatically given ids (client-initiated ones are odd, server-initiated are even)
const streamA = clientConn.createStream()
const streamB = clientConn.createStream()
console.log(`sending data to server on stream ${streamA.id}`)
streamA.write('hello there!')
console.log(`sending data to server on stream ${streamB.id}`)
streamB.write('hello there!')
console.log(`sending money to server on stream ${streamA.id}`)
await streamA.sendTotal(100)
console.log('sent 100 units')
console.log(`sending money to server on stream ${streamB.id}`)
await streamB.sendTotal(200)
console.log('sent 200 units')
}
run().catch((err) => console.log(err))
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment