server.js

var THUMBNAILS_DIR = "thumbnails/";
var BUFFER_DIR = "buffer/";

var fs = require('fs')
  , async = require('async')
  , express = require('express')
  , spawn = require('child_process').spawn
  , exec = require('child_process').exec
  , humanize = require('humanize')
  , utils = require('./lib/utils')
  , mw = require('./lib/middlewares')
  , env = process.env.NODE_ENV || "development"
  ;

utils.ensureDirectoryExists('videos');
utils.ensureDirectoryExists('thumbnails');

var hooks = require('./hooks/index');

var settings = require('./settings.'+env+'.json');

var server = express();
var port = process.env.PORT || process.env.NODE_PORT || 1212;
server.set('port', port);

server.recordingWindow = { start: -8, duration: 20 };

require('./config/express')(server);

server.lastRecording = { time: 0, data: {} };

server.info = function() {
  return { recordingWindow: server.recordingWindow, channel: settings.channel, lastRecording: server.lastRecording };
}

/* *************
 * Server routes
 */
server.get('/start', function(req, res) {
  if(req.param('secret') != settings.secret) return res.send(403, "Unauthorized");
  var channel = req.param('channel');
  if(settings.videostreams[channel]) {
    exec("pm2 restart stream-"+channel);
    return res.send("Running pm2 restart stream-"+channel);
  }
});

server.get('/stop', function(req, res) {
  if(req.param('secret') != settings.secret) return res.send(403, "Unauthorized");
  var channel = req.param('channel');
  if(settings.videostreams[channel]) {
    exec("pm2 stop stream-"+channel);
    return res.send("Running pm2 stop stream-"+channel);
  }
});

server.get('/setup', function(req, res) {
  var secret = req.param('secret');

  if(secret == settings.secret) {
    var start = req.param('start', server.recordingWindow.start);
    var duration = req.param('duration', server.recordingWindow.duration);
    var channel = req.param('channel');
    if(channel && settings.videostreams[channel] && channel != settings.channel) {
      console.log(humanize.date('Y-m-d H:i:s')+" changing videostream channel to "+channel);
      settings.channel = channel;
      fs.writeFileSync('./settings.'+env+'.json',JSON.stringify(settings,null,2));
      exec("pm2 restart stream");
    }
    server.recordingWindow.start = start;
    server.recordingWindow.duration = duration;
  }

  res.send(server.info());
});

server.get('/record', mw.localhost, function(req, res) {
  if(server.busy) {
    return res.send("Sorry server already busy recording");
  }

  if(((new Date).getTime() - server.lastRecording.time) < 5000) {
    console.error("Last recording less than 5s ago, aborting");
    return res.send("Last recording less than 5s ago, aborting"); 
  }

  var channel = req.param('channel', settings.channel); 
  var start = req.param('start', server.recordingWindow.start);
  var duration = req.param('duration', server.recordingWindow.duration);
  var text = req.param('text','');

  console.log(humanize.date('Y-m-d H:i:s')+" /record?channel="+channel+"&start="+start+"&duration="+duration+"&text="+text);
  res.send("Recording video...");

  server.lastRecording.time = new Date;
  server.busy = true;

  utils.record(channel, start, duration, function(err, videofilename) {
    if(err || !videofilename) return res.send(500, "No video filename returned");
    var videoId = videofilename.replace('videos/','').replace('.mp4','');
    var videoUrl = settings.base_url+"/video?v="+videoId;

    // Generating the thumbnail and animated gif
    async.parallel([
      function(done) {
        utils.mp4toJPG(videofilename, Math.floor(duration/2), done); 
      },
      function(done) {
        utils.mp4toGIF(videofilename, Math.max(2,start), Math.min(13,duration), done); 
      }], function(err, results) {
        server.busy = false;
        var data = {
            id: videoId 
          , text: text 
          , video: videoUrl
          , thumbnail: videoUrl.replace('video','thumbnail')
          , gif: settings.base_url+"/videos/"+videoId+".gif" 
          , gifsize: fs.statSync('videos/'+videoId+'.gif').size
        }
        server.lastRecording.data = data;
        try { 
          hooks(data);
        } catch(e) {
          console.error("Error in hooks: ", e, e.stack);
        }
    });
  });
});

server.get('/latest.gif', function(req, res) {
  res.redirect("/gif?v="+server.lastRecording.data.id);
});

server.get('/', function(req, res) {
  res.render('home', { title: "@ReplayLastGoal" });
});

server.get('/latest', function(req, res) {
});

server.get('/video', mw.requireValidVideoID, function(req, res, next) {
  var v = req.param('v');
  var video = settings.base_url+'/videos/'+v+'.mp4';
  var thumbnail = settings.base_url+'/thumbnail?v='+ v;
  res.render('video.hbs', {title: "View video replay of the world cup goal", thumbnail: thumbnail, video: video });
});

server.get('/thumbnail', mw.requireValidVideoID, function(req, res, next) {
  var v = req.param('v');
  res.sendfile('./'+THUMBNAILS_DIR + v + '.jpg');
});

server.get('/gif', mw.requireValidVideoID, function(req, res, next) {
  var v = req.param('v');
  res.sendfile('./videos/' + v + '.gif');
});

server.get('/live', function(req, res) {
  if(req.param('secret') != settings.secret) return res.send(403, "Unauthorized");
  var channel = req.param('channel', settings.channel);
  res.render('live.hbs', {
    videostream: "/buffer/"+channel+"/livestream.m3u8" // settings.videostreams[channel] 
  });
});

server.use('/videos', express.static('videos/'));
server.use('/buffer', express.static('buffer/'));
server.use('/status', require('./lib/status'));

console.log(humanize.date('Y-m-d H:i:s')+" Server listening in "+server.set('env')+" environment on port "+port+" with the following settings: ", server.info());
server.listen(port);