sse

type Event struct {
	Type enum.SSEType    `json:"type"`
	Data json.RawMessage `json:"data"`
}

type Streamer interface {
	// Publish publishes a new event for the given project.
	Publish(ctx context.Context, projectID int64, eventType enum.SSEType, data any) error

	Stream(ctx context.Context, projectID int64) (<-chan *Event, <-chan error, func(context.Context) error)
}