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 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, the interactionId is reset
        self.agent.interaction_id = 0

        # Then 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')

        # Wait until the 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()

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