HEX
Server: LiteSpeed
System: Linux d8 4.18.0-553.121.1.lve.el8.x86_64 #1 SMP Thu Apr 30 16:40:41 UTC 2026 x86_64
User: wbwebdes (3015)
PHP: 8.1.31
Disabled: exec,system,passthru,shell_exec,proc_close,proc_open,dl,popen,show_source,posix_kill,posix_mkfifo,posix_getpwuid,posix_setpgid,posix_setsid,posix_setuid,posix_setgid,posix_seteuid,posix_setegid,posix_uname
Upload Files
File: /home/wbwebdes/domains/files.wb-cloud.nl/private_html/apps/notifications/lib/Command/TestPush.php
<?php

declare(strict_types=1);

/**
 * SPDX-FileCopyrightText: 2017 Nextcloud GmbH and Nextcloud contributors
 * SPDX-License-Identifier: AGPL-3.0-or-later
 */

namespace OCA\Notifications\Command;

use OCA\Notifications\App;
use OCP\AppFramework\Utility\ITimeFactory;
use OCP\IUser;
use OCP\IUserManager;
use OCP\Notification\IManager;
use Symfony\Component\Console\Command\Command;
use Symfony\Component\Console\Input\InputArgument;
use Symfony\Component\Console\Input\InputInterface;
use Symfony\Component\Console\Input\InputOption;
use Symfony\Component\Console\Output\OutputInterface;

class TestPush extends Command {
	public function __construct(
		protected ITimeFactory $timeFactory,
		protected IUserManager $userManager,
		protected IManager $notificationManager,
		protected App $app,
	) {
		parent::__construct();
	}

	#[\Override]
	protected function configure(): void {
		$this
			->setName('notification:test-push')
			->setDescription('Generate a notification for the given user')
			->addArgument(
				'user-id',
				InputArgument::REQUIRED,
				'User ID of the user to notify'
			)
			->addOption(
				'talk',
				null,
				InputOption::VALUE_NONE,
				'Test Talk devices'
			)
			->addOption(
				'files',
				null,
				InputOption::VALUE_NONE,
				'Test other devices (Files, Notes, …)'
			)
		;
	}

	#[\Override]
	protected function execute(InputInterface $input, OutputInterface $output): int {
		if (!$this->notificationManager->isFairUseOfFreePushService()) {
			$output->writeln('<error>We want to keep offering our push notification service for free, but large</error>');
			$output->writeln('<error>number of users overload our infrastructure. For this reason we have to rate-limit the</error>');
			$output->writeln('<error>use of push notifications. If you need this feature, consider using Nextcloud Enterprise.</error>');
			return 1;
		}

		$userId = $input->getArgument('user-id');
		$user = $this->userManager->get($userId);
		if (!$user instanceof IUser) {
			$output->writeln('<error>Unknown user</error>');
			return 1;
		}

		if ($input->getOption('talk')) {
			$failed = $this->sendNotification($output, $user, 'talk');
		} else {
			$failed = false;
		}
		if ($input->getOption('files')) {
			$failed = $this->sendNotification($output, $user, 'files') || $failed;
		}
		if (!$input->getOption('talk') && !$input->getOption('files')) {
			$failed = $this->sendNotification($output, $user, 'talk') || $failed;
			$failed = $this->sendNotification($output, $user, 'files') || $failed;
		}

		return $failed ? 1 : 0;
	}

	protected function sendNotification(OutputInterface $output, IUser $user, string $clients): bool {
		$app = $clients === 'talk' ? 'admin_notification_talk' : 'admin_notifications';
		$notification = $this->notificationManager->createNotification();
		$datetime = $this->timeFactory->getDateTime();

		$output->writeln('');
		if ($clients === 'talk') {
			$output->writeln('Testing Talk clients:');
		} else {
			$output->writeln('Testing other clients: Files, Notes, …');
		}

		try {
			$notification->setApp($app)
				->setUser($user->getUID())
				->setDateTime($datetime)
				->setObject('admin_notifications', dechex($datetime->getTimestamp()))
				->setSubject('cli', ['Testing push notifications']);

			$this->app->setOutput($output);
			$this->notificationManager->notify($notification);
		} catch (\InvalidArgumentException) {
			$output->writeln('Error while sending the notification');
			return true;
		}
		return false;
	}
}