(t *testing.T)
| 88 | } |
| 89 | |
| 90 | func TestA2AServer_MultipleRequests(t *testing.T) { |
| 91 | t.Parallel() |
| 92 | |
| 93 | _, runConfig := startRecordingAIProxy(t) |
| 94 | agentCard := startA2AServer(t, "testdata/basic.yaml", runConfig) |
| 95 | |
| 96 | messages := []string{ |
| 97 | "Say 'hello' in one word.", |
| 98 | "Say 'goodbye' in one word.", |
| 99 | } |
| 100 | |
| 101 | for i, message := range messages { |
| 102 | t.Run(fmt.Sprintf("request_%d", i), func(t *testing.T) { |
| 103 | requestID := fmt.Sprintf("test-request-%d", i) |
| 104 | msgID := fmt.Sprintf("msg-%d", i) |
| 105 | |
| 106 | resp := sendA2AMessage(t, agentCard.URL, requestID, msgID, message) |
| 107 | |
| 108 | assert.Equal(t, requestID, resp.ID) |
| 109 | assert.Nil(t, resp.Error) |
| 110 | assert.NotNil(t, resp.Result) |
| 111 | }) |
| 112 | } |
| 113 | } |
| 114 | |
| 115 | func TestA2AServer_MultiAgent(t *testing.T) { |
| 116 | t.Parallel() |
nothing calls this directly
no test coverage detected