<?php
|
namespace JVBase\integrations;
|
|
if (!defined('ABSPATH')) {
|
exit;
|
}
|
|
trait Requests
|
{
|
protected bool $hasRequests = true;
|
/**
|
* Child classes must set this (e.g. 'https://api.example.com/v1/')
|
*/
|
protected ?string $baseUrl = null;
|
protected int $ttl = 300; //5 minutes default
|
|
/**
|
* Child classes define their auth headers (Bearer token, API key, etc.)
|
*/
|
abstract protected function getRequestHeaders(): array;
|
|
/**
|
* Child classes inspect the wp_remote_request response,
|
* decode it, and handle/log errors as needed
|
*/
|
abstract protected function handleResponse(array|\WP_Error $response, string $method, string $endpoint): array;
|
|
public function getRequest(string $endpoint, array $data = [], bool $force = false, ?int $ttl = null): array
|
{
|
$key = [$this->service_name, $this->userID, $endpoint, $data];
|
if (!$force) {
|
$cached = $this->cache->get($key);
|
if ($cached) {
|
return $cached;
|
}
|
}
|
$response = $this->makeRequest('GET', $endpoint, $data);
|
|
if ($response && !is_wp_error($response)) {
|
$ttl = is_int($ttl) ? $ttl : $this->ttl;
|
$this->cache->set($key, $response, $ttl);
|
}
|
|
return $response;
|
}
|
|
public function postRequest(string $endpoint, array $data = []): array
|
{
|
return $this->makeRequest('POST', $endpoint, $data);
|
}
|
|
public function putRequest(string $endpoint, array $data = []): array
|
{
|
return $this->makeRequest('PUT', $endpoint, $data);
|
}
|
|
public function deleteRequest(string $endpoint, array $data = []): array
|
{
|
return $this->makeRequest('DELETE', $endpoint, $data);
|
}
|
|
protected function makeRequest(string $method, string $endpoint, array $data = []): array
|
{
|
if (is_null($this->baseUrl)) {
|
error_log('Can not make request. No $baseUrl set for '.$this->service_name);
|
return [];
|
}
|
if ($this->requestLimiter && !$this->awaitRateLimit($endpoint)) {
|
$error = new \WP_Error('rate_limit_exceeded', "Rate limit exceeded for {$endpoint}");
|
return $this->handleResponse($error, $method, $endpoint);
|
}
|
|
$url = rtrim($this->baseUrl, '/') . '/' . ltrim($endpoint, '/');
|
|
$args = [
|
'method' => $method,
|
'headers' => $this->getRequestHeaders(),
|
'timeout' => 15,
|
];
|
|
if (!empty($data)) {
|
if (in_array($method, ['GET', 'DELETE'], true)) {
|
$url = add_query_arg($data, $url);
|
} else {
|
$args['body'] = wp_json_encode($data);
|
}
|
}
|
|
$response = wp_remote_request($url, $args);
|
|
$this->requestLimiter?->recordRequest($endpoint);
|
|
return $this->handleResponse($response, $method, $endpoint);
|
}
|
|
/**
|
* Waits (with jitter) for the rate limit to clear, up to a few attempts.
|
* Returns false if still limited after max attempts.
|
*/
|
protected function awaitRateLimit(string $endpoint, int $maxAttempts = 3): bool
|
{
|
$attempts = 0;
|
|
while (!$this->requestLimiter->checkRateLimit($endpoint)) {
|
$attempts++;
|
if ($attempts >= $maxAttempts) {
|
return false;
|
}
|
usleep(random_int(250_000, 750_000)); // 250-750ms jitter
|
}
|
|
return true;
|
}
|
}
|
