app.js

//var app = require('express')();
var bodyParser = require('body-parser');
var express = require('express');
var multipart = require('connect-multiparty');
const Twitter = require('twitter');
const redis = require('redis');
const helmet = require('helmet'); 
const xssFilter = require('x-xss-protection')
const csrf = require('csurf');

//variables de entorno
require('dotenv').config();


//emails
const nodemailer = require('nodemailer');

//Importamos nuestros controllers
var index = require('./controllers/index');
var baseDatos = require('./controllers/baseDatos');
var mascotForm = require('./controllers/addMascot');
var mascotasForm = require('./controllers/MascotasController');
var userForm = require('./controllers/UserController');
var loginForm = require('./controllers/LoginController');
var registerForm = require('./controllers/RegisterController');
var session = require('client-sessions');
var realtime = require('./config/realtime/realTime');
var streaming = require('./controllers/streaming');
var confirmarForm = require('./controllers/confirmEmail');
const bootFacebook = require('./controllers/bootFacebook');


var view = '/views';

const app = new express();

const http = require('http').Server(app),
      sessionIo = require("express-session")({
        secret: "addoptap",
        resave: true,
        saveUninitialized: true
      }),
      sharedsession = require("express-socket.io-session");

var router = express.Router();
realtime(http,sessionIo,sharedsession);
//var io = require("socket.io")(http);
app.enable('trust proxy');
app.use(function(req, res, next) {
  if (req.session && req.session.user) {
    User.findOne({ email: req.session.user.email }, function(err, user) {
      if (user) {
        req.user = user;
        delete req.user.password; // delete the password from the session
        req.session.user = user;  //refresh the session value
        res.locals.user = user;
      }
      // finishing processing the middleware and run the route
      next();
    });
  } else {
    next();
  }
});

// Login MiddleWare 
function requireLogin (req, res, next) {
  if (!req.session.user) {
    res.redirect('/login');
  } else {
    next();
  }
};

//Seguridad
app.use(helmet());
app.disable('x-powered-by');
app.use(helmet.xssFilter())

//https
const fs = require('fs');
const httpR = require('http');
const https = require('https');

const privateKey  = fs.readFileSync('privateKey.key', 'utf8');
const certificate = fs.readFileSync('certificate.crt', 'utf8');
const credentials = {key: privateKey, cert: certificate};

const httpServer = httpR.createServer(app);
const httpsServer = https.createServer(credentials, app);




// Convierte una petición recibida (POST-GET...) a objeto JSON
app.use(bodyParser.json()); // to support JSON bodies
app.use(bodyParser.urlencoded({ extended: true })); // to support URL-encoded bodies
app.use(multipart()); //Express 4

app.use(express.static('public'));
//Nuestro sistema de templates - EJS
app.set('view engine', 'ejs')
app.set('views', 'views');
 
//Rutas
app.use(session({
  cookieName: 'session',
  secret: 'eg[isfd-8yF9-7w2315df{}+Ijsli;;to8',
  duration: 30 * 60 * 10000000,
  activeDuration: 5 * 60 * 10000000,
  httpOnly: true,
  secure: true,
  ephemeral: true
}));


app.use('/', index);
app.use('/mascotas', mascotasForm);
app.use('/perfil', userForm);

app.use('/baseDatos',baseDatos);
app.use('/streaming', streaming);
app.use('webhook', bootFacebook)

app.use('/registrate', registerForm);
app.use('/confirmar', confirmarForm);
app.use('/nuevamascota', requireLogin, mascotForm);

app.use('/login', loginForm);
app.get('/logout', function(req, res) {
  req.session.reset();
  res.redirect('/');
});


const rClient = redis.createClient();

//Twitter client - appadoptes@gmail.com

const client = new Twitter({
  consumer_key: 'QPVhuH5TqE7s5QJ3DdVqEKCAy',
  consumer_secret: 'mJc2EBaPR2U8mRWJOpNUUQ6BBd4xEp9clTHd0lDjiqQ49xPfx1',
  access_token_key: '548766227-3XkCg04G6F3Zqy1HnlmD0wRUFqtBbT5hdvTShhNH',
  access_token_secret: 'NiSYFiW5NHKhbAMphtKEZY1ZnowKvCLYksxpulwE2pogP'
});

//Escucha del stream - track:palabras claves
const stream = client.stream('statuses/filter', {track:'#plaiaundiApp'});
stream.on('data', (tweet) => {

  /* Hacamos retwitt */
  client.post('statuses/retweet', {id:tweet.id_str}, (err, response) => {
      if (response) {
          console.log('Retweeteado');
      }
      // if there was an error while tweeting
      if (err) {
          console.log('Error al retwittear');
      }
  });

  /* Damos una respuesta al twitt */
  //Contruimos nuestro objeto de respuesta
  let statusObj = {status: `Hola @${tweet.user.screen_name}, puedes buscar un dueño para la mascota en nuestra web :)`};

   //llamamos a la funcion post para crear una respuesta
   client.post('statuses/update', statusObj, (error, tweetReply, response) => {
         //Si llega algun error los printeamos
         if(error){
          console.log(error);
         }else{
          //Motsramos en consola nuestra respuesta
          console.log(tweetReply.text);
         }

  });

  /* Marcamos como favorito el twitt */
  client.post('favorites/create', {id:tweet.id_str}, (error, response) => {
     if(error){
      console.log(error)
     }else{
       nuevoTwitt = {
         id: response.id_str,
         text: response.text,
         user: response.user.screen_name
       }
      // console.log(`Twit ID ${response.id_str} Liked! - ${response.text}`);
      let url = `https://twitter.com/${response.user.screen_name}/status/${response.id_str}`;
      rClient.publish('nuevoTwitt',JSON.stringify(nuevoTwitt));
     }
  });
  
});

stream.on('error', (error) => {
  console.log(`Ha ocurrido un error ${error}`)
});


app.use(function(req, res, next){
  res.status(404);
  // respond with html page
  if (req.accepts('html')) {
    res.render('404', { url: req.url, usuario : req.session.user });
    return;
  }

});



var port = process.env.PORT || 88;

http.listen(port, function(){
  console.log('listening on *:' + port);
});
    
const httpsPort = process.env.PORTHTTPS || 3010;
httpsServer.listen(httpsPort, () => {
  console.log(httpsPort+' -> https:');
}); 

// Exportar la variable 'app' que contiene express para poder usarla-requerirla en otros ficheros
module.exports = app;