Add gcp source process (#1291)

Resolves #1264

GitOrigin-RevId: a94bb7cabab02816177fd7f27f9363001a02e927

Author: omerdemirok

cmd/explore.go

@@ -15,6 +15,7 @@ import (
 	"github.com/overmindtech/cli/tfutils"
 	"github.com/overmindtech/cli/discovery"
 	"github.com/overmindtech/cli/sdp-go"
+	gcpproc "github.com/overmindtech/workspace/sources/gcp/proc"
 	stdlibSource "github.com/overmindtech/cli/stdlib-source/adapters"
 	"github.com/overmindtech/cli/tracing"
 	"github.com/pkg/browser"
@@ -49,6 +50,7 @@ func StartLocalSources(ctx context.Context, oi sdp.OvermindInstance, token *oaut
 	}()
 	stdlibSpinner, _ := pterm.DefaultSpinner.WithWriter(multi.NewWriter()).Start("Starting stdlib source engine")
 	awsSpinner, _ := pterm.DefaultSpinner.WithWriter(multi.NewWriter()).Start("Starting AWS source engine")
+	gcpSpinner, _ := pterm.DefaultSpinner.WithWriter(multi.NewWriter()).Start("Starting GCP source engine")
 	statusArea := pterm.DefaultParagraph.WithWriter(multi.NewWriter())
 
 	natsOptions := natsOptions(ctx, oi, token)
@@ -167,6 +169,39 @@ func StartLocalSources(ctx context.Context, oi sdp.OvermindInstance, token *oaut
 		return awsEngine, nil
 	})
 
+	p.Go(func() (*discovery.Engine, error) {
+		ec := discovery.EngineConfig{
+			EngineType:            "cli-gcp",
+			Version:               fmt.Sprintf("cli-%v", tracing.Version()),
+			SourceName:            fmt.Sprintf("gcp-source-%v", hostname),
+			SourceUUID:            uuid.New(),
+			App:                   oi.ApiUrl.Host,
+			ApiKey:                token.AccessToken,
+			MaxParallelExecutions: 2_000,
+			NATSOptions:           &natsOptions,
+			HeartbeatOptions:      heartbeatOptions,
+		}
+
+		gcpEngine, err := gcpproc.Initialize(ctx, &ec)
+		if err != nil {
+			gcpSpinner.Fail("Failed to initialize GCP source engine", err.Error())
+			// TODO: return the actual error when we have a company-wide GCP setup
+			// https://github.com/overmindtech/workspace/issues/1337
+			return nil, nil
+		}
+
+		err = gcpEngine.Start() //nolint:contextcheck
+		if err != nil {
+			gcpSpinner.Fail("Failed to start GCP source engine", err.Error())
+			// TODO: return the actual error when we have a company-wide GCP setup
+			// https://github.com/overmindtech/workspace/issues/1337
+			return nil, nil
+		}
+
+		gcpSpinner.Success("GCP source engine started")
+		return gcpEngine, nil
+	})
+
 	engines, err := p.Wait()
 	if err != nil {
 		return func() {}, fmt.Errorf("error starting sources: %w", err)

tfutils/plan_mapper.go

@@ -14,6 +14,7 @@ import (
 	awsAdapters "github.com/overmindtech/cli/aws-source/adapters"
 	k8sAdapters "github.com/overmindtech/cli/k8s-source/adapters"
 	"github.com/overmindtech/cli/sdp-go"
+	gcpAdapters "github.com/overmindtech/workspace/sources/gcp/adapters"
 	log "github.com/sirupsen/logrus"
 	"go.opentelemetry.io/otel/attribute"
 	"go.opentelemetry.io/otel/trace"
@@ -147,7 +148,9 @@ func MappedItemDiffsFromPlan(ctx context.Context, planJson []byte, fileName stri
 
 	// Load mapping data from the sources and convert into a map so that we can
 	// index by Terraform type
-	adapterMetadata := append(awsAdapters.Metadata.AllAdapterMetadata(), k8sAdapters.Metadata.AllAdapterMetadata()...)
+	adapterMetadata := awsAdapters.Metadata.AllAdapterMetadata()
+	adapterMetadata = append(adapterMetadata, k8sAdapters.Metadata.AllAdapterMetadata()...)
+	adapterMetadata = append(adapterMetadata, gcpAdapters.Metadata.AllAdapterMetadata()...)
 	// These mappings are from the terraform type, to required mapping data
 	mappings := make(map[string][]TfMapData)
 	for _, metadata := range adapterMetadata {