aboutsummaryrefslogtreecommitdiffstats
path: root/lib/private/hooks
diff options
context:
space:
mode:
authorRobin Appelman <icewind@owncloud.com>2015-05-07 13:37:38 +0200
committerRobin Appelman <icewind@owncloud.com>2015-06-02 14:07:54 +0200
commitc91b52d38cdfe68d17485795be6811c2120280b9 (patch)
treed479d9824b66f018b555b195c9d80de6ce4f00f4 /lib/private/hooks
parent3ebc8f0564395fbb519fc4275e0f6f883df708b7 (diff)
downloadnextcloud-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.php78
-rw-r--r--lib/private/hooks/emittertrait.php103
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);
+ }
+ }
+ }
+}