Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
22 changes: 17 additions & 5 deletions karma.start.js
Original file line number Diff line number Diff line change
Expand Up @@ -2,7 +2,7 @@
var $rootScope, $q, $log, $timeout, DSHttpAdapterProvider, DSProvider, DSLocalStorageAdapter, DS, DSUtils, DSHttpAdapter, app, $httpBackend, p1, p2, p3, p4, p5;

var user1, organization2, comment3, profile4;
var comment11, comment12, comment13, organization14, profile15, user10, user16, user17, user18, organization15, user20, comment19, user22, profile21;
var comment11, comment12, comment13, organization14, profile15, user10, user16, user17, user18, organization15, user19, user20, comment19, user22, profile21;

var lifecycle = {};

Expand Down Expand Up @@ -184,10 +184,16 @@ function startInjector() {
name: 'comment',
relations: {
belongsTo: {
user: {
localField: 'user',
localKey: 'userId'
}
user: [
{
localField: 'user',
localKey: 'userId'
},
{
localField: 'approvedByUser',
localKey: 'approvedBy'
}
]
}
}
});
Expand Down Expand Up @@ -294,13 +300,19 @@ function startInjector() {
user18
]
};
user19 = {
id: 19,
name: 'test user 19'
};
user20 = {
id: 20,
name: 'test user 20'
};
comment19 = {
content: 'test comment 19',
id: 19,
approvedBy: 19,
approvedByUser: user19,
userId: 20,
user: user20
};
Expand Down
44 changes: 25 additions & 19 deletions src/datastore/async_methods/loadRelations.js
Original file line number Diff line number Diff line change
Expand Up @@ -87,30 +87,36 @@ function loadRelations(resourceName, instance, relations, options) {
var tasks = [];
var fields = [];

DS.utils.forOwn(definition.relations, function (relation, type) {
DS.utils.forOwn(relation, function (def, relationName) {
if (DS.utils.contains(relations, relationName)) {
var task;
var params = {};
params[def.foreignKey] = instance[definition.idAttribute];
DS.utils.forOwn(definition.relations, function (relatedModels, type) {
DS.utils.forOwn(relatedModels, function (defs, relationName) {
if (!DS.utils.isArray(defs)) {
defs = [defs];
}

if (type === 'hasMany') {
task = DS.findAll(relationName, params, options);
} else if (type === 'hasOne') {
if (def.localKey && instance[def.localKey]) {
task = DS.find(relationName, instance[def.localKey], options);
} else if (def.foreignKey) {
defs.forEach(function (def) {
if (DS.utils.contains(relations, relationName)) {
var task;
var params = {};
params[def.foreignKey] = instance[definition.idAttribute];

if (type === 'hasMany') {
task = DS.findAll(relationName, params, options);
} else if (type === 'hasOne') {
if (def.localKey && instance[def.localKey]) {
task = DS.find(relationName, instance[def.localKey], options);
} else if (def.foreignKey) {
task = DS.findAll(relationName, params, options);
}
} else {
task = DS.find(relationName, instance[def.localKey], options);
}
} else {
task = DS.find(relationName, instance[def.localKey], options);
}

if (task) {
tasks.push(task);
fields.push(def.localField);
if (task) {
tasks.push(task);
fields.push(def.localField);
}
}
}
});
});
});

Expand Down
22 changes: 14 additions & 8 deletions src/datastore/sync_methods/inject.js
Original file line number Diff line number Diff line change
Expand Up @@ -115,15 +115,21 @@ function _inject(definition, resource, attrs) {

function _injectRelations(definition, injected) {
var DS = this;
DS.utils.forOwn(definition.relations, function (relation, type) {
DS.utils.forOwn(relation, function (def, relationName) {
if (DS.definitions[relationName] && injected[def.localField]) {
try {
injected[def.localField] = DS.inject(relationName, injected[def.localField]);
} catch (err) {
DS.$log.error(errorPrefix(definition.name) + 'Failed to inject ' + type + ' relation: "' + relationName + '"!', err);
}
DS.utils.forOwn(definition.relations, function (relatedModels, type) {
DS.utils.forOwn(relatedModels, function (defs, relationName) {
if (!DS.utils.isArray(defs)) {
defs = [defs];
}

defs.forEach(function (def) {
if (DS.definitions[relationName] && injected[def.localField]) {
try {
injected[def.localField] = DS.inject(relationName, injected[def.localField]);
} catch (err) {
DS.$log.error(errorPrefix(definition.name) + 'Failed to inject ' + type + ' relation: "' + relationName + '"!', err);
}
}
});
});
});
}
Expand Down
11 changes: 11 additions & 0 deletions test/integration/datastore/async_methods/loadRelations.test.js
Original file line number Diff line number Diff line change
Expand Up @@ -69,6 +69,17 @@ describe('DS.loadRelations(resourceName, instance(Id), relations[, options]): ',
}, fail);

$httpBackend.flush();

// try a comment that has a belongsTo relationship to multiple users:
DS.inject('comment', comment19);
$httpBackend.expectGET('http://test.angular-cache.com/user/20').respond(200, user20);
$httpBackend.expectGET('http://test.angular-cache.com/user/19').respond(200, user19);
DS.loadRelations('comment', 19, ['user']).then(function (comment) {
assert.deepEqual(comment.user, user20);
assert.deepEqual(comment.approvedByUser, user19);
}, fail);
$httpBackend.flush();

});
it('should get an item from the server but not store it if cacheResponse is false', function () {
DS.inject('user', {
Expand Down
1 change: 1 addition & 0 deletions test/integration/datastore/sync_methods/inject.test.js
Original file line number Diff line number Diff line change
Expand Up @@ -185,6 +185,7 @@ describe('DS.inject(resourceName, attrs)', function () {

// comment19 relations
assert.deepEqual(DS.get('user', 20), user20);
assert.deepEqual(DS.get('user', 19), user19);

// profile21 relations
assert.deepEqual(DS.get('user', 22), user22);
Expand Down