verdnatura-mirror
/
loopback-datasource-juggler
mirror of https://github.com/loopbackio/loopback-datasource-juggler
0
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

All tests passed

This commit is contained in:
Wert_Lex 2015-08-24 20:45:41 +03:00
parent fb56915371
commit 84dc39dfe2
1 changed files with 6 additions and 77 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

83
lib/include.js
View File

@ -270,7 +270,7 @@ Inclusion.include = function (objects, include, options, cb) {
}
//This handles exactly hasMany. Fast and straightforward. Without parallel, each and other boilerplate.
if(relation.type === 'hasMany' && relation.multiple && !subInclude) {
if(relation.type === 'hasMany' && relation.multiple && !subInclude){
return includeHasManySimple(cb);
}
//assuming all other relations with multiple=true as hasMany
@ -503,91 +503,20 @@ Inclusion.include = function (objects, include, options, cb) {
};
relation.applyScope(null, filter);
relation.modelTo.find(filter, options, targetFetchHandler2);
relation.modelTo.find(filter, options, targetFetchHandler);
function targetFetchHandler2(err, targets) {
function targetFetchHandler(err, targets) {
if(err) {
return callback(err);
}
var targetsIdMap = includeUtils.buildOneToManyIdentityMap(targets, relation.keyTo);
includeUtils.join(objIdMap, targetsIdMap, function(obj1, valueToMergeIn){
obj1[relation.name] = valueToMergeIn;
defineCachedRelations(obj1);
obj1.__cachedRelations[relationName] = valueToMergeIn;
processTargetObj(obj1, function(){});
});
callback(err, objs);
}
/**
* Process fetched related objects
* @param err
* @param {Array<Model>} targets
* @returns {*}
*/
function targetFetchHandler(err, targets) {
console.log("### query done. I'm in targetFetchHandler");
console.log("### obtained: \ntargets(permission) count: " + targets.length + "\nobjs(users) count: " + objs.length);
if (err) {
return callback(err);
}
var modelToFKIdMap = includeUtils.buildOneToManyIdentityMap(targets, relation.keyTo);
var tasks = [];
//simultaneously process subIncludes
if (subInclude && targets) {
tasks.push(function subIncludesTask(next) {
relation.modelTo.include(targets, subInclude, options, next);
});
}
//process each target object
tasks.push(targetLinkingTask);
function targetLinkingTask(next) {
if (targets.length === 0) {
return async.each(objs, function(obj, next) {
processTargetObj(obj, next);
}, next);
}
// TODO: show targets length
// почему так сложно???? Не очень понимаю.
async.each(targets, linkManyToOne, next);
function linkManyToOne(target, next) {
console.log("### processing target: " + JSON.stringify(target));
//fix for bug in hasMany with referencesMany
var targetIds = [].concat(target[relation.keyTo]);
console.log("### targetIds: " + JSON.stringify(targetIds));
async.each(targetIds, function (targetId, next) {
var obj = objIdMap[targetId.toString()];
if (!obj) return next();
obj.__cachedRelations[relationName].push(target);
//console.time("@@@Prepare1");
processTargetObj(obj, next);
//console.timeEnd("@@@Prepare1");
}, function(err, processedTargets) {
if (err) {
return next(err);
}
console.time("finding object with empty ids");
var objsWithEmptyRelation = objs.filter(function(obj) {
return obj.__cachedRelations[relationName].length === 0;
});
console.timeEnd("finding object with empty ids"); // 0-1 ms
console.log("### objs with empty relations count: " + objsWithEmptyRelation.length);
//next(processedTargets);
console.time("Prepare empty");
async.each(objsWithEmptyRelation, function(obj, next) {
console.time("Prepare one");
processTargetObj(obj, next);
console.timeEnd("Prepare one");
}, function(err) {
console.timeEnd("Prepare empty");
next(err, processedTargets);
});
});
}
}
console.log("### tasks count: " + tasks.length);
execTasksWithInterLeave(tasks, callback);
}
}
/**