Source code for states.StateBooting

import logging
from spade.behaviour import State

from behaviours.CheckCoreInitializationBehaviour import CheckCoreInitializationBehaviour
from behaviours.InitAASarchiveBehaviour import InitAASarchiveBehaviour
from behaviours.InitSubmodelsBehaviour import InitSubmodelsBehaviour
from logic import IntraAASInteractions_utils
from utilities import AAS_Archive_utils
from utilities.AASmanagerInfo import AASmanagerInfo

_logger = logging.getLogger(__name__)




class StateBooting(State):
    """
    This class contains the Boot state of the common AAS Manager.
    """



    async def run(self):
        """
        This method implements the boot state of the common AAS Manager. Here all the required initialization tasks
        are performed.
        """

        await self.booting_state_logic()
        self.set_next_state(AASmanagerInfo.RUNNING_STATE_NAME)




    async def booting_state_logic(self):
        """
        This method contains the logic of the boot state of the common AAS Manager. This method can be used by any
        inherited class.
        """
        _logger.info("## STATE 1: BOOTING ##  (Initial state)")

        # First, it is ensured that the attributes of the AAS Manager are initialized
        self.agent.initialize_aas_manager_attributes()

        # The AAS Archive is initialized. To do so, the associated behaviour is added to the agent
        init_aas_archive_behav = InitAASarchiveBehaviour(self.agent)
        self.agent.add_behaviour(init_aas_archive_behav)

        # The submodels also have to be initalized, so its behaviour is also added
        init_submodels_behav = InitSubmodelsBehaviour(self.agent)
        self.agent.add_behaviour(init_submodels_behav)

        # Wait until the behaviours have finished because the AAS Archive has to be initialized to pass to running state
        await init_aas_archive_behav.join()
        await init_submodels_behav.join()

        # If the initialization behaviour has completed, AAS Manager is in the InitializationReady status
        AAS_Archive_utils.change_status('InitializationReady')
        # Change of status must be notified to the AAS core
        result = await IntraAASInteractions_utils.send_interaction_msg_to_core(client_id='i4-0-smia-manager',
                                                                               msg_key='manager-status',
                                                                               msg_data={
                                                                                   'status': 'InitializationReady'})
        # TODO cuidado, en los envios de estado no se está añadiendo el interaction_id. Es necesario? Estas
        #  interacciones son como las demas? En realidad el key es solo de estado, no de peticion ni respuesta...

        if result != "OK":
            _logger.error("The AAS Manager-Core interaction is not working: " + str(result))
        else:
            _logger.info("The AAS Manager has notified the AAS Core that its initialization has been completed.")

        # Wait until the AAS Core has initialized
        _logger.info('AAS Manager is waiting until its AAS Core has initialized.')
        check_core_initialization_behav = CheckCoreInitializationBehaviour(self.agent)
        self.agent.add_behaviour(check_core_initialization_behav)
        await check_core_initialization_behav.join()
        _logger.info('AAS Core has initialized.')

        # Finished the Boot State the agent can move to the next state
        _logger.info(f"{self.agent.jid} agent has finished it Boot state.")