app.js

var express = require('express');
var path = require('path');
var favicon = require('serve-favicon')
var logger = require('morgan');
var cookieParser = require('cookie-parser');
var bodyParser = require('body-parser');
var queue = require('queue');
var config = require('config');

var routes = require('./routes/index');
var add = require('./routes/add');
var edit = require('./routes/edit');
var pumps = require('./routes/pumps');
var admin = require('./routes/admin');

var mongoose = require('mongoose');
var db = mongoose.createConnection('mongodb://localhost/barmixvah');

var DrinkSchema = require('./models/Drink.js').DrinkSchema;
var Drink = db.model('drinks', DrinkSchema);

var PumpSchema = require('./models/Pump.js').PumpSchema;
var Pump = db.model('pumps', PumpSchema);

var robot = require('./public/javascripts/robot/backend.js');

var app = express();

// view engine setup
app.set('views', path.join(__dirname, 'views'));
app.set('view engine', 'jade');

app.use(favicon(path.join(__dirname, 'public', 'images', 'icon.png')));
app.use(logger('dev'));
app.use(bodyParser.json());
app.use(bodyParser.urlencoded());
app.use(cookieParser());
app.use(express.static(path.join(__dirname, 'public')));

app.get('/', routes.index(Drink, Pump));
app.get('/add', add.form(Drink));
app.get('/edit', edit.show(Drink));
app.get('/pumps', pumps.access(Drink, Pump));
app.get('/admin', admin.access(Drink, Pump));

app.post('/updatepump.json', routes.updatePump(Pump));
app.post('/drink.json', add.addDrink(Drink));
app.post('/pump.json', add.addPump(Pump));
app.post('/updatedrink.json', edit.updateDrink(Drink));


/// catch 404 and forwarding to error handler
app.use(function(req, res, next) {
    var err = new Error('Not Found');
    err.status = 404;
    next(err);
});

var server = app.listen(3000, '0.0.0.0');
var io = require('socket.io').listen(server);

var q = queue();
q.concurrency = 1;
q.autostart = true;

io.sockets.on('connection', function (socket) {
  socket.on("Make Drink", function (ingredients, slot) {
    if (q.length > 0) {
      socket.emit("Drink Status", "Pending");
    }
    q.push(function (cb) {
      console.log("Slot " + slot + " is now being served");
      if (config.has('Robot.multiGlassMode') &&
            config.get('Robot.multiGlassMode') == true) {
        socket.emit("Drink Status", "Moving");
        robot.moveToSlot(slot, function() {
          socket.emit("Drink Status", "Making");
          robot.pump(ingredients, cb);
        });
      } else {
        socket.emit("Drink Status", "Making");
        robot.pump(ingredients, cb);
      }
    });
  });

  socket.on("Start Pump", function (pump) {
    robot.startPump(pump);
  });

  socket.on("Stop Pump", function (pump) {
    robot.stopPump(pump);
  });
});

db.once('open', function () {
  Pump.findOne({}, function (err, pump) {
    if (pump == null) {
      var pumps = {
        label: "pumps",
        ingredients: [ { label: "pump0", ingredient: "" } ]
      };
      Pump.create(pumps);
    }
  });
});

/// error handlers

// development error handler
// will print stacktrace
if (app.get('env') === 'development') {
    app.use(function(err, req, res, next) {
        res.status(err.status || 500);
        res.render('error', {
            message: err.message,
            error: err
        });
    });
}

// production error handler
// no stacktraces leaked to user
app.use(function(err, req, res, next) {
    res.status(err.status || 500);
    res.render('error', {
        message: err.message,
        error: {}
    });
});


module.exports = app;