<gh_stars>0
from time import sleep
from typing import Iterable, Optional
from .shared.networking import ConnectionSettings, NetworkConnection
from .shared.configuration import Configuration
from .shared.logs import get_logger, initialize
from .messaging.broker import Broker, BrokerSettings
from .messaging.logging_broker import LoggingBroker
from .computing.facade import get_computational_problem
from .computing.base import Subproblem, SubproblemResult, SubproblemPool
from .computing.domain_commands import DomainCommand, PruneCommand
from .app import ApplicationSettings, ComputationManager, EmptySubproblemPoolError
from .messaging.commands import CommandMapper
from .messaging.command_handler import CommandHandler, CommandNotRegisteredException
from time import time


ResultCommand: type = None
RegisterCommand: type = None


def main(computation_manager: ComputationManager):

    config = Configuration(__package__) \
        .add_json_file('config.json')
    app_settings = config.get('Application').bind_as(ApplicationSettings)
    broker_settings = config.get('Broker').bind_as(BrokerSettings)
    logger = get_logger(__package__)

    mode_name = 'active' if app_settings.active_mode else 'passive'
    logger.info(f'Codeine started in {mode_name} mode.')

    handler = create_command_handler(computation_manager.pool)
    broker = create_broker(broker_settings, create_command_mapper())
    broker.start()
    broker.discover_network()
    subproblem: Optional[Subproblem] = None
    active_mode = app_settings.active_mode
    any_free_subproblems = True
    ttt = time()

    try:
        while True:
            if computation_manager.pool.not_started_pool:
                any_free_subproblems = True

            if time() - ttt > 5:
                display_pool(computation_manager.pool, logger)
                broker.discover_network()

                broker.broadcast(ProgressCommand(*computation_manager.get_progress()))
                ttt = time()
            
            if active_mode and any_free_subproblems:
                if requested_subproblem_drop(subproblem, computation_manager):
                    subproblem.stop()
                    logger.info(f'Subproblem drop requested.')

                if subproblem is None:
                    try:
                        subproblem = computation_manager.create_random()
                        subproblem.start()
                        identifier = subproblem.identifier
                        broker.broadcast(RegisterCommand(identifier))
                        logger.info(f'Subproblem #{identifier} has started.')
                    except EmptySubproblemPoolError:
                        logger.warning('No more subproblems to take.')
                        any_free_subproblems = False
                elif not subproblem.is_alive():
                    identifier = subproblem.identifier
                    if computation_manager.pool.get_id_in_progress_locally() is None:
                        logger.info(f'Subproblem #{identifier} has been dropped.')
                    else:
                        result = subproblem.result
                        computation_manager.handle_completed(subproblem)
                        broadcast_result(subproblem, broker)
                        logger.info(f'Subproblem #{identifier} has ended (result: {result}).')
                    subproblem = None

                results = computation_manager.pool.results
                if computation_manager.stop_condition_is_met():
                    active_mode = False
                    logger.info(f'Stop condition is met: {results}')
                elif computation_manager.all_subproblems_finished():
                    any_free_subproblems = False
                    logger.info(f'All subproblems finished: {results}')

            for payload in broker.get_payloads():
                try:
                    logger.info(f'Received command from {payload.address}: {payload.command}')
                    responses = handler.handle(payload)
                    for response in responses:
                        broker.send(response)
                except CommandNotRegisteredException as exc:
                    logger.error(f'Unregistered command received from {payload.address}: {exc}')

                logger.info(computation_manager.pool.results)
            if not broker.is_alive():
                break
            sleep(0.01)
    except KeyboardInterrupt:
        pass
    except BaseException as exc:
        logger.exception(f'An unexpected exception has occurred: {exc}')

    logger.info('Gracefully stopping Codeine...')
    broker.stop()
    broker.join()

    if subproblem:
        subproblem.stop()
        subproblem.join()

    logger.info('Gracefully stopped.')


def requested_subproblem_drop(subproblem, computation_manager) -> bool:
    return (computation_manager.pool.get_id_in_progress_locally() is None
            and subproblem is not None)


def create_broker(broker_settings: BrokerSettings, mapper: CommandMapper) -> Broker:
    logger = get_logger('broker')
    connection = NetworkConnection(broker_settings.connection)
    broker = LoggingBroker(connection, logger, mapper, broker_settings)
    broker.on_prune(lambda addr: PruneCommand(addr))
    return broker


def create_command_mapper() -> CommandMapper:
    return CommandMapper() \
        .register(ResultCommand) \
        .register(RegisterCommand) \
        .register(DropCommand) \
        .register(ProgressCommand)


def create_command_handler(pool: SubproblemPool) -> CommandHandler:
    return CommandHandler() \
        .register(DomainCommand, pool)


def broadcast_result(subproblem: Subproblem, broker: Broker):
    command = ResultCommand(subproblem.identifier, subproblem.result)
    broker.broadcast(command)


def display_pool(pool: SubproblemPool, logger):
    logger.info(f'[Not started] {pool.not_started_pool}')
    logger.info(f'[In progress] {pool.in_progress_pool}')
    logger.info(f'     [Solved] {pool.results}')


if __name__ == '__main__':
    initialize()
    PROBLEM = get_computational_problem()
    ResultCommand = PROBLEM.result_command_type
    RegisterCommand = PROBLEM.register_command_type
    DropCommand = PROBLEM.drop_command_type
    ProgressCommand = PROBLEM.progress_command_type
    main(ComputationManager(PROBLEM))

