Source code for smia.behaviours.acl_handling_behaviour

import json
import logging

from spade.behaviour import CyclicBehaviour

from smia.behaviours.specific_handle_behaviours.handle_capability_behaviour import HandleCapabilityBehaviour
from smia.behaviours.specific_handle_behaviours.handle_svc_request_behaviour import HandleSvcRequestBehaviour
from smia.behaviours.specific_handle_behaviours.handle_svc_response_behaviour import HandleSvcResponseBehaviour
from smia.logic import inter_aas_interactions_utils
from smia.utilities.fipa_acl_info import FIPAACLInfo
from smia.utilities.general_utils import GeneralUtils

_logger = logging.getLogger(__name__)




class ACLHandlingBehaviour(CyclicBehaviour):
    """
    This class implements the behaviour that handles all the ACL messages that the SMIA will receive from the
    others standardized SMIAs in the I4.0 System.
    """

    def __init__(self, agent_object):
        """
        The constructor method is rewritten to add the object of the agent
        Args:
            agent_object (spade.Agent): the SPADE agent object of the SMIA agent.
        """

        # The constructor of the inherited class is executed.
        super().__init__()

        # The SPADE agent object is stored as a variable of the behaviour class
        self.myagent = agent_object



    async def on_start(self):
        """
        This method implements the initialization process of this behaviour.
        """
        _logger.info("ACLHandlingBehaviour starting...")




    async def run(self):
        """
        This method implements the logic of the behaviour.
        """

        # Wait for a message with the standard ACL template to arrive.
        msg = await self.receive(
            timeout=10)  # Timeout set to 10 seconds so as not to continuously execute the behavior.
        if msg:
            # An ACL message has been received by the agent
            _logger.aclinfo("         + Message received on SMIA (ACLHandlingBehaviour) from {}".format(msg.sender))
            _logger.aclinfo("                 |___ Message received with content: {}".format(msg.body))

            # The msg body will be parsed to a JSON object
            msg_json_body = json.loads(msg.body)

            # Depending on the performative of the message, the agent will have to perform some actions or others
            match msg.get_metadata('performative'):
                case FIPAACLInfo.FIPA_ACL_PERFORMATIVE_REQUEST:
                    _logger.aclinfo("The performative of the message is Request, so the DT needs to perform some"
                                    " action.")

                    # TODO pensar si generar un behaviour para recibir peticiones de servicios y otro para peticiones
                    #  de capacidades (en ese caso solo hay que comprobar la ontologia, no la performativa, ya que esta
                    #  se analiza en los behaviours de gestion individuales)
                    if ((msg.get_metadata('ontology') == FIPAACLInfo.FIPA_ACL_ONTOLOGY_CAPABILITY_REQUEST) or
                            (msg.get_metadata('ontology') == FIPAACLInfo.FIPA_ACL_ONTOLOGY_CAPABILITY_CHECKING)):
                        _logger.aclinfo("The agent has received a request related to Capability-Skill model")
                        # The behaviour to handle this specific capability will be added to the agent
                        svc_req_data = inter_aas_interactions_utils.create_svc_json_data_from_acl_msg(msg)
                        capability_handling_behav = HandleCapabilityBehaviour(self.agent, svc_req_data)
                        self.myagent.add_behaviour(capability_handling_behav)

                    elif msg.get_metadata('ontology') == FIPAACLInfo.FIPA_ACL_ONTOLOGY_SVC_REQUEST:
                        _logger.aclinfo("The agent has received a request to perform a service")
                        # The behaviour to handle this specific capability will be added to the agent
                        svc_req_data = inter_aas_interactions_utils.create_svc_json_data_from_acl_msg(msg)
                        svc_req_handling_behav = HandleSvcRequestBehaviour(self.agent, svc_req_data)
                        self.myagent.add_behaviour(svc_req_handling_behav)
                    else:
                        # TODO Parte del enfoque antiguo
                        service_category = msg_json_body['serviceData']['serviceCategory']
                        if service_category == 'service-response':
                            # TODO PENSAR COMO RECOGER LAS RESPUESTAS DE PETICIONES ANTERIORES. NO VENDRIAN CON
                            #  PERFORMATIVE 'Request', sai que aqui no se deberian tratar (recoger con Performative
                            #  'Inform', 'Confirm', 'Agree', 'Refuse'... dentro de los behaviours para gestiones
                            #  individuales?)
                            _logger.aclinfo(
                                "The agent has received the response of a service with thread [" + msg.thread + "].")

                            # As it is a response to a previous request, a new HandleSvcResponseBehaviour to handle this service
                            # response will be added to the agent
                            svc_resp_data = inter_aas_interactions_utils.create_svc_json_data_from_acl_msg(msg)
                            svc_resp_handling_behav = HandleSvcResponseBehaviour(self.agent,
                                                                                 'Inter AAS interaction',
                                                                                 svc_resp_data)
                            self.myagent.add_behaviour(svc_resp_handling_behav)

                case FIPAACLInfo.FIPA_ACL_PERFORMATIVE_QUERY_IF:
                    _logger.aclinfo("The performative of the message is Query-If, so the DT has been asked about some "
                                    "aspect of it.")

                    # service_category = msg_json_body['serviceID']
                    # if service_category == 'capabilityChecking':
                    if msg.get_metadata('ontology') == FIPAACLInfo.FIPA_ACL_ONTOLOGY_CAPABILITY_CHECKING:
                        _logger.info("The DT has been asked to check if it has a given capability.")
                        svc_req_data = inter_aas_interactions_utils.create_svc_json_data_from_acl_msg(msg)
                        capability_handling_behav = HandleCapabilityBehaviour(self.agent, svc_req_data)
                        self.myagent.add_behaviour(capability_handling_behav)
                case _:
                    _logger.error("ACL performative type not available.")

        else:
            _logger.info("         - No message received within 10 seconds on SMIA (ACLHandlingBehaviour)")