DC Metro Pro synchronization logic

syncerIndex.js

import { EventEmitter } from 'events';
import realtimeAction from './realtime';
import incidentsAction from './incidents';
import advisoriesAction from './advisories';

const eventEmitter = new EventEmitter();

const syncers = [
  { name: 'realtime', action: realtimeAction, interval: 2.5 * 1000 },
  { name: 'incidcents', action: incidentsAction, interval: 60 * 1000 },
  { name: 'advisories', action: advisoriesAction, interval: 60 * 1000 },
];

const loopWithInterval = (syncer) => {
  syncer.action().then((data) => {
    eventEmitter.emit(`change:${syncer.name}`, data);
    setTimeout(() => loopWithInterval(syncer), syncer.interval);
  });
};

syncers.forEach(loopWithInterval);

export default eventEmitter;