125 lines
2.4 KiB
PHP
125 lines
2.4 KiB
PHP
<?php
|
|
|
|
|
|
namespace Kiri;
|
|
|
|
|
|
use Exception;
|
|
use Kiri\Abstracts\Component;
|
|
use ReflectionException;
|
|
|
|
defined('ASPECT_ERROR') or define('ASPECT_ERROR', 'Aspect annotation must implement ');
|
|
|
|
|
|
/**
|
|
* Class Aop
|
|
* @package Kiri
|
|
*/
|
|
class AspectManager extends Component
|
|
{
|
|
|
|
|
|
private static array $_aop = [];
|
|
|
|
|
|
/**
|
|
* @param array $handler
|
|
* @param string $aspect
|
|
*/
|
|
public function aop_add(array $handler, string $aspect)
|
|
{
|
|
[$class, $method] = $handler;
|
|
$alias = $class::class . '::' . $method;
|
|
if (!isset(static::$_aop[$alias])) {
|
|
static::$_aop[$alias] = [];
|
|
}
|
|
if (in_array($aspect, static::$_aop[$alias])) {
|
|
return;
|
|
}
|
|
static::$_aop[$alias][] = $aspect;
|
|
}
|
|
|
|
|
|
/**
|
|
* @param string $class
|
|
* @param string $method
|
|
* @param string $aspect
|
|
*/
|
|
public function addAspect(string $class, string $method, string $aspect)
|
|
{
|
|
$alias = $class . '::' . $method;
|
|
if (!isset(static::$_aop[$alias])) {
|
|
static::$_aop[$alias] = [];
|
|
}
|
|
if (in_array($aspect, static::$_aop[$alias])) {
|
|
return;
|
|
}
|
|
static::$_aop[$alias][] = $aspect;
|
|
}
|
|
|
|
|
|
/**
|
|
* @param $handler
|
|
* @return bool
|
|
*/
|
|
public function hasAop($handler): bool
|
|
{
|
|
return isset(static::$_aop[$handler[0]::class . '::' . $handler[1]]);
|
|
}
|
|
|
|
|
|
/**
|
|
* @param $handler
|
|
* @param $params
|
|
* @return mixed
|
|
* @throws ReflectionException
|
|
* @throws Exception
|
|
*/
|
|
final public function dispatch($handler, $params): mixed
|
|
{
|
|
$aopName = $handler[0]::class . '::' . $handler[1];
|
|
|
|
$reflect = Kiri::getDi()->getReflect(current(static::$_aop[$aopName]));
|
|
if (!$reflect->isInstantiable() || !$reflect->hasMethod('invoke')) {
|
|
throw new Exception(ASPECT_ERROR . IAspect::class);
|
|
}
|
|
$method = $reflect->getMethod('invoke');
|
|
|
|
return $method->invokeArgs($reflect->newInstance($handler), $params);
|
|
}
|
|
|
|
|
|
/**
|
|
* @param array $handler
|
|
* @return IAspect
|
|
* @throws Exception
|
|
* @throws ReflectionException
|
|
*/
|
|
public function getAop(array $handler): IAspect
|
|
{
|
|
$aopName = $handler[0]::class . '::' . $handler[1];
|
|
|
|
$reflect = Kiri::getDi()->get(current(static::$_aop[$aopName]));
|
|
if (!method_exists($reflect, 'invoke')) {
|
|
throw new Exception(ASPECT_ERROR . IAspect::class);
|
|
}
|
|
return $reflect;
|
|
}
|
|
|
|
|
|
/**
|
|
* @param $handler
|
|
* @param $params
|
|
* @return mixed
|
|
* @throws Exception
|
|
*/
|
|
private function notFound($handler, $params): mixed
|
|
{
|
|
if (!method_exists($handler[0], $handler[1])) {
|
|
return response()->close(404);
|
|
}
|
|
return call_user_func($handler, ...$params);
|
|
}
|
|
|
|
}
|