Bankiru\Api\JsonRpc\Adapters\JMS\SerializedJsonRpcResponseListener

Complexity

Total Complexity

11

Size/Duplication

Total Lines	75
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	6

Importance

Changes

0

3 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	4	1
B	onPlainResponse()	0	25	4
B	createSerializerContext()	0	27	6

<?php

namespace Bankiru\Api\JsonRpc\Adapters\JMS;

use Bankiru\Api\JsonRpc\Specification\JsonRpcResponse;
use Bankiru\Api\Rpc\Event\ViewEvent;
use JMS\Serializer\SerializationContext;
use JMS\Serializer\Serializer;
use ScayTrase\Api\JsonRpc\JsonRpcRequestInterface;
use ScayTrase\Api\JsonRpc\JsonRpcResponseInterface;

final class SerializedJsonRpcResponseListener
{
    /** @var  Serializer */
    private $serializer;

    /**
     * SerializedJsonRpcResponseListener constructor.
     *
     * @param Serializer $serializer
     */
    public function __construct(Serializer $serializer)
    {
        $this->serializer = $serializer;
    }

    public function onPlainResponse(ViewEvent $event)
    {
        $request  = $event->getRequest();
        $response = $event->getResponse();

        // No need to perform JSON-RPC serialization here
        if (!$request instanceof JsonRpcRequestInterface || $request->isNotification()) {
            return;
        }

        // Response is already properly formatted
        if ($response instanceof JsonRpcResponseInterface) {
            return;
        }

        $response = new JsonRpcResponse(
            $request->getId(),
            $this->serializer->toArray(
                $event->getResponse(),
                $this->createSerializerContext($event)

            )
        );
        $event->setResponse($response);
    }

    /**
     * @param ViewEvent $event
     *
     * @return SerializationContext
     * @throws \LogicException
     */
    private function createSerializerContext(ViewEvent $event)
    {
        $context = SerializationContext::create();
        $context->setSerializeNull(true);
        $attributes = $event->getRequest()->getAttributes();
        $defaults   = $attributes->get('_with_default_context', true);

        if (!$defaults && (false === $attributes->get('_context', false))) {
            throw new \LogicException(
                'Could not perform object serialization as no default context allowed and no custom set'
            );
        }

        $groups = [];
        if ($defaults) {
            $groups[] = 'Default';
        }
        if (false !== $attributes->get('_context', false)) {
            foreach ((array)$attributes->get('_context') as $group) {
                $groups[] = $group;
            }
        }

        $context->setGroups($groups);

        return $context;
    }
}