| 92 | } |
| 93 | |
| 94 | func TestFixingQueue_NonArtifactEvent(t *testing.T) { |
| 95 | t.Parallel() |
| 96 | mock := &mockQueue{} |
| 97 | fq := &fixingQueue{queue: mock} |
| 98 | |
| 99 | // Create a different type of event |
| 100 | reqCtx := &a2asrv.RequestContext{ |
| 101 | TaskID: "test-task", |
| 102 | ContextID: "test-context", |
| 103 | } |
| 104 | event := a2a.NewStatusUpdateEvent(reqCtx, a2a.TaskStateCompleted, nil) |
| 105 | |
| 106 | // Write the event through the fixing queue |
| 107 | err := fq.Write(t.Context(), event) |
| 108 | require.NoError(t, err) |
| 109 | |
| 110 | // Verify the event was written unchanged |
| 111 | require.Len(t, mock.events, 1) |
| 112 | assert.IsType(t, &a2a.TaskStatusUpdateEvent{}, mock.events[0]) |
| 113 | } |