Carno\HRPC\Client\Handlers\RoutesMarking

Complexity

Total Complexity

4

Size/Duplication

Total Lines	33
Duplicated Lines	0 %

Importance

Changes	1
Bugs	0	Features	1

3 Methods

Rating	Name	Duplication	Size	Complexity
A	exception()	0	3	1
A	outbound()	0	3	1
A	inbound()	0	11	2

<?php
/**
 * Marked of custom routes
 * User: moyo
 * Date: 2018/4/20
 * Time: 3:40 PM
 */

namespace Carno\HRPC\Client\Handlers;

use Carno\Chain\Layered;
use Carno\Cluster\Contracts\Tags;
use Carno\Coroutine\Context;
use Carno\HRPC\Client\Contracts\Defined;
use Carno\RPC\Protocol\Request;
use Throwable;

class RoutesMarking implements Layered
{
    /**
     * flag in ctx
     */
    public const FLAG = 'routes.marked';

    /**
     * @param Request $request
     * @param Context $ctx
     * @return Request
     */
    public function inbound($request, Context $ctx)
    {
        $tags = $ctx->get(self::FLAG) ?? $request->getTags();
        if ($tags !== Tags::DEFAULT) {
            $request->opsExtra('h-headers', static function (&$headers) use ($request, $tags) {
                $request->setTags(...$tags);
                $headers[Defined::X_ROUTE_TAGS] = implode(',', $tags);
            });
        }

        return $request;
    }

    public function outbound($response, Context $ctx)
    {
        return $response;
    }

    public function exception(Throwable $e, Context $ctx)
    {
        throw $e;
    }
}