mirror of
https://github.com/mclueppers/xo-server.git
synced 2025-07-27 07:54:54 +02:00
Minor fix.
This commit is contained in:
parent
1f09d9e8b9
commit
9eb3973131
11
src/xo.js
11
src/xo.js
@ -228,6 +228,10 @@ Xo.prototype.start = function (cfg) {
|
|||||||
});
|
});
|
||||||
|
|
||||||
// When a server is added we should connect to it and fetch data.
|
// When a server is added we should connect to it and fetch data.
|
||||||
|
var xclasses_map = {}; // @todo Remove this ugly map.
|
||||||
|
_.each(xo.xclasses, function (xclass) {
|
||||||
|
xclasses_map[xclass.toLowerCase()] = xclass;
|
||||||
|
});
|
||||||
var connect = function (server) {
|
var connect = function (server) {
|
||||||
var pool_id = server.id;
|
var pool_id = server.id;
|
||||||
var xapi = new Xapi(server.host, server.username, server.password);
|
var xapi = new Xapi(server.host, server.username, server.password);
|
||||||
@ -242,6 +246,7 @@ Xo.prototype.start = function (cfg) {
|
|||||||
records = _.map(records, function (record, ref) {
|
records = _.map(records, function (record, ref) {
|
||||||
record.id = ref;
|
record.id = ref;
|
||||||
record.pool = pool_id;
|
record.pool = pool_id;
|
||||||
|
|
||||||
return record;
|
return record;
|
||||||
});
|
});
|
||||||
|
|
||||||
@ -256,9 +261,13 @@ Xo.prototype.start = function (cfg) {
|
|||||||
return xapi.call('event.next').then(function (event) {
|
return xapi.call('event.next').then(function (event) {
|
||||||
event = event[0]; // @todo Handle multiple events.
|
event = event[0]; // @todo Handle multiple events.
|
||||||
|
|
||||||
var collection = xobjs[event.class];
|
var collection = xobjs[xclasses_map[event.class]];
|
||||||
if (collection)
|
if (collection)
|
||||||
{
|
{
|
||||||
|
var record = event.snapshot;
|
||||||
|
record.id = event.ref;
|
||||||
|
record.pool = pool_id;
|
||||||
|
|
||||||
// @todo Handle operation types.
|
// @todo Handle operation types.
|
||||||
collection.add(event.snapshot, {'replace': true});
|
collection.add(event.snapshot, {'replace': true});
|
||||||
}
|
}
|
||||||
|
Loading…
x
Reference in New Issue
Block a user