BaseModel.js

import SocketClient from 'socket.io-client';
import Feathers from 'feathers-client';
import Utils from '../lib/Utils';

const API_HOST = "http://localhost:3030";

class BaseModel {
  defaults() { return {}; }

  constructor(resource_name, host = API_HOST) {
    this.utils = new Utils();
    console.log(resource_name);
    console.log(this.utils.pluralize(resource_name));
		this.socket = new SocketClient(host);
		this.app = Feathers().configure(Feathers.socketio(this.socket));
		this.service = this.app.service(this.utils.pluralize(resource_name));
		this.onChanges = [];
		this.resources = [];

		this.service.find(function(error, resources) {
      console.log(resources);
			this.resources = resources.data;
			this.inform();
		}.bind(this));

		this.service.on('created', this.createResource.bind(this));
		this.service.on('updated', this.updateResource.bind(this));
		this.service.on('removed', this.removeResource.bind(this));
	}

	subscribe(onChange) {
		this.onChanges.push(onChange);
	}

	inform() {
		this.onChanges.forEach((cb) => { cb(); });
	}

  getResource() {
		return this.service.get(arguments);
  }

	createResource(resource) {
    console.log('createResource');
		this.resources = this.resources.concat(resource);
		this.inform();
	}

	updateResource(resource) {
		this.resources = this.resources.map((current) => {
			return resource._id === current._id ? resource : current;
		});

		this.inform();
	}

	removeResource(resource) {
		this.resources = this.resources.filter((current) => {
			return resource._id !== current._id;
		});

		this.inform();
	}

	addResource(properties = {}) {
    console.log('addResource');
		this.service.create(this.utils.extend({}, this.defaults(), properties));
  }

	destroy(resource) {
		this.service.remove(resource._id);
  }

	save(resource, properties) {
		this.service.update(resource._id, this.utils.extend({}, resource, properties));
  }
}

export default BaseModel;