server.js

// NPM dependencies
var express = require('express');
var sharejs = require('../ShareJS/').server;
var faye = require('faye');
var fs = require('fs');

// Local Modules
var DashboardManager = require('./js/server/dashboardsManager');
var DataSetsManager = require('./js/server/dataSetsManager');
var GadgetsManager = require('./public/gadgets/gadgetsInfo');
var xhr = require("./js/shared/xhr");

var app = express.createServer();
var dashboardsManager;
var dataSetsManager;
var gadgetsManager;

// Share JS options
var options = {
  rest: { path : '/dashboard/:name/state'},
  db: { type: 'none'},
  auth: function(client, action) {
    // This auth handler rejects any ops bound for docs starting with 'readonly'.
    if (action.name === 'submit op' && action.docName.match(/^readonly/)) {
      action.reject();
    } else {
      action.accept();
    }
  }
};

// Lets try and enable redis persistance if redis is installed...
try {
  require('redis');
  options.db = {type: 'redis'};
} catch (e) {}


// Attach the sharejs REST and Socket.io interfaces to the server
sharejs.attach(app, options);

// Faye adapter for pub/sub of dashboards
var adapter = new faye.NodeAdapter({ mount: '/faye', timeout: 45 });
adapter.attach(app);

// Configuration
app.configure(function(){
  app.set('views', __dirname + '/templates');
  app.set('view engine', 'mustache');
  app.register(".mustache", require('stache'));
  app.set('view options', {layout: false });
  app.use(express.bodyParser());
  app.use(express.static(__dirname + '/js/client'));
  app.use(express.static(__dirname + '/js/shared'));  
  app.use(express.static(__dirname + '/public')); 
});

app.configure('development', function(){
  app.use(express.errorHandler({ dumpExceptions: true, showStack: true })); 
});

app.configure('production', function(){
  app.use(express.errorHandler()); 
});

dashboardsManager = new DashboardManager(app, app.model); 

app.get('/xhrProxy/:request', function(req, res){
  var options = {
    url: req.params.request,
    type: "GET",
    success: function(response) { res.send(response); }
  }
  xhr.ajax(options); 
});

app.get('/gadgets/', function(req, res){
  res.send(GadgetsManager.all);
});


app.get('/dataSet/:id', function(req, res){
  var dataSetFound = function (dataSet) {
    res.send(JSON.stringify(dataSet));
  };
  DataSetsManager.find(req.params.id, dataSetFound);
});

app.post('/dataSet/', function(req, res){
  var queryInfo = req.body || undefined;
  var dataSetCreated = function(datasetId){
    res.send(JSON.stringify(datasetId));
  }
  DataSetsManager.createDataSet(queryInfo, dataSetCreated);
});    

app.post('/uploadFITS/:dashboardId', function(req, res) {	
	// Add the image to /images/fitsViewer/(dashboardId)
	var tmpPath = req.files.fitsImage.path;
	var dashboardId = req.params.dashboardId;
	var targetPath = './public/images/fitsViewer/';
	
	// Create the directory if it doesnt exist
	if (!fs.existsSync(targetPath)) {
		fs.mkdirSync(targetPath);
	}
	if (!fs.existsSync(targetPath + dashboardId)) {
		fs.mkdirSync(targetPath + dashboardId);
	}
	
	targetPath +=  dashboardId + '/' + req.files.fitsImage.name;
	fs.rename(tmpPath, targetPath, function(err) {
		if (err) throw err;
		fs.unlink(tmpPath, function() {
			if (err) throw err;
			res.send('/images/fitsViewer/' + dashboardId + '/' + req.files.fitsImage.name);
		});
	});
});       

if (!module.parent) {
  app.listen(80);
  console.log("ASCOT server listening on port %d", app.address().port);
}