* * @author Morris Jobke * * @license GNU AGPL version 3 or any later version * * This program is free software: you can redistribute it and/or modify * it under the terms of the GNU Affero General Public License as * published by the Free Software Foundation, either version 3 of the * License, or (at your option) any later version. * * 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 * along with this program. If not, see . * */ namespace OCA\Talk\Controller; use OCA\Talk\DataObjects\AccountId; use OCA\Talk\DataObjects\RegisterAccountData; use OCA\Talk\Exceptions\HostedSignalingServerAPIException; use OCA\Talk\Exceptions\HostedSignalingServerInputException; use OCA\Talk\Service\HostedSignalingServerService; use OCP\AppFramework\Http; use OCP\AppFramework\Http\Attribute\PublicPage; use OCP\AppFramework\Http\DataResponse; use OCP\AppFramework\OCSController; use OCP\Http\Client\IClientService; use OCP\IConfig; use OCP\IL10N; use OCP\IRequest; use Psr\Log\LoggerInterface; class HostedSignalingServerController extends OCSController { protected IClientService $clientService; protected IL10N $l10n; protected IConfig $config; protected LoggerInterface $logger; private HostedSignalingServerService $hostedSignalingServerService; public function __construct( string $appName, IRequest $request, IClientService $clientService, IL10N $l10n, IConfig $config, LoggerInterface $logger, HostedSignalingServerService $hostedSignalingServerService, ) { parent::__construct($appName, $request); $this->clientService = $clientService; $this->l10n = $l10n; $this->config = $config; $this->logger = $logger; $this->hostedSignalingServerService = $hostedSignalingServerService; } #[PublicPage] public function auth(): DataResponse { $storedNonce = $this->config->getAppValue('spreed', 'hosted-signaling-server-nonce', ''); // reset nonce after one request $this->config->deleteAppValue('spreed', 'hosted-signaling-server-nonce'); if ($storedNonce !== '') { return new DataResponse([ 'nonce' => $storedNonce, ]); } return new DataResponse([], Http::STATUS_PRECONDITION_FAILED); } public function requestTrial(string $url, string $name, string $email, string $language, string $country): DataResponse { try { $registerAccountData = new RegisterAccountData( $url, $name, $email, $language, $country ); $accountId = $this->hostedSignalingServerService->registerAccount($registerAccountData); $accountInfo = $this->hostedSignalingServerService->fetchAccountInfo($accountId); $this->config->setAppValue('spreed', 'hosted-signaling-server-account', json_encode($accountInfo)); } catch (HostedSignalingServerAPIException $e) { // API or connection issues return new DataResponse(['message' => $e->getMessage()], Http::STATUS_INTERNAL_SERVER_ERROR); } catch (HostedSignalingServerInputException $e) { // user solvable issues return new DataResponse(['message' => $e->getMessage()], Http::STATUS_BAD_REQUEST); } return new DataResponse($accountInfo); } public function deleteAccount(): DataResponse { $accountId = $this->config->getAppValue('spreed', 'hosted-signaling-server-account-id'); if ($accountId === null) { return new DataResponse(['message' => $this->l10n->t('No account available to delete.')], Http::STATUS_BAD_REQUEST); } try { $this->hostedSignalingServerService->deleteAccount(new AccountId($accountId)); $this->config->deleteAppValue('spreed', 'hosted-signaling-server-account'); $this->config->deleteAppValue('spreed', 'hosted-signaling-server-account-id'); // remove signaling servers if account is not active anymore $this->config->deleteAppValue('spreed', 'signaling_mode'); $this->config->deleteAppValue('spreed', 'signaling_servers'); $this->logger->info('Deleted hosted signaling server account with ID ' . $accountId); } catch (HostedSignalingServerAPIException $e) { // API or connection issues return new DataResponse(['message' => $e->getMessage()], Http::STATUS_INTERNAL_SERVER_ERROR); } return new DataResponse([], Http::STATUS_NO_CONTENT); } }