mcorten87\rabbitmq_api\services\JobService

Complexity

Total Complexity

3

Size/Duplication

Total Lines	38
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	6

Test Coverage

Coverage

0%

Importance

Changes	1
Bugs	0	Features	0

2 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	5	1
A	execute()	0	18	2

<?php

namespace mcorten87\rabbitmq_api\services;

use GuzzleHttp\Client;
use GuzzleHttp\Exception\ClientException;
use mcorten87\rabbitmq_api\jobs\JobBase;
use mcorten87\rabbitmq_api\MqManagementFactory;
use mcorten87\rabbitmq_api\objects\JobResult;

class JobService
{
    /** @var MqManagementFactory */
    private $factory;

    /** @var Client */
    private $client;

    public function __construct(MqManagementFactory $factory, Client $client)
    {
        $this->factory = $factory;
        $this->client = $client;
    }

    /**
     * @param JobBase $job
     * @return JobResult
     * @throws \mcorten87\rabbitmq_api\exceptions\NoMapperForJob
     */
    public function execute(JobBase $job) : JobResult
    {
        $mapper = $this->factory->getJobMapper($job);

        $mapResult = $mapper->map($job);

        try {
            $res = $this->client->request(
                $mapResult->getMethod(),
                $this->factory->getConfig()->getUrl().$mapResult->getUrl(),
                $mapResult->getConfig()
            );

            return new JobResult($res);
        } catch (ClientException $e) {
            return JobResult::populateFromClientException($e);
        }
    }
}