Add plural data source for retrieving Maven artifacts from an Artifact Registry repository (#14785)

Author: bestefreund

mmv1/third_party/terraform/provider/provider_mmv1_resources.go.tmpl

@@ -30,6 +30,7 @@ var handwrittenDatasources = map[string]*schema.Resource{
 	"google_artifact_registry_docker_images":           artifactregistry.DataSourceArtifactRegistryDockerImages(),
 	"google_artifact_registry_locations":               artifactregistry.DataSourceGoogleArtifactRegistryLocations(),
 	"google_artifact_registry_maven_artifact":          artifactregistry.DataSourceArtifactRegistryMavenArtifact(),
+	"google_artifact_registry_maven_artifacts":         artifactregistry.DataSourceArtifactRegistryMavenArtifacts(),
 	"google_artifact_registry_npm_package":             artifactregistry.DataSourceArtifactRegistryNpmPackage(),
 	"google_artifact_registry_npm_packages":            artifactregistry.DataSourceArtifactRegistryNpmPackages(),
 	"google_artifact_registry_package":                 artifactregistry.DataSourceArtifactRegistryPackage(),

mmv1/third_party/terraform/services/artifactregistry/data_source_artifact_registry_maven_artifacts.go

@@ -0,0 +1,167 @@
+package artifactregistry
+
+import (
+	"fmt"
+	"net/http"
+	"net/url"
+
+	"github.com/hashicorp/terraform-plugin-sdk/v2/helper/schema"
+	"github.com/hashicorp/terraform-provider-google/google/tpgresource"
+	transport_tpg "github.com/hashicorp/terraform-provider-google/google/transport"
+)
+
+func DataSourceArtifactRegistryMavenArtifacts() *schema.Resource {
+	return &schema.Resource{
+		Read: dataSourceArtifactRegistryMavenArtifactsRead,
+		Schema: map[string]*schema.Schema{
+			"location": {
+				Type:     schema.TypeString,
+				Required: true,
+			},
+			"repository_id": {
+				Type:     schema.TypeString,
+				Required: true,
+			},
+			"project": {
+				Type:     schema.TypeString,
+				Optional: true,
+			},
+			"maven_artifacts": {
+				Type:     schema.TypeList,
+				Computed: true,
+				Elem: &schema.Resource{
+					Schema: map[string]*schema.Schema{
+						"name": {
+							Type:     schema.TypeString,
+							Computed: true,
+						},
+						"group_id": {
+							Type:     schema.TypeString,
+							Required: true,
+						},
+						"artifact_id": {
+							Type:     schema.TypeString,
+							Required: true,
+						},
+						"pom_uri": {
+							Type:     schema.TypeString,
+							Computed: true,
+						},
+						"version": {
+							Type:     schema.TypeString,
+							Computed: true,
+						},
+						"create_time": {
+							Type:     schema.TypeString,
+							Computed: true,
+						},
+						"update_time": {
+							Type:     schema.TypeString,
+							Computed: true,
+						},
+					},
+				},
+			},
+		},
+	}
+}
+
+func dataSourceArtifactRegistryMavenArtifactsRead(d *schema.ResourceData, meta interface{}) error {
+	config := meta.(*transport_tpg.Config)
+	userAgent, err := tpgresource.GenerateUserAgentString(d, config.UserAgent)
+	if err != nil {
+		return err
+	}
+
+	project, err := tpgresource.GetProject(d, config)
+	if err != nil {
+		return err
+	}
+
+	basePath, err := tpgresource.ReplaceVars(d, config, "{{ArtifactRegistryBasePath}}")
+	if err != nil {
+		return fmt.Errorf("Error setting Artifact Registry base path: %s", err)
+	}
+
+	resourcePath, err := tpgresource.ReplaceVars(d, config, fmt.Sprintf("projects/{{project}}/locations/{{location}}/repositories/{{repository_id}}/mavenArtifacts"))
+	if err != nil {
+		return fmt.Errorf("Error setting resource path: %s", err)
+	}
+
+	urlRequest := basePath + resourcePath
+
+	headers := make(http.Header)
+	mavenArtifacts := make([]map[string]interface{}, 0)
+	pageToken := ""
+
+	for {
+		u, err := url.Parse(urlRequest)
+		if err != nil {
+			return fmt.Errorf("Error parsing URL: %s", err)
+		}
+
+		q := u.Query()
+		if pageToken != "" {
+			q.Set("pageToken", pageToken)
+		}
+		u.RawQuery = q.Encode()
+
+		res, err := transport_tpg.SendRequest(transport_tpg.SendRequestOptions{
+			Config:    config,
+			Method:    "GET",
+			RawURL:    u.String(),
+			UserAgent: userAgent,
+			Headers:   headers,
+		})
+
+		if err != nil {
+			return fmt.Errorf("Error listing Artifact Registry Maven artifacts: %s", err)
+		}
+
+		if items, ok := res["mavenArtifacts"].([]interface{}); ok {
+			for _, item := range items {
+				pkg := item.(map[string]interface{})
+
+				name, ok := pkg["name"].(string)
+				if !ok {
+					return fmt.Errorf("Error getting Artifact Registry Maven artifact name: %s", err)
+				}
+
+				getString := func(m map[string]interface{}, key string) string {
+					if v, ok := m[key].(string); ok {
+						return v
+					}
+					return ""
+				}
+
+				mavenArtifacts = append(mavenArtifacts, map[string]interface{}{
+					"name":        name,
+					"group_id":    getString(pkg, "groupId"),
+					"artifact_id": getString(pkg, "artifactId"),
+					"pom_uri":     getString(pkg, "pomUri"),
+					"version":     getString(pkg, "version"),
+					"create_time": getString(pkg, "createTime"),
+					"update_time": getString(pkg, "updateTime"),
+				})
+			}
+		}
+
+		if nextToken, ok := res["nextPageToken"].(string); ok && nextToken != "" {
+			pageToken = nextToken
+		} else {
+			break
+		}
+	}
+
+	if err := d.Set("project", project); err != nil {
+		return fmt.Errorf("Error setting project: %s", err)
+	}
+
+	if err := d.Set("maven_artifacts", mavenArtifacts); err != nil {
+		return fmt.Errorf("Error setting Artifact Registry Maven artifacts: %s", err)
+	}
+
+	d.SetId(resourcePath)
+
+	return nil
+}

mmv1/third_party/terraform/services/artifactregistry/data_source_artifact_registry_maven_artifacts_test.go

@@ -0,0 +1,43 @@
+package artifactregistry_test
+
+import (
+	"testing"
+
+	"github.com/hashicorp/terraform-plugin-testing/helper/resource"
+	"github.com/hashicorp/terraform-provider-google/google/acctest"
+)
+
+func TestAccDataSourceArtifactRegistryMavenArtifacts_basic(t *testing.T) {
+	t.Parallel()
+
+	// At the moment there are no public Maven artifacts available in Artifact Registry.
+	// This test is skipped to avoid unnecessary failures.
+	// As soon as there are public artifacts available, this test can be enabled by removing the skip and adjusting the configuration accordingly.
+	t.Skip("No public Maven artifacts available in Artifact Registry")
+
+	acctest.VcrTest(t, resource.TestCase{
+		PreCheck:                 func() { acctest.AccTestPreCheck(t) },
+		ProtoV5ProviderFactories: acctest.ProtoV5ProviderFactories(t),
+		Steps: []resource.TestStep{
+			{
+				Config: testAccDataSourceArtifactRegistryMavenArtifactsConfig,
+				Check: resource.ComposeTestCheckFunc(
+					resource.TestCheckResourceAttrSet("data.google_artifact_registry_maven_artifacts.test", "project"),
+					resource.TestCheckResourceAttrSet("data.google_artifact_registry_maven_artifacts.test", "location"),
+					resource.TestCheckResourceAttrSet("data.google_artifact_registry_maven_artifacts.test", "repository_id"),
+					resource.TestCheckResourceAttrSet("data.google_artifact_registry_maven_artifacts.test", "maven_artifacts.0.artifact_id"),
+					resource.TestCheckResourceAttrSet("data.google_artifact_registry_maven_artifacts.test", "maven_artifacts.0.group_id"),
+					resource.TestCheckResourceAttrSet("data.google_artifact_registry_maven_artifacts.test", "maven_artifacts.0.name"),
+				),
+			},
+		},
+	})
+}
+
+const testAccDataSourceArtifactRegistryMavenArtifactsConfig = `
+data "google_artifact_registry_maven_artifacts" "test" {
+  project       = "example-project"
+  location      = "us"
+  repository_id = "example-repo"
+}
+`

mmv1/third_party/terraform/website/docs/d/artifact_registry_maven_artifacts.html.markdown

@@ -0,0 +1,55 @@
+---
+subcategory: "Artifact Registry"
+description: |-
+  Get information about Maven artifacts within a Google Artifact Registry repository.
+---
+
+# google_artifact_registry_maven_artifacts
+
+Get information about Artifact Registry Maven artifacts.
+See [the official documentation](https://cloud.google.com/artifact-registry/docs/java)
+and [API](https://cloud.google.com/artifact-registry/docs/reference/rest/v1/projects.locations.repositories.mavenArtifacts/list).
+
+## Example Usage
+
+```hcl
+data "google_artifact_registry_maven_artifacts" "my_artifacts" {
+  location      = "us-central1"
+  repository_id = "example-repo"
+}
+```
+
+## Argument Reference
+
+The following arguments are supported:
+
+* `location` - (Required) The location of the Artifact Registry repository.
+
+* `repository_id` - (Required) The last part of the repository name to fetch from.
+
+* `project` - (Optional) The project ID in which the resource belongs. If it is not provided, the provider project is used.
+
+## Attributes Reference
+
+The following attributes are exported:
+
+* `maven_artifacts` - A list of all retrieved Artifact Registry Maven artifacts. Structure is [defined below](#nested_maven_artifacts).
+
+<a name="nested_maven_artifacts"></a>The `maven_artifacts` block supports:
+
+* `name` – The fully qualified name of the fetched artifact. Format:
+  ```
+  projects/{{project}}/locations/{{location}}/repositories/{{repository_id}}/mavenArtifacts/{{group_id}}:{{artifact_id}}:{{version}}
+  ```
+
+* `group_id` – Group ID for the artifact.
+
+* `artifact_id` – The name of the artifact to fetch.
+
+* `pom_uri` – URL to access the pom file of the artifact.
+
+* `version` – The version of the Maven artifact.
+
+* `create_time` – The time the artifact was created.
+
+* `update_time` – The time the artifact was last updated.