SqsFifoConnector::connect() - Code Metrics - Inspection of "Update scrutinizer config to attempt to use PHP 7...." - shiftonelabs/laravel-sqs-fifo-queue - Measure and Improve Code Quality continuously with Scrutinizer

Passed

Branch — ci-test (6a037c)

by Patrick

created 2018-04-21 01:27 UTC

SqsFifoConnector::connect() A

↳ Parent: SqsFifoConnector

Complexity

Conditions	4
Paths	3

Size

Total Lines	21
Code Lines	13

Duplication

Lines	0
Ratio	0 %

Code Coverage

Tests	13
CRAP Score	4.0378

Importance

Changes

Metric	Value
cc	4
eloc	13
nc	3
nop	1
dl	0
loc	21
ccs	13
cts	15
cp	0.8667
crap	4.0378
rs	9.0534
c	0
b	0
f	0

<?php

namespace ShiftOneLabs\LaravelSqsFifoQueue\Queue\Connectors;

use Aws\Sqs\SqsClient;
use InvalidArgumentException;
use Illuminate\Queue\Connectors\SqsConnector;
use ShiftOneLabs\LaravelSqsFifoQueue\SqsFifoQueue;

class SqsFifoConnector extends SqsConnector
{
    /**
     * Establish a queue connection.
     *
     * @param  array  $config
     *
     * @return \Illuminate\Contracts\Queue\Queue
     */
    public function connect(array $config)
    {
        $config = $this->getDefaultConfiguration($config);

        if (!ends_with($config['queue'], '.fifo')) {
            throw new InvalidArgumentException('FIFO queue name must end in ".fifo"');
        }

        if ($config['key'] && $config['secret']) {
            $config['credentials'] = array_only($config, ['key', 'secret']);
        }

        $group = array_pull($config, 'group', 'default');
        $deduplicator = array_pull($config, 'deduplicator', 'unique');

        return new SqsFifoQueue(
            new SqsClient($config),
            $config['queue'],
            array_get($config, 'prefix', ''),
            $group,
            $deduplicator
        );
    }

    /**
     * Get the default configuration for SQS.
     *
     * @param  array  $config
     *
     * @return array
     */
    protected function getDefaultConfiguration(array $config)
    {
        // Laravel >= 5.1 has the "getDefaultConfiguration" method.
        if (method_exists(get_parent_class(), 'getDefaultConfiguration')) {
            return parent::getDefaultConfiguration($config);
        }

        return array_merge([
            'version' => 'latest',
            'http' => [
                'timeout' => 60,
                'connect_timeout' => 60,
            ],
        ], $config);
    }
}


1		<?php
2
3		namespace ShiftOneLabs\LaravelSqsFifoQueue\Queue\Connectors;
4
5		use Aws\Sqs\SqsClient;
6		use InvalidArgumentException;
7		use Illuminate\Queue\Connectors\SqsConnector;
8		use ShiftOneLabs\LaravelSqsFifoQueue\SqsFifoQueue;
9
10		class SqsFifoConnector extends SqsConnector
11		{
12		/**
13		* Establish a queue connection.
14		*
15		* @param array $config
16		*
17		* @return \Illuminate\Contracts\Queue\Queue
18		*/
19	20	public function connect(array $config)
20		{
21	20	$config = $this->getDefaultConfiguration($config);
22
23	20	if (!ends_with($config['queue'], '.fifo')) {
24	5	throw new InvalidArgumentException('FIFO queue name must end in ".fifo"');
25		}
26
27	15	if ($config['key'] && $config['secret']) {
28		$config['credentials'] = array_only($config, ['key', 'secret']);
29		}
30
31	15	$group = array_pull($config, 'group', 'default');
32	15	$deduplicator = array_pull($config, 'deduplicator', 'unique');
33
34	15	return new SqsFifoQueue(
35	15	new SqsClient($config),
36	15	$config['queue'],
37	15	array_get($config, 'prefix', ''),
38	15	$group,
39	9	$deduplicator
40	6	);
41		}
42
43		/**
44		* Get the default configuration for SQS.
45		*
46		* @param array $config
47		*
48		* @return array
49		*/
50	20	protected function getDefaultConfiguration(array $config)
51		{
52		// Laravel >= 5.1 has the "getDefaultConfiguration" method.
53	20	if (method_exists(get_parent_class(), 'getDefaultConfiguration')) {
54	20	return parent::getDefaultConfiguration($config);
55		}
56
57		return array_merge([
58		'version' => 'latest',
59		'http' => [
60		'timeout' => 60,
61		'connect_timeout' => 60,
62		],
63		], $config);
64		}
65		}
66

shiftonelabs / laravel-sqs-fifo-queue

Branch — ci-test (6a037c)

SqsFifoConnector::connect() A

Complexity

Size

Duplication

Code Coverage

Importance

Duplication Side-by-Side

Filter issues like