|
|
@ -9,7 +9,12 @@ import re
|
|
|
|
from ansible.module_utils.urls import open_url
|
|
|
|
from ansible.module_utils.urls import open_url
|
|
|
|
from ansible.module_utils.six.moves.urllib.error import URLError, HTTPError
|
|
|
|
from ansible.module_utils.six.moves.urllib.error import URLError, HTTPError
|
|
|
|
|
|
|
|
|
|
|
|
HEADERS = {'content-type': 'application/json'}
|
|
|
|
GET_HEADERS = {'accept': 'application/json', 'OData-Version': '4.0'}
|
|
|
|
|
|
|
|
POST_HEADERS = {'content-type': 'application/json', 'accept': 'application/json',
|
|
|
|
|
|
|
|
'OData-Version': '4.0'}
|
|
|
|
|
|
|
|
PATCH_HEADERS = {'content-type': 'application/json', 'accept': 'application/json',
|
|
|
|
|
|
|
|
'OData-Version': '4.0'}
|
|
|
|
|
|
|
|
DELETE_HEADERS = {'accept': 'application/json', 'OData-Version': '4.0'}
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
class RedfishUtils(object):
|
|
|
|
class RedfishUtils(object):
|
|
|
@ -23,7 +28,7 @@ class RedfishUtils(object):
|
|
|
|
# The following functions are to send GET/POST/PATCH/DELETE requests
|
|
|
|
# The following functions are to send GET/POST/PATCH/DELETE requests
|
|
|
|
def get_request(self, uri):
|
|
|
|
def get_request(self, uri):
|
|
|
|
try:
|
|
|
|
try:
|
|
|
|
resp = open_url(uri, method="GET",
|
|
|
|
resp = open_url(uri, method="GET", headers=GET_HEADERS,
|
|
|
|
url_username=self.creds['user'],
|
|
|
|
url_username=self.creds['user'],
|
|
|
|
url_password=self.creds['pswd'],
|
|
|
|
url_password=self.creds['pswd'],
|
|
|
|
force_basic_auth=True, validate_certs=False,
|
|
|
|
force_basic_auth=True, validate_certs=False,
|
|
|
@ -39,10 +44,10 @@ class RedfishUtils(object):
|
|
|
|
return {'ret': False, 'msg': "Unknown error"}
|
|
|
|
return {'ret': False, 'msg': "Unknown error"}
|
|
|
|
return {'ret': True, 'data': data}
|
|
|
|
return {'ret': True, 'data': data}
|
|
|
|
|
|
|
|
|
|
|
|
def post_request(self, uri, pyld, hdrs):
|
|
|
|
def post_request(self, uri, pyld):
|
|
|
|
try:
|
|
|
|
try:
|
|
|
|
resp = open_url(uri, data=json.dumps(pyld),
|
|
|
|
resp = open_url(uri, data=json.dumps(pyld),
|
|
|
|
headers=hdrs, method="POST",
|
|
|
|
headers=POST_HEADERS, method="POST",
|
|
|
|
url_username=self.creds['user'],
|
|
|
|
url_username=self.creds['user'],
|
|
|
|
url_password=self.creds['pswd'],
|
|
|
|
url_password=self.creds['pswd'],
|
|
|
|
force_basic_auth=True, validate_certs=False,
|
|
|
|
force_basic_auth=True, validate_certs=False,
|
|
|
@ -57,10 +62,10 @@ class RedfishUtils(object):
|
|
|
|
return {'ret': False, 'msg': "Unknown error"}
|
|
|
|
return {'ret': False, 'msg': "Unknown error"}
|
|
|
|
return {'ret': True, 'resp': resp}
|
|
|
|
return {'ret': True, 'resp': resp}
|
|
|
|
|
|
|
|
|
|
|
|
def patch_request(self, uri, pyld, hdrs):
|
|
|
|
def patch_request(self, uri, pyld):
|
|
|
|
try:
|
|
|
|
try:
|
|
|
|
resp = open_url(uri, data=json.dumps(pyld),
|
|
|
|
resp = open_url(uri, data=json.dumps(pyld),
|
|
|
|
headers=hdrs, method="PATCH",
|
|
|
|
headers=PATCH_HEADERS, method="PATCH",
|
|
|
|
url_username=self.creds['user'],
|
|
|
|
url_username=self.creds['user'],
|
|
|
|
url_password=self.creds['pswd'],
|
|
|
|
url_password=self.creds['pswd'],
|
|
|
|
force_basic_auth=True, validate_certs=False,
|
|
|
|
force_basic_auth=True, validate_certs=False,
|
|
|
@ -75,10 +80,10 @@ class RedfishUtils(object):
|
|
|
|
return {'ret': False, 'msg': "Unknown error"}
|
|
|
|
return {'ret': False, 'msg': "Unknown error"}
|
|
|
|
return {'ret': True, 'resp': resp}
|
|
|
|
return {'ret': True, 'resp': resp}
|
|
|
|
|
|
|
|
|
|
|
|
def delete_request(self, uri, pyld, hdrs):
|
|
|
|
def delete_request(self, uri, pyld):
|
|
|
|
try:
|
|
|
|
try:
|
|
|
|
resp = open_url(uri, data=json.dumps(pyld),
|
|
|
|
resp = open_url(uri, data=json.dumps(pyld),
|
|
|
|
headers=hdrs, method="DELETE",
|
|
|
|
headers=DELETE_HEADERS, method="DELETE",
|
|
|
|
url_username=self.creds['user'],
|
|
|
|
url_username=self.creds['user'],
|
|
|
|
url_password=self.creds['pswd'],
|
|
|
|
url_password=self.creds['pswd'],
|
|
|
|
force_basic_auth=True, validate_certs=False,
|
|
|
|
force_basic_auth=True, validate_certs=False,
|
|
|
@ -265,7 +270,7 @@ class RedfishUtils(object):
|
|
|
|
# Check to make sure option is available, otherwise error is ugly
|
|
|
|
# Check to make sure option is available, otherwise error is ugly
|
|
|
|
if "Actions" in _data:
|
|
|
|
if "Actions" in _data:
|
|
|
|
if "#LogService.ClearLog" in _data[u"Actions"]:
|
|
|
|
if "#LogService.ClearLog" in _data[u"Actions"]:
|
|
|
|
self.post_request(self.root_uri + _data[u"Actions"]["#LogService.ClearLog"]["target"], {}, HEADERS)
|
|
|
|
self.post_request(self.root_uri + _data[u"Actions"]["#LogService.ClearLog"]["target"], {})
|
|
|
|
if response['ret'] is False:
|
|
|
|
if response['ret'] is False:
|
|
|
|
return response
|
|
|
|
return response
|
|
|
|
return {'ret': True}
|
|
|
|
return {'ret': True}
|
|
|
@ -368,7 +373,7 @@ class RedfishUtils(object):
|
|
|
|
action_uri = data[key]["#Manager.Reset"]["target"]
|
|
|
|
action_uri = data[key]["#Manager.Reset"]["target"]
|
|
|
|
|
|
|
|
|
|
|
|
payload = {'ResetType': 'GracefulRestart'}
|
|
|
|
payload = {'ResetType': 'GracefulRestart'}
|
|
|
|
response = self.post_request(self.root_uri + action_uri, payload, HEADERS)
|
|
|
|
response = self.post_request(self.root_uri + action_uri, payload)
|
|
|
|
if response['ret'] is False:
|
|
|
|
if response['ret'] is False:
|
|
|
|
return response
|
|
|
|
return response
|
|
|
|
return {'ret': True}
|
|
|
|
return {'ret': True}
|
|
|
@ -397,7 +402,7 @@ class RedfishUtils(object):
|
|
|
|
else:
|
|
|
|
else:
|
|
|
|
return {'ret': False, 'msg': 'Invalid Command'}
|
|
|
|
return {'ret': False, 'msg': 'Invalid Command'}
|
|
|
|
|
|
|
|
|
|
|
|
response = self.post_request(self.root_uri + action_uri, payload, HEADERS)
|
|
|
|
response = self.post_request(self.root_uri + action_uri, payload)
|
|
|
|
if response['ret'] is False:
|
|
|
|
if response['ret'] is False:
|
|
|
|
return response
|
|
|
|
return response
|
|
|
|
result['ret'] = True
|
|
|
|
result['ret'] = True
|
|
|
@ -443,7 +448,7 @@ class RedfishUtils(object):
|
|
|
|
roleid = {'RoleId': user['userrole']}
|
|
|
|
roleid = {'RoleId': user['userrole']}
|
|
|
|
enabled = {'Enabled': True}
|
|
|
|
enabled = {'Enabled': True}
|
|
|
|
for payload in username, pswd, roleid, enabled:
|
|
|
|
for payload in username, pswd, roleid, enabled:
|
|
|
|
response = self.patch_request(uri, payload, HEADERS)
|
|
|
|
response = self.patch_request(uri, payload)
|
|
|
|
if response['ret'] is False:
|
|
|
|
if response['ret'] is False:
|
|
|
|
return response
|
|
|
|
return response
|
|
|
|
return {'ret': True}
|
|
|
|
return {'ret': True}
|
|
|
@ -451,7 +456,7 @@ class RedfishUtils(object):
|
|
|
|
def enable_user(self, user):
|
|
|
|
def enable_user(self, user):
|
|
|
|
uri = self.root_uri + self.accounts_uri + "/" + user['userid']
|
|
|
|
uri = self.root_uri + self.accounts_uri + "/" + user['userid']
|
|
|
|
payload = {'Enabled': True}
|
|
|
|
payload = {'Enabled': True}
|
|
|
|
response = self.patch_request(uri, payload, HEADERS)
|
|
|
|
response = self.patch_request(uri, payload)
|
|
|
|
if response['ret'] is False:
|
|
|
|
if response['ret'] is False:
|
|
|
|
return response
|
|
|
|
return response
|
|
|
|
return {'ret': True}
|
|
|
|
return {'ret': True}
|
|
|
@ -459,7 +464,7 @@ class RedfishUtils(object):
|
|
|
|
def delete_user(self, user):
|
|
|
|
def delete_user(self, user):
|
|
|
|
uri = self.root_uri + self.accounts_uri + "/" + user['userid']
|
|
|
|
uri = self.root_uri + self.accounts_uri + "/" + user['userid']
|
|
|
|
payload = {'UserName': ""}
|
|
|
|
payload = {'UserName': ""}
|
|
|
|
response = self.patch_request(uri, payload, HEADERS)
|
|
|
|
response = self.patch_request(uri, payload)
|
|
|
|
if response['ret'] is False:
|
|
|
|
if response['ret'] is False:
|
|
|
|
return response
|
|
|
|
return response
|
|
|
|
return {'ret': True}
|
|
|
|
return {'ret': True}
|
|
|
@ -467,7 +472,7 @@ class RedfishUtils(object):
|
|
|
|
def disable_user(self, user):
|
|
|
|
def disable_user(self, user):
|
|
|
|
uri = self.root_uri + self.accounts_uri + "/" + user['userid']
|
|
|
|
uri = self.root_uri + self.accounts_uri + "/" + user['userid']
|
|
|
|
payload = {'Enabled': False}
|
|
|
|
payload = {'Enabled': False}
|
|
|
|
response = self.patch_request(uri, payload, HEADERS)
|
|
|
|
response = self.patch_request(uri, payload)
|
|
|
|
if response['ret'] is False:
|
|
|
|
if response['ret'] is False:
|
|
|
|
return response
|
|
|
|
return response
|
|
|
|
return {'ret': True}
|
|
|
|
return {'ret': True}
|
|
|
@ -475,7 +480,7 @@ class RedfishUtils(object):
|
|
|
|
def update_user_role(self, user):
|
|
|
|
def update_user_role(self, user):
|
|
|
|
uri = self.root_uri + self.accounts_uri + "/" + user['userid']
|
|
|
|
uri = self.root_uri + self.accounts_uri + "/" + user['userid']
|
|
|
|
payload = {'RoleId': user['userrole']}
|
|
|
|
payload = {'RoleId': user['userrole']}
|
|
|
|
response = self.patch_request(uri, payload, HEADERS)
|
|
|
|
response = self.patch_request(uri, payload)
|
|
|
|
if response['ret'] is False:
|
|
|
|
if response['ret'] is False:
|
|
|
|
return response
|
|
|
|
return response
|
|
|
|
return {'ret': True}
|
|
|
|
return {'ret': True}
|
|
|
@ -483,7 +488,7 @@ class RedfishUtils(object):
|
|
|
|
def update_user_password(self, user):
|
|
|
|
def update_user_password(self, user):
|
|
|
|
uri = self.root_uri + self.accounts_uri + "/" + user['userid']
|
|
|
|
uri = self.root_uri + self.accounts_uri + "/" + user['userid']
|
|
|
|
payload = {'Password': user['userpswd']}
|
|
|
|
payload = {'Password': user['userpswd']}
|
|
|
|
response = self.patch_request(uri, payload, HEADERS)
|
|
|
|
response = self.patch_request(uri, payload)
|
|
|
|
if response['ret'] is False:
|
|
|
|
if response['ret'] is False:
|
|
|
|
return response
|
|
|
|
return response
|
|
|
|
return {'ret': True}
|
|
|
|
return {'ret': True}
|
|
|
@ -656,7 +661,7 @@ class RedfishUtils(object):
|
|
|
|
data = response['data']
|
|
|
|
data = response['data']
|
|
|
|
reset_bios_settings_uri = data["Actions"]["#Bios.ResetBios"]["target"]
|
|
|
|
reset_bios_settings_uri = data["Actions"]["#Bios.ResetBios"]["target"]
|
|
|
|
|
|
|
|
|
|
|
|
response = self.post_request(self.root_uri + reset_bios_settings_uri, {}, HEADERS)
|
|
|
|
response = self.post_request(self.root_uri + reset_bios_settings_uri, {})
|
|
|
|
if response['ret'] is False:
|
|
|
|
if response['ret'] is False:
|
|
|
|
return response
|
|
|
|
return response
|
|
|
|
return {'ret': True}
|
|
|
|
return {'ret': True}
|
|
|
@ -688,7 +693,7 @@ class RedfishUtils(object):
|
|
|
|
else:
|
|
|
|
else:
|
|
|
|
payload = {"Boot": {"BootSourceOverrideTarget": bootdevice}}
|
|
|
|
payload = {"Boot": {"BootSourceOverrideTarget": bootdevice}}
|
|
|
|
|
|
|
|
|
|
|
|
response = self.patch_request(self.root_uri + self.systems_uri, payload, HEADERS)
|
|
|
|
response = self.patch_request(self.root_uri + self.systems_uri, payload)
|
|
|
|
if response['ret'] is False:
|
|
|
|
if response['ret'] is False:
|
|
|
|
return response
|
|
|
|
return response
|
|
|
|
return {'ret': True}
|
|
|
|
return {'ret': True}
|
|
|
@ -704,7 +709,7 @@ class RedfishUtils(object):
|
|
|
|
manager_attr = "{\"%s\": \"%s\"}" % (attr['mgr_attr_name'], attr['mgr_attr_value'])
|
|
|
|
manager_attr = "{\"%s\": \"%s\"}" % (attr['mgr_attr_name'], attr['mgr_attr_value'])
|
|
|
|
|
|
|
|
|
|
|
|
payload = {"Attributes": json.loads(manager_attr)}
|
|
|
|
payload = {"Attributes": json.loads(manager_attr)}
|
|
|
|
response = self.patch_request(self.root_uri + self.manager_uri + "/" + attributes, payload, HEADERS)
|
|
|
|
response = self.patch_request(self.root_uri + self.manager_uri + "/" + attributes, payload)
|
|
|
|
if response['ret'] is False:
|
|
|
|
if response['ret'] is False:
|
|
|
|
if '404' in response.get('msg'):
|
|
|
|
if '404' in response.get('msg'):
|
|
|
|
response['msg'] = 'The SetManagerAttributes command is not supported on this Redfish service'
|
|
|
|
response['msg'] = 'The SetManagerAttributes command is not supported on this Redfish service'
|
|
|
@ -747,7 +752,7 @@ class RedfishUtils(object):
|
|
|
|
# Example: bios_attr = {\"name\":\"value\"}
|
|
|
|
# Example: bios_attr = {\"name\":\"value\"}
|
|
|
|
bios_attr = "{\"" + attr['bios_attr_name'] + "\":\"" + attr['bios_attr_value'] + "\"}"
|
|
|
|
bios_attr = "{\"" + attr['bios_attr_name'] + "\":\"" + attr['bios_attr_value'] + "\"}"
|
|
|
|
payload = {"Attributes": json.loads(bios_attr)}
|
|
|
|
payload = {"Attributes": json.loads(bios_attr)}
|
|
|
|
response = self.patch_request(self.root_uri + set_bios_attr_uri, payload, HEADERS)
|
|
|
|
response = self.patch_request(self.root_uri + set_bios_attr_uri, payload)
|
|
|
|
if response['ret'] is False:
|
|
|
|
if response['ret'] is False:
|
|
|
|
return response
|
|
|
|
return response
|
|
|
|
return {'ret': True, 'changed': True, 'msg': "Modified BIOS attribute"}
|
|
|
|
return {'ret': True, 'changed': True, 'msg': "Modified BIOS attribute"}
|
|
|
@ -778,7 +783,7 @@ class RedfishUtils(object):
|
|
|
|
set_bios_attr_uri = data["@Redfish.Settings"]["SettingsObject"]["@odata.id"]
|
|
|
|
set_bios_attr_uri = data["@Redfish.Settings"]["SettingsObject"]["@odata.id"]
|
|
|
|
|
|
|
|
|
|
|
|
payload = {"TargetSettingsURI": set_bios_attr_uri}
|
|
|
|
payload = {"TargetSettingsURI": set_bios_attr_uri}
|
|
|
|
response = self.post_request(self.root_uri + self.manager_uri + "/" + jobs, payload, HEADERS)
|
|
|
|
response = self.post_request(self.root_uri + self.manager_uri + "/" + jobs, payload)
|
|
|
|
if response['ret'] is False:
|
|
|
|
if response['ret'] is False:
|
|
|
|
return response
|
|
|
|
return response
|
|
|
|
|
|
|
|
|
|
|
|