Skip to content

Commit

Permalink
provisionAfterExtension field for chaining multiple extensions… (#2937)
Browse files Browse the repository at this point in the history
  • Loading branch information
imvalient authored and katbyte committed May 7, 2019
1 parent 92b600a commit 20cd26a
Show file tree
Hide file tree
Showing 4 changed files with 224 additions and 4 deletions.
44 changes: 40 additions & 4 deletions azurerm/resource_arm_virtual_machine_scale_set.go
Original file line number Diff line number Diff line change
Expand Up @@ -21,10 +21,12 @@ import (

func resourceArmVirtualMachineScaleSet() *schema.Resource {
return &schema.Resource{
Create: resourceArmVirtualMachineScaleSetCreateUpdate,
Read: resourceArmVirtualMachineScaleSetRead,
Update: resourceArmVirtualMachineScaleSetCreateUpdate,
Delete: resourceArmVirtualMachineScaleSetDelete,
Create: resourceArmVirtualMachineScaleSetCreateUpdate,
Read: resourceArmVirtualMachineScaleSetRead,
Update: resourceArmVirtualMachineScaleSetCreateUpdate,
Delete: resourceArmVirtualMachineScaleSetDelete,
MigrateState: resourceVirtualMachineScaleSetMigrateState,
SchemaVersion: 1,

Importer: &schema.ResourceImporter{
State: schema.ImportStatePassthrough,
Expand Down Expand Up @@ -714,6 +716,16 @@ func resourceArmVirtualMachineScaleSet() *schema.Resource {
Optional: true,
},

"provision_after_extensions": {
Type: schema.TypeSet,
Optional: true,
Elem: &schema.Schema{
Type: schema.TypeString,
ValidateFunc: validate.NoEmptyStrings,
},
Set: schema.HashString,
},

"settings": {
Type: schema.TypeString,
Optional: true,
Expand Down Expand Up @@ -1464,6 +1476,14 @@ func flattenAzureRmVirtualMachineScaleSetExtensionProfile(profile *compute.Virtu
e["auto_upgrade_minor_version"] = *properties.AutoUpgradeMinorVersion
}

provisionAfterExtensions := make([]interface{}, 0)
if properties.ProvisionAfterExtensions != nil {
for _, provisionAfterExtension := range *properties.ProvisionAfterExtensions {
provisionAfterExtensions = append(provisionAfterExtensions, provisionAfterExtension)
}
}
e["provision_after_extensions"] = schema.NewSet(schema.HashString, provisionAfterExtensions)

if settings := properties.Settings; settings != nil {
settingsVal := settings.(map[string]interface{})
settingsJson, err := structure.FlattenJsonToString(settingsVal)
Expand Down Expand Up @@ -1567,6 +1587,10 @@ func resourceArmVirtualMachineScaleSetExtensionHash(v interface{}) int {
buf.WriteString(fmt.Sprintf("%t-", v.(bool)))
}

if v, ok := m["provision_after_extensions"]; ok {
buf.WriteString(fmt.Sprintf("%s-", v.(*schema.Set).List()))
}

// we need to ensure the whitespace is consistent
settings := m["settings"].(string)
if settings != "" {
Expand Down Expand Up @@ -2151,6 +2175,18 @@ func expandAzureRMVirtualMachineScaleSetExtensions(d *schema.ResourceData) (*com
extension.VirtualMachineScaleSetExtensionProperties.AutoUpgradeMinorVersion = &upgrade
}

if a := config["provision_after_extensions"]; a != nil {
provision_after_extensions := config["provision_after_extensions"].(*schema.Set).List()
if len(provision_after_extensions) > 0 {
var provisionAfterExtensions []string
for _, a := range provision_after_extensions {
str := a.(string)
provisionAfterExtensions = append(provisionAfterExtensions, str)
}
extension.VirtualMachineScaleSetExtensionProperties.ProvisionAfterExtensions = &provisionAfterExtensions
}
}

if s := config["settings"].(string); s != "" {
settings, err := structure.ExpandJsonFromString(s)
if err != nil {
Expand Down
44 changes: 44 additions & 0 deletions azurerm/resource_arm_virtual_machine_scale_set_migration.go
Original file line number Diff line number Diff line change
@@ -0,0 +1,44 @@
package azurerm

import (
"fmt"
"log"

"github.com/hashicorp/terraform/terraform"
)

func resourceVirtualMachineScaleSetMigrateState(v int, is *terraform.InstanceState, meta interface{}) (*terraform.InstanceState, error) {
switch v {
case 0:
log.Println("[INFO] Found AzureRM Scale Set State v0; migrating to v1")
return resourceVirtualMachineScaleSetStateV0toV1(is, meta)
default:
return is, fmt.Errorf("Unexpected schema version: %d", v)
}
}

func resourceVirtualMachineScaleSetStateV0toV1(is *terraform.InstanceState, meta interface{}) (*terraform.InstanceState, error) {
if is.Empty() {
log.Println("[DEBUG] Empty InstanceState; nothing to migrate.")
return is, nil
}

log.Printf("[DEBUG] ARM Virtual Machine Scale Set Attributes before Migration: %#v", is.Attributes)

client := meta.(*ArmClient).vmScaleSetClient
ctx := meta.(*ArmClient).StopContext

resGroup := is.Attributes["resource_group_name"]
name := is.Attributes["name"]

read, err := client.Get(ctx, resGroup, name)
if err != nil {
return is, err
}

is.ID = *read.ID

log.Printf("[DEBUG] ARM Virtual Machine Scale Set Attributes after State Migration: %#v", is.Attributes)

return is, nil
}
139 changes: 139 additions & 0 deletions azurerm/resource_arm_virtual_machine_scale_set_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -796,6 +796,32 @@ func TestAccAzureRMVirtualMachineScaleSet_multipleExtensions(t *testing.T) {
})
}

func TestAccAzureRMVirtualMachineScaleSet_multipleExtensions_provision_after_extension(t *testing.T) {
resourceName := "azurerm_virtual_machine_scale_set.test"
ri := tf.AccRandTimeInt()
config := testAccAzureRMVirtualMachineScaleSetMultipleExtensionsTemplate_provision_after_extension(ri, testLocation())
resource.ParallelTest(t, resource.TestCase{
PreCheck: func() { testAccPreCheck(t) },
Providers: testAccProviders,
CheckDestroy: testCheckAzureRMVirtualMachineScaleSetDestroy,
Steps: []resource.TestStep{
{
Config: config,
Check: resource.ComposeTestCheckFunc(
testCheckAzureRMVirtualMachineScaleSetExists(resourceName),
testCheckAzureRMVirtualMachineScaleSetExtension(resourceName),
),
},
{
ResourceName: resourceName,
ImportState: true,
ImportStateVerify: true,
ImportStateVerifyIgnore: []string{"os_profile.0.admin_password"},
},
},
})
}

func TestAccAzureRMVirtualMachineScaleSet_osDiskTypeConflict(t *testing.T) {
ri := tf.AccRandTimeInt()
config := testAccAzureRMVirtualMachineScaleSet_osDiskTypeConflict(ri, testLocation())
Expand Down Expand Up @@ -4077,6 +4103,119 @@ SETTINGS
`, rInt, location)
}

func testAccAzureRMVirtualMachineScaleSetMultipleExtensionsTemplate_provision_after_extension(rInt int, location string) string {
return fmt.Sprintf(`
resource "azurerm_resource_group" "test" {
name = "acctestRG-%[1]d"
location = "%[2]s"
}
resource "azurerm_virtual_network" "test" {
name = "acctvn-%[1]d"
address_space = ["10.0.0.0/16"]
location = "${azurerm_resource_group.test.location}"
resource_group_name = "${azurerm_resource_group.test.name}"
}
resource "azurerm_subnet" "test" {
name = "acctsub-%[1]d"
resource_group_name = "${azurerm_resource_group.test.name}"
virtual_network_name = "${azurerm_virtual_network.test.name}"
address_prefix = "10.0.2.0/24"
}
resource "azurerm_storage_account" "test" {
name = "accsa%[1]d"
resource_group_name = "${azurerm_resource_group.test.name}"
location = "${azurerm_resource_group.test.location}"
account_tier = "Standard"
account_replication_type = "LRS"
}
resource "azurerm_storage_container" "test" {
name = "vhds"
resource_group_name = "${azurerm_resource_group.test.name}"
storage_account_name = "${azurerm_storage_account.test.name}"
container_access_type = "private"
}
resource "azurerm_virtual_machine_scale_set" "test" {
name = "acctvmss-%[1]d"
location = "${azurerm_resource_group.test.location}"
resource_group_name = "${azurerm_resource_group.test.name}"
upgrade_policy_mode = "Manual"
overprovision = false
sku {
name = "Standard_D1_v2"
tier = "Standard"
capacity = 1
}
os_profile {
computer_name_prefix = "testvm-%[1]d"
admin_username = "myadmin"
admin_password = "Passwword1234"
}
network_profile {
name = "TestNetworkProfile"
primary = true
ip_configuration {
name = "TestIPConfiguration"
primary = true
subnet_id = "${azurerm_subnet.test.id}"
}
}
storage_profile_os_disk {
name = "os-disk"
caching = "ReadWrite"
create_option = "FromImage"
vhd_containers = ["${azurerm_storage_account.test.primary_blob_endpoint}${azurerm_storage_container.test.name}"]
}
storage_profile_image_reference {
publisher = "Canonical"
offer = "UbuntuServer"
sku = "16.04-LTS"
version = "latest"
}
extension {
name = "CustomScript"
publisher = "Microsoft.Azure.Extensions"
type = "CustomScript"
type_handler_version = "2.0"
auto_upgrade_minor_version = true
settings = <<SETTINGS
{
"commandToExecute": "echo $HOSTNAME"
}
SETTINGS
protected_settings = <<SETTINGS
{
"storageAccountName": "${azurerm_storage_account.test.name}",
"storageAccountKey": "${azurerm_storage_account.test.primary_access_key}"
}
SETTINGS
}
extension {
name = "Docker"
publisher = "Microsoft.Azure.Extensions"
type = "DockerExtension"
type_handler_version = "1.0"
auto_upgrade_minor_version = true
provision_after_extensions = ["CustomScript"]
}
}
`, rInt, location)
}

func testAccAzureRMVirtualMachineScaleSet_osDiskTypeConflict(rInt int, location string) string {
return fmt.Sprintf(`
resource "azurerm_resource_group" "test" {
Expand Down
1 change: 1 addition & 0 deletions website/docs/r/virtual_machine_scale_set.html.markdown
Original file line number Diff line number Diff line change
Expand Up @@ -489,6 +489,7 @@ machine scale set, as in the [example below](#example-of-storage_profile_image_r
* `type` - (Required) The type of extension, available types for a publisher can be found using the Azure CLI.
* `type_handler_version` - (Required) Specifies the version of the extension to use, available versions can be found using the Azure CLI.
* `auto_upgrade_minor_version` - (Optional) Specifies whether or not to use the latest minor version available.
* `provision_after_extensions` - (Optional) Specifies a dependency array of extensions required to be executed before, the array stores the name of each extension.
* `settings` - (Required) The settings passed to the extension, these are specified as a JSON object in a string.
* `protected_settings` - (Optional) The protected_settings passed to the extension, like settings, these are specified as a JSON object in a string.

Expand Down

0 comments on commit 20cd26a

Please sign in to comment.