/*! * Dependencies */ var assert = require('assert'); var util = require('util'); var i8n = require('inflection'); var defineScope = require('./scope.js').defineScope; var ModelBaseClass = require('./model.js'); exports.Relation = Relation; exports.RelationDefinition = RelationDefinition; var RelationTypes = { belongsTo: 'belongsTo', hasMany: 'hasMany', hasOne: 'hasOne', hasAndBelongsToMany: 'hasAndBelongsToMany' }; exports.RelationTypes = RelationTypes; exports.HasMany = HasMany; exports.HasManyThrough = HasManyThrough; exports.HasOne = HasOne; exports.HasAndBelongsToMany = HasAndBelongsToMany; exports.BelongsTo = BelongsTo; var RelationClasses = { belongsTo: BelongsTo, hasMany: HasMany, hasManyThrough: HasManyThrough, hasOne: HasOne, hasAndBelongsToMany: HasAndBelongsToMany }; function normalizeType(type) { if (!type) { return type; } var t1 = type.toLowerCase(); for (var t2 in RelationTypes) { if (t2.toLowerCase() === t1) { return t2; } } return null; } /** * Relation definition class. Use to define relationships between models. * @param {Object} definition * @class RelationDefinition */ function RelationDefinition(definition) { if (!(this instanceof RelationDefinition)) { return new RelationDefinition(definition); } definition = definition || {}; this.name = definition.name; assert(this.name, 'Relation name is missing'); this.type = normalizeType(definition.type); assert(this.type, 'Invalid relation type: ' + definition.type); this.modelFrom = definition.modelFrom; assert(this.modelFrom); this.keyFrom = definition.keyFrom; this.modelTo = definition.modelTo; assert(this.modelTo); this.keyTo = definition.keyTo; this.modelThrough = definition.modelThrough; this.keyThrough = definition.keyThrough; this.multiple = (this.type !== 'belongsTo' && this.type !== 'hasOne'); } RelationDefinition.prototype.toJSON = function () { var json = { name: this.name, type: this.type, modelFrom: this.modelFrom.modelName, keyFrom: this.keyFrom, modelTo: this.modelTo.modelName, keyTo: this.keyTo, multiple: this.multiple }; if (this.modelThrough) { json.modelThrough = this.modelThrough.modelName; json.keyThrough = this.keyThrough; } return json; }; /** * A relation attaching to a given model instance * @param {RelationDefinition|Object} definition * @param {Object} modelInstance * @returns {Relation} * @constructor * @class Relation */ function Relation(definition, modelInstance) { if (!(this instanceof Relation)) { return new Relation(definition, modelInstance); } if (!(definition instanceof RelationDefinition)) { definition = new RelationDefinition(definition); } this.definition = definition; this.modelInstance = modelInstance; } /** * HasMany subclass * @param {RelationDefinition|Object} definition * @param {Object} modelInstance * @returns {HasMany} * @constructor * @class HasMany */ function HasMany(definition, modelInstance) { if (!(this instanceof HasMany)) { return new HasMany(definition, modelInstance); } assert(definition.type === RelationTypes.hasMany); Relation.apply(this, arguments); } util.inherits(HasMany, Relation); /** * HasManyThrough subclass * @param {RelationDefinition|Object} definition * @param {Object} modelInstance * @returns {HasManyThrough} * @constructor * @class HasManyThrough */ function HasManyThrough(definition, modelInstance) { if (!(this instanceof HasManyThrough)) { return new HasManyThrough(definition, modelInstance); } assert(definition.type === RelationTypes.hasMany); assert(definition.modelThrough); HasMany.apply(this, arguments); } util.inherits(HasManyThrough, HasMany); /** * BelongsTo subclass * @param {RelationDefinition|Object} definition * @param {Object} modelInstance * @returns {BelongsTo} * @constructor * @class BelongsTo */ function BelongsTo(definition, modelInstance) { if (!(this instanceof BelongsTo)) { return new BelongsTo(definition, modelInstance); } assert(definition.type === RelationTypes.belongsTo); Relation.apply(this, arguments); } util.inherits(BelongsTo, Relation); /** * HasAndBelongsToMany subclass * @param {RelationDefinition|Object} definition * @param {Object} modelInstance * @returns {HasAndBelongsToMany} * @constructor * @class HasAndBelongsToMany */ function HasAndBelongsToMany(definition, modelInstance) { if (!(this instanceof HasAndBelongsToMany)) { return new HasAndBelongsToMany(definition, modelInstance); } assert(definition.type === RelationTypes.hasAndBelongsToMany); Relation.apply(this, arguments); } util.inherits(HasAndBelongsToMany, Relation); /** * HasOne subclass * @param {RelationDefinition|Object} definition * @param {Object} modelInstance * @returns {HasOne} * @constructor * @class HasOne */ function HasOne(definition, modelInstance) { if (!(this instanceof HasOne)) { return new HasOne(definition, modelInstance); } assert(definition.type === RelationTypes.hasOne); Relation.apply(this, arguments); } util.inherits(HasOne, Relation); /*! * Find the relation by foreign key * @param {*} foreignKey The foreign key * @returns {Object} The relation object */ function findBelongsTo(modelFrom, modelTo, keyTo) { var relations = modelFrom.relations; var keys = Object.keys(relations); for (var k = 0; k < keys.length; k++) { var rel = relations[keys[k]]; if (rel.type === RelationTypes.belongsTo && rel.modelTo === modelTo && rel.keyTo === keyTo) { return rel.keyFrom; } } return null; } /*! * Look up a model by name from the list of given models * @param {Object} models Models keyed by name * @param {String} modelName The model name * @returns {*} The matching model class */ function lookupModel(models, modelName) { if(models[modelName]) { return models[modelName]; } var lookupClassName = modelName.toLowerCase(); for (var name in models) { if (name.toLowerCase() === lookupClassName) { return models[name]; } } } /** * Define a "one to many" relationship by specifying the model name * * Examples: * ``` * User.hasMany(Post, {as: 'posts', foreignKey: 'authorId'}); * ``` * * ``` * Book.hasMany(Chapter); * ``` * Or, equivalently: * ``` * Book.hasMany('chapters', {model: Chapter}); * ``` * @param {Model} modelFrom Source model class * @param {Object|String} modelTo Model object (or String name of model) to which you are creating the relationship. * @options {Object} params Configuration parameters; see below. * @property {String} as Name of the property in the referring model that corresponds to the foreign key field in the related model. * @property {String} foreignKey Property name of foreign key field. * @property {Object} model Model object */ RelationDefinition.hasMany = function hasMany(modelFrom, modelTo, params) { var thisClassName = modelFrom.modelName; params = params || {}; if (typeof modelTo === 'string') { params.as = modelTo; if (params.model) { modelTo = params.model; } else { var modelToName = i8n.singularize(modelTo).toLowerCase(); modelTo = lookupModel(modelFrom.dataSource.modelBuilder.models, modelToName); } } var relationName = params.as || i8n.camelize(modelTo.pluralModelName, true); var fk = params.foreignKey || i8n.camelize(thisClassName + '_id', true); var idName = modelFrom.dataSource.idName(modelFrom.modelName) || 'id'; var definition = new RelationDefinition({ name: relationName, type: RelationTypes.hasMany, modelFrom: modelFrom, keyFrom: idName, keyTo: fk, modelTo: modelTo, multiple: true }); if (params.through) { definition.modelThrough = params.through; var keyThrough = definition.throughKey || i8n.camelize(modelTo.modelName + '_id', true); definition.keyThrough = keyThrough; } modelFrom.relations[relationName] = definition; if (!params.through) { // obviously, modelTo should have attribute called `fk` modelTo.dataSource.defineForeignKey(modelTo.modelName, fk, this.modelName); } var scopeMethods = { findById: scopeMethod(definition, 'findById'), destroy: scopeMethod(definition, 'destroyById') } if(definition.modelThrough) { scopeMethods.create = scopeMethod(definition, 'create'); scopeMethods.add = scopeMethod(definition, 'add'); scopeMethods.remove = scopeMethod(definition, 'remove'); } // Mix the property and scoped methods into the prototype class defineScope(modelFrom.prototype, params.through || modelTo, relationName, function () { var filter = {}; filter.where = {}; filter.where[fk] = this[idName]; if (params.through) { filter.collect = i8n.camelize(modelTo.modelName, true); filter.include = filter.collect; } return filter; }, scopeMethods); }; function scopeMethod(definition, methodName) { var method = function () { var relationClass = RelationClasses[definition.type]; if (definition.type === RelationTypes.hasMany && definition.modelThrough) { relationClass = RelationClasses.hasManyThrough; } var relation = new relationClass(definition, this); return relation[methodName].apply(relation, arguments); }; return method; } HasMany.prototype.findById = function (id, cb) { var modelTo = this.definition.modelTo; var fk = this.definition.keyTo; var pk = this.definition.keyFrom; var modelInstance = this.modelInstance; modelTo.findById(id, function (err, inst) { if (err) { return cb(err); } if (!inst) { return cb(new Error('Not found')); } // Check if the foreign key matches the primary key if (inst[fk] && inst[fk].toString() === modelInstance[pk].toString()) { cb(null, inst); } else { cb(new Error('Permission denied: foreign key does not match the primary key')); } }); }; HasMany.prototype.destroyById = function (id, cb) { var modelTo = this.definition.modelTo; var fk = this.definition.keyTo; var pk = this.definition.keyFrom; var modelInstance = this.modelInstance; modelTo.findById(id, function (err, inst) { if (err) { return cb(err); } if (!inst) { return cb(new Error('Not found')); } // Check if the foreign key matches the primary key if (inst[fk] && inst[fk].toString() === modelInstance[pk].toString()) { inst.destroy(cb); } else { cb(new Error('Permission denied: foreign key does not match the primary key')); } }); }; // Create an instance of the target model and connect it to the instance of // the source model by creating an instance of the through model HasManyThrough.prototype.create = function create(data, done) { var definition = this.definition; var modelTo = definition.modelTo; var modelThrough = definition.modelThrough; if (typeof data === 'function' && !done) { done = data; data = {}; } var modelInstance = this.modelInstance; // First create the target model modelTo.create(data, function (err, ac) { if (err) { return done && done(err, ac); } // The primary key for the target model var pk2 = modelTo.dataSource.idName(modelTo.modelName) || 'id'; var fk1 = findBelongsTo(modelThrough, definition.modelFrom, definition.keyFrom); var fk2 = findBelongsTo(modelThrough, definition.modelTo, pk2); var d = {}; d[fk1] = modelInstance[definition.keyFrom]; d[fk2] = ac[pk2]; // Then create the through model modelThrough.create(d, function (e) { if (e) { // Undo creation of the target model ac.destroy(function () { done && done(e); }); } else { done && done(err, ac); } }); }); }; /** * Add the target model instance to the 'hasMany' relation * @param {Object|ID} acInst The actual instance or id value */ HasManyThrough.prototype.add = function (acInst, done) { var definition = this.definition; var modelThrough = definition.modelThrough; var modelTo = definition.modelTo; var pk1 = definition.keyFrom; var data = {}; var query = {}; var fk1 = findBelongsTo(modelThrough, definition.modelFrom, definition.keyFrom); // The primary key for the target model var pk2 = modelTo.dataSource.idName(modelTo.modelName) || 'id'; var fk2 = findBelongsTo(modelThrough, definition.modelTo, pk2); query[fk1] = this.modelInstance[pk1]; query[fk2] = acInst[pk2] || acInst; data[fk1] = this.modelInstance[pk1]; data[fk2] = acInst[pk2] || acInst; // Create an instance of the through model modelThrough.findOrCreate({where: query}, data, done); }; /** * Remove the target model instance from the 'hasMany' relation * @param {Object|ID) acInst The actual instance or id value */ HasManyThrough.prototype.remove = function (acInst, done) { var modelThrough = this.definition.modelThrough; var fk2 = this.definition.keyThrough; var pk = this.definition.keyFrom; var q = {}; q[fk2] = acInst[pk] || acInst; modelThrough.deleteAll(q, done ); }; /** * Declare "belongsTo" relation that sets up a one-to-one connection with * another model, such that each instance of the declaring model "belongs to" * one instance of the other model. * * For example, if an application includes users and posts, and each post can * be written by exactly one user. The following code specifies that `Post` has * a reference called `author` to the `User` model via the `userId` property of * `Post` as the foreign key. * ``` * Post.belongsTo(User, {as: 'author', foreignKey: 'userId'}); * ``` * * This optional parameter default value is false, so the related object will * be loaded from cache if available. * * @param {Class|String} modelTo Model object (or String name of model) to * which you are creating the relationship. * @options {Object} params Configuration parameters; see below. * @property {String} as Name of the property in the referring model that * corresponds to the foreign key field in the related model. * @property {String} foreignKey Name of foreign key property. * */ RelationDefinition.belongsTo = function (modelFrom, modelTo, params) { params = params || {}; if ('string' === typeof modelTo) { params.as = modelTo; if (params.model) { modelTo = params.model; } else { var modelToName = modelTo.toLowerCase(); modelTo = lookupModel(modelFrom.dataSource.modelBuilder.models, modelToName); } } var idName = modelFrom.dataSource.idName(modelTo.modelName) || 'id'; var relationName = params.as || i8n.camelize(modelTo.modelName, true); var fk = params.foreignKey || relationName + 'Id'; var relationDef = modelFrom.relations[relationName] = new RelationDefinition({ name: relationName, type: RelationTypes.belongsTo, modelFrom: modelFrom, keyFrom: fk, keyTo: idName, modelTo: modelTo }); modelFrom.dataSource.defineForeignKey(modelFrom.modelName, fk, modelTo.modelName); // Define a property for the scope so that we have 'this' for the scoped methods Object.defineProperty(modelFrom.prototype, relationName, { enumerable: true, configurable: true, get: function() { var relation = new BelongsTo(relationDef, this); var relationMethod = relation.related.bind(relation); relationMethod.create = relation.create.bind(relation); relationMethod.build = relation.build.bind(relation); relationMethod._targetClass = relationDef.modelTo.modelName; return relationMethod; } }); // Wrap the property into a function for remoting // so that it can be accessed as /api/// // For example, /api/orders/1/customer var fn = function() { var f = this[relationName]; f.apply(this, arguments); }; fn.shared = true; fn.http = {verb: 'get', path: '/' + relationName}; fn.accepts = {arg: 'refresh', type: 'boolean', http: {source: 'query'}}; fn.description = 'Fetches belongsTo relation ' + relationName; fn.returns = {arg: relationName, type: 'object', root: true}; modelFrom.prototype['__get__' + relationName] = fn; }; BelongsTo.prototype.create = function(targetModelData, cb) { var modelTo = this.definition.modelTo; var fk = this.definition.keyTo; var pk = this.definition.keyFrom; var modelInstance = this.modelInstance; modelTo.create(targetModelData, function(err, targetModel) { if(!err) { modelInstance[fk] = targetModel[pk]; cb && cb(err, targetModel); } else { cb && cb(err); } }); }; BelongsTo.prototype.build = function(targetModelData) { var modelTo = this.definition.modelTo; return new modelTo(targetModelData); }; /** * Define the method for the belongsTo relation itself * It will support one of the following styles: * - order.customer(refresh, callback): Load the target model instance asynchronously * - order.customer(customer): Synchronous setter of the target model instance * - order.customer(): Synchronous getter of the target model instance * * @param refresh * @param params * @returns {*} */ BelongsTo.prototype.related = function (refresh, params) { var modelTo = this.definition.modelTo; var pk = this.definition.keyTo; var fk = this.definition.keyFrom; var modelInstance = this.modelInstance; var relationName = this.definition.name; if (arguments.length === 1) { params = refresh; refresh = false; } else if (arguments.length > 2) { throw new Error('Method can\'t be called with more than two arguments'); } var cachedValue; if (!refresh && modelInstance.__cachedRelations && (modelInstance.__cachedRelations[relationName] !== undefined)) { cachedValue = modelInstance.__cachedRelations[relationName]; } if (params instanceof ModelBaseClass) { // acts as setter modelInstance[fk] = params[pk]; modelInstance.__cachedRelations[relationName] = params; } else if (typeof params === 'function') { // acts as async getter var cb = params; if (cachedValue === undefined) { modelTo.findById(modelInstance[fk], function (err, inst) { if (err) { return cb(err); } if (!inst) { return cb(null, null); } // Check if the foreign key matches the primary key if (inst[pk] === modelInstance[fk]) { cb(null, inst); } else { cb(new Error('Permission denied')); } }); return modelInstance[fk]; } else { cb(null, cachedValue); return cachedValue; } } else if (params === undefined) { // acts as sync getter return modelInstance[fk]; } else { // setter modelInstance[fk] = params; delete modelInstance.__cachedRelations[relationName]; } }; /** * A hasAndBelongsToMany relation creates a direct many-to-many connection with * another model, with no intervening model. For example, if your application * includes users and groups, with each group having many users and each user * appearing in many groups, you could declare the models this way: * ``` * User.hasAndBelongsToMany('groups', {model: Group, foreignKey: 'groupId'}); * ``` * * @param {String|Object} modelTo Model object (or String name of model) to * which you are creating the relationship. * @options {Object} params Configuration parameters; see below. * @property {String} as Name of the property in the referring model that * corresponds to the foreign key field in the related model. * @property {String} foreignKey Property name of foreign key field. * @property {Object} model Model object */ RelationDefinition.hasAndBelongsToMany = function hasAndBelongsToMany(modelFrom, modelTo, params) { params = params || {}; var models = modelFrom.dataSource.modelBuilder.models; if ('string' === typeof modelTo) { params.as = modelTo; if (params.model) { modelTo = params.model; } else { modelTo = lookupModel(models, i8n.singularize(modelTo)) || modelTo; } if (typeof modelTo === 'string') { throw new Error('Could not find "' + modelTo + '" relation for ' + modelFrom.modelName); } } if (!params.through) { var name1 = modelFrom.modelName + modelTo.modelName; var name2 = modelTo.modelName + modelFrom.modelName; params.through = lookupModel(models, name1) || lookupModel(models, name2) || modelFrom.dataSource.define(name1); } params.through.belongsTo(modelFrom); params.through.belongsTo(modelTo); this.hasMany(modelFrom, modelTo, {as: params.as, through: params.through}); }; /** * A HasOne relation creates a one-to-one connection from modelFrom to modelTo. * This relation indicates that each instance of a model contains or possesses * one instance of another model. For example, each supplier in your application * has only one account. * * @param {Function} modelFrom The declaring model class * @param {String|Function} modelTo Model object (or String name of model) to * which you are creating the relationship. * @options {Object} params Configuration parameters; see below. * @property {String} as Name of the property in the referring model that * corresponds to the foreign key field in the related model. * @property {String} foreignKey Property name of foreign key field. * @property {Object} model Model object */ RelationDefinition.hasOne = function (modelFrom, modelTo, params) { params = params || {}; if ('string' === typeof modelTo) { params.as = modelTo; if (params.model) { modelTo = params.model; } else { var modelToName = modelTo.toLowerCase(); modelTo = lookupModel(modelFrom.dataSource.modelBuilder.models, modelToName); } } var pk = modelFrom.dataSource.idName(modelTo.modelName) || 'id'; var relationName = params.as || i8n.camelize(modelTo.modelName, true); var fk = params.foreignKey || i8n.camelize(modelFrom.modelName + '_id', true); var relationDef = modelFrom.relations[relationName] = new RelationDefinition({ name: relationName, type: RelationTypes.hasOne, modelFrom: modelFrom, keyFrom: pk, keyTo: fk, modelTo: modelTo }); modelFrom.dataSource.defineForeignKey(modelTo.modelName, fk, modelFrom.modelName); // Define a property for the scope so that we have 'this' for the scoped methods Object.defineProperty(modelFrom.prototype, relationName, { enumerable: true, configurable: true, get: function() { var relation = new HasOne(relationDef, this); var relationMethod = relation.related.bind(relation) relationMethod.create = relation.create.bind(relation); relationMethod.build = relation.build.bind(relation); return relationMethod; } }); }; /** * Create a target model instance * @param {Object} targetModelData The target model data * @callback {Function} [cb] Callback function * @param {String|Object} err Error string or object * @param {Object} The newly created target model instance */ HasOne.prototype.create = function(targetModelData, cb) { var modelTo = this.definition.modelTo; var fk = this.definition.keyTo; var pk = this.definition.keyFrom; var modelInstance = this.modelInstance; targetModelData = targetModelData || {}; targetModelData[fk] = modelInstance[pk]; modelTo.create(targetModelData, function(err, targetModel) { if(!err) { cb && cb(err, targetModel); } else { cb && cb(err); } }); }; /** * Build a target model instance * @param {Object} targetModelData The target model data * @returns {Object} The newly built target model instance */ HasOne.prototype.build = function(targetModelData) { var modelTo = this.definition.modelTo; var pk = this.definition.keyFrom; var fk = this.definition.keyTo; targetModelData = targetModelData || {}; targetModelData[fk] = this.modelInstance[pk]; return new modelTo(targetModelData); }; /** * Define the method for the hasOne relation itself * It will support one of the following styles: * - order.customer(refresh, callback): Load the target model instance asynchronously * - order.customer(customer): Synchronous setter of the target model instance * - order.customer(): Synchronous getter of the target model instance * * @param {Boolean} refresh Reload from the data source * @param {Object|Function} params Query parameters * @returns {Object} */ HasOne.prototype.related = function (refresh, params) { var modelTo = this.definition.modelTo; var fk = this.definition.keyTo; var pk = this.definition.keyFrom; var modelInstance = this.modelInstance; var relationName = this.definition.name; if (arguments.length === 1) { params = refresh; refresh = false; } else if (arguments.length > 2) { throw new Error('Method can\'t be called with more than two arguments'); } var cachedValue; if (!refresh && modelInstance.__cachedRelations && (modelInstance.__cachedRelations[relationName] !== undefined)) { cachedValue = modelInstance.__cachedRelations[relationName]; } if (params instanceof ModelBaseClass) { // acts as setter params[fk] = modelInstance[pk]; modelInstance.__cachedRelations[relationName] = params; } else if (typeof params === 'function') { // acts as async getter var cb = params; if (cachedValue === undefined) { var query = {where: {}}; query.where[fk] = modelInstance[pk]; modelTo.findOne(query, function (err, inst) { if (err) { return cb(err); } if (!inst) { return cb(null, null); } // Check if the foreign key matches the primary key if (inst[fk] === modelInstance[pk]) { cb(null, inst); } else { cb(new Error('Permission denied')); } }); return modelInstance[pk]; } else { cb(null, cachedValue); return cachedValue; } } else if (params === undefined) { // acts as sync getter return modelInstance[pk]; } else { // setter params[fk] = modelInstance[pk]; delete modelInstance.__cachedRelations[relationName]; } };