Cutlery/invoiceninja
1
0
Fork 0
mirror of https://github.com/invoiceninja/invoiceninja.git synced 2025-07-09 03:14:30 -04:00
Code Issues Packages Projects Releases Wiki Activity

Fixes for Emailer to use the appropriate backoff()

Browse Source
This commit is contained in:
David Bomba 2023-01-29 14:32:00 +11:00
parent a896faf0bf
commit 94a84dfb15
1 changed files with 22 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

30
app/Services/Email/EmailMailer.php
View File

@ -64,6 +64,7 @@ class EmailMailer implements ShouldQueue
public function handle(): void public function handle(): void
{ {
MultiDB::setDb($this->email_service->company->db); MultiDB::setDb($this->email_service->company->db);
/* Perform final checks */ /* Perform final checks */
@ -97,10 +98,8 @@ class EmailMailer implements ShouldQueue
} catch (\Exception | \RuntimeException | \Google\Service\Exception $e) { } catch (\Exception | \RuntimeException | \Google\Service\Exception $e) {
nlog("error failed with {$e->getMessage()}"); nlog("Mailer failed with {$e->getMessage()}");
$this->cleanUpMailers();
$message = $e->getMessage(); $message = $e->getMessage();
/** /**
@ -117,17 +116,32 @@ class EmailMailer implements ShouldQueue
$message = $message_body->Message; $message = $message_body->Message;
nlog($message); nlog($message);
} }
$this->fail();
$this->cleanUpMailers();
return;
}
//only report once, not on all tries
if($this->attempts() == $this->tries)
{
/* If the is an entity attached to the message send a failure mailer */
$this->entityEmailFailed($message);
/* Don't send postmark failures to Sentry */
if(Ninja::isHosted() && (!$e instanceof ClientException))
app('sentry')->captureException($e);
} }
/* If the is an entity attached to the message send a failure mailer */
$this->entityEmailFailed($message);
/* Don't send postmark failures to Sentry */ /* Releasing immediately does not add in the backoff */
if(Ninja::isHosted() && (!$e instanceof ClientException)) $this->release($this->backoff()[$this->attempts()-1]);
app('sentry')->captureException($e);
$message = null; $message = null;
$this->cleanUpMailers();
} }