1 files changed, 92 insertions, 0 deletions
diff --git a/application/clicommands/LegacyCommand.php b/application/clicommands/LegacyCommand.php
new file mode 100644
index 0000000..f9784be
--- /dev/null
+++ b/application/clicommands/LegacyCommand.php
@@ -0,0 +1,92 @@
+<?php
+/* TopLevelView module for Icingaweb2 - Copyright (c) 2021 Icinga Development Team <info@icinga.com> */
+
+namespace Icinga\Module\Toplevelview\Clicommands;
+
+use Icinga\Exception\ConfigurationError;
+use Icinga\Module\Monitoring\Backend\MonitoringBackend;
+use Icinga\Module\Toplevelview\Command;
+use Icinga\Module\Toplevelview\Legacy\LegacyDbHelper;
+use Zend_Db_Adapter_Pdo_Sqlite;
+
+/**
+ * Tools for the legacy DB
+ */
+class LegacyCommand extends Command
+{
+    public function init()
+    {
+        parent::init();
+
+        if (! extension_loaded('pdo_sqlite')) {
+            throw new ConfigurationError('You need the PHP extension "pdo_sqlite" in order to convert TopLevelView');
+        }
+    }
+
+    /**
+     * Delete unreferenced objects from the database
+     *
+     * Arguments:
+     *   --db <file>  SQLite3 data from from old TopLevelView module
+     *   --noop       Only show counts, don't delete
+     */
+    public function cleanupAction()
+    {
+        $dbFile = $this->params->getRequired('db');
+        $noop = $this->params->shift('noop');
+        $db = $this->sqlite($dbFile);
+
+        $helper = new LegacyDbHelper($db);
+
+        $result = $helper->cleanupUnreferencedObjects($noop);
+        foreach ($result as $type => $c) {
+            printf("%s: %d\n", $type, $c);
+        }
+    }
+
+    /**
+     * Migrate database ids from an IDO to another IDO
+     *
+     * Arguments:
+     *   --db <file>      SQLite3 data from from old TopLevelView module
+     *   --target <file>  Target database path (will be overwritten)
+     *   --old <backend>  OLD IDO backend (configured in monitoring module)
+     *   --new <backend>  New IDO backend (configured in monitoring module) (optional)
+     *   --purge          Remove unresolvable data during update (see log)
+     */
+    public function idomigrateAction()
+    {
+        $dbFile = $this->params->getRequired('db');
+        $old = $this->params->getRequired('old');
+        $target = $this->params->getRequired('target');
+        $new = $this->params->get('new');
+        $purge = $this->params->shift('purge');
+
+        $db = $this->sqlite($dbFile);
+
+        $helper = new LegacyDbHelper($db, MonitoringBackend::instance($new));
+        $helper->setOldBackend(MonitoringBackend::instance($old));
+
+        // Use the copy as db
+        $helper->setDb($helper->copySqliteDb($db, $target));
+
+        $result = $helper->migrateObjectIds(false, $purge);
+        foreach ($result as $type => $c) {
+            printf("%s: %d\n", $type, $c);
+        }
+    }
+
+    /**
+     * Sets up the Zend PDO resource for SQLite
+     *
+     * @param string $file
+     *
+     * @return Zend_Db_Adapter_Pdo_Sqlite
+     */
+    protected function sqlite($file)
+    {
+        return new Zend_Db_Adapter_Pdo_Sqlite(array(
+            'dbname' => $file,
+        ));
+    }
+}