import { get, set } from '@ember/object';

const proxies = {};
export default function(ObjProxy, ArrProxy, createListeners) {
  return function(source, data = []) {
    let Proxy = ObjProxy;
    // TODO: Why are these two separate?
    // And when is data ever a string?
    if (typeof data !== 'string' && typeof get(data, 'length') !== 'undefined') {
      data = data.filter(function(item) {
        return !get(item, 'isDestroyed') && !get(item, 'isDeleted') && get(item, 'isLoaded');
      });
    }
    let type = 'object';
    if (typeof data !== 'string' && typeof get(data, 'length') !== 'undefined') {
      Proxy = ArrProxy;
      type = 'array';
    }
    if (typeof proxies[type] === 'undefined') {
      proxies[type] = Proxy.extend({
        closed: false,
        error: null,
        init: function() {
          this.listeners = createListeners();
          this.listeners.add(this._source, 'message', e => set(this, 'content', e.data));
          this.listeners.add(this._source, 'open', () => set(this, 'closed', false));
          this.listeners.add(this._source, 'close', () => set(this, 'closed', true));
          this.listeners.add(this._source, 'error', e => set(this, 'error', e.error));
          this._super(...arguments);
        },
        addEventListener: function(type, handler) {
          // Force use of computed for messages
          // Temporarily disable this restriction
          // if (type !== 'message') {
          this.listeners.add(this._source, type, handler);
          // }
        },
        getCurrentEvent: function() {
          return this._source.getCurrentEvent(...arguments);
        },
        removeEventListener: function() {
          return this._source.removeEventListener(...arguments);
        },
        dispatchEvent: function() {
          return this._source.dispatchEvent(...arguments);
        },
        close: function() {
          return this._source.close(...arguments);
        },
        open: function() {
          return this._source.open(...arguments);
        },
        willDestroy: function() {
          this._super(...arguments);
          this.close();
          this.listeners.remove();
        },
      });
    }
    return proxies[type].create({
      content: data,
      _source: source,
      configuration: source.configuration,
    });
  };
}