Function startA2AServer

e2e/a2a_test.go:169–197

(t *testing.T, agentFile string, runConfig *config.RuntimeConfig)

}

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

	var lc net.ListenConfig
	ln, err := lc.Listen(t.Context(), "tcp", ":0")
	require.NoError(t, err)

	go func() {
		_ = a2aserver.Run(t.Context(), agentFile, "root", filepath.Join(t.TempDir(), "session.db"), runConfig, ln)
	}()

	port := ln.Addr().(*net.TCPAddr).Port
	serverURL := fmt.Sprintf("http://localhost:%d", port)

	cardReq, err := http.NewRequestWithContext(t.Context(), http.MethodGet, serverURL+a2asrv.WellKnownAgentCardPath, http.NoBody)
	require.NoError(t, err)

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

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

	var agentCard a2a.AgentCard
	err = json.NewDecoder(resp.Body).Decode(&agentCard)
	require.NoError(t, err)

	return agentCard
}