Island: Rename setup_island_event_{subscribers,handlers}

This commit is contained in:
Mike Salvatore 2022-09-12 11:25:58 -04:00
parent fd7a00a225
commit 4bc9f735be
3 changed files with 4 additions and 4 deletions

View File

@ -1,2 +1,2 @@
from .version import Version from .version import Version
from .subscribe_to_topics import setup_island_event_subscribers from .setup_island_event_handlers import setup_island_event_handlers

View File

@ -10,7 +10,7 @@ import gevent.hub
import requests import requests
from gevent.pywsgi import WSGIServer from gevent.pywsgi import WSGIServer
from monkey_island.cc import Version, setup_island_event_subscribers from monkey_island.cc import Version, setup_island_event_handlers
from monkey_island.cc.deployment import Deployment from monkey_island.cc.deployment import Deployment
from monkey_island.cc.server_utils.consts import ISLAND_PORT from monkey_island.cc.server_utils.consts import ISLAND_PORT
from monkey_island.cc.server_utils.island_logger import get_log_file_path from monkey_island.cc.server_utils.island_logger import get_log_file_path
@ -62,7 +62,7 @@ def run_monkey_island():
_initialize_mongodb_connection(config_options.start_mongodb, config_options.data_dir) _initialize_mongodb_connection(config_options.start_mongodb, config_options.data_dir)
_start_island_server(ip_addresses, island_args.setup_only, config_options, container) _start_island_server(ip_addresses, island_args.setup_only, config_options, container)
setup_island_event_subscribers(container) setup_island_event_handlers(container)
def _extract_config(island_args: IslandCmdArgs) -> IslandConfigOptions: def _extract_config(island_args: IslandCmdArgs) -> IslandConfigOptions:

View File

@ -3,7 +3,7 @@ from monkey_island.cc.event_queue import IslandEventTopic, PyPubSubIslandEventQu
from monkey_island.cc.services.reset_agent_configuration import reset_agent_configuration from monkey_island.cc.services.reset_agent_configuration import reset_agent_configuration
def setup_island_event_subscribers(container: DIContainer): def setup_island_event_handlers(container: DIContainer):
event_queue = container.resolve(PyPubSubIslandEventQueue) event_queue = container.resolve(PyPubSubIslandEventQueue)
event_queue.subscribe( event_queue.subscribe(