Ubiquity\events\EventsManager

Complexity

Total Complexity

11

Size/Duplication

Total Lines	59
Duplicated Lines	0 %

Test Coverage

Coverage

90.48%

Importance

Changes

0

5 Methods

Rating	Name	Duplication	Size	Complexity
A	addListener()	0	5	2
A	start()	0	3	2
A	store()	0	2	1
A	trigger()	0	4	3
A	triggerOne()	0	8	3

<?php
namespace Ubiquity\events;

use Ubiquity\cache\CacheManager;

/**
 * Manage events
 *
 * @author jc
 *
 */
class EventsManager {

	private static string $key = 'events/events';

	/**
	 *
	 * @var array|mixed
	 */
	protected static $managedEvents = [];

	/**
	 * Starts the event manager (in app/config/services.php)
	 */
	public static function start():void {
		if (CacheManager::$cache->exists(self::$key)) {
			self::$managedEvents = CacheManager::$cache->fetch(self::$key);
		}
	}

	/**
	 * Adds a listener on eventName
	 * @param string $eventName
	 * @param EventListenerInterface|callable $action
	 */
	public static function addListener(string $eventName, $action):void {
		if (! isset(self::$managedEvents[$eventName])) {
			self::$managedEvents[$eventName] = [];
		}
		self::$managedEvents[$eventName][] = $action;
	}

	/**
	 * Store the managed events in cache (do not use in prod)
	 */
	public static function store():void {
		CacheManager::$cache->store(self::$key, self::$managedEvents);
	}

	/**
	 * Trigger an event
	 * @param string $eventName
	 * @param mixed ...$params
	 */
	public static function trigger(string $eventName, &...$params):void {
		if (isset(self::$managedEvents[$eventName])) {
			foreach (self::$managedEvents[$eventName] as $action) {
				self::triggerOne($action, $params);
			}
		}
	}

	private static function triggerOne($action, &$params):void {
		if (\is_callable($action)) {
			\call_user_func_array($action, $params);
		} elseif (is_subclass_of($action, EventListenerInterface::class)) {
			\call_user_func_array([
				new $action(),
				'on'
			], $params);
		}
	}
}