<?php
class CSocServOAuthTransport
{
	const SERVICE_ID = "generic";

	protected $appID;
	protected $appSecret;
	protected $code = false;
	protected $access_token = false;
	protected $accessTokenExpires = 0;
	protected $refresh_token = '';

	protected $scope = array();

	protected $userId;

	public function __construct($appID, $appSecret, $code = false)
	{
		global $USER;

		$this->httpTimeout = SOCSERV_DEFAULT_HTTP_TIMEOUT;
		$this->appID = $appID;
		$this->appSecret = $appSecret;
		$this->code = $code;

		if(is_object($USER) && $USER->IsAuthorized())
		{
			$this->userId = $USER->GetID();
		}
	}

	public function getAppID()
	{
		return $this->appID;
	}

	public function getAppSecret()
	{
		return $this->appSecret;
	}

	public function getAccessTokenExpires()
	{
		return $this->accessTokenExpires;
	}

	public function setAccessTokenExpires($accessTokenExpires)
	{
		$this->accessTokenExpires = $accessTokenExpires;
	}

	public function getToken()
	{
		return $this->access_token;
	}

	public function setToken($access_token)
	{
		$this->access_token = $access_token;
	}

	public function setRefreshToken($refresh_token)
	{
		$this->refresh_token = $refresh_token;
	}

	public function getRefreshToken()
	{
		return $this->refresh_token;
	}

	public function removeScope(string $scope): void
	{
		if (!$this->scope)
		{
			return;
		}

		$this->scope = array_diff($this->scope, [$scope]);
	}

	public function addScope($scope)
	{
		if(is_array($scope))
			$this->scope = array_merge($this->scope, $scope);
		else
			$this->scope[] = $scope;
		return $this;
	}

	public function setScope($scope)
	{
		$this->scope = $scope;
	}

	public function getScope()
	{
		return $this->scope;
	}

	public function getScopeEncode()
	{
		return implode(',', array_map('urlencode', array_unique($this->getScope())));
	}

	public function setCode($code)
	{
		$this->code = $code;
	}

	public function setUser($userId)
	{
		$this->userId = $userId;
	}

	protected function getStorageTokens()
	{
		$accessToken = '';
		if($this->userId > 0)
		{
			$dbSocservUser = \Bitrix\Socialservices\UserTable::getList([
				'filter' => [
					'=USER_ID' => $this->userId,
					"=EXTERNAL_AUTH_ID" => static::SERVICE_ID
				],
				'select' => ["USER_ID", "XML_ID", "OATOKEN", "OATOKEN_EXPIRES", "REFRESH_TOKEN", "PERMISSIONS"]
			]);

			$accessToken = $dbSocservUser->fetch();
		}
		return $accessToken;
	}

	public function deleteStorageTokens()
	{
		if($this->userId > 0)
		{
			$dbSocservUser = \Bitrix\Socialservices\UserTable::getList(array(
				'filter' => array(
					'=USER_ID' => $this->userId,
					"=EXTERNAL_AUTH_ID" => static::SERVICE_ID
				),
				'select' => array("ID")
			));

			while($accessToken = $dbSocservUser->fetch())
			{
				\Bitrix\Socialservices\UserTable::delete($accessToken['ID']);
			}
		}
	}

	public function checkAccessToken()
	{
		return (($this->accessTokenExpires - 30) < time()) ? false : true;
	}

	public function getResult()
	{
		return array();
	}

	protected function getDecodedJson($url, $postData = null)
	{
		$http = new \Bitrix\Main\Web\HttpClient([
			'socketTimeout' => $this->httpTimeout,
			'streamTimeout' => $this->httpTimeout,
		]);

		if (isset($postData))
		{
			$postResult = $http->post($url, $postData);
		}
		else
		{
			$postResult = $http->get($url);
		}

		try
		{
			$decodedResult = \Bitrix\Main\Web\Json::decode($postResult);
		}
		catch (\Bitrix\Main\ArgumentException $e)
		{
			if (defined("BX_SOCIALSERVICES_ERROR_DEBUG"))
			{
				AddMessage2Log([
					'post_url' => $http->getEffectiveUrl(),
					'result_status' => $http->getStatus(),
					'result_error' => $http->getError(),
					'result_text' => $http->getResult(),
				], 'socialservices', 40);
			}
			$decodedResult = [];
		}

		return $decodedResult;
	}
}