feat: view SDK events on ldcli dev server

internal/dev_server/api/api.yaml

@@ -188,6 +188,92 @@ paths:
           $ref: "#/components/responses/ErrorResponse"
         400:
           $ref: "#/components/responses/ErrorResponse"
+  /debug-sessions:
+    get:
+      operationId: getDebugSessions
+      summary: list all debug sessions with event counts
+      parameters:
+        - name: limit
+          in: query
+          description: limit the number of debug sessions returned
+          required: false
+          schema:
+            type: integer
+            default: 50
+        - name: offset
+          in: query
+          description: offset for pagination
+          required: false
+          schema:
+            type: integer
+            default: 0
+      responses:
+        200:
+          description: OK. List of debug sessions
+          content:
+            application/json:
+              schema:
+                $ref: "#/components/schemas/DebugSessionsPage"
+        400:
+          $ref: "#/components/responses/ErrorResponse"
+  /debug-sessions/{debugSessionKey}:
+    delete:
+      operationId: deleteDebugSession
+      summary: delete a specific debug session and all its events
+      parameters:
+        - name: debugSessionKey
+          in: path
+          required: true
+          schema:
+            type: string
+          description: unique identifier for the debug session
+      responses:
+        204:
+          description: OK. Debug session and all associated events were deleted
+        404:
+          $ref: "#/components/responses/ErrorResponse"
+  /debug-sessions/{debugSessionKey}/events:
+    get:
+      operationId: getDebugSessionEvents
+      summary: get events for a specific debug session
+      parameters:
+        - name: debugSessionKey
+          in: path
+          required: true
+          schema:
+            type: string
+          description: unique identifier for the debug session
+        - name: kind
+          in: query
+          description: filter events by kind (e.g., summary, diagnostic, feature)
+          required: false
+          schema:
+            type: string
+        - name: limit
+          in: query
+          description: limit the number of events returned
+          required: false
+          schema:
+            type: integer
+            default: 50
+        - name: offset
+          in: query
+          description: offset for pagination
+          required: false
+          schema:
+            type: integer
+            default: 0
+      responses:
+        200:
+          description: OK. List of events for the debug session
+          content:
+            application/json:
+              schema:
+                $ref: "#/components/schemas/EventsPage"
+        404:
+          $ref: "#/components/responses/ErrorResponse"
+        400:
+          $ref: "#/components/responses/ErrorResponse"
 components:
   parameters:
     flagKey:
@@ -294,6 +380,89 @@ components:
           type: string
         name:
           type: string
+    DebugSession:
+      description: Debug session with event count
+      type: object
+      required:
+        - key
+        - written_at
+        - event_count
+      properties:
+        key:
+          type: string
+          description: unique identifier for the debug session
+        written_at:
+          type: string
+          format: date-time
+          description: timestamp when the debug session was created
+        event_count:
+          type: integer
+          format: int64
+          description: number of events associated with this debug session
+    DebugSessionsPage:
+      description: Paginated response of debug sessions
+      type: object
+      required:
+        - sessions
+        - total_count
+        - has_more
+      properties:
+        sessions:
+          type: array
+          items:
+            $ref: "#/components/schemas/DebugSession"
+          description: list of debug sessions
+        total_count:
+          type: integer
+          format: int64
+          description: total number of debug sessions available
+        has_more:
+          type: boolean
+          description: whether there are more results available
+    Event:
+      description: A stored event with metadata
+      type: object
+      required:
+        - id
+        - written_at
+        - kind
+        - data
+      properties:
+        id:
+          type: integer
+          format: int64
+          description: unique identifier for the event
+        written_at:
+          type: string
+          format: date-time
+          description: timestamp when the event was written
+        kind:
+          type: string
+          description: type of event (e.g., summary, diagnostic, feature)
+        data:
+          type: object
+          description: raw event data as JSON
+          x-go-type: json.RawMessage
+    EventsPage:
+      description: Paginated response of events
+      type: object
+      required:
+        - events
+        - total_count
+        - has_more
+      properties:
+        events:
+          type: array
+          items:
+            $ref: "#/components/schemas/Event"
+          description: list of events
+        total_count:
+          type: integer
+          format: int64
+          description: total number of events available
+        has_more:
+          type: boolean
+          description: whether there are more results available
   responses:
     FlagOverride:
       description: Flag override

internal/dev_server/api/delete_debug_session.go

@@ -0,0 +1,19 @@
+package api
+
+import (
+	"context"
+
+	"github.com/launchdarkly/ldcli/internal/dev_server/model"
+)
+
+func (s server) DeleteDebugSession(ctx context.Context, request DeleteDebugSessionRequestObject) (DeleteDebugSessionResponseObject, error) {
+	eventStore := model.EventStoreFromContext(ctx)
+
+	// Delete the debug session
+	err := eventStore.DeleteDebugSession(ctx, request.DebugSessionKey)
+	if err != nil {
+		return nil, err
+	}
+
+	return DeleteDebugSession204Response{}, nil
+}

