Swm\Bundle\MailHookBundle\ApiService\SesApiService

Complexity

Total Complexity

10

Size/Duplication

Total Lines	63
Duplicated Lines	9.52 %

Coupling/Cohesion

Components	1
Dependencies	3

Importance

Changes	1
Bugs	0	Features	0

1 Method

Rating	Name	Duplication	Size	Complexity
D	bind()	6	43	10

<?php

namespace Swm\Bundle\MailHookBundle\ApiService;

use Swm\Bundle\MailHookBundle\Hook\DefaultHook;
use Swm\Bundle\MailHookBundle\SwmMailHookEvent;

class SesApiService extends BaseApiService
{
    private $eventAssoc = [
        'permanent_bounce'    => SwmMailHookEvent::MAILHOOK_HARDBOUNCE,
        'transient_bounce'    => SwmMailHookEvent::MAILHOOK_SOFTBOUNCE,
        'undetermined_bounce' => SwmMailHookEvent::MAILHOOK_SOFTBOUNCE,
        'spam_complaint'      => SwmMailHookEvent::MAILHOOK_SPAM,
        'delivery'            => SwmMailHookEvent::MAILHOOK_SEND,
    ];

    const SNS_BOUNCE    = 'Bounce';
    const SNS_COMPLAINT = 'Complaint';
    const SNS_DELIVERY  = 'Delivery';

    /**
     * @throws \Exception
     *
     * @return array<HookInterface>
     */
    public function bind()
    {
        $metaData = json_decode($this->request->getContent(), true);

        if (isset($params['Type']) && $metaData['Type'] == 'SubscriptionConfirmation') {

The variable $params seems to never exist, and therefore isset should always return false. Did you maybe rename this variable?

            throw new \Exception('AWS SNS Require a subscription confirmation: '.$metaData['SubscribeURL']);
        }

        if (!isset($metaData['Message'])) {
            throw new \Exception('Could not find data');
        }

        $sesMessage = json_decode($metaData['Message'], true);

        $hooks = [];

        switch ($sesMessage['notificationType']) {
            case self::SNS_BOUNCE:
                $event = strtolower($sesMessage['bounce']['bounceType']).'_bounce';
                foreach ($sesMessage['bounce']['bouncedRecipients'] as $recipient) {

This code seems to be duplicated across your project.

                    $hooks[] = new DefaultHook($event, $recipient['emailAddress'], 'ses', $sesMessage, $this->eventAssoc[$event]);
                }

                break;
            case self::SNS_COMPLAINT:
                $event = 'spam_complaint';
                foreach ($sesMessage['complaint']['complainedRecipients'] as $recipient) {

This code seems to be duplicated across your project.

                    $hooks[] = new DefaultHook($event, $recipient['emailAddress'], 'ses', $sesMessage, $this->eventAssoc[$event]);
                }

                break;
            case self::SNS_DELIVERY:
                $event = 'delivery';
                foreach ($sesMessage['delivery']['recipients'] as $recipient) {
                    $hooks[] = new DefaultHook($event, $recipient, 'ses', $sesMessage, $this->eventAssoc[$event]);
                }

                break;
            default:
        }

        return $hooks;
    }
}