Data source for packer registry

go.mod

@@ -11,7 +11,7 @@ require (
 	github.com/hashicorp/go-cty v1.4.1-0.20200414143053-d3edf31b6320
 	github.com/hashicorp/go-version v1.3.0
 	github.com/hashicorp/hcl/v2 v2.8.2 // indirect
-	github.com/hashicorp/hcp-sdk-go v0.10.0
+	github.com/hashicorp/hcp-sdk-go v0.10.1-0.20210709190444-22372a371cc8
 	github.com/hashicorp/terraform-exec v0.13.3 // indirect
 	github.com/hashicorp/terraform-plugin-docs v0.4.0
 	github.com/hashicorp/terraform-plugin-sdk/v2 v2.5.0

go.sum

@@ -351,8 +351,8 @@ github.com/hashicorp/golang-lru v0.5.1/go.mod h1:/m3WP610KZHVQ1SGc6re/UDhFvYD7pJ
 github.com/hashicorp/hcl/v2 v2.3.0/go.mod h1:d+FwDBbOLvpAM3Z6J7gPj/VoAGkNe/gm352ZhjJ/Zv8=
 github.com/hashicorp/hcl/v2 v2.8.2 h1:wmFle3D1vu0okesm8BTLVDyJ6/OL9DCLUwn0b2OptiY=
 github.com/hashicorp/hcl/v2 v2.8.2/go.mod h1:bQTN5mpo+jewjJgh8jr0JUguIi7qPHUF6yIfAEN3jqY=
-github.com/hashicorp/hcp-sdk-go v0.10.0 h1:RB2GD9orNtINInggRmsw1iC4ODj5X7JagXK5CY+7Db4=
-github.com/hashicorp/hcp-sdk-go v0.10.0/go.mod h1:Tm9BAlTkp6jknZ0YNxF/556JBC/meCN1LUmWFN38HsU=
+github.com/hashicorp/hcp-sdk-go v0.10.1-0.20210709190444-22372a371cc8 h1:OuweqkFd5uNrEbSEs5tThGjODjYNEm/w5SjY8VmwVUU=
+github.com/hashicorp/hcp-sdk-go v0.10.1-0.20210709190444-22372a371cc8/go.mod h1:Tm9BAlTkp6jknZ0YNxF/556JBC/meCN1LUmWFN38HsU=
 github.com/hashicorp/logutils v1.0.0 h1:dLEQVugN8vlakKOUE3ihGLTZJRB4j+M2cdTm/ORI65Y=
 github.com/hashicorp/logutils v1.0.0/go.mod h1:QIAnNjmIWmVIIkWDTG1z5v++HQmx9WQRO+LraFDTW64=
 github.com/hashicorp/terraform-exec v0.12.0/go.mod h1:SGhto91bVRlgXQWcJ5znSz+29UZIa8kpBbkGwQ+g9E8=

internal/clients/client.go

@@ -1,17 +1,23 @@
 package clients
 
 import (
-	cloud_consul "github.com/hashicorp/hcp-sdk-go/clients/cloud-consul-service/preview/2021-02-04/client"
-	"github.com/hashicorp/hcp-sdk-go/clients/cloud-consul-service/preview/2021-02-04/client/consul_service"
 	cloud_network "github.com/hashicorp/hcp-sdk-go/clients/cloud-network/preview/2020-09-07/client"
 	"github.com/hashicorp/hcp-sdk-go/clients/cloud-network/preview/2020-09-07/client/network_service"
 	cloud_operation "github.com/hashicorp/hcp-sdk-go/clients/cloud-operation/preview/2020-05-05/client"
 	"github.com/hashicorp/hcp-sdk-go/clients/cloud-operation/preview/2020-05-05/client/operation_service"
 	cloud_resource_manager "github.com/hashicorp/hcp-sdk-go/clients/cloud-resource-manager/preview/2019-12-10/client"
 	"github.com/hashicorp/hcp-sdk-go/clients/cloud-resource-manager/preview/2019-12-10/client/organization_service"
 	"github.com/hashicorp/hcp-sdk-go/clients/cloud-resource-manager/preview/2019-12-10/client/project_service"
+
+	cloud_consul "github.com/hashicorp/hcp-sdk-go/clients/cloud-consul-service/preview/2021-02-04/client"
+	"github.com/hashicorp/hcp-sdk-go/clients/cloud-consul-service/preview/2021-02-04/client/consul_service"
+
 	cloud_vault "github.com/hashicorp/hcp-sdk-go/clients/cloud-vault-service/preview/2020-11-25/client"
 	"github.com/hashicorp/hcp-sdk-go/clients/cloud-vault-service/preview/2020-11-25/client/vault_service"
+
+	cloud_packer "github.com/hashicorp/hcp-sdk-go/clients/cloud-packer-service/preview/2021-04-30/client"
+	"github.com/hashicorp/hcp-sdk-go/clients/cloud-packer-service/preview/2021-04-30/client/packer_service"
+
 	sdk "github.com/hashicorp/hcp-sdk-go/httpclient"
 )
 
@@ -25,6 +31,7 @@ type Client struct {
 	Organization organization_service.ClientService
 	Consul       consul_service.ClientService
 	Vault        vault_service.ClientService
+	Packer       packer_service.ClientService
 }
 
 // ClientConfig specifies configuration for the client that interacts with HCP
@@ -69,6 +76,7 @@ func NewClient(config ClientConfig) (*Client, error) {
 		Organization: cloud_resource_manager.New(httpClient, nil).OrganizationService,
 		Consul:       cloud_consul.New(httpClient, nil).ConsulService,
 		Vault:        cloud_vault.New(httpClient, nil).VaultService,
+		Packer:       cloud_packer.New(httpClient, nil).PackerService,
 	}
 
 	return client, nil

internal/clients/packer.go

@@ -0,0 +1,26 @@
+package clients
+
+import (
+	"context"
+
+	"github.com/hashicorp/hcp-sdk-go/clients/cloud-packer-service/preview/2021-04-30/client/packer_service"
+	packermodels "github.com/hashicorp/hcp-sdk-go/clients/cloud-packer-service/preview/2021-04-30/models"
+	sharedmodels "github.com/hashicorp/hcp-sdk-go/clients/cloud-shared/v1/models"
+)
+
+func GetPackerChannelBySlug(ctx context.Context, client *Client, loc *sharedmodels.HashicorpCloudLocationLocation,
+	bucketName string, channel string) (*packermodels.HashicorpCloudPackerChannel, error) {
+
+	getParams := packer_service.NewGetChannelParams()
+	getParams.BucketSlug = bucketName
+	getParams.Slug = channel
+	getParams.LocationOrganizationID = loc.OrganizationID
+	getParams.LocationProjectID = loc.ProjectID
+
+	getResp, err := client.Packer.GetChannel(getParams, nil)
+	if err != nil {
+		return nil, err
+	}
+
+	return getResp.Payload.Channel, nil
+}

internal/provider/data_source_packer_image_iteration.go

@@ -0,0 +1,210 @@
+package provider
+
+import (
+	"context"
+	"log"
+	"time"
+
+	packermodels "github.com/hashicorp/hcp-sdk-go/clients/cloud-packer-service/preview/2021-04-30/models"
+	sharedmodels "github.com/hashicorp/hcp-sdk-go/clients/cloud-shared/v1/models"
+	"github.com/hashicorp/terraform-plugin-sdk/v2/diag"
+	"github.com/hashicorp/terraform-plugin-sdk/v2/helper/schema"
+	"github.com/hashicorp/terraform-provider-hcp/internal/clients"
+)
+
+// a minute sounds like a lot already since this would be mainly pulling data.
+var defaultPackerTimeout = time.Minute
+
+func dataSourcePackerImageIteration() *schema.Resource {
+	return &schema.Resource{
+		Description: "The Packer Image data source iteration gets the most recent iteration (or build) of an image given an channel.",
+		ReadContext: dataSourcePackerImageRead,
+		Timeouts: &schema.ResourceTimeout{
+			Default: &defaultPackerTimeout,
+		},
+		Schema: map[string]*schema.Schema{
+			// Required inputs
+			"bucket": {
+				Description:      "The slug of the HCP Packer Registry image bucket to pull from.",
+				Type:             schema.TypeString,
+				Required:         true,
+				ValidateDiagFunc: validateSlugID,
+			},
+			// Optional inputs
+			"channel": {
+				Description:      "The channel that points to the version of the image you want.",
+				Type:             schema.TypeString,
+				Optional:         true,
+				ValidateDiagFunc: validateSlugID,
+			},
+			// computed outputs
+			"organization_id": {
+				Description: "The ID of the organization this HCP Packer registry is located in.",
+				Type:        schema.TypeString,
+				Computed:    true,
+			},
+			"project_id": {
+				Description: "The ID of the project this HCP Packer registry is located in.",
+				Type:        schema.TypeString,
+				Computed:    true,
+			},
+
+			// Actual iteration:
+
+			"id": {
+				Description: "ID of this iteration",
+				Type:        schema.TypeString,
+				Computed:    true,
+			},
+			"incremental_version": {
+				Description: "Incremental version of this iteration",
+				Type:        schema.TypeInt,
+				Computed:    true,
+			},
+			"created_at": {
+				Description: "Creation time of this iteration",
+				Type:        schema.TypeString,
+				Computed:    true,
+			},
+			"builds": {
+				Description: "Builds for this iteration",
+				Type:        schema.TypeList,
+				Computed:    true,
+				Elem: &schema.Schema{
+					Type: schema.TypeSet,
+					Elem: &schema.Resource{
+						Schema: map[string]*schema.Schema{
+							"cloud_provider": {
+								Type: schema.TypeString,
+							},
+							"component_type": {
+								Type: schema.TypeString,
+							},
+							"created_at": {
+								Type: schema.TypeString,
+							},
+							// "id": {
+							// 	Type: schema.TypeString,
+							// },
+							"images": {
+								Type: schema.TypeList,
+								Elem: &schema.Schema{
+									Type: schema.TypeSet,
+									Elem: &schema.Resource{
+										Schema: map[string]*schema.Schema{
+											"created_at": {
+												Type: schema.TypeString,
+											},
+											"id": {
+												Type: schema.TypeString,
+											},
+											"image_id": {
+												Type: schema.TypeString,
+											},
+											"region": {
+												Type: schema.TypeString,
+											},
+										},
+									},
+								},
+							},
+							"iteration_id": {
+								Type: schema.TypeString,
+							},
+							"labels": {
+								Type: schema.TypeMap,
+								Elem: &schema.Schema{
+									Type: schema.TypeString,
+								},
+							},
+							"packer_run_uuid": {
+								Type: schema.TypeString,
+							},
+							"status": {
+								Type: schema.TypeString,
+							},
+							"updated_at": {
+								Type: schema.TypeString,
+							},
+						},
+					},
+				},
+			},
+		},
+	}
+}
+
+func dataSourcePackerImageRead(ctx context.Context, d *schema.ResourceData, meta interface{}) diag.Diagnostics {
+	bucketName := d.Get("bucket").(string)
+	channelSlug := d.Get("channel").(string)
+	client := meta.(*clients.Client)
+
+	loc := &sharedmodels.HashicorpCloudLocationLocation{
+		OrganizationID: client.Config.OrganizationID,
+		ProjectID:      client.Config.ProjectID,
+	}
+
+	if err := setLocationData(d, loc); err != nil {
+		return diag.FromErr(err)
+	}
+
+	log.Printf("[INFO] Reading HCP Packer registry (%s) [project_id=%s, organization_id=%s, channel=%s]", bucketName, loc.ProjectID, loc.OrganizationID, channelSlug)
+
+	channel, err := clients.GetPackerChannelBySlug(ctx, client, loc, bucketName, channelSlug)
+	if err != nil {
+		return diag.FromErr(err)
+	}
+
+	iteration := channel.Pointer.Iteration
+
+	d.SetId(channel.Pointer.Iteration.ID)
+
+	d.Set("incremental_version", iteration.IncrementalVersion)
+	d.Set("created_at", iteration.CreatedAt.String())
+	d.Set("builds", flattenPackerBuildList(iteration.Builds))
+
+	return nil
+}
+
+func setLocationData(d *schema.ResourceData, loc *sharedmodels.HashicorpCloudLocationLocation) error {
+	if err := d.Set("organization_id", loc.OrganizationID); err != nil {
+		return err
+	}
+
+	if err := d.Set("project_id", loc.ProjectID); err != nil {
+		return err
+	}
+	return nil
+}
+
+func flattenPackerBuildList(builds []*packermodels.HashicorpCloudPackerBuild) (flattened []map[string]interface{}) {
+	for _, build := range builds {
+		out := map[string]interface{}{
+			"cloud_provider":  build.CloudProvider,
+			"component_type":  build.ComponentType,
+			"created_at":      build.CreatedAt.String(),
+			"id":              build.ID,
+			"images":          flattenPackerBuildImagesList(build.Images),
+			"iteration_id":    build.IterationID,
+			"labels":          build.Labels,
+			"packer_run_uuid": build.PackerRunUUID,
+			"status":          build.Status,
+			"updated_at":      build.UpdatedAt.String(),
+		}
+		flattened = append(flattened, out)
+	}
+	return
+}
+
+func flattenPackerBuildImagesList(images []*packermodels.HashicorpCloudPackerImage) (flattened []map[string]interface{}) {
+	for _, image := range images {
+		out := map[string]interface{}{
+			"created_at": image.CreatedAt.String(),
+			"id":         image.ID,
+			"image_id":   image.ImageID,
+			"region":     image.Region,
+		}
+		flattened = append(flattened, out)
+	}
+	return
+}

internal/provider/data_source_packer_image_iteration_test.go

@@ -0,0 +1,38 @@
+package provider
+
+import (
+	"os"
+	"testing"
+
+	"github.com/hashicorp/terraform-plugin-sdk/v2/helper/resource"
+)
+
+var (
+	testAccPackerAlpineProductionImage = `
+	data "hcp_packer_image_iteration" "alpine" {
+		bucket  = "alpine"
+		channel = "production"
+	}`
+)
+
+func TestAcc_dataSourcePacker(t *testing.T) {
+	resourceName := "data.hcp_packer_image_iteration.alpine"
+
+	resource.Test(t, resource.TestCase{
+		PreCheck:          func() { testAccPreCheck(t, false) },
+		ProviderFactories: providerFactories,
+
+		Steps: []resource.TestStep{
+			// testing that getting the production channel of the alpine image
+			// works.
+
+			{
+				Config: testConfig(testAccPackerAlpineProductionImage),
+				Check: resource.ComposeTestCheckFunc(
+					resource.TestCheckResourceAttrSet(resourceName, "organization_id"),
+					resource.TestCheckResourceAttrSet(resourceName, "project_id"),
+				),
+			},
+		},
+	})
+}

internal/provider/provider.go

@@ -27,6 +27,7 @@ func New() func() *schema.Provider {
 				"hcp_hvn":                            dataSourceHvn(),
 				"hcp_hvn_route":                      dataSourceHVNRoute(),
 				"hcp_vault_cluster":                  dataSourceVaultCluster(),
+				"hcp_packer_image_iteration":         dataSourcePackerImageIteration(),
 			},
 			ResourcesMap: map[string]*schema.Resource{
 				"hcp_aws_network_peering":            resourceAwsNetworkPeering(),