JobOptionsExtractor::extractOptions() - Code Metrics - cfrutos/async-jobs - Measure and Improve Code Quality continuously with Scrutinizer

JobOptionsExtractor::extractOptions() A
last analyzed 2016-11-30 11:33 UTC

↳ Parent: JobOptionsExtractor

Complexity

Conditions	1
Paths	1

Size

Total Lines	9
Code Lines	6

Duplication

Lines	0
Ratio	0 %

Importance

Changes

Metric	Value
dl	0
loc	9
rs	9.6666
c	0
b	0
f	0
cc	1
eloc	6
nc	1
nop	1

<?php
namespace Workana\AsyncJobs\Normalizer;

use InvalidArgumentException;
use Workana\AsyncJobs\Job;

/**
 * Extracts and hydrates options of base Job, to be used on normalizers
 *
 * @author Carlos Frutos <[email protected]>
 */
trait JobOptionsExtractor
{
    /**
     * @param Job $job
     *
     * @return array Options
     */
    public function extractOptions(Job $job)
    {
        return [
            'delay' => $job->getDelay(),
            'retries' => $job->getRetries(),
            'maxRetries' => $job->getMaxRetries(),
            'preferredQueueName' => $job->getPreferredQueueName(),
        ];
    }

    /**
     * @param Job $job
     * @param array $options
     *
     * @return void
     */
    public function hydrateOptions(Job $job, array $options)
    {
        $missingOptions = array_diff([
            'delay',
            'retries',
            'maxRetries',
            'preferredQueueName'
        ], array_keys($options));

        if (!empty($missingOptions)) {
            throw new InvalidArgumentException(strtr('The following options are missing: :missingOptions', [
                ':missingOptions' => implode(', ', $missingOptions)
            ]));
        }

        $job->withDelay($options['delay']);
        Accesor::set($job, 'retries', $options['retries']);
        $job->withMaxRetries($options['maxRetries']);
        $job->withPreferredQueueName($options['preferredQueueName']);
    }
}

1			<?php
2			namespace Workana\AsyncJobs\Normalizer;
3
4			use InvalidArgumentException;
5			use Workana\AsyncJobs\Job;
6
7			/**
8			* Extracts and hydrates options of base Job, to be used on normalizers
9			*
10			* @author Carlos Frutos <[email protected]>
11			*/
12			trait JobOptionsExtractor
13			{
14			/**
15			* @param Job $job
16			*
17			* @return array Options
18			*/
19			public function extractOptions(Job $job)
20			{
21			return [
22			'delay' => $job->getDelay(),
23			'retries' => $job->getRetries(),
24			'maxRetries' => $job->getMaxRetries(),
25			'preferredQueueName' => $job->getPreferredQueueName(),
26			];
27			}
28
29			/**
30			* @param Job $job
31			* @param array $options
32			*
33			* @return void
34			*/
35			public function hydrateOptions(Job $job, array $options)
36			{
37			$missingOptions = array_diff([
38			'delay',
39			'retries',
40			'maxRetries',
41			'preferredQueueName'
42			], array_keys($options));
43
44			if (!empty($missingOptions)) {
45			throw new InvalidArgumentException(strtr('The following options are missing: :missingOptions', [
46			':missingOptions' => implode(', ', $missingOptions)
47			]));
48			}
49
50			$job->withDelay($options['delay']);
51			Accesor::set($job, 'retries', $options['retries']);
52			$job->withMaxRetries($options['maxRetries']);
53			$job->withPreferredQueueName($options['preferredQueueName']);
54			}
55			}

cfrutos / async-jobs

JobOptionsExtractor::extractOptions() A last analyzed 2016-11-30 11:33 UTC

Complexity

Size

Duplication

Importance

Duplication Side-by-Side

Filter issues like

JobOptionsExtractor::extractOptions() A
last analyzed 2016-11-30 11:33 UTC