wehub-resource-sync
54 lines
2.1 KiB
TypeScript
54 lines
2.1 KiB
TypeScript
/**
|
|
* E2E tests for the SSE (server-sent events) streaming response path.
|
|
*
|
|
* Compound respondWith values (e.g. 'markdown+html') require
|
|
* Accept: text/event-stream and produce a stream of JSON-encoded events.
|
|
*/
|
|
import { describe, it } from 'node:test';
|
|
import assert from 'node:assert';
|
|
import { crawlStream, parseSSELines } from '../helpers/client';
|
|
|
|
describe('SSE response for markdown+html', () => {
|
|
it('returns HTTP 200 with text/event-stream content-type', async () => {
|
|
const res = await crawlStream('markdown+html');
|
|
assert.strictEqual(res.status, 200);
|
|
assert.match(res.headers['content-type'], /text\/event-stream/);
|
|
});
|
|
|
|
it('response body contains data: lines', async () => {
|
|
const res = await crawlStream('markdown+html');
|
|
assert.match(res.text, /^data:/m);
|
|
});
|
|
|
|
it('produces multiple SSE events', async () => {
|
|
const res = await crawlStream('markdown+html');
|
|
const dataLines = (res.text as string)
|
|
.split('\n')
|
|
.filter((l: string) => l.startsWith('data:'));
|
|
assert.ok(dataLines.length >= 2, `Expected >= 2 data: lines, got ${dataLines.length}`);
|
|
});
|
|
|
|
it('all non-terminal data: lines are valid JSON', async () => {
|
|
const res = await crawlStream('markdown+html');
|
|
const events = parseSSELines(res);
|
|
assert.ok(events.length > 0, 'Expected at least one parsed SSE event');
|
|
for (const event of events) {
|
|
assert.strictEqual(typeof event, 'object', `SSE event should be an object: ${JSON.stringify(event)}`);
|
|
}
|
|
});
|
|
});
|
|
|
|
describe('SSE response for markdown+text', () => {
|
|
it('returns event-stream for markdown+text compound format', async () => {
|
|
const res = await crawlStream('markdown+text');
|
|
assert.strictEqual(res.status, 200);
|
|
assert.match(res.headers['content-type'], /event-stream/);
|
|
});
|
|
|
|
it('produces parseable SSE events for markdown+text', async () => {
|
|
const res = await crawlStream('markdown+text');
|
|
const events = parseSSELines(res);
|
|
assert.ok(events.length > 0, 'Expected at least one SSE event');
|
|
});
|
|
});
|