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

Implement IcingaObjectImport to handle object imports

This commit is contained in:
Alexander Fuhr 2015-06-26 15:54:00 +02:00
parent 097b4dec25
commit 864b9ea55c
1 changed files with 10 additions and 31 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

41
library/Director/Objects/IcingaObjectImports.php
View File

@ -88,8 +88,7 @@ class IcingaObjectImports implements Iterator, Countable, IcingaConfigRenderer
$new[] = $i; $new[] = $i;
} }
} }
sort($existing);
sort($new);
if ($existing === $new) { if ($existing === $new) {
return $this; return $this;
} }
@ -120,7 +119,6 @@ class IcingaObjectImports implements Iterator, Countable, IcingaConfigRenderer
protected function refreshIndex() protected function refreshIndex()
{ {
ksort($this->imports);
$this->idx = array_keys($this->imports); $this->idx = array_keys($this->imports);
} }
@ -156,7 +154,6 @@ class IcingaObjectImports implements Iterator, Countable, IcingaConfigRenderer
); );
} }
var_dump($imports);die;
$this->imports[$import] = $imports[$import]; $this->imports[$import] = $imports[$import];
$this->modified = true; $this->modified = true;
@ -209,47 +206,29 @@ class IcingaObjectImports implements Iterator, Countable, IcingaConfigRenderer
return $this; return $this;
} }
/**
* Modification TODO
*
* @return $this
*/
public function store() public function store()
{ {
$storedGroups = array_keys($this->storedGroups);
$groups = array_keys($this->groups);
$objectId = $this->object->id; $objectId = $this->object->id;
$type = $this->getType(); $type = $this->getType();
$objectCol = $type . '_id'; $objectCol = $type . '_id';
$groupCol = $type . 'group_id'; $importCol = 'parent_' . $type . '_id';
$toDelete = array_diff($storedGroups, $groups); $this->object->db->delete($this->getImportTableName(), $objectCol . ' = ' . $objectId);
foreach ($toDelete as $group) {
$where = sprintf(
$objectCol . ' = %d AND ' . $groupCol . ' = %d',
$objectId,
$this->storedGroups[$group]->id
);
$this->object->db->delete( $weight = 1;
$this->getGroupMemberTableName(), foreach ($this->imports as $import) {
$where
);
}
$toAdd = array_diff($groups, $storedGroups);
foreach ($toAdd as $group) {
$this->object->db->insert( $this->object->db->insert(
$this->getGroupMemberTableName(), $this->getImportTableName(),
array( array(
$objectCol => $objectId, $objectCol => $objectId,
$groupCol => $this->groups[$group]->id $importCol => $import->id,
'weight' => $weight++
) )
); );
} }
$this->storedGroups = $this->groups;
$this->storedImports = $this->imports;
return $this; return $this;
} }