Skip to content

Commit

Permalink
add resource azurerm_data_protection_backup_vault (#11955)
Browse files Browse the repository at this point in the history
  • Loading branch information
ms-henglu authored Jun 3, 2021
1 parent aa7ed18 commit 37290d1
Show file tree
Hide file tree
Showing 33 changed files with 10,307 additions and 0 deletions.
1 change: 1 addition & 0 deletions .teamcity/components/generated/services.kt
Original file line number Diff line number Diff line change
Expand Up @@ -28,6 +28,7 @@ var services = mapOf(
"datalake" to "Data Lake",
"datashare" to "Data Share",
"databricks" to "DataBricks",
"dataprotection" to "DataProtection",
"databasemigration" to "Database Migration",
"databoxedge" to "Databox Edge",
"desktopvirtualization" to "Desktop Virtualization",
Expand Down
3 changes: 3 additions & 0 deletions azurerm/internal/clients/client.go
Original file line number Diff line number Diff line change
Expand Up @@ -33,6 +33,7 @@ import (
databricks "github.com/terraform-providers/terraform-provider-azurerm/azurerm/internal/services/databricks/client"
datafactory "github.com/terraform-providers/terraform-provider-azurerm/azurerm/internal/services/datafactory/client"
datalake "github.com/terraform-providers/terraform-provider-azurerm/azurerm/internal/services/datalake/client"
dataprotection "github.com/terraform-providers/terraform-provider-azurerm/azurerm/internal/services/dataprotection/client"
datashare "github.com/terraform-providers/terraform-provider-azurerm/azurerm/internal/services/datashare/client"
desktopvirtualization "github.com/terraform-providers/terraform-provider-azurerm/azurerm/internal/services/desktopvirtualization/client"
devspace "github.com/terraform-providers/terraform-provider-azurerm/azurerm/internal/services/devspace/client"
Expand Down Expand Up @@ -134,6 +135,7 @@ type Client struct {
DataboxEdge *databoxedge.Client
DataFactory *datafactory.Client
Datalake *datalake.Client
DataProtection *dataprotection.Client
DataShare *datashare.Client
DesktopVirtualization *desktopvirtualization.Client
DevSpace *devspace.Client
Expand Down Expand Up @@ -237,6 +239,7 @@ func (client *Client) Build(ctx context.Context, o *common.ClientOptions) error
client.DataboxEdge = databoxedge.NewClient(o)
client.DataFactory = datafactory.NewClient(o)
client.Datalake = datalake.NewClient(o)
client.DataProtection = dataprotection.NewClient(o)
client.DataShare = datashare.NewClient(o)
client.DesktopVirtualization = desktopvirtualization.NewClient(o)
client.DevSpace = devspace.NewClient(o)
Expand Down
2 changes: 2 additions & 0 deletions azurerm/internal/provider/services.go
Original file line number Diff line number Diff line change
Expand Up @@ -29,6 +29,7 @@ import (
"github.com/terraform-providers/terraform-provider-azurerm/azurerm/internal/services/databricks"
"github.com/terraform-providers/terraform-provider-azurerm/azurerm/internal/services/datafactory"
"github.com/terraform-providers/terraform-provider-azurerm/azurerm/internal/services/datalake"
"github.com/terraform-providers/terraform-provider-azurerm/azurerm/internal/services/dataprotection"
"github.com/terraform-providers/terraform-provider-azurerm/azurerm/internal/services/datashare"
"github.com/terraform-providers/terraform-provider-azurerm/azurerm/internal/services/desktopvirtualization"
"github.com/terraform-providers/terraform-provider-azurerm/azurerm/internal/services/devspace"
Expand Down Expand Up @@ -137,6 +138,7 @@ func SupportedUntypedServices() []sdk.UntypedServiceRegistration {
datalake.Registration{},
databasemigration.Registration{},
databoxedge.Registration{},
dataprotection.Registration{},
datashare.Registration{},
desktopvirtualization.Registration{},
devspace.Registration{},
Expand Down
1 change: 1 addition & 0 deletions azurerm/internal/resourceproviders/required.go
Original file line number Diff line number Diff line change
Expand Up @@ -28,6 +28,7 @@ func Required() map[string]struct{} {
"Microsoft.DataLakeAnalytics": {},
"Microsoft.DataLakeStore": {},
"Microsoft.DataMigration": {},
"Microsoft.DataProtection": {},
"Microsoft.DBforMariaDB": {},
"Microsoft.DBforMySQL": {},
"Microsoft.DBforPostgreSQL": {},
Expand Down
19 changes: 19 additions & 0 deletions azurerm/internal/services/dataprotection/client/client.go
Original file line number Diff line number Diff line change
@@ -0,0 +1,19 @@
package client

import (
"github.com/terraform-providers/terraform-provider-azurerm/azurerm/internal/common"
"github.com/terraform-providers/terraform-provider-azurerm/azurerm/internal/services/dataprotection/legacysdk/dataprotection"
)

type Client struct {
BackupVaultClient *dataprotection.BackupVaultsClient
}

func NewClient(o *common.ClientOptions) *Client {
backupVaultClient := dataprotection.NewBackupVaultsClientWithBaseURI(o.ResourceManagerEndpoint, o.SubscriptionId)
o.ConfigureClient(&backupVaultClient.Client, o.ResourceManagerAuthorizer)

return &Client{
BackupVaultClient: &backupVaultClient,
}
}
Original file line number Diff line number Diff line change
@@ -0,0 +1,230 @@
package dataprotection

import (
"fmt"
"log"
"regexp"
"time"

"github.com/hashicorp/terraform-plugin-sdk/helper/schema"
"github.com/terraform-providers/terraform-provider-azurerm/azurerm/helpers/azure"
"github.com/terraform-providers/terraform-provider-azurerm/azurerm/helpers/tf"
"github.com/terraform-providers/terraform-provider-azurerm/azurerm/internal/clients"
"github.com/terraform-providers/terraform-provider-azurerm/azurerm/internal/identity"
"github.com/terraform-providers/terraform-provider-azurerm/azurerm/internal/location"
"github.com/terraform-providers/terraform-provider-azurerm/azurerm/internal/services/dataprotection/legacysdk/dataprotection"
"github.com/terraform-providers/terraform-provider-azurerm/azurerm/internal/services/dataprotection/parse"
"github.com/terraform-providers/terraform-provider-azurerm/azurerm/internal/tags"
azSchema "github.com/terraform-providers/terraform-provider-azurerm/azurerm/internal/tf/schema"
"github.com/terraform-providers/terraform-provider-azurerm/azurerm/internal/tf/validation"
"github.com/terraform-providers/terraform-provider-azurerm/azurerm/internal/timeouts"
"github.com/terraform-providers/terraform-provider-azurerm/azurerm/utils"
)

func resourceDataProtectionBackupVault() *schema.Resource {
return &schema.Resource{
Create: resourceDataProtectionBackupVaultCreate,
Read: resourceDataProtectionBackupVaultRead,
Update: resourceDataProtectionBackupVaultUpdate,
Delete: resourceDataProtectionBackupVaultDelete,

Timeouts: &schema.ResourceTimeout{
Create: schema.DefaultTimeout(30 * time.Minute),
Read: schema.DefaultTimeout(5 * time.Minute),
Update: schema.DefaultTimeout(30 * time.Minute),
Delete: schema.DefaultTimeout(30 * time.Minute),
},

Importer: azSchema.ValidateResourceIDPriorToImport(func(id string) error {
_, err := parse.BackupVaultID(id)
return err
}),

Schema: map[string]*schema.Schema{
"name": {
Type: schema.TypeString,
Required: true,
ForceNew: true,
ValidateFunc: validation.StringMatch(
regexp.MustCompile("^[-a-zA-Z0-9]{2,50}$"),
"DataProtection BackupVault name must be 2 - 50 characters long, contain only letters, numbers and hyphens.).",
),
},

"resource_group_name": azure.SchemaResourceGroupName(),

"location": azure.SchemaLocation(),

"datastore_type": {
Type: schema.TypeString,
Required: true,
ForceNew: true,
ValidateFunc: validation.StringInSlice([]string{
string(dataprotection.StorageSettingStoreTypesArchiveStore),
string(dataprotection.StorageSettingStoreTypesSnapshotStore),
string(dataprotection.StorageSettingStoreTypesVaultStore),
}, false),
},

"redundancy": {
Type: schema.TypeString,
Required: true,
ForceNew: true,
ValidateFunc: validation.StringInSlice([]string{
string(dataprotection.GeoRedundant),
string(dataprotection.LocallyRedundant),
}, false),
},

"identity": identity.SystemAssigned{}.Schema(),

"tags": tags.Schema(),
},
}
}
func resourceDataProtectionBackupVaultCreate(d *schema.ResourceData, meta interface{}) error {
subscriptionId := meta.(*clients.Client).Account.SubscriptionId
client := meta.(*clients.Client).DataProtection.BackupVaultClient
ctx, cancel := timeouts.ForCreate(meta.(*clients.Client).StopContext, d)
defer cancel()

name := d.Get("name").(string)
resourceGroup := d.Get("resource_group_name").(string)

id := parse.NewBackupVaultID(subscriptionId, resourceGroup, name)

existing, err := client.Get(ctx, id.Name, id.ResourceGroup)
if err != nil {
if !utils.ResponseWasNotFound(existing.Response) {
return fmt.Errorf("checking for existing DataProtection BackupVault (%q): %+v", id, err)
}
}
if !utils.ResponseWasNotFound(existing.Response) {
return tf.ImportAsExistsError("azurerm_data_protection_backup_vault", id.ID())
}

parameters := dataprotection.BackupVaultResource{
Location: utils.String(location.Normalize(d.Get("location").(string))),
Properties: &dataprotection.BackupVault{
StorageSettings: &[]dataprotection.StorageSetting{
{
DatastoreType: dataprotection.StorageSettingStoreTypes(d.Get("datastore_type").(string)),
Type: dataprotection.StorageSettingTypes(d.Get("redundancy").(string)),
}},
},
Identity: expandBackupVaultDppIdentityDetails(d.Get("identity").([]interface{})),
Tags: tags.Expand(d.Get("tags").(map[string]interface{})),
}
future, err := client.CreateOrUpdate(ctx, id.Name, id.ResourceGroup, parameters)
if err != nil {
return fmt.Errorf("creating DataProtection BackupVault (%q): %+v", id, err)
}

if err := future.WaitForCompletionRef(ctx, client.Client); err != nil {
return fmt.Errorf("waiting for creation of the DataProtection BackupVault (%q): %+v", id, err)
}

d.SetId(id.ID())
return resourceDataProtectionBackupVaultRead(d, meta)
}

func resourceDataProtectionBackupVaultRead(d *schema.ResourceData, meta interface{}) error {
client := meta.(*clients.Client).DataProtection.BackupVaultClient
ctx, cancel := timeouts.ForRead(meta.(*clients.Client).StopContext, d)
defer cancel()

id, err := parse.BackupVaultID(d.Id())
if err != nil {
return err
}

resp, err := client.Get(ctx, id.Name, id.ResourceGroup)
if err != nil {
if utils.ResponseWasNotFound(resp.Response) {
log.Printf("[INFO] DataProtection BackupVault %q does not exist - removing from state", d.Id())
d.SetId("")
return nil
}
return fmt.Errorf("retrieving DataProtection BackupVault (%q): %+v", id, err)
}
d.Set("name", id.Name)
d.Set("resource_group_name", id.ResourceGroup)
d.Set("location", location.NormalizeNilable(resp.Location))
if props := resp.Properties; props != nil {
if props.StorageSettings != nil && len(*props.StorageSettings) > 0 {
d.Set("datastore_type", (*props.StorageSettings)[0].DatastoreType)
d.Set("redundancy", (*props.StorageSettings)[0].Type)
}
}
if err := d.Set("identity", flattenBackupVaultDppIdentityDetails(resp.Identity)); err != nil {
return fmt.Errorf("setting `identity`: %+v", err)
}
return tags.FlattenAndSet(d, resp.Tags)
}

func resourceDataProtectionBackupVaultUpdate(d *schema.ResourceData, meta interface{}) error {
client := meta.(*clients.Client).DataProtection.BackupVaultClient
ctx, cancel := timeouts.ForUpdate(meta.(*clients.Client).StopContext, d)
defer cancel()

id, err := parse.BackupVaultID(d.Id())
if err != nil {
return err
}

parameters := dataprotection.PatchResourceRequestInput{}
if d.HasChange("identity") {
parameters.Identity = expandBackupVaultDppIdentityDetails(d.Get("identity").([]interface{}))
}
if d.HasChange("tags") {
parameters.Tags = tags.Expand(d.Get("tags").(map[string]interface{}))
}

future, err := client.Patch(ctx, id.Name, id.ResourceGroup, parameters)
if err != nil {
return fmt.Errorf("updating DataProtection BackupVault (%q): %+v", id, err)
}

if err := future.WaitForCompletionRef(ctx, client.Client); err != nil {
return fmt.Errorf("waiting for update of the DataProtection BackupVault %q: %+v", id, err)
}
return resourceDataProtectionBackupVaultRead(d, meta)
}

func resourceDataProtectionBackupVaultDelete(d *schema.ResourceData, meta interface{}) error {
client := meta.(*clients.Client).DataProtection.BackupVaultClient
ctx, cancel := timeouts.ForDelete(meta.(*clients.Client).StopContext, d)
defer cancel()

id, err := parse.BackupVaultID(d.Id())
if err != nil {
return err
}

if resp, err := client.Delete(ctx, id.Name, id.ResourceGroup); err != nil {
if utils.ResponseWasNotFound(resp) {
return nil
}
return fmt.Errorf("deleting DataProtection BackupVault (%q): %+v", id, err)
}
return nil
}

func expandBackupVaultDppIdentityDetails(input []interface{}) *dataprotection.DppIdentityDetails {
config, _ := identity.SystemAssigned{}.Expand(input)
return &dataprotection.DppIdentityDetails{
Type: utils.String(config.Type),
}
}

func flattenBackupVaultDppIdentityDetails(input *dataprotection.DppIdentityDetails) []interface{} {
var config *identity.ExpandedConfig
if input != nil {
config = &identity.ExpandedConfig{
Type: *input.Type,
PrincipalId: input.PrincipalID,
TenantId: input.TenantID,
}
}
return identity.SystemAssigned{}.Flatten(config)
}
Loading

0 comments on commit 37290d1

Please sign in to comment.