wip

src/Events/MailUnsuppressed.php

@@ -0,0 +1,20 @@
+<?php
+
+namespace Vormkracht10\Mails\Events;
+
+use Illuminate\Broadcasting\InteractsWithSockets;
+use Illuminate\Foundation\Events\Dispatchable;
+use Illuminate\Queue\SerializesModels;
+use Vormkracht10\Mails\Models\MailEvent;
+
+class MailUnsuppressed
+{
+    use Dispatchable, InteractsWithSockets, SerializesModels;
+
+    /**
+     * Create a new event instance.
+     */
+    public function __construct(
+        public MailEvent $mailEvent
+    ) {}
+}

src/Listeners/UnsuppressEmailAddress.php

@@ -0,0 +1,11 @@
+<?php
+
+namespace Vormkracht10\Mails\Listeners;
+
+class UnsupsressEmailAddress
+{
+    public function handle(MailUnsuppressed $event): void
+    {
+        $event->mailEvent->update('unsuppressed_at', now());
+    }
+}

src/Models/MailEvent.php

@@ -12,6 +12,7 @@
 use Vormkracht10\Mails\Database\Factories\MailEventFactory;
 use Vormkracht10\Mails\Enums\EventType;
 use Vormkracht10\Mails\Events\MailEventLogged;
+use Vormkracht10\Mails\Events\MailUnsuppressed;
 
 /**
  * @property Mail $mail
@@ -92,7 +93,7 @@ public function mail()
 
     protected function getEventClassAttribute(): string
     {
-        return 'Vormkracht10\Mails\Events\Mail'.Str::studly($this->type->value);
+        return 'Vormkracht10\Mails\Events\Mail' . Str::studly($this->type->value);
     }
 
     public function unSuppress()
@@ -105,7 +106,7 @@ public function unSuppress()
                 ])
                 ->baseUrl('https://api.postmarkapp.com/');
 
-            $response = $client->post('message-streams/'.config('mail.mailers.postmark.stream_id', 'broadcast').'/suppressions/delete', [
+            $response = $client->post('message-streams/' . config('mail.mailers.postmark.stream_id', 'broadcast') . '/suppressions/delete', [
                 'Suppressions' => [
                     [
                         'emailAddress' => key($this->mail->to),
@@ -114,11 +115,10 @@ public function unSuppress()
             ]);
 
             if ($response->successful()) {
-
-                $this->update(['unsuppressed_at' => now()]);
+                event(MailUnsuppressed::class, $mailEvent);
             } else {
 
-                throw new \Exception('Failed to unsuppress email address due to '.$response);
+                throw new \Exception('Failed to unsuppress email address due to ' . $response);
             }
         }
 
@@ -129,11 +129,10 @@ public function unSuppress()
             $response = $mailgun->suppressions()->unsubscribes()->delete(config('services.mailgun.domain'), key($this->mail->to));
 
             if ($response) {
-
-                $this->update(['unsuppressed_at' => now()]);
+                event(MailUnsuppressed::class, $mailEvent);
             } else {
 
-                throw new \Exception('Failed to unsuppress email address due to '.$response);
+                throw new \Exception('Failed to unsuppress email address due to ' . $response);
             }
         }
     }