Add google_eventarc_pipeline resource (#13265) (#21761)

[upstream:0dc748220e17769a9c27625ba6b681a4b405dafe]

Signed-off-by: Modular Magician <[email protected]>

Author: modular-magician

.changelog/13265.txt

@@ -0,0 +1,3 @@
+```release-note:new-resource
+`google_eventarc_pipeline`
+```

google/provider/provider_mmv1_resources.go

@@ -486,9 +486,9 @@ var handwrittenIAMDatasources = map[string]*schema.Resource{
 }
 
 // Resources
-// Generated resources: 547
+// Generated resources: 548
 // Generated IAM resources: 276
-// Total generated resources: 823
+// Total generated resources: 824
 var generatedResources = map[string]*schema.Resource{
 	"google_folder_access_approval_settings":                                     accessapproval.ResourceAccessApprovalFolderSettings(),
 	"google_organization_access_approval_settings":                               accessapproval.ResourceAccessApprovalOrganizationSettings(),
@@ -916,6 +916,7 @@ var generatedResources = map[string]*schema.Resource{
 	"google_eventarc_google_api_source":                                          eventarc.ResourceEventarcGoogleApiSource(),
 	"google_eventarc_google_channel_config":                                      eventarc.ResourceEventarcGoogleChannelConfig(),
 	"google_eventarc_message_bus":                                                eventarc.ResourceEventarcMessageBus(),
+	"google_eventarc_pipeline":                                                   eventarc.ResourceEventarcPipeline(),
 	"google_eventarc_trigger":                                                    eventarc.ResourceEventarcTrigger(),
 	"google_filestore_backup":                                                    filestore.ResourceFilestoreBackup(),
 	"google_filestore_instance":                                                  filestore.ResourceFilestoreInstance(),

google/services/eventarc/resource_eventarc_message_bus_test.go

@@ -23,6 +23,7 @@ func TestAccEventarcMessageBus(t *testing.T) {
 		"cryptoKey":       testAccEventarcMessageBus_cryptoKey,
 		"update":          testAccEventarcMessageBus_update,
 		"googleApiSource": testAccEventarcMessageBus_googleApiSource,
+		"pipeline":        testAccEventarcMessageBus_pipeline,
 	}
 
 	for name, tc := range testCases {
@@ -286,14 +287,61 @@ resource "google_eventarc_google_api_source" "primary" {
     log_severity = "DEBUG"
   }
 }
-
 resource "google_eventarc_message_bus" "message_bus" {
   location       = "%{region}"
   message_bus_id = "tf-test-messagebus%{random_suffix}"
 }
 `, context)
 }
 
+// Although this test is defined in resource_eventarc_message_bus_test, it is primarily
+// concerned with testing the Pipeline resource, which depends on a singleton MessageBus.
+func testAccEventarcMessageBus_pipeline(t *testing.T) {
+	context := map[string]interface{}{
+		"project_id":              envvar.GetTestProjectFromEnv(),
+		"region":                  envvar.GetTestRegionFromEnv(),
+		"random_suffix":           acctest.RandString(t, 10),
+		"network_attachment_name": acctest.BootstrapNetworkAttachment(t, "tf-test-eventarc-messagebus-na", acctest.BootstrapSubnet(t, "tf-test-eventarc-messagebus-subnet", acctest.BootstrapSharedTestNetwork(t, "tf-test-eventarc-messagebus-network"))),
+	}
+
+	acctest.VcrTest(t, resource.TestCase{
+		PreCheck:                 func() { acctest.AccTestPreCheck(t) },
+		ProtoV5ProviderFactories: acctest.ProtoV5ProviderFactories(t),
+		CheckDestroy:             testAccCheckEventarcPipelineDestroyProducer(t),
+		Steps: []resource.TestStep{
+			{
+				Config: testAccEventarcMessageBus_pipelineCfg(context),
+			},
+			{
+				ResourceName:            "google_eventarc_pipeline.primary",
+				ImportState:             true,
+				ImportStateVerify:       true,
+				ImportStateVerifyIgnore: []string{"labels", "terraform_labels", "annotations"},
+			},
+		},
+	})
+}
+
+func testAccEventarcMessageBus_pipelineCfg(context map[string]interface{}) string {
+	return acctest.Nprintf(`
+resource "google_eventarc_pipeline" "primary" {
+  location    = "%{region}"
+  pipeline_id = "tf-test-some-pipeline%{random_suffix}"
+  destinations {
+    message_bus = google_eventarc_message_bus.primary.id
+    network_config {
+      network_attachment = "projects/%{project_id}/regions/%{region}/networkAttachments/%{network_attachment_name}"
+    }
+  }
+}
+
+resource "google_eventarc_message_bus" "primary" {
+  location       = "%{region}"
+  message_bus_id = "tf-test-messagebus%{random_suffix}"
+}
+`, context)
+}
+
 func testAccCheckEventarcMessageBusDestroyProducer(t *testing.T) func(s *terraform.State) error {
 	return func(s *terraform.State) error {
 		for name, rs := range s.RootModule().Resources {