1 files changed, 161 insertions, 0 deletions
diff --git a/application/controllers/MigrateController.php b/application/controllers/MigrateController.php
new file mode 100644
index 0000000..811b5d0
--- /dev/null
+++ b/application/controllers/MigrateController.php
@@ -0,0 +1,161 @@
+<?php
+
+/* Icinga DB Web | (c) 2020 Icinga GmbH | GPLv2 */
+
+namespace Icinga\Module\Icingadb\Controllers;
+
+use Exception;
+use GuzzleHttp\Psr7\ServerRequest;
+use Icinga\Application\Hook;
+use Icinga\Application\Icinga;
+use Icinga\Exception\IcingaException;
+use Icinga\Module\Icingadb\Compat\UrlMigrator;
+use Icinga\Module\Icingadb\Forms\SetAsBackendForm;
+use Icinga\Module\Icingadb\Hook\IcingadbSupportHook;
+use Icinga\Module\Icingadb\Web\Controller;
+use ipl\Html\HtmlString;
+use ipl\Stdlib\Filter;
+use ipl\Web\Filter\QueryString;
+use ipl\Web\Url;
+
+class MigrateController extends Controller
+{
+    public function monitoringUrlAction()
+    {
+        $this->assertHttpMethod('post');
+        if (! $this->getRequest()->isApiRequest()) {
+            $this->httpBadRequest('No API request');
+        }
+
+        if (
+            ! preg_match('/([^;]*);?/', $this->getRequest()->getHeader('Content-Type'), $matches)
+            || $matches[1] !== 'application/json'
+        ) {
+            $this->httpBadRequest('No JSON content');
+        }
+
+        $urls = $this->getRequest()->getPost();
+
+        $result = [];
+        $errors = [];
+        foreach ($urls as $urlString) {
+            $url = Url::fromPath($urlString);
+            if (UrlMigrator::isSupportedUrl($url)) {
+                try {
+                    $urlString = rawurldecode(UrlMigrator::transformUrl($url)->getAbsoluteUrl());
+                } catch (Exception $e) {
+                    $errors[$urlString] = [
+                        IcingaException::describe($e),
+                        IcingaException::getConfidentialTraceAsString($e)
+                    ];
+                    $urlString = false;
+                }
+            }
+
+            $result[] = $urlString;
+        }
+
+        $response = $this->getResponse()->json();
+        if (empty($errors)) {
+            $response->setSuccessData($result);
+        } else {
+            $response->setFailData([
+                'result' => $result,
+                'errors' => $errors
+            ]);
+        }
+
+        $response->sendResponse();
+    }
+
+    public function searchUrlAction()
+    {
+        $this->assertHttpMethod('post');
+        if (! $this->getRequest()->isApiRequest()) {
+            $this->httpBadRequest('No API request');
+        }
+
+        if (
+            ! preg_match('/([^;]*);?/', $this->getRequest()->getHeader('Content-Type'), $matches)
+            || $matches[1] !== 'application/json'
+        ) {
+            $this->httpBadRequest('No JSON content');
+        }
+
+        $urls = $this->getRequest()->getPost();
+
+        $result = [];
+        foreach ($urls as $urlString) {
+            $url = Url::fromPath($urlString);
+            $params = $url->onlyWith(['sort', 'limit', 'view', 'columns', 'page'])->getParams();
+            $filter = $url->without(['sort', 'limit', 'view', 'columns', 'page'])->getParams();
+            $filter = QueryString::parse((string) $filter);
+            $filter = UrlMigrator::transformLegacyWildcardFilter($filter);
+            $result[] = rawurldecode($url->setParams($params)->setFilter($filter)->getAbsoluteUrl());
+        }
+
+        $response = $this->getResponse()->json();
+        $response->setSuccessData($result);
+
+        $response->sendResponse();
+    }
+
+    public function checkboxStateAction()
+    {
+        $this->assertHttpMethod('get');
+
+        $form = new SetAsBackendForm();
+        $form->setAction(Url::fromPath('icingadb/migrate/checkbox-submit')->getAbsoluteUrl());
+
+        $this->getDocument()->addHtml($form);
+    }
+
+    public function checkboxSubmitAction()
+    {
+        $this->assertHttpMethod('post');
+        $this->addPart(HtmlString::create('"bogus"'), 'Behavior:Migrate');
+
+        (new SetAsBackendForm())->handleRequest(ServerRequest::fromGlobals());
+    }
+
+    public function backendSupportAction()
+    {
+        $this->assertHttpMethod('post');
+        if (! $this->getRequest()->isApiRequest()) {
+            $this->httpBadRequest('No API request');
+        }
+
+        if (
+            ! preg_match('/([^;]*);?/', $this->getRequest()->getHeader('Content-Type'), $matches)
+            || $matches[1] !== 'application/json'
+        ) {
+            $this->httpBadRequest('No JSON content');
+        }
+
+        $moduleSupportStates = [];
+        if (
+            Icinga::app()->getModuleManager()->hasEnabled('monitoring')
+            && $this->Auth()->hasPermission('module/monitoring')
+        ) {
+            $supportList = [];
+            foreach (Hook::all('Icingadb/IcingadbSupport') as $hook) {
+                /** @var IcingadbSupportHook $hook */
+                $supportList[$hook->getModule()->getName()] = $hook->supportsIcingaDb();
+            }
+
+            $moduleSupportStates = [];
+            foreach ($this->getRequest()->getPost() as $moduleName) {
+                if (isset($supportList[$moduleName])) {
+                    $moduleSupportStates[] = $supportList[$moduleName];
+                } else {
+                    $moduleSupportStates[] = false;
+                }
+            }
+        }
+
+        $this->getResponse()
+            ->json()
+            ->setSuccessData($moduleSupportStates)
+            ->sendResponse();
+    }
+}