ansible/community.general
1
0
Fork 0
mirror of https://github.com/ansible-collections/community.general.git synced 2024-09-14 20:13:21 +02:00
Code Releases Activity

update to capture peer status

Browse source
This commit is contained in:
Mike Mochan 2016-01-09 20:03:30 +10:00 committed by Matt Clay
parent 985e485706
commit deaf40d942
1 changed files with 22 additions and 14 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

36
lib/ansible/modules/extras/cloud/amazon/ec2_vpc_peer.py
View file

@ -200,12 +200,19 @@ def create_peer_connection(client, module):
return (changed, peering_conn['VpcPeeringConnectionId']) return (changed, peering_conn['VpcPeeringConnectionId'])
if is_pending(peering_conn): if is_pending(peering_conn):
return (changed, peering_conn['VpcPeeringConnectionId']) return (changed, peering_conn['VpcPeeringConnectionId'])
try: try:
peering_conn = client.create_vpc_peering_connection(**params) peering_conn = client.create_vpc_peering_connection(**params)
changed = True changed = True
return (changed, peering_conn['VpcPeeringConnection']['VpcPeeringConnectionId']) return (changed, peering_conn['VpcPeeringConnection']['VpcPeeringConnectionId'])
except botocore.exceptions.ClientError as e: except botocore.exceptions.ClientError as e:
module.fail_json(msg=str(e)) module.fail_json(msg=str(e))
def peer_status(client, module):
params = dict()
params['VpcPeeringConnectionIds'] = [module.params.get('peering_id')]
vpc_peering_connection = client.describe_vpc_peering_connections(**params)
return vpc_peering_connection['VpcPeeringConnections'][0]['Status']['Code']
def accept_reject_delete(state, client, module): def accept_reject_delete(state, client, module):
@ -218,12 +225,13 @@ def accept_reject_delete(state, client, module):
'reject': client.reject_vpc_peering_connection, 'reject': client.reject_vpc_peering_connection,
'absent': client.delete_vpc_peering_connection 'absent': client.delete_vpc_peering_connection
} }
try: if state == 'absent' or peer_status(client, module) != 'active':
invocations[state](**params) try:
changed = True invocations[state](**params)
except botocore.exceptions.ClientError as e: changed = True
module.fail_json(msg=str(e)) except botocore.exceptions.ClientError as e:
module.fail_json(msg=str(e))
return changed, params['VpcPeeringConnectionId'] return changed, params['VpcPeeringConnectionId']
@ -241,11 +249,11 @@ def main():
module = AnsibleModule(argument_spec=argument_spec) module = AnsibleModule(argument_spec=argument_spec)
if not HAS_BOTO3: if not HAS_BOTO3:
module.fail_json(msg='json and boto/boto3 is required.') module.fail_json(msg='json and boto3 is required.')
state = module.params.get('state').lower() state = module.params.get('state').lower()
try: try:
region, ec2_url, aws_connect_kwargs = get_aws_connection_info(module, boto3=True) region, ec2_url, aws_connect_kwargs = get_aws_connection_info(module, boto3=True)
client = boto3_conn(module, conn_type='client', resource='ec2', region=region, endpoint=ec2_url, **aws_connect_kwargs) client = boto3_conn(module, conn_type='client', resource='ec2', region=region, endpoint=ec2_url, **aws_connect_kwargs)
except botocore.exceptions.NoCredentialsError, e: except botocore.exceptions.NoCredentialsError, e:
module.fail_json(msg="Can't authorize connection - "+str(e)) module.fail_json(msg="Can't authorize connection - "+str(e))