dash_client.py

# -*- coding: utf-8 -*-
"""
@author: Marcos F. Caetano (mfcaetano@unb.br) 11/03/2020

@description: PyDash Project

Dash client representation. It knows all entities in our
layer model (Player, R2A and Connection_Handler).
There isn't a strong relation among the entities
(they don't know each other). The Dash_client is
responsible to make the communication among them happens.
"""

import importlib

from base.configuration_parser import ConfigurationParser
from base.scheduler import Scheduler
from connection.connection_handler import ConnectionHandler
from player.player import Player


class DashClient:

    def __init__(self):
        config_parser = ConfigurationParser.get_instance()

        r2a_algorithm = str(config_parser.get_parameter('r2a_algorithm'))

        self.scheduler = Scheduler()

        self.modules = []

        # adding modules to manage
        self.player = Player(0)

        # automatic loading class by the name
        r2a_class = getattr(importlib.import_module('r2a.' + r2a_algorithm.lower()), r2a_algorithm)
        self.r2a = r2a_class(1)

        self.connection_handler = ConnectionHandler(2)

        self.modules.append(self.player)
        self.modules.append(self.r2a)
        self.modules.append(self.connection_handler)


    def run_application(self):
        self.modules_initialization()

        while not self.scheduler.is_empty():
            event = self.scheduler.get_event()
            self.handle_scheduler_event(event)

        self.modules_finalization()


    def handle_scheduler_event(self, event):

        #checking if the event is inside of the modules position range limits
        if event.get_dst() < 0 or event.get_dst() >= len(self.modules):
            print(f'It is no possible to route a {event.get_msg()} message from {event.get_src()} to {event.get_dst()} module list position.')
            exit(0)

        self.modules[event.get_dst()].handle_message(event.get_msg())



    def modules_initialization(self):
        print('Initialization modules phase.')
        for m in self.modules:
            super(type(m), m).initialize()
            m.initialize()

    def modules_finalization(self):
        print('Finalization modules phase.')
        for m in self.modules:
            super(type(m), m).finalization()
            m.finalization()