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

Fix credentials for Tower API V2

Browse source
This commit is contained in:
Thierry Bouvet 2018-01-15 16:39:11 +01:00 committed by Sam Doran
parent 53cfd70b7d
commit 640749d54f
1 changed files with 44 additions and 4 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

48
lib/ansible/modules/web_infrastructure/ansible_tower/tower_credential.py
View file

@ -165,6 +165,11 @@ except ImportError:
pass pass
def _add_input_(module, param, results):
if module.params.get(param):
results[param] = module.params.get(param)
def main(): def main():
argument_spec = tower_argument_spec() argument_spec = tower_argument_spec()
@ -213,22 +218,57 @@ def main():
tower_check_mode(module) tower_check_mode(module)
credential = tower_cli.get_resource('credential') credential = tower_cli.get_resource('credential')
try: try:
params = module.params.copy() params = {}
params['create_on_missing'] = True params['create_on_missing'] = True
params['name'] = name
if organization: if organization:
org_res = tower_cli.get_resource('organization') org_res = tower_cli.get_resource('organization')
org = org_res.get(name=organization) org = org_res.get(name=organization)
params['organization'] = org['id'] params['organization'] = org['id']
if params['ssh_key_data']: credential_type_res = tower_cli.get_resource('credential_type')
filename = params['ssh_key_data'] credential_type = credential_type_res.get(kind=module.params.get('kind'))
params['credential_type'] = credential_type['id']
if module.params.get('description'):
params['description'] = module.params.get('description')
if module.params.get('user'):
user_res = tower_cli.get_resource('user')
user = user_res.get(name=module.params.get('user'))
params['user'] = user['id']
if module.params.get('team'):
team_res = tower_cli.get_resource('team')
team = team_res.get(name=module.params.get('team'))
params['team'] = team['id']
params['inputs'] = {}
if module.params.get('ssh_key_data'):
filename = module.params.get('ssh_key_data')
if not os.path.exists(filename): if not os.path.exists(filename):
module.fail_json(msg='file not found: %s' % filename) module.fail_json(msg='file not found: %s' % filename)
if os.path.isdir(filename): if os.path.isdir(filename):
module.fail_json(msg='attempted to read contents of directory: %s' % filename) module.fail_json(msg='attempted to read contents of directory: %s' % filename)
with open(filename, 'rb') as f: with open(filename, 'rb') as f:
params['ssh_key_data'] = f.read() params['inputs']['ssh_key_data'] = f.read()
_add_input_(module, 'authorize', params['inputs'])
_add_input_(module, 'authorize_password', params['inputs'])
_add_input_(module, 'client', params['inputs'])
_add_input_(module, 'secret', params['inputs'])
_add_input_(module, 'tenant', params['inputs'])
_add_input_(module, 'subscription', params['inputs'])
_add_input_(module, 'domain', params['inputs'])
_add_input_(module, 'become_method', params['inputs'])
_add_input_(module, 'become_username', params['inputs'])
_add_input_(module, 'become_password', params['inputs'])
_add_input_(module, 'vault_password', params['inputs'])
_add_input_(module, 'project', params['inputs'])
_add_input_(module, 'host', params['inputs'])
_add_input_(module, 'username', params['inputs'])
_add_input_(module, 'password', params['inputs'])
if state == 'present': if state == 'present':
result = credential.modify(**params) result = credential.modify(**params)