(self, spec)
| 1330 | raise result |
| 1331 | |
| 1332 | def check_events(self, spec): |
| 1333 | for event_spec in spec: |
| 1334 | client_name = event_spec["client"] |
| 1335 | events = event_spec["events"] |
| 1336 | event_type = event_spec.get("eventType", "command") |
| 1337 | ignore_extra_events = event_spec.get("ignoreExtraEvents", False) |
| 1338 | server_connection_id = event_spec.get("serverConnectionId") |
| 1339 | has_server_connection_id = event_spec.get("hasServerConnectionId", False) |
| 1340 | listener = self.entity_map.get_listener_for_client(client_name) |
| 1341 | actual_events = listener.get_events(event_type) |
| 1342 | if ignore_extra_events: |
| 1343 | actual_events = actual_events[: len(events)] |
| 1344 | |
| 1345 | if len(events) == 0: |
| 1346 | self.assertEqual(actual_events, []) |
| 1347 | continue |
| 1348 | |
| 1349 | if len(actual_events) != len(events): |
| 1350 | expected = "\n".join(str(e) for e in events) |
| 1351 | actual = "\n".join(str(a) for a in actual_events) |
| 1352 | self.assertEqual( |
| 1353 | len(actual_events), |
| 1354 | len(events), |
| 1355 | f"expected events:\n{expected}\nactual events:\n{actual}", |
| 1356 | ) |
| 1357 | |
| 1358 | for idx, expected_event in enumerate(events): |
| 1359 | self.match_evaluator.match_event(expected_event, actual_events[idx]) |
| 1360 | |
| 1361 | if has_server_connection_id: |
| 1362 | assert server_connection_id is not None |
| 1363 | assert server_connection_id >= 0 |
| 1364 | else: |
| 1365 | assert server_connection_id is None |
| 1366 | |
| 1367 | def process_ignore_messages(self, ignore_logs, actual_logs): |
| 1368 | final_logs = [] |
no test coverage detected