nextcloud/apps/updatenotification/lib/Notification/BackgroundJob.php

221 lines
5.6 KiB
PHP
Raw Normal View History

<?php
/**
* @copyright Copyright (c) 2016, ownCloud, Inc.
2016-07-21 17:49:16 +03:00
*
* @author Joas Schilling <coding@schilljs.com>
*
* @license AGPL-3.0
*
* This code is free software: you can redistribute it and/or modify
* it under the terms of the GNU Affero General Public License, version 3,
* as published by the Free Software Foundation.
*
* This program is distributed in the hope that it will be useful,
* but WITHOUT ANY WARRANTY; without even the implied warranty of
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
* GNU Affero General Public License for more details.
*
* You should have received a copy of the GNU Affero General Public License, version 3,
* along with this program. If not, see <http://www.gnu.org/licenses/>
*
*/
namespace OCA\UpdateNotification\Notification;
use OC\BackgroundJob\TimedJob;
use OC\Installer;
use OC\Updater\VersionCheck;
use OCP\App\IAppManager;
use OCP\Http\Client\IClientService;
use OCP\IConfig;
2016-05-09 10:43:06 +03:00
use OCP\IGroup;
use OCP\IGroupManager;
2016-05-10 12:31:03 +03:00
use OCP\IURLGenerator;
use OCP\IUser;
use OCP\Notification\IManager;
class BackgroundJob extends TimedJob {
/** @var IConfig */
protected $config;
/** @var IManager */
protected $notificationManager;
/** @var IGroupManager */
protected $groupManager;
/** @var IAppManager */
protected $appManager;
/** @var IClientService */
protected $client;
2016-05-10 12:31:03 +03:00
/** @var IURLGenerator */
protected $urlGenerator;
/** @var IUser[] */
protected $users;
/**
* NotificationBackgroundJob constructor.
*
* @param IConfig $config
* @param IManager $notificationManager
* @param IGroupManager $groupManager
* @param IAppManager $appManager
* @param IClientService $client
2016-05-10 12:31:03 +03:00
* @param IURLGenerator $urlGenerator
*/
2016-05-10 12:31:03 +03:00
public function __construct(IConfig $config, IManager $notificationManager, IGroupManager $groupManager, IAppManager $appManager, IClientService $client, IURLGenerator $urlGenerator) {
// Run once a day
$this->setInterval(60 * 60 * 24);
$this->config = $config;
$this->notificationManager = $notificationManager;
$this->groupManager = $groupManager;
$this->appManager = $appManager;
$this->client = $client;
2016-05-10 12:31:03 +03:00
$this->urlGenerator = $urlGenerator;
}
protected function run($argument) {
$this->checkCoreUpdate();
$this->checkAppUpdates();
}
/**
* Check for ownCloud update
*/
protected function checkCoreUpdate() {
2016-05-09 13:04:32 +03:00
if (in_array($this->getChannel(), ['daily', 'git'])) {
// "These aren't the update channels you're looking for." - Ben Obi-Wan Kenobi
return;
}
2016-05-09 13:04:32 +03:00
$updater = $this->createVersionCheck();
$status = $updater->check();
if (isset($status['version'])) {
$url = $this->urlGenerator->linkToRouteAbsolute('settings.AdminSettings.index') . '#updater';
$this->createNotifications('core', $status['version'], $url, $status['versionstring']);
}
}
/**
* Check all installed apps for updates
*/
protected function checkAppUpdates() {
$apps = $this->appManager->getInstalledApps();
foreach ($apps as $app) {
2016-05-09 13:04:32 +03:00
$update = $this->isUpdateAvailable($app);
if ($update !== false) {
2016-05-10 12:31:03 +03:00
$url = $this->urlGenerator->linkToRouteAbsolute('settings.AppSettings.viewApps') . '#app-' . $app;
$this->createNotifications($app, $update, $url);
}
}
}
/**
* Create notifications for this app version
*
* @param string $app
* @param string $version
2016-05-10 12:31:03 +03:00
* @param string $url
* @param string $visibleVersion
*/
protected function createNotifications($app, $version, $url, $visibleVersion = '') {
$lastNotification = $this->config->getAppValue('updatenotification', $app, false);
if ($lastNotification === $version) {
// We already notified about this update
return;
} else if ($lastNotification !== false) {
// Delete old updates
$this->deleteOutdatedNotifications($app, $lastNotification);
}
$notification = $this->notificationManager->createNotification();
$notification->setApp('updatenotification')
->setDateTime(new \DateTime())
->setObject($app, $version)
2016-05-10 12:31:03 +03:00
->setLink($url);
if ($visibleVersion !== '') {
$notification->setSubject('update_available', ['version' => $visibleVersion]);
} else {
$notification->setSubject('update_available');
}
2016-05-09 13:04:32 +03:00
foreach ($this->getUsersToNotify() as $uid) {
$notification->setUser($uid);
$this->notificationManager->notify($notification);
}
$this->config->setAppValue('updatenotification', $app, $version);
}
/**
2016-05-09 13:04:32 +03:00
* @return string[]
*/
protected function getUsersToNotify() {
if ($this->users !== null) {
return $this->users;
}
2016-05-09 13:04:32 +03:00
$notifyGroups = json_decode($this->config->getAppValue('updatenotification', 'notify_groups', '["admin"]'), true);
$this->users = [];
2016-05-09 10:43:06 +03:00
foreach ($notifyGroups as $group) {
$groupToNotify = $this->groupManager->get($group);
if ($groupToNotify instanceof IGroup) {
2016-05-09 13:04:32 +03:00
foreach ($groupToNotify->getUsers() as $user) {
$this->users[$user->getUID()] = true;
}
2016-05-09 10:43:06 +03:00
}
}
2016-05-09 13:04:32 +03:00
$this->users = array_keys($this->users);
return $this->users;
}
/**
* Delete notifications for old updates
*
* @param string $app
* @param string $version
*/
protected function deleteOutdatedNotifications($app, $version) {
$notification = $this->notificationManager->createNotification();
$notification->setApp('updatenotification')
->setObject($app, $version);
$this->notificationManager->markProcessed($notification);
}
2016-05-09 13:04:32 +03:00
/**
* @return VersionCheck
*/
protected function createVersionCheck() {
return new VersionCheck(
$this->client,
$this->config
);
}
/**
* @return string
*/
protected function getChannel() {
return \OC_Util::getChannel();
}
/**
* @param string $app
* @return string|false
*/
protected function isUpdateAvailable($app) {
return Installer::isUpdateAvailable($app);
}
}