reflect/client-php
1
0
Fork 0
mirror of https://codeberg.org/reflect/reflect-client-php.git synced 2025-09-13 17:43:42 +02:00
Code Issues Projects Releases Packages Wiki Activity Actions

wip: 1682609355

Browse source
This commit is contained in:
Victor Westerlund 2023-04-27 17:29:15 +02:00
parent e048bd9eea
commit 1ed156f3d2
1 changed files with 10 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

12
src/Reflect/Client.php
View file

@ -21,8 +21,10 @@
class Client { class Client {
// Use this HTTP method if no method specified to call() // Use this HTTP method if no method specified to call()
const HTTP_DEFAULT_METHOD = Method::GET; const HTTP_DEFAULT_METHOD = Method::GET;
// The amount of bytes to read for each chunk from socket
const SOCKET_READ_BYTES = 2048;
public function __construct(string $endpoint, string $key = null, Connection $con = null) { public function __construct(string $endpoint, string $key = null, Connection $con = null, bool $https_peer_verify = true) {
$this->_con = $con ?: $this::resolve_connection($endpoint); $this->_con = $con ?: $this::resolve_connection($endpoint);
$this->_endpoint = $endpoint; $this->_endpoint = $endpoint;
$this->_key = $key; $this->_key = $key;
@ -34,6 +36,8 @@
} else if ($this->_con === Connection::HTTP) { } else if ($this->_con === Connection::HTTP) {
// Append tailing "/" for HTTP if absent // Append tailing "/" for HTTP if absent
$this->_endpoint = substr($this->_endpoint, -1) === "/" ? $this->_endpoint : $this->_endpoint . "/"; $this->_endpoint = substr($this->_endpoint, -1) === "/" ? $this->_endpoint : $this->_endpoint . "/";
// Flag which enables or disables SSL peer validation (for self-signed certificates)
$this->_https_peer_verify = $https_peer_verify;
} }
} }
@ -79,6 +83,10 @@
"method" => $method->value, "method" => $method->value,
"ignore_errors" => true, "ignore_errors" => true,
"content" => !empty($payload) ? json_encode($payload) : "" "content" => !empty($payload) ? json_encode($payload) : ""
],
"ssl" => [
"verify_peer" => $this->_https_peer_verify,
"allow_self_signed" => !$this->_https_peer_verify
] ]
]); ]);
@ -94,7 +102,7 @@
// Make request and return response over socket // Make request and return response over socket
private function socket_txn(string $payload): string { private function socket_txn(string $payload): string {
$tx = socket_write($this->_socket, $payload, strlen($payload)); $tx = socket_write($this->_socket, $payload, strlen($payload));
$rx = socket_read($this->_socket, 2024); $rx = socket_read($this->_socket, $this::SOCKET_READ_BYTES);
if (!$tx || !$rx) { if (!$tx || !$rx) {
throw new \Error("Failed to complete transaction"); throw new \Error("Failed to complete transaction");