6f6c8f4521
refs #9178 - avoid importing 4 modules (logging, errors, events and i18n) - simply require common in each file
99 lines
3.3 KiB
JavaScript
99 lines
3.3 KiB
JavaScript
/**
|
|
* # Utils
|
|
* Parts of the model code which can be split out and unit tested
|
|
*/
|
|
var _ = require('lodash'),
|
|
Promise = require('bluebird'),
|
|
ObjectId = require('bson-objectid'),
|
|
common = require('../../lib/common'),
|
|
attach, detach;
|
|
|
|
/**
|
|
* Attach wrapper (please never call attach manual!)
|
|
*
|
|
* We register the creating event to be able to hook into the model creation process of Bookshelf.
|
|
* We need to load the model again, because of a known bookshelf issue:
|
|
* see https://github.com/tgriesser/bookshelf/issues/629
|
|
* (withRelated option causes a null value for the foreign key)
|
|
*
|
|
* roles [1,2]
|
|
* roles [{id: 1}, {id: 2}]
|
|
* roles [{role_id: 1}]
|
|
* roles [BookshelfModel]
|
|
*/
|
|
attach = function attach(Model, effectedModelId, relation, modelsToAttach, options) {
|
|
options = options || {};
|
|
|
|
var fetchedModel,
|
|
localOptions = {transacting: options.transacting};
|
|
|
|
return Model.forge({id: effectedModelId}).fetch(localOptions)
|
|
.then(function successFetchedModel(_fetchedModel) {
|
|
fetchedModel = _fetchedModel;
|
|
|
|
if (!fetchedModel) {
|
|
throw new common.errors.NotFoundError({level: 'critical', help: effectedModelId});
|
|
}
|
|
|
|
fetchedModel.related(relation).on('creating', function (collection, data) {
|
|
data.id = ObjectId.generate();
|
|
});
|
|
|
|
return Promise.resolve(modelsToAttach)
|
|
.then(function then(models) {
|
|
models = _.map(models, function mapper(model) {
|
|
if (model.id) {
|
|
return model.id;
|
|
} else if (!_.isObject(model)) {
|
|
return model.toString();
|
|
} else {
|
|
return model;
|
|
}
|
|
});
|
|
|
|
return fetchedModel.related(relation).attach(models, localOptions);
|
|
});
|
|
})
|
|
.finally(function () {
|
|
if (!fetchedModel) {
|
|
return;
|
|
}
|
|
|
|
fetchedModel.related(relation).off('creating');
|
|
});
|
|
};
|
|
|
|
detach = function detach(Model, effectedModelId, relation, modelsToAttach, options) {
|
|
options = options || {};
|
|
|
|
var fetchedModel,
|
|
localOptions = {transacting: options.transacting};
|
|
|
|
return Model.forge({id: effectedModelId}).fetch(localOptions)
|
|
.then(function successFetchedModel(_fetchedModel) {
|
|
fetchedModel = _fetchedModel;
|
|
|
|
if (!fetchedModel) {
|
|
throw new common.errors.NotFoundError({level: 'critical', help: effectedModelId});
|
|
}
|
|
|
|
return Promise.resolve(modelsToAttach)
|
|
.then(function then(models) {
|
|
models = _.map(models, function mapper(model) {
|
|
if (model.id) {
|
|
return model.id;
|
|
} else if (!_.isObject(model)) {
|
|
return model.toString();
|
|
} else {
|
|
return model;
|
|
}
|
|
});
|
|
|
|
return fetchedModel.related(relation).detach(models, localOptions);
|
|
});
|
|
});
|
|
};
|
|
|
|
module.exports.attach = attach;
|
|
module.exports.detach = detach;
|