use go-vcr package

config/tests/samples/create/harness.go

@@ -24,6 +24,8 @@ import (
 	"testing"
 	"time"
 
+	"gopkg.in/dnaeon/go-vcr.v3/recorder"
+
 	"github.com/go-logr/logr"
 	"github.com/google/go-cmp/cmp"
 	transport_tpg "github.com/hashicorp/terraform-provider-google-beta/google-beta/transport"
@@ -75,6 +77,8 @@ type Harness struct {
 	// gcpAccessToken is set to the oauth2 token to use for GCP, primarily when GCP is mocked.
 	gcpAccessToken string
 	kccConfig      kccmanager.Config
+
+	Rec *recorder.Recorder
 }
 
 type httpRoundTripperKeyType int
@@ -237,6 +241,8 @@ func NewHarness(ctx context.Context, t *testing.T) *Harness {
 		kccConfig.GCPAccessToken = h.gcpAccessToken
 	} else if targetGCP := os.Getenv("E2E_GCP_TARGET"); targetGCP == "real" {
 		t.Logf("targeting real GCP")
+	} else if targetGCP := os.Getenv("E2E_GCP_TARGET"); targetGCP == "vcr" {
+		t.Logf("creating vcr test")
 	} else {
 		t.Fatalf("E2E_GCP_TARGET=%q not supported", targetGCP)
 	}
@@ -306,17 +312,37 @@ func NewHarness(ctx context.Context, t *testing.T) *Harness {
 		kccConfig.HTTPClient = &http.Client{Transport: t}
 	}
 
-	// Intercept (and log) TF requests
-	transport_tpg.DefaultHTTPClientTransformer = func(ctx context.Context, inner *http.Client) *http.Client {
-		ret := inner
-		if t := ctx.Value(httpRoundTripperKey); t != nil {
-			ret = &http.Client{Transport: t.(http.RoundTripper)}
+	if targetGCP := os.Getenv("E2E_GCP_TARGET"); targetGCP == "vcr" {
+		transport_tpg.DefaultHTTPClientTransformer = func(ctx context.Context, inner *http.Client) *http.Client {
+			ret := inner
+			if t := ctx.Value(httpRoundTripperKey); t != nil {
+				ret = &http.Client{Transport: t.(http.RoundTripper)}
+			}
+			dir := "vcr/fixtures/cassette/"
+			testName := strings.ReplaceAll(t.Name(), "/", "_")
+			opts := &recorder.Options{
+				CassetteName:  dir + testName,
+				Mode:          recorder.ModeRecordOnly,
+				RealTransport: ret.Transport,
+			}
+			r, _ := recorder.NewWithOptions(opts)
+			h.Rec = r
+			ret = &http.Client{Transport: h.Rec}
+			return ret
 		}
-		if len(eventSinks) != 0 {
-			t := test.NewHTTPRecorder(ret.Transport, eventSinks...)
-			ret = &http.Client{Transport: t}
+	} else {
+		// Intercept (and log) TF requests
+		transport_tpg.DefaultHTTPClientTransformer = func(ctx context.Context, inner *http.Client) *http.Client {
+			ret := inner
+			if t := ctx.Value(httpRoundTripperKey); t != nil {
+				ret = &http.Client{Transport: t.(http.RoundTripper)}
+			}
+			if len(eventSinks) != 0 {
+				t := test.NewHTTPRecorder(ret.Transport, eventSinks...)
+				ret = &http.Client{Transport: t}
+			}
+			return ret
 		}
-		return ret
 	}
 
 	// Intercept (and log) TF oauth requests

go.mod

@@ -45,6 +45,7 @@ require (
 	golang.org/x/time v0.5.0
 	google.golang.org/api v0.160.0
 	google.golang.org/protobuf v1.32.0
+	gopkg.in/dnaeon/go-vcr.v3 v3.1.2
 	gopkg.in/yaml.v2 v2.4.0
 	k8s.io/api v0.27.11
 	k8s.io/apiextensions-apiserver v0.27.9

tests/e2e/unified_test.go

@@ -120,6 +120,16 @@ func TestAllInSeries(t *testing.T) {
 				h := create.NewHarness(ctx, t)
 				project := h.Project
 
+				if os.Getenv("E2E_GCP_TARGET") == "vcr" {
+					// Stop recording after tests finish and write to cassette
+					defer func() {
+						err := h.Rec.Stop()
+						if err != nil {
+							t.Errorf("[VCR] Failed stop vcr recorder: %v", err)
+						}
+					}()
+				}
+
 				primaryResource, opt := loadFixture(project)
 
 				exportResources := []*unstructured.Unstructured{primaryResource}