mirror of
https://github.com/nextcloud/app_api.git
synced 2026-01-13 20:19:21 +00:00
eea14dc504
The system flag and extra table for that `ex_app_users` is removed to optimize database usage and simplify the system logic. --------- Signed-off-by: Andrey Borysenko <andrey18106x@gmail.com>
73 lines
2.2 KiB
PHP
73 lines
2.2 KiB
PHP
<?php
|
|
|
|
declare(strict_types=1);
|
|
|
|
namespace OCA\AppAPI\Command\ExApp;
|
|
|
|
use OCA\AppAPI\Service\AppAPIService;
|
|
use OCA\AppAPI\Service\ExAppService;
|
|
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 Notify extends Command {
|
|
public function __construct(
|
|
private AppAPIService $service,
|
|
private ExAppService $exAppService,
|
|
) {
|
|
parent::__construct();
|
|
}
|
|
|
|
protected function configure(): void {
|
|
$this->setName('app_api:app:notify');
|
|
$this->setDescription('Notify ExApp about internal event');
|
|
$this->setHidden(true);
|
|
$this->addArgument('appid', InputArgument::REQUIRED);
|
|
$this->addArgument('route', InputArgument::REQUIRED);
|
|
$this->addOption('user-id', null, InputOption::VALUE_REQUIRED, 'User ID');
|
|
$this->addOption('event-json', null, InputOption::VALUE_REQUIRED, 'Event JSON payload');
|
|
}
|
|
|
|
protected function execute(InputInterface $input, OutputInterface $output): int {
|
|
$appId = $input->getArgument('appid');
|
|
|
|
$exApp = $this->exAppService->getExApp($appId);
|
|
if ($exApp === null) {
|
|
$output->writeln(sprintf('ExApp %s not found. Failed to notify.', $appId));
|
|
return 1;
|
|
}
|
|
|
|
$eventJson = $input->getOption('event-json');
|
|
if ($eventJson === null) {
|
|
$output->writeln('Event JSON payload is required');
|
|
return 1;
|
|
}
|
|
|
|
$eventJsonData = json_decode($eventJson, true);
|
|
if ($eventJsonData === null) {
|
|
$output->writeln('Invalid JSON payload');
|
|
return 1;
|
|
}
|
|
|
|
$route = $input->getArgument('route');
|
|
$userId = $input->getOption('user-id');
|
|
$response = $this->service->requestToExApp($exApp, $route, $userId, params: $eventJsonData,
|
|
options: ['timeout' => 2]);
|
|
if (is_array($response) && isset($response['error'])) {
|
|
$output->writeln(sprintf('Failed to notify ExApp %s: %s', $appId, $response['error']));
|
|
return 1;
|
|
}
|
|
|
|
if ($response->getStatusCode() !== 200) {
|
|
$output->writeln(sprintf('Failed to notify ExApp %s: %s', $appId, $response->getBody()));
|
|
return 1;
|
|
}
|
|
|
|
$output->writeln(sprintf('ExApp %s notified about event: %s', $appId, $eventJson));
|
|
|
|
return 0;
|
|
}
|
|
}
|