TrueAsync\HttpResponse

(PHP 8.6+, true_async_server 0.6+)

Response-Objekt mit Fluent-Interface. Wird als zweiter Parameter an den Handler übergeben. Wird vom Server erzeugt — nicht vom Benutzer konstruiert.

php
namespace TrueAsync;

final class HttpResponse
{
    // status
    public function setStatusCode(int $code): static;
    public function getStatusCode(): int;
    public function setReasonPhrase(string $phrase): static;
    public function getReasonPhrase(): string;

    // headers
    public function setHeader(string $name, string|array $value): static;
    public function addHeader(string $name, string|array $value): static;
    public function hasHeader(string $name): bool;
    public function getHeader(string $name): ?string;
    public function getHeaderLine(string $name): string;
    public function getHeaders(): array;
    public function resetHeaders(): static;

    // trailers (HTTP/2)
    public function setTrailer(string $name, string $value): static;
    public function setTrailers(array $trailers): static;
    public function resetTrailers(): static;
    public function getTrailers(): array;

    // protocol introspection
    public function getProtocolName(): string;
    public function getProtocolVersion(): string;

    // body
    public function write(string $data): static;
    public function send(string $chunk): static;
    public function sendable(): bool;
    public function setNoCompression(): static;
    public function getBody(): string;
    public function setBody(string $body): static;
    public function getBodyStream(): mixed;       // TODO
    public function setBodyStream(mixed $stream): static;  // TODO

    // helpers
    public function json(array|string|object|null|int|float|bool $data, int $status = 200, int $flags = 0): static;
    public function html(string $html): static;
    public function redirect(string $url, int $status = 302): static;

    // send / state
    public function end(?string $data = null): void;
    public function sendFile(string $path, ?SendFileOptions $options = null): void;
    public function isHeadersSent(): bool;
    public function isClosed(): bool;
}

Status

setStatusCode

php
public HttpResponse::setStatusCode(int $code): static

HTTP-Code 100..599.

getStatusCode

php
public HttpResponse::getStatusCode(): int

setReasonPhrase / getReasonPhrase

php
public HttpResponse::setReasonPhrase(string $phrase): static
public HttpResponse::getReasonPhrase(): string

"OK", "Not Found" usw.

setHeader

php
public HttpResponse::setHeader(string $name, string|array $value): static

Header setzen und vorhandene Werte ersetzen.

addHeader

php
public HttpResponse::addHeader(string $name, string|array $value): static

Wert zu vorhandenen hinzufügen (z. B. Set-Cookie).

hasHeader / getHeader / getHeaderLine / getHeaders

php
public HttpResponse::hasHeader(string $name): bool
public HttpResponse::getHeader(string $name): ?string
public HttpResponse::getHeaderLine(string $name): string
public HttpResponse::getHeaders(): array

Case-insensitives Lesen dessen, was der Handler gesetzt hat.

resetHeaders

php
public HttpResponse::resetHeaders(): static

Alle Header entfernen.

Trailers (HTTP/2)

HEADERS-Frame, der nach dem Body gesendet wird. Kanonischer Consumer ist gRPC (grpc-status). Auf HTTP/1.1 wird der Wert stillschweigend ignoriert — Trailer-Emission via Chunked Encoding ist nicht im Scope von Step 5b.

setTrailer

php
public HttpResponse::setTrailer(string $name, string $value): static

Name — lowercase (RFC 9113 §8.2.2); Großbuchstaben werden automatisch konvertiert.

setTrailers

php
public HttpResponse::setTrailers(array $trailers): static

Bulk-Set. Vorhandene Trailers bleiben erhalten — für einen Clean Slate vorher resetTrailers() aufrufen.

resetTrailers

php
public HttpResponse::resetTrailers(): static

getTrailers

php
public HttpResponse::getTrailers(): array

Protokoll

getProtocolName / getProtocolVersion

php
public HttpResponse::getProtocolName(): string     // immer "HTTP"
public HttpResponse::getProtocolVersion(): string  // "1.1", "2", "3"

Body

write

php
public HttpResponse::write(string $data): static

Append in den internen Body-Buffer. Versendet wird bei end() / automatisch beim Rückkehr aus dem Handler.

send

php
public HttpResponse::send(string $chunk): static

Chunk an den Client senden (Streaming).

  • Der erste send() committet Status + Header — danach nicht mehr änderbar.
  • Folgende — Append von DATA-Frames (HTTP/2) oder chunked Segments (HTTP/1).
  • Blockiert die Handler-Coroutine nur unter Backpressure (Per-Stream-Staging-Buffer voll). Default-Schwelle: setStreamWriteBufferBytes() — 256 KiB.
  • Im Normalfall kehrt es sofort zurück.

sendable

