52 lines
1.3 KiB
Python
52 lines
1.3 KiB
Python
import threading
|
|
|
|
from colony.core.network.core import Network
|
|
from colony.core.dispatcher import Dispatcher
|
|
from colony.core.state_manager import StateManager
|
|
from colony.core.storage import DefaultStorage
|
|
from colony.role_registry import RoleRegistry
|
|
from colony.roles.manager import RoleManager
|
|
from colony.transport.discover import Discover
|
|
from colony.transport.listener import Listener
|
|
from role_settings import available_roles
|
|
from colony.settings import configuration
|
|
|
|
|
|
def main():
|
|
storage = DefaultStorage()
|
|
state_manager = StateManager()
|
|
network = Network()
|
|
role_registry = RoleRegistry(role_list=available_roles)
|
|
dispatcher = Dispatcher(network=network, role_registry=role_registry)
|
|
role_manager = RoleManager(network=network, role_registry=role_registry)
|
|
|
|
threads = []
|
|
|
|
listener = Listener(dispatcher=dispatcher)
|
|
t = threading.Thread(
|
|
target=listener.start,
|
|
daemon=True,
|
|
name="Listener"
|
|
)
|
|
t.start()
|
|
threads.append(t)
|
|
|
|
t = threading.Thread(
|
|
target=Discover.listen,
|
|
args=(configuration.listener.port,),
|
|
daemon=True,
|
|
name="Discover"
|
|
)
|
|
t.start()
|
|
threads.append(t)
|
|
|
|
role_manager.initialize_roles()
|
|
role_manager.start_all()
|
|
|
|
for t in threads:
|
|
t.join()
|
|
|
|
|
|
if __name__ == "__main__":
|
|
main()
|