App\YetiForce\ApiClient

Complexity

Total Complexity

22

Size/Duplication

Total Lines	148
Duplicated Lines	0 %

Importance

Changes	1
Bugs	0	Features	0

7 Methods

Rating	Name	Duplication	Size	Complexity
A	getRequestOptions()	0	17	3
A	isWritable()	0	4	4
A	getError()	0	3	1
A	basicValidations()	0	9	4
B	send()	0	34	8
A	getStatusCode()	0	3	1
A	getResponseBody()	0	3	1

<?php
/**
 * YetiForce register file.
 * Modifying this file or functions that affect the footer appearance will violate the license terms!!!
 *
 * @package App
 *
 * @copyright YetiForce S.A.
 * @license   YetiForce Public License 6.5 (licenses/LicenseEN.txt or yetiforce.com)
 * @author    Radosław Skrzypczak <r.skrzypczak@yetiforce.com>
 */

namespace App\YetiForce;

/**
 * YetiForce register class.
 */
final class ApiClient
{
	/** @var string URL */
	public const URL = 'https://api.yetiforce.eu/registrations';

	/** @var string Last error. */
	public ?string $error = null;
	/** @var bool Response result */
	private bool $success;

	/** @var int|null Resopnse code */
	private ?int $responseCode = 0;
	/** @var string Resopnse body */
	private $responseBody;

	/** @var int Total timeout of the request in seconds. */
	private int $timeout = 20;
	/** @var int The number of seconds to wait while trying to connect to a server. */
	private int $connectTimeout = 2;

	/**
	 * Send registration data.
	 *
	 * @param string $url
	 * @param string $method
	 * @param array  $option
	 *
	 * @return bool
	 */
	public function send(string $url, string $method, array $option = []): bool
	{
		$this->error = null;
		$this->success = false;
		$this->basicValidations($url);
		if ($this->error) {
			return $this->success;
		}

		try {
			\App\Log::beginProfile($method . '|' . __METHOD__ . "|{$url}", __NAMESPACE__);
			$response = (new \GuzzleHttp\Client($this->getRequestOptions()))->request($method, $url, $option);

			\App\Log::endProfile($method . '|' . __METHOD__ . "|{$url}", __NAMESPACE__);

			$this->responseCode = $response->getStatusCode();
			$this->responseBody = $response->getBody()->getContents();
			$this->success = true;
		} catch (\GuzzleHttp\Exception\ClientException $e) {
			$this->responseCode = $e->getResponse()->getStatusCode();
			$this->error = $e->getResponse()->getBody()->getContents();
			if (\App\Json::isJson($this->error) && ($error = \App\Json::decode($this->error)['errors'] ?? null)) {
				$this->error = \is_array($error) ? implode(' | ', $error) : $error;
			}
			\App\Log::error($e->getMessage(), __METHOD__);
		} catch (\GuzzleHttp\Exception\ServerException $e) {
			$this->responseCode = $e->getResponse()->getStatusCode();
			$this->error = $this->responseCode . ' Internal Server Error';
			\App\Log::error($e->getMessage(), __METHOD__);
		} catch (\Throwable $e) {
			$this->error = \App\Language::translate("LBL_ERROR");
			\App\Log::error($e->getMessage(), __METHOD__);
		}

		return $this->success;
	}

	/**
	 * Get response status code.
	 *
	 * @return int
	 */
	public function getStatusCode()
	{
		return $this->responseCode;
	}

	/**
	 * Get response content.
	 *
	 * @return mixed
	 */
	public function getResponseBody()
	{
		return $this->responseBody;
	}

	/**
	 * Get last error.
	 *
	 * @return string
	 */
	public function getError(): string
	{
		return $this->error ?? '';
	}

	/**
	 * Get request options.
	 *
	 * @return array
	 */
	public function getRequestOptions(): array
	{
		$headers = [
			'x-crm-id' => \App\Config::main('application_unique_key'),
			'x-app-id' => Register::getInstanceKey(),
			'accept-language' => \App\Language::getLanguage() ?: 'en'
		];
		if ($key = (new Config())->getToken()) {
			$headers['x-api-key'] = $key;
		}

		$options = \App\RequestHttp::getOptions();

		return array_merge($options, [
			'headers' => array_merge($options['headers'] ?? [], $headers),
			'timeout' => $this->timeout,
			'connect_timeout' => $this->connectTimeout
		]);
	}

	/**
	 * Basic validations.
	 *
	 * @param string $url
	 *
	 * @return void
	 */
	private function basicValidations($url)
	{
		$hostName = parse_url($url, PHP_URL_HOST);
		if (!\App\RequestUtil::isNetConnection() || $hostName === gethostbyname($hostName)) {
			\App\Log::warning('ERR_NO_INTERNET_CONNECTION', __METHOD__);
			$this->error = 'ERR_NO_INTERNET_CONNECTION';
		} elseif (!$this->isWritable()) {
			\App\Log::warning('ERR_REGISTER_FILES_PERMISSIONS||app_data', __METHOD__);
			$this->error = 'ERR_REGISTER_FILES_PERMISSIONS||app_data';
		}
	}

	/**
	 * Check write permissions for the registry file.
	 *
	 * @return bool
	 */
	private function isWritable(): bool
	{
		$path = Register::REGISTRATION_FILE;
		return (file_exists($path) && is_writable($path)) || (!file_exists($path) && is_writable(\dirname($path)));
	}
}