1 files changed, 154 insertions, 0 deletions
diff --git a/application/forms/Jobs/JobConfigForm.php b/application/forms/Jobs/JobConfigForm.php
new file mode 100644
index 0000000..539bc58
--- /dev/null
+++ b/application/forms/Jobs/JobConfigForm.php
@@ -0,0 +1,154 @@
+<?php
+
+// Icinga Web 2 X.509 Module | (c) 2018 Icinga GmbH | GPLv2
+
+namespace Icinga\Module\X509\Forms\Jobs;
+
+use DateTime;
+use Exception;
+use Icinga\Authentication\Auth;
+use Icinga\Module\X509\Common\Database;
+use Icinga\Module\X509\Model\X509Job;
+use Icinga\User;
+use Icinga\Web\Notification;
+use ipl\Html\Contract\FormSubmitElement;
+use ipl\Html\HtmlDocument;
+use ipl\Stdlib\Str;
+use ipl\Validator\CallbackValidator;
+use ipl\Validator\CidrValidator;
+use ipl\Web\Compat\CompatForm;
+
+/**
+ * Create, update and delete jobs
+ */
+class JobConfigForm extends CompatForm
+{
+    /** @var ?X509Job */
+    protected $job;
+
+    public function __construct(X509Job $job = null)
+    {
+        $this->job = $job;
+    }
+
+    protected function isUpdating(): bool
+    {
+        return $this->job !== null;
+    }
+
+    public function hasBeenSubmitted(): bool
+    {
+        if (! $this->hasBeenSent()) {
+            return false;
+        }
+
+        $button = $this->getPressedSubmitElement();
+
+        return $button && ($button->getName() === 'btn_submit' || $button->getName() === 'btn_remove');
+    }
+
+    protected function assemble(): void
+    {
+        $this->addElement('text', 'name', [
+            'required'    => true,
+            'label'       => $this->translate('Name'),
+            'description' => $this->translate('Job name'),
+        ]);
+
+        $this->addElement('textarea', 'cidrs', [
+            'required'    => true,
+            'label'       => $this->translate('CIDRs'),
+            'description' => $this->translate('Comma-separated list of CIDR addresses to scan'),
+            'validators'  => [
+                new CallbackValidator(function ($value, CallbackValidator $validator): bool {
+                    $cidrValidator = new CidrValidator();
+                    $cidrs = Str::trimSplit($value);
+
+                    foreach ($cidrs as $cidr) {
+                        if (! $cidrValidator->isValid($cidr)) {
+                            $validator->addMessage(...$cidrValidator->getMessages());
+
+                            return false;
+                        }
+                    }
+
+                    return true;
+                })
+            ]
+        ]);
+
+        $this->addElement('textarea', 'ports', [
+            'required'    => true,
+            'label'       => $this->translate('Ports'),
+            'description' => $this->translate('Comma-separated list of ports to scan'),
+        ]);
+
+        $this->addElement('textarea', 'exclude_targets', [
+            'required'    => false,
+            'label'       => $this->translate('Exclude Targets'),
+            'description' => $this->translate('Comma-separated list of addresses/hostnames to exclude'),
+        ]);
+
+        $this->addElement('submit', 'btn_submit', [
+            'label' => $this->isUpdating() ? $this->translate('Update') : $this->translate('Create')
+        ]);
+
+        if ($this->isUpdating()) {
+            $removeButton = $this->createElement('submit', 'btn_remove', [
+                'class' => 'btn-remove',
+                'label' => $this->translate('Remove Job'),
+            ]);
+            $this->registerElement($removeButton);
+
+            /** @var HtmlDocument $wrapper */
+            $wrapper = $this->getElement('btn_submit')->getWrapper();
+            $wrapper->prepend($removeButton);
+        }
+    }
+
+    protected function onSuccess(): void
+    {
+        $conn = Database::get();
+        /** @var FormSubmitElement $submitElement */
+        $submitElement = $this->getPressedSubmitElement();
+        if ($submitElement->getName() === 'btn_remove') {
+            try {
+                /** @var X509Job $job */
+                $job = $this->job;
+                $conn->delete('x509_job', ['id = ?' => $job->id]);
+
+                Notification::success($this->translate('Removed job successfully'));
+            } catch (Exception $err) {
+                Notification::error($this->translate('Failed to remove job') . ': ' . $err->getMessage());
+            }
+        } else {
+            $values = $this->getValues();
+
+            try {
+                /** @var User $user */
+                $user = Auth::getInstance()->getUser();
+                if ($this->job === null) {
+                    $values['author'] = $user->getUsername();
+                    $values['ctime'] = (new DateTime())->getTimestamp() * 1000.0;
+                    $values['mtime'] = (new DateTime())->getTimestamp() * 1000.0;
+
+                    $conn->insert('x509_job', $values);
+                    $message = $this->translate('Created job successfully');
+                } else {
+                    $values['mtime'] = (new DateTime())->getTimestamp() * 1000.0;
+
+                    $conn->update('x509_job', $values, ['id = ?' => $this->job->id]);
+                    $message = $this->translate('Updated job successfully');
+                }
+
+                Notification::success($message);
+            } catch (Exception $err) {
+                $message = $this->isUpdating()
+                    ? $this->translate('Failed to update job')
+                    : $this->translate('Failed to create job');
+
+                Notification::error($message . ': ' . $err->getMessage());
+            }
+        }
+    }
+}