VladPolskiy/nextcloud-spreed
1
0
Fork 0
mirror of https://github.com/nextcloud/spreed.git synced 2025-08-16 15:27:59 +00:00
Code Issues Packages Projects Releases Wiki Activity

Retry sending signaling messages up to 3 times

Browse Source 
Signed-off-by: Joas Schilling <coding@schilljs.com>
This commit is contained in:
Joas Schilling
2022-05-13 15:50:10 +02:00
parent a4f3e569e2
commit a8aec629b4
2 changed files with 11 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

11
lib/Signaling/BackendNotifier.php
View File

@ -25,6 +25,7 @@ declare(strict_types=1);
namespace OCA\Talk\Signaling;
use GuzzleHttp\Exception\ServerException;
use OCA\Talk\Config;
use OCA\Talk\Model\Attendee;
use OCA\Talk\Model\Session;
@ -67,9 +68,10 @@ class BackendNotifier {
*
* @param string $url
* @param array $params
* @param int $retries
* @throws \Exception
*/
protected function doRequest(string $url, array $params): void {
protected function doRequest(string $url, array $params, int $retries = 3): void {
if (defined('PHPUNIT_RUN')) {
// Don't perform network requests when running tests.
return;
@ -82,6 +84,13 @@ class BackendNotifier {
if (!$this->signalingManager->isCompatibleSignalingServer($response)) {
throw new \RuntimeException('Signaling server needs to be updated to be compatible with this version of Talk');
}
} catch (ServerException $e) {
if ($retries > 1) {
$this->logger->error('Failed to send message to signaling server, ' . $retries . ' retries left!', ['exception' => $e]);
$this->doRequest($url, $params, $retries - 1);
} else {
$this->logger->error('Failed to send message to signaling server, giving up!', ['exception' => $e]);
}
} catch (\Exception $e) {
$this->logger->error('Failed to send message to signaling server', ['exception' => $e]);
}