<commit_before>/*!
 * Universidad Industrial de Santander
 * Grupo de Desarrollo de Software Calumet
 * Realtime | Databases
 * <NAME>, <EMAIL>
 * 2015
 **/

var rubi = require('../libs/rubi');
var diamante = require('../libs/diamante');
var portal = require('./dbs.portal');
var debug = require('debug')('dbs');


// -------------------------------------------------------------------------- //
// GLOBAL DATABASES PROCEDURES //

/**
 * Se ejecutan los procedimientos a realizarse en las bases de datos una vez
 * se inicie el servidor.
 *
 * > Recordar que una vez se inicie la conexión con el servidor, las demás
 * instancias de libs/rubi y libs/diamante podrán hacer todos los procedimientos
 * que necesiten.
 *
 * > Se saldrá el servidor sino se pudo conectar con alguna de las bases de datos.
 */

module.exports = exports = function (callback) {

	// Conectarse con rubi.
	rubi.connect(function (err) {
		if (err) throw err;
		else debug('rubi está conectada.');

		// Conectarse con diamante.
		diamante.connect(function (err) {
			if (err) throw err;
			else debug('diamante está conectada.');

		  // Resetear todas las instancias de los usuarios. Si habían conectados,
		  // se reconectarán y se recrean otra vez tales instancias.
	    portal.reset(function (err) {
	      if (err) debug(err);
	    });

		  // Iniciar todas las labores que necesiten de las bases de datos.
			callback();
		});
	});

};
<commit_msg>add: agregando modo de resetear instancias en ac_rooms<commit_after>/*!
 * Universidad Industrial de Santander
 * Grupo de Desarrollo de Software Calumet
 * Realtime | Databases
 * <NAME>, <EMAIL>
 * 2015
 **/

var rubi = require('../libs/rubi');
var diamante = require('../libs/diamante');
var portal = require('./dbs.portal');
var aula = require('./dbs.aula');
var async = require('async');
var debug = require('debug')('dbs');


// -------------------------------------------------------------------------- //
// GLOBAL DATABASES PROCEDURES //

/**
 * Se ejecutan los procedimientos a realizarse en las bases de datos una vez
 * se inicie el servidor.
 * @param {Function} callback Los procesos iniciales se han cargado.
 *
 * > Recordar que una vez se inicie la conexión con el servidor, las demás
 * instancias de libs/rubi y libs/diamante podrán hacer todos los procedimientos
 * que necesiten.
 *
 * > Se saldrá el servidor sino se pudo conectar con alguna de las bases de datos.
 *
 * > Las instancias de conexiones con los sockets se reestablecen una vez
 * ĺa conexión del server se reanuda.
 */
module.exports = exports = function (callback) {

  // Conectarse con rubi.
  rubi.connect(function (err) {
    if (err) throw err;
    else debug('rubi está conectada.');

    // Conectarse con diamante.
    diamante.connect(function (err) {
      if (err) throw err;
      else debug('diamante está conectada.');

      // Procesos iniciales.
      async.parallel([

        // Resetear todas las instancias de los usuarios.
        portal.reset,

        // Resetear todas las instancias de usuarios conectados en rubi.ac_rooms.
        aula.reset

      ], function (err) {
        if (err) debug(err);

        // Iniciar todas las labores que necesiten de las bases de datos.
        callback();
      });
    });
  });

};

{'fraction_non_alphanumeric': 0.1552357624004899, 'fraction_numerical': 0.002449479485609308, 'mean_word_length': 2.5242718446601944, 'pattern_counts': {'":': 0, '<': 7, '<?xml version=': 0, '>': 12, 'https://': 0, 'lorem ipsum': 0, 'www.': 0, 'xml': 0}, 'pii_count': 0, 'substrings_counts': 0, 'word_list_counts': {'cursed_substrings.json': 0, 'profanity_word_list.json': 0, 'sexual_word_list.json': 0, 'zh_pornsignals.json': 0}}
{'dir': 'git-commits-cleaned', 'id': '1632462', 'n_tokens_mistral': 1067, 'n_tokens_neox': 1023, 'n_words': 349}