add operator interfaces / API

Signed-off-by: Arthur Schiwon <blizzz@arthur-schiwon.de>

4 files changed, 198 insertions, 5 deletions

diff --git a/apps/workflowengine/lib/Manager.php b/apps/workflowengine/lib/Manager.php
index ecf3f24bda1..d19aa31547a 100644
--- a/apps/workflowengine/lib/Manager.php
+++ b/apps/workflowengine/lib/Manager.php
@@ -40,6 +40,7 @@ use OCP\WorkflowEngine\IEntity;
 use OCP\WorkflowEngine\IEntityAware;
 use OCP\WorkflowEngine\IManager;
 use OCP\WorkflowEngine\IOperation;
+use OCP\WorkflowEngine\IOperator;
 use Symfony\Component\EventDispatcher\EventDispatcherInterface;
 use Symfony\Component\EventDispatcher\GenericEvent;
 
@@ -75,6 +76,9 @@ class Manager implements IManager, IEntityAware {
 	/** @var IEntity[] */
 	protected $registeredEntities = [];
 
+	/** @var IOperator[] */
+	protected $registeredOperators = [];
+
 	/** @var ILogger */
 	protected $logger;
 
@@ -545,13 +549,22 @@ class Manager implements IManager, IEntityAware {
 	/**
 	 * @return IEntity[]
 	 */
-	public function getEntitiesList() {
+	public function getEntitiesList(): array {
 		$this->eventDispatcher->dispatch('OCP\WorkflowEngine::registerEntities', new GenericEvent($this));
 
 		return array_merge($this->getBuildInEntities(), $this->registeredEntities);
 	}
 
 	/**
+	 * @return IOperator[]
+	 */
+	public function getOperatorList(): array {
+		$this->eventDispatcher->dispatch('OCP\WorkflowEngine::registerOperators', new GenericEvent($this));
+
+		return array_merge($this->getBuildInOperators(), $this->registeredOperators);
+	}
+
+	/**
 	 * Listen to 'OCP/WorkflowEngine::registerEntities' at the EventDispatcher
 	 * for registering your entities
 	 *
@@ -561,6 +574,10 @@ class Manager implements IManager, IEntityAware {
 		$this->registeredEntities[$entity->getId()] = $entity;
 	}
 
+	public function registerOperator(IOperator $operator): void {
+		$this->registeredOperators[$operator->getId()] = $operator;
+	}
+
 	/**
 	 * @return IEntity[]
 	 */
@@ -574,4 +591,18 @@ class Manager implements IManager, IEntityAware {
 			return [];
 		}
 	}
+
+	/**
+	 * @return IOperator[]
+	 */
+	protected function getBuildInOperators(): array {
+		try {
+			return [
+				// None yet
+			];
+		} catch (QueryException $e) {
+			$this->logger->logException($e);
+			return [];
+		}
+	}
 }
diff --git a/apps/workflowengine/lib/Settings/ASettings.php b/apps/workflowengine/lib/Settings/ASettings.php
new file mode 100644
index 00000000000..78a23d924c7
--- /dev/null
+++ b/apps/workflowengine/lib/Settings/ASettings.php
@@ -0,0 +1,158 @@
+<?php
+declare(strict_types=1);
+/**
+ * @copyright Copyright (c) 2019 Arthur Schiwon <blizzz@arthur-schiwon.de>
+ *
+ * @author Arthur Schiwon <blizzz@arthur-schiwon.de>
+ *
+ * @license GNU AGPL version 3 or any later version
+ *
+ * This program is free software: you can redistribute it and/or modify
+ * it under the terms of the GNU Affero General Public License as
+ * published by the Free Software Foundation, either version 3 of the
+ * License, or (at your option) any later version.
+ *
+ * This program is distributed in the hope that it will be useful,
+ * but WITHOUT ANY WARRANTY; without even the implied warranty of
+ * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
+ * GNU Affero General Public License for more details.
+ *
+ * You should have received a copy of the GNU Affero General Public License
+ * along with this program.  If not, see <http://www.gnu.org/licenses/>.
+ *
+ */
+
+namespace OCA\WorkflowEngine\Settings;
+
+use OCA\WorkflowEngine\AppInfo\Application;
+use OCA\WorkflowEngine\Manager;
+use OCP\AppFramework\Http\TemplateResponse;
+use OCP\IInitialStateService;
+use OCP\IL10N;
+use OCP\Settings\ISettings;
+use OCP\WorkflowEngine\IComplexOperator;
+use OCP\WorkflowEngine\IEntity;
+use OCP\WorkflowEngine\IEntityEvent;
+use OCP\WorkflowEngine\IOperator;
+use OCP\WorkflowEngine\ISpecificOperator;
+use Symfony\Component\EventDispatcher\EventDispatcherInterface;
+
+abstract class ASettings implements ISettings {
+	/** @var IL10N */
+	private $l10n;
+
+	/** @var string */
+	private $appName;
+
+	/** @var EventDispatcherInterface */
+	private $eventDispatcher;
+
+	/** @var Manager */
+	private $manager;
+
+	/** @var IInitialStateService */
+	private $initialStateService;
+
+	/**
+	 * @param string $appName
+	 * @param IL10N $l
+	 * @param EventDispatcherInterface $eventDispatcher
+	 */
+	public function __construct(
+		$appName,
+		IL10N $l,
+		EventDispatcherInterface $eventDispatcher,
+		Manager $manager,
+		IInitialStateService $initialStateService
+	) {
+		$this->appName = $appName;
+		$this->l10n = $l;
+		$this->eventDispatcher = $eventDispatcher;
+		$this->manager = $manager;
+		$this->initialStateService = $initialStateService;
+	}
+
+	abstract function getScope(): int;
+
+	/**
+	 * @return TemplateResponse
+	 */
+	public function getForm() {
+		$this->eventDispatcher->dispatch('OCP\WorkflowEngine::loadAdditionalSettingScripts');
+
+		$entities = $this->manager->getEntitiesList();
+		$this->initialStateService->provideInitialState(
+			Application::APP_ID,
+			'entities',
+			$this->entitiesToArray($entities)
+		);
+
+		$operators = $this->manager->getOperatorList();
+		$this->initialStateService->provideInitialState(
+			Application::APP_ID,
+			'operators',
+			$this->operatorsToArray($operators)
+		);
+
+		$this->initialStateService->provideInitialState(
+			Application::APP_ID,
+			'scope',
+			$this->getScope()
+		);
+
+		return new TemplateResponse(Application::APP_ID, 'settings', [], 'blank');
+	}
+
+	/**
+	 * @return string the section ID, e.g. 'sharing'
+	 */
+	public function getSection() {
+		return 'workflow';
+	}
+
+	/**
+	 * @return int whether the form should be rather on the top or bottom of
+	 * the admin section. The forms are arranged in ascending order of the
+	 * priority values. It is required to return a value between 0 and 100.
+	 *
+	 * E.g.: 70
+	 */
+	public function getPriority() {
+		return 0;
+	}
+
+	private function entitiesToArray(array $entities) {
+		return array_map(function (IEntity $entity) {
+			$events = array_map(function(IEntityEvent $entityEvent) {
+				return [
+					'eventName' => $entityEvent->getEventName(),
+					'displayName' => $entityEvent->getDisplayName()
+				];
+			}, $entity->getEvents());
+
+			return [
+				'id' => $entity->getId(),
+				'icon' => $entity->getIcon(),
+				'name' => $entity->getName(),
+				'events' => $events,
+			];
+		}, $entities);
+	}
+
+	private function operatorsToArray(array $operators) {
+		$operators = array_filter($operators, function(IOperator $operator) {
+			return $operator->isAvailableForScope($this->getScope());
+		});
+
+		return array_map(function (IOperator $operator) {
+			return [
+				'id' => $operator->getId(),
+				'icon' => $operator->getIcon(),
+				'name' => $operator->getDisplayName(),
+				'description' => $operator->getDescription(),
+				'fixedEntity' => $operator instanceof ISpecificOperator ? $operator->getEntityId() : '',
+				'isComplex' => $operator instanceof IComplexOperator,
+			];
+		}, $operators);
+	}
+}
diff --git a/apps/workflowengine/lib/Settings/Admin.php b/apps/workflowengine/lib/Settings/Admin.php
index 39932d5f1f2..20ea8ad43c4 100644
--- a/apps/workflowengine/lib/Settings/Admin.php
+++ b/apps/workflowengine/lib/Settings/Admin.php
@@ -24,10 +24,12 @@ declare(strict_types=1);
 
 namespace OCA\WorkflowEngine\Settings;
 
+use OCP\WorkflowEngine\IManager;
+
 class Admin extends ASettings {
 
-	function isAdmin(): bool {
-		return true;
+	function getScope(): int {
+		return IManager::SCOPE_ADMIN;
 	}
 }
 
diff --git a/apps/workflowengine/lib/Settings/Personal.php b/apps/workflowengine/lib/Settings/Personal.php
index d6ed220577f..9c23a250355 100644
--- a/apps/workflowengine/lib/Settings/Personal.php
+++ b/apps/workflowengine/lib/Settings/Personal.php
@@ -24,9 +24,11 @@ declare(strict_types=1);
 
 namespace OCA\WorkflowEngine\Settings;
 
+use OCP\WorkflowEngine\IManager;
+
 class Personal extends ASettings {
 
-	function isAdmin(): bool {
-		return false;
+	function getScope(): int {
+		return IManager::SCOPE_USER;
 	}
 }