Added logging, removed superfluous comments

This commit is contained in:
Michael 2021-08-16 15:23:34 +00:00
parent c85ce2f6b0
commit 7158b35f58
3 changed files with 15 additions and 10 deletions

View file

@ -19,18 +19,12 @@
* *
*/ */
/**
* @see https://github.com/web-push-libs/web-push-php
* Possibly we should simply use this.
*/
namespace Friendica\Model; namespace Friendica\Model;
use Friendica\Core\Logger; use Friendica\Core\Logger;
use Friendica\Core\Worker; use Friendica\Core\Worker;
use Friendica\Database\DBA; use Friendica\Database\DBA;
use Friendica\DI; use Friendica\DI;
use Friendica\Util\Crypto;
use Minishlink\WebPush\VAPID; use Minishlink\WebPush\VAPID;
class Subscription class Subscription

View file

@ -34,8 +34,19 @@ class PushSubscription
{ {
public static function execute(int $sid, int $nid) public static function execute(int $sid, int $nid)
{ {
Logger::info('Start', ['subscription' => $sid, 'notification' => $nid]);
$subscription = DBA::selectFirst('subscription', [], ['id' => $sid]); $subscription = DBA::selectFirst('subscription', [], ['id' => $sid]);
if (empty($subscription)) {
Logger::info('Subscription not found', ['subscription' => $sid]);
return;
}
$notification = DBA::selectFirst('notification', [], ['id' => $nid]); $notification = DBA::selectFirst('notification', [], ['id' => $nid]);
if (empty($notification)) {
Logger::info('Notification not found', ['notification' => $nid]);
return;
}
if (!empty($notification['uri-id'])) { if (!empty($notification['uri-id'])) {
$notify = DBA::selectFirst('notify', ['msg'], ['uri-id' => $notification['target-uri-id']]); $notify = DBA::selectFirst('notify', ['msg'], ['uri-id' => $notification['target-uri-id']]);
@ -71,7 +82,7 @@ class PushSubscription
], ],
]; ];
$webPush = new WebPush($auth); $webPush = new WebPush($auth, [], DI::config()->get('system', 'xrd_timeout'));
$report = $webPush->sendOneNotification( $report = $webPush->sendOneNotification(
$push['subscription'], $push['subscription'],
@ -81,9 +92,9 @@ class PushSubscription
$endpoint = $report->getRequest()->getUri()->__toString(); $endpoint = $report->getRequest()->getUri()->__toString();
if ($report->isSuccess()) { if ($report->isSuccess()) {
Logger::info('Message sent successfully for subscription', ['endpoint' => $endpoint]); Logger::info('Message sent successfully for subscription', ['subscription' => $sid, 'notification' => $nid, 'endpoint' => $endpoint]);
} else { } else {
Logger::info('Message failed to sent for subscription', ['endpoint' => $endpoint, 'reason' => $report->getReason()]); Logger::info('Message failed to sent for subscription', ['subscription' => $sid, 'notification' => $nid, 'endpoint' => $endpoint, 'reason' => $report->getReason()]);
} }
} }
} }

View file

@ -568,7 +568,7 @@ return [
'worker_defer_limit' => 15, 'worker_defer_limit' => 15,
// xrd_timeout (Integer) // xrd_timeout (Integer)
// Timeout in seconds for fetching the XRD links. // Timeout in seconds for fetching the XRD links and other requests with an expected shorter timeout
'xrd_timeout' => 20, 'xrd_timeout' => 20,
], ],
'experimental' => [ 'experimental' => [