nextcloud / server

apps/workflowengine/lib/AppInfo/Application.php

Indentation +97 added lines, -97 removed lines

@@ -34,101 +34,101 @@
 
 class Application extends \OCP\AppFramework\App {
 
-	const APP_ID = 'workflowengine';
-
-	/** @var EventDispatcherInterface */
-	protected $dispatcher;
-	/** @var Manager */
-	protected $manager;
-
-	public function __construct() {
-		parent::__construct(self::APP_ID);
-
-		$this->getContainer()->registerAlias('RequestTimeController', RequestTime::class);
-
-		$this->dispatcher = $this->getContainer()->getServer()->getEventDispatcher();
-		$this->manager = $this->getContainer()->query(Manager::class);
-	}
-
-	/**
-	 * Register all hooks and listeners
-	 */
-	public function registerHooksAndListeners() {
-		$this->dispatcher->addListener(
-			'OCP\WorkflowEngine::loadAdditionalSettingScripts',
-			function () {
-				if (!function_exists('style')) {
-					// This is hacky, but we need to load the template class
-					class_exists(Template::class, true);
-				}
-
-				style(self::APP_ID, [
-					'admin',
-				]);
-
-				script('core', [
-					'files/fileinfo',
-					'files/client',
-					'systemtags/systemtags',
-					'systemtags/systemtagmodel',
-					'systemtags/systemtagscollection',
-				]);
-
-				script(self::APP_ID, [
-					'workflowengine',
-				]);
-			},
-			-100
-		);
-	}
-
-	public function registerRuleListeners() {
-		$configuredEvents = $this->manager->getAllConfiguredEvents();
-
-		foreach ($configuredEvents as $operationClass => $events) {
-			foreach ($events as $entityClass => $eventNames) {
-				array_map(function (string $eventName) use ($operationClass, $entityClass) {
-					$this->dispatcher->addListener(
-						$eventName,
-						function ($event) use ($eventName, $operationClass, $entityClass) {
-							$ruleMatcher = $this->manager->getRuleMatcher();
-							try {
-								/** @var IEntity $entity */
-								$entity = $this->getContainer()->query($entityClass);
-								/** @var IOperation $operation */
-								$operation = $this->getContainer()->query($operationClass);
-
-								$ruleMatcher->setEntity($entity);
-								$ruleMatcher->setOperation($operation);
-
-								if ($event instanceof Event) {
-									$entity->prepareRuleMatcher($ruleMatcher, $eventName, $event);
-									$operation->onEvent($eventName, $event, $ruleMatcher);
-								} else if ($entity instanceof IEntityCompat && $operation instanceof IOperationCompat) {
-									// TODO: Remove this block (and the compat classes) in the first major release in 2023
-									$entity->prepareRuleMatcherCompat($ruleMatcher, $eventName, $event);
-									$operation->onEventCompat($eventName, $event, $ruleMatcher);
-								} else {
-									$logger = $this->getContainer()->getServer()->getLogger();
-									$logger->debug(
-										'Cannot handle event {name} of {event} against entity {entity} and operation {operation}',
-										[
-											'app' => self::APP_ID,
-											'name' => $eventName,
-											'event' => get_class($event),
-											'entity' => $entityClass,
-											'operation' => $operationClass,
-										]
-									);
-								}
-
-							} catch (QueryException $e) {
-								// Ignore query exceptions since they might occur when an entity/operation were setup before by an app that is disabled now
-							}
-						}
-					);
-				}, $eventNames ?? []);
-			}
-		}
-	}
+    const APP_ID = 'workflowengine';
+
+    /** @var EventDispatcherInterface */
+    protected $dispatcher;
+    /** @var Manager */
+    protected $manager;
+
+    public function __construct() {
+        parent::__construct(self::APP_ID);
+
+        $this->getContainer()->registerAlias('RequestTimeController', RequestTime::class);
+
+        $this->dispatcher = $this->getContainer()->getServer()->getEventDispatcher();
+        $this->manager = $this->getContainer()->query(Manager::class);
+    }
+
+    /**
+     * Register all hooks and listeners
+     */
+    public function registerHooksAndListeners() {
+        $this->dispatcher->addListener(
+            'OCP\WorkflowEngine::loadAdditionalSettingScripts',
+            function () {
+                if (!function_exists('style')) {
+                    // This is hacky, but we need to load the template class
+                    class_exists(Template::class, true);
+                }
+
+                style(self::APP_ID, [
+                    'admin',
+                ]);
+
+                script('core', [
+                    'files/fileinfo',
+                    'files/client',
+                    'systemtags/systemtags',
+                    'systemtags/systemtagmodel',
+                    'systemtags/systemtagscollection',
+                ]);
+
+                script(self::APP_ID, [
+                    'workflowengine',
+                ]);
+            },
+            -100
+        );
+    }
+
+    public function registerRuleListeners() {
+        $configuredEvents = $this->manager->getAllConfiguredEvents();
+
+        foreach ($configuredEvents as $operationClass => $events) {
+            foreach ($events as $entityClass => $eventNames) {
+                array_map(function (string $eventName) use ($operationClass, $entityClass) {
+                    $this->dispatcher->addListener(
+                        $eventName,
+                        function ($event) use ($eventName, $operationClass, $entityClass) {
+                            $ruleMatcher = $this->manager->getRuleMatcher();
+                            try {
+                                /** @var IEntity $entity */
+                                $entity = $this->getContainer()->query($entityClass);
+                                /** @var IOperation $operation */
+                                $operation = $this->getContainer()->query($operationClass);
+
+                                $ruleMatcher->setEntity($entity);
+                                $ruleMatcher->setOperation($operation);
+
+                                if ($event instanceof Event) {
+                                    $entity->prepareRuleMatcher($ruleMatcher, $eventName, $event);
+                                    $operation->onEvent($eventName, $event, $ruleMatcher);
+                                } else if ($entity instanceof IEntityCompat && $operation instanceof IOperationCompat) {
+                                    // TODO: Remove this block (and the compat classes) in the first major release in 2023
+                                    $entity->prepareRuleMatcherCompat($ruleMatcher, $eventName, $event);
+                                    $operation->onEventCompat($eventName, $event, $ruleMatcher);
+                                } else {
+                                    $logger = $this->getContainer()->getServer()->getLogger();
+                                    $logger->debug(
+                                        'Cannot handle event {name} of {event} against entity {entity} and operation {operation}',
+                                        [
+                                            'app' => self::APP_ID,
+                                            'name' => $eventName,
+                                            'event' => get_class($event),
+                                            'entity' => $entityClass,
+                                            'operation' => $operationClass,
+                                        ]
+                                    );
+                                }
+
+                            } catch (QueryException $e) {
+                                // Ignore query exceptions since they might occur when an entity/operation were setup before by an app that is disabled now
+                            }
+                        }
+                    );
+                }, $eventNames ?? []);
+            }
+        }
+    }
 }