internal/dev_server/api/events/events_stream.go

@@ -0,0 +1,82 @@
+package events
+
+import (
+	"context"
+	"encoding/json"
+	"log"
+	"net/http"
+
+	"github.com/google/uuid"
+	"github.com/launchdarkly/ldcli/internal/dev_server/model"
+	"github.com/pkg/errors"
+
+	"github.com/launchdarkly/ldcli/internal/dev_server/sdk"
+)
+
+type sdkEventObserver struct {
+	ctx             context.Context
+	debugSessionKey string
+	updateChan      chan<- sdk.Message
+}
+
+func newSdkEventObserver(updateChan chan<- sdk.Message, ctx context.Context) sdkEventObserver {
+	debugSessionKey := uuid.New().String()
+	db := model.EventStoreFromContext(ctx)
+	err := db.CreateDebugSession(ctx, debugSessionKey)
+	if err != nil {
+		log.Printf("sdkEventObserver: error writting debug session: %v", err)
+	}
+	return sdkEventObserver{
+		debugSessionKey: debugSessionKey,
+		ctx:             ctx,
+		updateChan:      updateChan,
+	}
+}
+
+func (o sdkEventObserver) Handle(message interface{}) {
+	str, ok := message.(json.RawMessage)
+	if !ok {
+		return
+	}
+
+	event := sdk.SDKEventBase{}
+	err := json.Unmarshal(str, &event)
+	if err != nil {
+		log.Printf("sdkEventObserver: error unmarshaling event: %v", err)
+		return
+	}
+
+	db := model.EventStoreFromContext(o.ctx)
+
+	err = db.WriteEvent(o.ctx, o.debugSessionKey, event.Kind, str)
+	if err != nil {
+		log.Printf("sdkEventObserver: error writting event: %v", err)
+		return
+	}
+
+	o.updateChan <- sdk.Message{Event: sdk.TYPE_PUT, Data: str}
+}
+
+func SdkEventsTeeHandler(writer http.ResponseWriter, request *http.Request) {
+	updateChan, errChan := sdk.OpenStream(
+		writer,
+		request.Context().Done(),
+		sdk.Message{Event: sdk.TYPE_PUT, Data: []byte{}},
+	)
+	defer close(updateChan)
+	observers := model.GetObserversFromContext(request.Context())
+
+	observerId := observers.RegisterObserver(newSdkEventObserver(updateChan, request.Context()))
+	defer func() {
+		ok := observers.DeregisterObserver(observerId)
+		if !ok {
+			log.Printf("unable to remove observer")
+		}
+	}()
+
+	err := <-errChan
+	if err != nil {
+		sdk.WriteError(request.Context(), writer, errors.Wrap(err, "stream failure"))
+		return
+	}
+}

internal/dev_server/api/events/routes.go

@@ -0,0 +1,7 @@
+package events
+
+import "github.com/gorilla/mux"
+
+func BindRoutes(router *mux.Router) {
+	router.HandleFunc("/events/tee", SdkEventsTeeHandler)
+}

internal/dev_server/api/get_debug_session_events.go

@@ -0,0 +1,61 @@
+package api
+
+import (
+	"context"
+	"github.com/launchdarkly/ldcli/internal/dev_server/model"
+)
+
+func (s server) GetDebugSessionEvents(ctx context.Context, request GetDebugSessionEventsRequestObject) (GetDebugSessionEventsResponseObject, error) {
+	eventStore := model.EventStoreFromContext(ctx)
+
+	// Set default values for pagination
+	limit := 50
+	offset := 0
+
+	if request.Params.Limit != nil {
+		limit = *request.Params.Limit
+	}
+	if request.Params.Offset != nil {
+		offset = *request.Params.Offset
+	}
+
+	// Validate parameters
+	if limit < 1 || limit > 10000 {
+		return GetDebugSessionEvents400JSONResponse{ErrorResponseJSONResponse{
+			Code:    "invalid_parameter",
+			Message: "limit must be between 1 and 10000",
+		}}, nil
+	}
+
+	if offset < 0 {
+		return GetDebugSessionEvents400JSONResponse{ErrorResponseJSONResponse{
+			Code:    "invalid_parameter",
+			Message: "offset must be non-negative",
+		}}, nil
+	}
+
+	// Query events from the event store
+	page, err := eventStore.QueryEvents(ctx, request.DebugSessionKey, request.Params.Kind, limit, offset)
+	if err != nil {
+		return nil, err
+	}
+
+	// Convert model.Event to API Event
+	var apiEvents []Event
+	for _, event := range page.Events {
+		apiEvents = append(apiEvents, Event{
+			Id:        event.ID,
+			WrittenAt: event.WrittenAt,
+			Kind:      event.Kind,
+			Data:      event.Data,
+		})
+	}
+
+	response := EventsPage{
+		Events:     apiEvents,
+		TotalCount: page.TotalCount,
+		HasMore:    page.HasMore,
+	}
+
+	return GetDebugSessionEvents200JSONResponse(response), nil
+}