Skip to content

Commit

Permalink
new resource azurerm_spring_cloud_app
Browse files Browse the repository at this point in the history
  • Loading branch information
njuCZ committed Apr 23, 2020
1 parent dc3e6ab commit 1f07e3f
Show file tree
Hide file tree
Showing 10 changed files with 575 additions and 1 deletion.
5 changes: 5 additions & 0 deletions azurerm/internal/services/appplatform/client/client.go
Expand Up @@ -7,13 +7,18 @@ import (

type Client struct {
ServicesClient *appplatform.ServicesClient
AppsClient *appplatform.AppsClient
}

func NewClient(o *common.ClientOptions) *Client {
appsClient := appplatform.NewAppsClientWithBaseURI(o.ResourceManagerEndpoint, o.SubscriptionId)
o.ConfigureClient(&appsClient.Client, o.ResourceManagerAuthorizer)

servicesClient := appplatform.NewServicesClientWithBaseURI(o.ResourceManagerEndpoint, o.SubscriptionId)
o.ConfigureClient(&servicesClient.Client, o.ResourceManagerAuthorizer)

return &Client{
AppsClient: &appsClient,
ServicesClient: &servicesClient,
}
}
38 changes: 38 additions & 0 deletions azurerm/internal/services/appplatform/parse/spring_cloud_app.go
@@ -0,0 +1,38 @@
package parse

import (
"fmt"

"github.com/terraform-providers/terraform-provider-azurerm/azurerm/helpers/azure"
)

type SpringCloudAppId struct {
ResourceGroup string
ServiceName string
Name string
}

func SpringCloudAppID(input string) (*SpringCloudAppId, error) {
id, err := azure.ParseAzureResourceID(input)
if err != nil {
return nil, fmt.Errorf("parsing Spring Cloud App ID %q: %+v", input, err)
}

app := SpringCloudAppId{
ResourceGroup: id.ResourceGroup,
}

if app.ServiceName, err = id.PopSegment("Spring"); err != nil {
return nil, err
}

if app.Name, err = id.PopSegment("apps"); err != nil {
return nil, err
}

if err := id.ValidateNoEmptySegments(input); err != nil {
return nil, err
}

return &app, nil
}
@@ -0,0 +1,88 @@
package parse

import (
"testing"
)

func TestSpringCloudAppID(t *testing.T) {
testData := []struct {
Name string
Input string
Expected *SpringCloudAppId
}{
{
Name: "Empty",
Input: "",
Expected: nil,
},
{
Name: "No Resource Groups Segment",
Input: "/subscriptions/00000000-0000-0000-0000-000000000000",
Expected: nil,
},
{
Name: "No Resource Groups Value",
Input: "/subscriptions/00000000-0000-0000-0000-000000000000/resourceGroups/",
Expected: nil,
},
{
Name: "Resource Group ID",
Input: "/subscriptions/00000000-0000-0000-0000-000000000000/resourceGroups/foo/",
Expected: nil,
},
{
Name: "No Spring Value",
Input: "/subscriptions/00000000-0000-0000-0000-000000000000/resourceGroups/resGroup1/providers/Microsoft.AppPlatform/Spring/",
Expected: nil,
},
{
Name: "Missing Apps Segment",
Input: "/subscriptions/00000000-0000-0000-0000-000000000000/resourceGroups/resGroup1/providers/Microsoft.AppPlatform/Spring/spring1/",
Expected: nil,
},
{
Name: "Missing Apps Value",
Input: "/subscriptions/00000000-0000-0000-0000-000000000000/resourceGroups/resGroup1/providers/Microsoft.AppPlatform/Spring/spring1/apps/",
Expected: nil,
},
{
Name: "Spring Cloud App ID",
Input: "/subscriptions/00000000-0000-0000-0000-000000000000/resourceGroups/resGroup1/providers/Microsoft.AppPlatform/Spring/spring1/apps/app1",
Expected: &SpringCloudAppId{
ResourceGroup: "resGroup1",
ServiceName: "spring1",
Name: "app1",
},
},
{
Name: "Wrong Casing",
Input: "/subscriptions/00000000-0000-0000-0000-000000000000/resourceGroups/resGroup1/providers/Microsoft.AppPlatform/Spring/spring1/Apps/app1",
Expected: nil,
},
}

for _, v := range testData {
t.Logf("[DEBUG] Testing %q", v.Name)

actual, err := SpringCloudAppID(v.Input)
if err != nil {
if v.Expected == nil {
continue
}

t.Fatalf("Expected a value but got an error: %s", err)
}

if actual.ResourceGroup != v.Expected.ResourceGroup {
t.Fatalf("Expected %q but got %q for Resource Group", v.Expected.ResourceGroup, actual.ResourceGroup)
}

if actual.ServiceName != v.Expected.ServiceName {
t.Fatalf("Expected %q but got %q for ServiceName", v.Expected.ServiceName, actual.ServiceName)
}

if actual.Name != v.Expected.Name {
t.Fatalf("Expected %q but got %q for Name", v.Expected.Name, actual.Name)
}
}
}
1 change: 1 addition & 0 deletions azurerm/internal/services/appplatform/registration.go
Expand Up @@ -28,6 +28,7 @@ func (r Registration) SupportedDataSources() map[string]*schema.Resource {
// SupportedResources returns the supported Resources supported by this Service
func (r Registration) SupportedResources() map[string]*schema.Resource {
return map[string]*schema.Resource{
"azurerm_spring_cloud_app": resourceArmSpringCloudApp(),
"azurerm_spring_cloud_service": resourceArmSpringCloudService(),
}
}
139 changes: 139 additions & 0 deletions azurerm/internal/services/appplatform/resource_arm_spring_cloud_app.go
@@ -0,0 +1,139 @@
package appplatform

import (
"fmt"
"log"
"time"

"github.com/Azure/azure-sdk-for-go/services/preview/appplatform/mgmt/2019-05-01-preview/appplatform"
"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/services/appplatform/parse"
"github.com/terraform-providers/terraform-provider-azurerm/azurerm/internal/services/appplatform/validate"
azSchema "github.com/terraform-providers/terraform-provider-azurerm/azurerm/internal/tf/schema"
"github.com/terraform-providers/terraform-provider-azurerm/azurerm/internal/timeouts"
"github.com/terraform-providers/terraform-provider-azurerm/azurerm/utils"
)

func resourceArmSpringCloudApp() *schema.Resource {
return &schema.Resource{
Create: resourceArmSpringCloudAppCreate,
Read: resourceArmSpringCloudAppRead,
Update: nil,
Delete: resourceArmSpringCloudAppDelete,

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

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

Schema: map[string]*schema.Schema{
"name": {
Type: schema.TypeString,
Required: true,
ForceNew: true,
ValidateFunc: validate.SpringCloudAppName,
},

"resource_group_name": azure.SchemaResourceGroupName(),

"service_name": {
Type: schema.TypeString,
Required: true,
ForceNew: true,
ValidateFunc: validate.SpringCloudServiceName,
},
},
}
}

func resourceArmSpringCloudAppCreate(d *schema.ResourceData, meta interface{}) error {
client := meta.(*clients.Client).AppPlatform.AppsClient
ctx, cancel := timeouts.ForCreate(meta.(*clients.Client).StopContext, d)
defer cancel()

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

existing, err := client.Get(ctx, resourceGroup, serviceName, name, "")
if err != nil {
if !utils.ResponseWasNotFound(existing.Response) {
return fmt.Errorf("checking for present of existing Spring Cloud App %q (Spring Cloud Service %q / Resource Group %q): %+v", name, serviceName, resourceGroup, err)
}
}
if existing.ID != nil && *existing.ID != "" {
return tf.ImportAsExistsError("azurerm_spring_cloud_app", *existing.ID)
}

future, err := client.CreateOrUpdate(ctx, resourceGroup, serviceName, name, appplatform.AppResource{})
if err != nil {
return fmt.Errorf("creating Spring Cloud App %q (Spring Cloud Service %q / Resource Group %q): %+v", name, serviceName, resourceGroup, err)
}
if err = future.WaitForCompletionRef(ctx, client.Client); err != nil {
return fmt.Errorf("waiting for creation of Spring Cloud App %q (Spring Cloud Service %q / Resource Group %q): %+v", name, serviceName, resourceGroup, err)
}

resp, err := client.Get(ctx, resourceGroup, serviceName, name, "")
if err != nil {
return fmt.Errorf("retrieving Spring Cloud App %q (Spring Cloud Service %q / Resource Group %q): %+v", name, serviceName, resourceGroup, err)
}
if resp.ID == nil || *resp.ID == "" {
return fmt.Errorf("read Spring Cloud App %q (Spring Cloud Service %q / Resource Group %q) ID", name, serviceName, resourceGroup)
}
d.SetId(*resp.ID)

return resourceArmSpringCloudAppRead(d, meta)
}

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

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

resp, err := client.Get(ctx, id.ResourceGroup, id.ServiceName, id.Name, "")
if err != nil {
if utils.ResponseWasNotFound(resp.Response) {
log.Printf("[INFO] Spring Cloud App %q does not exist - removing from state", d.Id())
d.SetId("")
return nil
}
return fmt.Errorf("reading Spring Cloud App %q (Spring Cloud Service %q / Resource Group %q): %+v", id.Name, id.ServiceName, id.ResourceGroup, err)
}

d.Set("name", resp.Name)
d.Set("resource_group_name", id.ResourceGroup)
d.Set("service_name", id.ServiceName)

return nil
}

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

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

if _, err := client.Delete(ctx, id.ResourceGroup, id.ServiceName, id.Name); err != nil {
return fmt.Errorf("deleting Spring Cloud App %q (Spring Cloud Service %q / Resource Group %q): %+v", id.Name, id.ServiceName, id.ResourceGroup, err)
}

return nil
}

0 comments on commit 1f07e3f

Please sign in to comment.