diff options
author | Robin Appelman <icewind@owncloud.com> | 2015-05-07 13:37:38 +0200 |
---|---|---|
committer | Robin Appelman <icewind@owncloud.com> | 2015-06-02 14:07:54 +0200 |
commit | c91b52d38cdfe68d17485795be6811c2120280b9 (patch) | |
tree | d479d9824b66f018b555b195c9d80de6ce4f00f4 /lib/private/hooks | |
parent | 3ebc8f0564395fbb519fc4275e0f6f883df708b7 (diff) | |
download | nextcloud-server-c91b52d38cdfe68d17485795be6811c2120280b9.tar.gz nextcloud-server-c91b52d38cdfe68d17485795be6811c2120280b9.zip |
move emitter implementation to a trait
Diffstat (limited to 'lib/private/hooks')
-rw-r--r-- | lib/private/hooks/basicemitter.php | 78 | ||||
-rw-r--r-- | lib/private/hooks/emittertrait.php | 103 |
2 files changed, 104 insertions, 77 deletions
diff --git a/lib/private/hooks/basicemitter.php b/lib/private/hooks/basicemitter.php index 03d0d1d74ca..ae0f96fbc8c 100644 --- a/lib/private/hooks/basicemitter.php +++ b/lib/private/hooks/basicemitter.php @@ -23,81 +23,5 @@ namespace OC\Hooks; abstract class BasicEmitter implements Emitter { - - /** - * @var (callable[])[] $listeners - */ - protected $listeners = array(); - - /** - * @param string $scope - * @param string $method - * @param callable $callback - */ - public function listen($scope, $method, $callback) { - $eventName = $scope . '::' . $method; - if (!isset($this->listeners[$eventName])) { - $this->listeners[$eventName] = array(); - } - if (array_search($callback, $this->listeners[$eventName]) === false) { - $this->listeners[$eventName][] = $callback; - } - } - - /** - * @param string $scope optional - * @param string $method optional - * @param callable $callback optional - */ - public function removeListener($scope = null, $method = null, $callback = null) { - $names = array(); - $allNames = array_keys($this->listeners); - if ($scope and $method) { - $name = $scope . '::' . $method; - if (isset($this->listeners[$name])) { - $names[] = $name; - } - } elseif ($scope) { - foreach ($allNames as $name) { - $parts = explode('::', $name, 2); - if ($parts[0] == $scope) { - $names[] = $name; - } - } - } elseif ($method) { - foreach ($allNames as $name) { - $parts = explode('::', $name, 2); - if ($parts[1] == $method) { - $names[] = $name; - } - } - } else { - $names = $allNames; - } - - foreach ($names as $name) { - if ($callback) { - $index = array_search($callback, $this->listeners[$name]); - if ($index !== false) { - unset($this->listeners[$name][$index]); - } - } else { - $this->listeners[$name] = array(); - } - } - } - - /** - * @param string $scope - * @param string $method - * @param array $arguments optional - */ - protected function emit($scope, $method, $arguments = array()) { - $eventName = $scope . '::' . $method; - if (isset($this->listeners[$eventName])) { - foreach ($this->listeners[$eventName] as $callback) { - call_user_func_array($callback, $arguments); - } - } - } + use EmitterTrait; } diff --git a/lib/private/hooks/emittertrait.php b/lib/private/hooks/emittertrait.php new file mode 100644 index 00000000000..a80d7d5b03e --- /dev/null +++ b/lib/private/hooks/emittertrait.php @@ -0,0 +1,103 @@ +<?php +/** + * @author Morris Jobke <hey@morrisjobke.de> + * @author Robin Appelman <icewind@owncloud.com> + * + * @copyright Copyright (c) 2015, ownCloud, Inc. + * @license AGPL-3.0 + * + * This code is free software: you can redistribute it and/or modify + * it under the terms of the GNU Affero General Public License, version 3, + * as published by the Free Software Foundation. + * + * 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, version 3, + * along with this program. If not, see <http://www.gnu.org/licenses/> + * + */ + +namespace OC\Hooks; + +trait EmitterTrait { + + /** + * @var (callable[])[] $listeners + */ + protected $listeners = array(); + + /** + * @param string $scope + * @param string $method + * @param callable $callback + */ + public function listen($scope, $method, $callback) { + $eventName = $scope . '::' . $method; + if (!isset($this->listeners[$eventName])) { + $this->listeners[$eventName] = array(); + } + if (array_search($callback, $this->listeners[$eventName]) === false) { + $this->listeners[$eventName][] = $callback; + } + } + + /** + * @param string $scope optional + * @param string $method optional + * @param callable $callback optional + */ + public function removeListener($scope = null, $method = null, $callback = null) { + $names = array(); + $allNames = array_keys($this->listeners); + if ($scope and $method) { + $name = $scope . '::' . $method; + if (isset($this->listeners[$name])) { + $names[] = $name; + } + } elseif ($scope) { + foreach ($allNames as $name) { + $parts = explode('::', $name, 2); + if ($parts[0] == $scope) { + $names[] = $name; + } + } + } elseif ($method) { + foreach ($allNames as $name) { + $parts = explode('::', $name, 2); + if ($parts[1] == $method) { + $names[] = $name; + } + } + } else { + $names = $allNames; + } + + foreach ($names as $name) { + if ($callback) { + $index = array_search($callback, $this->listeners[$name]); + if ($index !== false) { + unset($this->listeners[$name][$index]); + } + } else { + $this->listeners[$name] = array(); + } + } + } + + /** + * @param string $scope + * @param string $method + * @param array $arguments optional + */ + protected function emit($scope, $method, $arguments = array()) { + $eventName = $scope . '::' . $method; + if (isset($this->listeners[$eventName])) { + foreach ($this->listeners[$eventName] as $callback) { + call_user_func_array($callback, $arguments); + } + } + } +} |