Add plural data source for retrieving Artifact Registry versions (#14727)

Author: bestefreund

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

@@ -42,6 +42,7 @@ var handwrittenDatasources = map[string]*schema.Resource{
 	"google_artifact_registry_tag":                     artifactregistry.DataSourceArtifactRegistryTag(),
 	"google_artifact_registry_tags":                    artifactregistry.DataSourceArtifactRegistryTags(),
 	"google_artifact_registry_version":                 artifactregistry.DataSourceArtifactRegistryVersion(),
+	"google_artifact_registry_versions":                artifactregistry.DataSourceArtifactRegistryVersions(),
 	"google_apphub_discovered_workload":		    apphub.DataSourceApphubDiscoveredWorkload(),
 	"google_app_engine_default_service_account":        appengine.DataSourceGoogleAppEngineDefaultServiceAccount(),
 	"google_apphub_application":						apphub.DataSourceGoogleApphubApplication(),

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

@@ -0,0 +1,236 @@
+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 DataSourceArtifactRegistryVersions() *schema.Resource {
+	return &schema.Resource{
+		Read: dataSourceArtifactRegistryVersionsRead,
+		Schema: map[string]*schema.Schema{
+			"location": {
+				Type:     schema.TypeString,
+				Required: true,
+			},
+			"repository_id": {
+				Type:     schema.TypeString,
+				Required: true,
+			},
+			"package_name": {
+				Type:     schema.TypeString,
+				Required: true,
+			},
+			"filter": {
+				Type:     schema.TypeString,
+				Optional: true,
+			},
+			"view": {
+				Type:         schema.TypeString,
+				Optional:     true,
+				Default:      "BASIC",
+				ValidateFunc: validateViewArtifactRegistryVersions,
+			},
+			"project": {
+				Type:     schema.TypeString,
+				Optional: true,
+			},
+			"versions": {
+				Type:     schema.TypeList,
+				Computed: true,
+				Elem: &schema.Resource{
+					Schema: map[string]*schema.Schema{
+						"name": {
+							Type:     schema.TypeString,
+							Computed: true,
+						},
+						"description": {
+							Type:     schema.TypeString,
+							Computed: true,
+						},
+						"related_tags": {
+							Type:     schema.TypeList,
+							Computed: true,
+							Elem: &schema.Resource{
+								Schema: map[string]*schema.Schema{
+									"name": {
+										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,
+						},
+						"annotations": {
+							Type:     schema.TypeMap,
+							Computed: true,
+							Elem:     &schema.Schema{Type: schema.TypeString},
+						},
+					},
+				},
+			},
+		},
+	}
+}
+
+func dataSourceArtifactRegistryVersionsRead(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}}/packages/{{package_name}}/versions"))
+	if err != nil {
+		return fmt.Errorf("Error setting resource path: %s", err)
+	}
+
+	view := d.Get("view").(string)
+
+	urlRequest := basePath + resourcePath
+
+	u, err := url.Parse(urlRequest)
+	if err != nil {
+		return fmt.Errorf("Error parsing URL: %s", err)
+	}
+
+	q := u.Query()
+	q.Set("view", view)
+
+	filter := ""
+	if v, ok := d.GetOk("filter"); ok {
+		filter = v.(string)
+		q.Set("filter", filter)
+	}
+
+	u.RawQuery = q.Encode()
+	urlRequest = u.String()
+
+	headers := make(http.Header)
+	versions := 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 versions: %s", err)
+		}
+
+		if items, ok := res["versions"].([]interface{}); ok {
+			for _, item := range items {
+				version := item.(map[string]interface{})
+
+				var relatedTags []map[string]interface{}
+				if rawTags, ok := version["relatedTags"].([]interface{}); ok {
+					for _, rawTag := range rawTags {
+						if tagMap, ok := rawTag.(map[string]interface{}); ok {
+							entry := map[string]interface{}{
+								"name":    tagMap["name"],
+								"version": tagMap["version"],
+							}
+							relatedTags = append(relatedTags, entry)
+						}
+					}
+				}
+
+				annotations := make(map[string]string)
+				if anno, ok := version["annotations"].(map[string]interface{}); ok {
+					for k, v := range anno {
+						if val, ok := v.(string); ok {
+							annotations[k] = val
+						}
+					}
+				}
+
+				getString := func(m map[string]interface{}, key string) string {
+					if v, ok := m[key].(string); ok {
+						return v
+					}
+					return ""
+				}
+
+				versions = append(versions, map[string]interface{}{
+					"name":         getString(version, "name"),
+					"description":  getString(version, "description"),
+					"related_tags": relatedTags,
+					"create_time":  getString(version, "createTime"),
+					"update_time":  getString(version, "updateTime"),
+					"annotations":  annotations,
+				})
+			}
+		}
+
+		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("versions", versions); err != nil {
+		return fmt.Errorf("Error setting Artifact Registry versions: %s", err)
+	}
+
+	d.SetId(resourcePath)
+
+	return nil
+}
+
+func validateViewArtifactRegistryVersions(val interface{}, key string) ([]string, []error) {
+	v := val.(string)
+	var errs []error
+
+	if v != "BASIC" && v != "FULL" {
+		errs = append(errs, fmt.Errorf("%q must be either 'BASIC' or 'FULL', got %q", key, v))
+	}
+
+	return nil, errs
+}

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

@@ -0,0 +1,45 @@
+package artifactregistry_test
+
+import (
+	"testing"
+
+	"github.com/hashicorp/terraform-plugin-testing/helper/resource"
+	"github.com/hashicorp/terraform-provider-google/google/acctest"
+)
+
+func TestAccDataSourceArtifactRegistryVersions_basic(t *testing.T) {
+	t.Parallel()
+
+	acctest.VcrTest(t, resource.TestCase{
+		PreCheck:                 func() { acctest.AccTestPreCheck(t) },
+		ProtoV5ProviderFactories: acctest.ProtoV5ProviderFactories(t),
+		Steps: []resource.TestStep{
+			{
+				Config: testAccDataSourceArtifactRegistryVersionsConfig,
+				Check: resource.ComposeTestCheckFunc(
+					resource.TestCheckResourceAttrSet("data.google_artifact_registry_versions.this", "project"),
+					resource.TestCheckResourceAttrSet("data.google_artifact_registry_versions.this", "location"),
+					resource.TestCheckResourceAttrSet("data.google_artifact_registry_versions.this", "repository_id"),
+					resource.TestCheckResourceAttrSet("data.google_artifact_registry_versions.this", "package_name"),
+					resource.TestCheckResourceAttrSet("data.google_artifact_registry_versions.this", "versions.0.name"),
+					resource.TestCheckResourceAttrSet("data.google_artifact_registry_versions.this", "versions.0.create_time"),
+					resource.TestCheckResourceAttrSet("data.google_artifact_registry_versions.this", "versions.0.update_time"),
+				),
+			},
+		},
+	})
+}
+
+// Test the data source against the public AR repos
+// https://console.cloud.google.com/artifacts/docker/cloudrun/us/container
+// https://console.cloud.google.com/artifacts/docker/go-containerregistry/us/gcr.io
+const testAccDataSourceArtifactRegistryVersionsConfig = `
+data "google_artifact_registry_versions" "this" {
+  project       = "go-containerregistry"
+  location      = "us"
+  repository_id = "gcr.io"
+  package_name  = "gcrane"
+  filter        = "name=\"projects/go-containerregistry/locations/us/repositories/gcr.io/packages/gcrane/versions/*:b*\""
+  view          = "FULL"
+}
+`

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

@@ -0,0 +1,57 @@
+---
+subcategory: "Artifact Registry"
+description: |-
+  Get information about versions within a Google Artifact Registry package.
+---
+
+# google_artifact_registry_versions
+
+Get information about Artifact Registry versions.
+See [the official documentation](https://cloud.google.com/artifact-registry/docs/overview)
+and [API](https://cloud.google.com/artifact-registry/docs/reference/rest/v1/projects.locations.repositories.packages.versions/list).
+
+## Example Usage
+
+```hcl
+data "google_artifact_registry_versions" "my_versions" {
+  location      = "us-central1"
+  repository_id = "example-repo"
+  package_name  = "example-package"
+}
+```
+
+## Argument Reference
+
+The following arguments are supported:
+
+* `location` - (Required) The location of the artifact registry.
+
+* `repository_id` - (Required) The last part of the repository name to fetch from.
+
+* `package_name` - (Required) The name of the package.
+
+* `filter` - (Optional) An expression for filtering the results of the request. Filter rules are case insensitive. The fields eligible for filtering are `name` and `version`. Further information can be found in the [REST API](https://cloud.google.com/artifact-registry/docs/reference/rest/v1/projects.locations.repositories.packages.versions/list#query-parameters).
+
+* `view` - (Optional) The view, which determines what version information is returned in a response. Possible values are `"BASIC"` and `"FULL"`. Defaults to `"BASIC"`.
+
+* `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:
+
+* `versions` - A list of all retrieved Artifact Registry versions. Structure is [defined below](#nested_versions).
+
+<a name="nested_versions"></a>The `versions` block supports:
+
+* `name` - The name of the version, for example: `projects/p1/locations/us-central1/repositories/repo1/packages/pkg1/versions/version1`. If the package part contains slashes, the slashes are escaped.
+
+* `description` - Description of the version, as specified in its metadata.
+
+* `related_tags` - A list of related tags. Will contain up to 100 tags that reference this version.
+
+* `create_time` - The time, as a RFC 3339 string, this package was created. 
+
+* `update_time` - The time, as a RFC 3339 string, this package was last updated. This includes publishing a new version of the package.
+
+* `annotations` - Client specified annotations.