Carno\HRPC\Handlers\ServerReplier

Complexity

Total Complexity

6

Size/Duplication

Total Lines	47
Duplicated Lines	0 %

Importance

Changes	1
Bugs	0	Features	1

4 Methods

Rating	Name	Duplication	Size	Complexity
A	replying()	0	10	3
A	inbound()	0	3	1
A	outbound()	0	4	1
A	exception()	0	4	1

<?php
/**
 * HTTP server replier
 * User: moyo
 * Date: 2018/6/6
 * Time: 4:01 PM
 */

namespace Carno\HRPC\Handlers;

use Carno\Chain\Layered;
use Carno\Coroutine\Context;
use Carno\HTTP\Server\Connection;
use Throwable;

class ServerReplier implements Layered
{
    /**
     * @param mixed $message
     * @param Context $ctx
     * @return mixed
     */
    public function inbound($message, Context $ctx)
    {
        return $message;
    }

    /**
     * @param mixed $message
     * @param Context $ctx
     * @return mixed
     */
    public function outbound($message, Context $ctx)
    {
        $this->replying($ctx);
        return $message;
    }

    /**
     * @param Throwable $e
     * @param Context $ctx
     * @throws Throwable
     */
    public function exception(Throwable $e, Context $ctx)
    {
        $this->replying($ctx);
        throw $e;
    }

    /**
     * @param Context $ctx
     */
    private function replying(Context $ctx) : void
    {
        /**
         * @var Connection $ingress
         */

        if (($ingress = $ctx->get(ServerWrapper::CONNECTION))
            && ($response = $ctx->get(ServerWrapper::RESPONDING))
        ) {
            $ingress->reply($response);
        }
    }
}