electron/atom/common/api/lib/callbacks-registry.js

'use strict';

var slice = [].slice;

const v8Util = process.atomBinding('v8_util');

class CallbacksRegistry {
  constructor() {
    this.nextId = 0;
    this.callbacks = {};
  }

  add(callback) {
    // The callback is already added.
    var filenameAndLine, id, location, match, ref, regexp, stackString, x;
    id = v8Util.getHiddenValue(callback, 'callbackId');
    if (id != null) {
      return id;
    }
    id = ++this.nextId;

    // Capture the location of the function and put it in the ID string,
    // so that release errors can be tracked down easily.
    regexp = /at (.*)/gi;
    stackString = (new Error).stack;
    while ((match = regexp.exec(stackString)) !== null) {
      x = match[0], location = match[1];
      if (location.indexOf('(native)') !== -1) {
        continue;
      }
      if (location.indexOf('atom.asar') !== -1) {
        continue;
      }
      ref = /([^\/^\)]*)\)?$/gi.exec(location), x = ref[0], filenameAndLine = ref[1];
      break;
    }
    this.callbacks[id] = callback;
    v8Util.setHiddenValue(callback, 'callbackId', id);
    v8Util.setHiddenValue(callback, 'location', filenameAndLine);
    return id;
  }

  get(id) {
    var ref;
    return (ref = this.callbacks[id]) != null ? ref : function() {};
  }

  call() {
    var args, id, ref;
    id = arguments[0], args = 2 <= arguments.length ? slice.call(arguments, 1) : [];
    return (ref = this.get(id)).call.apply(ref, [global].concat(slice.call(args)));
  }

  apply() {
    var args, id, ref;
    id = arguments[0], args = 2 <= arguments.length ? slice.call(arguments, 1) : [];
    return (ref = this.get(id)).apply.apply(ref, [global].concat(slice.call(args)));
  }

  remove(id) {
    return delete this.callbacks[id];
  }
}

module.exports = CallbacksRegistry