-
Notifications
You must be signed in to change notification settings - Fork 56
/
Collection.js
142 lines (127 loc) · 4.38 KB
/
Collection.js
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
// VIE - Vienna IKS Editables
// (c) 2011 Henri Bergius, IKS Consortium
// (c) 2011 Sebastian Germesin, IKS Consortium
// (c) 2011 Szaby Grünwald, IKS Consortium
// VIE may be freely distributed under the MIT license.
// For all details and documentation:
// http://viejs.org/
VIE.prototype.Collection = Backbone.Collection.extend({
model: VIE.prototype.Entity,
initialize: function (models, options) {
if (!options || !options.vie) {
throw new Error('Each collection needs a VIE reference');
}
this.vie = options.vie;
this.predicate = options.predicate;
},
canAdd: function (type) {
return true;
},
get: function(id) {
if (id === null) {
return null;
}
id = (id.getSubject)? id.getSubject() : id;
if (typeof id === "string" && id.indexOf("_:") === 0) {
if (id.indexOf("bnode") === 2) {
//bnode!
id = id.replace("_:bnode", 'c');
return this._byCid[id];
} else {
return this._byId["<" + id + ">"];
}
} else {
id = this.toReference(id);
return this._byId[id];
}
},
addOrUpdate: function(model, options) {
options = options || {};
var collection = this;
var existing;
if (_.isArray(model)) {
var entities = [];
_.each(model, function(item) {
entities.push(collection.addOrUpdate(item, options));
});
return entities;
}
if (model === undefined) {
throw new Error("No model given");
}
if (_.isString(model)) {
model = {
'@subject': model,
id: model
};
}
if (!model.isEntity) {
model = new this.model(model);
}
if (model.id && this.get(model.id)) {
existing = this.get(model.id);
}
if (this.getByCid(model.cid)) {
existing = this.getByCid(model.cid);
}
if (existing) {
var newAttribs = {};
_.each(model.attributes, function(value, attribute) {
if (!existing.has(attribute)) {
newAttribs[attribute] = value;
return true;
}
else if (existing.get(attribute) === value) {
return true;
} else {
//merge existing attribute values with new ones!
//not just overwrite 'em!!
var oldVals = existing.attributes[attribute];
var newVals = value;
if (oldVals instanceof collection.vie.Collection) {
// TODO: Merge collections
return true;
}
if (options.overrideAttributes) {
newAttribs[attribute] = value;
return true;
}
if (attribute === '@context') {
newAttribs[attribute] = jQuery.extend(true, {}, oldVals, newVals);
} else {
oldVals = (jQuery.isArray(oldVals))? oldVals : [ oldVals ];
newVals = (jQuery.isArray(newVals))? newVals : [ newVals ];
newAttribs[attribute] = _.uniq(oldVals.concat(newVals));
newAttribs[attribute] = (newAttribs[attribute].length === 1)? newAttribs[attribute][0] : newAttribs[attribute];
}
}
});
if (!_.isEmpty(newAttribs)) {
existing.set(newAttribs, options.updateOptions);
}
return existing;
}
this.add(model, options.addOptions);
return model;
},
isReference: function(uri){
var matcher = new RegExp("^\\<([^\\>]*)\\>$");
if (matcher.exec(uri)) {
return true;
}
return false;
},
toReference: function(uri){
if (this.isReference(uri)) {
return uri;
}
return '<' + uri + '>';
},
fromReference: function(uri){
if (!this.isReference(uri)) {
return uri;
}
return uri.substring(1, uri.length - 1);
},
isCollection: true
});