feat(mirrored_database): Add mirrored database data-source and resource

internal/provider/provider.go

@@ -50,6 +50,7 @@ import (
 	"github.com/microsoft/terraform-provider-fabric/internal/services/kqldatabase"
 	"github.com/microsoft/terraform-provider-fabric/internal/services/kqlqueryset"
 	"github.com/microsoft/terraform-provider-fabric/internal/services/lakehouse"
+	"github.com/microsoft/terraform-provider-fabric/internal/services/mirroreddatabase"
 	"github.com/microsoft/terraform-provider-fabric/internal/services/mirroredwarehouse"
 	"github.com/microsoft/terraform-provider-fabric/internal/services/mlexperiment"
 	"github.com/microsoft/terraform-provider-fabric/internal/services/mlmodel"
@@ -395,6 +396,7 @@ func (p *FabricProvider) Resources(ctx context.Context) []func() resource.Resour
 		kqldatabase.NewResourceKQLDatabase,
 		kqlqueryset.NewResourceKQLQueryset,
 		func() resource.Resource { return lakehouse.NewResourceLakehouse(ctx) },
+		mirroreddatabase.NewResourceMirroredDatabase,
 		mlexperiment.NewResourceMLExperiment,
 		mlmodel.NewResourceMLModel,
 		notebook.NewResourceNotebook,
@@ -442,6 +444,8 @@ func (p *FabricProvider) DataSources(ctx context.Context) []func() datasource.Da
 		func() datasource.DataSource { return lakehouse.NewDataSourceLakehouses(ctx) },
 		lakehouse.NewDataSourceLakehouseTable,
 		lakehouse.NewDataSourceLakehouseTables,
+		mirroreddatabase.NewDataSourceMirroredDatabase,
+		mirroreddatabase.NewDataSourceMirroredDatabases,
 		mirroredwarehouse.NewDataSourceMirroredWarehouses,
 		mlexperiment.NewDataSourceMLExperiment,
 		mlexperiment.NewDataSourceMLExperiments,

internal/services/mirroreddatabase/base.go

@@ -0,0 +1,45 @@
+// Copyright (c) Microsoft Corporation
+// SPDX-License-Identifier: MPL-2.0
+
+package mirroreddatabase
+
+import (
+	fabcore "github.com/microsoft/fabric-sdk-go/fabric/core"
+
+	"github.com/microsoft/terraform-provider-fabric/internal/common"
+	"github.com/microsoft/terraform-provider-fabric/internal/pkg/fabricitem"
+)
+
+const (
+	ItemName            = "Mirrored Database"
+	ItemTFName          = "mirrored_database"
+	ItemsName           = "Mirrored Databases"
+	ItemsTFName         = "mirrored_databases"
+	ItemType            = fabcore.ItemTypeMirroredDatabase
+	ItemDocsSPNSupport  = common.DocsSPNSupported
+	ItemDocsURL         = "https://learn.microsoft.com/en-us/fabric/database/mirrored-database/overview"
+	ItemDefinitionEmpty = `
+{
+	"properties": {
+    "source": {
+      "type": "GenericMirror"
+    },
+    "target": {
+      "type": "MountedRelationalDatabase",
+      "typeProperties": {
+        "format": "Delta",
+        "defaultSchema": "dbo"
+      }
+    }
+	}
+}`
+	ItemDefinitionPathDocsURL = "https://learn.microsoft.com/en-us/rest/api/fabric/articles/item-management/definitions/mirrored-database-definition"
+)
+
+var itemDefinitionFormats = []fabricitem.DefinitionFormat{ //nolint:gochecknoglobals
+	{
+		Type:  fabricitem.DefinitionFormatDefault,
+		API:   "",
+		Paths: []string{"mirroring.json"},
+	},
+}

internal/services/mirroreddatabase/base_test.go

@@ -0,0 +1,14 @@
+// Copyright (c) Microsoft Corporation
+// SPDX-License-Identifier: MPL-2.0
+
+package mirroreddatabase_test
+
+import (
+	"github.com/microsoft/terraform-provider-fabric/internal/services/mirroreddatabase"
+)
+
+const (
+	itemTFName  = mirroreddatabase.ItemTFName
+	itemsTFName = mirroreddatabase.ItemsTFName
+	itemType    = mirroreddatabase.ItemType
+)

internal/services/mirroreddatabase/data_mirrored_database.go

@@ -0,0 +1,79 @@
+// Copyright (c) Microsoft Corporation
+// SPDX-License-Identifier: MPL-2.0
+
+package mirroreddatabase
+
+import (
+	"context"
+
+	"github.com/hashicorp/terraform-plugin-framework/datasource"
+	"github.com/hashicorp/terraform-plugin-framework/diag"
+	"github.com/microsoft/fabric-sdk-go/fabric"
+	fabcore "github.com/microsoft/fabric-sdk-go/fabric/core"
+	"github.com/microsoft/fabric-sdk-go/fabric/mirroreddatabase"
+	supertypes "github.com/orange-cloudavenue/terraform-plugin-framework-supertypes"
+
+	"github.com/microsoft/terraform-provider-fabric/internal/pkg/fabricitem"
+)
+
+func NewDataSourceMirroredDatabase() datasource.DataSource {
+	propertiesSetter := func(ctx context.Context, from *mirroreddatabase.Properties, to *fabricitem.DataSourceFabricItemDefinitionPropertiesModel[mirroredDatabasePropertiesModel, mirroreddatabase.Properties]) diag.Diagnostics {
+		properties := supertypes.NewSingleNestedObjectValueOfNull[mirroredDatabasePropertiesModel](ctx)
+		if from != nil {
+			propertiesModel := &mirroredDatabasePropertiesModel{}
+			propertiesModel.set(ctx, *from)
+			if diags := properties.Set(ctx, propertiesModel); diags.HasError() {
+				return diags
+			}
+		}
+		to.Properties = properties
+		return nil
+	}
+
+	itemGetter := func(ctx context.Context, fabricClient fabric.Client, model fabricitem.DataSourceFabricItemDefinitionPropertiesModel[mirroredDatabasePropertiesModel, mirroreddatabase.Properties], fabricItem *fabricitem.FabricItemProperties[mirroreddatabase.Properties]) error {
+		client := mirroreddatabase.NewClientFactoryWithClient(fabricClient).NewItemsClient()
+		respGet, err := client.GetMirroredDatabase(ctx, model.WorkspaceID.ValueString(), model.ID.ValueString(), nil)
+		if err != nil {
+			return err
+		}
+		fabricItem.Set(respGet.MirroredDatabase)
+		return nil
+	}
+
+	itemListGetter := func(ctx context.Context, fabricClient fabric.Client, model fabricitem.DataSourceFabricItemDefinitionPropertiesModel[mirroredDatabasePropertiesModel, mirroreddatabase.Properties], errNotFound fabcore.ResponseError, fabricItem *fabricitem.FabricItemProperties[mirroreddatabase.Properties]) error {
+		client := mirroreddatabase.NewClientFactoryWithClient(fabricClient).NewItemsClient()
+		pager := client.NewListMirroredDatabasesPager(model.WorkspaceID.ValueString(), nil)
+		for pager.More() {
+			page, err := pager.NextPage(ctx)
+			if err != nil {
+				return err
+			}
+			for _, entity := range page.Value {
+				if *entity.DisplayName == model.DisplayName.ValueString() {
+					fabricItem.Set(entity)
+					return nil
+				}
+			}
+		}
+		return &errNotFound
+	}
+
+	config := fabricitem.DataSourceFabricItemDefinitionProperties[mirroredDatabasePropertiesModel, mirroreddatabase.Properties]{
+		DataSourceFabricItemDefinition: fabricitem.DataSourceFabricItemDefinition{
+			Type:   ItemType,
+			Name:   ItemName,
+			TFName: ItemTFName,
+			MarkdownDescription: "Get a Fabric " + ItemName + ".\n\n" +
+				"Use this data source to fetch a [" + ItemName + "](" + ItemDocsURL + ").\n\n" +
+				ItemDocsSPNSupport,
+			IsDisplayNameUnique: true,
+			DefinitionFormats:   itemDefinitionFormats,
+		},
+		PropertiesAttributes: getDataSourceMirroredDatabasePropertiesAttributes(), // define this function to return schema attributes
+		PropertiesSetter:     propertiesSetter,
+		ItemGetter:           itemGetter,
+		ItemListGetter:       itemListGetter,
+	}
+
+	return fabricitem.NewDataSourceFabricItemDefinitionProperties(config)
+}