Join our community: https://t.me/+DOylgFv1jyJlNzM0
Description
No integration tests verify the event indexer, stream controller, SSE broadcast, and RPC fallback working end-to-end.
Test Cases Needed
- Indexer processes
stream_created → stream in GET /v1/streams/{id}
- Indexer processes
stream_topped_up → depositedAmount updated
- Indexer processes
stream_paused → isPaused = true, claimable stops growing
- Indexer processes
stream_resumed → isPaused = false, accrual resumes
- Indexer processes
stream_cancelled → isActive = false
- Stale DB (>30s) →
GET /v1/streams/{id}/claimable falls back to RPC
- SSE client receives broadcast for each event
Files
backend/src/__tests__/integration/streams.test.ts (create)
Acceptance Criteria
Description
No integration tests verify the event indexer, stream controller, SSE broadcast, and RPC fallback working end-to-end.
Test Cases Needed
stream_created→ stream inGET /v1/streams/{id}stream_topped_up→depositedAmountupdatedstream_paused→isPaused = true, claimable stops growingstream_resumed→isPaused = false, accrual resumesstream_cancelled→isActive = falseGET /v1/streams/{id}/claimablefalls back to RPCFiles
backend/src/__tests__/integration/streams.test.ts(create)Acceptance Criteria