feat(mnq): add datasource for sns (#2718)

Author: jremy42

docs/data-sources/mnq_sns.md

@@ -0,0 +1,41 @@
+---
+subcategory: "Messaging and Queuing"
+page_title: "Scaleway: scaleway_mnq_sns"
+---
+
+# scaleway_mnq_sns
+
+Gets information about SNS for a Project
+
+## Examples
+
+### Basic
+
+```hcl
+// For default project
+data "scaleway_mnq_sns" "main" {}
+
+// For specific project
+data "scaleway_mnq_sns" "for_project" {
+  project_id = scaleway_account_project.main.id
+}
+```
+
+## Arguments Reference
+
+The following arguments are supported:
+
+- `region` - (Defaults to [provider](../index.md#region) `region`). The [region](../guides/regions_and_zones.md#regions) in which sns is enabled.
+
+- `project_id` - (Defaults to [provider](../index.md#project_id) `project_id`) The ID of the Project in which sns is enabled.
+
+
+## Attributes Reference
+
+In addition to all arguments above, the following attributes are exported:
+
+- `id` - The ID of the Project
+
+~> **Important:** Messaging and Queueing sns' IDs are [regional](../guides/regions_and_zones.md#resource-ids), which means they are of the form `{region}/{id}`, e.g. `fr-par/11111111-1111-1111-1111-111111111111`
+
+- `endpoint` - The endpoint of the SNS service for this Project.

internal/provider/provider.go

@@ -287,6 +287,7 @@ func Provider(config *Config) plugin.ProviderFunc {
 				"scaleway_lbs":                                 lb.DataSourceLbs(),
 				"scaleway_marketplace_image":                   marketplace.DataSourceImage(),
 				"scaleway_mnq_sqs":                             mnq.DataSourceSQS(),
+				"scaleway_mnq_sns":                             mnq.DataSourceSNS(),
 				"scaleway_object_bucket":                       object.DataSourceBucket(),
 				"scaleway_object_bucket_policy":                object.DataSourceBucketPolicy(),
 				"scaleway_rdb_acl":                             rdb.DataSourceACL(),

internal/services/mnq/sns_data_source.go

@@ -0,0 +1,56 @@
+package mnq
+
+import (
+	"context"
+	"fmt"
+
+	"github.com/hashicorp/terraform-plugin-sdk/v2/diag"
+	"github.com/hashicorp/terraform-plugin-sdk/v2/helper/schema"
+	mnq "github.com/scaleway/scaleway-sdk-go/api/mnq/v1beta1"
+	"github.com/scaleway/terraform-provider-scaleway/v2/internal/datasource"
+)
+
+func DataSourceSNS() *schema.Resource {
+	// Generate datasource schema from resource
+	dsSchema := datasource.SchemaFromResourceSchema(ResourceSNS().Schema)
+
+	datasource.AddOptionalFieldsToSchema(dsSchema, "region", "project_id")
+
+	return &schema.Resource{
+		ReadContext: DataSourceMNQSNSRead,
+		Schema:      dsSchema,
+	}
+}
+
+func DataSourceMNQSNSRead(ctx context.Context, d *schema.ResourceData, m interface{}) diag.Diagnostics {
+	api, region, err := newMNQSNSAPI(d, m)
+	if err != nil {
+		return diag.FromErr(err)
+	}
+
+	sns, err := api.GetSnsInfo(&mnq.SnsAPIGetSnsInfoRequest{
+		Region:    region,
+		ProjectID: d.Get("project_id").(string),
+	})
+	if err != nil {
+		return diag.FromErr(err)
+	}
+
+	if sns.Status != mnq.SnsInfoStatusEnabled {
+		return diag.FromErr(fmt.Errorf("expected mnq sns status to be enabled, got: %s", sns.Status))
+	}
+
+	regionID := datasource.NewRegionalID(sns.ProjectID, region)
+	d.SetId(regionID)
+
+	diags := ResourceMNQSNSRead(ctx, d, m)
+	if diags != nil {
+		return append(diags, diag.Errorf("failed to read sns state")...)
+	}
+
+	if d.Id() == "" {
+		return diag.Errorf("sns (%s) not found", regionID)
+	}
+
+	return nil
+}

internal/services/mnq/sns_data_source_test.go

@@ -0,0 +1,42 @@
+package mnq_test
+
+import (
+	"testing"
+
+	"github.com/hashicorp/terraform-plugin-sdk/v2/helper/resource"
+	"github.com/scaleway/terraform-provider-scaleway/v2/internal/acctest"
+)
+
+func TestAccDataSourceSNS_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: resource.ComposeTestCheckFunc(
+			isSNSDestroyed(tt),
+		),
+		Steps: []resource.TestStep{
+			{
+				Config: `
+					resource scaleway_account_project main {
+						name = "tf_tests_ds_mnq_sns_basic"
+					}
+
+					resource scaleway_mnq_sns main {
+						project_id = scaleway_account_project.main.id
+					}
+
+					data scaleway_mnq_sns main {
+						project_id = scaleway_mnq_sns.main.project_id
+					}
+				`,
+				Check: resource.ComposeTestCheckFunc(
+					isSNSPresent(tt, "scaleway_mnq_sns.main"),
+
+					resource.TestCheckResourceAttrPair("scaleway_mnq_sns.main", "id", "data.scaleway_mnq_sns.main", "id"),
+				),
+			},
+		},
+	})
+}