Reader.php

Go to the documentation of this file.

<?php
namespace Magento\Framework\MessageQueue\Topology\Config\RemoteService;

use Magento\Framework\Communication\Config\ReflectionGenerator;
use Magento\Framework\MessageQueue\Code\Generator\RemoteServiceGenerator;
use Magento\Framework\MessageQueue\DefaultValueProvider;
use Magento\Framework\MessageQueue\Topology\Config\ReaderInterface;
use Magento\Framework\ObjectManager\ConfigInterface as ObjectManagerConfig;
use Magento\Framework\Reflection\MethodsMap as ServiceMethodsMap;

class Reader implements ReaderInterface
{
    private $defaultValueProvider;

    private $objectManagerConfig;

    private $reflectionGenerator;

    private $serviceMethodsMap;

    public function __construct(
        DefaultValueProvider $defaultValueProvider,
        ObjectManagerConfig $objectManagerConfig,
        ReflectionGenerator $reflectionGenerator,
        ServiceMethodsMap $serviceMethodsMap
    ) {
        $this->defaultValueProvider = $defaultValueProvider;
        $this->objectManagerConfig = $objectManagerConfig;
        $this->reflectionGenerator = $reflectionGenerator;
        $this->serviceMethodsMap = $serviceMethodsMap;
    }

    public function read($scope = null)
    {
        $exchangeName = $this->defaultValueProvider->getExchange();
        return [
            $exchangeName => [
                'name' => $exchangeName,
                'type' => 'topic',
                'connection' => $this->defaultValueProvider->getConnection(),
                'durable' => true,
                'autoDelete' => false,
                'internal' => false,
                'bindings' => $this->generateBindings(),
                'arguments' => [],
            ]
        ];
    }

    private function generateBindings()
    {
        $bindings = [];
        foreach ($this->getRemoteServices() as $serviceInterface => $remoteImplementation) {
            try {
                $methodsMap = $this->serviceMethodsMap->getMethodsMap($serviceInterface);
            } catch (\Exception $e) {
                throw new \LogicException(sprintf('Service interface was expected, "%s" given', $serviceInterface));
            }
            foreach ($methodsMap as $methodName => $returnType) {
                $topic = $this->reflectionGenerator->generateTopicName($serviceInterface, $methodName);
                $exchangeName = $this->defaultValueProvider->getExchange();
                $destination = 'queue.' . $topic;
                $id = $topic . '--' . $exchangeName . '--' . $destination;
                $bindings[$id] = [
                    'id' => $id,
                    'destinationType' => 'queue',
                    'destination' => $destination,
                    'disabled' => false,
                    'topic' => $topic,
                    'arguments' => []
                ];
            }
        }
        return $bindings;
    }

    private function getRemoteServices()
    {
        $preferences = $this->objectManagerConfig->getPreferences();
        $remoteServices = [];
        foreach ($preferences as $type => $preference) {
            if ($preference == $type . RemoteServiceGenerator::REMOTE_SERVICE_SUFFIX) {
                $remoteServices[$type] = $preference;
            }
        }
        return $remoteServices;
    }
}