Class: StackMate::CloudStackFirewallRule
Constant Summary
Constants included
from Resolver
Resolver::INTEXP, Resolver::STRINGEXP, Resolver::UUIDEXP
Instance Attribute Summary
#name
Instance Method Summary
collapse
Methods included from Resolver
#get_named_tag, #get_resolved, #resolve_tags, #resolve_to_deviceid, #validate_param
Methods included from Intrinsic
#fn_base64, #fn_getatt, #fn_join, #fn_lookup, #fn_map, #fn_ref, #fn_select, #intrinsic
Methods included from Logging
configure_logger_for, #logger, logger_for
#initialize
Instance Method Details
#create ⇒ Object
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
|
# File 'lib/stackmate/participants/cloudstack_firewallrule.rb', line 9
def create
logger.debug("Creating resource #{@name}")
workitem[@name] = {}
name_cs = workitem['StackName'] + '-' + @name
args={}
begin
args['protocol'] = get_protocol
args['ipaddressid'] = get_ipaddressid
args['startport'] = get_startport if @props.has_key?('startport')
args['cidrlist'] = get_cidrlist if @props.has_key?('cidrlist')
args['icmpcode'] = get_icmpcode if @props.has_key?('icmpcode')
args['type'] = get_type if @props.has_key?('type')
args['icmptype'] = get_icmptype if @props.has_key?('icmptype')
args['endport'] = get_endport if @props.has_key?('endport')
logger.info("Creating resource #{@name} with following arguments")
p args
result_obj = make_async_request('createFirewallRule',args)
resource_obj = result_obj['FirewallRule'.downcase]
resource_obj.each_key do |k|
val = resource_obj[k]
if('id'.eql?(k))
k = 'physical_id'
end
workitem[@name][k] = val
end
set_tags(@props['tags'],workitem[@name]['physical_id'],"FirewallRule") if @props.has_key?('tags')
workitem['ResolvedNames'][@name] = name_cs
workitem['IdMap'][workitem[@name]['physical_id']] = @name
rescue NoMethodError => nme
logger.error("Create request failed for resource . Cleaning up the stack")
raise nme
rescue Exception => e
logger.error(e.message)
raise e
end
end
|
#delete ⇒ Object
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
|
# File 'lib/stackmate/participants/cloudstack_firewallrule.rb', line 50
def delete
logger.debug("Deleting resource #{@name}")
begin
physical_id = workitem[@name]['physical_id'] if !workitem[@name].nil?
if(!physical_id.nil?)
args = {'id' => physical_id
}
result_obj = make_async_request('deleteFirewallRule',args)
if (!(result_obj['error'] == true))
logger.info("Successfully deleted resource #{@name}")
else
logger.info("CloudStack error while deleting resource #{@name}")
end
else
logger.info("Resource not created in CloudStack. Skipping delete...")
end
rescue Exception => e
logger.error("Unable to delete resorce #{@name}")
end
end
|
#get_cidrlist ⇒ Object
108
109
110
111
112
113
114
|
# File 'lib/stackmate/participants/cloudstack_firewallrule.rb', line 108
def get_cidrlist
resolved_cidrlist = get_resolved(@props['cidrlist'],workitem)
if resolved_cidrlist.nil? || !validate_param(resolved_cidrlist,"list")
raise "Malformed optional parameter cidrlist for resource #{@name}"
end
resolved_cidrlist
end
|
#get_endport ⇒ Object
140
141
142
143
144
145
146
|
# File 'lib/stackmate/participants/cloudstack_firewallrule.rb', line 140
def get_endport
resolved_endport = get_resolved(@props['endport'],workitem)
if resolved_endport.nil? || !validate_param(resolved_endport,"integer")
raise "Malformed optional parameter endport for resource #{@name}"
end
resolved_endport
end
|
#get_icmpcode ⇒ Object
116
117
118
119
120
121
122
|
# File 'lib/stackmate/participants/cloudstack_firewallrule.rb', line 116
def get_icmpcode
resolved_icmpcode = get_resolved(@props['icmpcode'],workitem)
if resolved_icmpcode.nil? || !validate_param(resolved_icmpcode,"integer")
raise "Malformed optional parameter icmpcode for resource #{@name}"
end
resolved_icmpcode
end
|
#get_icmptype ⇒ Object
132
133
134
135
136
137
138
|
# File 'lib/stackmate/participants/cloudstack_firewallrule.rb', line 132
def get_icmptype
resolved_icmptype = get_resolved(@props['icmptype'],workitem)
if resolved_icmptype.nil? || !validate_param(resolved_icmptype,"integer")
raise "Malformed optional parameter icmptype for resource #{@name}"
end
resolved_icmptype
end
|
#get_ipaddressid ⇒ Object
92
93
94
95
96
97
98
|
# File 'lib/stackmate/participants/cloudstack_firewallrule.rb', line 92
def get_ipaddressid
resolved_ipaddressid = get_resolved(@props["ipaddressid"],workitem)
if resolved_ipaddressid.nil? || !validate_param(resolved_ipaddressid,"uuid")
raise "Missing mandatory parameter ipaddressid for resource #{@name}"
end
resolved_ipaddressid
end
|
#get_protocol ⇒ Object
84
85
86
87
88
89
90
|
# File 'lib/stackmate/participants/cloudstack_firewallrule.rb', line 84
def get_protocol
resolved_protocol = get_resolved(@props["protocol"],workitem)
if resolved_protocol.nil? || !validate_param(resolved_protocol,"string")
raise "Missing mandatory parameter protocol for resource #{@name}"
end
resolved_protocol
end
|
#get_startport ⇒ Object
100
101
102
103
104
105
106
|
# File 'lib/stackmate/participants/cloudstack_firewallrule.rb', line 100
def get_startport
resolved_startport = get_resolved(@props['startport'],workitem)
if resolved_startport.nil? || !validate_param(resolved_startport,"integer")
raise "Malformed optional parameter startport for resource #{@name}"
end
resolved_startport
end
|
#get_type ⇒ Object
124
125
126
127
128
129
130
|
# File 'lib/stackmate/participants/cloudstack_firewallrule.rb', line 124
def get_type
resolved_type = get_resolved(@props['type'],workitem)
if resolved_type.nil? || !validate_param(resolved_type,"string")
raise "Malformed optional parameter type for resource #{@name}"
end
resolved_type
end
|
#on_workitem ⇒ Object
71
72
73
74
75
76
77
78
79
80
81
82
|
# File 'lib/stackmate/participants/cloudstack_firewallrule.rb', line 71
def on_workitem
@name = workitem.participant_name
@props = workitem['Resources'][@name]['Properties']
@props.downcase_key
@resolved_names = workitem['ResolvedNames']
if workitem['params']['operation'] == 'create'
create
else
delete
end
reply
end
|