summaryrefslogtreecommitdiffstats
path: root/library/Director/DirectorObject/Automation/ImportExport.php
diff options
context:
space:
mode:
Diffstat (limited to 'library/Director/DirectorObject/Automation/ImportExport.php')
-rw-r--r--library/Director/DirectorObject/Automation/ImportExport.php7
1 files changed, 5 insertions, 2 deletions
diff --git a/library/Director/DirectorObject/Automation/ImportExport.php b/library/Director/DirectorObject/Automation/ImportExport.php
index a5e72fa..1664f5d 100644
--- a/library/Director/DirectorObject/Automation/ImportExport.php
+++ b/library/Director/DirectorObject/Automation/ImportExport.php
@@ -3,6 +3,7 @@
namespace Icinga\Module\Director\DirectorObject\Automation;
use Icinga\Module\Director\Data\Exporter;
+use Icinga\Module\Director\Data\ObjectImporter;
use Icinga\Module\Director\Db;
use Icinga\Module\Director\Objects\DirectorDatafield;
use Icinga\Module\Director\Objects\DirectorDatalist;
@@ -125,8 +126,9 @@ class ImportExport
{
$count = 0;
$this->connection->runFailSafeTransaction(function () use ($objects, &$count) {
+ $importer = new ObjectImporter($this->connection);
foreach ($objects as $object) {
- ImportSource::import($object, $this->connection)->store();
+ $importer->import(ImportSource::class, $object)->store();
$count++;
}
});
@@ -138,8 +140,9 @@ class ImportExport
{
$count = 0;
$this->connection->runFailSafeTransaction(function () use ($objects, &$count) {
+ $importer = new ObjectImporter($this->connection);
foreach ($objects as $object) {
- SyncRule::import($object, $this->connection)->store();
+ $importer->import(SyncRule::class, $object)->store();
}
$count++;
});