index.js

var express = require('express');
var app = express();
var port = process.env.PORT || 8080;
var ip = process.env.IP  || undefined;

// serve static files from client. This file is copied to dist in production.

var Firebase = require("firebase");
var http = require('http');
var youtubeData = 'http://gdata.youtube.com/feeds/api/videos/';
var youtubeQueryParams = '?v=2&alt=jsonc';



////////////////////////////////////////////
// NEED TO CHANGE THIS DATABASE LINK HERE 
// var config = {firebase:{url:'https://blistering-heat-6745.firebaseio.com'}};
// ORIGINAL: var config = {firebase:{url:'https://blistering-heat-6745.firebaseio.com'}};
// TEST: var config = {firebase:{url:'https://scheming-lion2.firebaseio.com'}};
///////////////////////////////////////////



var config = {firebase:{url:'https://scheming-lions.firebaseio.com'}};
var queueRef = new Firebase(config.firebase.url+'/rooms/<%= currentRoom %>/queue/');
var videoRef = new Firebase(config.firebase.url+'/rooms/<%= currentRoom %>/youTube/');

var getVideoData = function(video, cb){
  http.get(youtubeData + video + youtubeQueryParams, function(res){
    var ret = '';
    res.on('data', function(chunk) {
      console.log("Received body data:");
      ret += chunk.toString();
    });

    res.on('end', function() {
      console.log('ended receiving data!');
      console.log(ret);
      cb(JSON.parse(ret));
    });
  });
};

var stopped = true;
var roomID = '<%= currentRoom %>';

var handleNextQueueItem = function(queueSnapshot){
  console.log('The value of the queue is');
  var queue = queueSnapshot.val();
  console.log('QUEUE', queue);
  if(queue === null){
    videoRef.set({currentVideo: '', startTime: Date.now(), isPlaying: false}, function(){
      console.log('Set the current video to nothingness');
      // wait for next item in queue to continue looping.
      stopped = true;
    });
  } else{
    console.log('OK there is a video in the queue so lets use it.');
    var nextID = queueSnapshot.val().item.split('v=')[1];
    console.log('nextID ', nextID);
    var nextName = queueSnapshot.name();

    videoRef.set({currentVideo:nextID,isPlaying:true,startTime:Date.now()},function(){
      var remove = new Firebase(config.firebase.url+'/rooms/'+roomID+'/queue/'+nextName);
      remove.remove(function(){
        console.log('removed top vid from queue');
        // wait for this to end to finish looping.
        stopped = false;
        checkCurrentVideo();
      });
    });
  }
};

var updateQueueWatcher = function(id) {
  roomID = id;

  queueRef = new Firebase(config.firebase.url+'/rooms/'+id+'/queue/');
  videoRef = new Firebase(config.firebase.url+'/rooms/'+id+'/youTube/');
  
  // to handle case of empty queue and stopped player, listen for added children to queue
  queueRef.on('child_added', function(snap) {
    console.log('Child added',stopped);
    if(stopped){
      checkCurrentVideo();
    }
  });
};

// checks to see if current video must be removed (finished playing)
var checkCurrentVideo = function(){

  console.log('videoRef: ' + videoRef);

  videoRef.once('value', function (snapshot) {

    // get the current video with its starting time
    var currentVideo = snapshot.val();
    console.log("Curent Video Line 74", currentVideo);

    if (currentVideo === null) {

      videoRef.child('currentVideo').transaction(function() {
        return '';
      });
      videoRef.child('isPlaying').transaction(function() {
        return false;
      });
      videoRef.child('startTime').transaction(function() {
        return -1;
      });

      checkCurrentVideo();
    } else {
      // if there is no video currently playing, we don't do anything
      if(currentVideo.currentVideo === ""){
        console.log('Video is nothing now');
        queueRef.startAt().limit(1).once('child_added', handleNextQueueItem);
        return;
      }

      // get the video data
      getVideoData(currentVideo.currentVideo, function(res){
        var endTime = currentVideo.startTime+res.data.duration*1000;
        var remaining = endTime - Date.now();

        if(remaining < 0){
          // handle the next item on the queue if any
          queueRef.startAt().limit(1).once('child_added',handleNextQueueItem);
          return;
        }

        // get the video data
        getVideoData(currentVideo.currentVideo,function(res){
          var endTime = currentVideo.startTime+res.data.duration*1000;
          var remaining = endTime - Date.now();

          console.log('remaning time:  ' + remaining);

          if(remaining < 0){
            // handle the next item on the queue if any
            queueRef.startAt().limit(1).once('child_added',handleNextQueueItem);
          } else {
            // this video is fine. Wait and check again once the remaining time is done
            stopped = false;
            setTimeout(checkCurrentVideo,remaining);
          }
        });
      });
    }
  }, function (errorObject) {
    console.log('The read failed: ' + errorObject.code);
  });

};

// enables the views of the application to use straight HTML files.
// essentially we are using ejs as the template for our server's views
// but not really using ejs in the files at all.
app.engine('html', require('ejs').renderFile);
app.set('view engine', 'html');

// tells the application where to go to find the views so that they can
// be rendered.
app.set('views', __dirname + '/client');

app.use(express.static(__dirname + '/client'));

app.get('/:id', function(request, response) {
  console.log("id: " + request.params.id);

  updateQueueWatcher(request.params.id);
  checkCurrentVideo();

  response.render('index', { currentRoom: request.params.id });
});

var server = require('http').createServer(app);
// start server
server.listen(port, ip, function () {
  console.log('Express server listening on %d!', port);
  checkCurrentVideo();
});

// expose app
exports = module.exports = app;