Jobs\Queue\FetchExternalImageJob::execute()

Complexity

Conditions	7
Paths	7

Size

Total Lines	52
Code Lines	30

Duplication

Lines	0
Ratio	0 %

Code Coverage

Tests	0
CRAP Score	56

Importance

Changes

0

<?php
    public function execute()
    {
        $logger = $this->getLogger();

        if (!$this->repository) {
            return $this->failure('Cannot execute without repository.');
        }
        $payload = $this->getContent();

        if (!isset($payload['jobId'])) {
            return $this->failure('Missing jobId in playload.');
        }
        /* @var \Jobs\Entity\Job $jobEntity */
        $jobEntity = $this->repository->find($payload['jobId']);

        if (!$jobEntity) {

$jobEntity is of type Jobs\Entity\Job, thus it always evaluated to true.

            return $this->failure('No job entity with the id ' . $payload['jobId'] . ' was found.');
        }

        $uri = $jobEntity->getLogoRef();

        if (0 !== strpos($uri, 'http')) {
            $logger->notice('logoRef seems not to be external: ' . $uri);
            return $this->success('Skip fetching for this job.');
        }

        $logger->debug('Trying to fetch image from ' . $uri);

        $client = new Client($uri);
        $response = $client->send();

        if (200 != $response->getStatusCode()) {
            $logger->err('Received status code ' . $response->getStatusCode() . ' when trying to fetch ' . $uri);

            return $this->recoverable('Status code ' . $response->getStatusCode() . ' received.', ['delay' => '+5 minutes']);
        }

        $content = $response->getBody();
        $type = $response->getHeaders()->get('Content-Type')->getFieldValue();

The method getFieldValue() does not exist on ArrayIterator.

        list(,$ext) = explode('/', $type, 2);
        $imageName = '/static/Jobs/logos/' . $jobEntity->getId() . '.' . $ext;

        if (false === file_put_contents("public$imageName", $content, FILE_BINARY)) {
            return $this->failure('Writing image to "public' . $imageName . '" failed.');
        }

        $logger->info('Saved job logo as ' . basename($imageName));
        $jobEntity->setLogoRef($imageName);
        $this->repository->store($jobEntity);
        $logger->info('Saved job logo as ' . basename($imageName));

        return $this->success();
    }