crearYSubirVideo.js

const mysql = require('mysql');
const fs = require('fs');
console.log('Subir Videos');
const archivoRutas = require('./rutasImagenesYVideos.js');
let rutaVideos = archivoRutas.rutaVideos;
const config = require('config');
const ffmpeg = require('fluent-ffmpeg');
console.log('Montar Videos');
let rutaImagenes = archivoRutas.rutaImagenes;

async function comprobarUltimoYSubir(rutaEventos) {
  let lastID, lastMember;
  let sql;
  console.log('Obteniendo ultimo video');
  const con = mysql.createConnection({
    host: config.get('ConexionBasededatos.host'),
    port: config.get('ConexionBasededatos.port'),
    user: config.get('ConexionBasededatos.user'),
    password: config.get('ConexionBasededatos.password')
  });
  sql = 'SELECT id_video FROM videos1.videos ORDER BY id_video DESC LIMIT 1;';
  await  getLastID(con, sql).then(function (result) {
    lastID = result;
  });
  console.log('LastID:'+lastID);
  sql = 'SELECT fecha, hora FROM videos1.videos where id_video = '+lastID+';';
  await getLastMember(con,sql).then(function (result) {
    lastMember = result;
  });
  console.log('LastMember:');console.log(lastMember);

  let eventos;
  await leerDirectorio(rutaEventos).then((datos)=>{
    eventos = datos;
  });
  for(let i=0;i<eventos.length;i++){
    let horalarga,nombre;
    let objeto,fechaEvento;
    let localizacion,camara,universidad,provincia,fecha, anno, mes, dia, hora, minuto, segundo;
    //console.log("Evento("+i+"):"+eventos[i]);
    [nombre,horalarga] = eventos[i].split('--');
    [hora,minuto,segundo] = horalarga.split('-');
    [camara,universidad,provincia,anno,mes,dia] = nombre.split('-');
    localizacion = universidad+'-'+provincia;
    camara = camara.split('cam')[1];
    horalarga=hora+':'+minuto+':'+segundo;
    fecha = anno+'-'+mes+'-'+dia;
    objeto={camara: camara, fecha:fecha,hora:horalarga,ubicacion:eventos[i]};
    //console.log(objeto);

    fechaEvento = new Date(anno,mes,dia,hora,minuto,segundo);
    fechaEvento = new Date(fechaEvento.getTime()-fechaEvento.getTimezoneOffset()*60*1000);

    if(fechaEvento.getTime()>lastMember.getTime()){
      await subir(con,objeto).then(resultado =>{
        console.log("Subido evento("+resultado+"):");
      });
      console.log("Terminado?")
    }else{
      console.log("Menor");
      console.log("FechaEvento");
      console.log(fechaEvento);
      console.log(lastMember);
    }
  }
  con.end();
  return;
}
function getLastID(con,sql) {
  return new Promise( async function (resolve, reject) {
    let lastID;
    con.connect(function(err) {
      if (err){
        throw err;
        reject();
      }
      //console.log("Connected LastID!");
      //console.log('SQL interior:'+sql);
      con.query(sql, function (err, result) {
        if (err){
          throw err;reject();
        }
        lastID = result[0].id_video;
        //console.log('Elemento:'+result[0].id_video);
        resolve(lastID);
      });
      //

    });

  });
}
function getLastMember(con,sql) {
  return new Promise( async function (resolve, reject) {
    let lastMember;
    let fecha, hora, anno, mes, dia, hh, minuto, segundo;
    //console.log("Connected LastID!");
    //console.log('SQL interior:'+sql);
    con.query(sql, function (err, result) {
      if (err){
        throw err;reject();
      }
      console.log('Resultado con ultimo id');
      console.log(result);
      fecha = new Date(result[0].fecha);
      //console.log(fecha.getTime());
      anno = fecha.getFullYear()
      mes = fecha.getMonth()+1;
      dia = fecha.getDate();
      hora = result[0].hora;
      //console.log(hora);
      [hh,minuto,segundo] = hora.split(':');
      hh = hh - fecha.getTimezoneOffset()/60;
      if(hh<10) hh = '0'+hh;
      //console.log(hh);
      //lastMember = {anno:anno,mes:mes,dia:dia,hora:hh,minuto:minuto,segundo:segundo};
      console.log(anno+'-'+mes+'-'+dia+'T'+hh+':'+minuto+':'+segundo);
      lastMember = new Date(anno,mes,dia,hh,minuto,segundo);

      //console.log(lastMember.getTime());
      console.log('Elemento:');console.log(lastMember);
      resolve(lastMember);
    });
    //

  });
}
function leerDirectorio(directorio) {
  return new Promise(async function (resolve, reject) {
    await fs.readdir(directorio, function (err,elementosEventos) {
      if(err){
        console.log("error"+err.message);
        reject("error"+err.message);
      }else{
        resolve(elementosEventos);
      }

    });
  });
}
function subir(con,objeto) {
  return new Promise(async function (resolve,reject){

    let sql = 'INSERT INTO videos1.videos (camara,fecha,hora,ubicacion,aprobado,favor,contra) values ('+objeto.camara+',\''+objeto.fecha+'\',\''+objeto.hora+'\',\''+objeto.ubicacion+'\',0,0,0);';
    console.log(sql);
    con.query(sql, function (err, result) {
      if (err){
        throw err;reject();
      }
      console.log("Subidos:"+result.affectedRows);
      resolve(objeto.ubicacion);
    });
    //

  });
}

async function crearCarpetasYVideos(rutaVideos,rutaImagenes){
  let eventos;
  await crearDirectorios(rutaImagenes).then(resultado => {
    console.log(resultado);
  });
  await leerDirectorio(rutaVideos).then((datos)=>{
    eventos = datos;
  });
  console.log(eventos);
  for(let i=0;i<eventos.length;i++){
    console.log("Evento:"+i);
    let ruta = __dirname+'/videos/eventos/'+eventos[i]+'/evento.mp4';
    if(!fs.existsSync(ruta)){
      await llamarFFMPEG(eventos[i]).then((resultado)=>{
        console.log(resultado);
      });
    }

  }
  return;
}


async function llamarFFMPEG(evento){
  return new Promise((resolve,reject)=>{
    let ruta = __dirname+'/imagenes/eventos/'+evento+'/image-%d.jpeg';
    console.log(ruta);
    ffmpeg(ruta)
      .outputFps(24)
      .addOutput('videos/eventos/'+evento+'/evento.mp4')
      .on('end',function() {
        resolve('Transcoding succeeded !');
      })
      .on('error',function(err) {
        console.log('Transcoding failed !'+err.message);
        reject('Transcoding failed !'+err.message);
      })
      .run();
  });
}

function crearDirectorios(rutaImagenes) {
  return new Promise(async function (resolve, reject) {
    await fs.readdir(rutaImagenes, function (err,elementosEventos) {
      if(err){
        console.log("error"+err.message);
        reject("error"+err.message);
      }else{
        elementosEventos.forEach(file => {
          let rutaVideo = __dirname+ '/' +rutaVideos+file;
          if(!fs.existsSync(rutaVideo)){
            fs.mkdirSync(rutaVideo);
          }
        });
        resolve('Creadas carpetas video');
      }

    });
  });
}

crearCarpetasYVideos(rutaVideos,rutaImagenes).then(()=>{

  comprobarUltimoYSubir(rutaVideos);
  return console.log("done");
});