PeterNijssen\Ses\Manager\SesManager

Complexity

Total Complexity

13

Size/Duplication

Total Lines	153
Duplicated Lines	40.52 %

Coupling/Cohesion

Components	1
Dependencies	5

Test Coverage

Coverage

89.09%

Importance

Changes	1
Bugs	0	Features	0

7 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	5	1
A	verifyDkim()	0	8	1
A	enableDkim()	15	15	2
A	disableDkim()	15	15	2
A	fetchStatus()	16	16	2
A	fetchDkimStatus()	16	16	2
A	fetchDkimRecords()	0	21	3

<?php

namespace PeterNijssen\Ses\Manager;

use Aws\Ses\SesClient;
use PeterNijssen\Ses\Exception\InvalidFetchStatusException;
use PeterNijssen\Ses\Model\Dns;
use PeterNijssen\Ses\Model\IdentityInterface;

/**
 * This service manages AWS SES
 */
abstract class SesManager
{
    /**
     * @var SesClient
     */
    protected $sesClient;

    /**
     * @var IdentityInterface
     */
    protected $identity;

    /**
     * Constructor
     *
     * @param SesClient         $sesClient
     * @param IdentityInterface $identity
     */
    public function __construct(SesClient $sesClient, IdentityInterface $identity)
    {
        $this->sesClient = $sesClient;
        $this->identity = $identity;
    }

    /**
     * Fetch the current status
     *
     * @return string
     *
     * @throws InvalidFetchStatusException
     */
    public function fetchStatus()

This method seems to be duplicated in your project.

    {
        $result = $this->sesClient->getIdentityVerificationAttributes(
            [
                'Identities' => [$this->identity->getIdentity()],
            ]
        );

        $status = $result->search("VerificationAttributes.*.VerificationStatus");

        if (!is_array($status)) {
            throw new InvalidFetchStatusException("unable to fetch the status. Did you create the identity?");
        }

        return current($status);
    }

    /**
     * Fetch the current DKIM status
     *
     * @return string
     *
     * @throws InvalidFetchStatusException
     */
    public function fetchDkimStatus()

This method seems to be duplicated in your project.

    {
        $result = $this->sesClient->getIdentityDkimAttributes(
            [
                'Identities' => [$this->identity->getIdentity()],
            ]
        );

        $status = $result->search("DkimAttributes.*.DkimVerificationStatus");

        if (!is_array($status)) {
            throw new InvalidFetchStatusException("unable to fetch the DKIM status. Did you create the identity?");
        }

        return current($status);
    }

    /**
     * Return the DNS records for the DKIM settings
     *
     * @return array
     */
    public function fetchDkimRecords()
    {
        $result = $this->sesClient->getIdentityDkimAttributes(
            [
                'Identities' => [$this->identity->getIdentity()],
            ]
        );

        $records = [];
        $results = $result->search("DkimAttributes.*.DkimTokens");
        if (is_array($results)) {
            foreach (current($results) as $result) {
                $name = $result."._domainkey.".$this->identity->getDomain();
                $value = $result.".dkim.amazonses.com";

                $records[] = new Dns("CNAME", $name, $value);
            }
        }

        return $records;
    }

    /**
     * Request AWS to verify DKIM
     */
    public function verifyDkim()
    {
        $this->sesClient->verifyDomainDkim(
            [
                'Domain' => $this->identity->getDomain(),
            ]
        );
    }

    /**
     * Request AWS to enable DKIM
     *
     * @return bool
     */
    public function enableDkim()

This method seems to be duplicated in your project.

    {
        try {
            $this->sesClient->setIdentityDkimEnabled(
                [
                    'DkimEnabled' => true,
                    'Identity' => $this->identity->getIdentity(),
                ]
            );

            return true;
        } catch (\Exception $e) {
            return false;
        }
    }

    /**
     * Request AWS To disable DKIM
     *
     * @return bool
     */
    public function disableDkim()

This method seems to be duplicated in your project.

    {
        try {
            $this->sesClient->setIdentityDkimEnabled(
                [
                    'DkimEnabled' => false,
                    'Identity' => $this->identity->getIdentity(),
                ]
            );

            return true;
        } catch (\Exception $e) {
            return false;
        }
    }
}