157 lines
3.5 KiB
PHP
157 lines
3.5 KiB
PHP
<?php
|
|
/**
|
|
* Created by PhpStorm.
|
|
* User: whwyy
|
|
* Date: 2018/4/25 0025
|
|
* Time: 18:38
|
|
*/
|
|
declare(strict_types=1);
|
|
|
|
namespace Kiri;
|
|
|
|
|
|
use Kiri;
|
|
use Kiri\Abstracts\{BaseApplication, Kernel};
|
|
use Kiri\Di\Scanner;
|
|
use Kiri\Error\ErrorHandler;
|
|
use Kiri\Events\{OnAfterCommandExecute, OnBeforeCommandExecute};
|
|
use Symfony\Component\Console\{Application as ConsoleApplication,
|
|
Input\ArgvInput,
|
|
Output\ConsoleOutput,
|
|
Output\OutputInterface
|
|
};
|
|
use Kiri\Server\ServerCommand;
|
|
use Kiri\Di\Inject\Container;
|
|
use function config;
|
|
|
|
/**
|
|
* Class Init
|
|
*
|
|
* @package Kiri
|
|
*/
|
|
class Application extends BaseApplication
|
|
{
|
|
|
|
/**
|
|
* @var string
|
|
*/
|
|
public string $id = 'uniqueId';
|
|
|
|
|
|
public string $state = '';
|
|
|
|
|
|
/**
|
|
* @var ErrorHandler
|
|
*/
|
|
#[Container(ErrorHandler::class)]
|
|
public ErrorHandler $errorHandler;
|
|
|
|
|
|
/**
|
|
* @return void
|
|
* @throws
|
|
*/
|
|
public function init(): void
|
|
{
|
|
$this->errorHandler->registerShutdownHandler(config('site.error.shutdown', []));
|
|
$this->errorHandler->registerExceptionHandler(config('site.error.exception', []));
|
|
$this->errorHandler->registerErrorHandler(config('site.error.error', []));
|
|
|
|
$this->id = config('site.id', uniqid('id.'));
|
|
|
|
$this->provider->on(OnBeforeCommandExecute::class, [$this, 'beforeCommandExecute']);
|
|
|
|
parent::init();
|
|
}
|
|
|
|
|
|
/**
|
|
* @param OnBeforeCommandExecute $beforeCommandExecute
|
|
* @return void
|
|
* @throws
|
|
*/
|
|
public function beforeCommandExecute(OnBeforeCommandExecute $beforeCommandExecute): void
|
|
{
|
|
if ($beforeCommandExecute->command instanceof ServerCommand) {
|
|
return;
|
|
}
|
|
$scanner = $this->container->get(Scanner::class);
|
|
$scanner->scan(APP_PATH . 'app/');
|
|
}
|
|
|
|
|
|
/**
|
|
* @param string ...$services
|
|
* @return $this
|
|
* @throws
|
|
*/
|
|
public function import(string ...$services): static
|
|
{
|
|
foreach ($services as $service) {
|
|
if (!class_exists($service)) {
|
|
continue;
|
|
}
|
|
/** @var Kiri\Abstracts\Provider $class */
|
|
$class = $this->container->get($service);
|
|
if (method_exists($class, 'onImport')) {
|
|
$class->onImport();
|
|
}
|
|
}
|
|
return $this;
|
|
}
|
|
|
|
|
|
/**
|
|
* @param Kernel $kernel
|
|
* @return $this
|
|
* @throws
|
|
*/
|
|
public function commands(Kernel $kernel): static
|
|
{
|
|
foreach ($kernel->getCommands() as $command) {
|
|
$this->command($command);
|
|
}
|
|
return $this;
|
|
}
|
|
|
|
|
|
/**
|
|
* @param string ...$command
|
|
* @return void
|
|
* @throws
|
|
*/
|
|
public function command(string ...$command): void
|
|
{
|
|
$console = $this->container->get(ConsoleApplication::class);
|
|
foreach ($command as $value) {
|
|
$console->addCommand($this->container->get($value));
|
|
}
|
|
}
|
|
|
|
|
|
/**
|
|
* @param array $argv
|
|
* @return void
|
|
* @throws
|
|
*/
|
|
public function execute(array $argv): void
|
|
{
|
|
/** @var ArgvInput $input */
|
|
$input = $this->container->bind(ArgvInput::class, new ArgvInput($argv));
|
|
|
|
/** @var ConsoleOutput $output */
|
|
$output = $this->container->bind(OutputInterface::class, new ConsoleOutput());
|
|
|
|
$console = $this->container->get(ConsoleApplication::class);
|
|
$command = $console->find($input->getFirstArgument() ?? 'list');
|
|
|
|
fire(new OnBeforeCommandExecute($command));
|
|
$command->run($input, $output);
|
|
fire(new OnAfterCommandExecute($command));
|
|
|
|
$output->writeln('execute complete.');
|
|
}
|
|
|
|
}
|