kiri-core/HttpServer/Client/Http2.php

<?php
declare(strict_types=1);

namespace HttpServer\Client;


use Exception;
use HttpServer\Http\Context;
use Snowflake\Abstracts\Component;
use Snowflake\Core\Help;
use Snowflake\Core\JSON;
use Swoole\Http2\Request;
use \Swoole\Coroutine\Http2\Client as H2Client;


/**
 * Class Http2
 * @package HttpServer\Client
 */
class Http2 extends Component
{

	/**
	 * @param $domain
	 * @param $path
	 * @param array $params
	 * @param int $timeout
	 * @return mixed
	 * @throws Exception
	 */
	public function get($domain, $path, $params = [], $timeout = -1)
	{
		$client = $this->getClient($domain, $path, $timeout);
		$client->send($this->getRequest($domain, $path, 'GET', $params));
		return new Result(['code' => 0, 'data' => Help::toArray($client->recv())]);
	}


	/**
	 * @param $domain
	 * @param $path
	 * @param array $params
	 * @param int $timeout
	 * @return mixed
	 * @throws Exception
	 */
	public function post($domain, $path, $params = [], $timeout = -1)
	{
		$client = $this->getClient($domain, $path, $timeout);
		$client->send($this->getRequest($domain, $path, 'POST', $params));
		return new Result(['code' => 0, 'data' => Help::toArray($client->recv())]);
	}


	/**
	 * @param $domain
	 * @param $path
	 * @param array $params
	 * @param int $timeout
	 * @return mixed
	 * @throws Exception
	 */
	public function delete($domain, $path, $params = [], $timeout = -1)
	{
		$client = $this->getClient($domain, $path, $timeout);
		$client->send($this->getRequest($domain, $path, 'DELETE', $params));
		return new Result(['code' => 0, 'data' => Help::toArray($client->recv())]);
	}


	/**
	 * @param $domain
	 * @param $path
	 * @param array $params
	 * @param int $timeout
	 * @return mixed
	 * @throws Exception
	 */
	public function put($domain, $path, $params = [], $timeout = -1)
	{
		$client = $this->getClient($domain, $path, $timeout);
		$client->send($this->getRequest($domain, $path, 'PUT', $params));
		return new Result(['code' => 0, 'data' => Help::toArray($client->recv())]);
	}


	/**
	 * @param $domain
	 * @param $path
	 * @param $method
	 * @param $params
	 * @return Request
	 * @throws Exception
	 */
	public function getRequest($domain, $path, $method, $params)
	{
		if (Context::hasContext($domain . $path)) {
			$req = Context::getContext($domain . $path);
		} else {
			$req = new Request();
			$req->method = $method;
			$req->path = $path;
			$req->headers = [
				'host'            => $domain,
				'user-agent'      => 'Chrome/49.0.2587.3',
				'accept'          => 'text/html,application/json',
				'accept-encoding' => 'gzip'
			];
			if (!is_string($params)) {
				$params = JSON::encode($params);
			}
			Context::setContext($domain . $path, $req);
		}
		$req->data = $params;
		return $req;
	}


	/**
	 * @param $domain
	 * @param $path
	 * @param int $timeout
	 * @return H2Client
	 * @throws Exception
	 */
	private function getClient($domain, $path, $timeout = -1)
	{
		if (Context::hasContext($domain)) {
			return Context::getContext($domain);
		}
		$client = new H2Client($domain, 443, true);
		$client->set([
			'timeout'       => $timeout,
			'ssl_host_name' => $domain
		]);
		if (!$client->connect()) {
			throw new Exception('Connected fail.');
		}

		return Context::setContext($domain, $client);
	}


}