mirror of
https://codeberg.org/reflect/reflect-client-php.git
synced 2025-09-13 17:43:42 +02:00
fix: don't set content-type header with no request body
This commit is contained in:
parent
b029c874df
commit
f5f62ad2f0
1 changed files with 42 additions and 20 deletions
|
@ -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));
|
||||||
}
|
}
|
||||||
}
|
}
|
Loading…
Add table
Reference in a new issue