Reader.php

Go to the documentation of this file.

<?php
namespace Magento\Framework\MessageQueue\Publisher\Config\Env;

use Magento\Framework\MessageQueue\Config\Data as MessageQueueConfigData;
use Magento\Framework\App\DeploymentConfig;
use Magento\Framework\MessageQueue\Config\Reader\Env as MessageQueueEnvReader;

class Reader implements \Magento\Framework\Config\ReaderInterface
{
    private $deploymentConfig;

    private $configData;

    private $publisherNameToConnectionMap;

    public function __construct(
        DeploymentConfig $deploymentConfig,
        MessageQueueConfigData $configData,
        $publisherNameToConnectionMap = []
    ) {
        $this->deploymentConfig = $deploymentConfig;
        $this->configData = $configData;
        $this->publisherNameToConnectionMap = $publisherNameToConnectionMap;
    }

    public function read($scope = null)
    {
        $configData = $this->deploymentConfig->getConfigData(MessageQueueEnvReader::ENV_QUEUE);
        if (isset($configData['config'])) {
            $configData = isset($configData['config'][MessageQueueEnvReader::ENV_PUBLISHERS])
                ? $configData['config'][MessageQueueEnvReader::ENV_PUBLISHERS]
                : [];
        } else {
            $configData = isset($configData[MessageQueueEnvReader::ENV_PUBLISHERS])
                ? $this->convertConfigData($scope)
                : [];
        }
        return $configData;
    }

    private function convertConfigData($scope)
    {
        $configData = [];
        $topicsConfig = $this->configData->get('topics');
        foreach ($topicsConfig as $topicName => $topicConfig) {
            $configData[$topicName] = [];
            if (isset($topicConfig['disabled'])) {
                $configData[$topicName]['disabled'] = $topicConfig['disabled'];
            }
            $publisherName = $this->configData->get('topics/' . $topicName . '/publisher', $scope);
            $config = $this->configData->get('publishers/' . $publisherName, $scope);
            if (!empty($config) && isset($this->publisherNameToConnectionMap[$publisherName])) {
                $connectionName = $this->publisherNameToConnectionMap[$publisherName];
                $config['name'] = $config['connection'];
                unset($config['connection']);
                $disabled = isset($config['disabled']) ? $config['disabled'] : false;
                $config['disabled'] = $disabled;
                $configData[$topicName]['connections'][$connectionName] = $config;
            }
        }
        return $configData;
    }
}