From a86df7b374d9c3f72da519ff6215b99442d2099b Mon Sep 17 00:00:00 2001
From: David Bomba <turbo124@gmail.com>
Date: Tue, 16 Jan 2024 17:02:50 +1100
Subject: [PATCH] Completed webhook management from Mailgunb

---
 app/Jobs/Mailgun/ProcessMailgunWebhook.php | 81 +++++++++++++++++-----
 1 file changed, 62 insertions(+), 19 deletions(-)

diff --git a/app/Jobs/Mailgun/ProcessMailgunWebhook.php b/app/Jobs/Mailgun/ProcessMailgunWebhook.php
index 1411635e41..5b7182ecc2 100644
--- a/app/Jobs/Mailgun/ProcessMailgunWebhook.php
+++ b/app/Jobs/Mailgun/ProcessMailgunWebhook.php
@@ -116,11 +116,11 @@ class ProcessMailgunWebhook implements ShouldQueue
         switch ($this->request['event-data']['event']) {
             case 'delivered':
                 return $this->processDelivery();
-            case 'Bounce':
+            case 'failed':
                 return $this->processBounce();
             case 'complained':
                 return $this->processSpamComplaint();
-            case 'Open':
+            case 'opened':
                 return $this->processOpen();
             default:
                 # code...
@@ -177,14 +177,28 @@ class ProcessMailgunWebhook implements ShouldQueue
         $this->invitation->opened_date = now();
         $this->invitation->save();
 
-        SystemLogger::dispatch(
-            $this->request,
-            SystemLog::CATEGORY_MAIL,
-            SystemLog::EVENT_MAIL_OPENED,
-            SystemLog::TYPE_WEBHOOK_RESPONSE,
-            $this->invitation->contact->client,
-            $this->invitation->company
-        );
+        $sl = $this->getSystemLog($this->request['MessageID']);
+
+        /** Prevents Gmail tracking from firing inappropriately */
+        if($this->request['signature']['timestamp'] < $sl->log['signature']['timestamp'] + 3)
+            return;
+
+        $event = [
+            'bounce_id' => '',
+            'recipient' => $this->request['event-data']['recipient'] ?? '',
+            'status' => $this->request['event-data']['event'] ?? '',
+            'delivery_message' => collect($this->request['event-data']['client-info'])->implode(" ") ?? '',
+            'server' => collect($this->request['event-data']['geolocation'])->implode(" - ") ??  '',
+            'server_ip' => $this->request['event-data']['ip'] ?? '',
+            'date' => \Carbon\Carbon::parse($this->request['event-data']['timestamp'])->format('Y-m-d H:i:s') ?? '',
+        ];
+
+        if($sl) {
+            $data = $sl->log;
+            $data['history']['events'][] = $event;
+            $this->updateSystemLog($sl, $data);
+        }
+
     }
 
 /*
@@ -344,13 +358,29 @@ class ProcessMailgunWebhook implements ShouldQueue
 
         $bounce = new EmailBounce(
             $this->request['event-data']['tags'][0],
-            $this->request['From'],
-            $this->request['MessageID']
+            $this->request['event-data']['envelope']['sender'],
+            $this->message_id
         );
 
         LightLogs::create($bounce)->queue();
 
-        SystemLogger::dispatch($this->request, SystemLog::CATEGORY_MAIL, SystemLog::EVENT_MAIL_BOUNCED, SystemLog::TYPE_WEBHOOK_RESPONSE, $this->invitation->contact->client, $this->invitation->company);
+        $sl = $this->getSystemLog($this->message_id);
+
+        $event = [
+            'bounce_id' => $this->request['event-data']['id'],
+            'recipient' => $this->request['event-data']['recipient'] ?? '',
+            'status' => $this->request['event-data']['event'] ?? '',
+            'delivery_message' => $this->request['event-data']['delivery-status']['description'] ?? $this->request['event-data']['delivery-status']['message'] ?? '',
+            'server' => $this->request['event-data']['delivery-status']['mx-host'] ??  '',
+            'server_ip' => $this->request['event-data']['envelope']['sending-ip'] ?? '',
+            'date' => \Carbon\Carbon::parse($this->request['event-data']['timestamp'])->format('Y-m-d H:i:s') ?? '',
+        ];
+
+        if($sl) {
+            $data = $sl->log;
+            $data['history']['events'][] = $event;
+            $this->updateSystemLog($sl, $data);
+        }
 
     }
 
@@ -402,17 +432,30 @@ class ProcessMailgunWebhook implements ShouldQueue
 
         $spam = new EmailSpam(
             $this->request['event-data']['tags'][0],
-            $this->request['From'],
-            $this->request['MessageID']
+            $this->request['event-data']['message']['headers']['from'],
+            $this->message_id
         );
 
         LightLogs::create($spam)->queue();
 
-        SystemLogger::dispatch($this->request, SystemLog::CATEGORY_MAIL, SystemLog::EVENT_MAIL_SPAM_COMPLAINT, SystemLog::TYPE_WEBHOOK_RESPONSE, $this->invitation->contact->client, $this->invitation->company);
+        $sl = $this->getSystemLog($this->message_id);
 
-        if (config('ninja.notification.slack')) {
-            $this->invitation->company->notification(new EmailSpamNotification($this->invitation->company->account))->ninja();
+        $event = [
+            'bounce_id' => '',
+            'recipient' => $this->request['event-data']['recipient'] ?? '',
+            'status' => $this->request['event-data']['event'] ?? '',
+            'delivery_message' => 'Spam Complaint',
+            'server' => '',
+            'server_ip' => $this->request['event-data']['envelope']['sending-ip'] ?? '',
+            'date' => \Carbon\Carbon::parse($this->request['event-data']['timestamp'])->format('Y-m-d H:i:s') ?? '',
+        ];
+
+        if($sl) {
+            $data = $sl->log;
+            $data['history']['events'][] = $event;
+            $this->updateSystemLog($sl, $data);
         }
+
     }
 
     private function discoverInvitation($message_id)
@@ -470,7 +513,7 @@ class ProcessMailgunWebhook implements ShouldQueue
         $recipients = $this->request['event-data']['recipient'] ?? '';
 
         return [
-            'bounce_id' => $this->request['event-data']['id'] ?? '',
+            'bounce_id' => '',
             'recipient' => $recipients,
             'status' => $this->request['event-data']['event'] ?? '',
             'delivery_message' => $this->request['event-details']['delivery-status']['description'] ?? $this->request['event-details']['delivery-status']['message'] ?? '',