857-bytes

socket.js

'use strict';

const activeBuilds = [];

function socketEmitter(res, type, data) {

  // emit the event
  res.app.get('io').sockets.emit(type, data);

  // store the last event per project for future connections
  if (activeBuilds.length === 0) {
    activeBuilds.push({ name: data.name, data });
  } else {
    // loop through array of active projects and update/add as necessary
    for (let i = 0; i < activeBuilds.length; i++) {
      const match = activeBuilds[i].name === data.name;
      const done  = i + 1 === activeBuilds.length;
      if (match) {
        activeBuilds[i].data = data;
        return res.app.set('io-last-event', activeBuilds);
      }
      if (done && !match) {
        activeBuilds.push({ name: data.name, data });
        return res.app.set('io-last-event', activeBuilds);
      }
    }
  }
}

module.exports = socketEmitter;