Spaces:
Runtime error
Runtime error
File size: 3,968 Bytes
46252cd | 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 97 98 99 100 101 102 103 104 105 106 107 108 109 110 111 112 113 114 115 116 117 118 119 120 121 122 123 124 125 126 127 128 129 | <?php
declare(strict_types=1);
namespace OpenWA\Tests;
use GuzzleHttp\Client as GuzzleClient;
use GuzzleHttp\Handler\MockHandler;
use GuzzleHttp\HandlerStack;
use GuzzleHttp\Middleware;
use GuzzleHttp\Psr7\Response;
use OpenWA\Client as OpenWAClient;
use Psr\Http\Message\RequestInterface;
/**
* A scripted backend for SDK tests.
*
* Uses Guzzle's MockHandler + a history middleware to record every request so
* tests can assert on the exact method, URL, query string, and body — without
* any real network or global state.
*/
class MockBackend
{
private MockHandler $mock;
/** @var array<int,RequestInterface> */
private array $recorded = [];
public function __construct()
{
$this->mock = new MockHandler();
}
/**
* Queue a response for the next matching call.
*
* @param mixed $body JSON-encodable body (omit/null for empty/204).
*/
public function on(int $status = 200, $body = null, array $headers = []): self
{
if ($status === 204 || $body === null) {
$this->mock->append(new Response($status, $headers, ''));
} else {
$headers['Content-Type'] = 'application/json';
$this->mock->append(new Response($status, $headers, json_encode($body) ?: ''));
}
return $this;
}
public function httpClient(): GuzzleClient
{
// Record at the handler layer (innermost). The handler always sees the
// fully-prepared request — host merged from base_uri, JSON body
// serialized, headers applied — unlike history middleware which can run
// before prepare-body. This is the most reliable capture point.
$mock = $this->mock;
$recorded = &$this->recorded;
$recorder = static function (RequestInterface $request, array $options) use ($mock, &$recorded) {
$recorded[] = $request;
return $mock($request, $options);
};
return new GuzzleClient(['handler' => HandlerStack::create($recorder)]);
}
public function makeClient(string $baseUrl = 'http://localhost:2785', string $apiKey = 'owa_k1_test'): OpenWAClient
{
return new OpenWAClient([
'baseUrl' => $baseUrl,
'apiKey' => $apiKey,
'httpClient' => $this->httpClient(),
]);
}
/** @return array<string,mixed> */
public function lastCall(): array
{
return $this->callAt(count($this->recorded) - 1);
}
/**
* @param int $index Zero-based call index.
* @return array<string,mixed>
*/
public function callAt(int $index): array
{
if (!isset($this->recorded[$index])) {
return [];
}
$req = $this->recorded[$index];
$uri = $req->getUri();
$body = (string) $req->getBody();
$decoded = null;
if ($body !== '') {
$tmp = json_decode($body, true);
$decoded = ($tmp === null && json_last_error() !== JSON_ERROR_NONE) ? $body : $tmp;
}
$headerMap = [];
foreach ($req->getHeaders() as $k => $vs) {
$headerMap[strtolower((string) $k)] = $vs[0] ?? '';
}
return [
'method' => $req->getMethod(),
'url' => (string) $uri,
'host' => $uri->getHost(),
'path' => $uri->getPath(),
'query' => $uri->getQuery(),
'body' => $decoded,
'headers' => $headerMap,
];
}
/** @return array<int,array<string,mixed>> */
public function calls(): array
{
$out = [];
for ($i = 0, $n = count($this->recorded); $i < $n; $i++) {
$c = $this->callAt($i);
$out[] = [
'method' => $c['method'],
'url' => $c['url'],
'path' => $c['path'],
'query' => $c['query'],
'body' => $c['body'],
];
}
return $out;
}
}
|