Class: StackMate::CloudStackInstance

Inherits:

CloudStackResource

• Object
• Ruote::Participant
• CloudStackResource
• StackMate::CloudStackInstance

Defined in:

lib/stackmate/participants/cloudstack.rb

Constant Summary

Constants included from Resolver

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

Instance Attribute Summary

Attributes inherited from CloudStackResource

#name

Instance Method Summary

• #create ⇒ Object
• #default_zone_id ⇒ Object
• #delete ⇒ Object
• #image_id(imgstring, resolved, mappings) ⇒ Object
• #initialize(opts) ⇒ CloudStackInstance constructor

  A new instance of CloudStackInstance.

• #load_local_mappings ⇒ Object
• #on_workitem ⇒ Object
• #user_data(datum, resolved) ⇒ Object

Methods inherited from CloudStackResource

#set_metadata

Methods included from Resolver

#get_named_tag, #get_resolved, #recursive_resolve, #resolve_tags, #resolve_to_deviceid, #validate_param

Methods included from Logging

configure_logger_for, #logger, logger_for

Constructor Details

#initialize(opts) ⇒ CloudStackInstance

Returns a new instance of CloudStackInstance.

# File 'lib/stackmate/participants/cloudstack.rb', line 155

def initialize(opts)
  super (opts)
  @localized = {}
  load_local_mappings()
end

Instance Method Details

#create ⇒ Object

# File 'lib/stackmate/participants/cloudstack.rb', line 161

def create
  workitem[participant_name] = {}
  myname = participant_name
  @name = myname
  resolved = workitem['ResolvedNames']
  props = workitem['Resources'][workitem.participant_name]['Properties']
  security_group_names = []
  props['SecurityGroups'].each do |sg|
    sg_name = resolved[sg['Ref']]
    security_group_names << sg_name
  end
  keypair = resolved[props['KeyName']['Ref']] if props['KeyName']
  userdata = nil
  if props['UserData']
    userdata = user_data(props['UserData'], resolved)
  end
  templateid = image_id(props['ImageId'], resolved, workitem['Mappings'])
  templateid = @localized['templates'][templateid] if @localized['templates']
  svc_offer = resolved[props['InstanceType']['Ref']] #TODO fragile
  svc_offer = @localized['service_offerings'][svc_offer] if @localized['service_offerings']
  args = { 'serviceofferingid' => svc_offer,
           'templateid' => templateid,
           'zoneid' => default_zone_id,
           'securitygroupnames' => security_group_names.join(','),
           'displayname' => myname,
           #'name' => myname
           }
  args['keypair'] = keypair if keypair
  args['userdata'] = userdata if userdata
  resultobj = make_async_request('deployVirtualMachine', args)
  logger.debug("Created resource #{myname}")

  logger.debug("result = #{resultobj.inspect}")
  workitem[participant_name][:physical_id] = resultobj['virtualmachine']['id']
  workitem[participant_name][:AvailabilityZone] = resultobj['virtualmachine']['zoneid']
  ipaddress = resultobj['virtualmachine']['nic'][0]['ipaddress']
  workitem[participant_name][:PrivateDnsName] = ipaddress
  workitem[participant_name][:PublicDnsName] = ipaddress
  workitem[participant_name][:PrivateIp] = ipaddress
  workitem[participant_name][:PublicIp] = ipaddress
end

#default_zone_id ⇒ Object

# File 'lib/stackmate/participants/cloudstack.rb', line 240

def default_zone_id
  if @localized['zoneid']
    @localized['zoneid']
  else
    '1'
  end
end

#delete ⇒ Object

# File 'lib/stackmate/participants/cloudstack.rb', line 203

def delete
  logger.info "In delete #{participant_name}"
  return nil if !workitem[participant_name]
  physical_id = workitem[participant_name]['physical_id']
  if physical_id
    args = {'id' => physical_id}
    del_resp = make_async_request('destroyVirtualMachine', args)
  end
end

#image_id(imgstring, resolved, mappings) ⇒ Object

# File 'lib/stackmate/participants/cloudstack.rb', line 248

def image_id(imgstring, resolved, mappings)
  #TODO convoluted logic only handles the cases
  #ImageId : {"Ref" : "FooBar"}
  #ImageId : { "Fn::FindInMap" : [ "Map1", { "Ref" : "OuterKey" },
  # { "Fn::FindInMap" : [ "Map2", { "Ref" : "InnerKey" }, "InnerVal" ] } ] },
  #ImageId : { "Fn::FindInMap" : [ "Map1", { "Ref" : "Key" }, "Value" ] } ] },
  if imgstring['Ref']
    return resolved[imgstring['Ref']]
  else
    if imgstring['Fn::FindInMap']
      key = resolved[imgstring['Fn::FindInMap'][1]['Ref']]
      #print "Key = ", key, "\n"
      if imgstring['Fn::FindInMap'][2]['Ref']
        val = resolved[imgstring['Fn::FindInMap'][2]['Ref']]
        #print "Val [Ref] = ", val, "\n"
      else
        if imgstring['Fn::FindInMap'][2]['Fn::FindInMap']
          val = image_id(imgstring['Fn::FindInMap'][2], resolved, mappings)
          #print "Val [FindInMap] = ", val, "\n"
        else
          val = imgstring['Fn::FindInMap'][2]
        end
      end
    end
    return mappings[imgstring['Fn::FindInMap'][0]][key][val]
  end
end

#load_local_mappings ⇒ Object

# File 'lib/stackmate/participants/cloudstack.rb', line 232

def load_local_mappings()
  begin
    @localized = YAML.load_file('local.yml')
  rescue
    logger.warning "Warning: Failed to load localized mappings from local.yaml\n"
  end
end

#on_workitem ⇒ Object

# File 'lib/stackmate/participants/cloudstack.rb', line 213

def on_workitem
  if workitem['params']['operation'] == 'create'
    create
  else
    delete
  end
  reply
end

#user_data(datum, resolved) ⇒ Object

# File 'lib/stackmate/participants/cloudstack.rb', line 222

def user_data(datum, resolved)
  #TODO make this more general purpose
  actual = datum['Fn::Base64']['Fn::Join']
  delim = actual[0]
  data = actual[1].map { |d|
    d.kind_of?(Hash) ? resolved[d['Ref']]: d
  }
  Base64.urlsafe_encode64(data.join(delim))
end