mcorten87\rabbitmq_api\mappers\JobBindingToQueueDeleteMapper

Complexity

Total Complexity

6

Size/Duplication

Total Lines	52
Duplicated Lines	100 %

Coupling/Cohesion

Components	0
Dependencies	5

Test Coverage

Coverage

91.3%

Importance

Changes

0

3 Methods

Rating	Name	Duplication	Size	Complexity
A	mapMethod()	4	4	1
A	mapUrl()	16	16	3
A	mapConfig()	19	19	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\JobBindingToQueueDelete;
use mcorten87\rabbitmq_api\objects\Method;
use mcorten87\rabbitmq_api\objects\Url;
use mcorten87\rabbitmq_api\services\MqManagementConfig;

class JobBindingToQueueDeleteMapper extends BaseMapper

This class seems to be duplicated in your project.

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

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


        return new Url('bindings/'
            .urlencode((string)$job->getVirtualHost()).'/'
            .'e/'
            .urlencode((string)$job->getExchangeName()).'/'
            .$job->getDestinationType().'/'
            .urlencode((string)$job->getQueueName())
            .'/'.(!empty((string) $job->getRoutingKey()) ? (string) $job->getRoutingKey() : '~')
        );
    }

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


        $body = [
            'arguments'         => [],
            'destination'       => (string)$job->getQueueName(),
            'destination_type'  => $job->getDestinationType(),
            'routing_key'       => (string)$job->getRoutingKey(),
            'source'            => (string)$job->getExchangeName(),
            'vhost'             => $job->getVirtualHost(),
        ];

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