from time import sleep
from typing import Iterable, Optional
from .shared.networking import ConnectionSettings, NetworkConnection
from .shared.configuration import Configuration
from .shared.logs import get_logger, initialize
from .messaging.broker import Broker, BrokerSettings
from .messaging.logging_broker import LoggingBroker
from .computing.facade import get_computational_problem
from .computing.base import Subproblem, SubproblemResult, SubproblemPool
from .computing.domain_commands import DomainCommand, PruneCommand
from .app import ApplicationSettings, ComputationManager, EmptySubproblemPoolError
from .messaging.commands import CommandMapper
from .messaging.command_handler import CommandHandler, CommandNotRegisteredException
from time import time


ResultCommand: type = None
RegisterCommand: type = None


def main(computation_manager: ComputationManager):

    config = Configuration(__package__) \
        .add_json_file('config.json')
    app_settings = config.get('Application').bind_as(ApplicationSettings)
    broker_settings = config.get('Broker').bind_as(BrokerSettings)
    logger = get_logger(__package__)

    mode_name = 'active' if app_settings.active_mode else 'passive'
    logger.info(f'Codeine started in {mode_name} mode.')

    handler = create_command_handler(computation_manager.pool)
    broker = create_broker(broker_settings, create_command_mapper())
    broker.start()
    broker.discover_network()
    subproblem: Optional[Subproblem] = None
    active_mode = app_settings.active_mode
    any_free_subproblems = True
    ttt = time()

    try:
        while True:
            if computation_manager.pool.not_started_pool:
                any_free_subproblems = True

            if time() - ttt > 5:
                display_pool(computation_manager.pool, logger)
                broker.discover_network()

                broker.broadcast(ProgressCommand(*computation_manager.get_progress()))
                ttt = time()
            
            if active_mode and any_free_subproblems:
                if requested_subproblem_drop(subproblem, computation_manager):
                    subproblem.stop()
                    logger.info(f'Subproblem drop requested.')

                if subproblem is None:
                    try:
                        subproblem = computation_manager.create_random()
                        subproblem.start()
                        identifier = subproblem.identifier
                        broker.broadcast(RegisterCommand(identifier))
                        logger.info(f'Subproblem #{identifier} has started.')
                    except EmptySubproblemPoolError:
                        logger.warning('No more subproblems to take.')
                        any_free_subproblems = False
                elif not subproblem.is_alive():
                    identifier = subproblem.identifier
                    if computation_manager.pool.get_id_in_progress_locally() is None:
                        logger.info(f'Subproblem #{identifier} has been dropped.')
                    else:
                        result = subproblem.result
                        computation_manager.handle_completed(subproblem)
                        broadcast_result(subproblem, broker)
                        logger.info(f'Subproblem #{identifier} has ended (result: {result}).')
                    subproblem = None

                results = computation_manager.pool.results
                if computation_manager.stop_condition_is_met():
                    active_mode = False
                    logger.info(f'Stop condition is met: {results}')
                elif computation_manager.all_subproblems_finished():
                    any_free_subproblems = False
                    logger.info(f'All subproblems finished: {results}')

            for payload in broker.get_payloads():
                try:
                    logger.info(f'Received command from {payload.address}: {payload.command}')
                    responses = handler.handle(payload)
                    for response in responses:
                        broker.send(response)
                except CommandNotRegisteredException as exc:
                    logger.error(f'Unregistered command received from {payload.address}: {exc}')

                logger.info(computation_manager.pool.results)
            if not broker.is_alive():
                break
            sleep(0.01)
    except KeyboardInterrupt:
        pass
    except BaseException as exc:
        logger.exception(f'An unexpected exception has occurred: {exc}')

    logger.info('Gracefully stopping Codeine...')
    broker.stop()
    broker.join()

    if subproblem:
        subproblem.stop()
        subproblem.join()

    logger.info('Gracefully stopped.')


def requested_subproblem_drop(subproblem, computation_manager) -> bool:
    return (computation_manager.pool.get_id_in_progress_locally() is None
            and subproblem is not None)


def create_broker(broker_settings: BrokerSettings, mapper: CommandMapper) -> Broker:
    logger = get_logger('broker')
    connection = NetworkConnection(broker_settings.connection)
    broker = LoggingBroker(connection, logger, mapper, broker_settings)
    broker.on_prune(lambda addr: PruneCommand(addr))
    return broker


def create_command_mapper() -> CommandMapper:
    return CommandMapper() \
        .register(ResultCommand) \
        .register(RegisterCommand) \
        .register(DropCommand) \
        .register(ProgressCommand)


def create_command_handler(pool: SubproblemPool) -> CommandHandler:
    return CommandHandler() \
        .register(DomainCommand, pool)


def broadcast_result(subproblem: Subproblem, broker: Broker):
    command = ResultCommand(subproblem.identifier, subproblem.result)
    broker.broadcast(command)


def display_pool(pool: SubproblemPool, logger):
    logger.info(f'[Not started] {pool.not_started_pool}')
    logger.info(f'[In progress] {pool.in_progress_pool}')
    logger.info(f'     [Solved] {pool.results}')


if __name__ == '__main__':
    initialize()
    PROBLEM = get_computational_problem()
    ResultCommand = PROBLEM.result_command_type
    RegisterCommand = PROBLEM.register_command_type
    DropCommand = PROBLEM.drop_command_type
    ProgressCommand = PROBLEM.progress_command_type
    main(ComputationManager(PROBLEM))
#{identifier} has started.') #{identifier} has been dropped.') #{identifier} has ended (result: {result}).')