mcorten87\rabbitmq_api\mappers\JobExchangePublishMapper

Complexity

Total Complexity

5

Size/Duplication

Total Lines	50
Duplicated Lines	0 %

Coupling/Cohesion

Components	0
Dependencies	6

Test Coverage

Coverage

89.47%

Importance

Changes

0

3 Methods

Rating	Name	Duplication	Size	Complexity
A	mapMethod()	0	4	1
A	mapUrl()	0	12	2
A	mapConfig()	0	20	2

<?php
declare(strict_types=1);
namespace mcorten87\rabbitmq_api\mappers;

use mcorten87\rabbitmq_api\exceptions\WrongArgumentException;
use mcorten87\rabbitmq_api\jobs\JobBase;
use mcorten87\rabbitmq_api\jobs\JobExchangePublish;
use mcorten87\rabbitmq_api\objects\Method;
use mcorten87\rabbitmq_api\objects\Url;
use mcorten87\rabbitmq_api\services\MqManagementConfig;

class JobExchangePublishMapper extends BaseMapper
{

    protected function mapMethod() : Method
    {
        return new Method(Method::POST);
    }

    /**
     * @param JobBase $job
     * @return Url
     */
    protected function mapUrl(JobBase $job) : Url
    {
        if (!$job instanceof JobExchangePublish) {
            throw new WrongArgumentException($job, JobExchangePublish::class);
        }

        $url = 'exchanges';
        $url .= '/'.urlencode((string)$job->getVirtualHost());
        $url .= '/'.urlencode((string)$job->getExchangeName());
        $url .= '/publish';
        return new Url($url);
    }

    /**
     * @param JobBase $job
     * @return array
     */
    protected function mapConfig(JobBase $job) : array
    {
        if (!$job instanceof JobExchangePublish) {
            throw new WrongArgumentException($job, JobExchangePublish::class);
        }

        $body = [
            'payload' => (string)$job->getMessage(),
            'payload_encoding' => 'string', // TODO
            'routing_key' => (string)$job->getRoutingKey(),
            'properties' => [
                'delivery_mode' =>  $job->getDeliveryMode()->__toInt(),
                'headers' => []         // TODO
            ]
        ];

        return array_merge(parent::mapConfig($job), [
            'json'      =>  $body,
        ]);
    }
}