carno-php / hrpc

src/Components/Serving.php

<?php
/**
 * RPC serving init
 * User: moyo
 * Date: 18/03/2018
 * Time: 3:20 PM
 */

namespace Carno\HRPC\Components;

use Carno\Console\Component;
use Carno\Console\Contracts\Application;
use Carno\Console\Contracts\Bootable;
use Carno\Container\DI;
use Carno\HRPC\Handlers\ExceptionDump;
use Carno\HRPC\Handlers\RequestLogger;
use Carno\HRPC\Handlers\ServerReplier;
use Carno\HRPC\Handlers\ServerUnavailable;
use Carno\HRPC\Handlers\ServerWrapper;
use Carno\HRPC\Handlers\TrafficMonitor;
use Carno\Monitor\Daemon;

The type Carno\Monitor\Daemon was not found. Maybe you did not declare it correctly or list all dependencies?

use Carno\RPC\Handlers\ServiceInvoker;
use Carno\RPC\Options;
use Carno\RPC\Server;
use Carno\RPC\Service\Dispatcher;

This use statement conflicts with another class in this namespace, Carno\HRPC\Components\Dispatcher. Consider defining an alias.

class Serving extends Component implements Bootable
{
    /**
     * @var array
     */
    protected $dependencies = [Dispatcher::class];

    /**
     * @param Application $app
     */
    public function starting(Application $app) : void
    {
        // assign global extensions manager of server
        Server::layers()->append(
            null,
            DI::object(ExceptionDump::class),
            DI::object(ServerReplier::class),
            DI::object(ServerWrapper::class),
            DI::object(RequestLogger::class),
            DI::object(ServiceInvoker::class, DI::get(Dispatcher::class), $options = new Options())
        );

        // initial mark server "unavailable"
        Server::layers()->append(ServerWrapper::class, DI::object(ServerUnavailable::class));

        $app->starting()->add(static function () use ($app, $options) {
            // add traffic monitor layer
            DI::has(Daemon::class) && Server::layers()->append(
                ServerWrapper::class,
                DI::object(TrafficMonitor::class)
            );
            // configurable options link
            $app->conf()->bind($options, ['rpc.serv.opts' => ['tt.exec' => 'ttExec']]);

The method conf() does not exist on Carno\Console\Contracts\Application.

        });

        $app->starting()->done()->then(static function () {
            // mark server "available" when bootstrap done
            Server::layers()->remove(ServerUnavailable::class);
        });
    }
}