SWP\Bundle\CoreBundle\Serializer\TenantHandler

Complexity

Total Complexity

16

Size/Duplication

Total Lines	139
Duplicated Lines	10.07 %

Coupling/Cohesion

Components	2
Dependencies	18

Importance

Changes

0

5 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	17	1
A	getSubscribedEvents()	0	10	1
A	getSubscribingMethods()	0	11	1
C	onPostSerialize()	14	62	11
A	serializeToJson()	0	16	2

<?php

declare(strict_types=1);

/*
 * This file is part of the Superdesk Web Publisher Core Bundle.
 *
 * Copyright 2017 Sourcefabric z.ú. and contributors.
 *
 * For the full copyright and license information, please see the
 * AUTHORS and LICENSE files distributed with this source code.
 *
 * @copyright 2017 Sourcefabric z.ú
 * @license http://www.superdesk.org/license
 */

namespace SWP\Bundle\CoreBundle\Serializer;

use JMS\Serializer\EventDispatcher\Events;
use JMS\Serializer\EventDispatcher\EventSubscriberInterface;
use JMS\Serializer\EventDispatcher\ObjectEvent;
use JMS\Serializer\GraphNavigatorInterface;
use JMS\Serializer\Handler\SubscribingHandlerInterface;
use JMS\Serializer\JsonSerializationVisitor;
use JMS\Serializer\Metadata\StaticPropertyMetadata;
use JMS\Serializer\Context;
use JMS\Serializer\SerializationContext;
use JMS\Serializer\SerializerInterface;
use SWP\Bundle\ContentBundle\Model\RouteRepositoryInterface;
use SWP\Bundle\CoreBundle\Context\ScopeContext;
use SWP\Bundle\CoreBundle\Model\Tenant;
use SWP\Bundle\CoreBundle\Model\TenantInterface;
use SWP\Bundle\SettingsBundle\Manager\SettingsManagerInterface;
use SWP\Component\Common\Criteria\Criteria;
use SWP\Component\ContentList\Repository\ContentListRepositoryInterface;
use SWP\Component\MultiTenancy\Context\TenantContextInterface;
use SWP\Component\MultiTenancy\Provider\TenantProviderInterface;
use Symfony\Component\HttpFoundation\RequestStack;

final class TenantHandler implements EventSubscriberInterface, SubscribingHandlerInterface
{
    private $settingsManager;

    private $requestStack;

    private $routeRepository;

    private $contentListRepository;

    private $tenantContext;

    private $internalCache = [];

    private $serializer;

    private $tenantProvider;

    public function __construct(
        SettingsManagerInterface $settingsManager,
        RequestStack $requestStack,
        RouteRepositoryInterface $routeRepository,
        ContentListRepositoryInterface $contentListRepository,
        TenantContextInterface $tenantContext,
        TenantProviderInterface $tenantProvider,
        SerializerInterface $serializer
    ) {
        $this->settingsManager = $settingsManager;
        $this->requestStack = $requestStack;
        $this->routeRepository = $routeRepository;
        $this->contentListRepository = $contentListRepository;
        $this->tenantContext = $tenantContext;
        $this->serializer = $serializer;
        $this->tenantProvider = $tenantProvider;
    }

    public static function getSubscribedEvents(): array
    {
        return [
            [
                'event' => Events::POST_SERIALIZE,
                'class' => Tenant::class,
                'method' => 'onPostSerialize',
            ],
        ];
    }

    public static function getSubscribingMethods(): array
    {
        return [
            [
                'direction' => GraphNavigatorInterface::DIRECTION_SERIALIZATION,
                'format' => 'json',
                'type' => TenantInterface::class,
                'method' => 'serializeToJson',
            ],
        ];
    }

