mirror of
https://github.com/invoiceninja/invoiceninja.git
synced 2025-10-31 10:17:33 -04:00
283 lines
8.3 KiB
PHP
283 lines
8.3 KiB
PHP
<?php
|
|
/**
|
|
* Invoice Ninja (https://invoiceninja.com).
|
|
*
|
|
* @link https://github.com/invoiceninja/invoiceninja source repository
|
|
*
|
|
* @copyright Copyright (c) 2023. Invoice Ninja LLC (https://invoiceninja.com)
|
|
*
|
|
* @license https://www.elastic.co/licensing/elastic-license
|
|
*/
|
|
|
|
namespace App\Jobs\PostMark;
|
|
|
|
use App\DataMapper\Analytics\Mail\EmailBounce;
|
|
use App\DataMapper\Analytics\Mail\EmailSpam;
|
|
use App\Jobs\Util\SystemLogger;
|
|
use App\Libraries\MultiDB;
|
|
use App\Models\Company;
|
|
use App\Models\CreditInvitation;
|
|
use App\Models\InvoiceInvitation;
|
|
use App\Models\Payment;
|
|
use App\Models\PurchaseOrderInvitation;
|
|
use App\Models\QuoteInvitation;
|
|
use App\Models\RecurringInvoiceInvitation;
|
|
use App\Models\SystemLog;
|
|
use App\Notifications\Ninja\EmailBounceNotification;
|
|
use App\Notifications\Ninja\EmailSpamNotification;
|
|
use App\Utils\Ninja;
|
|
use Illuminate\Bus\Queueable;
|
|
use Illuminate\Contracts\Queue\ShouldQueue;
|
|
use Illuminate\Foundation\Bus\Dispatchable;
|
|
use Illuminate\Queue\InteractsWithQueue;
|
|
use Illuminate\Queue\SerializesModels;
|
|
use Turbo124\Beacon\Facades\LightLogs;
|
|
|
|
class ProcessPostmarkWebhook implements ShouldQueue
|
|
{
|
|
use Dispatchable, InteractsWithQueue, Queueable, SerializesModels;
|
|
|
|
public $tries = 1;
|
|
|
|
private array $request;
|
|
|
|
public $invitation;
|
|
/**
|
|
* Create a new job instance.
|
|
*
|
|
* @param Payment $payment
|
|
* @param $email_builder
|
|
* @param $contact
|
|
* @param $company
|
|
*/
|
|
public function __construct(array $request)
|
|
{
|
|
$this->request = $request;
|
|
}
|
|
|
|
/**
|
|
* Execute the job.
|
|
*
|
|
*
|
|
* @return void
|
|
*/
|
|
public function handle()
|
|
{
|
|
MultiDB::findAndSetDbByCompanyKey($this->request['Tag']);
|
|
|
|
$this->invitation = $this->discoverInvitation($this->request['MessageID']);
|
|
|
|
if (!$this->invitation) {
|
|
return;
|
|
}
|
|
|
|
if (array_key_exists('Details', $this->request)) {
|
|
$this->invitation->email_error = $this->request['Details'];
|
|
}
|
|
|
|
switch ($this->request['RecordType']) {
|
|
case 'Delivery':
|
|
return $this->processDelivery();
|
|
case 'Bounce':
|
|
return $this->processBounce();
|
|
case 'SpamComplaint':
|
|
return $this->processSpamComplaint();
|
|
case 'Open':
|
|
return $this->processOpen();
|
|
default:
|
|
# code...
|
|
break;
|
|
}
|
|
}
|
|
|
|
// {
|
|
// "Metadata": {
|
|
// "example": "value",
|
|
// "example_2": "value"
|
|
// },
|
|
// "RecordType": "Open",
|
|
// "FirstOpen": true,
|
|
// "Client": {
|
|
// "Name": "Chrome 35.0.1916.153",
|
|
// "Company": "Google",
|
|
// "Family": "Chrome"
|
|
// },
|
|
// "OS": {
|
|
// "Name": "OS X 10.7 Lion",
|
|
// "Company": "Apple Computer, Inc.",
|
|
// "Family": "OS X 10"
|
|
// },
|
|
// "Platform": "WebMail",
|
|
// "UserAgent": "Mozilla/5.0 (Macintosh; Intel Mac OS X 10_7_5) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/35.0.1916.153 Safari/537.36",
|
|
// "ReadSeconds": 5,
|
|
// "Geo": {
|
|
// "CountryISOCode": "RS",
|
|
// "Country": "Serbia",
|
|
// "RegionISOCode": "VO",
|
|
// "Region": "Autonomna Pokrajina Vojvodina",
|
|
// "City": "Novi Sad",
|
|
// "Zip": "21000",
|
|
// "Coords": "45.2517,19.8369",
|
|
// "IP": "188.2.95.4"
|
|
// },
|
|
// "MessageID": "00000000-0000-0000-0000-000000000000",
|
|
// "MessageStream": "outbound",
|
|
// "ReceivedAt": "2022-02-06T06:37:48Z",
|
|
// "Tag": "welcome-email",
|
|
// "Recipient": "john@example.com"
|
|
// }
|
|
|
|
private function processOpen()
|
|
{
|
|
$this->invitation->opened_date = now();
|
|
$this->invitation->save();
|
|
|
|
(new SystemLogger(
|
|
$this->request,
|
|
SystemLog::CATEGORY_MAIL,
|
|
SystemLog::EVENT_MAIL_OPENED,
|
|
SystemLog::TYPE_WEBHOOK_RESPONSE,
|
|
$this->invitation->contact->client,
|
|
$this->invitation->company
|
|
))->handle();
|
|
}
|
|
|
|
// {
|
|
// "RecordType": "Delivery",
|
|
// "ServerID": 23,
|
|
// "MessageStream": "outbound",
|
|
// "MessageID": "00000000-0000-0000-0000-000000000000",
|
|
// "Recipient": "john@example.com",
|
|
// "Tag": "welcome-email",
|
|
// "DeliveredAt": "2021-02-21T16:34:52Z",
|
|
// "Details": "Test delivery webhook details",
|
|
// "Metadata": {
|
|
// "example": "value",
|
|
// "example_2": "value"
|
|
// }
|
|
// }
|
|
private function processDelivery()
|
|
{
|
|
$this->invitation->email_status = 'delivered';
|
|
$this->invitation->save();
|
|
|
|
(new SystemLogger(
|
|
$this->request,
|
|
SystemLog::CATEGORY_MAIL,
|
|
SystemLog::EVENT_MAIL_DELIVERY,
|
|
SystemLog::TYPE_WEBHOOK_RESPONSE,
|
|
$this->invitation->contact->client,
|
|
$this->invitation->company
|
|
))->handle();
|
|
}
|
|
|
|
// {
|
|
// "Metadata": {
|
|
// "example": "value",
|
|
// "example_2": "value"
|
|
// },
|
|
// "RecordType": "Bounce",
|
|
// "ID": 42,
|
|
// "Type": "HardBounce",
|
|
// "TypeCode": 1,
|
|
// "Name": "Hard bounce",
|
|
// "Tag": "Test",
|
|
// "MessageID": "00000000-0000-0000-0000-000000000000",
|
|
// "ServerID": 1234,
|
|
// "MessageStream": "outbound",
|
|
// "Description": "The server was unable to deliver your message (ex: unknown user, mailbox not found).",
|
|
// "Details": "Test bounce details",
|
|
// "Email": "john@example.com",
|
|
// "From": "sender@example.com",
|
|
// "BouncedAt": "2021-02-21T16:34:52Z",
|
|
// "DumpAvailable": true,
|
|
// "Inactive": true,
|
|
// "CanActivate": true,
|
|
// "Subject": "Test subject",
|
|
// "Content": "Test content"
|
|
// }
|
|
|
|
private function processBounce()
|
|
{
|
|
$this->invitation->email_status = 'bounced';
|
|
$this->invitation->save();
|
|
|
|
$bounce = new EmailBounce(
|
|
$this->request['Tag'],
|
|
$this->request['From'],
|
|
$this->request['MessageID']
|
|
);
|
|
|
|
LightLogs::create($bounce)->send();
|
|
|
|
(new SystemLogger($this->request, SystemLog::CATEGORY_MAIL, SystemLog::EVENT_MAIL_BOUNCED, SystemLog::TYPE_WEBHOOK_RESPONSE, $this->invitation->contact->client, $this->invitation->company))->handle();
|
|
|
|
// if(config('ninja.notification.slack'))
|
|
// $this->invitation->company->notification(new EmailBounceNotification($this->invitation->company->account))->ninja();
|
|
}
|
|
|
|
// {
|
|
// "Metadata": {
|
|
// "example": "value",
|
|
// "example_2": "value"
|
|
// },
|
|
// "RecordType": "SpamComplaint",
|
|
// "ID": 42,
|
|
// "Type": "SpamComplaint",
|
|
// "TypeCode": 100001,
|
|
// "Name": "Spam complaint",
|
|
// "Tag": "Test",
|
|
// "MessageID": "00000000-0000-0000-0000-000000000000",
|
|
// "ServerID": 1234,
|
|
// "MessageStream": "outbound",
|
|
// "Description": "The subscriber explicitly marked this message as spam.",
|
|
// "Details": "Test spam complaint details",
|
|
// "Email": "john@example.com",
|
|
// "From": "sender@example.com",
|
|
// "BouncedAt": "2021-02-21T16:34:52Z",
|
|
// "DumpAvailable": true,
|
|
// "Inactive": true,
|
|
// "CanActivate": false,
|
|
// "Subject": "Test subject",
|
|
// "Content": "Test content"
|
|
// }
|
|
private function processSpamComplaint()
|
|
{
|
|
$this->invitation->email_status = 'spam';
|
|
$this->invitation->save();
|
|
|
|
$spam = new EmailSpam(
|
|
$this->request['Tag'],
|
|
$this->request['From'],
|
|
$this->request['MessageID']
|
|
);
|
|
|
|
LightLogs::create($spam)->send();
|
|
|
|
(new SystemLogger($this->request, SystemLog::CATEGORY_MAIL, SystemLog::EVENT_MAIL_SPAM_COMPLAINT, SystemLog::TYPE_WEBHOOK_RESPONSE, $this->invitation->contact->client, $this->invitation->company))->handle();
|
|
|
|
if (config('ninja.notification.slack')) {
|
|
$this->invitation->company->notification(new EmailSpamNotification($this->invitation->company->account))->ninja();
|
|
}
|
|
}
|
|
|
|
private function discoverInvitation($message_id)
|
|
{
|
|
$invitation = false;
|
|
|
|
if ($invitation = InvoiceInvitation::where('message_id', $message_id)->first()) {
|
|
return $invitation;
|
|
} elseif ($invitation = QuoteInvitation::where('message_id', $message_id)->first()) {
|
|
return $invitation;
|
|
} elseif ($invitation = RecurringInvoiceInvitation::where('message_id', $message_id)->first()) {
|
|
return $invitation;
|
|
} elseif ($invitation = CreditInvitation::where('message_id', $message_id)->first()) {
|
|
return $invitation;
|
|
} elseif ($invitation = PurchaseOrderInvitation::where('message_id', $message_id)->first()) {
|
|
return $invitation;
|
|
} else {
|
|
return $invitation;
|
|
}
|
|
}
|
|
}
|