php
public HttpResponse::sendable(): bool

Advisory Non-Blocking-Check:

  • truesend() nimmt den Chunk ohne Suspend an.
  • falsesend() blockiert auf Backpressure, oder die Response wurde von sendFile() versiegelt / ist geschlossen, oder es ist kein streaming-fähiger Antworttyp.

send() ist immer sicher aufrufbar — sendable() gibt dem Handler nur die Möglichkeit, andere Arbeit zu erledigen, statt auf einem langsamen Peer zu blockieren.

setNoCompression

php
public HttpResponse::setNoCompression(): static

Komprimierung für diese Response verbieten — überschreibt Accept-Encoding, MIME-Whitelist und Size-Threshold. Anwenden bei: BREACH-sensiblen Endpoints (Secrets + reflected User-Input), Payloads mit bereits gesetztem Content-Encoding, Bodies, die der Server nicht wrappen soll. Idempotent.

getBody / setBody

php
public HttpResponse::getBody(): string
public HttpResponse::setBody(string $body): static

Get/Set des aktuellen Buffer-Inhalts.

Helpers

json

php
public HttpResponse::json(
    array|string|object|null|int|float|bool $data,
    int $status = 200,
    int $flags  = 0
): static

JSON-Serialisierung über php_json_encode_ex (derselbe Pfad wie json_encode()):

  • array / object / Skalar-$data → encoded.
  • string $data → wird wie es ist gesendet (cached JSON, pre-built Bytes). Spart Re-Encoding.

Content-Type: application/json wird nur gesetzt, wenn der Handler keinen eigenen vergeben hat — chainen Sie setHeader('Content-Type', 'application/problem+json')->json($payload) für einen anderen Media-Type.

$flagsJSON_*-Bitmask. 0 — Server-Defaults aus HttpServerConfig::setJsonEncodeFlags() (JSON_UNESCAPED_UNICODE | JSON_UNESCAPED_SLASHES out of the box).

JSON_THROW_ON_ERROR wird stillschweigend entfernt: ein Encoding-Fehler liefert eine 500 mit JSON-Fehlerbody, eine Exception wird nicht durchgereicht. Der Handler sollte json() nie in einen try/catch wrappen.

html

php
public HttpResponse::html(string $html): static

Setzt Content-Type: text/html.

redirect

php
public HttpResponse::redirect(string $url, int $status = 302): static

Senden

end

php
public HttpResponse::end(?string $data = null): void

Antwort abschließen und an den Client senden. Nach end() darf nichts mehr geschrieben werden.

sendFile

php
public HttpResponse::sendFile(string $path, ?SendFileOptions $options = null): void

Handler-gesteuerte Dateiauslieferung. Schreibt Pfad + Optionen auf die Response und kehrt sofort zurück — die Übertragung läuft in der Dispose-Phase über dieselbe FSM wie StaticHandler (MIME, ETag, IMF-Date, Range, Conditional GET, Precompressed Sidecars).

Nach sendFile() ist die Response sealed: setHeader / setStatus* / write / send / setBody / json / html / redirect / end / erneutes sendFile() werfen HttpServerRuntimeException.

Der Pfad ist vertrauenswürdig (Handler hat über den Zugriff entschieden). Open/fstat-Fehler (ENOENT, EACCES, oversize, non-regular) — 500, da die Header noch nicht auf dem Draht sind.

Compression Middleware wird für sendFile-Bodies umgangen (eigene Delivery-Pipeline).

Der HTTP/3-Pfad für sendFile() ist noch in Arbeit; aktuell weist der H3-Dispose-Hook mit 500 zurück.

Siehe SendFileOptions.

State

isHeadersSent

php
public HttpResponse::isHeadersSent(): bool

isClosed

php
public HttpResponse::isClosed(): bool

Beispiel

php
use TrueAsync\HttpResponse;
use TrueAsync\SendFileOptions;
use TrueAsync\SendFileDisposition;

$server->addHttpHandler(function ($req, HttpResponse $res) {
    // SSE
    if ($req->getPath() === '/events') {
        $res
            ->setStatusCode(200)
            ->setHeader('Content-Type', 'text/event-stream')
            ->setHeader('Cache-Control', 'no-store')
            ->setNoCompression();

        foreach (loadEvents() as $event) {
            $res->send("data: " . json_encode($event) . "\n\n");
        }
        return;
    }

    // sendFile
    if ($req->getPath() === '/report.pdf') {
        $res->sendFile('/var/reports/q1.pdf', new SendFileOptions(
            disposition:  SendFileDisposition::ATTACHMENT,
            downloadName: 'Q1-Report.pdf',
        ));
        return;
    }

    // JSON
    $res->json(['ok' => true]);
});

Siehe auch