diff options
author | Peter Sprygada <privateip@users.noreply.github.com> | 2016-09-07 21:41:51 -0400 |
---|---|---|
committer | GitHub <noreply@github.com> | 2016-09-07 21:41:51 -0400 |
commit | d64eaae2320eecdf69a2f5f4dfdcffd3625a058f (patch) | |
tree | 0413a7e1df281c3c1cd7ff050287db8da95759cc | |
parent | ba28f1a2dab6e9f067c360c151e6bb0c37d94f8e (diff) | |
parent | b6c30e7985308b3daa0c0b9785bf43a1fcb47f2b (diff) | |
download | ansible-d64eaae2320eecdf69a2f5f4dfdcffd3625a058f.tar.gz |
Merge pull request #16553 from ericchou1/devel
Added axapi_authenticate_v3 and axapi_call_v3 for AXAPIv3
-rw-r--r-- | lib/ansible/module_utils/a10.py | 37 |
1 files changed, 37 insertions, 0 deletions
diff --git a/lib/ansible/module_utils/a10.py b/lib/ansible/module_utils/a10.py index 45fda0eb39..737919b463 100644 --- a/lib/ansible/module_utils/a10.py +++ b/lib/ansible/module_utils/a10.py @@ -88,6 +88,43 @@ def axapi_authenticate(module, base_url, username, password): sessid = result['session_id'] return base_url + '&session_id=' + sessid +def axapi_authenticate_v3(module, base_url, username, password): + url = base_url + auth_payload = {"credentials": {"username": username, "password": password}} + result = axapi_call_v3(module, url, post=auth_payload) + if axapi_failure(result): + return module.fail_json(msg=result['response']['err']['msg']) + signature = result['authresponse']['signature'] + return signature + +def axapi_call_v3(module, url, method=None, body=None, signature=None): + ''' + Returns a datastructure based on the result of the API call + ''' + if signature: + headers = {'content-type': 'application/json', 'Authorization': 'A10 %s' % signature} + else: + headers = {'content-type': 'application/json'} + rsp, info = fetch_url(module, url, method=method, data=json.dumps(body), headers=headers) + if not rsp or info['status'] >= 400: + module.fail_json(msg="failed to connect (status code %s), error was %s" % (info['status'], info.get('msg', 'no error given'))) + try: + raw_data = rsp.read() + data = json.loads(raw_data) + except ValueError: + # at least one API call (system.action.write_config) returns + # XML even when JSON is requested, so do some minimal handling + # here to prevent failing even when the call succeeded + if 'status="ok"' in raw_data.lower(): + data = {"response": {"status": "OK"}} + else: + data = {"response": {"status": "fail", "err": {"msg": raw_data}}} + except: + module.fail_json(msg="could not read the result from the host") + finally: + rsp.close() + return data + def axapi_enabled_disabled(flag): ''' The axapi uses 0/1 integer values for flags, rather than strings |