    public function onPostSerialize(ObjectEvent $event): void
    {
        /** @var TenantInterface $tenant */
        $tenant = $event->getObject();
        /** @var JsonSerializationVisitor $visitor */
        $visitor = $event->getVisitor();

        if (isset($this->internalCache[$tenant->getCode()])) {
            $cachedData = $this->internalCache[$tenant->getCode()];
            $visitor->visitProperty(new StaticPropertyMetadata('', 'fbia_enabled', null), $cachedData['settings']['fbiaEnabled']);
            $visitor->visitProperty(new StaticPropertyMetadata('', 'paywall_enabled', null), $cachedData['settings']['paywallEnabled']);
            if (isset($cachedData['routes'])) {
                $visitor->visitProperty(
                    new StaticPropertyMetadata('', 'routes', null, ['api_routes_list']),
                    $cachedData['routes']
                );
            }
            if (isset($cachedData['contentLists'])) {
                $visitor->visitProperty(new StaticPropertyMetadata('', 'content_lists', null), $cachedData['contentLists']);
            }

            return;
        }

        $originalTenant = $this->tenantContext->getTenant();
        if ($originalTenant->getCode() !== $tenant->getCode()) {
            $this->tenantContext->setTenant($tenant);
        }

        $fbiaEnabled = $this->settingsManager->get('fbia_enabled', ScopeContext::SCOPE_TENANT, $tenant, false);
        $paywallEnabled = $this->settingsManager->get('paywall_enabled', ScopeContext::SCOPE_TENANT, $tenant, false);
        $this->internalCache[$tenant->getCode()]['settings'] = [
            'fbiaEnabled' => $fbiaEnabled,
            'paywallEnabled' => $paywallEnabled,
        ];

        $visitor->visitProperty(new StaticPropertyMetadata('', 'fbia_enabled', null), $fbiaEnabled);
        $visitor->visitProperty(new StaticPropertyMetadata('', 'paywall_enabled', null), $paywallEnabled);

        $masterRequest = $this->requestStack->getMasterRequest();
        if (null !== $masterRequest && (null !== $masterRequest->get('withRoutes') || null !== $masterRequest->get('withContentLists'))) {
            if (null !== $masterRequest->get('withRoutes')) {

This code seems to be duplicated across your project.

                $routes = $this->routeRepository->getQueryByCriteria(new Criteria(['maxResults' => 9999]), [], 'r')->getQuery()->getResult();
                $routesArray = $this->serializer->toArray($routes, SerializationContext::create()->setGroups(['Default', 'api_routes_list']));

It seems like you code against a concrete implementation and not the interface JMS\Serializer\SerializerInterface as the method toArray() does only exist in the following implementations of said interface: JMS\Serializer\Serializer.

                $this->internalCache[$tenant->getCode()]['routes'] = $routesArray;

                $visitor->visitProperty(new StaticPropertyMetadata('', 'routes', null, ['api_routes_list']), $routesArray);
            }

            if (null !== $masterRequest->get('withContentLists')) {

This code seems to be duplicated across your project.

                $contentLists = $this->contentListRepository->getQueryByCriteria(new Criteria(['maxResults' => 9999]), [], 'cl')->getQuery()->getResult();
                $contentListsArray = $this->serializer->toArray($contentLists, SerializationContext::create()->setGroups(['Default', 'api']));

It seems like you code against a concrete implementation and not the interface JMS\Serializer\SerializerInterface as the method toArray() does only exist in the following implementations of said interface: JMS\Serializer\Serializer.

                $this->internalCache[$tenant->getCode()]['contentLists'] = $contentListsArray;

                $visitor->visitProperty(new StaticPropertyMetadata('', 'content_lists', null), $contentListsArray);
            }
        }

        if ($originalTenant->getCode() !== $tenant->getCode()) {
            $this->tenantContext->setTenant($originalTenant);
        }
    }

    public function serializeToJson(
        JsonSerializationVisitor $visitor,

The parameter $visitor is not used and could be removed.

        string $tenantCode,
        array $type,

The parameter $type is not used and could be removed.

        Context $context
    ) {
        $tenant = $this->tenantProvider->findOneByCode($tenantCode);
        if (null === $tenant) {
            return;
        }

        $data = $context->getNavigator()->accept($tenant);
        unset($data['articles_count'], $data['created_at'], $data['enabled'], $data['organization'],$data['theme_name'], $data['updated_at']);

        return $data;
    }
}