Add query

Author: dmashuda

internal/dev_server/events_db/sqlite.go

@@ -29,7 +29,7 @@ func (s *Sqlite) WriteEvent(ctx context.Context, debugSessionKey string, kind st
 	return err
 }
 
-func (s *Sqlite) QueryEvents(ctx context.Context, kind *string, limit int, offset int) (*model.EventsPage, error) {
+func (s *Sqlite) QueryEvents(ctx context.Context, debugSessionKey string, kind *string, limit int, offset int) (*model.EventsPage, error) {
 	// Build the query based on whether kind filter is provided
 	var query string
 	var args []interface{}
@@ -38,17 +38,20 @@ func (s *Sqlite) QueryEvents(ctx context.Context, kind *string, limit int, offse
 		query = `
 			SELECT id, written_at, kind, data
 			FROM debug_events
-			WHERE kind = ?
+			WHERE 
+			    debug_session_key = ?
+			    AND kind = ?
 			ORDER BY id DESC
 			LIMIT ? OFFSET ?`
-		args = []interface{}{*kind, limit, offset}
+		args = []interface{}{debugSessionKey, *kind, limit, offset}
 	} else {
 		query = `
 			SELECT id, written_at, kind, data
 			FROM debug_events
+			where debug_session_key = ?
 			ORDER BY id DESC
 			LIMIT ? OFFSET ?`
-		args = []interface{}{limit, offset}
+		args = []interface{}{debugSessionKey, limit, offset}
 	}
 
 	// Execute the main query

internal/dev_server/events_db/sqlite_test.go

@@ -57,7 +57,7 @@ func TestDBFunctions(t *testing.T) {
 		require.NoError(t, err)
 
 		// Query all events
-		page, err := store.QueryEvents(ctx, nil, 10, 0)
+		page, err := store.QueryEvents(ctx, debugSessionKey, nil, 10, 0)
 		require.NoError(t, err)
 		require.NotNil(t, page)
 		require.Len(t, page.Events, 4) // 3 new + 1 from previous test
@@ -67,7 +67,7 @@ func TestDBFunctions(t *testing.T) {
 
 	t.Run("QueryEvents with kind filter", func(t *testing.T) {
 		kind := "summary"
-		page, err := store.QueryEvents(ctx, &kind, 10, 0)
+		page, err := store.QueryEvents(ctx, debugSessionKey, &kind, 10, 0)
 		require.NoError(t, err)
 		require.NotNil(t, page)
 		require.Len(t, page.Events, 3) // Only summary events
@@ -82,15 +82,15 @@ func TestDBFunctions(t *testing.T) {
 
 	t.Run("QueryEvents with pagination", func(t *testing.T) {
 		// Query with limit
-		page, err := store.QueryEvents(ctx, nil, 2, 0)
+		page, err := store.QueryEvents(ctx, debugSessionKey, nil, 2, 0)
 		require.NoError(t, err)
 		require.NotNil(t, page)
 		require.Len(t, page.Events, 2)
 		require.Equal(t, int64(4), page.TotalCount)
 		require.True(t, page.HasMore)
 
 		// Query next page
-		page, err = store.QueryEvents(ctx, nil, 2, 2)
+		page, err = store.QueryEvents(ctx, debugSessionKey, nil, 2, 2)
 		require.NoError(t, err)
 		require.NotNil(t, page)
 		require.Len(t, page.Events, 2)

internal/dev_server/model/event_store.go

@@ -33,7 +33,7 @@ type EventsPage struct {
 type EventStore interface {
 	CreateDebugSession(ctx context.Context, debugSessionKey string) error
 	WriteEvent(ctx context.Context, debugSessionKey string, kind string, data json.RawMessage) error
-	QueryEvents(ctx context.Context, kind *string, limit int, offset int) (*EventsPage, error)
+	QueryEvents(ctx context.Context, debugSessionKey string, kind *string, limit int, offset int) (*EventsPage, error)
 }
 
 func ContextWithEventStore(ctx context.Context, store EventStore) context.Context {