Function sendA2AMessage

e2e/a2a_test.go:133–167

sendA2AMessage sends a message/send JSON-RPC request and returns the parsed response.

(t *testing.T, url, requestID, messageID, text string)

// sendA2AMessage sends a message/send JSON-RPC request and returns the parsed response.
func sendA2AMessage(t *testing.T, url, requestID, messageID, text string) a2aResponse {
	t.Helper()

	body, err := json.Marshal(map[string]any{
		"jsonrpc": "2.0",
		"id":      requestID,
		"method":  "message/send",
		"params": map[string]any{
			"message": map[string]any{
				"messageId": messageID,
				"role":      "user",
				"parts":     []map[string]any{{"kind": "text", "text": text}},
			},
		},
	})
	require.NoError(t, err)

	req, err := http.NewRequestWithContext(t.Context(), http.MethodPost, url, bytes.NewReader(body))
	require.NoError(t, err)
	req.Header.Set("Content-Type", "application/json")

	resp, err := http.DefaultClient.Do(req)
	require.NoError(t, err)
	defer resp.Body.Close()

	require.Equal(t, http.StatusOK, resp.StatusCode)

	data, err := io.ReadAll(resp.Body)
	require.NoError(t, err)

	var parsed a2aResponse
	require.NoError(t, json.Unmarshal(data, &parsed))

	return parsed
}

func startA2AServer(t *testing.T, agentFile string, runConfig *config.RuntimeConfig) a2a.AgentCard {
	t.Helper()