Reactive data layers with Flux

TodoStore.js

var alt = require('../alt');
var TodoActions = require('./TodoActions');

// Reactive data layer
var Todos = alt.Todos;

class TodoStore {

  constructor() {
    this.bindActions(TodoActions);

    this.todos = Todos.find({});

    // Listen for data pushed via WebSocket
    Todos.on('change', this.refresh.bind(this));
  }

  onCreate(text) {
    if (!this.getInstance()) {
      // prevent pre-init calls
      return true;
    }

    Todos.insert({ text: text });
  }

  onRemove(_id) {
    if (!this.getInstance()) {
      // prevent pre-init calls
      return true;
    }

    Todos.remove(_id);
  }

  refresh() {
    if (!this.getInstance()) {
      // prevent pre-init calls
      return true;
    }

    this.todos = Todos.find({});
    this.getInstance().emitChange();
  }

}

module.exports = alt.createStore(TodoStore);