GET /sse

GET /sse alias: /sse

Returns a well-formed Server-Sent Events stream: `data:`, `event:`, `id:`, and `retry:` fields all correctly framed, blank-line event separators, four events then close. Served as text/event-stream. Counterpart to /sse, which ships one of four WHATWG EventSource violations.

expect: 200 OK with Content-Type: text/event-stream. A conforming stream that any spec-compliant EventSource client parses and dispatches correctly. Build SSE consumers against this, then flip hostname to chaos.catastrophic.io to test adversity.

bash

curl -sN 'https://not.catastrophic.io/sse' | head -40

import urllib.request
resp = urllib.request.urlopen("https://not.catastrophic.io/sse")
print("Content-Type:", resp.headers.get("Content-Type"))
print("X-Chaos-Sse-Mode:", resp.headers.get("X-Chaos-Sse-Mode"))
print("--- raw stream ---")
for line in resp:
    print(repr(line))

// Node 18+ has a built-in EventSource via undici, browsers have window.EventSource.
const es = new EventSource("https://not.catastrophic.io/sse");
es.onmessage = (e) => console.log("default message:", e.data);
es.addEventListener("connected", (e) => console.log("connected:", e.data));
es.addEventListener("message", (e) => console.log("message:", e.data));
es.addEventListener("done", (e) => { console.log("done:", e.data); es.close(); });
es.onerror = (e) => console.log("error:", e);

package main

import (
    "bufio"
    "fmt"
    "net/http"
)

func main() {
    resp, _ := http.Get("https://not.catastrophic.io/sse")
    defer resp.Body.Close()
    fmt.Println("Content-Type:", resp.Header.Get("Content-Type"))
    fmt.Println("X-Chaos-Sse-Mode:", resp.Header.Get("X-Chaos-Sse-Mode"))
    scanner := bufio.NewScanner(resp.Body)
    for scanner.Scan() {
        fmt.Printf("%q\n", scanner.Text())
    }
}

// Cargo.toml: reqwest = { version = "0.12", features = ["blocking"] }
use std::io::{BufRead, BufReader};
fn main() -> Result<(), Box> {
    let resp = reqwest::blocking::get("https://not.catastrophic.io/sse")?;
    println!("Content-Type: {:?}", resp.headers().get("content-type"));
    println!("X-Chaos-Sse-Mode: {:?}", resp.headers().get("x-chaos-sse-mode"));
    for line in BufReader::new(resp).lines() {
        println!("{:?}", line?);
    }
    Ok(())
}

import java.net.URI;
import java.net.http.*;

public class SseChaos {
    public static void main(String[] args) throws Exception {
        var client = HttpClient.newHttpClient();
        var req = HttpRequest.newBuilder(URI.create("https://not.catastrophic.io/sse")).build();
        var resp = client.send(req, HttpResponse.BodyHandlers.ofString());
        System.out.println("Content-Type: " +
            resp.headers().firstValue("Content-Type").orElse(""));
        System.out.println("X-Chaos-Sse-Mode: " +
            resp.headers().firstValue("X-Chaos-Sse-Mode").orElse(""));
        System.out.println("Body: " + resp.body());
    }
}

using var client = new HttpClient();
var resp = await client.GetAsync("https://not.catastrophic.io/sse");
Console.WriteLine($"Content-Type: {resp.Content.Headers.ContentType}");
Console.WriteLine($"X-Chaos-Sse-Mode: " +
    $"{resp.Headers.GetValues("X-Chaos-Sse-Mode").FirstOrDefault()}");
var body = await resp.Content.ReadAsStringAsync();
Console.WriteLine($"Body: {body}");

require "net/http"
uri = URI("https://not.catastrophic.io/sse")
Net::HTTP.start(uri.host, uri.port, use_ssl: true) do |http|
    req = Net::HTTP::Get.new(uri.request_uri)
    http.request(req) do |res|
        puts "Content-Type: #{res['Content-Type']}"
        puts "X-Chaos-Sse-Mode: #{res['X-Chaos-Sse-Mode']}"
        res.read_body { |chunk| chunk.each_line { |line| puts line.inspect } }
    end
end

$r = Invoke-WebRequest -Uri 'https://not.catastrophic.io/sse'
"Content-Type: $($r.Headers['Content-Type'])"
"X-Chaos-Sse-Mode: $($r.Headers['X-Chaos-Sse-Mode'])"
$r.Content -split "`n" | ForEach-Object { '{0}' -f $_ }