mongoose.js

var util = require('util');
var moment = require('moment');
var mongoose = require('mongoose');
var Schema = mongoose.Schema;

exports.connect = function(dburl, callback) {
  mongoose.connect(dburl);
}

exports.disconnect = function(callback) {
  mongoose.disconnect(callback);
}

exports.setup = function(callback) { callback(null); }

var ArticleSchema = new Schema({
  ts     : { type: Date, default: Date.now },
  title  : String,
  article   : String,
  description : String,
  keywords : String,
  alias : String
});
var PrefsSchema = new Schema({
  name: String,
  email: String,
  items: Number,
  description : String,
  keywords: String,
  gravatar: Boolean
});
var PagesSchema = new Schema({
  ts     : { type: Date, default: Date.now },
  page   : String,
  content: String,
  description : String,
  keywords : String,
  alias : String
});

mongoose.model('Articles', ArticleSchema);
var Article = mongoose.model('Articles');

mongoose.model('Prefs', PrefsSchema);
var Prefs = mongoose.model('Prefs');

mongoose.model('Pages', PagesSchema);
var Pages = mongoose.model('Pages');

exports.emptyArticle = { "_id": "", title: "", article: "", alias: "", description: "", keywords: "" };
exports.emptyPage = { "_id": "", page: "", content: "", alias: "", description: "", keywords: ""  };

exports.add = function(title, ts, article, description, keywords, alias, callback) {
  var newArticle = new Article();
  newArticle.title = title;
  if (ts !== '') {
    var date_fields = ts.split("/");
    newArticle.ts = new Date(date_fields[2], date_fields[0]-1, date_fields[1]);
  } else {
    newArticle.ts = new Date();
  }
  newArticle.article   = article;
  newArticle.description = description;
  newArticle.keywords = keywords;
  newArticle.alias = alias;
  newArticle.save(function(err) {
    if (err) {
      util.log('FATAL '+ err);
      callback(err);
    } else
      callback(null);
  });
}
exports.addpage = function(page, ts, content, description, keywords, alias, callback) {
  var newPage = new Pages();
  newPage.page = page;
  if (ts !== '') {
    var date_fields = ts.split("/");
    newPage.ts = new Date(date_fields[2], date_fields[0]-1, date_fields[1]);
  } else {
    newPage.ts = new Date();
  }
  newPage.content   = content;
  newPage.description = description;
  newPage.keywords = keywords;
  newPage.alias = alias;
  newPage.save(function(err) {
    if (err) {
      util.log('FATAL '+ err);
      callback(err);
    } else
      callback(null);
  });
}

exports.delete = function(id, callback) {
  exports.findArticleById(id, function(err, doc) {
    if (err) 
      callback(err);
    else {
      util.log(util.inspect(doc));
      doc.remove();
      callback(null);
    }
  });
}
exports.deletePage = function(id, callback) {
  exports.findPageById(id, function(err, doc) {
    if (err) 
      callback(err);
    else {
      util.log(util.inspect(doc));
      doc.remove();
      callback(null);
    }
  });
}

exports.countArticles = function(callback) {
  Article.count({}, function(err, doc) {
    if (err) {
      util.log('FATAL '+ err);
      callback(err, null);
    }
    callback(null, doc);
  });
}

exports.edit = function(id, title, ts, article, description, keywords, alias, callback) {
  exports.findArticleById(id, function(err, doc) {
    if (err)
      callback(err);
    else {
      if (ts !== undefined) {
        var date_fields = ts.split("/");
        doc.ts = new Date(date_fields[2], date_fields[0]-1, date_fields[1]);
      } else {
        doc.ts = new Date();
      }
      doc.title = title;
      doc.article   = article;
      doc.description = description;
      doc.keywords = keywords;
      doc.alias = alias;
      doc.save(function(err) {
        if (err) {
          util.log('FATAL '+ err);
          callback(err);
        } else
            callback(null);
      });
    }
  });    
}

