This commit is contained in:
xl
2023-05-25 16:59:17 +08:00
parent f7768bbe40
commit 75bae59d62
2 changed files with 424 additions and 379 deletions
+333 -290
View File
@@ -22,349 +22,392 @@ use ReflectionParameter;
class Container implements ContainerInterface
{
/**
* @var array
*
* instance class by className
*/
private array $_singletons = [];
/**
* @var array
*
* instance class by className
*/
private array $_singletons = [];
/**
* @var array
*
* implements \ReflectClass
*/
private array $_reflection = [];
/**
* @var array
*
* implements \ReflectClass
*/
private array $_reflection = [];
/**
* @var array
*/
private array $_parameters = [];
/**
* @var array
*/
private array $_parameters = [];
/**
* @var array
*/
private array $_interfaces = [];
/**
* @var array
*/
private array $_interfaces = [];
private static self|null $container = null;
private static self|null $container = null;
private function __construct()
{
}
private function __construct()
{
}
/**
* @return static
*/
public static function instance(): static
{
if (static::$container === null) {
static::$container = new Container();
}
return static::$container;
}
/**
* @return static
*/
public static function instance(): static
{
if (static::$container === null) {
static::$container = new Container();
}
return static::$container;
}
/**
* @param string $id
* @return mixed
* @throws ReflectionException
* @throws \Exception
*/
public function get(string $id): mixed
{
if ($id === ContainerInterface::class) {
return $this;
}
if (!isset($this->_singletons[$id])) {
if (isset($this->_interfaces[$id])) {
$id = $this->_interfaces[$id];
}
$this->_singletons[$id] = $this->make($id);
if (!$this->_singletons[$id]) {
throw new \Exception('Class that cannot be instantiated。');
}
}
return $this->_singletons[$id];
}
/**
* @param string $id
* @return mixed
* @throws ReflectionException
* @throws \Exception
*/
public function get(string $id): mixed
{
if ($id === ContainerInterface::class) {
return $this;
}
if (!isset($this->_singletons[$id])) {
if (isset($this->_interfaces[$id])) {
$id = $this->_interfaces[$id];
}
$this->_singletons[$id] = $this->make($id);
if (!$this->_singletons[$id]) {
throw new \Exception('Class that cannot be instantiated。');
}
}
return $this->_singletons[$id];
}
/**
* @param string $id
* @return void
* @throws ReflectionException
*/
public function parse(string $id): void
{
if (isset($this->_singletons[$id])) {
return;
}
$this->make($id);
}
/**
* @param string $id
* @return void
* @throws ReflectionException
*/
public function parse(string $id): void
{
if (isset($this->_singletons[$id])) {
return;
}
$this->make($id);
}
/**
* @param string $interface
* @param string $class
* @return void
*/
public function set(string $interface, string $class): void
{
$this->_interfaces[$interface] = $class;
}
/**
* @param string $interface
* @param string $class
* @return void
*/
public function set(string $interface, string $class): void
{
$this->_interfaces[$interface] = $class;
}
/**
* @param string $interface
* @param object $object
* @return void
*/
public function bind(string $interface, object $object): void
{
$this->_singletons[$interface] = $object;
}
/**
* @param string $interface
* @param object $object
* @return void
*/
public function bind(string $interface, object $object): void
{
$this->_singletons[$interface] = $object;
}
/**
* @param string $className
* @return ReflectionClass
* @throws ReflectionException
*/
public function getReflectionClass(string $className): ReflectionClass
{
if (isset($this->_reflection[$className])) {
return $this->_reflection[$className];
}
/**
* @param string $className
* @return ReflectionClass
* @throws ReflectionException
*/
public function getReflectionClass(string $className): ReflectionClass
{
if (isset($this->_reflection[$className])) {
return $this->_reflection[$className];
}
$class = new ReflectionClass($className);
$class = new ReflectionClass($className);
return $this->_reflection[$className] = $class;
}
return $this->_reflection[$className] = $class;
}
/**
* @param string $className
* @param array $construct
* @param array $config
* @return object|null
* @throws ReflectionException
*/
public function make(string $className, array $construct = [], array $config = []): ?object
{
$reflect = $this->getReflectionClass($className);
if (!$reflect->isInstantiable()) {
throw new ReflectionException('Class ' . $className . ' cannot be instantiated');
}
/**
* @param string $className
* @param array $construct
* @param array $config
* @return object|null
* @throws ReflectionException
*/
public function make(string $className, array $construct = [], array $config = []): ?object
{
$reflect = $this->getReflectionClass($className);
if (!$reflect->isInstantiable()) {
throw new ReflectionException('Class ' . $className . ' cannot be instantiated');
}
$constructorHandler = $reflect->getConstructor();
if (count($construct) < 1 && $constructorHandler !== null) {
$construct = $this->getMethodParams($constructorHandler);
}
$constructorHandler = $reflect->getConstructor();
if (count($construct) < 1 && $constructorHandler !== null) {
$construct = $this->getMethodParams($constructorHandler);
}
$object = self::configure($reflect->newInstanceArgs($construct), $config);
$object = self::configure($reflect->newInstanceArgs($construct), $config);
return $this->inject($object, $reflect);
}
return $this->inject($object, $reflect);
}
/**
* @param object $object
* @param ReflectionClass $reflect
* @return object
*/
private function inject(object $object, ReflectionClass $reflect): object
{
$targetAttributes = $reflect->getAttributes();
foreach ($targetAttributes as $attribute) {
if (!class_exists($attribute->getName())) {
continue;
}
if ($object instanceof InjectProxyInterface) {
$attribute->newInstance()->dispatch($reflect->getFileName(), $object);
} else {
$attribute->newInstance()->dispatch($object);
}
}
/**
* @param object $object
* @param ReflectionClass $reflect
* @return object
*/
private function inject(object $object, ReflectionClass $reflect): object
{
$targetAttributes = $reflect->getAttributes();
foreach ($targetAttributes as $attribute) {
if (!class_exists($attribute->getName())) {
continue;
}
if ($object instanceof InjectProxyInterface) {
$attribute->newInstance()->dispatch($reflect->getFileName(), $object);
} else {
$attribute->newInstance()->dispatch($object);
}
}
$this->resolveProperties($reflect, $object);
if (method_exists($object, 'init') && $object::class !== 'Symfony\Component\Console\Application') {
call_user_func([$object, 'init']);
}
return $object;
}
$this->resolveProperties($reflect, $object);
if (method_exists($object, 'init') && $object::class !== 'Symfony\Component\Console\Application') {
call_user_func([$object, 'init']);
}
return $object;
}
/**
* @param ReflectionClass $getReflectionClass
* @param object $class
* @return void
*/
public function resolveProperties(ReflectionClass $getReflectionClass, object $class): void
{
$properties = $getReflectionClass->getProperties();
/**
* @param ReflectionClass $getReflectionClass
* @param object $class
* @return void
*/
public function resolveProperties(ReflectionClass $getReflectionClass, object $class): void
{
$properties = $getReflectionClass->getProperties();
$filename = $getReflectionClass->getFileName();
foreach ($properties as $property) {
$propertyAttributes = $property->getAttributes();
foreach ($propertyAttributes as $attribute) {
if (!class_exists($attribute->getName()) ||
in_array(ValidatorInterface::class, class_implements($attribute->getName()))) {
continue;
}
if ($class instanceof InjectProxyInterface) {
$attribute->newInstance()->dispatch($filename, $class, $property->getName());
} else {
$attribute->newInstance()->dispatch($class, $property->getName());
}
}
}
}
$filename = $getReflectionClass->getFileName();
foreach ($properties as $property) {
$propertyAttributes = $property->getAttributes();
foreach ($propertyAttributes as $attribute) {
if (!class_exists($attribute->getName()) ||
in_array(ValidatorInterface::class, class_implements($attribute->getName()))) {
continue;
}
if ($class instanceof InjectProxyInterface) {
$attribute->newInstance()->dispatch($filename, $class, $property->getName());
} else {
$attribute->newInstance()->dispatch($class, $property->getName());
}
}
}
}
/**
* @param string $className
* @param string $method
* @return ReflectionMethod
* @throws ReflectionException
*/
public function getMethod(string $className, string $method): ReflectionMethod
{
$reflection = $this->getReflectionClass($className);
/**
* @param string $className
* @param string $method
* @return ReflectionMethod
* @throws ReflectionException
*/
public function getMethod(string $className, string $method): ReflectionMethod
{
$reflection = $this->getReflectionClass($className);
return $reflection->getMethod($method);
}
return $reflection->getMethod($method);
}
/**
* @param string $className
* @return ReflectionMethod[]
* @throws ReflectionException
*/
public function getMethods(string $className): array
{
$reflection = $this->getReflectionClass($className);
/**
* @param string $className
* @return ReflectionMethod[]
* @throws ReflectionException
*/
public function getMethods(string $className): array
{
$reflection = $this->getReflectionClass($className);
return $reflection->getMethods();
}
return $reflection->getMethods();
}
/**
* @param ReflectionMethod $parameters
* @return array
* @throws ReflectionException
*/
public function getMethodParams(ReflectionMethod $parameters): array
{
$className = $parameters->getDeclaringClass()->getName();
$methodName = $parameters->getName();
if (!isset($this->_parameters[$className])) {
return $this->_parameters[$className][$methodName] = $this->resolveMethodParams($parameters);
}
if (!isset($this->_parameters[$className][$methodName])) {
$this->_parameters[$className][$methodName] = $this->resolveMethodParams($parameters);
}
return $this->_parameters[$className][$methodName];
}
/**
* @param ReflectionMethod $parameters
* @return array
* @throws ReflectionException
*/
public function getMethodParams(ReflectionMethod $parameters): array
{
$className = $parameters->getDeclaringClass()->getName();
$methodName = $parameters->getName();
if (!isset($this->_parameters[$className])) {
return $this->_parameters[$className][$methodName] = $this->resolveMethodParams($parameters);
}
if (!isset($this->_parameters[$className][$methodName])) {
$this->_parameters[$className][$methodName] = $this->resolveMethodParams($parameters);
}
return $this->_parameters[$className][$methodName];
}
/**
* @param \Closure $parameters
* @return array
* @throws ReflectionException
*/
public function getFunctionParams(\Closure $parameters): array
{
return $this->resolveMethodParams(new ReflectionFunction($parameters));
}
/**
* @param \Closure $parameters
* @return array
* @throws ReflectionException
*/
public function getFunctionParams(\Closure $parameters): array
{
return $this->resolveMethodParams(new ReflectionFunction($parameters));
}
/**
* @param ReflectionMethod|ReflectionFunction $parameters
* @return array
* @throws ReflectionException
*/
public function resolveMethodParams(ReflectionMethod|ReflectionFunction $parameters): array
{
$params = [];
if ($parameters->getNumberOfParameters() < 1) {
return $params;
}
$parametersArray = $parameters->getParameters();
$className = $parameters->getDeclaringClass()->getName();
foreach ($parametersArray as $parameter) {
$parameterAttributes = $parameter->getAttributes();
if (count($parameterAttributes) < 1) {
if ($parameter->isDefaultValueAvailable()) {
$value = $parameter->getDefaultValue();
} else if ($parameter->getType() === null) {
$value = $parameter->getType();
} else {
$value = $parameter->getType()->getName();
if (class_exists($value) || interface_exists($value)) {
$value = $this->get($value);
} else {
$value = $this->getTypeValue($parameter);
}
}
$params[$parameter->getName()] = $value;
} else {
$attribute = $parameterAttributes[0]->newInstance();
$params[$parameter->getName()] = $attribute->dispatch($className, $parameters->getName());
}
}
return $params;
}
// public function resolveMethodParams(ReflectionMethod|ReflectionFunction $parameters): array
// {
// $params = [];
// $numOfParameters = $parameters->getNumberOfParameters();
// if ($numOfParameters < 1) {
// return $params;
// }
//
// foreach ($parameters->getParameters() as $parameter) {
// $value = $this->getParameterValue($parameter);
// $params[$parameter->getName()] = $value;
// }
//
// return $params;
// }
//
// private function getParameterValue(ReflectionParameter $parameter)
// {
// $parameterAttributes = $parameter->getAttributes();
// if (count($parameterAttributes) > 0) {
// $attribute = $parameterAttributes[0]->newInstance();
// return $attribute->dispatch($parameter->getDeclaringClass()->getName(), $parameter->getDeclaringFunction()->getName());
// }
//
// if ($parameter->isDefaultValueAvailable()) {
// return $parameter->getDefaultValue();
// }
//
// $type = $parameter->getType();
//
// if ($type === null) {
// return null;
// }
//
// $value = $type->getName();
// if (class_exists($value) || interface_exists($value)) {
// return $this->get($value);
// }
//
// return $this->getTypeValue($parameter);
// }
/**
* @param ReflectionParameter $parameter
* @return string|int|bool|null
*/
private function getTypeValue(ReflectionParameter $parameter): string|int|bool|null
{
return match ($parameter->getType()) {
'string' => '',
'int', 'float' => 0,
'', null, 'object', 'mixed' => NULL,
'bool' => false,
'default' => null
};
}
/**
* @param ReflectionMethod|ReflectionFunction $parameters
* @return array
* @throws ReflectionException
*/
public function resolveMethodParams(ReflectionMethod|ReflectionFunction $parameters): array
{
$params = [];
if ($parameters->getNumberOfParameters() < 1) {
return $params;
}
$parametersArray = $parameters->getParameters();
$className = $parameters->getDeclaringClass()->getName();
foreach ($parametersArray as $parameter) {
$parameterAttributes = $parameter->getAttributes();
if (count($parameterAttributes) < 1) {
if ($parameter->isDefaultValueAvailable()) {
$value = $parameter->getDefaultValue();
} else if ($parameter->getType() === null) {
$value = $parameter->getType();
} else {
$value = $parameter->getType()->getName();
if (class_exists($value) || interface_exists($value)) {
$value = $this->get($value);
} else {
$value = $this->getTypeValue($parameter);
}
}
$params[$parameter->getName()] = $value;
} else {
$attribute = $parameterAttributes[0]->newInstance();
$params[$parameter->getName()] = $attribute->dispatch($className, $parameters->getName());
}
}
return $params;
}
/**
* @param object $object
* @param array $config
* @return object
*/
public static function configure(object $object, array $config): object
{
foreach ($config as $key => $value) {
if (!property_exists($object, $key)) {
continue;
}
$object->{$key} = $value;
}
return $object;
}
/**
* @param ReflectionParameter $parameter
* @return string|int|bool|null
*/
private function getTypeValue(ReflectionParameter $parameter): string|int|bool|null
{
return match ($parameter->getType()) {
'string' => '',
'int', 'float' => 0,
'', null, 'object', 'mixed' => NULL,
'bool' => false,
'default' => null
};
}
/**
* @param string $id
* @return bool
*/
public function has(string $id): bool
{
// TODO: Implement has() method.
return isset($this->_singletons[$id]) && isset($this->_reflection[$id]);
}
/**
* @param object $object
* @param array $config
* @return object
*/
public static function configure(object $object, array $config): object
{
foreach ($config as $key => $value) {
if (!property_exists($object, $key)) {
continue;
}
$object->{$key} = $value;
}
return $object;
}
/**
* @param string $id
* @return bool
*/
public function has(string $id): bool
{
// TODO: Implement has() method.
return isset($this->_singletons[$id]) && isset($this->_reflection[$id]);
}
}
+91 -89
View File
@@ -7,7 +7,7 @@ namespace Kiri\Di;
use Exception;
use Kiri\Abstracts\Component;
use Kiri\Abstracts\Config;
use Kiri\Config\ConfigProvider;
use Kiri\Di\Inject\Skip;
use ReflectionException;
@@ -15,104 +15,106 @@ class Scanner extends Component
{
/**
* @var array
*/
private array $files = [];
/**
* @var array
*/
private array $files = [];
/**
* @param string $path
* @return void
*/
public function read(string $path): void
{
$this->load_dir($path);
}
/**
* @param string $path
* @return void
*/
public function read(string $path): void
{
$this->load_dir($path);
}
/**
* @param string $namespace
* @return void
* @throws ReflectionException
* @throws Exception
*/
public function parse(string $namespace): void
{
$container = Container::instance();
foreach ($this->files as $file) {
$class = $this->rename($file);
if (!class_exists($class)) {
error('Please follow the PSR-4 specification to write code.' . $class);
continue;
}
$reflect = $container->getReflectionClass($class);
if ($reflect->isInstantiable()) {
$data = $reflect->getAttributes(Skip::class);
if (count($data) > 0) {
continue;
}
$container->parse($class);
}
}
}
/**
* @param string $namespace
* @return void
* @throws ReflectionException
* @throws Exception
*/
public function parse(string $namespace): void
{
$container = Container::instance();
foreach ($this->files as $file) {
$class = $this->rename($file);
if (!class_exists($class)) {
error('Please follow the PSR-4 specification to write code.' . $class);
continue;
}
$reflect = $container->getReflectionClass($class);
if ($reflect->isInstantiable()) {
$data = $reflect->getAttributes(Skip::class);
if (count($data) > 0) {
continue;
}
$container->parse($class);
}
}
}
/**
* @param string $file
* @return string
*/
private function rename(string $file): string
{
$filter = array_filter(explode('/', $file), function ($value) {
if (empty($value)) {
return false;
}
return ucfirst($value);
});
return ucfirst(implode('\\', $filter));
}
/**
* @param string $file
* @return string
*/
private function rename(string $file): string
{
$filter = array_filter(explode('/', $file), function ($value) {
if (empty($value)) {
return false;
}
return ucfirst($value);
});
return ucfirst(implode('\\', $filter));
}
/**
* @param string $path
* @return void
*/
private function load_dir(string $path): void
{
$dir = new \DirectoryIterator($path);
$skip = Config::get('scanner.skip', []);
foreach ($dir as $value) {
if ($value->isDot() || str_starts_with($value->getFilename(), '.')) {
continue;
}
if ($value->isDir()) {
if (in_array($value->getRealPath() . '/', $skip)) {
continue;
}
$this->load_dir($value->getRealPath());
} else if ($value->getExtension() == 'php') {
$this->load_file($value->getRealPath());
}
}
}
/**
* @param string $path
* @return void
* @throws ReflectionException
*/
private function load_dir(string $path): void
{
$dir = new \DirectoryIterator($path);
$skip = \config('scanner.skip', []);
foreach ($dir as $value) {
if ($value->isDot() || str_starts_with($value->getFilename(), '.')) {
continue;
}
if ($value->isDir()) {
if (in_array($value->getRealPath() . '/', $skip)) {
continue;
}
$this->load_dir($value->getRealPath());
} else if ($value->getExtension() == 'php') {
$this->load_file($value->getRealPath());
}
}
}
/**
* @param string $path
* @return void
*/
private function load_file(string $path): void
{
try {
require_once "$path";
$path = str_replace($_SERVER['PWD'], '', $path);
$path = str_replace('.php', '', $path);
$this->files[] = $path;
} catch (\Throwable $throwable) {
error($throwable);
}
}
/**
* @param string $path
* @return void
* @throws ReflectionException
*/
private function load_file(string $path): void
{
try {
require_once "$path";
$path = str_replace($_SERVER['PWD'], '', $path);
$path = str_replace('.php', '', $path);
$this->files[] = $path;
} catch (\Throwable $throwable) {
error($throwable);
}
}
}