app.js

var express         = require("express");
var parser          = require("body-parser");
var morgan          = require("morgan");
var methodOverride  = require("method-override");
var qs              = require('qs');
var mongoose        = require('mongoose');
var cors            = require('cors');
var path            = require('path');
var bodyParser      = require('body-parser');
var passport        = require('passport');
var cookieParser    = require("cookie-parser");
var jwt             = require('jsonwebtoken');
var expressJWT      = require('express-jwt');
var app             = express();
var server          = require('http').createServer(app);
var io              = require("socket.io")(server);

var User            = require('./models/user');
var routes          = require('./config/routes');
var config          = require('./config/config');
var secret          = require('./config/config').secret;

mongoose.connect(config.databaseUrl);

require('./config/passport')(passport);

app.use(cookieParser());
app.use(morgan("dev"));
app.use(cors());
app.use(passport.initialize());
app.use(parser.json({urlencoded: true}));
app.use(methodOverride(function(req, res){
  if (req.body && typeof req.body === "object" && "_method" in req.body){
    var method = req.body._method;
    delete req.body._method;
    return method;
  }
}));

app.use('/api', expressJWT({ secret: secret })
  .unless({
    path: [
      { url: '/api/login', methods: ['POST'] },
      { url: '/api/register', methods: ['POST'] },
      { url: '/api/auth/facebook', methods: ['POST'] }
    ]
  })
);

app.use(function(req, res, next){
  var payload;
  if (req.headers.authorization && req.headers.authorization.split(' ')[0] === 'Bearer') {
    payload = req.headers.authorization.split(' ')[1];
  }
  if (payload) {
    var decoded = jwt.verify(payload, secret);
    if (decoded._doc) {
      User
      .findById({ _id: decoded._doc._id }, function(err, user) {
        if (err) return res.json({err: err, user: user});
        if (!user) return res.status(401).json({message: 'No user found'});
        req.user = user;
        return next();
      });
    } else {
      return next();
    }
  } else {
    return next();
  }
});

app.use(function (err, req, res, next) {
  if (err.name === 'UnauthorizedError') {
    return res.status(401).json({message: 'Unauthorized request.', err: err});
  }
  next();
});

app.use("/", express.static("public"));
app.use("/", express.static("bower_components"));

app.use("/api", routes);

app.get("/*", function(req, res){
  res.sendFile(__dirname + "/public/index.html");
});

server.listen(config.port);
console.log("Express is listening on port " + config.port);

io.on('connect', function(socket) {
  socket.on("joinRoom", function(room){
    socket.join(room);
  });
  socket.on('addVideo', function(data) {
    socket.broadcast.to(data.channel_id).emit("updateVideo", data.videos_array);
  });
});