Function fakeCloud

cli/internal/platform/inject_test.go:66–84

(t *testing.T, tenants func(w http.ResponseWriter, r *http.Request), session func(w http.ResponseWriter, r *http.Request))

}

func fakeCloud(t *testing.T, tenants func(w http.ResponseWriter, r *http.Request), session func(w http.ResponseWriter, r *http.Request)) *httptest.Server {
	t.Helper()
	if tenants == nil {
		tenants = func(w http.ResponseWriter, _ *http.Request) {
			writeTenants(w, tenantItem("11111111-1111-1111-1111-111111111111", "active", "team-x"))
		}
	}
	if session == nil {
		session = func(w http.ResponseWriter, _ *http.Request) {
			writeSession(w, "cqpd_payload.sig", "https://x.us.platform.cloudquery.io")
		}
	}
	mux := http.NewServeMux()
	mux.HandleFunc("/user/platform/tenants", tenants)
	mux.HandleFunc("/platform-destination/session", session)
	srv := httptest.NewServer(mux)
	t.Cleanup(srv.Close)
	return srv
}

func TestInject_OptIn_AppendsDestination(t *testing.T) {
	srv := fakeCloud(t, func(w http.ResponseWriter, r *http.Request) {