nats_credentials_test.go

package mnq_test

import (
	"fmt"
	"testing"

	"github.com/hashicorp/terraform-plugin-sdk/v2/helper/resource"
	"github.com/hashicorp/terraform-plugin-sdk/v2/terraform"
	mnqSDK "github.com/scaleway/scaleway-sdk-go/api/mnq/v1beta1"
	"github.com/scaleway/terraform-provider-scaleway/v2/internal/acctest"
	"github.com/scaleway/terraform-provider-scaleway/v2/internal/httperrors"
	"github.com/scaleway/terraform-provider-scaleway/v2/internal/services/mnq"
)

func TestAccNatsCredentials_Basic(t *testing.T) {
	tt := acctest.NewTestTools(t)
	defer tt.Cleanup()

	resource.ParallelTest(t, resource.TestCase{
		PreCheck:          func() { acctest.PreCheck(t) },
		ProviderFactories: tt.ProviderFactories,
		CheckDestroy:      isNatsCredentialsDestroyed(tt),
		Steps: []resource.TestStep{
			{
				Config: `
					resource scaleway_account_project main {
						name = "tf_tests_mnq_nats_credential_basic"
					}

					resource scaleway_mnq_nats_account main {
						project_id = scaleway_account_project.main.id
						name = "test-mnq-nats-credentials-basic-test"
					}

					resource scaleway_mnq_nats_credentials main {
						account_id = scaleway_mnq_nats_account.main.id
					}
				`,
				Check: resource.ComposeTestCheckFunc(
					isNatsCredentialsPresent(tt, "scaleway_mnq_nats_credentials.main"),
					resource.TestCheckResourceAttrSet("scaleway_mnq_nats_credentials.main", "file"),
				),
			},
		},
	})
}

func TestAccNatsCredentials_UpdateName(t *testing.T) {
	tt := acctest.NewTestTools(t)
	defer tt.Cleanup()

	resource.ParallelTest(t, resource.TestCase{
		PreCheck:          func() { acctest.PreCheck(t) },
		ProviderFactories: tt.ProviderFactories,
		CheckDestroy:      isNatsCredentialsDestroyed(tt),
		Steps: []resource.TestStep{
			{
				Config: `
					resource scaleway_account_project main {
						name = "tf_tests_mnq_nats_credential_update"
					}

					resource scaleway_mnq_nats_account main {
						project_id = scaleway_account_project.main.id
						name = "test-mnq-nats-credentials-update"
					}

					resource scaleway_mnq_nats_credentials main {
						account_id = scaleway_mnq_nats_account.main.id
					}
				`,
				Check: resource.ComposeTestCheckFunc(
					isNatsCredentialsPresent(tt, "scaleway_mnq_nats_credentials.main"),
					resource.TestCheckResourceAttrSet("scaleway_mnq_nats_credentials.main", "file"),
				),
			},
			{
				Config: `
					resource scaleway_account_project main {
						name = "tf_tests_mnq_nats_credential_update"
					}

					resource scaleway_mnq_nats_account main {
						project_id = scaleway_account_project.main.id
						name = "test-mnq-nats-credentials-update"
					}

					resource scaleway_mnq_nats_credentials main {
						account_id = scaleway_mnq_nats_account.main.id
						name="toto"
					}
				`,
				Check: resource.ComposeTestCheckFunc(
					isNatsCredentialsPresent(tt, "scaleway_mnq_nats_credentials.main"),
					resource.TestCheckResourceAttrSet("scaleway_mnq_nats_credentials.main", "file"),
				),
			},
		},
	})
}

func isNatsCredentialsPresent(tt *acctest.TestTools, n string) resource.TestCheckFunc {
	return func(state *terraform.State) error {
		rs, ok := state.RootModule().Resources[n]
		if !ok {
			return fmt.Errorf("resource not found: %s", n)
		}

		api, region, id, err := mnq.NewNatsAPIWithRegionAndID(tt.Meta, rs.Primary.ID)
		if err != nil {
			return err
		}

		_, err = api.GetNatsCredentials(&mnqSDK.NatsAPIGetNatsCredentialsRequest{
			NatsCredentialsID: id,
			Region:            region,
		})
		if err != nil {
			return err
		}

		return nil
	}
}

func isNatsCredentialsDestroyed(tt *acctest.TestTools) resource.TestCheckFunc {
	return func(state *terraform.State) error {
		for _, rs := range state.RootModule().Resources {
			if rs.Type != "scaleway_mnq_nats_credentials" {
				continue
			}

			api, region, id, err := mnq.NewNatsAPIWithRegionAndID(tt.Meta, rs.Primary.ID)
			if err != nil {
				return err
			}

			err = api.DeleteNatsCredentials(&mnqSDK.NatsAPIDeleteNatsCredentialsRequest{
				NatsCredentialsID: id,
				Region:            region,
			})

			if err == nil {
				return fmt.Errorf("mnq nats credentials (%s) still exists", rs.Primary.ID)
			}

			if !httperrors.Is404(err) {
				return err
			}
		}

		return nil
	}
}