csvToEs.js

// An example of one of our microservices - handles importing to Elasticsearch
class ESCollection extends UpdateEmitter {
  get status() {
    // should return a JSON object which is passed along with the websocket event  
  }
  
  syncESWithCSV(csvName) {
    this.started(); // emits 'started' event to any front-end listening for it
    // do stuff to load CSV to Elasticsearch
    this.progress(); // emits 'progress' event with the status
    // do more stuff
    this.completed; // emits 'completed' event
  }
}