Class: StackMate::CloudStackNetwork

Inherits:
CloudStackResource show all
Includes:
Intrinsic, Logging, Resolver
Defined in:
lib/stackmate/participants/cloudstack_network.rb

Constant Summary

Constants included from Resolver

Resolver::INTEXP, Resolver::STRINGEXP, Resolver::UUIDEXP

Instance Attribute Summary

Attributes inherited from CloudStackResource

#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

Methods inherited from CloudStackResource

#initialize

Constructor Details

This class inherits a constructor from StackMate::CloudStackResource

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
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
 
# File 'lib/stackmate/participants/cloudstack_network.rb', line 9

def create
  logger.debug("Creating resource #{@name}")
  workitem[@name] = {}
  name_cs = workitem['StackName'] + '-' + @name
  args={}
  begin
    args['displaytext'] = get_displaytext
    args['networkofferingid'] = get_networkofferingid
    args['name'] = workitem['StackName'] +'-' +get_name
    args['zoneid'] = get_zoneid
    args['networkdomain'] = get_networkdomain if @props.has_key?('networkdomain')
    args['projectid'] = get_projectid if @props.has_key?('projectid')
    args['startip'] = get_startip if @props.has_key?('startip')
    args['domainid'] = get_domainid if @props.has_key?('domainid')
    args['displaynetwork'] = get_displaynetwork if @props.has_key?('displaynetwork')
    args['startipv6'] = get_startipv6 if @props.has_key?('startipv6')
    args['acltype'] = get_acltype if @props.has_key?('acltype')
    args['endip'] = get_endip if @props.has_key?('endip')
    args['account'] =  if @props.has_key?('account')
    args['gateway'] = get_gateway if @props.has_key?('gateway')
    args['vlan'] = get_vlan if @props.has_key?('vlan')
    args['endipv6'] = get_endipv6 if @props.has_key?('endipv6')
    args['ip6cidr'] = get_ip6cidr if @props.has_key?('ip6cidr')
    args['aclid'] = get_aclid if @props.has_key?('aclid')
    args['isolatedpvlan'] = get_isolatedpvlan if @props.has_key?('isolatedpvlan')
    args['ip6gateway'] = get_ip6gateway if @props.has_key?('ip6gateway')
    args['netmask'] = get_netmask if @props.has_key?('netmask')
    args['subdomainaccess'] = get_subdomainaccess if @props.has_key?('subdomainaccess')
    args['vpcid'] = get_vpcid if @props.has_key?('vpcid')
    args['physicalnetworkid'] = get_physicalnetworkid if @props.has_key?('physicalnetworkid')

    logger.info("Creating resource #{@name} with following arguments")
    p args
    result_obj = make_sync_request('createNetwork',args)
    resource_obj = result_obj['Network'.downcase]
    #doing it this way since it is easier to change later, rather than cloning whole object
    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'],"Network") 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 



66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
 
