Gateway::startSession() - Code Metrics - nextcloud/twofactor_gateway - Measure and Improve Code Quality continuously with Scrutinizer

Gateway::startSession() A
last analyzed 2025-09-28 01:55 UTC

↳ Parent: Gateway
Complexity

Conditions	1
Paths	1
Size

Total Lines	7
Code Lines	6
Duplication

Lines	0
Ratio	0 %
Code Coverage

Tests	0
CRAP Score	2
Importance

Changes	1
Bugs	0	Features	1
Metric	Value
eloc	6
dl	0
loc	7
ccs	0
cts	7
cp	0
rs	10
c	1
b	0
f	1
cc	1
nc	1
nop	0
crap	2
<?php

declare(strict_types=1);

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

namespace OCA\TwoFactorGateway\Provider\Channel\WhatsApp;

use GuzzleHttp\Exception\ClientException;
filter:
    dependency_paths: ["lib/*"]
use GuzzleHttp\Exception\RequestException;
filter:
    dependency_paths: ["lib/*"]
use GuzzleHttp\Exception\ServerException;
filter:
    dependency_paths: ["lib/*"]
use OCA\TwoFactorGateway\Exception\ConfigurationException;
use OCA\TwoFactorGateway\Exception\MessageTransmissionException;
use OCA\TwoFactorGateway\Provider\Gateway\AGateway;
use OCA\TwoFactorGateway\Vendor\BaconQrCode\Renderer\PlainTextRenderer;
filter:
    dependency_paths: ["lib/*"]
use OCA\TwoFactorGateway\Vendor\BaconQrCode\Writer;
filter:
    dependency_paths: ["lib/*"]
use OCP\Http\Client\IClient;
use OCP\Http\Client\IClientService;
use OCP\IAppConfig;
use OCP\IConfig;
use OCP\IL10N;
use Psr\Log\LoggerInterface;
use Symfony\Component\Console\Cursor;
use Symfony\Component\Console\Helper\QuestionHelper;
use Symfony\Component\Console\Input\InputInterface;
use Symfony\Component\Console\Output\OutputInterface;
use Symfony\Component\Console\Question\Question;

/**
 * @method string getBaseUrl()
 * @method static setBaseUrl(string $baseUrl)
 */
class Gateway extends AGateway {
	public const SCHEMA = [
		'name' => 'WhatsApp',
		'allow_markdown' => true,
		'fields' => [
			['field' => 'base_url', 'prompt' => 'Base URL to your WhatsApp API endpoint:'],
		],
	];
	private string $instanceId;
	private IClient $client;
	private string $lazyBaseUrl = '';
	public function __construct(
		public IAppConfig $appConfig,
		private IConfig $config,
		private IClientService $clientService,
		private LoggerInterface $logger,
		private IL10N $l10n,
	) {
		parent::__construct($appConfig);
		$this->instanceId = $this->config->getSystemValue('instanceid');
		$this->client = $this->clientService->newClient();
	}

	#[\Override]
	public function send(string $identifier, string $message, array $extra = []): void {
		$this->logger->debug("sending whatsapp message to $identifier, message: $message");

		$response = $this->getSessionStatus();
		if ($response !== 'CONNECTED') {
			throw new MessageTransmissionException('WhatsApp session is not connected. Current status: ' . $response);
		}

		$chatId = $this->getChatIdFromPhoneNumber($identifier);

		try {
			$response = $this->client->post($this->getBaseUrl() . '/client/sendMessage/' . $this->instanceId, [

				'json' => [
					'chatId' => $chatId,
					'contentType' => 'string',
					'content' => $message,
					'options' => [],
				],
			]);
		} catch (\Exception $e) {
			$this->logger->error('Could not send WhatsApp message', [
				'identifier' => $identifier,
				'exception' => $e,
			]);
			throw new MessageTransmissionException();
		}

		$this->logger->debug("whatsapp message to chat $identifier sent");
	}

	#[\Override]
	public function cliConfigure(InputInterface $input, OutputInterface $output): int {
		$helper = new QuestionHelper();
		$baseUrlQuestion = new Question(self::SCHEMA['fields'][0]['prompt'] . ' ');
		$this->lazyBaseUrl = $helper->ask($input, $output, $baseUrlQuestion);
		$this->lazyBaseUrl = rtrim($this->lazyBaseUrl, '/');

		try {
			if ($this->getSessionQr($output) === 1) {
				return 1;
			}
		} catch (\Exception $e) {
			$output->writeln('<error>' . $e->getMessage() . '</error>');
		}

		$this->setBaseUrl($this->lazyBaseUrl);
		$this->setBaseUrl(/** @scrutinizer ignore-type */ $this->lazyBaseUrl);

		return 0;
	}