apps/workflowengine/lib/Service/RuleMatcher.php

Indentation +139 added lines, -139 removed lines

@@ -42,143 +42,143 @@
 
 class RuleMatcher implements IRuleMatcher {
 
-	/** @var IUserSession */
-	protected $session;
-	/** @var IManager */
-	protected $manager;
-	/** @var array */
-	protected $contexts;
-	/** @var IServerContainer */
-	protected $container;
-	/** @var array */
-	protected $fileInfo = [];
-	/** @var IL10N */
-	protected $l;
-	/** @var IOperation */
-	protected $operation;
-	/** @var IEntity */
-	protected $entity;
-
-	public function __construct(
-		IUserSession $session,
-		IServerContainer $container,
-		IL10N $l,
-		Manager $manager
-	) {
-		$this->session = $session;
-		$this->manager = $manager;
-		$this->container = $container;
-		$this->l = $l;
-	}
-
-	public function setFileInfo(IStorage $storage, string $path, bool $isDir = false): void {
-		$this->fileInfo['storage'] = $storage;
-		$this->fileInfo['path'] = $path;
-		$this->fileInfo['isDir'] = $isDir;
-	}
-
-	public function setEntitySubject(IEntity $entity, $subject): void {
-		$this->contexts[get_class($entity)] = [$entity, $subject];
-	}
-
-	public function setOperation(IOperation $operation): void {
-		if($this->operation !== null) {
-			throw new RuntimeException('This method must not be called more than once');
-		}
-		$this->operation = $operation;
-	}
-
-	public function setEntity(IEntity $entity): void {
-		if($this->entity !== null) {
-			throw new RuntimeException('This method must not be called more than once');
-		}
-		$this->entity = $entity;
-	}
-
-	public function getEntity(): IEntity {
-		if($this->entity === null) {
-			throw new \LogicException('Entity was not set yet');
-		}
-		return $this->entity;
-	}
-
-	public function getFlows(bool $returnFirstMatchingOperationOnly = true): array {
-		if(!$this->operation) {
-			throw new RuntimeException('Operation is not set');
-		}
-		return $this->getMatchingOperations(get_class($this->operation), $returnFirstMatchingOperationOnly);
-	}
-
-	public function getMatchingOperations(string $class, bool $returnFirstMatchingOperationOnly = true): array {
-		$scopes[] = new ScopeContext(IManager::SCOPE_ADMIN);
-		$user = $this->session->getUser();
-		if($user !== null) {
-			$scopes[] = new ScopeContext(IManager::SCOPE_USER, $user->getUID());
-		}
-
-		$operations = [];
-		foreach ($scopes as $scope) {
-			$operations = array_merge($operations, $this->manager->getOperations($class, $scope));
-		}
-
-		$additionalScopes = $this->manager->getAllConfiguredScopesForOperation($class);
-		foreach ($additionalScopes as $hash => $scopeCandidate) {
-			/** @var ScopeContext $scopeCandidate */
-			if ($scopeCandidate->getScope() !== IManager::SCOPE_USER || in_array($scopeCandidate, $scopes)) {
-				continue;
-			}
-			if ($this->entity->isLegitimatedForUserId($scopeCandidate->getScopeId())) {
-				$operations = array_merge($operations, $this->manager->getOperations($class, $scopeCandidate));
-			}
-		}
-
-		$matches = [];
-		foreach ($operations as $operation) {
-			$checkIds = json_decode($operation['checks'], true);
-			$checks = $this->manager->getChecks($checkIds);
-
-			foreach ($checks as $check) {
-				if (!$this->check($check)) {
-					// Check did not match, continue with the next operation
-					continue 2;
-				}
-			}
-
-			if ($returnFirstMatchingOperationOnly) {
-				return $operation;
-			}
-			$matches[] = $operation;
-		}
-
-		return $matches;
-	}
-
-	/**
-	 * @param array $check
-	 * @return bool
-	 */
-	public function check(array $check) {
-		try {
-			$checkInstance = $this->container->query($check['class']);
-		} catch (QueryException $e) {
-			// Check does not exist, assume it matches.
-			return true;
-		}
-
-		if ($checkInstance instanceof IFileCheck) {
-			if (empty($this->fileInfo)) {
-				throw new RuntimeException('Must set file info before running the check');
-			}
-			$checkInstance->setFileInfo($this->fileInfo['storage'], $this->fileInfo['path'], $this->fileInfo['isDir']);
-		} elseif ($checkInstance instanceof IEntityCheck) {
-			foreach($this->contexts as $entityInfo) {
-				list($entity, $subject) = $entityInfo;
-				$checkInstance->setEntitySubject($entity, $subject);
-			}
-		} else if(!$checkInstance instanceof ICheck) {
-			// Check is invalid
-			throw new \UnexpectedValueException($this->l->t('Check %s is invalid or does not exist', $check['class']));
-		}
-		return $checkInstance->executeCheck($check['operator'], $check['value']);
-	}
+    /** @var IUserSession */
+    protected $session;
+    /** @var IManager */
+    protected $manager;
+    /** @var array */
+    protected $contexts;
+    /** @var IServerContainer */
+    protected $container;
+    /** @var array */
+    protected $fileInfo = [];
+    /** @var IL10N */
+    protected $l;
+    /** @var IOperation */
+    protected $operation;
+    /** @var IEntity */
+    protected $entity;
+
+    public function __construct(
+        IUserSession $session,
+        IServerContainer $container,
+        IL10N $l,
+        Manager $manager
+    ) {
+        $this->session = $session;
+        $this->manager = $manager;
+        $this->container = $container;
+        $this->l = $l;
+    }
+
+    public function setFileInfo(IStorage $storage, string $path, bool $isDir = false): void {
+        $this->fileInfo['storage'] = $storage;
+        $this->fileInfo['path'] = $path;
+        $this->fileInfo['isDir'] = $isDir;
+    }
+
+    public function setEntitySubject(IEntity $entity, $subject): void {
+        $this->contexts[get_class($entity)] = [$entity, $subject];
+    }
+
+    public function setOperation(IOperation $operation): void {
+        if($this->operation !== null) {
+            throw new RuntimeException('This method must not be called more than once');
+        }
+        $this->operation = $operation;
+    }
+
+    public function setEntity(IEntity $entity): void {
+        if($this->entity !== null) {
+            throw new RuntimeException('This method must not be called more than once');
+        }
+        $this->entity = $entity;
+    }
+
+    public function getEntity(): IEntity {
+        if($this->entity === null) {
+            throw new \LogicException('Entity was not set yet');
+        }
+        return $this->entity;
+    }
+
+    public function getFlows(bool $returnFirstMatchingOperationOnly = true): array {
+        if(!$this->operation) {
+            throw new RuntimeException('Operation is not set');
+        }
+        return $this->getMatchingOperations(get_class($this->operation), $returnFirstMatchingOperationOnly);
+    }
+
+    public function getMatchingOperations(string $class, bool $returnFirstMatchingOperationOnly = true): array {
+        $scopes[] = new ScopeContext(IManager::SCOPE_ADMIN);
+        $user = $this->session->getUser();
+        if($user !== null) {
+            $scopes[] = new ScopeContext(IManager::SCOPE_USER, $user->getUID());
+        }
+
+        $operations = [];
+        foreach ($scopes as $scope) {
+            $operations = array_merge($operations, $this->manager->getOperations($class, $scope));
+        }
+
+        $additionalScopes = $this->manager->getAllConfiguredScopesForOperation($class);
+        foreach ($additionalScopes as $hash => $scopeCandidate) {
+            /** @var ScopeContext $scopeCandidate */
+            if ($scopeCandidate->getScope() !== IManager::SCOPE_USER || in_array($scopeCandidate, $scopes)) {
+                continue;
+            }
+            if ($this->entity->isLegitimatedForUserId($scopeCandidate->getScopeId())) {
+                $operations = array_merge($operations, $this->manager->getOperations($class, $scopeCandidate));
+            }
+        }
+
+        $matches = [];
+        foreach ($operations as $operation) {
+            $checkIds = json_decode($operation['checks'], true);
+            $checks = $this->manager->getChecks($checkIds);
+
+            foreach ($checks as $check) {
+                if (!$this->check($check)) {
+                    // Check did not match, continue with the next operation
+                    continue 2;
+                }
+            }
+
+            if ($returnFirstMatchingOperationOnly) {
+                return $operation;
+            }
+            $matches[] = $operation;
+        }
+
+        return $matches;
+    }
+
+    /**
+     * @param array $check
+     * @return bool
+     */
+    public function check(array $check) {
+        try {
+            $checkInstance = $this->container->query($check['class']);
+        } catch (QueryException $e) {
+            // Check does not exist, assume it matches.
+            return true;
+        }
+
+        if ($checkInstance instanceof IFileCheck) {
+            if (empty($this->fileInfo)) {
+                throw new RuntimeException('Must set file info before running the check');
+            }
+            $checkInstance->setFileInfo($this->fileInfo['storage'], $this->fileInfo['path'], $this->fileInfo['isDir']);
+        } elseif ($checkInstance instanceof IEntityCheck) {
+            foreach($this->contexts as $entityInfo) {
+                list($entity, $subject) = $entityInfo;
+                $checkInstance->setEntitySubject($entity, $subject);
+            }
+        } else if(!$checkInstance instanceof ICheck) {
+            // Check is invalid
+            throw new \UnexpectedValueException($this->l->t('Check %s is invalid or does not exist', $check['class']));
+        }
+        return $checkInstance->executeCheck($check['operator'], $check['value']);
+    }
 }