Skip to content

Commit

Permalink
feat: add credentials_secret field in azure blob storage block for go…
Browse files Browse the repository at this point in the history
…ogle storage transfer job resource (GoogleCloudPlatform#9278)

* feat: add `credentials_secret` in `azure_blob_storage_data` source config

* feat: add version guard for `credentials_secret` as in preview

* docs: add documentation on `credentials_secret`
  • Loading branch information
kumailkermalli-datatonic authored Mar 12, 2024
1 parent 4fa7f7c commit 4555c33
Show file tree
Hide file tree
Showing 2 changed files with 45 additions and 12 deletions.
Original file line number Diff line number Diff line change
@@ -1,3 +1,4 @@
<% autogen_exception -%>
package storagetransfer

import (
Expand Down Expand Up @@ -50,6 +51,12 @@ var (
"transfer_spec.0.aws_s3_data_source.0.aws_access_key",
"transfer_spec.0.aws_s3_data_source.0.role_arn",
}
<% unless version == 'ga' -%>
azureOptionCredentials = []string{
"transfer_spec.0.azure_blob_storage_data_source.0.azure_credentials",
"transfer_spec.0.azure_blob_storage_data_source.0.credentials_secret",
}
<% end -%>
)

func ResourceStorageTransferJob() *schema.Resource {
Expand Down Expand Up @@ -559,9 +566,14 @@ func azureBlobStorageDataSchema() *schema.Resource {
Description: `Root path to transfer objects. Must be an empty string or full path name that ends with a '/'. This field is treated as an object prefix. As such, it should generally not begin with a '/'.`,
},
"azure_credentials": {
Type: schema.TypeList,
Required: true,
MaxItems: 1,
Type: schema.TypeList,
<% unless version == 'ga' -%>
Optional: true,
ExactlyOneOf: azureOptionCredentials,
<% else -%>
Required: true,
<% end -%>
MaxItems: 1,
Elem: &schema.Resource{
Schema: map[string]*schema.Schema{
"sas_token": {
Expand All @@ -574,6 +586,14 @@ func azureBlobStorageDataSchema() *schema.Resource {
},
Description: ` Credentials used to authenticate API requests to Azure.`,
},
<% unless version == 'ga' -%>
"credentials_secret": {
Optional: true,
Type: schema.TypeString,
Description: `The Resource name of a secret in Secret Manager containing SAS Credentials in JSON form. Service Agent must have permissions to access secret. If credentials_secret is specified, do not specify azure_credentials.`,
ExactlyOneOf: azureOptionCredentials,
},
<% end -%>
},
}
}
Expand Down Expand Up @@ -1099,6 +1119,11 @@ func expandAzureCredentials(azureCredentials []interface{}) *storagetransfer.Azu
}

func flattenAzureCredentials(d *schema.ResourceData) []map[string]interface{} {
<% unless version == 'ga' -%>
if d.Get("transfer_spec.0.azure_blob_storage_data_source.0.azure_credentials.0.sas_token") == "" {
return []map[string]interface{}{}
}
<% end -%>
data := map[string]interface{}{
"sas_token": d.Get("transfer_spec.0.azure_blob_storage_data_source.0.azure_credentials.0.sas_token"),
}
Expand All @@ -1114,19 +1139,25 @@ func expandAzureBlobStorageData(azureBlobStorageDatas []interface{}) *storagetra
azureBlobStorageData := azureBlobStorageDatas[0].(map[string]interface{})

return &storagetransfer.AzureBlobStorageData{
Container: azureBlobStorageData["container"].(string),
Path: azureBlobStorageData["path"].(string),
StorageAccount: azureBlobStorageData["storage_account"].(string),
AzureCredentials: expandAzureCredentials(azureBlobStorageData["azure_credentials"].([]interface{})),
Container: azureBlobStorageData["container"].(string),
Path: azureBlobStorageData["path"].(string),
StorageAccount: azureBlobStorageData["storage_account"].(string),
AzureCredentials: expandAzureCredentials(azureBlobStorageData["azure_credentials"].([]interface{})),
<% unless version == 'ga' -%>
CredentialsSecret: azureBlobStorageData["credentials_secret"].(string),
<% end -%>
}
}

func flattenAzureBlobStorageData(azureBlobStorageData *storagetransfer.AzureBlobStorageData, d *schema.ResourceData) []map[string]interface{} {
data := map[string]interface{}{
"container": azureBlobStorageData.Container,
"path": azureBlobStorageData.Path,
"storage_account": azureBlobStorageData.StorageAccount,
"azure_credentials": flattenAzureCredentials(d),
"container": azureBlobStorageData.Container,
"path": azureBlobStorageData.Path,
"storage_account": azureBlobStorageData.StorageAccount,
"azure_credentials": flattenAzureCredentials(d),
<% unless version == 'ga' -%>
"credentials_secret": azureBlobStorageData.CredentialsSecret,
<% end -%>
}

return []map[string]interface{}{data}
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -247,7 +247,9 @@ The `aws_access_key` block supports:

* `path` - (Required) Root path to transfer objects. Must be an empty string or full path name that ends with a '/'. This field is treated as an object prefix. As such, it should generally not begin with a '/'.

* `azure_credentials` - (Required) Credentials used to authenticate API requests to Azure block.
* `credentials_secret` - (Optional, [Beta](https://terraform.io/docs/providers/google/guides/provider_versions.html)) Full Resource name of a secret in Secret Manager containing [SAS Credentials in JSON form](https://cloud.google.com/storage-transfer/docs/reference/rest/v1/TransferSpec#azureblobstoragedata:~:text=begin%20with%20a%20%27/%27.-,credentialsSecret,-string). Service Agent for Storage Transfer must have permissions to access secret. If credentials_secret is specified, do not specify azure_credentials.`,

* `azure_credentials` - (Required in GA, Optional in [Beta](https://terraform.io/docs/providers/google/guides/provider_versions.html)) Credentials used to authenticate API requests to Azure block.

The `azure_credentials` block supports:

Expand Down

0 comments on commit 4555c33

Please sign in to comment.