Fetch-átvitel
Az alapértelmezett fetch() a Phasis-ben a PHP ext-curl megoldásán fut: CURLOPT_FOLLOWLOCATION=false (a specifikáció szerinti átirányítási ciklus a Phasis oldalán fut), miközben a CURLOPT_PROGRESSFUNCTION ellenőrzi a AbortSignal-t. A legtöbb beágyazásnál ez megfelelő.
Minden más esetben — például proxyk, egyéni DNS, a gazdaalkalmazás meglévő HTTP kliense, hálózati homokozó vagy tesztbeli szimulálás esetén — az átviteli mód cserélhető.
A felület
public function setFetchTransport(callable $transport): void
A hívható elem a következőket kapja:
function (array $request, ?\Phasis\Value\JsObject $signal): array
A $request asszociatív tömb:
| Kulcs | Típus | Megjegyzések |
|---|---|---|
method |
string |
Már nagybetűs (GET, POST, …) |
url |
string |
A URL feldolgozása és az átirányítási lánc után feloldott abszolút URL |
headers |
list<list<string>> |
[name, value] párok; kis- és nagybetűzés a specifikáció szerinti normalizálással; a többször előforduló értékek külön párok (például Set-Cookie) |
body |
string |
Nyers bájtok. Törzs nélküli metódusoknál üres karakterlánc. |
redirect |
string |
"follow" / "error" / "manual" (az átviteli módnak NEM szabad követnie őket — az átirányítási ciklus a Phasis-ben fut) |
timeout |
int |
Valós idejű keret milliszekundumban. A 0 azt jelenti: nincs korlát. |
credentials |
string |
"omit" / "same-origin" / "include" — tájékoztató jellegű; a cookie-k bekötése külön, a setCookieJar() segítségével történik. |
A $signal értéke null, ha a kéréshez nem tartozott jel; ellenkező esetben olyan JsObject, amely elérhetővé teszi az aborted és az reason értékét. Hosszú átvitelek közben rendszeresen ellenőrizze.
A visszatérési érték formája:
return [
'status' => 200, // int
'statusText' => 'OK', // string
'headers' => [['content-type', 'text/plain'], ['x-custom', '1']],
'body' => '...response bytes...', // string
];
Ha az átviteli mód kivételt dob, a Phasis elkapja és lefordítja:
- Egy
Phasis\BuiltIn\Fetch\TransportExceptiona$e->kind === "aborted"értékkel → afetchAbortError DOMException-mal utasítja el a kérést. - A
kind === "timeout"→TypeError, az üzenettel együtt. - A
kind === "network-error"(alapértelmezés) →TypeError. - Minden más esetben →
TypeErrora kivétel üzenetével.
Kidolgozott példák
Guzzle
use GuzzleHttp\Client;
use GuzzleHttp\Exception\GuzzleException;
$client = new Client(['allow_redirects' => false]);
$engine->setFetchTransport(function (array $req, $signal) use ($client) {
try {
$r = $client->request($req['method'], $req['url'], [
'headers' => collect($req['headers'])->groupBy(0)->map->pluck(1)->all(),
'body' => $req['body'],
'timeout' => max(1, $req['timeout'] / 1000.0),
'http_errors' => false,
]);
} catch (GuzzleException $e) {
throw new \Phasis\BuiltIn\Fetch\TransportException($e->getMessage(), 'network-error');
}
$headers = [];
foreach ($r->getHeaders() as $name => $values) {
foreach ($values as $v) {
$headers[] = [$name, $v];
}
}
return [
'status' => $r->getStatusCode(),
'statusText' => $r->getReasonPhrase(),
'headers' => $headers,
'body' => (string) $r->getBody(),
];
});
Symfony HttpClient
use Symfony\Component\HttpClient\HttpClient;
$client = HttpClient::create(['max_redirects' => 0]);
$engine->setFetchTransport(function (array $req, $signal) use ($client) {
$headers = [];
foreach ($req['headers'] as [$name, $value]) {
$headers[$name][] = $value;
}
$r = $client->request($req['method'], $req['url'], [
'headers' => $headers,
'body' => $req['body'],
'timeout' => $req['timeout'] / 1000.0,
'max_redirects'=> 0,
]);
return [
'status' => $r->getStatusCode(),
'statusText' => '',
'headers' => collect($r->getHeaders(false))
->flatMap(fn ($values, $name) => array_map(fn ($v) => [$name, $v], $values))
->values()->all(),
'body' => $r->getContent(false),
];
});
Mindent tiltó mód
$engine->setFetchTransport(function () {
throw new \Phasis\BuiltIn\Fetch\TransportException(
'network access disabled in this sandbox',
'network-error',
);
});
Ezzel minden fetch() hívás TypeError hibával utasítódik el. Hasznos a felhasználó által megadott JS kód homokozóba zárásához.
Tesztbeli szimuláció
$canned = [
'https://api.example.com/users' => ['status' => 200, 'body' => '{"users":[]}'],
'https://api.example.com/404' => ['status' => 404, 'body' => 'not found'],
];
$engine->setFetchTransport(function (array $req) use ($canned) {
$r = $canned[$req['url']] ?? ['status' => 500, 'body' => 'no mock'];
return [
'status' => $r['status'],
'statusText' => $r['status'] === 200 ? 'OK' : 'ERR',
'headers' => [['content-type', 'application/json']],
'body' => $r['body'],
];
});
A házirend-hook
Az átviteli mód végrehajtja a kérést; a házirend-hook dönti el, hogy egyáltalán végrehajtható-e. Használja HTTPS-alapú szabályozáshoz, fejléc beszúrásához, URL átírásához, engedélyezési listákhoz vagy bérlőnként eltérő hitelesítő adatok kötéséhez.
public function setFetchPolicy(callable $hook): void
A hook aláírása: function (JsObject $request): ?JsObject. A null visszaadása változatlanul engedélyezi a kérést. A Request visszaadása átírja. A kivételdobás a fetch elutasítását eredményezi a dobott hibával.
$allowedHosts = ['api.example.com', 'cdn.example.com'];
$engine->setFetchPolicy(function ($req) use ($allowedHosts) {
$url = parse_url($req->get('url')->value);
if (!in_array($url['host'] ?? '', $allowedHosts, true)) {
throw new \RuntimeException("host not allowed: " . ($url['host'] ?? ''));
}
// Inject internal-only auth header
$req->get('headers')->call('set', 'X-Internal-Token', $secret);
return null;
});
A házirend-hook az átviteli mód előtt fut — így még egy hibás vagy nem megbízható átviteli mód sem tudja megkerülni.
Az alapértelmezett viselkedés összefoglalása
| Tényező | Alapértelmezés |
|---|---|
| Átviteli mód | CurlTransport (PHP ext-curl) |
| Átirányítások | Követés legfeljebb 20 alkalommal a specifikáció szerint. A redirect: "manual" az átirányított Response választ adja vissza type: "opaqueredirect" értékkel. |
| Időkorlát | 30 s valós idő, 10 s csatlakozás |
| TLS ellenőrzése | CURLOPT_SSL_VERIFYPEER = true (nem kapcsolható ki — az átviteli mód cseréjével írható felül) |
| User-Agent | A Phasis/0.1 csak akkor kerül be, ha még nincs beállítva |
| Cookie-k | Nincs tárolva. Az engedélyezéshez használja a setCookieJar() elemet. |
| Házirend-hook | Nincs. Minden kérés engedélyezett, kivéve, ha kifejezetten letiltják. |
| AbortSignal | Az átvitel közben a curl előrehaladási visszahívásának ellenőrzésével érvényesül. |
Lásd még
- API referencia — Fetch-hookok — rövid aláírási referencia.
- Webes API-k — a teljes Fetch csomag felülete.
- Cookie-tár — cookie-k megőrzése a fetch-hívások között PHP vagy JS tárolóobjektummal.