Create SSE endpoint for project events #34

New Issue

cardosofelipe · 2025-12-29T23:48:24Z

cardosofelipe commented

2025-12-29 23:48:24 +00:00

Description

Implement Server-Sent Events (SSE) endpoint for real-time project updates.

Requirements

Endpoint

GET /api/v1/projects/{project_id}/events/stream

Implementation

@router.get("/projects/{project_id}/events/stream")
async def stream_events(
    project_id: UUID,
    current_user: User = Depends(get_current_user),
    event_bus: EventBus = Depends(get_event_bus)
):
    # Authorization check
    # Subscribe to project channel
    # Yield SSE formatted events
    # Keepalive every 30s

SSE Format

event: agent.status_changed
data: {"id": "...", "type": "agent.status_changed", ...}

: keepalive

event: issue.created
data: {...}

Features

Automatic reconnection support (Last-Event-ID)
Keepalive every 30 seconds
Connection cleanup on disconnect
Rate limiting

Tests

Event streaming
Keepalive mechanism
Authorization
Reconnection

Acceptance Criteria

SSE endpoint implemented
Events stream correctly
Keepalive working
Authorization enforced
Last-Event-ID support
Integration tests

Dependencies

Depends on: #33 (EventBus)

Assignable To

backend-engineer agent

## Description Implement Server-Sent Events (SSE) endpoint for real-time project updates. ## Requirements ### Endpoint ``` GET /api/v1/projects/{project_id}/events/stream ``` ### Implementation ```python @router.get("/projects/{project_id}/events/stream") async def stream_events( project_id: UUID, current_user: User = Depends(get_current_user), event_bus: EventBus = Depends(get_event_bus) ): # Authorization check # Subscribe to project channel # Yield SSE formatted events # Keepalive every 30s ``` ### SSE Format ``` event: agent.status_changed data: {"id": "...", "type": "agent.status_changed", ...} : keepalive event: issue.created data: {...} ``` ### Features - Automatic reconnection support (Last-Event-ID) - Keepalive every 30 seconds - Connection cleanup on disconnect - Rate limiting ### Tests - Event streaming - Keepalive mechanism - Authorization - Reconnection ## Acceptance Criteria - [ ] SSE endpoint implemented - [ ] Events stream correctly - [ ] Keepalive working - [ ] Authorization enforced - [ ] Last-Event-ID support - [ ] Integration tests ## Dependencies - Depends on: #33 (EventBus) ## Assignable To backend-engineer agent

cardosofelipe referenced this issue

2025-12-29 23:48:24 +00:00

Implement client-side SSE handling #35

cardosofelipe added the backend phase-1 labels 2025-12-29 23:50:16 +00:00

cardosofelipe referenced this issue from a commit

2025-12-30 01:08:29 +00:00

feat(backend): Add SSE endpoint for project event streaming

cardosofelipe closed this issue

2025-12-30 01:10:39 +00:00

Sign in to join this conversation.