Add CA Product DataSource

Author: aidy

docs/data-sources/ca_product.md

@@ -0,0 +1,26 @@
+---
+# generated by https://github.com/hashicorp/terraform-plugin-docs
+page_title: "tlspc_ca_product Data Source - tlspc"
+subcategory: ""
+description: |-
+  
+---
+
+# tlspc_ca_product (Data Source)
+
+
+
+
+
+<!-- schema generated by tfplugindocs -->
+## Schema
+
+### Required
+
+- `ca_name` (String)
+- `product_option` (String)
+- `type` (String)
+
+### Read-Only
+
+- `id` (String) The ID of this resource.

internal/provider/ca_product_data_source.go

@@ -0,0 +1,106 @@
+// Copyright (c) Venafi, Inc.
+// SPDX-License-Identifier: MPL-2.0
+
+package provider
+
+import (
+	"context"
+	"fmt"
+
+	"terraform-provider-tlspc/internal/tlspc"
+
+	"github.com/hashicorp/terraform-plugin-framework/datasource"
+	"github.com/hashicorp/terraform-plugin-framework/datasource/schema"
+	"github.com/hashicorp/terraform-plugin-framework/types"
+)
+
+// Ensure the implementation satisfies the expected interfaces.
+var (
+	_ datasource.DataSource              = &caProductDataSource{}
+	_ datasource.DataSourceWithConfigure = &caProductDataSource{}
+)
+
+// NewCoffeesDataSource is a helper function to simplify the provider implementation.
+func NewCAProductDataSource() datasource.DataSource {
+	return &caProductDataSource{}
+}
+
+// caProductDataSource is the data source implementation.
+type caProductDataSource struct {
+	client *tlspc.Client
+}
+
+// Configure adds the provider configured client to the data source.
+func (d *caProductDataSource) Configure(_ context.Context, req datasource.ConfigureRequest, resp *datasource.ConfigureResponse) {
+	// Add a nil check when handling ProviderData because Terraform
+	// sets that data after it calls the ConfigureProvider RPC.
+	if req.ProviderData == nil {
+		return
+	}
+
+	client, ok := req.ProviderData.(*tlspc.Client)
+	if !ok {
+		resp.Diagnostics.AddError(
+			"Unexpected Data Source Configure Type",
+			fmt.Sprintf("Expected *tlspc.Client, got: %T. Please report this issue to the provider developers.", req.ProviderData),
+		)
+
+		return
+	}
+
+	d.client = client
+}
+
+// Metadata returns the data source type name.
+func (d *caProductDataSource) Metadata(_ context.Context, req datasource.MetadataRequest, resp *datasource.MetadataResponse) {
+	resp.TypeName = req.ProviderTypeName + "_ca_product"
+}
+
+// Schema defines the schema for the data source.
+func (d *caProductDataSource) Schema(_ context.Context, _ datasource.SchemaRequest, resp *datasource.SchemaResponse) {
+	resp.Schema = schema.Schema{
+		Attributes: map[string]schema.Attribute{
+			"id": schema.StringAttribute{
+				Computed: true,
+			},
+			"type": schema.StringAttribute{
+				Required: true,
+			},
+			"ca_name": schema.StringAttribute{
+				Required: true,
+			},
+			"product_option": schema.StringAttribute{
+				Required: true,
+			},
+		},
+	}
+}
+
+type caProductDataSourceModel struct {
+	ID            types.String `tfsdk:"id"`
+	Type          types.String `tfsdk:"type"`
+	CAName        types.String `tfsdk:"ca_name"`
+	ProductOption types.String `tfsdk:"product_option"`
+}
+
+// Read refreshes the Terraform state with the latest data.
+func (d *caProductDataSource) Read(ctx context.Context, req datasource.ReadRequest, resp *datasource.ReadResponse) {
+	var model caProductDataSourceModel
+	diags := req.Config.Get(ctx, &model)
+	resp.Diagnostics.Append(diags...)
+	if resp.Diagnostics.HasError() {
+		return
+	}
+
+	caProduct, err := d.client.GetCAProductOption(model.Type.ValueString(), model.CAName.ValueString(), model.ProductOption.ValueString())
+	if err != nil {
+		resp.Diagnostics.AddError(
+			"Error retrieving CA Product",
+			fmt.Sprintf("Error retrieving CA Product: %s", err.Error()),
+		)
+		return
+	}
+	model.ID = types.StringValue(caProduct.ID)
+	diags = resp.State.Set(ctx, &model)
+	resp.Diagnostics.Append(diags...)
+}

internal/provider/provider.go

@@ -92,6 +92,7 @@ func (p *tlspcProvider) Resources(ctx context.Context) []func() resource.Resourc
 func (p *tlspcProvider) DataSources(ctx context.Context) []func() datasource.DataSource {
 	return []func() datasource.DataSource{
 		NewUserDataSource,
+		NewCAProductDataSource,
 	}
 }
 

internal/tlspc/tlspc.go

@@ -505,3 +505,53 @@ func (c *Client) DeletePlugin(id string) error {
 
 	return nil
 }
+
+type CAProductOption struct {
+	ID   string `json:"id"`
+	Name string `json:"productName"`
+}
+
+type CAAccount struct {
+	ID   string `json:"id"`
+	Name string `json:"key"`
+}
+
+type caAccounts struct {
+	Accounts []caAccount `json:"accounts"`
+}
+
+type caAccount struct {
+	Account        CAAccount         `json:"account"`
+	ProductOptions []CAProductOption `json:"productOptions"`
+}
+
+func (c *Client) GetCAProductOption(kind, name, option string) (*CAProductOption, error) {
+	path := c.Path(`%s/v1/certificateauthorities/` + kind + "/accounts")
+
+	resp, err := c.Get(path)
+	if err != nil {
+		return nil, fmt.Errorf("Error getting user: %s", err)
+	}
+	body, err := io.ReadAll(resp.Body)
+	if err != nil {
+		return nil, fmt.Errorf("Error reading response body: %s", err)
+	}
+	var accounts caAccounts
+	err = json.Unmarshal(body, &accounts)
+	if err != nil {
+		return nil, fmt.Errorf("Error decoding response: %s", string(body))
+	}
+	for _, acc := range accounts.Accounts {
+		acct := acc.Account
+		if acct.Name != name {
+			continue
+		}
+		for _, opt := range acc.ProductOptions {
+			if opt.Name == option {
+				return &opt, nil
+			}
+		}
+	}
+
+	return nil, fmt.Errorf("Specified CA product option not found.")
+}