example.js

const { PaymentServer, createSocket } = require('.')
const IlpPluginBtp = require('ilp-plugin-btp')
const crypto = require('crypto')

async function run () {
  const receiverPlugin = new IlpPluginBtp({ server: `btp+wss://:${crypto.randomBytes(16).toString('hex')}@amundsen.ilpdemo.org:1810` })
  const server = new PaymentServer({
    plugin: receiverPlugin,
    secret: crypto.randomBytes(32)
  })
  await server.connect()
  const receiverSocket = server.createSocket({
    enableRefunds: true
  })
  receiverSocket.setMaxBalance(4000)

  const senderPlugin = new IlpPluginBtp({ server: `btp+wss://:${crypto.randomBytes(16).toString('hex')}@amundsen.ilpdemo.org:1810` })
  const senderSocket = await createSocket({
    plugin: senderPlugin,
    destinationAccount: receiverSocket.destinationAccount,
    sharedSecret: receiverSocket.sharedSecret
  })
  senderSocket.setMinAndMaxBalance(-5000)

  senderSocket.on('chunk', () => {
    if (senderSocket.balance === '-4000' && senderSocket.minBalance !== '0') {
      senderSocket.setMinAndMaxBalance(0)
    }
  })
}

run().catch(err => console.log(err))