Add SesApiService

ApiService/SesApiService.php

@@ -0,0 +1,70 @@
+<?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') {
+            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) {
+                    $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) {
+                    $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;
+    }
+}

Resources/config/apiService.yml

@@ -36,3 +36,8 @@ services:
         class: "%swm.mail_hook.api_service.sparkpost.class%"
         tags:
             -  { name: swm.mailhook, alias: sparkpost }
+
+    swm.mail_hook.api_service.ses:
+        class: "%swm.mail_hook.api_service.ses.class%"
+        tags:
+            -  { name: swm.mailhook, alias: ses }