functions.js

var Q			  = require('q')
  , fs      = require('fs')
  , path 		= require('path')

  , exports = module.exports = {}
  ;

exports.readJSONFile = function(filePath){
  var deferred = Q.defer();
  fs.readFile(filePath, function (error, text) {
    if (error) {
      deferred.reject(new Error(error));
    } else {
      try{
        text = JSON.parse(text);
        deferred.resolve(text);
      }catch(error){
        deferred.reject('Invalid JSON');
      }
    }
  });
  return deferred.promise;
};

exports.readDir = function(dirPath, fileExtension){
  var deferred = Q.defer();
  fs.readdir(dirPath, function(error, filesList){
    if (error) {
      deferred.reject(new Error(dirPath + ': ' + error));
    } else {
      filesList = filesList.filter(function(file){
        return path.extname(file) == fileExtension;
      }).map(function(file){
        return dirPath + '/' + file;
      });
      deferred.resolve(filesList);
    }
  });
  return deferred.promise;
};

exports.pushContentFiles = function(filesList){
  var deferred 	= Q.defer()
    , contentDir 	= [];

  filesList.forEach(function(file) {
    exports.readJSONFile(file)
      .then(function(content){
        contentDir.push(content);
        if(contentDir.length == filesList.length){
          deferred.resolve( contentDir );
        }
      })
      .catch(function(){
        deferred.reject(new Error(file + ': reading file'));
      })
  });
  return deferred.promise;
};

exports.reply = function(request, response, status, header, content, filePath){
  if(!response.finished){
    response.writeHead(status, header);
    if(content){
      response.write(content.toString());
    }
    response.end();
    console.log(" -> " + request.method + " " + serverUrl + request.url + ' ' + (status > 299 ? status.toString().red : status.toString().green) + (filePath ? ' -> ' + filePath.cyan : ''));
  }
};