tyler.durden/xo-server
1
0
Fork 0
mirror of https://github.com/mclueppers/xo-server.git synced 2025-07-28 08:24:28 +02:00
Code Issues Packages Projects Releases Wiki Activity

Handles object deletions in XAPI events.

Browse Source
This commit is contained in:
Julien Fontanet 2013-10-10 15:25:12 +02:00
parent 95a4dc94a4
commit 302d9cb321
1 changed files with 19 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

27
src/xo.js
View File

@ -321,18 +321,27 @@ Xo.prototype.start = function (cfg) {
return function loop() { return function loop() {
return xapi.call('event.next').then(function (events) { return xapi.call('event.next').then(function (events) {
_.each(events, function (event) { _.each(events, function (event) {
var collection = xobjs[xclasses_map[event.class]]; var klass = event.class;
var collection = xobjs[xclasses_map[klass]];
if (collection) if (collection)
{ {
var record = event.snapshot; var operation = event.operation;
record.id = event.ref; var ref = event.ref;
record.pool = pool_id;
console.log(xapi.host, event.class, event.ref); console.log(xapi.host, operation, klass, ref);
// @todo Handle operation types. if ('del' === event.operation)
collection.add(event.snapshot, {'replace': true}); {
collection.remove(event.ref);
}
else
{
var record = event.snapshot;
record.id = ref;
record.pool = pool_id;
collection.add(record, {'replace': true});
}
} }
}); });
@ -364,7 +373,9 @@ Xo.prototype.start = function (cfg) {
_.each(servers, connect); _.each(servers, connect);
}); });
xo.servers.on('remove', function (server_ids) { xo.servers.on('remove', function (server_ids) {
// @todo _.each(server_ids, function (server_id) {
delete xo.connections[server_id];
});
}); });
// xo events are used to automatically close connections if the // xo events are used to automatically close connections if the