Carno\HRPC\Client\Handlers\ContextPacking

Complexity

Total Complexity

7

Size/Duplication

Total Lines	47
Duplicated Lines	0 %

Importance

Changes	1
Bugs	0	Features	1

4 Methods

Rating	Name	Duplication	Size	Complexity
A	keys()	0	3	1
A	exception()	0	3	1
A	inbound()	0	20	4
A	outbound()	0	3	1

<?php
/**
 * Client packing of attachments
 * User: moyo
 * Date: 19/03/2018
 * Time: 9:53 PM
 */

namespace Carno\HRPC\Client\Handlers;

use Carno\Chain\Layered;
use Carno\Coroutine\Context;
use Carno\RPC\Protocol\Request;
use Throwable;

class ContextPacking implements Layered
{
    public const HTTP_HEADER = 'X-Trans-CTX';

    /**
     * @var array
     */
    protected $keys = [];

    /**
     * @param string ...$allowed
     */
    public function keys(string ...$allowed) : void
    {
        $this->keys = $allowed;
    }

    public function inbound($request, Context $ctx)
    {
        /**
         * @var Request $request
         */

        $attachments = [];

        foreach ($this->keys as $key) {
            $ctx->has($key) && $attachments[$key] = $ctx->get($key);
        }

        if ($attachments) {
            $dat = base64_encode(json_encode($attachments, JSON_UNESCAPED_SLASHES | JSON_UNESCAPED_UNICODE));
            $request->opsExtra('h-headers', static function (&$headers) use ($dat) {
                $headers[self::HTTP_HEADER] = $dat;
            });
        }

        return $request;
    }

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

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