sbot/app/lib/muxrpc-ipc.js

var ipc        = require('ipc')
var muxrpc     = require('muxrpc')
var pull       = require('pull-stream')
var pushable   = require('pull-pushable')
var Api        = require('scuttlebot/lib/api')

module.exports = function (window, sbot, params) {
  // construct api
  var api = Api(sbot)
  for (var k in sbot.manifest) {
    if (typeof sbot.manifest[k] == 'object')
      api[k] = sbot[k] // copy over the plugin APIs
  }

  // create rpc object
  var rpc = muxrpc(null, sbot.manifest, serialize)(api)
  rpc.authorized = { id: sbot.feed.id, role: 'master' }
  rpc.permissions({allow: null, deny: null})
  function serialize (stream) { return stream }

  // setup rpc stream over ipc
  var rpcStream = rpc.createStream()
  var ipcPush = pushable()
  ipc.on('muxrpc-ssb', function (e, msg) {
    if (e.sender == window.webContents) {
      if (msg.bvalue) {
        msg.value = new Buffer(msg.bvalue, 'base64')
        delete msg.bvalue
      }
      ipcPush.push(msg)
    }
  })
  pull(ipcPush, rpcStream, pull.drain(
    function (msg) { 
      if (msg.value && Buffer.isBuffer(msg.value)) {
        // convert buffers to base64
        msg.bvalue = msg.value.toString('base64')
        delete msg.value
      }
      window.webContents.send('muxrpc-ssb', msg)
    },
    function (err) { if (err) { console.error(err) } }
  ))

  // setup helper messages
  ipc.on('fetch-manifest', function(e) {
    if (e.sender == window.webContents)
      e.returnValue = sbot.manifest
  });
  ipc.on('fetch-params', function(e) {
    if (e.sender == window.webContents)
      e.returnValue = params
  });
}