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

feat: add Response object

Browse source
This commit is contained in:
Victor Westerlund 2023-10-02 11:48:44 +02:00
parent 47cee961d1
commit e67a59fa53
1 changed files with 14 additions and 18 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

32
src/Reflect/Client.php
View file

@ -2,15 +2,11 @@
namespace Reflect; namespace Reflect;
// Allowed HTTP verbs use Reflect\Method;
enum Method: string { use Reflect\Response;
case GET = "GET";
case POST = "POST"; require_once "Method.php";
case PUT = "PUT"; require_once "Response.php";
case DELETE = "DELETE";
case PATCH = "PATCH";
case OPTIONS = "OPTIONS";
}
// Supported connection methods // Supported connection methods
enum Connection { enum Connection {
@ -37,7 +33,7 @@
const SOCKET_READ_BYTES = 2048; const SOCKET_READ_BYTES = 2048;
public function __construct(string $endpoint, string $key = null, Connection $con = null, bool $https_peer_verify = true) { 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 ?: self::resolve_connection($endpoint);
$this->endpoint = $endpoint; $this->endpoint = $endpoint;
$this->key = $key; $this->key = $key;
@ -65,7 +61,7 @@
private static function resolve_method(Method|string $method): Method { private static function resolve_method(Method|string $method): Method {
return ($method instanceof Method) return ($method instanceof Method)
? $method ? $method
: Method::tryFrom($method) ?? (__CLASS__)::HTTP_DEFAULT_METHOD; : Method::tryFrom($method) ?? self::HTTP_DEFAULT_METHOD;
} }
// Construct stream_context_create() compatible header string // Construct stream_context_create() compatible header string
@ -83,9 +79,9 @@
} }
// Make request and return response over HTTP // Make request and return response over HTTP
private function http_call(string $endpoint, Method|string $method = (__CLASS__)::HTTP_DEFAULT_METHOD, array $payload = null): array { private function http_call(string $endpoint, Method|string $method = self::HTTP_DEFAULT_METHOD, array $payload = null): array {
// Resolve string to enum // Resolve string to enum
$method = $this::resolve_method($method); $method = self::resolve_method($method);
// Remove leading "/" if present, as it's already present in $this->endpoint // Remove leading "/" if present, as it's already present in $this->endpoint
$endpoint = substr($endpoint, 0, 1) !== "/" ? $endpoint : substr($endpoint, 1, strlen($endpoint) - 1); $endpoint = substr($endpoint, 0, 1) !== "/" ? $endpoint : substr($endpoint, 1, strlen($endpoint) - 1);
@ -110,13 +106,13 @@
$resp_code = (int) explode(" ", $http_response_header[0])[1]; $resp_code = (int) explode(" ", $http_response_header[0])[1];
// Return response as [<http_status_code>, <resp_body_assoc_array>] // Return response as [<http_status_code>, <resp_body_assoc_array>]
return [$resp_code, json_decode($resp, true)]; return [$resp_code, $resp];
} }
// 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, $this::SOCKET_READ_BYTES); $rx = socket_read($this->_socket, self::SOCKET_READ_BYTES);
if (!$tx || !$rx) { if (!$tx || !$rx) {
throw new \Error("Failed to complete transaction"); throw new \Error("Failed to complete transaction");
@ -126,9 +122,9 @@
} }
// Call a Reflect endpoint and return response as assoc array // Call a Reflect endpoint and return response as assoc array
public function call(string $endpoint, Method|string $method = (__CLASS__)::HTTP_DEFAULT_METHOD, array $payload = null): array { public function call(string $endpoint, Method|string $method = self::HTTP_DEFAULT_METHOD, array $payload = null): Response {
// Resolve string to enum // Resolve string to enum
$method = $this::resolve_method($method); $method = self::resolve_method($method);
// Call endpoint over UNIX socket // Call endpoint over UNIX socket
if ($this->con === Connection::AF_UNIX) { if ($this->con === Connection::AF_UNIX) {
@ -144,6 +140,6 @@
} }
// Call endpoint over HTTP // Call endpoint over HTTP
return $this->http_call(...func_get_args()); return new Response($this->http_call(...func_get_args()));
} }
} }