|
2 | 2 | from queue import Queue |
3 | 3 | from unittest.mock import MagicMock |
4 | 4 | from .attack import process_attack |
| 5 | +from ..queue_helpers import ReportingQueueAttackWaveEvent |
5 | 6 |
|
6 | 7 |
|
7 | 8 | class MockCloudConnectionManager: |
@@ -57,13 +58,16 @@ def test_process_attack_with_different_data_formats(): |
57 | 58 | data1 = ("injection_results", "context", True, "stacktrace") |
58 | 59 | data2 = ("injection_results", "context", False, "stacktrace") |
59 | 60 | data3 = ("injection_results", "context", None, "stacktrace") |
| 61 | + data4 = ReportingQueueAttackWaveEvent(None, {"a": "b"}) |
60 | 62 |
|
61 | 63 | process_attack(connection_manager, data1, queue) |
62 | 64 | process_attack(connection_manager, data2, queue) |
63 | 65 | process_attack(connection_manager, data3, queue) |
| 66 | + process_attack(connection_manager, data4, queue) |
64 | 67 |
|
65 | 68 | # Check if all data items are added to the queue |
66 | | - assert queue.qsize() == 3 |
| 69 | + assert queue.qsize() == 4 |
67 | 70 | assert queue.get() == data1 |
68 | 71 | assert queue.get() == data2 |
69 | 72 | assert queue.get() == data3 |
| 73 | + assert queue.get() == data4 |
0 commit comments