From 26e9c1ad61dad61a8fb104c6a1f15e38320337dc Mon Sep 17 00:00:00 2001 From: Scott Anderson Date: Sat, 8 Feb 2014 18:35:26 -0500 Subject: [PATCH] Change standard AWS access and secret key parameter names to aws_access_key and aws_secret_key. Fixes an authentication problem with the rds module and standardizes the naming convention on something more encompassing than ec2_*_key. --- cloud/ec2 | 3 ++- cloud/ec2_elb | 12 ++++++------ cloud/ec2_elb_lb | 16 ++++++---------- cloud/ec2_vpc | 11 ++++++----- cloud/elasticache | 16 ++++++---------- cloud/rds | 11 ++++++----- cloud/route53 | 7 +++---- cloud/s3 | 9 ++++----- 8 files changed, 39 insertions(+), 46 deletions(-) diff --git a/cloud/ec2 b/cloud/ec2 index 557830b7500..8d0214ea3ce 100644 --- a/cloud/ec2 +++ b/cloud/ec2 @@ -1045,6 +1045,8 @@ def main(): ec2 = ec2_connect(module) + tagged_instances = [] + if module.params.get('state') == 'absent': instance_ids = module.params.get('instance_ids') if not isinstance(instance_ids, list): @@ -1064,7 +1066,6 @@ def main(): if not module.params.get('image'): module.fail_json(msg='image parameter is required for new instance') - tagged_instances = [] if module.params.get('exact_count'): (tagged_instances, instance_dict_array, new_instance_ids, changed) = enforce_count(module, ec2) else: diff --git a/cloud/ec2_elb b/cloud/ec2_elb index 1927d6c3a7a..a591b982911 100644 --- a/cloud/ec2_elb +++ b/cloud/ec2_elb @@ -284,21 +284,21 @@ class ElbManager: def main(): - - module = AnsibleModule( - argument_spec=dict( + argument_spec = ec2_argument_spec() + argument_spec.update(dict( state={'required': True, 'choices': ['present', 'absent']}, instance_id={'required': True}, ec2_elbs={'default': None, 'required': False, 'type':'list'}, - ec2_secret_key={'default': None, 'aliases': ['aws_secret_key', 'secret_key'], 'no_log': True}, - ec2_access_key={'default': None, 'aliases': ['aws_access_key', 'access_key']}, - region={'default': None, 'required': False, 'aliases':['aws_region', 'ec2_region'], 'choices':AWS_REGIONS}, enable_availability_zone={'default': True, 'required': False, 'choices': BOOLEANS, 'type': 'bool'}, wait={'required': False, 'choices': BOOLEANS, 'default': True, 'type': 'bool'} ) ) + module = AnsibleModule( + argument_spec=argument_spec, + ) + # def get_ec2_creds(module): # return ec2_url, ec2_access_key, ec2_secret_key, region ec2_url, aws_access_key, aws_secret_key, region = get_ec2_creds(module) diff --git a/cloud/ec2_elb_lb b/cloud/ec2_elb_lb index 5e4db144c87..867c19c8652 100644 --- a/cloud/ec2_elb_lb +++ b/cloud/ec2_elb_lb @@ -439,8 +439,8 @@ class ElbManager(object): def main(): - module = AnsibleModule( - argument_spec=dict( + argument_spec = ec2_argument_spec() + argument_spec.update(dict( state={'required': True, 'choices': ['present', 'absent']}, name={'required': True}, listeners={'default': None, 'required': False, 'type': 'list'}, @@ -450,17 +450,13 @@ def main(): purge_zones={'default': False, 'required': False, 'choices': BOOLEANS, 'type': 'bool'}, health_check={'default': None, 'required': False, 'type': 'dict'}, - ec2_secret_key={'default': None, - 'aliases': ['aws_secret_key', 'secret_key'], - 'no_log': True}, - ec2_access_key={'default': None, - 'aliases': ['aws_access_key', 'access_key']}, - region={'default': None, 'required': False, - 'aliases': ['aws_region', 'ec2_region'], - 'choices': AWS_REGIONS}, ) ) + module = AnsibleModule( + argument_spec=argument_spec, + ) + # def get_ec2_creds(module): # return ec2_url, ec2_access_key, ec2_secret_key, region ec2_url, aws_access_key, aws_secret_key, region = get_ec2_creds(module) diff --git a/cloud/ec2_vpc b/cloud/ec2_vpc index d50bed4bcba..82f74783b3e 100644 --- a/cloud/ec2_vpc +++ b/cloud/ec2_vpc @@ -471,8 +471,8 @@ def terminate_vpc(module, vpc_conn, vpc_id=None, cidr=None): def main(): - module = AnsibleModule( - argument_spec = dict( + argument_spec = ec2_argument_spec() + argument_spec.update(dict( cidr_block = dict(), wait = dict(choices=BOOLEANS, default=False), wait_timeout = dict(default=300), @@ -482,13 +482,14 @@ def main(): vpc_id = dict(), internet_gateway = dict(choices=BOOLEANS, default=False), route_tables = dict(type='list'), - region = dict(aliases=['aws_region', 'ec2_region'], choices=AWS_REGIONS), state = dict(choices=['present', 'absent'], default='present'), - ec2_secret_key = dict(aliases=['aws_secret_key', 'secret_key'], no_log=True), - ec2_access_key = dict(aliases=['aws_access_key', 'access_key']), ) ) + module = AnsibleModule( + argument_spec=argument_spec, + ) + state = module.params.get('state') ec2_url, aws_access_key, aws_secret_key, region = get_ec2_creds(module) diff --git a/cloud/elasticache b/cloud/elasticache index a54deafc25d..7cbd72d736d 100644 --- a/cloud/elasticache +++ b/cloud/elasticache @@ -458,8 +458,8 @@ class ElastiCacheManager(object): def main(): - module = AnsibleModule( - argument_spec=dict( + argument_spec = ec2_argument_spec() + argument_spec.update(dict( state={'required': True, 'choices': ['present', 'absent', 'rebooted']}, name={'required': True}, engine={'required': False, 'default': 'memcached'}, @@ -470,19 +470,15 @@ def main(): cache_security_groups={'required': False, 'default': ['default'], 'type': 'list'}, zone={'required': False, 'default': None}, - ec2_secret_key={'default': None, - 'aliases': ['aws_secret_key', 'secret_key'], - 'no_log': True}, - ec2_access_key={'default': None, - 'aliases': ['aws_access_key', 'access_key']}, - region={'default': None, 'required': False, - 'aliases': ['aws_region', 'ec2_region'], - 'choices': AWS_REGIONS}, wait={'required': False, 'choices': BOOLEANS, 'default': True}, hard_modify={'required': False, 'choices': BOOLEANS, 'default': False} ) ) + module = AnsibleModule( + argument_spec=argument_spec, + ) + ec2_url, aws_access_key, aws_secret_key, region = get_ec2_creds(module) name = module.params['name'] diff --git a/cloud/rds b/cloud/rds index 246a53690ba..7a83e339099 100644 --- a/cloud/rds +++ b/cloud/rds @@ -277,8 +277,8 @@ def get_current_resource(conn, resource, command): def main(): - module = AnsibleModule( - argument_spec = dict( + argument_spec = ec2_argument_spec() + argument_spec.update(dict( command = dict(choices=['create', 'replicate', 'delete', 'facts', 'modify', 'promote', 'snapshot', 'restore'], required=True), instance_name = dict(required=True), source_instance = dict(required=False), @@ -300,11 +300,8 @@ def main(): maint_window = dict(required=False), backup_window = dict(required=False), backup_retention = dict(required=False), - region = dict(aliases=['aws_region', 'ec2_region'], choices=AWS_REGIONS, required=False), zone = dict(aliases=['aws_zone', 'ec2_zone'], required=False), subnet = dict(required=False), - aws_secret_key = dict(aliases=['ec2_secret_key', 'secret_key'], no_log=True, required=False), - aws_access_key = dict(aliases=['ec2_access_key', 'access_key'], required=False), wait = dict(type='bool', default=False), wait_timeout = dict(default=300), snapshot = dict(required=False), @@ -313,6 +310,10 @@ def main(): ) ) + module = AnsibleModule( + argument_spec=argument_spec, + ) + command = module.params.get('command') instance_name = module.params.get('instance_name') source_instance = module.params.get('source_instance') diff --git a/cloud/route53 b/cloud/route53 index f6d5e44ef05..4298799b460 100644 --- a/cloud/route53 +++ b/cloud/route53 @@ -145,19 +145,18 @@ def commit(changes): time.sleep(500) def main(): - module = AnsibleModule( - argument_spec = dict( + argument_spec = ec2_argument_keys_spec() + argument_spec.update(dict( command = dict(choices=['get', 'create', 'delete'], required=True), zone = dict(required=True), record = dict(required=True), ttl = dict(required=False, default=3600), type = dict(choices=['A', 'CNAME', 'MX', 'AAAA', 'TXT', 'PTR', 'SRV', 'SPF', 'NS'], required=True), value = dict(required=False), - ec2_secret_key = dict(aliases=['aws_secret_key', 'secret_key'], no_log=True, required=False), - ec2_access_key = dict(aliases=['aws_access_key', 'access_key'], required=False), overwrite = dict(required=False, type='bool') ) ) + module = AnsibleModule(argument_spec=argument_spec) command_in = module.params.get('command') zone_in = module.params.get('zone') diff --git a/cloud/s3 b/cloud/s3 index 5d2c97baf39..6e566e4b8dc 100644 --- a/cloud/s3 +++ b/cloud/s3 @@ -249,8 +249,8 @@ def is_walrus(s3_url): return False def main(): - module = AnsibleModule( - argument_spec = dict( + argument_spec = ec2_argument_keys_spec() + argument_spec.update(dict( bucket = dict(required=True), object = dict(), src = dict(), @@ -258,11 +258,10 @@ def main(): mode = dict(choices=['get', 'put', 'delete', 'create', 'geturl', 'getstr'], required=True), expiry = dict(default=600, aliases=['expiration']), s3_url = dict(aliases=['S3_URL']), - ec2_secret_key = dict(aliases=['aws_secret_key', 'secret_key'], no_log=True), - ec2_access_key = dict(aliases=['aws_access_key', 'access_key']), overwrite = dict(aliases=['force'], default=True, type='bool'), - ), + ) ) + module = AnsibleModule(argument_spec=argument_spec) bucket = module.params.get('bucket') obj = module.params.get('object')