160 lines
3.4 KiB
PHP
160 lines
3.4 KiB
PHP
<?php
|
|
/**
|
|
* Created by PhpStorm.
|
|
* User: whwyy
|
|
* Date: 2018/4/25 0025
|
|
* Time: 18:38
|
|
*/
|
|
declare(strict_types=1);
|
|
|
|
namespace Snowflake;
|
|
|
|
|
|
use Console\Console;
|
|
use Console\ConsoleProviders;
|
|
use Database\DatabasesProviders;
|
|
use Exception;
|
|
use HttpServer\ServerProviders;
|
|
use ReflectionException;
|
|
use Snowflake\Abstracts\BaseApplication;
|
|
use Snowflake\Abstracts\Config;
|
|
use Snowflake\Abstracts\Input;
|
|
use Snowflake\Abstracts\Kernel;
|
|
use Snowflake\Exception\ComponentException;
|
|
use Snowflake\Exception\NotFindClassException;
|
|
use Snowflake\Exception\NotFindPropertyException;
|
|
use stdClass;
|
|
use Swoole\Timer;
|
|
|
|
/**
|
|
* Class Init
|
|
*
|
|
* @package Snowflake
|
|
*
|
|
* @property-read Config $config
|
|
*/
|
|
class Application extends BaseApplication
|
|
{
|
|
|
|
/**
|
|
* @var string
|
|
*/
|
|
public string $id = 'uniqueId';
|
|
|
|
|
|
/**
|
|
* @throws NotFindClassException
|
|
*/
|
|
public function init()
|
|
{
|
|
$this->import(ConsoleProviders::class);
|
|
$this->import(DatabasesProviders::class);
|
|
$this->import(ServerProviders::class);
|
|
}
|
|
|
|
|
|
/**
|
|
* @param string $service
|
|
* @return $this
|
|
* @throws
|
|
*/
|
|
public function import(string $service): static
|
|
{
|
|
if (!class_exists($service)) {
|
|
throw new NotFindClassException($service);
|
|
}
|
|
$class = Snowflake::createObject($service);
|
|
if (method_exists($class, 'onImport')) {
|
|
$class->onImport($this);
|
|
}
|
|
return $this;
|
|
}
|
|
|
|
|
|
/**
|
|
* @param $kernel
|
|
* @return $this
|
|
*/
|
|
public function commands(Kernel $kernel): static
|
|
{
|
|
foreach ($kernel->getCommands() as $command) {
|
|
$this->register($command);
|
|
}
|
|
return $this;
|
|
}
|
|
|
|
|
|
/**
|
|
* @param string $command
|
|
* @throws
|
|
*/
|
|
public function register(string $command)
|
|
{
|
|
/** @var Console $abstracts */
|
|
$abstracts = $this->get('console');
|
|
$abstracts->register($command);
|
|
}
|
|
|
|
|
|
/**
|
|
* @param Input $argv
|
|
* @return bool|string
|
|
* @throws Exception
|
|
*/
|
|
public function start(Input $argv): bool|string
|
|
{
|
|
try {
|
|
// $this->scan_system_annotation();
|
|
|
|
fire(Event::SERVER_BEFORE_START);
|
|
|
|
$this->set('input', $argv);
|
|
|
|
$manager = Snowflake::app()->get('console');
|
|
$manager->setParameters($argv);
|
|
$class = $manager->search();
|
|
return response()->send($manager->execCommand($class));
|
|
} catch (\Throwable $exception) {
|
|
return response()->send(implode("\n", [
|
|
'Msg: ' . $exception->getMessage(),
|
|
'Line: ' . $exception->getLine(),
|
|
'File: ' . $exception->getFile()
|
|
]));
|
|
} finally {
|
|
Timer::clearAll();
|
|
}
|
|
}
|
|
|
|
|
|
/**
|
|
* @throws ReflectionException
|
|
* @throws ComponentException
|
|
* @throws NotFindPropertyException|NotFindClassException
|
|
*/
|
|
public function scan_system_annotation()
|
|
{
|
|
$this->debug('scan system files...');
|
|
|
|
$annotation = Snowflake::app()->getAttributes();
|
|
$annotation->readControllers(__DIR__ . '/../Console/', 'Console', 'system');
|
|
$annotation->readControllers(__DIR__ . '/../Database/', 'Database', 'system');
|
|
$annotation->readControllers(__DIR__ . '/../Gii/', 'Gii', 'system');
|
|
$annotation->readControllers(__DIR__ . '/../HttpServer/', 'HttpServer', 'system');
|
|
$annotation->readControllers(__DIR__ . '/../Kafka/', 'Kafka', 'system');
|
|
$annotation->readControllers(__DIR__ . '/../System/', 'Snowflake', 'system');
|
|
$annotation->readControllers(__DIR__ . '/../Validator/', 'Validator', 'system');
|
|
}
|
|
|
|
|
|
/**
|
|
* @param $className
|
|
* @param null $abstracts
|
|
* @return stdClass
|
|
* @throws Exception
|
|
*/
|
|
public function make($className, $abstracts = null): stdClass
|
|
{
|
|
return make($className, $abstracts);
|
|
}
|
|
}
|