ShiftOneLabs\LaravelSqsFifoQueue\Queue\Connectors\SqsFifoConnector::connect()

Complexity

Conditions	4
Paths	3

Size

Total Lines	28
Code Lines	18

Duplication

Lines	0
Ratio	0 %

Code Coverage

Tests	20
CRAP Score	4

Importance

Changes	2
Bugs	0	Features	0

<?php
    public function connect(array $config)
    {
        $config = $this->getDefaultConfiguration($config);

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

        if (!empty($config['key']) && !empty($config['secret'])) {
            $config['credentials'] = Arr::only($config, ['key', 'secret', 'token']);
        }

        // Pull the custom config options out of the config array sent to SqsClient.
        $group = Arr::pull($config, 'group', 'default');
        $deduplicator = Arr::pull($config, 'deduplicator', 'unique');
        $allowDelay = (bool)Arr::pull($config, 'allow_delay', false);

        return new SqsFifoQueue(
            new SqsClient(
                Arr::except($config, ['token'])
            ),
            $config['queue'],
            $config['prefix'] ?? '',
            $config['suffix'] ?? '',
            (bool)($config['after_commit'] ?? null),
            $group,
            $deduplicator,
            $allowDelay
        );