ansible-collections/community.general
1
0
Fork 0
mirror of https://github.com/ansible-collections/community.general.git synced 2025-04-23 19:01:26 -07:00
Code Issues Projects Releases Packages Wiki Activity Actions 11

modified POST body in axapi_authenticate_v3() and axapi_call_v3() (#18104)

Browse source
This commit is contained in:
Eric Chou 2016-11-23 08:10:58 -08:00 • committed by Nathaniel Case
parent 03dd186c63
commit 9d0b8c8545
1 changed files with 3 additions and 2 deletions
Download patch file Download diff file Expand all files Collapse all files

5
lib/ansible/module_utils/a10.py
View file

@ -30,6 +30,7 @@ import json
from ansible.module_utils.urls import fetch_url from ansible.module_utils.urls import fetch_url
AXAPI_PORT_PROTOCOLS = { AXAPI_PORT_PROTOCOLS = {
'tcp': 2, 'tcp': 2,
'udp': 3, 'udp': 3,
@ -91,7 +92,7 @@ def axapi_authenticate(module, base_url, username, password):
def axapi_authenticate_v3(module, base_url, username, password): def axapi_authenticate_v3(module, base_url, username, password):
url = base_url url = base_url
auth_payload = {"credentials": {"username": username, "password": password}} auth_payload = {"credentials": {"username": username, "password": password}}
result = axapi_call_v3(module, url, method='POST', body=auth_payload) result = axapi_call_v3(module, url, method='POST', body=json.dumps(auth_payload))
if axapi_failure(result): if axapi_failure(result):
return module.fail_json(msg=result['response']['err']['msg']) return module.fail_json(msg=result['response']['err']['msg'])
signature = result['authresponse']['signature'] signature = result['authresponse']['signature']
@ -105,7 +106,7 @@ def axapi_call_v3(module, url, method=None, body=None, signature=None):
headers = {'content-type': 'application/json', 'Authorization': 'A10 %s' % signature} headers = {'content-type': 'application/json', 'Authorization': 'A10 %s' % signature}
else: else:
headers = {'content-type': 'application/json'} headers = {'content-type': 'application/json'}
rsp, info = fetch_url(module, url, method=method, data=json.dumps(body), headers=headers) rsp, info = fetch_url(module, url, method=method, data=body, headers=headers)
if not rsp or info['status'] >= 400: 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'))) module.fail_json(msg="failed to connect (status code %s), error was %s" % (info['status'], info.get('msg', 'no error given')))
try: try: