* * @author Arthur Schiwon * * @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 . * */ namespace OCA\WorkflowEngine\Service; use OCA\WorkflowEngine\AppInfo\Application; use OCA\WorkflowEngine\Entity\File; use OCA\WorkflowEngine\Helper\ScopeContext; use OCA\WorkflowEngine\Manager; use OCP\AppFramework\QueryException; use OCP\Files\Node; use OCP\Files\Storage\IStorage; use OCP\IL10N; use OCP\IServerContainer; use OCP\IUserSession; use OCP\WorkflowEngine\ICheck; use OCP\WorkflowEngine\IEntity; use OCP\WorkflowEngine\IFileCheck; use OCP\WorkflowEngine\IManager; use OCP\WorkflowEngine\IRuleMatcher; 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; 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): void { $this->fileInfo['storage'] = $storage; $this->fileInfo['path'] = $path; } public function setEntitySubject(IEntity $entity, $subject): void { $this->contexts[get_class($entity)] = [$entity, $subject]; } 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)); } $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 ICheck) { foreach($this->contexts as $entityInfo) { list($entity, $subject) = $entityInfo; $checkInstance->setEntitySubject($entity, $subject); } return $checkInstance->executeCheck($check['operator'], $check['value']); } elseif ($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']); return $checkInstance->executeCheck($check['operator'], $check['value']); } else { // Check is invalid throw new \UnexpectedValueException($this->l->t('Check %s is invalid or does not exist', $check['class'])); } } }