"""This class groups the methods related to the interactions between the Manager and the Core."""
import calendar
import logging
from datetime import datetime
import time
from utilities.AASarchiveInfo import AASarchiveInfo
from utilities.AAS_Archive_utils import file_to_json, update_json_file
_logger = logging.getLogger(__name__)
# --------------------------------------------
# Methods related to requests (by AAS Manager)
# --------------------------------------------
[docs]
def create_svc_request_json(interaction_id, svc_id, svc_type, svc_data = None):
"""
This method creates a service request JSON object.
Args:
interaction_id (int): Identifier of the interaction.
svc_id (str): Identifier of the service
svc_type (str): Type of the service.
svc_data (dict, optional): Data of the service in JSON format.
Returns:
dict: a JSON object with the service request information.
"""
svc_request_json = {"interactionID": interaction_id,
"serviceID": svc_id,
"serviceType": svc_type
}
if svc_data is not None:
svc_request_json['serviceData'] = svc_data
svc_request_json['serviceData']['timestamp'] = calendar.timegm(time.gmtime())
return svc_request_json
[docs]
def add_new_svc_request(new_request_json):
"""
This method adds a new service request to the related service interaction file of the manager and updates it
in the AAS Archive.
Args:
new_request_json: The service requests content in JSON format.
"""
# Get the content of the service requests interaction file
svc_requests_file_path = AASarchiveInfo.MANAGER_INTERACTIONS_FOLDER_PATH + AASarchiveInfo.SVC_REQUEST_FILE_SUBPATH
svc_requests_json = file_to_json(svc_requests_file_path)
if svc_requests_json is None:
svc_requests_json = {'serviceRequests': [new_request_json]}
else:
svc_requests_json['serviceRequests'].append(new_request_json)
update_json_file(svc_requests_file_path, svc_requests_json)
[docs]
def get_svc_request_info(interaction_id):
"""
This method gets the information of a service request.
Args:
interaction_id (int): Identifier of the interaction.
Returns:
dict: the information of the service request in JSON format.
"""
svc_requests_json = file_to_json(AASarchiveInfo.MANAGER_INTERACTIONS_FOLDER_PATH +
AASarchiveInfo.SVC_REQUEST_FILE_SUBPATH)
for i in svc_requests_json['serviceRequests']:
if i['interactionID'] == interaction_id:
return i
return None
# --------------------------------------------
# Methods related to responses (from AAS Core)
# --------------------------------------------
[docs]
def get_svc_response_info(interaction_id):
"""
This method gets the information of a response from the AAS Core related to a request made by the AAS Manager.
Args:
interaction_id (int): Identifier of the interaction.
Returns:
dict: the information of the service request in JSON format.
"""
svc_responses_json = file_to_json(
AASarchiveInfo.CORE_INTERACTIONS_FOLDER_PATH + AASarchiveInfo.SVC_RESPONSE_FILE_SUBPATH)
for i in svc_responses_json['serviceResponses']:
if i['interactionID'] == interaction_id:
return i
return None
# ----------------------------
# Methods related to responses
# ----------------------------
[docs]
def save_svc_info_in_log_file(requested_entity, svc_type_log_file_name, interaction_id):
"""
This method saves the information of a service request in the associated log file.
Args:
requested_entity (str): The entity that has requested the service, to know in which interaction files to search.
svc_type_log_file_name (str): The log file name of the service type.
interaction_id (int): Identifier of the interaction.
"""
# Get the information about the request and response
svc_request_info, svc_response_info = get_svc_info(requested_entity, interaction_id)
# Create the JSON structure
log_structure = {
'level': 'INFO',
'interactionID': interaction_id,
'serviceStatus': svc_response_info['serviceStatus'],
'serviceInfo': {
'serviceID': svc_request_info['serviceID'],
'serviceType': svc_request_info['serviceType'],
'requestTimestamp': str(datetime.fromtimestamp(svc_request_info['serviceData']['timestamp'])),
'responseTimestamp': str(datetime.fromtimestamp(svc_response_info['serviceData']['timestamp']))
}
}
# If some data has been requested, added to the structura
requested_data = svc_request_info['serviceData']['requestedData']
if requested_data is not None:
svc_data_json = {'requestedData': requested_data, 'dataValue': svc_response_info['serviceData'][requested_data]}
log_structure['serviceInfo']['serviceData'] = svc_data_json
# Get the content of LOG file
log_file_json = file_to_json(AASarchiveInfo.SVC_LOG_FOLDER_PATH + '/' + svc_type_log_file_name)
# Add the structure in the file
log_file_json.append(log_structure)
update_json_file(file_path=AASarchiveInfo.SVC_LOG_FOLDER_PATH + '/' + svc_type_log_file_name, content=log_file_json)
_logger.info("Service information related to interaction " + str(interaction_id) + " added in log file.")
# -------------
# Other methods
# -------------
[docs]
def get_svc_info(requested_entity, interaction_id):
"""
This method obtains the information of the service considering the entity that has requested the service. In the
entity is Manager it has to search in Manager requests and Core responses, and in the case of being the Core the
one that has made the request, the opposite.
Args:
requested_entity (str): The entity that has requested the service, to know in which interaction files to search.
interaction_id (int): Identifier of the interaction.
Returns:
dict: Information of the service request in JSON format
dict: Information of the service response in JSON format.
"""
if requested_entity == "Manager":
return get_svc_request_info(interaction_id), get_svc_response_info(interaction_id)
elif requested_entity == "Core":
# In this case, it has to search in the opposite files (request of Core and response of Manager)
svc_requests_json = file_to_json(AASarchiveInfo.MANAGER_INTERACTIONS_FOLDER_PATH +
AASarchiveInfo.SVC_REQUEST_FILE_SUBPATH)
svc_request_info = None
for i in svc_requests_json['serviceRequests']:
if i['interactionID'] == interaction_id:
svc_request_info = i
break
svc_responses_json = file_to_json(AASarchiveInfo.CORE_INTERACTIONS_FOLDER_PATH +
AASarchiveInfo.SVC_RESPONSE_FILE_SUBPATH)
svc_response_info = None
for i in svc_responses_json['serviceResponses']:
if i['interactionID'] == interaction_id:
svc_response_info = i
break
return svc_request_info, svc_response_info