exports.editpage = function(id, page, ts, content, description, keywords, alias, callback) {
  exports.findPageById(id, function(err, doc) {
    if (err)
      callback(err);
    else {
      if (ts !== undefined) {
        var date_fields = ts.split("/");
        doc.ts = new Date(date_fields[2], date_fields[0]-1, date_fields[1]);
      } else {
        doc.ts = new Date();
      }
      doc.page = page;
      doc.content   = content;
      doc.description = description;
      doc.keywords = keywords;
      doc.alias = alias;
      doc.save(function(err) {
        if (err) {
          util.log('FATAL '+ err);
          callback(err);
        } else
            callback(null);
      });
    }
  });    
}

exports.allArticlesPages = function(num, callback) {
  exports.allArticles(num, function(err, articles){
    exports.allPages(num, function(err, pages){
      callback(err, articles, pages);
    })
  });
}
exports.allArticles = function(num, callback) {
  Article.find({}).limit(num).sort("-ts").execFind(callback);
}
exports.allPages = function(num, callback) {
  Pages.find({}).limit(num).sort("-ts").execFind(callback);
}
exports.allArticlesPaged = function(num, page, callback) {
  var skip = 0;
  if (page > 0){
    skip = num * page - num;
  }
  Article.find({}).skip(skip).limit(num).sort("-ts").execFind(callback);
}

exports.forAll = function(doEach, done) {
  Article.find({}, function(err, docs) {
    if (err) {
      util.log('FATAL '+ err);
      done(err, null);
    }
    docs.forEach(function(doc) {
      doEach(null, doc);
    });
    done(null);
  });
}

exports.projectPreferences = function(params, callback){
  Prefs.findOne({ }, function(err, doc) {
    if (err) {
      util.log('FATAL '+ err);
      callback(err, null);
    }
    if (doc===null){
      doc = { name: params.config.project, email: "", items: params.config.per_page, description: "", keywords: "" };
    }            
    callback(null, doc);
  });
}
exports.save = function(name, email, items, description, keywords, gravatar, callback) {
  Prefs.findOne({ }, function(err, doc) {
    if (err) {
        util.log('FATAL '+ err);
        callback(err);
    } else {
      if (doc===null){
          exports.newPref(name, email, items, description, keywords, gravatar, callback);
      } else {
        doc.name = name;
        doc.email = email;
        doc.items = items;
        doc.description = description;
        doc.keywords = keywords;
        doc.gravatar = gravatar;
        doc.save(function(err) {
          if (err) {
            util.log('FATAL '+ err);
            callback(err);
          } else
            callback(null);
        });
      }
    }
  }); 
}

exports.newPref = function(name, email, items, description, keywords, callback) {
  var newPrefs = new Prefs();
  newPrefs.name = name;
  newPrefs.email = email;
  newPrefs.items   = items;
  newPrefs.description = description;
  newPrefs.keywords = keywords;
  newPrefs.gravatar = gravatar;
  newPrefs.save(function(err) {
    if (err) {
      util.log('FATAL '+ err);
      callback(err);
    } else
      callback(null);
  });
}

var findArticleById = exports.findArticleById = function(id, callback) {
  Article.findOne({ _id: id }, function(err, doc) {
    if (err) {
      util.log('FATAL '+ err);
      callback(err, null);
    }
    callback(null, doc);
  });
}
var findPageById = exports.findPageById = function(id, callback) {
  Pages.findOne({ _id: id }, function(err, doc) {
    if (err) {
      util.log('FATAL '+ err);
      callback(err, null);
    }
    callback(null, doc);
  });
}
var findPageByAlias = exports.findPageByAlias = function(alias, callback) {
  Pages.findOne({ alias: alias }, function(err, doc) {
    if (err) {
      util.log('FATAL '+ err);
      callback(err, null);
    }
    callback(null, doc);
  });
}
var findArticleByDate = exports.findArticleByDate = function(year, month, day, title, callback) {
  var start = new Date(year, month-1, day);   //months are 0 based so Jan equals 0
  var end = new Date(year, month-1, day);
  end.setMonth( end.getMonth( ) + 1 );
  Article.findOne({ts: {$gte: start, $lt: end}, alias: title}, function(err, doc) {
    if (err) {
      util.log('FATAL '+ err);
      callback(err, null);
    }
    callback(null, doc);
  });
}