Initial

Author: KoryNunn

.gitignore

@@ -0,0 +1,25 @@
+# Logs
+logs
+*.log
+
+# Runtime data
+pids
+*.pid
+*.seed
+
+# Directory for instrumented libs generated by jscoverage/JSCover
+lib-cov
+
+# Coverage directory used by tools like istanbul
+coverage
+
+# Grunt intermediate storage (http://gruntjs.com/creating-plugins#storing-task-files)
+.grunt
+
+# Compiled binary addons (http://nodejs.org/api/addons.html)
+build/Release
+
+# Dependency directory
+# Deployed apps should consider commenting this line out:
+# see https://npmjs.org/doc/faq.html#Should-I-check-my-node_modules-folder-into-git
+node_modules

format.js

@@ -0,0 +1,12 @@
+var toJsonObject = require('object-tojson'),
+    transformData = require('./transformData');
+
+module.exports = function(sequelizeResult, prequelizeModel, callback){
+    var rawData = toJsonObject(sequelizeResult);
+
+    if(sequelizeResult && sequelizeResult.sequelize){
+        return callback(null, transformData(rawData, prequelizeModel, prequelizeModel.settings.transformProperty.from));
+    }
+
+    callback(null, rawData);
+};

index.js

@@ -0,0 +1,344 @@
+var parseSettings = require('./parseSettings'),
+    transformData = require('./transformData'),
+    format = require('./format'),
+    righto = require('righto'),
+    abbott = require('abbott'),
+    errors = require('generic-errors'),
+    merge = require('flat-merge'),
+    extend = require('cyclic-deep-extend'),
+    oneResultOrError = require('./oneResultOrError'),
+    resultOrError = require('./resultOrError');
+
+function extendSettings(settings, extendedSettings){
+    settings = merge({}, settings);
+    settings.where = extend({}, settings.where);
+    settings.include = extend({}, settings.include);
+    return settings;
+}
+
+/*
+    ## Get.
+
+    Get exactly one result by ID.
+
+    If no results are found, the call will be rejected with an Error with code 404.
+*/
+function get(id, settings, callback){
+    var prequelizeModel = this;
+
+    settings = extendSettings(settings, {
+        where: {
+            id: id
+        }
+    });
+
+    var sequelizeSettings = parseSettings(settings, prequelizeModel);
+
+    sequelizeSettings.transaction = settings.transaction;
+
+    var result = prequelizeModel.findOne(sequelizeSettings);
+
+    callback && result(callback);
+
+    return result;
+}
+
+/*
+    ## Find.
+
+    Find the first result of a query.
+
+    If no results are found, the call will be resolved no result.
+*/
+function find(settings, callback){
+    var prequelizeModel = this;
+
+    settings = extendSettings(settings);
+
+    var sequelizeSettings = parseSettings(settings, prequelizeModel);
+
+    extend(sequelizeSettings, {
+        limit: 1,
+        transaction: settings.transaction
+    });
+
+    var sequelizeResult = prequelizeModel.model.find(sequelizeSettings);
+
+    var result = righto(format, sequelizeResult, prequelizeModel);
+
+    callback && result(callback);
+
+    return result;
+}
+
+/*
+    ## Find All.
+
+    Find all results of a query.
+*/
+function findAll(settings, callback){
+    var prequelizeModel = this;
+
+    settings = extendSettings(settings);
+
+    var sequelizeSettings = parseSettings(settings, prequelizeModel);
+
+    extend(sequelizeSettings, {
+        transaction: settings.transaction
+    });
+
+    var sequelizeResult = prequelizeModel.model.findAll(sequelizeSettings);
+
+    var result = righto(format, sequelizeResult, prequelizeModel);
+
+    callback && result(callback);
+
+    return result;
+}
+
+/*
+    ## Find All.
+
+    Find and count all results of a query.
+*/
+function findAndCountAll(settings, callback){
+    var prequelizeModel = this;
+
+    settings = extendSettings(settings);
+
+    var sequelizeSettings = parseSettings(settings, prequelizeModel);
+
+    extend(sequelizeSettings, {
+        transaction: settings.transaction
+    });
+
+    var sequelizeResult = prequelizeModel.model.findAndCountAll(sequelizeSettings);
+
+    var result = righto(format, sequelizeResult, prequelizeModel);
+
+    callback && result(callback);
+
+    return result;
+}
+
+/*
+    ## Find one.
+
+    Find exactly one result of a query.
+
+    If no results are found, the call will be rejected with an Error with code 404.
+
+    If more than one result is found, the call will throw.
+*/
+function findOne(settings, callback){
+    var prequelizeModel = this;
+
+    settings = extendSettings(settings);
+
+    var sequelizeSettings = parseSettings(settings, prequelizeModel);
+
+    extend(sequelizeSettings, {
+        limit: 2,
+        transaction: settings.transaction
+    });
+
+    var sequelizeResult = prequelizeModel.model.findAll(sequelizeSettings);
+
+    var result = righto(oneResultOrError, sequelizeResult, prequelizeModel);
+
+    callback && result(callback);
+
+    return result;
+}
+
+/*
+    ## Remove.
+
+    Remove all results of a query.
+*/
+function remove(settings, callback){
+    var prequelizeModel = this;
+
+    settings = extendSettings(settings);
+
+    var sequelizeSettings = parseSettings(settings, prequelizeModel);
+
+    extend(sequelizeSettings, {
+        transaction: settings.transaction
+    });
+
+    var sequelizeResult = prequelizeModel.model.remove(sequelizeSettings);
+
+    var result = righto(format, sequelizeResult, prequelizeModel);
+
+    callback && result(callback);
+
+    return result;
+}
+
+/*
+    ## Remove One.
+
+    Remove exactly one result of a query.
+
+    If no results are found, the call will be rejected with an Error with code 404.
+
+    If more than one result is found, the call will throw.
+*/
+function removeOne(settings, callback){
+    var prequelizeModel = this;
+
+    settings = extendSettings(settings);
+
+    var sequelizeSettings = parseSettings(settings, prequelizeModel),
+        removeTransaction = settings.transaction ?
+            null :
+            prequelizeModel.model.sequelize.transaction();
+
+    extend(sequelizeSettings, {
+        transaction: settings.transaction || removeTransaction
+    });
+
+    var sequelizeResult = prequelizeModel.model.remove(sequelizeSettings);
+
+    function resolveResult(done){
+        var deleteResult = righto(format, sequelizeResult, prequelizeModel);
+
+        deleteResult(function(error, result){
+            if(error){
+                if(removeTransaction){
+                    return abbott(removeTransaction.rollback())(function(){
+                        done(error, result);
+                    });
+                }
+
+                return done(error);
+            }
+
+            if(result > 2){
+                throw new Error('Expected only 1 affected row, instead affected ' + result);
+            }
+
+            function checkOne(error, result){
+                if(error || result < 1){
+                    return done(error || new errors.NotFound());
+                }
+
+                done(null, result);
+            }
+
+            if(removeTransaction){
+                return abbott(removeTransaction.commit())(function(commitError){
+                    checkOne(commitError, result);
+                });
+            }
+
+            checkOne(null, result);
+        });
+    }
+
+    var result = righto(resolveResult);
+
+    callback && result(callback);
+
+    return result;
+}
+
+/*
+    ## Create.
+
+    Create a record.
+*/
+function create(data, settings, callback){
+    var prequelizeModel = this;
+
+    settings = extendSettings(settings);
+
+    var sequelizeSettings = parseSettings(settings, prequelizeModel);
+
+    extend(sequelizeSettings, {
+        transaction: settings.transaction
+    });
+
+    var sequelizeResult = prequelizeModel.model.create(
+            transformData(data, prequelizeModel, prequelizeModel.settings.transformProperty.to),
+            sequelizeSettings
+        );
+
+    var result = righto(format, sequelizeResult, prequelizeModel);
+
+    callback && result(callback);
+
+    return result;
+}
+
+/*
+    ## Update.
+
+    Update all results of a query.
+*/
+function update(data, settings, callback){
+    var prequelizeModel = this;
+
+    settings = extendSettings(settings);
+
+    var sequelizeSettings = parseSettings(settings, prequelizeModel);
+
+    extend(sequelizeSettings, {
+        transaction: settings.transaction
+    });
+
+    var sequelizeResult = prequelizeModel.model.update(
+            transformData(data, prequelizeModel, prequelizeModel.settings.transformProperty.to),
+            sequelizeSettings
+        );
+
+    var result = righto(format, sequelizeResult, prequelizeModel);
+
+    callback && result(callback);
+
+    return result;
+}
+
+var defaultTransformProperty = {
+    to: function(data){
+        return data;
+    },
+    from: function(data){
+        return data;
+    }
+}
+
+function createModelMethods(model, modelName, settings) {
+    var modelSettings = settings.modelSettings && settings.modelSettings[modelName],
+        prequelizeModel = {
+            name: modelName,
+            prequelizeSettings: settings,
+            settings: {
+                transformProperty:
+                    settings.transformProperty ||
+                    defaultTransformProperty
+            },
+            model: model
+        };
+
+    prequelizeModel.get = get.bind(prequelizeModel);
+    prequelizeModel.find = find.bind(prequelizeModel);
+    prequelizeModel.findAll = findAll.bind(prequelizeModel);
+    prequelizeModel.findAndCountAll = findAndCountAll.bind(prequelizeModel);
+    prequelizeModel.findOne = findOne.bind(prequelizeModel);
+    prequelizeModel.remove = remove.bind(prequelizeModel);
+    prequelizeModel.removeOne = removeOne.bind(prequelizeModel);
+    prequelizeModel.create = create.bind(prequelizeModel);
+    prequelizeModel.update = update.bind(prequelizeModel);
+
+    return prequelizeModel;
+}
+
+module.exports = function(models, settings){
+    settings = settings || {};
+    return Object.keys(models).reduce(function(result, key){
+        result[key] = createModelMethods(models[key], key, settings);
+        return result;
+    }, {});
+};