tyler.durden
/
icingaweb2-module-director
mirror of https://github.com/Icinga/icingaweb2-module-director.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Sync: start to work with multiple datasources... 

...working, but still unfinished
This commit is contained in:
Thomas Gelf 2015-07-26 15:46:25 +02:00
parent 87c1f8c121
commit 68e359cbc0
1 changed files with 56 additions and 44 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

100
library/Director/Import/Sync.php
View File

@ -60,8 +60,10 @@ class Sync
$imported = array(); $imported = array();
foreach ($sources as $source) { foreach ($sources as $source) {
$sourceId = $source->id; $sourceId = $source->id;
$rows = $db->fetchLatestImportedRows($sourceId, $sourceColumns[$sourceId]);
$key = $source->key_column; $key = $source->key_column;
$sourceColumns[$sourceId][$key] = $key;
$rows = $db->fetchLatestImportedRows($sourceId, $sourceColumns[$sourceId]);
$imported[$sourceId] = array(); $imported[$sourceId] = array();
foreach ($rows as $row) { foreach ($rows as $row) {
if (! property_exists($row, $key)) { if (! property_exists($row, $key)) {
@ -78,54 +80,63 @@ class Sync
// TODO: Filter auf object, nicht template // TODO: Filter auf object, nicht template
$objects = IcingaHost::loadAll($db, null, 'object_name'); $objects = IcingaHost::loadAll($db, null, 'object_name');
// TODO: "hardcoded" single sourceId, fix this! foreach ($sources as $source) {
foreach ($imported[$sourceId] as $key => $row) { $sourceId = $source->id;
$newProps = array(
'object_type' => 'object',
'object_name' => $key
);
$newVars = array(); foreach ($imported[$sourceId] as $key => $row) {
$newProps = array(
'object_type' => 'object',
'object_name' => $key
);
foreach ($properties as $p) { $newVars = array();
$prop = $p->destination_field;
$val = $this->fillVariables($p->source_expression, $row);
if (substr($prop, 0, 5) === 'vars.') { foreach ($properties as $p) {
$newVars[substr($prop, 5)] = $val; if ($p->source_id !== $sourceId) continue;
$prop = $p->destination_field;
$val = $this->fillVariables($p->source_expression, $row);
if (substr($prop, 0, 5) === 'vars.') {
$newVars[substr($prop, 5)] = $val;
} else {
$newProps[$prop] = $val;
}
}
if (array_key_exists($key, $objects)) {
switch ($rule->update_policy) {
case 'override':
$objects[$key] = IcingaHost::create($newProps);
foreach ($newVars as $prop => $var) {
$objects[$key]->vars()->$prop = $var;
}
break;
case 'merge':
$object = $objects[$key];
foreach ($newProps as $prop => $value) {
// TODO: data type?
$object->set($prop, $value);
}
foreach ($newVars as $prop => $var) {
// TODO: property merge policy
$object->vars()->$prop = $var;
}
break;
default:
// policy 'ignore', no action
}
} else { } else {
$newProps[$prop] = $val; $objects[$key] = IcingaHost::create($newProps);
foreach ($newVars as $prop => $var) {
$objects[$key]->vars()->$prop = $var;
}
} }
} }
if (array_key_exists($key, $objects)) { }
switch ($rule->update_policy) {
case 'override':
$objects[$key] = IcingaHost::create($newProps);
foreach ($newVars as $prop => $var) {
$objects[$key]->vars()->$prop = $var;
}
break;
case 'merge':
$object = $objects[$key];
foreach ($newProps as $prop => $value) {
// TODO: data type?
$object->set($prop, $value);
}
foreach ($newVars as $prop => $var) {
// TODO: property merge policy
$object->vars()->$prop = $var;
}
break;
default:
// policy 'ignore', no action
}
} else {
$objects[$key] = IcingaHost::create($newProps);
foreach ($newVars as $prop => $var) {
$objects[$key]->vars()->$prop = $var;
}
}
$dba = $db->getDbAdapter(); $dba = $db->getDbAdapter();
$dba->beginTransaction(); $dba->beginTransaction();
@ -156,12 +167,13 @@ class Sync
$object->delete(); $object->delete();
} }
} }
if (! $object->object_name) {
continue;
}
$object->store($db); $object->store($db);
} }
$dba->commit(); $dba->commit();
}
return 42; // We have no sync_run history table yet return 42; // We have no sync_run history table yet
} }
} }