ctrlNucleo.js

var unificador = require("./unificador");
var _ = require('underscore');
require("./precondicion");

// hay que crear carpeta C:\data\db
var MongoClient = require("mongodb").MongoClient;
var mongo_prot = require("./propiedades.json").mongo.protocolo;
var mongo_serv = require("./propiedades.json").mongo.servidor;
var mongo_bd = require("./propiedades.json").mongo.bd;

/*
param 1 = indice del que es responsable en reloj vectorial
param 2 = coleccion en donde persiten sus documentos este servidor
param 3 = nombre de la cola MOM que escucha este servidor
param 4 = instancia de bus para gestion de eventos
param 5 = lista de suscriptores del servidor dado
param 6 = cantidad de confirmaciones externas para fin corte consistente
*/
module.exports = function(
  mi_reloj,
  coleccion,
  cola_escucha,
  bus,
  suscriptores,
  corte_resp_esperadas
){

  var module = {};

  /*
  ......... persistencia
  */

  var db_global;

  var url = mongo_prot + mongo_serv;
  MongoClient.connect(url, function(err, db) {

    if(err) throw err;

    var dbase = db.db(mongo_bd);
    dbase.createCollection(coleccion);
    db_global = dbase;
  });

  /*
  ......... negocio
  */

  module.id_mayor = 0;

  bus.on("negocio", function (evento) {

    if(evento.tarea !== "momResultadoPublicaciones" &&
          evento.tarea !== "momGetPublicaciones")

            module.agregarCompra(evento);

    if(evento.id > module.id_mayor)
      module.id_mayor = evento.id;

    bus.emit(evento.tarea, evento);
  });

  var compras = new Array();

  module.compras = function(){
    return compras;
  }

  module.persistir = function() {

    if(!mw.corteEnProceso()){
      try {
        console.log("INT: persistiendo estado");
        var coleccion_obj = db_global.collection(coleccion);

        compras.forEach(function(compra){
          coleccion_obj.update({id:compra.id}, compra, {up:true});
        });
        console.log("INT: estado persistido");
      } catch (e) {
        console.error("INT: no es posible presistir estado en este momento");
      } finally { }
    }
  }

  /*
  param 1 = indice del que es responsable en reloj vectorial
  param 2 = nombre de la cola MOM que escucha este servidor
  param 3 = instancia de bus para gestion de eventos
  param 4 = lista de suscriptores del servidor dado
  param 5 = cantidad de confirmaciones externas para fin corte consistente
  param 6 = estado actual del servidor. son los valores en memoria dinamica
  param 7 = llamada a funcion de persistencia del negocio
  */
  var mw = require("mom-nucleo")(
    mi_reloj,
    cola_escucha,
    bus,
    suscriptores,
    corte_resp_esperadas,
    module.compras,
    module.persistir
  );

  module.mw = mw;

  // ---------

  module.caida = function() {
    if(!mw.corteEnProceso()){
      console.log("\nINT: caida programada del servidor\n");
      process.exit(0);
    }
  }

  module.actualizarAtributo = function(evento){

    var ev_antiguo = aislarEvento(evento);

    var antigua = ev_antiguo.compra;
    var actualizacion = evento.compra;

    actualizacion = unificador.unificar(antigua, actualizacion);
    evento.compra = actualizacion;
    compras.push(evento);

    return evento;
  }

  function aislarEvento(evento){

    var compra = compras.find(function(item, index, array){
      return item.id == evento.id;
    });

    compras = _(compras).filter(function(item) {
      return item.id != evento.id;
    });

    return compra;
  }

  var canceladas = {confirmacion:0, autorizacion:0, infraccion:0};
  var estadisticas = {totales:0, aceptadas:0, canceladas, en_curso:0};

  module.estadisticas = estadisticas;

  setInterval(function() {
    estadisticas.totales = compras.length;
    estadisticas.aceptadas = 0;

    estadisticas.canceladas.confirmacion = 0;
    estadisticas.canceladas.autorizacion = 0;
    estadisticas.canceladas.infraccion = 0;

    var tot_canceladas = 0;
    compras.forEach(function(evento){

      // compras aceptadas
      if(evento.compra.estado === evento.compra.estado_valores[3])
        estadisticas.aceptadas++;

      var marca = false;
      // si todavia no esta aceptada
      if(evento.compra.estado !== evento.compra.estado_valores[3]){
        if(!marca && (evento.compra.estado === evento.compra.estado_valores[2])){
          estadisticas.canceladas.confirmacion++;
          marca = true;
        }
        if(!marca && (evento.compra.pago === evento.compra.pago_valores[2])){
          estadisticas.canceladas.autorizacion++;
          marca = true;
        }
        if(!marca && (evento.compra.infracciones === evento.compra.infracciones_valores[2])){
          estadisticas.canceladas.infraccion++;
          marca = true;
        }
      }
      tot_canceladas = estadisticas.canceladas.confirmacion + estadisticas.canceladas.autorizacion + estadisticas.canceladas.infraccion;
    });
    estadisticas.en_curso = estadisticas.totales - estadisticas.aceptadas - tot_canceladas;

  }, 1000);

  /*
  solo agrega la compra en caso que no exista. no realiza ningun analisis de versiones
  si la compra existe, no la agrega
  */
  module.agregarCompra = function(evento){
    if(!compras.some(x => x.id === evento.id))
      compras.push(evento);
  }

  module.sumar = function(estado_sincro, indice_objetivo, incremento){

    while(estado_sincro.length <= indice_objetivo)
      estado_sincro.push(0);

    estado_sincro[indice_objetivo] += incremento;
  }

  return module;
}