# File 'lib/stackmate/participants/cloudstack_network.rb', line 66

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('deleteNetwork',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_account ⇒ Object 



196
197
198
199
200
201
202
 
# File 'lib/stackmate/participants/cloudstack_network.rb', line 196

def 
   = get_resolved(@props['account'],workitem)
  if .nil? || !validate_param(,"string")
    raise "Malformed optional parameter account for resource #{@name}"
  end
  
end

#get_aclid ⇒ Object 



236
237
238
239
240
241
242
 
# File 'lib/stackmate/participants/cloudstack_network.rb', line 236

def get_aclid
  resolved_aclid = get_resolved(@props['aclid'],workitem)
  if resolved_aclid.nil? || !validate_param(resolved_aclid,"uuid")
    raise "Malformed optional parameter aclid for resource #{@name}"
  end
  resolved_aclid
end

#get_acltype ⇒ Object 



180
181
182
183
184
185
186
 
# File 'lib/stackmate/participants/cloudstack_network.rb', line 180

def get_acltype
  resolved_acltype = get_resolved(@props['acltype'],workitem)
  if resolved_acltype.nil? || !validate_param(resolved_acltype,"string")
    raise "Malformed optional parameter acltype for resource #{@name}"
  end
  resolved_acltype
end

#get_displaynetwork ⇒ Object 



164
165
166
167
168
169
170
 
# File 'lib/stackmate/participants/cloudstack_network.rb', line 164

def get_displaynetwork
  resolved_displaynetwork = get_resolved(@props['displaynetwork'],workitem)
  if resolved_displaynetwork.nil? || !validate_param(resolved_displaynetwork,"boolean")
    raise "Malformed optional parameter displaynetwork for resource #{@name}"
  end
  resolved_displaynetwork
end

#get_displaytext ⇒ Object 



100
101
102
103
104
105
106
 
# File 'lib/stackmate/participants/cloudstack_network.rb', line 100

def get_displaytext
  resolved_displaytext = get_resolved(@props["displaytext"],workitem)
  if resolved_displaytext.nil? || !validate_param(resolved_displaytext,"string")
    raise "Missing mandatory parameter displaytext for resource #{@name}"
  end
  resolved_displaytext
end

#get_domainid ⇒ Object 



156
157
158
159
160
161
162
 
# File 'lib/stackmate/participants/cloudstack_network.rb', line 156

def get_domainid
  resolved_domainid = get_resolved(@props['domainid'],workitem)
  if resolved_domainid.nil? || !validate_param(resolved_domainid,"uuid")
    raise "Malformed optional parameter domainid for resource #{@name}"
  end
  resolved_domainid
end

#get_endip ⇒ Object 



188
189
190
191
192
193
194
 
# File 'lib/stackmate/participants/cloudstack_network.rb', line 188

def get_endip
  resolved_endip = get_resolved(@props['endip'],workitem)
  if resolved_endip.nil? || !validate_param(resolved_endip,"string")
    raise "Malformed optional parameter endip for resource #{@name}"
  end
  resolved_endip
end

#get_endipv6 ⇒ Object 



220
221
222
223
224
225
226
 
# File 'lib/stackmate/participants/cloudstack_network.rb', line 220

def get_endipv6
  resolved_endipv6 = get_resolved(@props['endipv6'],workitem)
  if resolved_endipv6.nil? || !validate_param(resolved_endipv6,"string")
    raise "Malformed optional parameter endipv6 for resource #{@name}"
  end
  resolved_endipv6
end

#get_gateway ⇒ Object 



204
205
206
207
208
209
210
 
# File 'lib/stackmate/participants/cloudstack_network.rb', line 204

def get_gateway
  resolved_gateway = get_resolved(@props['gateway'],workitem)
  if resolved_gateway.nil? || !validate_param(resolved_gateway,"string")
    raise "Malformed optional parameter gateway for resource #{@name}"
  end
  resolved_gateway
end

#get_ip6cidr ⇒ Object 



228
229
230
231
232
233
234
 
# File 'lib/stackmate/participants/cloudstack_network.rb', line 228

def get_ip6cidr
  resolved_ip6cidr = get_resolved(@props['ip6cidr'],workitem)
  if resolved_ip6cidr.nil? || !validate_param(resolved_ip6cidr,"string")
    raise "Malformed optional parameter ip6cidr for resource #{@name}"
  end
  resolved_ip6cidr
end

#get_ip6gateway ⇒ Object 



252
253
254
255
256
257
258
 
# File 'lib/stackmate/participants/cloudstack_network.rb', line 252

def get_ip6gateway
  resolved_ip6gateway = get_resolved(@props['ip6gateway'],workitem)
  if resolved_ip6gateway.nil? || !validate_param(resolved_ip6gateway,"string")
    raise "Malformed optional parameter ip6gateway for resource #{@name}"
  end
  resolved_ip6gateway
end

#get_isolatedpvlan ⇒ Object 



244
245
246
247
248
249
250
 
# File 'lib/stackmate/participants/cloudstack_network.rb', line 244

def get_isolatedpvlan
  resolved_isolatedpvlan = get_resolved(@props['isolatedpvlan'],workitem)
  if resolved_isolatedpvlan.nil? || !validate_param(resolved_isolatedpvlan,"string")
    raise "Malformed optional parameter isolatedpvlan for resource #{@name}"
  end
  resolved_isolatedpvlan
end

#get_name ⇒ Object 



116
117
118
119
120
121
122
 
# File 'lib/stackmate/participants/cloudstack_network.rb', line 116

def get_name
  resolved_name = get_resolved(@props["name"],workitem)
  if resolved_name.nil? || !validate_param(resolved_name,"string")
    raise "Missing mandatory parameter name for resource #{@name}"
  end
  resolved_name
end

#get_netmask ⇒ Object 



260
261
262
263
264
265
266
 
# File 'lib/stackmate/participants/cloudstack_network.rb', line 260

def get_netmask
  resolved_netmask = get_resolved(@props['netmask'],workitem)
  if resolved_netmask.nil? || !validate_param(resolved_netmask,"string")
    raise "Malformed optional parameter netmask for resource #{@name}"
  end
  resolved_netmask
end

#get_networkdomain ⇒ Object 



132
133
134
135
136
137
138
 
# File 'lib/stackmate/participants/cloudstack_network.rb', line 132

def get_networkdomain
  resolved_networkdomain = get_resolved(@props['networkdomain'],workitem)
  if resolved_networkdomain.nil? || !validate_param(resolved_networkdomain,"string")
    raise "Malformed optional parameter networkdomain for resource #{@name}"
  end
  resolved_networkdomain
end

#get_networkofferingid ⇒ Object 



108
109
110
111
112
113
114
 
# File 'lib/stackmate/participants/cloudstack_network.rb', line 108

def get_networkofferingid
  resolved_networkofferingid = get_resolved(@props["networkofferingid"],workitem)
  if resolved_networkofferingid.nil? || !validate_param(resolved_networkofferingid,"uuid")
    raise "Missing mandatory parameter networkofferingid for resource #{@name}"
  end
  resolved_networkofferingid
end

#get_physicalnetworkid ⇒ Object 



284
285
286
287
288
289
290
 
# File 'lib/stackmate/participants/cloudstack_network.rb', line 284

def get_physicalnetworkid
  resolved_physicalnetworkid = get_resolved(@props['physicalnetworkid'],workitem)
  if resolved_physicalnetworkid.nil? || !validate_param(resolved_physicalnetworkid,"uuid")
    raise "Malformed optional parameter physicalnetworkid for resource #{@name}"
  end
  resolved_physicalnetworkid
end

#get_projectid ⇒ Object 



140
141
142
143
144
145
146
 
# File 'lib/stackmate/participants/cloudstack_network.rb', line 140

def get_projectid
  resolved_projectid = get_resolved(@props['projectid'],workitem)
  if resolved_projectid.nil? || !validate_param(resolved_projectid,"uuid")
    raise "Malformed optional parameter projectid for resource #{@name}"
  end
  resolved_projectid
end

#get_startip ⇒ Object 



148
149
150
151
152
153
154
 
# File 'lib/stackmate/participants/cloudstack_network.rb', line 148

def get_startip
  resolved_startip = get_resolved(@props['startip'],workitem)
  if resolved_startip.nil? || !validate_param(resolved_startip,"string")
    raise "Malformed optional parameter startip for resource #{@name}"
  end
  resolved_startip
end

#get_startipv6 ⇒ Object 



172
173
174
175
176
177
178
 
# File 'lib/stackmate/participants/cloudstack_network.rb', line 172

def get_startipv6
  resolved_startipv6 = get_resolved(@props['startipv6'],workitem)
  if resolved_startipv6.nil? || !validate_param(resolved_startipv6,"string")
    raise "Malformed optional parameter startipv6 for resource #{@name}"
  end
  resolved_startipv6
end

#get_subdomainaccess ⇒ Object 



268
269
270
271
272
273
274
 
# File 'lib/stackmate/participants/cloudstack_network.rb', line 268

def get_subdomainaccess
  resolved_subdomainaccess = get_resolved(@props['subdomainaccess'],workitem)
  if resolved_subdomainaccess.nil? || !validate_param(resolved_subdomainaccess,"boolean")
    raise "Malformed optional parameter subdomainaccess for resource #{@name}"
  end
  resolved_subdomainaccess
end

#get_vlan ⇒ Object 



212
213
214
215
216
217
218
 
# File 'lib/stackmate/participants/cloudstack_network.rb', line 212

def get_vlan
  resolved_vlan = get_resolved(@props['vlan'],workitem)
  if resolved_vlan.nil? || !validate_param(resolved_vlan,"string")
    raise "Malformed optional parameter vlan for resource #{@name}"
  end
  resolved_vlan
end

#get_vpcid ⇒ Object 



276
277
278
279
280
281
282
 
# File 'lib/stackmate/participants/cloudstack_network.rb', line 276

def get_vpcid
  resolved_vpcid = get_resolved(@props['vpcid'],workitem)
  if resolved_vpcid.nil? || !validate_param(resolved_vpcid,"uuid")
    raise "Malformed optional parameter vpcid for resource #{@name}"
  end
  resolved_vpcid
end

#get_zoneid ⇒ Object 



124
125
126
127
128
129
130
 
# File 'lib/stackmate/participants/cloudstack_network.rb', line 124

def get_zoneid
  resolved_zoneid = get_resolved(@props["zoneid"],workitem)
  if resolved_zoneid.nil? || !validate_param(resolved_zoneid,"uuid")
    raise "Missing mandatory parameter zoneid for resource #{@name}"
  end
  resolved_zoneid
end

#on_workitem ⇒ Object 



87
88
89
90
91
92
93
94
95
96
97
98
 
# File 'lib/stackmate/participants/cloudstack_network.rb', line 87

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