1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
|
package v1
import (
"fmt"
"testing"
"github.com/gophercloud/gophercloud"
"github.com/gophercloud/gophercloud/acceptance/tools"
"github.com/gophercloud/gophercloud/openstack/orchestration/v1/stacks"
th "github.com/gophercloud/gophercloud/testhelper"
)
const basicTemplateResourceName = "secgroup_1"
const basicTemplate = `
{
"heat_template_version": "2013-05-23",
"description": "Simple template to test heat commands",
"resources": {
"secgroup_1": {
"type": "OS::Neutron::SecurityGroup",
"properties": {
"description": "Gophercloud test",
"name": "secgroup_1"
}
}
}
}
`
const validateTemplate = `
{
"heat_template_version": "2013-05-23",
"description": "Simple template to test heat commands",
"parameters": {
"flavor": {
"default": "m1.tiny",
"type": "string"
}
},
"resources": {
"hello_world": {
"type": "OS::Nova::Server",
"properties": {
"key_name": "heat_key",
"flavor": {
"get_param": "flavor"
},
"image": "ad091b52-742f-469e-8f3c-fd81cadf0743",
"user_data": "#!/bin/bash -xv\necho \"hello world\" > /root/hello-world.txt\n"
}
}
}
}
`
// CreateStack will create a heat stack with a randomly generated name.
// An error will be returned if the stack failed to be created.
func CreateStack(t *testing.T, client *gophercloud.ServiceClient) (*stacks.RetrievedStack, error) {
stackName := tools.RandomString("ACCPTEST", 8)
t.Logf("Attempting to create stack %s", stackName)
template := new(stacks.Template)
template.Bin = []byte(basicTemplate)
createOpts := stacks.CreateOpts{
Name: stackName,
Timeout: 60,
TemplateOpts: template,
DisableRollback: gophercloud.Disabled,
}
stack, err := stacks.Create(client, createOpts).Extract()
th.AssertNoErr(t, err)
if err := WaitForStackStatus(client, stackName, stack.ID, "CREATE_COMPLETE"); err != nil {
return nil, err
}
newStack, err := stacks.Get(client, stackName, stack.ID).Extract()
return newStack, err
}
// DeleteStack deletes a stack via its ID.
// A fatal error will occur if the stack failed to be deleted. This works
// best when used as a deferred function.
func DeleteStack(t *testing.T, client *gophercloud.ServiceClient, stackName, stackID string) {
t.Logf("Attempting to delete stack %s (%s)", stackName, stackID)
err := stacks.Delete(client, stackName, stackID).ExtractErr()
if err != nil {
t.Fatalf("Failed to delete stack %s: %s", stackID, err)
}
t.Logf("Deleted stack: %s", stackID)
}
// WaitForStackStatus will wait until a stack has reached a certain status.
func WaitForStackStatus(client *gophercloud.ServiceClient, stackName, stackID, status string) error {
return tools.WaitFor(func() (bool, error) {
latest, err := stacks.Get(client, stackName, stackID).Extract()
if err != nil {
return false, err
}
if latest.Status == status {
return true, nil
}
if latest.Status == "ERROR" {
return false, fmt.Errorf("Stack in ERROR state")
}
return false, nil
})
}
// CreateStackWithFile will create a heat stack with a randomly generated name that uses get_file.
// An error will be returned if the stack failed to be created.
func CreateStackWithFile(t *testing.T, client *gophercloud.ServiceClient) (*stacks.RetrievedStack, error) {
stackName := tools.RandomString("ACCPTEST", 8)
t.Logf("Attempting to create stack %s", stackName)
template := new(stacks.Template)
template.Bin = []byte(`heat_template_version: 2015-04-30
resources:
test_resource:
type: OS::Heat::TestResource
properties:
value:
get_file: testdata/samplefile`)
createOpts := stacks.CreateOpts{
Name: stackName,
Timeout: 1,
TemplateOpts: template,
DisableRollback: gophercloud.Disabled,
}
stack, err := stacks.Create(client, createOpts).Extract()
th.AssertNoErr(t, err)
if err := WaitForStackStatus(client, stackName, stack.ID, "CREATE_COMPLETE"); err != nil {
return nil, err
}
newStack, err := stacks.Get(client, stackName, stack.ID).Extract()
return newStack, err
}
|
