hyper/lib/utils/rpc.js

export default class Client {

  constructor () {
    const electron = window.require('electron');
    const EventEmitter = window.require('events');
    this.emitter = new EventEmitter();
    this.ipc = electron.ipcRenderer;
    this.ipcListener = this.ipcListener.bind(this);
    if (window.__rpcId) {
      setTimeout(() => {
        this.id = window.__rpcId;
        this.ipc.on(this.id, this.ipcListener);
        this.emitter.emit('ready');
      }, 0);
    } else {
      this.ipc.on('init', (ev, uid) => {
        // we cache so that if the object
        // gets re-instantiated we don't
        // wait for a `init` event
        window.__rpcId = uid;
        this.id = uid;
        this.ipc.on(uid, this.ipcListener);
        this.emitter.emit('ready');
      });
    }
  }

  ipcListener (event, { ch, data }) {
    this.emitter.emit(ch, data);
  }

  on (ev, fn) {
    this.emitter.on(ev, fn);
  }

  once (ev, fn) {
    this.emitter.once(ev, fn);
  }

  emit (ev, data) {
    if (!this.id) throw new Error('Not ready');
    this.ipc.send(this.id, { ev, data });
  }

  removeListener (ev, fn) {
    this.emitter.removeListener(ev, fn);
  }

  removeAllListeners () {
    this.emitter.removeAllListeners();
  }

  destroy () {
    this.removeAllListeners();
    this.ipc.removeAllListeners();
  }

}