@@ -33,17 +33,17 @@ |
||
| 33 | 33 | */ |
| 34 | 34 | class Capabilities implements ICapability { |
| 35 | 35 | |
| 36 | - /** |
|
| 37 | - * Return this classes capabilities |
|
| 38 | - * |
|
| 39 | - * @return array |
|
| 40 | - */ |
|
| 41 | - public function getCapabilities() { |
|
| 42 | - return [ |
|
| 43 | - 'files' => [ |
|
| 44 | - 'undelete' => true |
|
| 45 | - ] |
|
| 46 | - ]; |
|
| 47 | - } |
|
| 36 | + /** |
|
| 37 | + * Return this classes capabilities |
|
| 38 | + * |
|
| 39 | + * @return array |
|
| 40 | + */ |
|
| 41 | + public function getCapabilities() { |
|
| 42 | + return [ |
|
| 43 | + 'files' => [ |
|
| 44 | + 'undelete' => true |
|
| 45 | + ] |
|
| 46 | + ]; |
|
| 47 | + } |
|
| 48 | 48 | |
| 49 | 49 | } |
@@ -34,76 +34,76 @@ |
||
| 34 | 34 | |
| 35 | 35 | class ExpireTrash extends \OC\BackgroundJob\TimedJob { |
| 36 | 36 | |
| 37 | - /** |
|
| 38 | - * @var Expiration |
|
| 39 | - */ |
|
| 40 | - private $expiration; |
|
| 37 | + /** |
|
| 38 | + * @var Expiration |
|
| 39 | + */ |
|
| 40 | + private $expiration; |
|
| 41 | 41 | |
| 42 | - /** |
|
| 43 | - * @var IUserManager |
|
| 44 | - */ |
|
| 45 | - private $userManager; |
|
| 42 | + /** |
|
| 43 | + * @var IUserManager |
|
| 44 | + */ |
|
| 45 | + private $userManager; |
|
| 46 | 46 | |
| 47 | - /** |
|
| 48 | - * @param IUserManager|null $userManager |
|
| 49 | - * @param Expiration|null $expiration |
|
| 50 | - */ |
|
| 51 | - public function __construct(IUserManager $userManager = null, |
|
| 52 | - Expiration $expiration = null) { |
|
| 53 | - // Run once per 30 minutes |
|
| 54 | - $this->setInterval(60 * 30); |
|
| 47 | + /** |
|
| 48 | + * @param IUserManager|null $userManager |
|
| 49 | + * @param Expiration|null $expiration |
|
| 50 | + */ |
|
| 51 | + public function __construct(IUserManager $userManager = null, |
|
| 52 | + Expiration $expiration = null) { |
|
| 53 | + // Run once per 30 minutes |
|
| 54 | + $this->setInterval(60 * 30); |
|
| 55 | 55 | |
| 56 | - if (is_null($expiration) || is_null($userManager)) { |
|
| 57 | - $this->fixDIForJobs(); |
|
| 58 | - } else { |
|
| 59 | - $this->userManager = $userManager; |
|
| 60 | - $this->expiration = $expiration; |
|
| 61 | - } |
|
| 62 | - } |
|
| 56 | + if (is_null($expiration) || is_null($userManager)) { |
|
| 57 | + $this->fixDIForJobs(); |
|
| 58 | + } else { |
|
| 59 | + $this->userManager = $userManager; |
|
| 60 | + $this->expiration = $expiration; |
|
| 61 | + } |
|
| 62 | + } |
|
| 63 | 63 | |
| 64 | - protected function fixDIForJobs() { |
|
| 65 | - $application = new Application(); |
|
| 66 | - $this->userManager = \OC::$server->getUserManager(); |
|
| 67 | - $this->expiration = $application->getContainer()->query('Expiration'); |
|
| 68 | - } |
|
| 64 | + protected function fixDIForJobs() { |
|
| 65 | + $application = new Application(); |
|
| 66 | + $this->userManager = \OC::$server->getUserManager(); |
|
| 67 | + $this->expiration = $application->getContainer()->query('Expiration'); |
|
| 68 | + } |
|
| 69 | 69 | |
| 70 | - /** |
|
| 71 | - * @param $argument |
|
| 72 | - * @throws \Exception |
|
| 73 | - */ |
|
| 74 | - protected function run($argument) { |
|
| 75 | - $maxAge = $this->expiration->getMaxAgeAsTimestamp(); |
|
| 76 | - if (!$maxAge) { |
|
| 77 | - return; |
|
| 78 | - } |
|
| 70 | + /** |
|
| 71 | + * @param $argument |
|
| 72 | + * @throws \Exception |
|
| 73 | + */ |
|
| 74 | + protected function run($argument) { |
|
| 75 | + $maxAge = $this->expiration->getMaxAgeAsTimestamp(); |
|
| 76 | + if (!$maxAge) { |
|
| 77 | + return; |
|
| 78 | + } |
|
| 79 | 79 | |
| 80 | - $this->userManager->callForSeenUsers(function(IUser $user) { |
|
| 81 | - $uid = $user->getUID(); |
|
| 82 | - if (!$this->setupFS($uid)) { |
|
| 83 | - return; |
|
| 84 | - } |
|
| 85 | - $dirContent = Helper::getTrashFiles('/', $uid, 'mtime'); |
|
| 86 | - Trashbin::deleteExpiredFiles($dirContent, $uid); |
|
| 87 | - }); |
|
| 80 | + $this->userManager->callForSeenUsers(function(IUser $user) { |
|
| 81 | + $uid = $user->getUID(); |
|
| 82 | + if (!$this->setupFS($uid)) { |
|
| 83 | + return; |
|
| 84 | + } |
|
| 85 | + $dirContent = Helper::getTrashFiles('/', $uid, 'mtime'); |
|
| 86 | + Trashbin::deleteExpiredFiles($dirContent, $uid); |
|
| 87 | + }); |
|
| 88 | 88 | |
| 89 | - \OC_Util::tearDownFS(); |
|
| 90 | - } |
|
| 89 | + \OC_Util::tearDownFS(); |
|
| 90 | + } |
|
| 91 | 91 | |
| 92 | - /** |
|
| 93 | - * Act on behalf on trash item owner |
|
| 94 | - * @param string $user |
|
| 95 | - * @return boolean |
|
| 96 | - */ |
|
| 97 | - protected function setupFS($user) { |
|
| 98 | - \OC_Util::tearDownFS(); |
|
| 99 | - \OC_Util::setupFS($user); |
|
| 92 | + /** |
|
| 93 | + * Act on behalf on trash item owner |
|
| 94 | + * @param string $user |
|
| 95 | + * @return boolean |
|
| 96 | + */ |
|
| 97 | + protected function setupFS($user) { |
|
| 98 | + \OC_Util::tearDownFS(); |
|
| 99 | + \OC_Util::setupFS($user); |
|
| 100 | 100 | |
| 101 | - // Check if this user has a trashbin directory |
|
| 102 | - $view = new \OC\Files\View('/' . $user); |
|
| 103 | - if (!$view->is_dir('/files_trashbin/files')) { |
|
| 104 | - return false; |
|
| 105 | - } |
|
| 101 | + // Check if this user has a trashbin directory |
|
| 102 | + $view = new \OC\Files\View('/' . $user); |
|
| 103 | + if (!$view->is_dir('/files_trashbin/files')) { |
|
| 104 | + return false; |
|
| 105 | + } |
|
| 106 | 106 | |
| 107 | - return true; |
|
| 108 | - } |
|
| 107 | + return true; |
|
| 108 | + } |
|
| 109 | 109 | } |
@@ -117,7 +117,7 @@ |
||
| 117 | 117 | \OC_Util::setupFS($user); |
| 118 | 118 | |
| 119 | 119 | // Check if this user has a trashbin directory |
| 120 | - $view = new \OC\Files\View('/' . $user); |
|
| 120 | + $view = new \OC\Files\View('/'.$user); |
|
| 121 | 121 | if (!$view->is_dir('/files_trashbin/files')) { |
| 122 | 122 | return false; |
| 123 | 123 | } |
@@ -28,45 +28,45 @@ |
||
| 28 | 28 | use OCP\Settings\IIconSection; |
| 29 | 29 | |
| 30 | 30 | class Section implements IIconSection { |
| 31 | - /** @var IL10N */ |
|
| 32 | - private $l; |
|
| 33 | - /** @var IURLGenerator */ |
|
| 34 | - private $url; |
|
| 31 | + /** @var IL10N */ |
|
| 32 | + private $l; |
|
| 33 | + /** @var IURLGenerator */ |
|
| 34 | + private $url; |
|
| 35 | 35 | |
| 36 | - /** |
|
| 37 | - * @param IURLGenerator $url |
|
| 38 | - * @param IL10N $l |
|
| 39 | - */ |
|
| 40 | - public function __construct(IURLGenerator $url, IL10N $l) { |
|
| 41 | - $this->url = $url; |
|
| 42 | - $this->l = $l; |
|
| 43 | - } |
|
| 36 | + /** |
|
| 37 | + * @param IURLGenerator $url |
|
| 38 | + * @param IL10N $l |
|
| 39 | + */ |
|
| 40 | + public function __construct(IURLGenerator $url, IL10N $l) { |
|
| 41 | + $this->url = $url; |
|
| 42 | + $this->l = $l; |
|
| 43 | + } |
|
| 44 | 44 | |
| 45 | - /** |
|
| 46 | - * {@inheritdoc} |
|
| 47 | - */ |
|
| 48 | - public function getID() { |
|
| 49 | - return 'workflow'; |
|
| 50 | - } |
|
| 45 | + /** |
|
| 46 | + * {@inheritdoc} |
|
| 47 | + */ |
|
| 48 | + public function getID() { |
|
| 49 | + return 'workflow'; |
|
| 50 | + } |
|
| 51 | 51 | |
| 52 | - /** |
|
| 53 | - * {@inheritdoc} |
|
| 54 | - */ |
|
| 55 | - public function getName() { |
|
| 56 | - return $this->l->t('Workflow'); |
|
| 57 | - } |
|
| 52 | + /** |
|
| 53 | + * {@inheritdoc} |
|
| 54 | + */ |
|
| 55 | + public function getName() { |
|
| 56 | + return $this->l->t('Workflow'); |
|
| 57 | + } |
|
| 58 | 58 | |
| 59 | - /** |
|
| 60 | - * {@inheritdoc} |
|
| 61 | - */ |
|
| 62 | - public function getPriority() { |
|
| 63 | - return 55; |
|
| 64 | - } |
|
| 59 | + /** |
|
| 60 | + * {@inheritdoc} |
|
| 61 | + */ |
|
| 62 | + public function getPriority() { |
|
| 63 | + return 55; |
|
| 64 | + } |
|
| 65 | 65 | |
| 66 | - /** |
|
| 67 | - * {@inheritdoc} |
|
| 68 | - */ |
|
| 69 | - public function getIcon() { |
|
| 70 | - return $this->url->imagePath('core', 'actions/tag.svg'); |
|
| 71 | - } |
|
| 66 | + /** |
|
| 67 | + * {@inheritdoc} |
|
| 68 | + */ |
|
| 69 | + public function getIcon() { |
|
| 70 | + return $this->url->imagePath('core', 'actions/tag.svg'); |
|
| 71 | + } |
|
| 72 | 72 | } |
@@ -28,94 +28,94 @@ |
||
| 28 | 28 | |
| 29 | 29 | abstract class AbstractStringCheck implements ICheck { |
| 30 | 30 | |
| 31 | - /** @var array[] Nested array: [Pattern => [ActualValue => Regex Result]] */ |
|
| 32 | - protected $matches; |
|
| 31 | + /** @var array[] Nested array: [Pattern => [ActualValue => Regex Result]] */ |
|
| 32 | + protected $matches; |
|
| 33 | 33 | |
| 34 | - /** @var IL10N */ |
|
| 35 | - protected $l; |
|
| 34 | + /** @var IL10N */ |
|
| 35 | + protected $l; |
|
| 36 | 36 | |
| 37 | - /** |
|
| 38 | - * @param IL10N $l |
|
| 39 | - */ |
|
| 40 | - public function __construct(IL10N $l) { |
|
| 41 | - $this->l = $l; |
|
| 42 | - } |
|
| 37 | + /** |
|
| 38 | + * @param IL10N $l |
|
| 39 | + */ |
|
| 40 | + public function __construct(IL10N $l) { |
|
| 41 | + $this->l = $l; |
|
| 42 | + } |
|
| 43 | 43 | |
| 44 | - /** |
|
| 45 | - * @param IStorage $storage |
|
| 46 | - * @param string $path |
|
| 47 | - */ |
|
| 48 | - public function setFileInfo(IStorage $storage, $path) { |
|
| 49 | - // Nothing changes here with a different path |
|
| 50 | - } |
|
| 44 | + /** |
|
| 45 | + * @param IStorage $storage |
|
| 46 | + * @param string $path |
|
| 47 | + */ |
|
| 48 | + public function setFileInfo(IStorage $storage, $path) { |
|
| 49 | + // Nothing changes here with a different path |
|
| 50 | + } |
|
| 51 | 51 | |
| 52 | - /** |
|
| 53 | - * @return string |
|
| 54 | - */ |
|
| 55 | - abstract protected function getActualValue(); |
|
| 52 | + /** |
|
| 53 | + * @return string |
|
| 54 | + */ |
|
| 55 | + abstract protected function getActualValue(); |
|
| 56 | 56 | |
| 57 | - /** |
|
| 58 | - * @param string $operator |
|
| 59 | - * @param string $value |
|
| 60 | - * @return bool |
|
| 61 | - */ |
|
| 62 | - public function executeCheck($operator, $value) { |
|
| 63 | - $actualValue = $this->getActualValue(); |
|
| 64 | - return $this->executeStringCheck($operator, $value, $actualValue); |
|
| 65 | - } |
|
| 57 | + /** |
|
| 58 | + * @param string $operator |
|
| 59 | + * @param string $value |
|
| 60 | + * @return bool |
|
| 61 | + */ |
|
| 62 | + public function executeCheck($operator, $value) { |
|
| 63 | + $actualValue = $this->getActualValue(); |
|
| 64 | + return $this->executeStringCheck($operator, $value, $actualValue); |
|
| 65 | + } |
|
| 66 | 66 | |
| 67 | - /** |
|
| 68 | - * @param string $operator |
|
| 69 | - * @param string $checkValue |
|
| 70 | - * @param string $actualValue |
|
| 71 | - * @return bool |
|
| 72 | - */ |
|
| 73 | - protected function executeStringCheck($operator, $checkValue, $actualValue) { |
|
| 74 | - if ($operator === 'is') { |
|
| 75 | - return $checkValue === $actualValue; |
|
| 76 | - } else if ($operator === '!is') { |
|
| 77 | - return $checkValue !== $actualValue; |
|
| 78 | - } else { |
|
| 79 | - $match = $this->match($checkValue, $actualValue); |
|
| 80 | - if ($operator === 'matches') { |
|
| 81 | - return $match === 1; |
|
| 82 | - } else { |
|
| 83 | - return $match === 0; |
|
| 84 | - } |
|
| 85 | - } |
|
| 86 | - } |
|
| 67 | + /** |
|
| 68 | + * @param string $operator |
|
| 69 | + * @param string $checkValue |
|
| 70 | + * @param string $actualValue |
|
| 71 | + * @return bool |
|
| 72 | + */ |
|
| 73 | + protected function executeStringCheck($operator, $checkValue, $actualValue) { |
|
| 74 | + if ($operator === 'is') { |
|
| 75 | + return $checkValue === $actualValue; |
|
| 76 | + } else if ($operator === '!is') { |
|
| 77 | + return $checkValue !== $actualValue; |
|
| 78 | + } else { |
|
| 79 | + $match = $this->match($checkValue, $actualValue); |
|
| 80 | + if ($operator === 'matches') { |
|
| 81 | + return $match === 1; |
|
| 82 | + } else { |
|
| 83 | + return $match === 0; |
|
| 84 | + } |
|
| 85 | + } |
|
| 86 | + } |
|
| 87 | 87 | |
| 88 | - /** |
|
| 89 | - * @param string $operator |
|
| 90 | - * @param string $value |
|
| 91 | - * @throws \UnexpectedValueException |
|
| 92 | - */ |
|
| 93 | - public function validateCheck($operator, $value) { |
|
| 94 | - if (!in_array($operator, ['is', '!is', 'matches', '!matches'])) { |
|
| 95 | - throw new \UnexpectedValueException($this->l->t('The given operator is invalid'), 1); |
|
| 96 | - } |
|
| 88 | + /** |
|
| 89 | + * @param string $operator |
|
| 90 | + * @param string $value |
|
| 91 | + * @throws \UnexpectedValueException |
|
| 92 | + */ |
|
| 93 | + public function validateCheck($operator, $value) { |
|
| 94 | + if (!in_array($operator, ['is', '!is', 'matches', '!matches'])) { |
|
| 95 | + throw new \UnexpectedValueException($this->l->t('The given operator is invalid'), 1); |
|
| 96 | + } |
|
| 97 | 97 | |
| 98 | - if (in_array($operator, ['matches', '!matches']) && |
|
| 99 | - @preg_match($value, null) === false) { |
|
| 100 | - throw new \UnexpectedValueException($this->l->t('The given regular expression is invalid'), 2); |
|
| 101 | - } |
|
| 102 | - } |
|
| 98 | + if (in_array($operator, ['matches', '!matches']) && |
|
| 99 | + @preg_match($value, null) === false) { |
|
| 100 | + throw new \UnexpectedValueException($this->l->t('The given regular expression is invalid'), 2); |
|
| 101 | + } |
|
| 102 | + } |
|
| 103 | 103 | |
| 104 | - /** |
|
| 105 | - * @param string $pattern |
|
| 106 | - * @param string $subject |
|
| 107 | - * @return int|bool |
|
| 108 | - */ |
|
| 109 | - protected function match($pattern, $subject) { |
|
| 110 | - $patternHash = md5($pattern); |
|
| 111 | - $subjectHash = md5($subject); |
|
| 112 | - if (isset($this->matches[$patternHash][$subjectHash])) { |
|
| 113 | - return $this->matches[$patternHash][$subjectHash]; |
|
| 114 | - } |
|
| 115 | - if (!isset($this->matches[$patternHash])) { |
|
| 116 | - $this->matches[$patternHash] = []; |
|
| 117 | - } |
|
| 118 | - $this->matches[$patternHash][$subjectHash] = preg_match($pattern, $subject); |
|
| 119 | - return $this->matches[$patternHash][$subjectHash]; |
|
| 120 | - } |
|
| 104 | + /** |
|
| 105 | + * @param string $pattern |
|
| 106 | + * @param string $subject |
|
| 107 | + * @return int|bool |
|
| 108 | + */ |
|
| 109 | + protected function match($pattern, $subject) { |
|
| 110 | + $patternHash = md5($pattern); |
|
| 111 | + $subjectHash = md5($subject); |
|
| 112 | + if (isset($this->matches[$patternHash][$subjectHash])) { |
|
| 113 | + return $this->matches[$patternHash][$subjectHash]; |
|
| 114 | + } |
|
| 115 | + if (!isset($this->matches[$patternHash])) { |
|
| 116 | + $this->matches[$patternHash] = []; |
|
| 117 | + } |
|
| 118 | + $this->matches[$patternHash][$subjectHash] = preg_match($pattern, $subject); |
|
| 119 | + return $this->matches[$patternHash][$subjectHash]; |
|
| 120 | + } |
|
| 121 | 121 | } |
@@ -59,7 +59,7 @@ |
||
| 59 | 59 | * @param string $value |
| 60 | 60 | * @return bool |
| 61 | 61 | */ |
| 62 | - public function executeCheck($operator, $value) { |
|
| 62 | + public function executeCheck($operator, $value) { |
|
| 63 | 63 | $actualValue = $this->getActualValue(); |
| 64 | 64 | return $this->executeStringCheck($operator, $value, $actualValue); |
| 65 | 65 | } |
@@ -29,101 +29,101 @@ |
||
| 29 | 29 | |
| 30 | 30 | class RequestTime implements ICheck { |
| 31 | 31 | |
| 32 | - const REGEX_TIME = '([0-1][0-9]|2[0-3]):([0-5][0-9])'; |
|
| 33 | - const REGEX_TIMEZONE = '([a-zA-Z]+(?:\\/[a-zA-Z\-\_]+)+)'; |
|
| 34 | - |
|
| 35 | - /** @var bool[] */ |
|
| 36 | - protected $cachedResults; |
|
| 37 | - |
|
| 38 | - /** @var IL10N */ |
|
| 39 | - protected $l; |
|
| 40 | - |
|
| 41 | - /** @var ITimeFactory */ |
|
| 42 | - protected $timeFactory; |
|
| 43 | - |
|
| 44 | - /** |
|
| 45 | - * @param ITimeFactory $timeFactory |
|
| 46 | - */ |
|
| 47 | - public function __construct(IL10N $l, ITimeFactory $timeFactory) { |
|
| 48 | - $this->l = $l; |
|
| 49 | - $this->timeFactory = $timeFactory; |
|
| 50 | - } |
|
| 51 | - |
|
| 52 | - /** |
|
| 53 | - * @param IStorage $storage |
|
| 54 | - * @param string $path |
|
| 55 | - */ |
|
| 56 | - public function setFileInfo(IStorage $storage, $path) { |
|
| 57 | - // A different path doesn't change time, so nothing to do here. |
|
| 58 | - } |
|
| 59 | - |
|
| 60 | - /** |
|
| 61 | - * @param string $operator |
|
| 62 | - * @param string $value |
|
| 63 | - * @return bool |
|
| 64 | - */ |
|
| 65 | - public function executeCheck($operator, $value) { |
|
| 66 | - $valueHash = md5($value); |
|
| 67 | - |
|
| 68 | - if (isset($this->cachedResults[$valueHash])) { |
|
| 69 | - return $this->cachedResults[$valueHash]; |
|
| 70 | - } |
|
| 71 | - |
|
| 72 | - $timestamp = $this->timeFactory->getTime(); |
|
| 73 | - |
|
| 74 | - $values = json_decode($value, true); |
|
| 75 | - $timestamp1 = $this->getTimestamp($timestamp, $values[0]); |
|
| 76 | - $timestamp2 = $this->getTimestamp($timestamp, $values[1]); |
|
| 77 | - |
|
| 78 | - if ($timestamp1 < $timestamp2) { |
|
| 79 | - $in = $timestamp1 <= $timestamp && $timestamp <= $timestamp2; |
|
| 80 | - } else { |
|
| 81 | - $in = $timestamp1 <= $timestamp || $timestamp <= $timestamp2; |
|
| 82 | - } |
|
| 83 | - |
|
| 84 | - return ($operator === 'in') ? $in : !$in; |
|
| 85 | - } |
|
| 86 | - |
|
| 87 | - /** |
|
| 88 | - * @param int $currentTimestamp |
|
| 89 | - * @param string $value Format: "H:i e" |
|
| 90 | - * @return int |
|
| 91 | - */ |
|
| 92 | - protected function getTimestamp($currentTimestamp, $value) { |
|
| 93 | - list($time1, $timezone1) = explode(' ', $value); |
|
| 94 | - list($hour1, $minute1) = explode(':', $time1); |
|
| 95 | - $date1 = new \DateTime('now', new \DateTimeZone($timezone1)); |
|
| 96 | - $date1->setTimestamp($currentTimestamp); |
|
| 97 | - $date1->setTime($hour1, $minute1); |
|
| 98 | - |
|
| 99 | - return $date1->getTimestamp(); |
|
| 100 | - } |
|
| 101 | - |
|
| 102 | - /** |
|
| 103 | - * @param string $operator |
|
| 104 | - * @param string $value |
|
| 105 | - * @throws \UnexpectedValueException |
|
| 106 | - */ |
|
| 107 | - public function validateCheck($operator, $value) { |
|
| 108 | - if (!in_array($operator, ['in', '!in'])) { |
|
| 109 | - throw new \UnexpectedValueException($this->l->t('The given operator is invalid'), 1); |
|
| 110 | - } |
|
| 111 | - |
|
| 112 | - $regexValue = '\"' . self::REGEX_TIME . ' ' . self::REGEX_TIMEZONE . '\"'; |
|
| 113 | - $result = preg_match('/^\[' . $regexValue . ',' . $regexValue . '\]$/', $value, $matches); |
|
| 114 | - if (!$result) { |
|
| 115 | - throw new \UnexpectedValueException($this->l->t('The given time span is invalid'), 2); |
|
| 116 | - } |
|
| 117 | - |
|
| 118 | - $values = json_decode($value, true); |
|
| 119 | - $time1 = \DateTime::createFromFormat('H:i e', $values[0]); |
|
| 120 | - if ($time1 === false) { |
|
| 121 | - throw new \UnexpectedValueException($this->l->t('The given start time is invalid'), 3); |
|
| 122 | - } |
|
| 123 | - |
|
| 124 | - $time2 = \DateTime::createFromFormat('H:i e', $values[1]); |
|
| 125 | - if ($time2 === false) { |
|
| 126 | - throw new \UnexpectedValueException($this->l->t('The given end time is invalid'), 4); |
|
| 127 | - } |
|
| 128 | - } |
|
| 32 | + const REGEX_TIME = '([0-1][0-9]|2[0-3]):([0-5][0-9])'; |
|
| 33 | + const REGEX_TIMEZONE = '([a-zA-Z]+(?:\\/[a-zA-Z\-\_]+)+)'; |
|
| 34 | + |
|
| 35 | + /** @var bool[] */ |
|
| 36 | + protected $cachedResults; |
|
| 37 | + |
|
| 38 | + /** @var IL10N */ |
|
| 39 | + protected $l; |
|
| 40 | + |
|
| 41 | + /** @var ITimeFactory */ |
|
| 42 | + protected $timeFactory; |
|
| 43 | + |
|
| 44 | + /** |
|
| 45 | + * @param ITimeFactory $timeFactory |
|
| 46 | + */ |
|
| 47 | + public function __construct(IL10N $l, ITimeFactory $timeFactory) { |
|
| 48 | + $this->l = $l; |
|
| 49 | + $this->timeFactory = $timeFactory; |
|
| 50 | + } |
|
| 51 | + |
|
| 52 | + /** |
|
| 53 | + * @param IStorage $storage |
|
| 54 | + * @param string $path |
|
| 55 | + */ |
|
| 56 | + public function setFileInfo(IStorage $storage, $path) { |
|
| 57 | + // A different path doesn't change time, so nothing to do here. |
|
| 58 | + } |
|
| 59 | + |
|
| 60 | + /** |
|
| 61 | + * @param string $operator |
|
| 62 | + * @param string $value |
|
| 63 | + * @return bool |
|
| 64 | + */ |
|
| 65 | + public function executeCheck($operator, $value) { |
|
| 66 | + $valueHash = md5($value); |
|
| 67 | + |
|
| 68 | + if (isset($this->cachedResults[$valueHash])) { |
|
| 69 | + return $this->cachedResults[$valueHash]; |
|
| 70 | + } |
|
| 71 | + |
|
| 72 | + $timestamp = $this->timeFactory->getTime(); |
|
| 73 | + |
|
| 74 | + $values = json_decode($value, true); |
|
| 75 | + $timestamp1 = $this->getTimestamp($timestamp, $values[0]); |
|
| 76 | + $timestamp2 = $this->getTimestamp($timestamp, $values[1]); |
|
| 77 | + |
|
| 78 | + if ($timestamp1 < $timestamp2) { |
|
| 79 | + $in = $timestamp1 <= $timestamp && $timestamp <= $timestamp2; |
|
| 80 | + } else { |
|
| 81 | + $in = $timestamp1 <= $timestamp || $timestamp <= $timestamp2; |
|
| 82 | + } |
|
| 83 | + |
|
| 84 | + return ($operator === 'in') ? $in : !$in; |
|
| 85 | + } |
|
| 86 | + |
|
| 87 | + /** |
|
| 88 | + * @param int $currentTimestamp |
|
| 89 | + * @param string $value Format: "H:i e" |
|
| 90 | + * @return int |
|
| 91 | + */ |
|
| 92 | + protected function getTimestamp($currentTimestamp, $value) { |
|
| 93 | + list($time1, $timezone1) = explode(' ', $value); |
|
| 94 | + list($hour1, $minute1) = explode(':', $time1); |
|
| 95 | + $date1 = new \DateTime('now', new \DateTimeZone($timezone1)); |
|
| 96 | + $date1->setTimestamp($currentTimestamp); |
|
| 97 | + $date1->setTime($hour1, $minute1); |
|
| 98 | + |
|
| 99 | + return $date1->getTimestamp(); |
|
| 100 | + } |
|
| 101 | + |
|
| 102 | + /** |
|
| 103 | + * @param string $operator |
|
| 104 | + * @param string $value |
|
| 105 | + * @throws \UnexpectedValueException |
|
| 106 | + */ |
|
| 107 | + public function validateCheck($operator, $value) { |
|
| 108 | + if (!in_array($operator, ['in', '!in'])) { |
|
| 109 | + throw new \UnexpectedValueException($this->l->t('The given operator is invalid'), 1); |
|
| 110 | + } |
|
| 111 | + |
|
| 112 | + $regexValue = '\"' . self::REGEX_TIME . ' ' . self::REGEX_TIMEZONE . '\"'; |
|
| 113 | + $result = preg_match('/^\[' . $regexValue . ',' . $regexValue . '\]$/', $value, $matches); |
|
| 114 | + if (!$result) { |
|
| 115 | + throw new \UnexpectedValueException($this->l->t('The given time span is invalid'), 2); |
|
| 116 | + } |
|
| 117 | + |
|
| 118 | + $values = json_decode($value, true); |
|
| 119 | + $time1 = \DateTime::createFromFormat('H:i e', $values[0]); |
|
| 120 | + if ($time1 === false) { |
|
| 121 | + throw new \UnexpectedValueException($this->l->t('The given start time is invalid'), 3); |
|
| 122 | + } |
|
| 123 | + |
|
| 124 | + $time2 = \DateTime::createFromFormat('H:i e', $values[1]); |
|
| 125 | + if ($time2 === false) { |
|
| 126 | + throw new \UnexpectedValueException($this->l->t('The given end time is invalid'), 4); |
|
| 127 | + } |
|
| 128 | + } |
|
| 129 | 129 | } |
@@ -109,8 +109,8 @@ |
||
| 109 | 109 | throw new \UnexpectedValueException($this->l->t('The given operator is invalid'), 1); |
| 110 | 110 | } |
| 111 | 111 | |
| 112 | - $regexValue = '\"' . self::REGEX_TIME . ' ' . self::REGEX_TIMEZONE . '\"'; |
|
| 113 | - $result = preg_match('/^\[' . $regexValue . ',' . $regexValue . '\]$/', $value, $matches); |
|
| 112 | + $regexValue = '\"'.self::REGEX_TIME.' '.self::REGEX_TIMEZONE.'\"'; |
|
| 113 | + $result = preg_match('/^\['.$regexValue.','.$regexValue.'\]$/', $value, $matches); |
|
| 114 | 114 | if (!$result) { |
| 115 | 115 | throw new \UnexpectedValueException($this->l->t('The given time span is invalid'), 2); |
| 116 | 116 | } |
@@ -31,84 +31,84 @@ |
||
| 31 | 31 | |
| 32 | 32 | class UserGroupMembership implements ICheck { |
| 33 | 33 | |
| 34 | - /** @var string */ |
|
| 35 | - protected $cachedUser; |
|
| 36 | - |
|
| 37 | - /** @var string[] */ |
|
| 38 | - protected $cachedGroupMemberships; |
|
| 39 | - |
|
| 40 | - /** @var IUserSession */ |
|
| 41 | - protected $userSession; |
|
| 42 | - |
|
| 43 | - /** @var IGroupManager */ |
|
| 44 | - protected $groupManager; |
|
| 45 | - |
|
| 46 | - /** @var IL10N */ |
|
| 47 | - protected $l; |
|
| 48 | - |
|
| 49 | - /** |
|
| 50 | - * @param IUserSession $userSession |
|
| 51 | - * @param IGroupManager $groupManager |
|
| 52 | - * @param IL10N $l |
|
| 53 | - */ |
|
| 54 | - public function __construct(IUserSession $userSession, IGroupManager $groupManager, IL10N $l) { |
|
| 55 | - $this->userSession = $userSession; |
|
| 56 | - $this->groupManager = $groupManager; |
|
| 57 | - $this->l = $l; |
|
| 58 | - } |
|
| 59 | - |
|
| 60 | - /** |
|
| 61 | - * @param IStorage $storage |
|
| 62 | - * @param string $path |
|
| 63 | - */ |
|
| 64 | - public function setFileInfo(IStorage $storage, $path) { |
|
| 65 | - // A different path doesn't change group memberships, so nothing to do here. |
|
| 66 | - } |
|
| 67 | - |
|
| 68 | - /** |
|
| 69 | - * @param string $operator |
|
| 70 | - * @param string $value |
|
| 71 | - * @return bool |
|
| 72 | - */ |
|
| 73 | - public function executeCheck($operator, $value) { |
|
| 74 | - $user = $this->userSession->getUser(); |
|
| 75 | - |
|
| 76 | - if ($user instanceof IUser) { |
|
| 77 | - $groupIds = $this->getUserGroups($user); |
|
| 78 | - return ($operator === 'is') === in_array($value, $groupIds); |
|
| 79 | - } else { |
|
| 80 | - return $operator !== 'is'; |
|
| 81 | - } |
|
| 82 | - } |
|
| 83 | - |
|
| 84 | - |
|
| 85 | - /** |
|
| 86 | - * @param string $operator |
|
| 87 | - * @param string $value |
|
| 88 | - * @throws \UnexpectedValueException |
|
| 89 | - */ |
|
| 90 | - public function validateCheck($operator, $value) { |
|
| 91 | - if (!in_array($operator, ['is', '!is'])) { |
|
| 92 | - throw new \UnexpectedValueException($this->l->t('The given operator is invalid'), 1); |
|
| 93 | - } |
|
| 94 | - |
|
| 95 | - if (!$this->groupManager->groupExists($value)) { |
|
| 96 | - throw new \UnexpectedValueException($this->l->t('The given group does not exist'), 2); |
|
| 97 | - } |
|
| 98 | - } |
|
| 99 | - |
|
| 100 | - /** |
|
| 101 | - * @param IUser $user |
|
| 102 | - * @return string[] |
|
| 103 | - */ |
|
| 104 | - protected function getUserGroups(IUser $user) { |
|
| 105 | - $uid = $user->getUID(); |
|
| 106 | - |
|
| 107 | - if ($this->cachedUser !== $uid) { |
|
| 108 | - $this->cachedUser = $uid; |
|
| 109 | - $this->cachedGroupMemberships = $this->groupManager->getUserGroupIds($user); |
|
| 110 | - } |
|
| 111 | - |
|
| 112 | - return $this->cachedGroupMemberships; |
|
| 113 | - } |
|
| 34 | + /** @var string */ |
|
| 35 | + protected $cachedUser; |
|
| 36 | + |
|
| 37 | + /** @var string[] */ |
|
| 38 | + protected $cachedGroupMemberships; |
|
| 39 | + |
|
| 40 | + /** @var IUserSession */ |
|
| 41 | + protected $userSession; |
|
| 42 | + |
|
| 43 | + /** @var IGroupManager */ |
|
| 44 | + protected $groupManager; |
|
| 45 | + |
|
| 46 | + /** @var IL10N */ |
|
| 47 | + protected $l; |
|
| 48 | + |
|
| 49 | + /** |
|
| 50 | + * @param IUserSession $userSession |
|
| 51 | + * @param IGroupManager $groupManager |
|
| 52 | + * @param IL10N $l |
|
| 53 | + */ |
|
| 54 | + public function __construct(IUserSession $userSession, IGroupManager $groupManager, IL10N $l) { |
|
| 55 | + $this->userSession = $userSession; |
|
| 56 | + $this->groupManager = $groupManager; |
|
| 57 | + $this->l = $l; |
|
| 58 | + } |
|
| 59 | + |
|
| 60 | + /** |
|
| 61 | + * @param IStorage $storage |
|
| 62 | + * @param string $path |
|
| 63 | + */ |
|
| 64 | + public function setFileInfo(IStorage $storage, $path) { |
|
| 65 | + // A different path doesn't change group memberships, so nothing to do here. |
|
| 66 | + } |
|
| 67 | + |
|
| 68 | + /** |
|
| 69 | + * @param string $operator |
|
| 70 | + * @param string $value |
|
| 71 | + * @return bool |
|
| 72 | + */ |
|
| 73 | + public function executeCheck($operator, $value) { |
|
| 74 | + $user = $this->userSession->getUser(); |
|
| 75 | + |
|
| 76 | + if ($user instanceof IUser) { |
|
| 77 | + $groupIds = $this->getUserGroups($user); |
|
| 78 | + return ($operator === 'is') === in_array($value, $groupIds); |
|
| 79 | + } else { |
|
| 80 | + return $operator !== 'is'; |
|
| 81 | + } |
|
| 82 | + } |
|
| 83 | + |
|
| 84 | + |
|
| 85 | + /** |
|
| 86 | + * @param string $operator |
|
| 87 | + * @param string $value |
|
| 88 | + * @throws \UnexpectedValueException |
|
| 89 | + */ |
|
| 90 | + public function validateCheck($operator, $value) { |
|
| 91 | + if (!in_array($operator, ['is', '!is'])) { |
|
| 92 | + throw new \UnexpectedValueException($this->l->t('The given operator is invalid'), 1); |
|
| 93 | + } |
|
| 94 | + |
|
| 95 | + if (!$this->groupManager->groupExists($value)) { |
|
| 96 | + throw new \UnexpectedValueException($this->l->t('The given group does not exist'), 2); |
|
| 97 | + } |
|
| 98 | + } |
|
| 99 | + |
|
| 100 | + /** |
|
| 101 | + * @param IUser $user |
|
| 102 | + * @return string[] |
|
| 103 | + */ |
|
| 104 | + protected function getUserGroups(IUser $user) { |
|
| 105 | + $uid = $user->getUID(); |
|
| 106 | + |
|
| 107 | + if ($this->cachedUser !== $uid) { |
|
| 108 | + $this->cachedUser = $uid; |
|
| 109 | + $this->cachedGroupMemberships = $this->groupManager->getUserGroupIds($user); |
|
| 110 | + } |
|
| 111 | + |
|
| 112 | + return $this->cachedGroupMemberships; |
|
| 113 | + } |
|
| 114 | 114 | } |
@@ -27,66 +27,66 @@ |
||
| 27 | 27 | |
| 28 | 28 | class RequestURL extends AbstractStringCheck { |
| 29 | 29 | |
| 30 | - /** @var string */ |
|
| 31 | - protected $url; |
|
| 30 | + /** @var string */ |
|
| 31 | + protected $url; |
|
| 32 | 32 | |
| 33 | - /** @var IRequest */ |
|
| 34 | - protected $request; |
|
| 33 | + /** @var IRequest */ |
|
| 34 | + protected $request; |
|
| 35 | 35 | |
| 36 | - /** |
|
| 37 | - * @param IL10N $l |
|
| 38 | - * @param IRequest $request |
|
| 39 | - */ |
|
| 40 | - public function __construct(IL10N $l, IRequest $request) { |
|
| 41 | - parent::__construct($l); |
|
| 42 | - $this->request = $request; |
|
| 43 | - } |
|
| 36 | + /** |
|
| 37 | + * @param IL10N $l |
|
| 38 | + * @param IRequest $request |
|
| 39 | + */ |
|
| 40 | + public function __construct(IL10N $l, IRequest $request) { |
|
| 41 | + parent::__construct($l); |
|
| 42 | + $this->request = $request; |
|
| 43 | + } |
|
| 44 | 44 | |
| 45 | - /** |
|
| 46 | - * @param string $operator |
|
| 47 | - * @param string $value |
|
| 48 | - * @return bool |
|
| 49 | - */ |
|
| 50 | - public function executeCheck($operator, $value) { |
|
| 51 | - $actualValue = $this->getActualValue(); |
|
| 52 | - if (in_array($operator, ['is', '!is'])) { |
|
| 53 | - switch ($value) { |
|
| 54 | - case 'webdav': |
|
| 55 | - if ($operator === 'is') { |
|
| 56 | - return $this->isWebDAVRequest(); |
|
| 57 | - } else { |
|
| 58 | - return !$this->isWebDAVRequest(); |
|
| 59 | - } |
|
| 60 | - } |
|
| 61 | - } |
|
| 62 | - return $this->executeStringCheck($operator, $value, $actualValue); |
|
| 63 | - } |
|
| 45 | + /** |
|
| 46 | + * @param string $operator |
|
| 47 | + * @param string $value |
|
| 48 | + * @return bool |
|
| 49 | + */ |
|
| 50 | + public function executeCheck($operator, $value) { |
|
| 51 | + $actualValue = $this->getActualValue(); |
|
| 52 | + if (in_array($operator, ['is', '!is'])) { |
|
| 53 | + switch ($value) { |
|
| 54 | + case 'webdav': |
|
| 55 | + if ($operator === 'is') { |
|
| 56 | + return $this->isWebDAVRequest(); |
|
| 57 | + } else { |
|
| 58 | + return !$this->isWebDAVRequest(); |
|
| 59 | + } |
|
| 60 | + } |
|
| 61 | + } |
|
| 62 | + return $this->executeStringCheck($operator, $value, $actualValue); |
|
| 63 | + } |
|
| 64 | 64 | |
| 65 | - /** |
|
| 66 | - * @return string |
|
| 67 | - */ |
|
| 68 | - protected function getActualValue() { |
|
| 69 | - if ($this->url !== null) { |
|
| 70 | - return $this->url; |
|
| 71 | - } |
|
| 65 | + /** |
|
| 66 | + * @return string |
|
| 67 | + */ |
|
| 68 | + protected function getActualValue() { |
|
| 69 | + if ($this->url !== null) { |
|
| 70 | + return $this->url; |
|
| 71 | + } |
|
| 72 | 72 | |
| 73 | - $this->url = $this->request->getServerProtocol() . '://';// E.g. http(s) + :// |
|
| 74 | - $this->url .= $this->request->getServerHost();// E.g. localhost |
|
| 75 | - $this->url .= $this->request->getScriptName();// E.g. /nextcloud/index.php |
|
| 76 | - $this->url .= $this->request->getPathInfo();// E.g. /apps/files_texteditor/ajax/loadfile |
|
| 73 | + $this->url = $this->request->getServerProtocol() . '://';// E.g. http(s) + :// |
|
| 74 | + $this->url .= $this->request->getServerHost();// E.g. localhost |
|
| 75 | + $this->url .= $this->request->getScriptName();// E.g. /nextcloud/index.php |
|
| 76 | + $this->url .= $this->request->getPathInfo();// E.g. /apps/files_texteditor/ajax/loadfile |
|
| 77 | 77 | |
| 78 | - return $this->url; // E.g. https://localhost/nextcloud/index.php/apps/files_texteditor/ajax/loadfile |
|
| 79 | - } |
|
| 78 | + return $this->url; // E.g. https://localhost/nextcloud/index.php/apps/files_texteditor/ajax/loadfile |
|
| 79 | + } |
|
| 80 | 80 | |
| 81 | - /** |
|
| 82 | - * @return bool |
|
| 83 | - */ |
|
| 84 | - protected function isWebDAVRequest() { |
|
| 85 | - return substr($this->request->getScriptName(), 0 - strlen('/remote.php')) === '/remote.php' && ( |
|
| 86 | - $this->request->getPathInfo() === '/webdav' || |
|
| 87 | - strpos($this->request->getPathInfo(), '/webdav/') === 0 || |
|
| 88 | - $this->request->getPathInfo() === '/dav/files' || |
|
| 89 | - strpos($this->request->getPathInfo(), '/dav/files/') === 0 |
|
| 90 | - ); |
|
| 91 | - } |
|
| 81 | + /** |
|
| 82 | + * @return bool |
|
| 83 | + */ |
|
| 84 | + protected function isWebDAVRequest() { |
|
| 85 | + return substr($this->request->getScriptName(), 0 - strlen('/remote.php')) === '/remote.php' && ( |
|
| 86 | + $this->request->getPathInfo() === '/webdav' || |
|
| 87 | + strpos($this->request->getPathInfo(), '/webdav/') === 0 || |
|
| 88 | + $this->request->getPathInfo() === '/dav/files' || |
|
| 89 | + strpos($this->request->getPathInfo(), '/dav/files/') === 0 |
|
| 90 | + ); |
|
| 91 | + } |
|
| 92 | 92 | } |
@@ -47,7 +47,7 @@ discard block |
||
| 47 | 47 | * @param string $value |
| 48 | 48 | * @return bool |
| 49 | 49 | */ |
| 50 | - public function executeCheck($operator, $value) { |
|
| 50 | + public function executeCheck($operator, $value) { |
|
| 51 | 51 | $actualValue = $this->getActualValue(); |
| 52 | 52 | if (in_array($operator, ['is', '!is'])) { |
| 53 | 53 | switch ($value) { |
@@ -70,10 +70,10 @@ discard block |
||
| 70 | 70 | return $this->url; |
| 71 | 71 | } |
| 72 | 72 | |
| 73 | - $this->url = $this->request->getServerProtocol() . '://';// E.g. http(s) + :// |
|
| 74 | - $this->url .= $this->request->getServerHost();// E.g. localhost |
|
| 75 | - $this->url .= $this->request->getScriptName();// E.g. /nextcloud/index.php |
|
| 76 | - $this->url .= $this->request->getPathInfo();// E.g. /apps/files_texteditor/ajax/loadfile |
|
| 73 | + $this->url = $this->request->getServerProtocol().'://'; // E.g. http(s) + :// |
|
| 74 | + $this->url .= $this->request->getServerHost(); // E.g. localhost |
|
| 75 | + $this->url .= $this->request->getScriptName(); // E.g. /nextcloud/index.php |
|
| 76 | + $this->url .= $this->request->getPathInfo(); // E.g. /apps/files_texteditor/ajax/loadfile |
|
| 77 | 77 | |
| 78 | 78 | return $this->url; // E.g. https://localhost/nextcloud/index.php/apps/files_texteditor/ajax/loadfile |
| 79 | 79 | } |
@@ -323,7 +323,7 @@ |
||
| 323 | 323 | * @return int Check unique ID |
| 324 | 324 | */ |
| 325 | 325 | protected function addCheck($class, $operator, $value) { |
| 326 | - $hash = md5($class . '::' . $operator . '::' . $value); |
|
| 326 | + $hash = md5($class.'::'.$operator.'::'.$value); |
|
| 327 | 327 | |
| 328 | 328 | $query = $this->connection->getQueryBuilder(); |
| 329 | 329 | $query->select('id') |
@@ -34,318 +34,318 @@ |
||
| 34 | 34 | |
| 35 | 35 | class Manager implements IManager { |
| 36 | 36 | |
| 37 | - /** @var IStorage */ |
|
| 38 | - protected $storage; |
|
| 39 | - |
|
| 40 | - /** @var string */ |
|
| 41 | - protected $path; |
|
| 42 | - |
|
| 43 | - /** @var array[] */ |
|
| 44 | - protected $operations = []; |
|
| 45 | - |
|
| 46 | - /** @var array[] */ |
|
| 47 | - protected $checks = []; |
|
| 48 | - |
|
| 49 | - /** @var IDBConnection */ |
|
| 50 | - protected $connection; |
|
| 51 | - |
|
| 52 | - /** @var IServerContainer|\OC\Server */ |
|
| 53 | - protected $container; |
|
| 54 | - |
|
| 55 | - /** @var IL10N */ |
|
| 56 | - protected $l; |
|
| 57 | - |
|
| 58 | - /** |
|
| 59 | - * @param IDBConnection $connection |
|
| 60 | - * @param IServerContainer $container |
|
| 61 | - * @param IL10N $l |
|
| 62 | - */ |
|
| 63 | - public function __construct(IDBConnection $connection, IServerContainer $container, IL10N $l) { |
|
| 64 | - $this->connection = $connection; |
|
| 65 | - $this->container = $container; |
|
| 66 | - $this->l = $l; |
|
| 67 | - } |
|
| 68 | - |
|
| 69 | - /** |
|
| 70 | - * @inheritdoc |
|
| 71 | - */ |
|
| 72 | - public function setFileInfo(IStorage $storage, $path) { |
|
| 73 | - $this->storage = $storage; |
|
| 74 | - $this->path = $path; |
|
| 75 | - } |
|
| 76 | - |
|
| 77 | - /** |
|
| 78 | - * @inheritdoc |
|
| 79 | - */ |
|
| 80 | - public function getMatchingOperations($class, $returnFirstMatchingOperationOnly = true) { |
|
| 81 | - $operations = $this->getOperations($class); |
|
| 82 | - |
|
| 83 | - $matches = []; |
|
| 84 | - foreach ($operations as $operation) { |
|
| 85 | - $checkIds = json_decode($operation['checks'], true); |
|
| 86 | - $checks = $this->getChecks($checkIds); |
|
| 87 | - |
|
| 88 | - foreach ($checks as $check) { |
|
| 89 | - if (!$this->check($check)) { |
|
| 90 | - // Check did not match, continue with the next operation |
|
| 91 | - continue 2; |
|
| 92 | - } |
|
| 93 | - } |
|
| 94 | - |
|
| 95 | - if ($returnFirstMatchingOperationOnly) { |
|
| 96 | - return $operation; |
|
| 97 | - } |
|
| 98 | - $matches[] = $operation; |
|
| 99 | - } |
|
| 100 | - |
|
| 101 | - return $matches; |
|
| 102 | - } |
|
| 103 | - |
|
| 104 | - /** |
|
| 105 | - * @param array $check |
|
| 106 | - * @return bool |
|
| 107 | - */ |
|
| 108 | - protected function check(array $check) { |
|
| 109 | - try { |
|
| 110 | - $checkInstance = $this->container->query($check['class']); |
|
| 111 | - } catch (QueryException $e) { |
|
| 112 | - // Check does not exist, assume it matches. |
|
| 113 | - return true; |
|
| 114 | - } |
|
| 115 | - |
|
| 116 | - if ($checkInstance instanceof ICheck) { |
|
| 117 | - $checkInstance->setFileInfo($this->storage, $this->path); |
|
| 118 | - return $checkInstance->executeCheck($check['operator'], $check['value']); |
|
| 119 | - } else { |
|
| 120 | - // Check is invalid |
|
| 121 | - throw new \UnexpectedValueException($this->l->t('Check %s is invalid or does not exist', $check['class'])); |
|
| 122 | - } |
|
| 123 | - } |
|
| 124 | - |
|
| 125 | - /** |
|
| 126 | - * @param string $class |
|
| 127 | - * @return array[] |
|
| 128 | - */ |
|
| 129 | - public function getOperations($class) { |
|
| 130 | - if (isset($this->operations[$class])) { |
|
| 131 | - return $this->operations[$class]; |
|
| 132 | - } |
|
| 133 | - |
|
| 134 | - $query = $this->connection->getQueryBuilder(); |
|
| 135 | - |
|
| 136 | - $query->select('*') |
|
| 137 | - ->from('flow_operations') |
|
| 138 | - ->where($query->expr()->eq('class', $query->createNamedParameter($class))); |
|
| 139 | - $result = $query->execute(); |
|
| 140 | - |
|
| 141 | - $this->operations[$class] = []; |
|
| 142 | - while ($row = $result->fetch()) { |
|
| 143 | - $this->operations[$class][] = $row; |
|
| 144 | - } |
|
| 145 | - $result->closeCursor(); |
|
| 146 | - |
|
| 147 | - return $this->operations[$class]; |
|
| 148 | - } |
|
| 149 | - |
|
| 150 | - /** |
|
| 151 | - * @param int $id |
|
| 152 | - * @return array |
|
| 153 | - * @throws \UnexpectedValueException |
|
| 154 | - */ |
|
| 155 | - protected function getOperation($id) { |
|
| 156 | - $query = $this->connection->getQueryBuilder(); |
|
| 157 | - $query->select('*') |
|
| 158 | - ->from('flow_operations') |
|
| 159 | - ->where($query->expr()->eq('id', $query->createNamedParameter($id))); |
|
| 160 | - $result = $query->execute(); |
|
| 161 | - $row = $result->fetch(); |
|
| 162 | - $result->closeCursor(); |
|
| 163 | - |
|
| 164 | - if ($row) { |
|
| 165 | - return $row; |
|
| 166 | - } |
|
| 167 | - |
|
| 168 | - throw new \UnexpectedValueException($this->l->t('Operation #%s does not exist', [$id])); |
|
| 169 | - } |
|
| 170 | - |
|
| 171 | - /** |
|
| 172 | - * @param string $class |
|
| 173 | - * @param string $name |
|
| 174 | - * @param array[] $checks |
|
| 175 | - * @param string $operation |
|
| 176 | - * @return array The added operation |
|
| 177 | - * @throws \UnexpectedValueException |
|
| 178 | - */ |
|
| 179 | - public function addOperation($class, $name, array $checks, $operation) { |
|
| 180 | - $this->validateOperation($class, $name, $checks, $operation); |
|
| 181 | - |
|
| 182 | - $checkIds = []; |
|
| 183 | - foreach ($checks as $check) { |
|
| 184 | - $checkIds[] = $this->addCheck($check['class'], $check['operator'], $check['value']); |
|
| 185 | - } |
|
| 186 | - |
|
| 187 | - $query = $this->connection->getQueryBuilder(); |
|
| 188 | - $query->insert('flow_operations') |
|
| 189 | - ->values([ |
|
| 190 | - 'class' => $query->createNamedParameter($class), |
|
| 191 | - 'name' => $query->createNamedParameter($name), |
|
| 192 | - 'checks' => $query->createNamedParameter(json_encode(array_unique($checkIds))), |
|
| 193 | - 'operation' => $query->createNamedParameter($operation), |
|
| 194 | - ]); |
|
| 195 | - $query->execute(); |
|
| 196 | - |
|
| 197 | - $id = $query->getLastInsertId(); |
|
| 198 | - return $this->getOperation($id); |
|
| 199 | - } |
|
| 200 | - |
|
| 201 | - /** |
|
| 202 | - * @param int $id |
|
| 203 | - * @param string $name |
|
| 204 | - * @param array[] $checks |
|
| 205 | - * @param string $operation |
|
| 206 | - * @return array The updated operation |
|
| 207 | - * @throws \UnexpectedValueException |
|
| 208 | - */ |
|
| 209 | - public function updateOperation($id, $name, array $checks, $operation) { |
|
| 210 | - $row = $this->getOperation($id); |
|
| 211 | - $this->validateOperation($row['class'], $name, $checks, $operation); |
|
| 212 | - |
|
| 213 | - $checkIds = []; |
|
| 214 | - foreach ($checks as $check) { |
|
| 215 | - $checkIds[] = $this->addCheck($check['class'], $check['operator'], $check['value']); |
|
| 216 | - } |
|
| 217 | - |
|
| 218 | - $query = $this->connection->getQueryBuilder(); |
|
| 219 | - $query->update('flow_operations') |
|
| 220 | - ->set('name', $query->createNamedParameter($name)) |
|
| 221 | - ->set('checks', $query->createNamedParameter(json_encode(array_unique($checkIds)))) |
|
| 222 | - ->set('operation', $query->createNamedParameter($operation)) |
|
| 223 | - ->where($query->expr()->eq('id', $query->createNamedParameter($id))); |
|
| 224 | - $query->execute(); |
|
| 225 | - |
|
| 226 | - return $this->getOperation($id); |
|
| 227 | - } |
|
| 228 | - |
|
| 229 | - /** |
|
| 230 | - * @param int $id |
|
| 231 | - * @return bool |
|
| 232 | - * @throws \UnexpectedValueException |
|
| 233 | - */ |
|
| 234 | - public function deleteOperation($id) { |
|
| 235 | - $query = $this->connection->getQueryBuilder(); |
|
| 236 | - $query->delete('flow_operations') |
|
| 237 | - ->where($query->expr()->eq('id', $query->createNamedParameter($id))); |
|
| 238 | - return (bool) $query->execute(); |
|
| 239 | - } |
|
| 240 | - |
|
| 241 | - /** |
|
| 242 | - * @param string $class |
|
| 243 | - * @param string $name |
|
| 244 | - * @param array[] $checks |
|
| 245 | - * @param string $operation |
|
| 246 | - * @throws \UnexpectedValueException |
|
| 247 | - */ |
|
| 248 | - protected function validateOperation($class, $name, array $checks, $operation) { |
|
| 249 | - try { |
|
| 250 | - /** @var IOperation $instance */ |
|
| 251 | - $instance = $this->container->query($class); |
|
| 252 | - } catch (QueryException $e) { |
|
| 253 | - throw new \UnexpectedValueException($this->l->t('Operation %s does not exist', [$class])); |
|
| 254 | - } |
|
| 255 | - |
|
| 256 | - if (!($instance instanceof IOperation)) { |
|
| 257 | - throw new \UnexpectedValueException($this->l->t('Operation %s is invalid', [$class])); |
|
| 258 | - } |
|
| 259 | - |
|
| 260 | - $instance->validateOperation($name, $checks, $operation); |
|
| 261 | - |
|
| 262 | - foreach ($checks as $check) { |
|
| 263 | - try { |
|
| 264 | - /** @var ICheck $instance */ |
|
| 265 | - $instance = $this->container->query($check['class']); |
|
| 266 | - } catch (QueryException $e) { |
|
| 267 | - throw new \UnexpectedValueException($this->l->t('Check %s does not exist', [$class])); |
|
| 268 | - } |
|
| 269 | - |
|
| 270 | - if (!($instance instanceof ICheck)) { |
|
| 271 | - throw new \UnexpectedValueException($this->l->t('Check %s is invalid', [$class])); |
|
| 272 | - } |
|
| 273 | - |
|
| 274 | - $instance->validateCheck($check['operator'], $check['value']); |
|
| 275 | - } |
|
| 276 | - } |
|
| 277 | - |
|
| 278 | - /** |
|
| 279 | - * @param int[] $checkIds |
|
| 280 | - * @return array[] |
|
| 281 | - */ |
|
| 282 | - public function getChecks(array $checkIds) { |
|
| 283 | - $checkIds = array_map('intval', $checkIds); |
|
| 284 | - |
|
| 285 | - $checks = []; |
|
| 286 | - foreach ($checkIds as $i => $checkId) { |
|
| 287 | - if (isset($this->checks[$checkId])) { |
|
| 288 | - $checks[$checkId] = $this->checks[$checkId]; |
|
| 289 | - unset($checkIds[$i]); |
|
| 290 | - } |
|
| 291 | - } |
|
| 292 | - |
|
| 293 | - if (empty($checkIds)) { |
|
| 294 | - return $checks; |
|
| 295 | - } |
|
| 296 | - |
|
| 297 | - $query = $this->connection->getQueryBuilder(); |
|
| 298 | - $query->select('*') |
|
| 299 | - ->from('flow_checks') |
|
| 300 | - ->where($query->expr()->in('id', $query->createNamedParameter($checkIds, IQueryBuilder::PARAM_INT_ARRAY))); |
|
| 301 | - $result = $query->execute(); |
|
| 302 | - |
|
| 303 | - while ($row = $result->fetch()) { |
|
| 304 | - $this->checks[(int) $row['id']] = $row; |
|
| 305 | - $checks[(int) $row['id']] = $row; |
|
| 306 | - } |
|
| 307 | - $result->closeCursor(); |
|
| 308 | - |
|
| 309 | - $checkIds = array_diff($checkIds, array_keys($checks)); |
|
| 310 | - |
|
| 311 | - if (!empty($checkIds)) { |
|
| 312 | - $missingCheck = array_pop($checkIds); |
|
| 313 | - throw new \UnexpectedValueException($this->l->t('Check #%s does not exist', $missingCheck)); |
|
| 314 | - } |
|
| 315 | - |
|
| 316 | - return $checks; |
|
| 317 | - } |
|
| 318 | - |
|
| 319 | - /** |
|
| 320 | - * @param string $class |
|
| 321 | - * @param string $operator |
|
| 322 | - * @param string $value |
|
| 323 | - * @return int Check unique ID |
|
| 324 | - */ |
|
| 325 | - protected function addCheck($class, $operator, $value) { |
|
| 326 | - $hash = md5($class . '::' . $operator . '::' . $value); |
|
| 327 | - |
|
| 328 | - $query = $this->connection->getQueryBuilder(); |
|
| 329 | - $query->select('id') |
|
| 330 | - ->from('flow_checks') |
|
| 331 | - ->where($query->expr()->eq('hash', $query->createNamedParameter($hash))); |
|
| 332 | - $result = $query->execute(); |
|
| 333 | - |
|
| 334 | - if ($row = $result->fetch()) { |
|
| 335 | - $result->closeCursor(); |
|
| 336 | - return (int) $row['id']; |
|
| 337 | - } |
|
| 338 | - |
|
| 339 | - $query = $this->connection->getQueryBuilder(); |
|
| 340 | - $query->insert('flow_checks') |
|
| 341 | - ->values([ |
|
| 342 | - 'class' => $query->createNamedParameter($class), |
|
| 343 | - 'operator' => $query->createNamedParameter($operator), |
|
| 344 | - 'value' => $query->createNamedParameter($value), |
|
| 345 | - 'hash' => $query->createNamedParameter($hash), |
|
| 346 | - ]); |
|
| 347 | - $query->execute(); |
|
| 348 | - |
|
| 349 | - return $query->getLastInsertId(); |
|
| 350 | - } |
|
| 37 | + /** @var IStorage */ |
|
| 38 | + protected $storage; |
|
| 39 | + |
|
| 40 | + /** @var string */ |
|
| 41 | + protected $path; |
|
| 42 | + |
|
| 43 | + /** @var array[] */ |
|
| 44 | + protected $operations = []; |
|
| 45 | + |
|
| 46 | + /** @var array[] */ |
|
| 47 | + protected $checks = []; |
|
| 48 | + |
|
| 49 | + /** @var IDBConnection */ |
|
| 50 | + protected $connection; |
|
| 51 | + |
|
| 52 | + /** @var IServerContainer|\OC\Server */ |
|
| 53 | + protected $container; |
|
| 54 | + |
|
| 55 | + /** @var IL10N */ |
|
| 56 | + protected $l; |
|
| 57 | + |
|
| 58 | + /** |
|
| 59 | + * @param IDBConnection $connection |
|
| 60 | + * @param IServerContainer $container |
|
| 61 | + * @param IL10N $l |
|
| 62 | + */ |
|
| 63 | + public function __construct(IDBConnection $connection, IServerContainer $container, IL10N $l) { |
|
| 64 | + $this->connection = $connection; |
|
| 65 | + $this->container = $container; |
|
| 66 | + $this->l = $l; |
|
| 67 | + } |
|
| 68 | + |
|
| 69 | + /** |
|
| 70 | + * @inheritdoc |
|
| 71 | + */ |
|
| 72 | + public function setFileInfo(IStorage $storage, $path) { |
|
| 73 | + $this->storage = $storage; |
|
| 74 | + $this->path = $path; |
|
| 75 | + } |
|
| 76 | + |
|
| 77 | + /** |
|
| 78 | + * @inheritdoc |
|
| 79 | + */ |
|
| 80 | + public function getMatchingOperations($class, $returnFirstMatchingOperationOnly = true) { |
|
| 81 | + $operations = $this->getOperations($class); |
|
| 82 | + |
|
| 83 | + $matches = []; |
|
| 84 | + foreach ($operations as $operation) { |
|
| 85 | + $checkIds = json_decode($operation['checks'], true); |
|
| 86 | + $checks = $this->getChecks($checkIds); |
|
| 87 | + |
|
| 88 | + foreach ($checks as $check) { |
|
| 89 | + if (!$this->check($check)) { |
|
| 90 | + // Check did not match, continue with the next operation |
|
| 91 | + continue 2; |
|
| 92 | + } |
|
| 93 | + } |
|
| 94 | + |
|
| 95 | + if ($returnFirstMatchingOperationOnly) { |
|
| 96 | + return $operation; |
|
| 97 | + } |
|
| 98 | + $matches[] = $operation; |
|
| 99 | + } |
|
| 100 | + |
|
| 101 | + return $matches; |
|
| 102 | + } |
|
| 103 | + |
|
| 104 | + /** |
|
| 105 | + * @param array $check |
|
| 106 | + * @return bool |
|
| 107 | + */ |
|
| 108 | + protected function check(array $check) { |
|
| 109 | + try { |
|
| 110 | + $checkInstance = $this->container->query($check['class']); |
|
| 111 | + } catch (QueryException $e) { |
|
| 112 | + // Check does not exist, assume it matches. |
|
| 113 | + return true; |
|
| 114 | + } |
|
| 115 | + |
|
| 116 | + if ($checkInstance instanceof ICheck) { |
|
| 117 | + $checkInstance->setFileInfo($this->storage, $this->path); |
|
| 118 | + return $checkInstance->executeCheck($check['operator'], $check['value']); |
|
| 119 | + } else { |
|
| 120 | + // Check is invalid |
|
| 121 | + throw new \UnexpectedValueException($this->l->t('Check %s is invalid or does not exist', $check['class'])); |
|
| 122 | + } |
|
| 123 | + } |
|
| 124 | + |
|
| 125 | + /** |
|
| 126 | + * @param string $class |
|
| 127 | + * @return array[] |
|
| 128 | + */ |
|
| 129 | + public function getOperations($class) { |
|
| 130 | + if (isset($this->operations[$class])) { |
|
| 131 | + return $this->operations[$class]; |
|
| 132 | + } |
|
| 133 | + |
|
| 134 | + $query = $this->connection->getQueryBuilder(); |
|
| 135 | + |
|
| 136 | + $query->select('*') |
|
| 137 | + ->from('flow_operations') |
|
| 138 | + ->where($query->expr()->eq('class', $query->createNamedParameter($class))); |
|
| 139 | + $result = $query->execute(); |
|
| 140 | + |
|
| 141 | + $this->operations[$class] = []; |
|
| 142 | + while ($row = $result->fetch()) { |
|
| 143 | + $this->operations[$class][] = $row; |
|
| 144 | + } |
|
| 145 | + $result->closeCursor(); |
|
| 146 | + |
|
| 147 | + return $this->operations[$class]; |
|
| 148 | + } |
|
| 149 | + |
|
| 150 | + /** |
|
| 151 | + * @param int $id |
|
| 152 | + * @return array |
|
| 153 | + * @throws \UnexpectedValueException |
|
| 154 | + */ |
|
| 155 | + protected function getOperation($id) { |
|
| 156 | + $query = $this->connection->getQueryBuilder(); |
|
| 157 | + $query->select('*') |
|
| 158 | + ->from('flow_operations') |
|
| 159 | + ->where($query->expr()->eq('id', $query->createNamedParameter($id))); |
|
| 160 | + $result = $query->execute(); |
|
| 161 | + $row = $result->fetch(); |
|
| 162 | + $result->closeCursor(); |
|
| 163 | + |
|
| 164 | + if ($row) { |
|
| 165 | + return $row; |
|
| 166 | + } |
|
| 167 | + |
|
| 168 | + throw new \UnexpectedValueException($this->l->t('Operation #%s does not exist', [$id])); |
|
| 169 | + } |
|
| 170 | + |
|
| 171 | + /** |
|
| 172 | + * @param string $class |
|
| 173 | + * @param string $name |
|
| 174 | + * @param array[] $checks |
|
| 175 | + * @param string $operation |
|
| 176 | + * @return array The added operation |
|
| 177 | + * @throws \UnexpectedValueException |
|
| 178 | + */ |
|
| 179 | + public function addOperation($class, $name, array $checks, $operation) { |
|
| 180 | + $this->validateOperation($class, $name, $checks, $operation); |
|
| 181 | + |
|
| 182 | + $checkIds = []; |
|
| 183 | + foreach ($checks as $check) { |
|
| 184 | + $checkIds[] = $this->addCheck($check['class'], $check['operator'], $check['value']); |
|
| 185 | + } |
|
| 186 | + |
|
| 187 | + $query = $this->connection->getQueryBuilder(); |
|
| 188 | + $query->insert('flow_operations') |
|
| 189 | + ->values([ |
|
| 190 | + 'class' => $query->createNamedParameter($class), |
|
| 191 | + 'name' => $query->createNamedParameter($name), |
|
| 192 | + 'checks' => $query->createNamedParameter(json_encode(array_unique($checkIds))), |
|
| 193 | + 'operation' => $query->createNamedParameter($operation), |
|
| 194 | + ]); |
|
| 195 | + $query->execute(); |
|
| 196 | + |
|
| 197 | + $id = $query->getLastInsertId(); |
|
| 198 | + return $this->getOperation($id); |
|
| 199 | + } |
|
| 200 | + |
|
| 201 | + /** |
|
| 202 | + * @param int $id |
|
| 203 | + * @param string $name |
|
| 204 | + * @param array[] $checks |
|
| 205 | + * @param string $operation |
|
| 206 | + * @return array The updated operation |
|
| 207 | + * @throws \UnexpectedValueException |
|
| 208 | + */ |
|
| 209 | + public function updateOperation($id, $name, array $checks, $operation) { |
|
| 210 | + $row = $this->getOperation($id); |
|
| 211 | + $this->validateOperation($row['class'], $name, $checks, $operation); |
|
| 212 | + |
|
| 213 | + $checkIds = []; |
|
| 214 | + foreach ($checks as $check) { |
|
| 215 | + $checkIds[] = $this->addCheck($check['class'], $check['operator'], $check['value']); |
|
| 216 | + } |
|
| 217 | + |
|
| 218 | + $query = $this->connection->getQueryBuilder(); |
|
| 219 | + $query->update('flow_operations') |
|
| 220 | + ->set('name', $query->createNamedParameter($name)) |
|
| 221 | + ->set('checks', $query->createNamedParameter(json_encode(array_unique($checkIds)))) |
|
| 222 | + ->set('operation', $query->createNamedParameter($operation)) |
|
| 223 | + ->where($query->expr()->eq('id', $query->createNamedParameter($id))); |
|
| 224 | + $query->execute(); |
|
| 225 | + |
|
| 226 | + return $this->getOperation($id); |
|
| 227 | + } |
|
| 228 | + |
|
| 229 | + /** |
|
| 230 | + * @param int $id |
|
| 231 | + * @return bool |
|
| 232 | + * @throws \UnexpectedValueException |
|
| 233 | + */ |
|
| 234 | + public function deleteOperation($id) { |
|
| 235 | + $query = $this->connection->getQueryBuilder(); |
|
| 236 | + $query->delete('flow_operations') |
|
| 237 | + ->where($query->expr()->eq('id', $query->createNamedParameter($id))); |
|
| 238 | + return (bool) $query->execute(); |
|
| 239 | + } |
|
| 240 | + |
|
| 241 | + /** |
|
| 242 | + * @param string $class |
|
| 243 | + * @param string $name |
|
| 244 | + * @param array[] $checks |
|
| 245 | + * @param string $operation |
|
| 246 | + * @throws \UnexpectedValueException |
|
| 247 | + */ |
|
| 248 | + protected function validateOperation($class, $name, array $checks, $operation) { |
|
| 249 | + try { |
|
| 250 | + /** @var IOperation $instance */ |
|
| 251 | + $instance = $this->container->query($class); |
|
| 252 | + } catch (QueryException $e) { |
|
| 253 | + throw new \UnexpectedValueException($this->l->t('Operation %s does not exist', [$class])); |
|
| 254 | + } |
|
| 255 | + |
|
| 256 | + if (!($instance instanceof IOperation)) { |
|
| 257 | + throw new \UnexpectedValueException($this->l->t('Operation %s is invalid', [$class])); |
|
| 258 | + } |
|
| 259 | + |
|
| 260 | + $instance->validateOperation($name, $checks, $operation); |
|
| 261 | + |
|
| 262 | + foreach ($checks as $check) { |
|
| 263 | + try { |
|
| 264 | + /** @var ICheck $instance */ |
|
| 265 | + $instance = $this->container->query($check['class']); |
|
| 266 | + } catch (QueryException $e) { |
|
| 267 | + throw new \UnexpectedValueException($this->l->t('Check %s does not exist', [$class])); |
|
| 268 | + } |
|
| 269 | + |
|
| 270 | + if (!($instance instanceof ICheck)) { |
|
| 271 | + throw new \UnexpectedValueException($this->l->t('Check %s is invalid', [$class])); |
|
| 272 | + } |
|
| 273 | + |
|
| 274 | + $instance->validateCheck($check['operator'], $check['value']); |
|
| 275 | + } |
|
| 276 | + } |
|
| 277 | + |
|
| 278 | + /** |
|
| 279 | + * @param int[] $checkIds |
|
| 280 | + * @return array[] |
|
| 281 | + */ |
|
| 282 | + public function getChecks(array $checkIds) { |
|
| 283 | + $checkIds = array_map('intval', $checkIds); |
|
| 284 | + |
|
| 285 | + $checks = []; |
|
| 286 | + foreach ($checkIds as $i => $checkId) { |
|
| 287 | + if (isset($this->checks[$checkId])) { |
|
| 288 | + $checks[$checkId] = $this->checks[$checkId]; |
|
| 289 | + unset($checkIds[$i]); |
|
| 290 | + } |
|
| 291 | + } |
|
| 292 | + |
|
| 293 | + if (empty($checkIds)) { |
|
| 294 | + return $checks; |
|
| 295 | + } |
|
| 296 | + |
|
| 297 | + $query = $this->connection->getQueryBuilder(); |
|
| 298 | + $query->select('*') |
|
| 299 | + ->from('flow_checks') |
|
| 300 | + ->where($query->expr()->in('id', $query->createNamedParameter($checkIds, IQueryBuilder::PARAM_INT_ARRAY))); |
|
| 301 | + $result = $query->execute(); |
|
| 302 | + |
|
| 303 | + while ($row = $result->fetch()) { |
|
| 304 | + $this->checks[(int) $row['id']] = $row; |
|
| 305 | + $checks[(int) $row['id']] = $row; |
|
| 306 | + } |
|
| 307 | + $result->closeCursor(); |
|
| 308 | + |
|
| 309 | + $checkIds = array_diff($checkIds, array_keys($checks)); |
|
| 310 | + |
|
| 311 | + if (!empty($checkIds)) { |
|
| 312 | + $missingCheck = array_pop($checkIds); |
|
| 313 | + throw new \UnexpectedValueException($this->l->t('Check #%s does not exist', $missingCheck)); |
|
| 314 | + } |
|
| 315 | + |
|
| 316 | + return $checks; |
|
| 317 | + } |
|
| 318 | + |
|
| 319 | + /** |
|
| 320 | + * @param string $class |
|
| 321 | + * @param string $operator |
|
| 322 | + * @param string $value |
|
| 323 | + * @return int Check unique ID |
|
| 324 | + */ |
|
| 325 | + protected function addCheck($class, $operator, $value) { |
|
| 326 | + $hash = md5($class . '::' . $operator . '::' . $value); |
|
| 327 | + |
|
| 328 | + $query = $this->connection->getQueryBuilder(); |
|
| 329 | + $query->select('id') |
|
| 330 | + ->from('flow_checks') |
|
| 331 | + ->where($query->expr()->eq('hash', $query->createNamedParameter($hash))); |
|
| 332 | + $result = $query->execute(); |
|
| 333 | + |
|
| 334 | + if ($row = $result->fetch()) { |
|
| 335 | + $result->closeCursor(); |
|
| 336 | + return (int) $row['id']; |
|
| 337 | + } |
|
| 338 | + |
|
| 339 | + $query = $this->connection->getQueryBuilder(); |
|
| 340 | + $query->insert('flow_checks') |
|
| 341 | + ->values([ |
|
| 342 | + 'class' => $query->createNamedParameter($class), |
|
| 343 | + 'operator' => $query->createNamedParameter($operator), |
|
| 344 | + 'value' => $query->createNamedParameter($value), |
|
| 345 | + 'hash' => $query->createNamedParameter($hash), |
|
| 346 | + ]); |
|
| 347 | + $query->execute(); |
|
| 348 | + |
|
| 349 | + return $query->getLastInsertId(); |
|
| 350 | + } |
|
| 351 | 351 | } |
@@ -20,11 +20,11 @@ |
||
| 20 | 20 | */ |
| 21 | 21 | |
| 22 | 22 | return [ |
| 23 | - 'routes' => [ |
|
| 24 | - ['name' => 'flowOperations#getOperations', 'url' => '/operations', 'verb' => 'GET'], |
|
| 25 | - ['name' => 'flowOperations#addOperation', 'url' => '/operations', 'verb' => 'POST'], |
|
| 26 | - ['name' => 'flowOperations#updateOperation', 'url' => '/operations/{id}', 'verb' => 'PUT'], |
|
| 27 | - ['name' => 'flowOperations#deleteOperation', 'url' => '/operations/{id}', 'verb' => 'DELETE'], |
|
| 28 | - ['name' => 'requestTime#getTimezones', 'url' => '/timezones', 'verb' => 'GET'], |
|
| 29 | - ] |
|
| 23 | + 'routes' => [ |
|
| 24 | + ['name' => 'flowOperations#getOperations', 'url' => '/operations', 'verb' => 'GET'], |
|
| 25 | + ['name' => 'flowOperations#addOperation', 'url' => '/operations', 'verb' => 'POST'], |
|
| 26 | + ['name' => 'flowOperations#updateOperation', 'url' => '/operations/{id}', 'verb' => 'PUT'], |
|
| 27 | + ['name' => 'flowOperations#deleteOperation', 'url' => '/operations/{id}', 'verb' => 'DELETE'], |
|
| 28 | + ['name' => 'requestTime#getTimezones', 'url' => '/timezones', 'verb' => 'GET'], |
|
| 29 | + ] |
|
| 30 | 30 | ]; |