|
1
|
|
|
<?php |
|
2
|
|
|
|
|
3
|
|
|
namespace Swm\Bundle\MailHookBundle\ApiService; |
|
4
|
|
|
|
|
5
|
|
|
use Swm\Bundle\MailHookBundle\Hook\DefaultHook; |
|
6
|
|
|
use Swm\Bundle\MailHookBundle\SwmMailHookEvent; |
|
7
|
|
|
|
|
8
|
|
|
class SesApiService extends BaseApiService |
|
9
|
|
|
{ |
|
10
|
|
|
private $eventAssoc = [ |
|
11
|
|
|
'permanent_bounce' => SwmMailHookEvent::MAILHOOK_HARDBOUNCE, |
|
12
|
|
|
'transient_bounce' => SwmMailHookEvent::MAILHOOK_SOFTBOUNCE, |
|
13
|
|
|
'undetermined_bounce' => SwmMailHookEvent::MAILHOOK_SOFTBOUNCE, |
|
14
|
|
|
'spam_complaint' => SwmMailHookEvent::MAILHOOK_SPAM, |
|
15
|
|
|
'delivery' => SwmMailHookEvent::MAILHOOK_SEND, |
|
16
|
|
|
]; |
|
17
|
|
|
|
|
18
|
|
|
const SNS_BOUNCE = 'Bounce'; |
|
19
|
|
|
const SNS_COMPLAINT = 'Complaint'; |
|
20
|
|
|
const SNS_DELIVERY = 'Delivery'; |
|
21
|
|
|
|
|
22
|
|
|
protected $mailerManager; |
|
23
|
|
|
|
|
24
|
|
|
public function __construct($mailerManager) |
|
25
|
|
|
{ |
|
26
|
|
|
$this->mailerManager = $mailerManager; |
|
27
|
|
|
} |
|
28
|
|
|
|
|
29
|
|
|
/** |
|
30
|
|
|
* @throws \Exception |
|
31
|
|
|
* |
|
32
|
|
|
* @return array<HookInterface> |
|
33
|
|
|
*/ |
|
34
|
|
|
public function bind() |
|
35
|
|
|
{ |
|
36
|
|
|
$metaData = json_decode($this->request->getContent(), true); |
|
37
|
|
|
|
|
38
|
|
|
if (isset($params['Type']) && $metaData['Type'] == 'SubscriptionConfirmation') { |
|
|
|
|
|
|
39
|
|
|
throw new \Exception('AWS SNS Require a subscription confirmation: '.$metaData['SubscribeURL']); |
|
40
|
|
|
} |
|
41
|
|
|
|
|
42
|
|
|
if (!isset($metaData['Message'])) { |
|
43
|
|
|
throw new \Exception('Could not find data'); |
|
44
|
|
|
} |
|
45
|
|
|
|
|
46
|
|
|
$sesMessage = json_decode($metaData['Message'], true); |
|
47
|
|
|
|
|
48
|
|
|
$hooks = []; |
|
49
|
|
|
|
|
50
|
|
|
switch ($sesMessage['notificationType']) { |
|
51
|
|
|
case self::SNS_BOUNCE: |
|
52
|
|
|
$event = strtolower($sesMessage['bounce']['bounceType']).'_bounce'; |
|
53
|
|
View Code Duplication |
foreach ($sesMessage['bounce']['bouncedRecipients'] as $recipient) { |
|
|
|
|
|
|
54
|
|
|
$hooks[] = new DefaultHook($event, $recipient['emailAddress'], 'ses', $sesMessage, $this->eventAssoc[$event]); |
|
55
|
|
|
} |
|
56
|
|
|
|
|
57
|
|
|
break; |
|
58
|
|
|
case self::SNS_COMPLAINT: |
|
59
|
|
|
$event = 'spam_complaint'; |
|
60
|
|
View Code Duplication |
foreach ($sesMessage['complaint']['complainedRecipients'] as $recipient) { |
|
|
|
|
|
|
61
|
|
|
$hooks[] = new DefaultHook($event, $recipient['emailAddress'], 'ses', $sesMessage, $this->eventAssoc[$event]); |
|
62
|
|
|
} |
|
63
|
|
|
|
|
64
|
|
|
break; |
|
65
|
|
|
case self::SNS_DELIVERY: |
|
66
|
|
|
$event = 'delivery'; |
|
67
|
|
|
foreach ($sesMessage['delivery']['recipients'] as $recipient) { |
|
68
|
|
|
$hooks[] = new DefaultHook($event, $recipient, 'ses', $sesMessage, $this->eventAssoc[$event]); |
|
69
|
|
|
} |
|
70
|
|
|
|
|
71
|
|
|
break; |
|
72
|
|
|
default: |
|
73
|
|
|
} |
|
74
|
|
|
|
|
75
|
|
|
return $hooks; |
|
76
|
|
|
} |
|
77
|
|
|
} |
|
78
|
|
|
|
ScullWM /
MailHookBundle
Loading history...
This check looks for calls to
isset(...)orempty()on variables that are yet undefined. These calls will always produce the same result and can be removed.This is most likely caused by the renaming of a variable or the removal of a function/method parameter.