fix: events filter by request keys query (#1416)

block · May 6, 2024 · c96b5e8 · c96b5e8
1 parent d6ee107
commit c96b5e8
Show file tree

Hide file tree

Showing 2 changed files with 7 additions and 1 deletion.
diff --git a/backend/controller/dal/dal_test.go b/backend/controller/dal/dal_test.go
@@ -290,6 +290,12 @@ func TestDAL(t *testing.T) {
 			assert.NoError(t, err)
 			assertEventsEqual(t, []Event{logEvent}, events)
 		})
+
+		t.Run("ByRequests", func(t *testing.T) {
+			events, err := dal.QueryEvents(ctx, 1000, FilterRequests(requestKey))
+			assert.NoError(t, err)
+			assertEventsEqual(t, []Event{callEvent, logEvent}, events)
+		})
 	})
 
 	t.Run("GetRoutingTable", func(t *testing.T) {

diff --git a/backend/controller/dal/events.go b/backend/controller/dal/events.go
@@ -277,7 +277,7 @@ func (d *DAL) QueryEvents(ctx context.Context, limit int, filters ...EventFilter
 	q += fmt.Sprintf(` AND e.deployment_id = ANY($%d::BIGINT[])`, param(deploymentIDs))
 
 	if filter.requests != nil {
-		q += fmt.Sprintf(` AND ir.name = ANY($%d::TEXT[])`, param(filter.requests))
+		q += fmt.Sprintf(` AND ir.key = ANY($%d::TEXT[])`, param(filter.requests))
 	}
 	if filter.types != nil {
 		// Why are we double casting? Because I hit "cannot find encode plan" and