@@ -73,14 +73,12 @@ def test_stop_snort_ides(self, mock_stop_snort_ids) -> None:
73
73
)
74
74
75
75
@patch ("csle_common.controllers.snort_ids_controller.SnortIDSController.start_snort_manager" )
76
- @patch (
77
- "csle_common.controllers.snort_ids_controller.SnortIDSController.get_snort_idses_monitor_threads_statuses_by_ip_and_port"
78
- )
76
+ @patch ("csle_common.controllers.snort_ids_controller.SnortIDSController."
77
+ "get_snort_idses_monitor_threads_statuses_by_ip_and_port" )
79
78
@patch ("csle_collector.snort_ids_manager.query_snort_ids_manager.start_snort_ids" )
80
79
@patch ("grpc.insecure_channel" )
81
- def test_start_snort_ids (
82
- self , mock_insecure_channel , mock_start_snort_ids , mock_get_statuses , mock_start_manager
83
- ) -> None :
80
+ def test_start_snort_ids (self , mock_insecure_channel , mock_start_snort_ids , mock_get_statuses , mock_start_manager ) \
81
+ -> None :
84
82
"""
85
83
Test utility function for starting the Snort IDS on a specific IP
86
84
@@ -111,13 +109,12 @@ def test_start_snort_ids(
111
109
mock_start_snort_ids .assert_called ()
112
110
113
111
@patch ("csle_common.controllers.snort_ids_controller.SnortIDSController.start_snort_manager" )
114
- @patch (
115
- "csle_common.controllers.snort_ids_controller.SnortIDSController.get_snort_idses_monitor_threads_statuses_by_ip_and_port"
116
- )
112
+ @patch ("csle_common.controllers.snort_ids_controller.SnortIDSController."
113
+ "get_snort_idses_monitor_threads_statuses_by_ip_and_port" )
117
114
@patch ("csle_collector.snort_ids_manager.query_snort_ids_manager.stop_snort_ids" )
118
115
@patch ("grpc.insecure_channel" )
119
116
def test_stop_snort_ids (
120
- self , mock_insecure_channel , mock_stop_snort_ids , mock_get_statuses , mock_start_manager
117
+ self , mock_insecure_channel , mock_stop_snort_ids , mock_get_statuses , mock_start_manager
121
118
) -> None :
122
119
"""
123
120
Test utility function for stopping the Snort IDS on a specific IP
@@ -245,14 +242,12 @@ def test_start_snort_idses_monitor_threads(self, mock_start_monitor_thread) -> N
245
242
self .logger .info .assert_called_once_with ("Starting Snort IDS monitor thread on IP: 10.0.0.1" )
246
243
247
244
@patch ("csle_common.controllers.snort_ids_controller.SnortIDSController.start_snort_manager" )
248
- @patch (
249
- "csle_common.controllers.snort_ids_controller.SnortIDSController.get_snort_idses_monitor_threads_statuses_by_ip_and_port"
250
- )
245
+ @patch ("csle_common.controllers.snort_ids_controller.SnortIDSController."
246
+ "get_snort_idses_monitor_threads_statuses_by_ip_and_port" )
251
247
@patch ("csle_collector.snort_ids_manager.query_snort_ids_manager.start_snort_ids_monitor" )
252
248
@patch ("grpc.insecure_channel" )
253
- def test_start_snort_idses_monitor_thread (
254
- self , mock_insecure_channel , mock_start_monitor , mock_get_statuses , mock_start_manager
255
- ):
249
+ def test_start_snort_idses_monitor_thread (self , mock_insecure_channel , mock_start_monitor , mock_get_statuses ,
250
+ mock_start_manager ) -> None :
256
251
"""
257
252
Test a method that sends a request to the SnortIDSManager on a specific container that runs
258
253
an IDS to start the IDS manager and the monitor thread
@@ -335,7 +330,8 @@ def test_stop_snort_idses_monitor_thread(self, mock_insecure_channel, mock_stop_
335
330
336
331
@patch ("csle_common.controllers.snort_ids_controller.SnortIDSController.start_snort_managers" )
337
332
@patch (
338
- "csle_common.controllers.snort_ids_controller.SnortIDSController.get_snort_idses_monitor_threads_statuses_by_ip_and_port"
333
+ "csle_common.controllers.snort_ids_controller.SnortIDSController."
334
+ "get_snort_idses_monitor_threads_statuses_by_ip_and_port"
339
335
)
340
336
def test_get_snort_idses_monitor_threads_statuses (self , mock_get_statuses , mock_start_managers ) -> None :
341
337
"""
@@ -365,9 +361,8 @@ def test_get_snort_idses_monitor_threads_statuses(self, mock_get_statuses, mock_
365
361
366
362
@patch ("grpc.insecure_channel" )
367
363
@patch ("csle_collector.snort_ids_manager.query_snort_ids_manager.get_snort_ids_monitor_status" )
368
- def test_get_snort_idses_monitor_threads_statuses_by_ip_and_port (
369
- self , mock_get_status , mock_insecure_channel
370
- ) -> None :
364
+ def test_get_snort_idses_monitor_threads_statuses_by_ip_and_port (self , mock_get_status , mock_insecure_channel ) \
365
+ -> None :
371
366
"""
372
367
Test a method that sends a request to the SnortIDSManager with a specific port and ip
373
368
to get the status of the IDS monitor thread
@@ -407,14 +402,13 @@ def test_get_snort_idses_managers_ports(self) -> None:
407
402
408
403
@patch ("csle_common.controllers.snort_ids_controller.SnortIDSController.get_snort_ids_managers_ips" )
409
404
@patch ("csle_common.controllers.snort_ids_controller.SnortIDSController.get_snort_idses_managers_ports" )
410
- @patch (
411
- "csle_common.controllers.snort_ids_controller.SnortIDSController.get_snort_idses_monitor_threads_statuses_by_ip_and_port"
412
- )
405
+ @patch ("csle_common.controllers.snort_ids_controller.SnortIDSController."
406
+ "get_snort_idses_monitor_threads_statuses_by_ip_and_port" )
413
407
@patch ("csle_common.util.emulation_util.EmulationUtil.physical_ip_match" )
414
408
@patch ("csle_collector.snort_ids_manager.snort_ids_manager_util.SnortIdsManagerUtil.snort_ids_monitor_dto_empty" )
415
409
def test_get_snort_managers_info (
416
- self , mock_snort_ids_monitor_dto_empty , mock_physical_ip_match , mock_get_statuses , mock_get_ports , mock_get_ips
417
- ) -> None :
410
+ self , mock_snort_ids_monitor_dto_empty , mock_physical_ip_match , mock_get_statuses , mock_get_ports ,
411
+ mock_get_ips ) -> None :
418
412
"""
419
413
Test the method that extracts the information of the Snort managers for a given emulation
420
414
@@ -445,7 +439,6 @@ def test_get_snort_managers_info(
445
439
logger = self .logger ,
446
440
physical_server_ip = physical_server_ip ,
447
441
)
448
-
449
442
mock_get_ips .assert_called_once_with (emulation_env_config = emulation_env_config )
450
443
mock_get_ports .assert_called_once_with (emulation_env_config = emulation_env_config )
451
444
mock_get_statuses .assert_any_call (port = 50051 , ip = "10.0.0.1" )
0 commit comments