<?php

namespace App\Libraries\MySocket;


use App\Entities\Cloudflare\AuthEntity;
use App\Libraries\CommonLibrary;
use App\Models\Cloudflare\AccountModel;
use App\Models\Cloudflare\AuthModel;
use Cloudflare\API\Adapter\ResponseException;
use GuzzleHttp\Client;
use GuzzleHttp\Exception\RequestException;

abstract class CloudflareSocket extends CommonLibrary
{
	private static int $_request = 0;
	private static int $_request_max = 1000;
	private static int $_request_perpage_max = 700;
	private static int $_request_timewait = 60;

	private $_authModel = null;
	private $_accountModel = null;
	private $_client = null;
	private $_auth_entity = null;
	protected function __construct(AuthEntity $auth_entity)
	{
		parent::__construct();
		$this->_auth_entity = $auth_entity;
		self::$_request_max = getenv("cfmgr.request.max") ?: 1000;
		self::$_request_perpage_max = getenv("cfmgr.request.perpage.max") ?: 700;
		self::$_request_timewait = getenv("cfmgr.request.timewait") ?: 60;
	}
	abstract protected function getArrayByResult($result, array $formDatas = []): array;
	private function getClient(): Client
	{
		if ($this->_client === null) {
			// Guzzle HTTP 클라이언트를 설정하면서 Cloudflare API 토큰 사용
			$this->_client = new Client([
				'base_uri' => 'https://api.cloudflare.com/client/v4/',
				'headers' => [
					'X-Auth-Email' => $this->_auth_entity->getID(), // 인증 토큰 사용
					'X-Auth-Key' => $this->_auth_entity->getAuthKey(), // 인증 토큰 사용
					'Content-Type' => 'application/json',
				],
				'verify' => false  // SSL 인증서 검증을 비활성화
			]);
		}
		return $this->_client;
	}
	final protected function getAuthModel(): AuthModel
	{
		if ($this->_authModel === null) {
			$this->_authModel = new AuthModel();
		}
		return $this->_authModel;
	}
	final protected function getAccountModel(): AccountModel
	{
		if ($this->_accountModel === null) {
			$this->_accountModel = new AccountModel();
		}
		return $this->_accountModel;
	}
	final protected function getRequest(string $method, string $uri, array $datas = [])
	{
		if (!in_array($method, ['get', 'post', 'put', 'patch', 'delete'])) {
			throw new \InvalidArgumentException('Request method must be get, post, put, patch, or delete');
		}
		try {
			$response = $this->getClient()->$method($uri, [
				$method == 'get' ? 'query' : 'json' => $datas,
			]);
			if (self::$_request >= self::$_request_max) {
				log_message('warning', sprintf("--Cloudflare API Call %s초 대기 시작--", self::$_request_timewait));
				sleep(intval(self::$_request_timewait));
				self::$_request = 0;
				log_message('warning', sprintf("--Cloudflare API Call %s초 대기 종료--", self::$_request_timewait));
			}
			self::$_request++;
		} catch (RequestException $err) {
			throw ResponseException::fromRequestException($err);
		}
		return $response;
	}

	final protected function reload_procedure($uri): array
	{
		$page        = 1; //Page는 1부터 시작해야함
		$perpage_max = self::$_request_perpage_max;
		$results     = [];
		do {
			$query = [
				'page'     => $page,
				'per_page' => $perpage_max,
				'match'    => 'all',
			];
			$cf    = $this->getClient()->get($uri, $query);
			$cf    = json_decode($cf->getBody());
			if (!$cf->success) {
				throw new \Exception(__FUNCTION__ . "에서 실패:\n" . var_export($cf, true));
			}
			//Loop 제한 : 한페이지에서 가져온 갯수가 perpage_max보다 적다는것은 더이상 다음페이지기 없으므로 0로 종료시키기 위함
			if (count($cf->result) < $perpage_max) {
				$results = $cf->result;
				$page = 0;
			} else {
				$results = array_merge($results, $cf->result);
				$page++;
			}
		} while (0 < $page);
		return $results;
	}
}