""" usage: sl vs [] [...] [options] Manage, delete, order compute instances The available commands are: cancel Cancel a running virtual server capture Create an image the disk(s) of a virtual server create Order and create a virtual server (see `sl vs create-options` for choices) create-options Output available available options when creating a VS detail Output details about a virtual server dns DNS related actions to a virtual server edit Edit details of a virtual server list List virtual servers on the account nic-edit Edit NIC settings pause Pauses an active virtual server power-off Powers off a running virtual server power-on Boots up a virtual server ready Check if a virtual server has finished provisioning reboot Reboots a running virtual server reload Reload the OS on a VS based on its current configuration resume Resumes a paused virtual server upgrade Upgrades parameters of a virtual server For several commands, will be asked for. This can be the id, hostname or the ip address for a virtual server. """ # :license: MIT, see LICENSE for more details. import os import os.path import SoftLayer from SoftLayer.CLI import environment from SoftLayer.CLI import exceptions from SoftLayer.CLI import formatting from SoftLayer.CLI import helpers from SoftLayer.CLI import template from SoftLayer import utils class ListVSIs(environment.CLIRunnable): """ usage: sl vs list [--hourly | --monthly] [--sortby=SORT_COLUMN] [--tags=TAGS] [options] List virtual servers Examples: sl vs list --datacenter=dal05 sl vs list --network=100 --cpu=2 sl vs list --memory='>= 2048' sl vs list --tags=production,db Options: --sortby=ARG Column to sort by. options: id, datacenter, host, Cores, memory, primary_ip, backend_ip Filters: -c --cpu=CPU Number of CPU cores -D --domain=DOMAIN Domain portion of the FQDN. example: example.com -d DC, --datacenter=DC datacenter shortname (sng01, dal05, ...) -H --hostname=HOST Host portion of the FQDN. example: server -m --memory=MEMORY Memory in mebibytes -n MBPS, --network=MBPS Network port speed in Mbps --hourly Show hourly instances --monthly Show monthly instances --tags=ARG Only show instances that have one of these tags. Comma-separated. (production,db) For more on filters see 'sl help filters' """ action = 'list' def execute(self, args): vsi = SoftLayer.VSManager(self.client) tags = None if args.get('--tags'): tags = [tag.strip() for tag in args.get('--tags').split(',')] guests = vsi.list_instances(hourly=args.get('--hourly'), monthly=args.get('--monthly'), hostname=args.get('--hostname'), domain=args.get('--domain'), cpus=args.get('--cpu'), memory=args.get('--memory'), datacenter=args.get('--datacenter'), nic_speed=args.get('--network'), tags=tags) table = formatting.Table([ 'id', 'datacenter', 'host', 'cores', 'memory', 'primary_ip', 'backend_ip', 'active_transaction', ]) table.sortby = args.get('--sortby') or 'host' for guest in guests: guest = utils.NestedDict(guest) table.add_row([ guest['id'], guest['datacenter']['name'] or formatting.blank(), guest['fullyQualifiedDomainName'], guest['maxCpu'], formatting.mb_to_gb(guest['maxMemory']), guest['primaryIpAddress'] or formatting.blank(), guest['primaryBackendIpAddress'] or formatting.blank(), formatting.active_txn(guest), ]) return table class VSDetails(environment.CLIRunnable): """ usage: sl vs detail [--passwords] [--price] [options] Get details for a virtual server Options: --passwords Show passwords (check over your shoulder!) --price Show associated prices """ action = 'detail' def execute(self, args): vsi = SoftLayer.VSManager(self.client) table = formatting.KeyValueTable(['Name', 'Value']) table.align['Name'] = 'r' table.align['Value'] = 'l' vs_id = helpers.resolve_id(vsi.resolve_ids, args.get(''), 'VS') result = vsi.get_instance(vs_id) result = utils.NestedDict(result) table.add_row(['id', result['id']]) table.add_row(['hostname', result['fullyQualifiedDomainName']]) table.add_row(['status', formatting.FormattedItem( result['status']['keyName'] or formatting.blank(), result['status']['name'] or formatting.blank() )]) table.add_row(['active_transaction', formatting.active_txn(result)]) table.add_row(['state', formatting.FormattedItem( utils.lookup(result, 'powerState', 'keyName'), utils.lookup(result, 'powerState', 'name'), )]) table.add_row(['datacenter', result['datacenter']['name'] or formatting.blank()]) operating_system = utils.lookup(result, 'operatingSystem', 'softwareLicense', 'softwareDescription') or {} table.add_row([ 'os', formatting.FormattedItem( operating_system.get('version') or formatting.blank(), operating_system.get('name') or formatting.blank() )]) table.add_row(['os_version', operating_system.get('version') or formatting.blank()]) table.add_row(['cores', result['maxCpu']]) table.add_row(['memory', formatting.mb_to_gb(result['maxMemory'])]) table.add_row(['public_ip', result['primaryIpAddress'] or formatting.blank()]) table.add_row(['private_ip', result['primaryBackendIpAddress'] or formatting.blank()]) table.add_row(['private_only', result['privateNetworkOnlyFlag']]) table.add_row(['private_cpu', result['dedicatedAccountHostOnlyFlag']]) table.add_row(['created', result['createDate']]) table.add_row(['modified', result['modifyDate']]) vlan_table = formatting.Table(['type', 'number', 'id']) for vlan in result['networkVlans']: vlan_table.add_row([ vlan['networkSpace'], vlan['vlanNumber'], vlan['id']]) table.add_row(['vlans', vlan_table]) if result.get('notes'): table.add_row(['notes', result['notes']]) if args.get('--price'): table.add_row(['price rate', result['billingItem']['recurringFee']]) if args.get('--passwords'): pass_table = formatting.Table(['username', 'password']) for item in result['operatingSystem']['passwords']: pass_table.add_row([item['username'], item['password']]) table.add_row(['users', pass_table]) tag_row = [] for tag in result['tagReferences']: tag_row.append(tag['tag']['name']) if tag_row: table.add_row(['tags', formatting.listing(tag_row, separator=',')]) # Test to see if this actually has a primary (public) ip address if result['primaryIpAddress']: ptr_domains = (self.client['Virtual_Guest'] .getReverseDomainRecords(id=vs_id)) for ptr_domain in ptr_domains: for ptr in ptr_domain['resourceRecords']: table.add_row(['ptr', ptr['data']]) return table class CreateOptionsVS(environment.CLIRunnable): """ usage: sl vs create-options [options] Output available available options when creating a virtual server Options: --all Show all options. default if no other option provided --cpu Show CPU options --datacenter Show datacenter options --disk Show disk options --memory Show memory size options --nic Show NIC speed options --os Show operating system options """ action = 'create-options' options = ['datacenter', 'cpu', 'nic', 'disk', 'os', 'memory'] def execute(self, args): vsi = SoftLayer.VSManager(self.client) result = vsi.get_create_options() show_all = True for opt_name in self.options: if args.get("--" + opt_name): show_all = False break if args['--all']: show_all = True table = formatting.KeyValueTable(['Name', 'Value']) table.align['Name'] = 'r' table.align['Value'] = 'l' if args['--datacenter'] or show_all: datacenters = [dc['template']['datacenter']['name'] for dc in result['datacenters']] table.add_row(['datacenter', formatting.listing(datacenters, separator=',')]) if args['--cpu'] or show_all: standard_cpu = [x for x in result['processors'] if not x['template'].get( 'dedicatedAccountHostOnlyFlag', False)] ded_cpu = [x for x in result['processors'] if x['template'].get('dedicatedAccountHostOnlyFlag', False)] def add_cpus_row(cpu_options, name): """ Add CPU rows to the table """ cpus = [] for cpu_option in cpu_options: cpus.append(str(cpu_option['template']['startCpus'])) table.add_row(['cpus (%s)' % name, formatting.listing(cpus, separator=',')]) add_cpus_row(ded_cpu, 'private') add_cpus_row(standard_cpu, 'standard') if args['--memory'] or show_all: memory = [ str(m['template']['maxMemory']) for m in result['memory']] table.add_row(['memory', formatting.listing(memory, separator=',')]) if args['--os'] or show_all: op_sys = [ o['template']['operatingSystemReferenceCode'] for o in result['operatingSystems']] op_sys = sorted(op_sys) os_summary = set() for operating_system in op_sys: os_summary.add(operating_system[0:operating_system.find('_')]) for summary in sorted(os_summary): table.add_row([ 'os (%s)' % summary, os.linesep.join(sorted([x for x in op_sys if x[0:len(summary)] == summary])) ]) if args['--disk'] or show_all: local_disks = [x for x in result['blockDevices'] if x['template'].get('localDiskFlag', False)] san_disks = [x for x in result['blockDevices'] if not x['template'].get('localDiskFlag', False)] def add_block_rows(disks, name): """ Add block rows to the table """ simple = {} for disk in disks: block = disk['template']['blockDevices'][0] bid = block['device'] if bid not in simple: simple[bid] = [] simple[bid].append(str(block['diskImage']['capacity'])) for label in sorted(simple.keys()): table.add_row(['%s disk(%s)' % (name, label), formatting.listing(simple[label], separator=',')]) add_block_rows(local_disks, 'local') add_block_rows(san_disks, 'san') if args['--nic'] or show_all: speeds = [] for comp in result['networkComponents']: speed = comp['template']['networkComponents'][0]['maxSpeed'] speeds.append(str(speed)) speeds = sorted(speeds) table.add_row(['nic', formatting.listing(speeds, separator=',')]) return table class CreateVS(environment.CLIRunnable): """ usage: sl vs create [--disk=SIZE...] [--key=KEY...] [options] Order/create a VS. See 'sl vs create-options' for valid options Required: -c, --cpu=CPU Number of CPU cores -D, --domain=DOMAIN Domain portion of the FQDN. example: example.com -H, --hostname=HOST Host portion of the FQDN. example: server --image=GUID Image GUID. See: 'sl image list' for reference -m, --memory=MEMORY Memory in mebibytes. example: 2048 -o, --os=OS OS install code. Tip: you can specify _LATEST --hourly Hourly rate instance type --monthly Monthly rate instance type Optional: -d, --datacenter=DC Datacenter shortname (sng01, dal05, ...) Note: Omitting this value defaults to the first available datacenter --dedicated Create a dedicated VS (Virtual Server (Private Node)) --san Use SAN storage instead of local disk. Applies to all disks specified with --disk. --test Do not create VS, just get a quote --export=FILE Exports options to a template file -F, --userfile=FILE Read userdata from file -i, --postinstall=URI Post-install script to download (Only HTTPS executes, HTTP leaves file in /root) -k, --key=KEY SSH keys to add to the root user. Can be specified multiple times --like=IDENTIFIER Use the configuration from an existing VS -n, --network=MBPS Network port speed in Mbps --disk=SIZE... Disks. Can be specified multiple times --private Forces the VS to only have access the private network -t, --template=FILE A template file that defaults the command-line options using the long name in INI format -u, --userdata=DATA User defined metadata string --vlan_public=VLAN The ID of the public VLAN on which you want the VS placed. --vlan_private=VLAN The ID of the private VLAN on which you want the VS placed. --wait=SECONDS Block until VS is finished provisioning for up to X seconds before returning """ action = 'create' options = ['confirm'] required_params = ['--hostname', '--domain', '--cpu', '--memory'] def execute(self, args): template.update_with_template_args(args, list_args=['--disk', '--key']) vsi = SoftLayer.VSManager(self.client) self._update_with_like_args(args) self._validate_args(args) # Do not create a virtual server with --test or --export do_create = not (args['--export'] or args['--test']) table = formatting.Table(['Item', 'cost']) table.align['Item'] = 'r' table.align['cost'] = 'r' data = self._parse_create_args(args) output = [] if args.get('--test'): result = vsi.verify_create_instance(**data) total_monthly = 0.0 total_hourly = 0.0 table = formatting.Table(['Item', 'cost']) table.align['Item'] = 'r' table.align['cost'] = 'r' for price in result['prices']: total_monthly += float(price.get('recurringFee', 0.0)) total_hourly += float(price.get('hourlyRecurringFee', 0.0)) if args.get('--hourly'): rate = "%.2f" % float(price['hourlyRecurringFee']) else: rate = "%.2f" % float(price['recurringFee']) table.add_row([price['item']['description'], rate]) if args.get('--hourly'): total = total_hourly else: total = total_monthly billing_rate = 'monthly' if args.get('--hourly'): billing_rate = 'hourly' table.add_row(['Total %s cost' % billing_rate, "%.2f" % total]) output.append(table) output.append(formatting.FormattedItem( None, ' -- ! Prices reflected here are retail and do not ' 'take account level discounts and are not guaranteed.')) if args['--export']: export_file = args.pop('--export') template.export_to_template(export_file, args, exclude=['--wait', '--test']) return 'Successfully exported options to a template file.' if do_create: if args['--really'] or formatting.confirm( "This action will incur charges on your account. " "Continue?"): result = vsi.create_instance(**data) table = formatting.KeyValueTable(['name', 'value']) table.align['name'] = 'r' table.align['value'] = 'l' table.add_row(['id', result['id']]) table.add_row(['created', result['createDate']]) table.add_row(['guid', result['globalIdentifier']]) output.append(table) if args.get('--wait'): ready = vsi.wait_for_ready( result['id'], int(args.get('--wait') or 1)) table.add_row(['ready', ready]) else: raise exceptions.CLIAbort('Aborting virtual server order.') return output def _validate_args(self, args): """ Raises an ArgumentError if the given arguments are not valid """ invalid_args = [k for k in self.required_params if args.get(k) is None] if invalid_args: raise exceptions.ArgumentError('Missing required options: %s' % ','.join(invalid_args)) if all([args['--userdata'], args['--userfile']]): raise exceptions.ArgumentError( '[-u | --userdata] not allowed with [-F | --userfile]') if args['--hourly'] in formatting.FALSE_VALUES: args['--hourly'] = False if args['--monthly'] in formatting.FALSE_VALUES: args['--monthly'] = False if all([args['--hourly'], args['--monthly']]): raise exceptions.ArgumentError( '[--hourly] not allowed with [--monthly]') if not any([args['--hourly'], args['--monthly']]): raise exceptions.ArgumentError( 'One of [--hourly | --monthly] is required') image_args = [args['--os'], args['--image']] if all(image_args): raise exceptions.ArgumentError( '[-o | --os] not allowed with [--image]') if not any(image_args): raise exceptions.ArgumentError( 'One of [--os | --image] is required') if args['--userfile']: if not os.path.exists(args['--userfile']): raise exceptions.ArgumentError( 'File does not exist [-u | --userfile] = %s' % args['--userfile']) def _update_with_like_args(self, args): """ Update arguments with options taken from a currently running VS. :param VSManager args: A VSManager :param dict args: CLI arguments """ if args['--like']: vsi = SoftLayer.VSManager(self.client) vs_id = helpers.resolve_id(vsi.resolve_ids, args.pop('--like'), 'VS') like_details = vsi.get_instance(vs_id) like_args = { '--hostname': like_details['hostname'], '--domain': like_details['domain'], '--cpu': like_details['maxCpu'], '--memory': like_details['maxMemory'], '--hourly': like_details['hourlyBillingFlag'], '--monthly': not like_details['hourlyBillingFlag'], '--datacenter': like_details['datacenter']['name'], '--network': like_details['networkComponents'][0]['maxSpeed'], '--user-data': like_details['userData'] or None, '--postinstall': like_details.get('postInstallScriptUri'), '--dedicated': like_details['dedicatedAccountHostOnlyFlag'], '--private': like_details['privateNetworkOnlyFlag'], } # Handle mutually exclusive options like_image = utils.lookup(like_details, 'blockDeviceTemplateGroup', 'globalIdentifier') like_os = utils.lookup(like_details, 'operatingSystem', 'softwareLicense', 'softwareDescription', 'referenceCode') if like_image and not args.get('--os'): like_args['--image'] = like_image elif like_os and not args.get('--image'): like_args['--os'] = like_os if args.get('--hourly'): like_args['--monthly'] = False if args.get('--monthly'): like_args['--hourly'] = False # Merge like VS options with the options passed in for key, value in like_args.items(): if args.get(key) in [None, False]: args[key] = value def _parse_create_args(self, args): """ Converts CLI arguments to arguments that can be passed into VSManager.create_instance. :param dict args: CLI arguments """ data = { "hourly": args['--hourly'], "cpus": args['--cpu'], "domain": args['--domain'], "hostname": args['--hostname'], "private": args['--private'], "dedicated": args['--dedicated'], "disks": args['--disk'], "local_disk": not args['--san'], } try: memory = int(args['--memory']) if memory < 1024: memory = memory * 1024 except ValueError: unit = args['--memory'][-1] memory = int(args['--memory'][0:-1]) if unit in ['G', 'g']: memory = memory * 1024 if unit in ['T', 'r']: memory = memory * 1024 * 1024 data["memory"] = memory if args['--monthly']: data['hourly'] = False if args.get('--os'): data['os_code'] = args['--os'] if args.get('--image'): data['image_id'] = args['--image'] if args.get('--datacenter'): data['datacenter'] = args['--datacenter'] if args.get('--network'): data['nic_speed'] = args.get('--network') if args.get('--userdata'): data['userdata'] = args['--userdata'] elif args.get('--userfile'): with open(args['--userfile'], 'r') as userfile: data['userdata'] = userfile.read() if args.get('--postinstall'): data['post_uri'] = args.get('--postinstall') # Get the SSH keys if args.get('--key'): keys = [] for key in args.get('--key'): resolver = SoftLayer.SshKeyManager(self.client).resolve_ids key_id = helpers.resolve_id(resolver, key, 'SshKey') keys.append(key_id) data['ssh_keys'] = keys if args.get('--vlan_public'): data['public_vlan'] = args['--vlan_public'] if args.get('--vlan_private'): data['private_vlan'] = args['--vlan_private'] return data class ReadyVS(environment.CLIRunnable): """ usage: sl vs ready [options] Check if a virtual server is ready. Optional: --wait=SECONDS Block until VS is finished provisioning for up to X seconds before returning. """ action = 'ready' def execute(self, args): vsi = SoftLayer.VSManager(self.client) vs_id = helpers.resolve_id(vsi.resolve_ids, args.get(''), 'VS') ready = vsi.wait_for_ready(vs_id, int(args.get('--wait') or 0)) if ready: return "READY" else: raise exceptions.CLIAbort("Instance %s not ready" % vs_id) class ReloadVS(environment.CLIRunnable): """ usage: sl vs reload [--key=KEY...] [options] Reload the OS on a virtual server based on its current configuration Optional: -i, --postinstall=URI Post-install script to download (Only HTTPS executes, HTTP leaves file in /root) -k, --key=KEY SSH keys to add to the root user. Can be specified multiple times """ action = 'reload' options = ['confirm'] def execute(self, args): vsi = SoftLayer.VSManager(self.client) vs_id = helpers.resolve_id(vsi.resolve_ids, args.get(''), 'VS') keys = [] if args.get('--key'): for key in args.get('--key'): resolver = SoftLayer.SshKeyManager(self.client).resolve_ids key_id = helpers.resolve_id(resolver, key, 'SshKey') keys.append(key_id) if args['--really'] or formatting.no_going_back(vs_id): vsi.reload_instance(vs_id, args['--postinstall'], keys) else: raise exceptions.CLIAbort('Aborted') class CancelVS(environment.CLIRunnable): """ usage: sl vs cancel [options] Cancel a virtual server """ action = 'cancel' options = ['confirm'] def execute(self, args): vsi = SoftLayer.VSManager(self.client) vs_id = helpers.resolve_id(vsi.resolve_ids, args.get(''), 'VS') if args['--really'] or formatting.no_going_back(vs_id): vsi.cancel_instance(vs_id) else: raise exceptions.CLIAbort('Aborted') class VSPowerOff(environment.CLIRunnable): """ usage: sl vs power-off [--hard] [options] Power off an active virtual server Optional: --hard Perform a hard shutdown """ action = 'power-off' options = ['confirm'] def execute(self, args): virtual_guest = self.client['Virtual_Guest'] vsi = SoftLayer.VSManager(self.client) vs_id = helpers.resolve_id(vsi.resolve_ids, args.get(''), 'VS') if args['--really'] or formatting.confirm('This will power off the VS ' 'with id %s. Continue?' % vs_id): if args['--hard']: virtual_guest.powerOff(id=vs_id) else: virtual_guest.powerOffSoft(id=vs_id) else: raise exceptions.CLIAbort('Aborted.') class VSReboot(environment.CLIRunnable): """ usage: sl vs reboot [--hard | --soft] [options] Reboot an active virtual server Optional: --hard Perform an abrupt reboot --soft Perform a graceful reboot """ action = 'reboot' options = ['confirm'] def execute(self, args): virtual_guest = self.client['Virtual_Guest'] vsi = SoftLayer.VSManager(self.client) vs_id = helpers.resolve_id(vsi.resolve_ids, args.get(''), 'VS') if args['--really'] or formatting.confirm('This will reboot the VS ' 'with id %s. Continue?' % vs_id): if args['--hard']: virtual_guest.rebootHard(id=vs_id) elif args['--soft']: virtual_guest.rebootSoft(id=vs_id) else: virtual_guest.rebootDefault(id=vs_id) else: raise exceptions.CLIAbort('Aborted.') class VSPowerOn(environment.CLIRunnable): """ usage: sl vs power-on [options] Power on a virtual server """ action = 'power-on' def execute(self, args): virtual_guest = self.client['Virtual_Guest'] vsi = SoftLayer.VSManager(self.client) vs_id = helpers.resolve_id(vsi.resolve_ids, args.get(''), 'VS') virtual_guest.powerOn(id=vs_id) class VSPause(environment.CLIRunnable): """ usage: sl vs pause [options] Pauses an active virtual server """ action = 'pause' options = ['confirm'] def execute(self, args): virtual_guest = self.client['Virtual_Guest'] vsi = SoftLayer.VSManager(self.client) vs_id = helpers.resolve_id(vsi.resolve_ids, args.get(''), 'VS') if args['--really'] or formatting.confirm('This will pause the VS ' 'with id %s. Continue?' % vs_id): virtual_guest.pause(id=vs_id) else: raise exceptions.CLIAbort('Aborted.') class VSResume(environment.CLIRunnable): """ usage: sl vs resume [options] Resumes a paused virtual server """ action = 'resume' def execute(self, args): virtual_guest = self.client['Virtual_Guest'] vsi = SoftLayer.VSManager(self.client) vs_id = helpers.resolve_id(vsi.resolve_ids, args.get(''), 'VS') virtual_guest.resume(id=vs_id) class NicEditVS(environment.CLIRunnable): """ usage: sl vs nic-edit (public | private) --speed=SPEED [options] Manage NIC settings Options: --speed=SPEED Port speed. 0 disables the port. [Options: 0, 10, 100, 1000, 10000] """ action = 'nic-edit' def execute(self, args): public = args['public'] vsi = SoftLayer.VSManager(self.client) vs_id = helpers.resolve_id(vsi.resolve_ids, args.get(''), 'VS') vsi.change_port_speed(vs_id, public, args['--speed']) class VSDNS(environment.CLIRunnable): """ usage: sl vs dns sync [options] Attempts to update DNS for the specified VS. If you don't specify any arguments, it will attempt to update both the A and PTR records. If you don't want to update both records, you may use the -a or --ptr arguments to limit the records updated. Options: -a Sync the A record for the host --ptr Sync the PTR record for the host --ttl=TTL Sets the TTL for the A and/or PTR records """ action = 'dns' options = ['confirm'] def execute(self, args): args['--ttl'] = args['--ttl'] or 7200 if args['sync']: return self.dns_sync(args) def dns_sync(self, args): """ Sync DNS records to match the FQDN of the virtual server """ dns = SoftLayer.DNSManager(self.client) vsi = SoftLayer.VSManager(self.client) vs_id = helpers.resolve_id(vsi.resolve_ids, args.get(''), 'VS') instance = vsi.get_instance(vs_id) zone_id = helpers.resolve_id(dns.resolve_ids, instance['domain'], name='zone') def sync_a_record(): """ Sync A record """ records = dns.get_records( zone_id, host=instance['hostname'], ) if not records: # don't have a record, lets add one to the base zone dns.create_record( zone['id'], instance['hostname'], 'a', instance['primaryIpAddress'], ttl=args['--ttl']) else: recs = [x for x in records if x['type'].lower() == 'a'] if len(recs) != 1: raise exceptions.CLIAbort("Aborting A record sync, found " "%d A record exists!" % len(recs)) rec = recs[0] rec['data'] = instance['primaryIpAddress'] rec['ttl'] = args['--ttl'] dns.edit_record(rec) def sync_ptr_record(): """ Sync PTR record """ host_rec = instance['primaryIpAddress'].split('.')[-1] ptr_domains = (self.client['Virtual_Guest'] .getReverseDomainRecords(id=instance['id'])[0]) edit_ptr = None for ptr in ptr_domains['resourceRecords']: if ptr['host'] == host_rec: ptr['ttl'] = args['--ttl'] edit_ptr = ptr break if edit_ptr: edit_ptr['data'] = instance['fullyQualifiedDomainName'] dns.edit_record(edit_ptr) else: dns.create_record( ptr_domains['id'], host_rec, 'ptr', instance['fullyQualifiedDomainName'], ttl=args['--ttl']) if not instance['primaryIpAddress']: raise exceptions.CLIAbort('No primary IP address associated with ' 'this VS') zone = dns.get_zone(zone_id) go_for_it = args['--really'] or formatting.confirm( "Attempt to update DNS records for %s" % instance['fullyQualifiedDomainName']) if not go_for_it: raise exceptions.CLIAbort("Aborting DNS sync") both = False if not args['--ptr'] and not args['-a']: both = True if both or args['-a']: sync_a_record() if both or args['--ptr']: sync_ptr_record() class EditVS(environment.CLIRunnable): """ usage: sl vs edit [options] Edit a virtual server's details Options: -D --domain=DOMAIN Domain portion of the FQDN example: example.com -F --userfile=FILE Read userdata from file -H --hostname=HOST Host portion of the FQDN. example: server -u --userdata=DATA User defined metadata string """ action = 'edit' def execute(self, args): data = {} if args['--userdata'] and args['--userfile']: raise exceptions.ArgumentError( '[-u | --userdata] not allowed with [-F | --userfile]') if args['--userfile']: if not os.path.exists(args['--userfile']): raise exceptions.ArgumentError( 'File does not exist [-u | --userfile] = %s' % args['--userfile']) if args.get('--userdata'): data['userdata'] = args['--userdata'] elif args.get('--userfile'): with open(args['--userfile'], 'r') as userfile: data['userdata'] = userfile.read() data['hostname'] = args.get('--hostname') data['domain'] = args.get('--domain') vsi = SoftLayer.VSManager(self.client) vs_id = helpers.resolve_id(vsi.resolve_ids, args.get(''), 'VS') if not vsi.edit(vs_id, **data): raise exceptions.CLIAbort("Failed to update virtual server") class CaptureVS(environment.CLIRunnable): """ usage: sl vs capture [options] Capture one or all disks from a virtual server to a SoftLayer image. Required: -n --name=NAME Name of the image Optional: --all Capture all disks belonging to the VS --note=NOTE Add a note to be associated with the image """ action = 'capture' def execute(self, args): vsi = SoftLayer.VSManager(self.client) vs_id = helpers.resolve_id(vsi.resolve_ids, args.get(''), 'VS') if args['--all']: additional_disks = True else: additional_disks = False capture = vsi.capture(vs_id, args.get('--name'), additional_disks, args.get('--note')) table = formatting.KeyValueTable(['Name', 'Value']) table.align['Name'] = 'r' table.align['Value'] = 'l' table.add_row(['vs_id', capture['guestId']]) table.add_row(['date', capture['createDate'][:10]]) table.add_row(['time', capture['createDate'][11:19]]) table.add_row(['transaction', formatting.transaction_status(capture)]) table.add_row(['transaction_id', capture['id']]) table.add_row(['all_disks', additional_disks]) return table class UpgradeVS(environment.CLIRunnable): """ usage: sl vs upgrade [options] Upgrade parameters of a virtual server Examples: sl vs upgrade --cpus 2 sl vs upgrade --memory 2048 --network 1000 Options: --cpu=CPU Number of CPU cores --private CPU core will be on a dedicated host server. Default is Public. Public: Resources are in multi-tenant environment. --memory=MEMORY Memory in megabytes --network=MBPS Network port speed in Mbps Note: SoftLayer automatically reboots the VS once upgrade request is placed. The VS is halted until the Upgrade transaction is completed. However for Network, no reboot is required. """ action = 'upgrade' options = ['confirm'] def execute(self, args): vsi = SoftLayer.VSManager(self.client) data = {} data['cpus'] = args.get('--cpu') data['memory'] = args.get('--memory') data['nic_speed'] = args.get('--network') data['public'] = True if args.get('--private'): data['public'] = False data = self.verify_upgrade_parameters(data) vs_id = helpers.resolve_id(vsi.resolve_ids, args.get(''), 'VS') if args['--really'] or formatting.confirm( "This action will incur charges on your account. " "Continue?"): if not vsi.upgrade(vs_id, **data): raise exceptions.CLIAbort('VS Upgrade Failed') def verify_upgrade_parameters(self, data): """ param int cpus: The number of virtual CPUs to upgrade to of a virtual server. :param int memory: RAM of the VS to be upgraded to. :param int nic_speed: The port speed to set """ try: if data['memory']: data['memory'] = int(data['memory']) / 1024 if data['cpus']: data['cpus'] = int(data['cpus']) if data['nic_speed']: data['nic_speed'] = int(data['nic_speed']) return data except Exception: raise ValueError( "One or more Values of VS parameters are not correct")