config = require('./config/config.json');
module.exports = knex = require('knex')(config.db)

require('./watch/index')(config.dir, onGetFile);

const wsServer = require('./webSocketServer/index')();
var planexArr = []

function onGetFile(fileString) {

  if (!fileString) return;

  var planex = require('./planex/index')(fileString);

  planexArr.push(planex);

  // Traigo proveedor, empresa
  require('./debo/relaciones')(planex, wsServer).then(function(result) {

    var planex = planexArr.filter(function(p) {
      return p.identificaxMensaje.idMensaje == result.planex.identificaxMensaje.idMensaje
    })[0];

    var entities = {};

    entities.proveedores = result.values[0];
    entities.empresa = result.values[1];

    var debo = require('./debo/index')(planex, entities);

    require('./debo/validacion')(debo, wsServer, planex.identificaxReceptorFactura.glnReceptor).then(function() {

      require('./db/index')(debo);
    }).catch(function(err) {

      console.log(err);
    });


  });
}

console.log('listen websocket port ' + config.port);
console.log('Ejecutar programa como administrador...');