---

async def mode_mt_in_journal(ws_client, cfg: SmokeSuiteConfig, imitator_start_time, test_data: CaseData):
    """
    Проверка записей журнала о режиме мт
    """
    exp_mode_part_message, exp_reason_part_message, status_msg = test_data.expected_result

    with allure.step(
        "Подключение по ws, получение и обработка сообщения типа: MessagesInfoContent" "Фильтр MessageType. ЭФ Журнал"
    ):
        request_body = t_utils.create_journal_req_body(
            pagination=Pagination(limit=TestConst.LIMIT_CONTROLLED_SITES),
            filtering=Filtering(messageTypes=int(MessageType.PUMPING_STATUS), objects=FilteringObjects(tuId=cfg.tu_id)),
        )
        payload = await t_utils.connect_and_get_msg(ws_client, "GetMessagesRequest", request_body)
        parsed_payload = parser.parse_journal_msg(payload)
        messages_info = parsed_payload.replyContent.messagesInfo

    with allure.step("Фильтрация сообщений по времени"):
        end_time = datetime.now()

        filter_start_msk = t_utils.localize_as_moscow(imitator_start_time)
        filter_end_msk = t_utils.localize_as_moscow(end_time)

        messages_time_filtered = [
            msg
            for msg in messages_info
            if filter_start_msk <= t_utils.ensure_moscow_timezone(msg.time) <= filter_end_msk
        ]
        messages_time_filtered.sort(key=lambda msg: t_utils.ensure_moscow_timezone(msg.time), reverse=True)

    with allure.step("Фильтрация уникальных наименований участков КП-КП"):

        control_points_list = []

        for msg in messages_time_filtered:
            control_points_list.append(msg.controlPoint)

        unique_control_points_list = set(control_points_list)

    with allure.step("Собираю список сообщений с уникальными наименованиями участков КП_КП"):

        filter_messages_with_unique_control_points = [
            msg for msg in messages_time_filtered if msg.controlPoint in unique_control_points_list
        ]

    with allure.step("Создание и наполнение списков сообщений с фильтром по 'event'"):

        containers = defaultdict(list)

        for msg in filter_messages_with_unique_control_points:
            event = msg.event
            if event in (
                TestConst.JOURNAL_MESSAGE_EVENT_STATIONARY,
                TestConst.JOURNAL_MESSAGE_EVENT_NOT_STATIONARY,
                TestConst.JOURNAL_MESSAGE_EVENT_STOP,
            ):
                containers[event].append(msg)
            else:
                containers["another"].append(msg)

        stationary_status_list = list(containers[TestConst.JOURNAL_MESSAGE_EVENT_STATIONARY])
        unstationary_status_list = list(containers[TestConst.JOURNAL_MESSAGE_EVENT_NOT_STATIONARY])
        stopped_status_list = list(containers[TestConst.JOURNAL_MESSAGE_EVENT_STOP])
        another_event_list = list(containers["another"])
        most_long_event_list = max(
            [stationary_status_list, unstationary_status_list, stopped_status_list, another_event_list], key=len
        )

        if most_long_event_list:
            first_message = next(iter(most_long_event_list))
            mode_part, reason_part = t_utils.parse_event(first_message.event)
            priority_message = first_message.priority
        else:
            priority_message = None
            mode_part, reason_part = None, None

    with SoftAssertions() as soft_failures:
        StepCheck(
            "Проверка результата фильтрации сообщений о режиме МТ",
            "Кол-во сообщений о режиме МТ с уникальными наименованиями участков КП-КП",
            soft_failures,
        ).actual(len(filter_messages_with_unique_control_points)).expected(TestConst.COUNT_CONTROLLED_SITES).equal_to()
        StepCheck(
            "Проверка режима МТ на ЛЧ в наибольшей области связности.",
            "Режим МТ",
            soft_failures,
        ).actual(
            mode_part
        ).expected(exp_mode_part_message).equal_to()
        StepCheck(
            "Проверка причины режима МТ на ЛЧ в наибольшей области связности.", "Причина режима МТ", soft_failures
        ).contains(reason_part, exp_reason_part_message)
        StepCheck("Проверка значимости сообщения", "Важность", soft_failures).actual(priority_message).expected(
            status_msg
        ).equal_to()








def parse_event(event_value: str) -> tuple[str | None, str | None]:
    """
    Разделяет строку события на имя и причину, вложенную с скобки
    """
    if not event_value or not isinstance(event_value, str):
        return None, None

    # Паттерн для "Состояние режима (Причина)"
    pattern = r'^([^\(]+?)\s*\(([^\)]+)\)\s*$'
    match = re.match(pattern, event_value)

    if match:
        mode_part = match.group(1).strip()
        reason_part = match.group(2).strip()
        return (mode_part if mode_part else None, reason_part if reason_part else None)
    # Если значение события не соответствует паттерну, возвращаю текст, если нет текста, тогда None
    return event_value, None