Da\Mailer\Queue\Backend\Sqs\SqsQueueStoreConnection

Complexity

Total Complexity

4

Size/Duplication

Total Lines	41
Duplicated Lines	0 %

Test Coverage

Coverage

100%

Importance

Changes	3
Bugs	0	Features	1

3 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	3	1
A	getInstance()	0	7	2
A	connect()	0	12	1

<?php

namespace Da\Mailer\Queue\Backend\Sqs;

use Aws\Sqs\SqsClient;
use Da\Mailer\Queue\Backend\AbstractQueueStoreConnection;

class SqsQueueStoreConnection extends AbstractQueueStoreConnection
{
    /**
     * SqsQueueStoreConnection constructor.
     *
     * @param array $configuration
     */
    public function __construct(array $configuration = [])
    {
        parent::__construct($configuration);
    }

    /**
     * @return $this
     */
    public function connect()
    {
        $this->disconnect();
        $key = $this->getConfigurationValue('key');
        $secret = $this->getConfigurationValue('secret');
        $region = $this->getConfigurationValue('region');
        $this->instance = new SqsClient([
            'key' => $key,
            'secret' => $secret,
            'region' => $region,
        ]);
        return $this;
    }

    /**
     * Returns the connection instance.
     *
     * @return SqsClient
     */
    public function getInstance()
    {
        if ($this->instance === null) {
            $this->connect();
        }

        return $this->instance;
    }
}