cerebrate-project
/
cerebrate
mirror of https://github.com/cerebrate-project/cerebrate
1
0
Fork 0
Code Issues Releases Wiki Activity

chg: [outboxProcessors:brood] Gracefully catch server errors on remote broods

pull/93/head
Sami Mokaddem 2022-01-24 17:36:12 +01:00
parent 244db2112c
commit 670c5abaae
No known key found for this signature in database
GPG Key ID: 164C473F627A06FA
1 changed files with 8 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
libraries/default/OutboxProcessors/BroodsOutboxProcessor.php
View File

@ -110,6 +110,14 @@ class ResendFailedMessageProcessor extends BroodsOutboxProcessor implements Gene
$dataSent = $outboxRequest->data['sent']; $dataSent = $outboxRequest->data['sent'];
$response = $this->Broods->sendRequest($brood, $url, true, $dataSent); $response = $this->Broods->sendRequest($brood, $url, true, $dataSent);
$jsonReply = $response->getJson(); $jsonReply = $response->getJson();
if (is_null($jsonReply)) {
$jsonReply = [
'success' => false,
'errors' => [
__('Brood returned an invalid JSON.')
]
];
}
$success = !empty($jsonReply['success']); $success = !empty($jsonReply['success']);
$messageSuccess = __('Message successfully sent to `{0}`', $brood->name); $messageSuccess = __('Message successfully sent to `{0}`', $brood->name);
$messageFail = __('Could not send message to `{0}`.', $brood->name); $messageFail = __('Could not send message to `{0}`.', $brood->name);