kiri-core/kiri-engine/Application.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('error.shutdown', []));
        $this->errorHandler->registerExceptionHandler(config('error.exception', []));
        $this->errorHandler->registerErrorHandler(config('error.error', []));
        $this->id = config('id', uniqid('id.'));

        $this->provider->on(OnBeforeCommandExecute::class, [$this, 'beforeCommandExecute']);
    }


    /**
     * @param OnBeforeCommandExecute $beforeCommandExecute
     * @return void
     * @throws
     */
    public function beforeCommandExecute(OnBeforeCommandExecute $beforeCommandExecute): void
    {
        if (!($beforeCommandExecute->command instanceof ServerCommand)) {
            $scanner = $this->container->get(Scanner::class);
            $scanner->load_directory(APP_PATH . 'app/');
        } else if (config('reload.hot', false) === false) {
            $scanner = $this->container->get(Scanner::class);
            $scanner->load_directory(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->add($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.');
    }

}