backbone.mongoose.js

var mongoose = require("mongoose"),
	fs = require('fs');

var backboneMongoose = function(config) {

	var files = fs.readdirSync(config.schema_dir),
		connection = mongoose.createConnection(config.db_url),
		mongooseSync;

	files.forEach(function(fileName) {
		require(config.schema_dir + '/' + fileName);
	});

	mongooseSync = function(method, model, options) {

		var MongooseModel = connection && connection.model(model.mongooseModel),

			process = function(err, docs) {
				if (err) {
					if (options.error) {
						options.error(model, err, options);
					}
				}
				if (options.success) {
					options.success(model, docs, options);
				}
			},

			data = model.toJSON() || {};

		options = options || (options = {});

		if (!MongooseModel) {
			return;
		}

		switch (method) {
		case 'create':
			MongooseModel.create(data, process);
			break;
		case 'update':
			MongooseModel.findByIdAndUpdate(model.id, data, process);
			break;
		case 'patch':
			//MongooseModel.patch(model, process);
			break;
		case 'delete':
			MongooseModel.remove(data, process);
			break;
		case 'read':
			MongooseModel.find(data, process);
		}
	};
	return mongooseSync;
};

backboneMongoose.VERSION = "0.1.1";

exports = module.exports = backboneMongoose;