1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
|
<?php
declare(strict_types=1);
/**
* SPDX-FileCopyrightText: 2024 Nextcloud GmbH and Nextcloud contributors
* SPDX-License-Identifier: AGPL-3.0-or-later
*/
namespace OCA\UpdateNotification\BackgroundJob;
use OCA\UpdateNotification\AppInfo\Application;
use OCA\UpdateNotification\Manager;
use OCP\App\IAppManager;
use OCP\AppFramework\Services\IAppConfig;
use OCP\AppFramework\Utility\ITimeFactory;
use OCP\BackgroundJob\QueuedJob;
use OCP\IConfig;
use OCP\IUser;
use OCP\IUserManager;
use OCP\Notification\IManager;
use OCP\Notification\INotification;
use Psr\Log\LoggerInterface;
class AppUpdatedNotifications extends QueuedJob {
public function __construct(
ITimeFactory $time,
private IConfig $config,
private IAppConfig $appConfig,
private IManager $notificationManager,
private IUserManager $userManager,
private IAppManager $appManager,
private LoggerInterface $logger,
private Manager $manager,
) {
parent::__construct($time);
}
/**
* @param array{appId: string, timestamp: int} $argument
*/
protected function run(mixed $argument): void {
$appId = $argument['appId'];
$timestamp = $argument['timestamp'];
$dateTime = $this->time->getDateTime();
$dateTime->setTimestamp($timestamp);
$this->logger->debug(
'Running background job to create app update notifications for "' . $appId . '"',
[
'app' => Application::APP_NAME,
],
);
if ($this->manager->getChangelogFile($appId, 'en') === null) {
$this->logger->debug('Skipping app updated notification - no changelog provided');
return;
}
$this->stopPreviousNotifications($appId);
// Create new notifications
$notification = $this->notificationManager->createNotification();
$notification->setApp(Application::APP_NAME)
->setDateTime($dateTime)
->setSubject('app_updated', [$appId])
->setObject('app_updated', $appId);
$this->notifyUsers($appId, $notification);
}
/**
* Stop all previous notifications users might not have dismissed until now
* @param string $appId The app to stop update notifications for
*/
private function stopPreviousNotifications(string $appId): void {
$notification = $this->notificationManager->createNotification();
$notification->setApp(Application::APP_NAME)
->setObject('app_updated', $appId);
$this->notificationManager->markProcessed($notification);
}
/**
* Notify all users for which the updated app is enabled
*/
private function notifyUsers(string $appId, INotification $notification): void {
$guestsEnabled = $this->appConfig->getAppValueBool('app_updated.notify_guests', false) && class_exists('\OCA\Guests\UserBackend');
$isDefer = $this->notificationManager->defer();
// Notify all seen users about the app update
$this->userManager->callForSeenUsers(function (IUser $user) use ($guestsEnabled, $appId, $notification): void {
if (!$guestsEnabled && ($user->getBackendClassName() === '\OCA\Guests\UserBackend')) {
return;
}
if (!$this->appManager->isEnabledForUser($appId, $user)) {
return;
}
$notification->setUser($user->getUID());
$this->notificationManager->notify($notification);
});
// If we enabled the defer we call the flush
if ($isDefer) {
$this->notificationManager->flush();
}
}
}
|
