MarshallOfSound/Google-Play-Music-Desktop-Player-UNOFFICIAL-

import { ipcRenderer, remote } from 'electron';

class Emitter {
  constructor() {
    let ready = true;
    this.__defineGetter__('ready', () => ready);
    this.__defineSetter__('ready', (newValue) => {
      ready = newValue;
      if (newValue) {
        this.q.forEach((fn) => {
          fn();
        });
        this.q = [];
      }
    });
    this.q = [];

    ipcRenderer.on('execute', (event, details) => {
      if (details && details.fn) {
        remote.getCurrentWebContents().executeJavaScript(details.fn);
      } else {
        Logger.warn('Function not passed to the execute event');
      }
    });

    ipcRenderer.on('passthrough', (event, details) => {
      const view = document.querySelector('webview');
      if (!view) {
        Logger.warn('Attempting to pass event through to WebView, but no WebView found', details);
        return;
      }
      if (details && details.event) {
        if (view.isLoading()) {
          let waitForPageLoad = 0;
          const _listener = () => {
            if (waitForPageLoad > 1 && !view.isLoading()) {
              view.send(details.event, ...details.details);
              view.removeEventListener('did-stop-loading', _listener);
            }
            waitForPageLoad++;
          };
          view.addEventListener('did-stop-loading', _listener);
        } else {
          view.send(details.event, ...details.details);
        }
      }
    });

    this._internalEventWrappers = {};
  }

  fire(event, ...details) {
    if (this.ready) {
      ipcRenderer.send(event, ...details);
    } else {
      this.q.push(this.fire.bind(this, event, ...details));
    }
  }

  fireSync(event, ...details) {
    if (this.ready) {
      ipcRenderer.sendSync(event, ...details);
    } else {
      this.q.push(this.fireSync.bind(this, event, ...details));
    }
  }

  fireAtAll(event, ...details) {
    if (this.ready) {
      ipcRenderer.send('passback:all', {
        event,
        details,
      });
      ipcRenderer.send(event, ...details);
    } else {
      this.q.push(this.fireAtAll.bind(this, event, ...details));
    }
  }

  fireAtMain(event, ...details) {
    if (this.ready) {
      ipcRenderer.send('passback:main', {
        event,
        details,
      });
    } else {
      this.q.push(this.fireAtMain.bind(this, event, ...details));
    }
  }

  fireAtGoogle(event, ...details) {
    if (this.ready) {
      ipcRenderer.send('passback', {
        event,
        details,
      });
    } else {
      this.q.push(this.fireAtGoogle.bind(this, event, ...details));
    }
  }

  on(event, fn) {
    const internalMethod = (internalEvent, ...internalDetails) => {
      if (this.ready) {
        this._call(fn, internalEvent, ...internalDetails);
      } else {
        this.q.push(this._call.bind(this, fn, internalEvent, ...internalDetails));
      }
    };
    this._internalEventWrappers[event] = this._internalEventWrappers[event] || {};
    this._internalEventWrappers[event][fn] = internalMethod;
    ipcRenderer.on(event, internalMethod);
  }

  once(event, fn) {
    ipcRenderer.once(event, (internalEvent, ...internalDetails) => {
      if (this.ready) {
        this._call(fn, internalEvent, ...internalDetails);
      } else {
        this.q.push(this._call.bind(this, fn, internalEvent, ...internalDetails));
      }
    });
  }

  off(event, fn) {
    if (this._internalEventWrappers[event] && this._internalEventWrappers[event][fn]) {
      ipcRenderer.removeListener(event, this._internalEventWrappers[event][fn]);
    }
  }

  _call(fn, internalEvent, ...internalDetails) {
    fn(internalEvent, ...internalDetails);
  }
}

global.Emitter = new Emitter();