	private function getChatIdFromPhoneNumber(string $phoneNumber): string {
		try {
			$response = $this->client->post($this->getBaseUrl() . '/client/getNumberId/' . $this->instanceId, [
				'json' => [
					'number' => preg_replace('/\D/', '', $phoneNumber),
				],
			]);
			$json = $response->getBody();
			$data = json_decode($json, true);
			$data = json_decode(/** @scrutinizer ignore-type */ $json, true);
			if (empty($data['result'])) {
				throw new MessageTransmissionException('The phone number is not registered on WhatsApp.');
			}
			return $data['result']['_serialized'];
		} catch (ServerException $e) {
			$content = $e->getResponse()?->getBody()?->getContents();
			if ($content === null) {
				throw new MessageTransmissionException('Unknown error');
			}
			$errorMessage = json_decode($content, true)['error'] ?? 'Unknown error';
			throw new MessageTransmissionException($errorMessage);
		}
	}

	/**
	 * @throws ConfigurationException
	 */
	public function getBaseUrl(): string {
		if ($this->lazyBaseUrl !== '') {
			return $this->lazyBaseUrl;
		}

		/** @var string */
		$this->lazyBaseUrl = $this->__call(__FUNCTION__, []);

		return $this->lazyBaseUrl;

	}

	private function getSessionQr(OutputInterface $output): int {
		$renderer = new PlainTextRenderer(margin: 3);
		$writer = new Writer($renderer);
		$cursor = new Cursor($output);

		if ($this->startSession() === 2) {
			$output->writeln('<info>Session already connected, no need to scan QR code.</info>');
			return 0;
		}

		$last = null;
		while (true) {
			$response = $this->client->get($this->getBaseUrl() . '/session/qr/' . $this->instanceId);
			$json = $response->getBody();
			$data = json_decode($json, true);
			$data = json_decode(/** @scrutinizer ignore-type */ $json, true);
			if ($data['success'] === false) {
				if ($data['message'] === 'qr code not ready or already scanned') {
					$output->writeln('<error>Session not connected yet, waiting...</error>');
					sleep(2);
					continue;
				}
				$output->writeln('<error>' . $data['message'] . '</error>');
				return 1;
			}
			$qrCodeContent = $data['qr'];

			if ($qrCodeContent !== $last) {
				$last = $qrCodeContent;
				$cursor->clearScreen();
				$cursor->moveToPosition(1, 1);

				$output->write($writer->writeString($qrCodeContent));
				$output->writeln('');
				$output->writeln('<info>Please confirm on your phone.</info>');
				$output->writeln('Press Ctrl+C to exit');
			}

			sleep(1);
			if ($this->startSession() === 2) {
				return 0;
			}
		}
		return 0;
	}

	private function getSessionStatus(): string {
		$endpoint = $this->getBaseUrl() . '/session/status/' . $this->instanceId;

		try {
			$response = $this->client->get($endpoint);
			$body = (string)$response->getBody();
			$responseData = json_decode($body, true);

			if (!is_array($responseData)) {
				return 'not_connected';
			}

			if (($responseData['success'] ?? null) === false) {
				$msg = $responseData['message'] ?? '';
				return in_array($msg, ['session_not_found', 'session_not_connected'], true)
					? $msg
					: 'not_connected';
			}

			return (string)($responseData['state'] ?? 'not_connected');
		} catch (ClientException $e) {
			return 'not_connected';
		} catch (RequestException $e) {
			$this->logger->info('Could not connect to ' . $endpoint, ['exception' => $e]);
			throw new \Exception('Could not connect to the WhatsApp API. Please check the URL.', 1);
		}
	}

	/**
	 * @return integer 0 = not connected, 1 = started, 2 = connected
	 */
	private function startSession(): int {
		$status = $this->getSessionStatus();
		return match ($status) {
			'CONNECTED' => 2,
			'session_not_connected' => 0,
			'session_not_found' => $this->getSessionStart(),
			default => 0,
		};
	}

	private function getSessionStart(): int {
		$endpoint = $this->getBaseUrl() . '/session/start/' . $this->instanceId;
		try {
			$this->client->get($endpoint);
		} catch (ClientException $e) {
			return 1;
		} catch (RequestException $e) {
			$this->logger->info('Could not connect to ' . $endpoint, [
				'exception' => $e,
			]);
			throw new \Exception('Could not connect to the WhatsApp API. Please check the URL.', 1);
		}
		return 0;
	}
}

nextcloud / twofactor_gateway

Gateway::startSession() A last analyzed 2025-09-28 01:55 UTC

Complexity

Size

Duplication

Code Coverage

Importance

Duplication Side-by-Side

Filter issues like

Gateway::startSession() A
last analyzed 2025-09-28 01:55 UTC
