ShiftOneLabs\LaravelSqsFifoQueue\Queue\Connectors\SqsFifoConnector

Complexity

Total Complexity

6

Size/Duplication

Total Lines	56
Duplicated Lines	0 %

Coupling/Cohesion

Components	0
Dependencies	3

Test Coverage

Coverage

68%

Importance

Changes

0

2 Methods

Rating	Name	Duplication	Size	Complexity
A	getDefaultConfiguration()	0	15	2
B	connect()	0	23	4

<?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);
    }
}