Example

// store.js
const { initStore } = require('heq-store');
const { Connection } = require('@heq/store-mongo');
const people = require('./models/people');

const mongoSource = new Connection({
  url: 'mongodb://localhost:27017',
  dbName: 'examples',
  models: [people],
});

const store = initStore({
  writeTo: 'https://events.tung.ninja',
  readFrom: [mongoSource],
});

module.exports = store;

// api.js
const store = require('./store.js');
const people = require('./models/people');
const { registerNewBorn, registerNewPerson } = require('./commands');

app.get('/api/people', async () => {
  const PeopleCollection = await store.read(people);
  return People.find({});
});

app.post('/api/people', req => {
  return registerNewPerson(store, req.body);
});

app.post('/api/births', req => {
  return registerNewBorn(store, req.body);
});

Subscription

{
  "scripts": {
    "subscribe:dev": "heq-store ./store.js --watch=./models",
    "subscribe": "NODE_ENV=production heq-store"
  }
}