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

fix: don't set content-type header with no request body (#11)

Browse source
This commit is contained in:
Victor Westerlund 2024-04-03 14:06:39 +00:00 • committed by GitHub
parent b029c874df
commit 6e35a3f7d8
No known key found for this signature in database
GPG key ID: B5690EEEBB952194
1 changed files with 42 additions and 20 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

62
src/Reflect/Client.php
View file

@ -9,15 +9,17 @@
require_once "Response.php"; require_once "Response.php";
class Client { class Client {
private string $params;
private string $endpoint;
private array $headers = [];
private ?array $payload = null;
protected ?string $key; protected ?string $key;
protected string $base_url; protected string $base_url;
protected bool $https_verify_peer; protected bool $https_verify_peer;
protected string $endpoint;
protected string $params;
public function __construct(string $base_url, string $key = null, bool $verify_peer = true) { public function __construct(string $base_url, string $key = null, bool $verify_peer = true) {
// Optional API key // Set optional API key and Authorization header
$this->key = $key; $this->key = $key;
// Append tailing "/" if absent // Append tailing "/" if absent
@ -34,27 +36,26 @@
// ---- // ----
// Construct stream_context_create() compatible header string // Construct stream_context_create() compatible header string
private function http_headers(): string { private function get_headers(): string {
$headers = ["Content-Type: application/json"]; // Set Authorization header if an API key is used
if ($this->key) {
// Append Authentication header if API key is provided $this->headers["Authorization"] = "Bearer {$this->key}";
if (!empty($this->key)) {
$headers[] = "Authorization: Bearer {$this->key}";
} }
// Append new line chars to each header
$headers = array_map(fn($header): string => $header . "\r\n", $headers); // Construct HTTP headers string from array
$headers = array_map(fn(string $k, string $v): string => "{$k}: {$v}\r\n", array_keys($this->headers), array_values($this->headers));
return implode("", $headers); return implode("", $headers);
} }
// Make request and return response over HTTP // Make request and return response over HTTP
private function http_call(Method $method, array $payload = null): array { private function http_call(Method $method): array {
$context = stream_context_create([ $context = stream_context_create([
"http" => [ "http" => [
"header" => $this->http_headers(), "header" => $this->get_headers(),
"method" => $method->name, "method" => $method->name,
"ignore_errors" => true, "ignore_errors" => true,
"content" => !empty($payload) ? json_encode($payload) : "" "content" => !empty($this->payload) ? json_encode($this->payload) : ""
], ],
"ssl" => [ "ssl" => [
"verify_peer" => $this->https_verify_peer, "verify_peer" => $this->https_verify_peer,
@ -73,6 +74,20 @@
return [$resp, $resp_code]; return [$resp, $resp_code];
} }
// Set request body to be JSON-stringified
private function set_request_body(?array $payload = null): self {
// Unset request body if no payload defined
if (empty($payload)) {
$this->payload = null;
return $this;
}
$this->headers["Content-Type"] = "application/json";
$this->payload = $payload;
return $this;
}
// ---- // ----
// Construct URL search parameters from array if set // Construct URL search parameters from array if set
@ -88,8 +103,10 @@
? $endpoint ? $endpoint
: substr($endpoint, 1, strlen($endpoint) - 1); : substr($endpoint, 1, strlen($endpoint) - 1);
// Reset search parameters // Reset initial values
$this->params(); $this->params();
$this->headers = [];
$this->set_request_body();
return $this; return $this;
} }
@ -102,18 +119,23 @@
} }
public function patch(?array $payload = []): Response { public function patch(?array $payload = []): Response {
return new Response(...$this->http_call(Method::PATCH, $payload)); $this->set_request_body($payload);
return new Response(...$this->http_call(Method::PATCH));
} }
public function put(?array $payload = []): Response { public function put(?array $payload = []): Response {
return new Response(...$this->http_call(Method::PUT, $payload)); $this->set_request_body($payload);
return new Response(...$this->http_call(Method::PUT));
} }
public function post(?array $payload = []): Response { public function post(?array $payload = []): Response {
return new Response(...$this->http_call(Method::POST, $payload)); $this->set_request_body($payload);
return new Response(...$this->http_call(Method::POST));
} }
public function delete(?array $payload = []): Response { public function delete(?array $payload = []): Response {
return new Response(...$this->http_call(Method::DELETE, $payload)); $this->set_request_body($payload);
print_r($this->headers);
return new Response(...$this->http_call(Method::DELETE));
} }
} }