BitBag\SyliusElasticsearchPlugin\EventListener\QueryCreatedSubscriber

Complexity

Total Complexity

3

Size/Duplication

Total Lines	25
Duplicated Lines	0 %

Importance

Changes	1
Bugs	0	Features	0

3 Methods

Rating	Name	Duplication	Size	Complexity
A	getSubscribedEvents()	0	4	1
A	onQueryCreated()	0	8	1
A	__construct()	0	3	1

<?php
/*

This file was created by developers working at BitBag

Do you need more information about us and what we do? Visit our   website!

We are hiring developers from all over the world. Join us and start your new, exciting adventure and become part of us: https://bitbag.io/career
*/
declare(strict_types=1);

namespace BitBag\SyliusElasticsearchPlugin\EventListener;

use BitBag\PluginCommonsPlugin\Event\QueryCreatedEvent;

The type BitBag\PluginCommonsPlugin\Event\QueryCreatedEvent was not found. Maybe you did not declare it correctly or list all dependencies?

use spec\Sylius\Component\Core\Test\Services\DefaultUnitedStatesChannelFactorySpec;
use Sylius\Component\Customer\Model\CustomerGroupInterface;
use Symfony\Component\EventDispatcher\EventSubscriberInterface;
use Elastica\Query\BoolQuery;
use Elastica\Query\Terms;
use App\Context\CustomerGroupContext;

The type App\Context\CustomerGroupContext was not found. Maybe you did not declare it correctly or list all dependencies?

final class QueryCreatedSubscriber implements EventSubscriberInterface, QueryCreatedSubscriberInterface
{
    /** @var CustomerGroupContext $groupContext */
    public $groupContext;

    public function __construct(CustomerGroupContext $groupContext)
    {
        $this->groupContext = $groupContext;
    }

    public static function getSubscribedEvents(): array
    {
        return [
            QueryCreatedEvent::NAME => 'onQueryCreated',
        ];
    }

    public function onQueryCreated(QueryCreatedEvent $event): void
    {
        /** @var BoolQuery $query */
        $query = $event->getQuery();

        $userGroupCode = $this->groupContext->getCustomerGroup()->getCode();

        $query->addMust(new \Elastica\Query\Terms(self::AUTHORIZED_GORUP_KEY,[$userGroupCode]));

    }
}