EventsService.php

Go to the documentation of this file.

<?php
namespace Elgg;
use Elgg\Debug\Inspector;

class EventsService extends \Elgg\HooksRegistrationService {
    use Profilable;

    const OPTION_STOPPABLE = 'stoppable';
    const OPTION_DEPRECATION_MESSAGE = 'deprecation_message';
    const OPTION_DEPRECATION_VERSION = 'deprecation_version';

    private $inspector;

    public function __construct(Inspector $inspector = null) {
        if (!$inspector) {
            $inspector = new Inspector();
        }
        $this->inspector = $inspector;
    }

    public function registerHandler($name, $type, $callback, $priority = 500) {
        if (in_array($type, ['member', 'friend', 'member_of_site', 'attached'])
                && in_array($name, ['create', 'update', 'delete'])) {
            $this->logger->error("'$name, $type' event is no longer triggered. Update your event registration "
                . "to use '$name, relationship'");
        }
        return parent::registerHandler($name, $type, $callback, $priority);
    }

    public function trigger($event, $type, $object = null, array $options = array()) {
        $options = array_merge(array(
            self::OPTION_STOPPABLE => true,
            self::OPTION_DEPRECATION_MESSAGE => '',
            self::OPTION_DEPRECATION_VERSION => '',
        ), $options);

        $events = $this->hasHandler($event, $type);
        if ($events && $options[self::OPTION_DEPRECATION_MESSAGE]) {
            elgg_deprecated_notice(
                $options[self::OPTION_DEPRECATION_MESSAGE],
                $options[self::OPTION_DEPRECATION_VERSION],
                2
            );
        }

        $events = $this->getOrderedHandlers($event, $type);
        $args = array($event, $type, $object);

        foreach ($events as $callback) {
            if (!is_callable($callback)) {
                if ($this->logger) {
                    $this->logger->warn("handler for event [$event, $type] is not callable: "
                                        . $this->inspector->describeCallable($callback));
                }
                continue;
            }

            if ($this->timer && $type === 'system' && $event !== 'shutdown') {
                $callback_as_string = $this->inspector->describeCallable($callback) . "()";

                $this->timer->begin(["[$event,$type]", $callback_as_string]);
                $return = call_user_func_array($callback, $args);
                $this->timer->end(["[$event,$type]", $callback_as_string]);
            } else {
                $return = call_user_func_array($callback, $args);
            }

            if (!empty($options[self::OPTION_STOPPABLE]) && ($return === false)) {
                return false;
            }
        }

        return true;
    }

    function triggerBefore($event, $object_type, $object = null) {
        return $this->trigger("$event:before", $object_type, $object);
    }

    public function triggerAfter($event, $object_type, $object = null) {
        $options = array(
            self::OPTION_STOPPABLE => false,
        );
        return $this->trigger("$event:after", $object_type, $object, $options);
    }

    function triggerDeprecated($event, $object_type, $object = null, $message, $version) {
        $options = array(
            self::OPTION_DEPRECATION_MESSAGE => $message,
            self::OPTION_DEPRECATION_VERSION => $version,
        );
        return $this->trigger($event, $object_type, $object, $options);
    }
}