Как обработать несколько сообщений как одно через Aiogram?

Question

[Andria Siradze]

Когда пользователь отсылает сообщение которое длиннее 4072 символов телеграм посылает его как 2 сообщения

Мне нужен способ отлавливать такие сообщения обрабатывать их как 1

Вот так выглядит хэндлер
1 сообщение это 1 ответ от пользователя
если пользователь посылает слишком длинное сообщение
получается что 1 ответ он считывает как 2

async def marathon_questions(message: types.Message, state: FSMContext):
    """
    На этом шаге получаем ответ о главной цели и ИИ будет задаваь вопроссы
    """

    logging.info(marathon_questions.__name__)
    reply = await message.reply('Ожидаем ИИ')

    async with state.proxy() as data:  # Получаем информацию из контекстных переменных
        logging.info(f"question : {data['questions']}")
        chat: AiChat = data['chat']
        response = await data['chat'].generate_response(message.text, tokens=586,
                                                        auto_reformat=True)  # генерируем ответ от ии

        if data['questions'] == 7:  # Когда количество вопроссов достигает 7 переходим к следующему шагу
            await FirstInteractionState.marathon_calibrations.set()
            await marathon_decompose(message, state)
            await reply.delete()

        data['questions'] += 1  # Счетчик вопроссов
        await reply.edit_text(response)  # вопросс о сфере развития
        print(chat is data['chat'])

Comments

[Модератор]

Не надо ставить как можно больше тэгов. Лучше оставить один, но конкретный, с которым проблема.
См.п.3.1 Регламента. Также обратите внимание на п.3.4

[Lapita12]

import textwrap

async def marathon_questions(message: types.Message, state: FSMContext):
    """
    На этом шаге получаем ответ о главной цели и ИИ будет задавать вопросы
    """

    logging.info(marathon_questions.__name__)
    reply = await message.reply('Ожидаем ИИ')

    async with state.proxy() as data:  # Получаем информацию из контекстных переменных
        logging.info(f"question : {data['questions']}")
        chat: AiChat = data['chat']
        
        
        message_text = message.text
        if len(message_text) > 4096:
            message_text_chunks = textwrap.wrap(message_text, width=4096)
        else:
            message_text_chunks = [message_text]

        # Process each chunk as a separate message
        for chunk in message_text_chunks:
            response = await data['chat'].generate_response(chunk, tokens=586,
                                                            auto_reformat=True)  # генерируем ответ от ии

            if data['questions'] == 7:  # Когда количество вопросов достигает 7 переходим к следующему шагу
                await FirstInteractionState.marathon_calibrations.set()
                await marathon_decompose(message, state)
                await reply.delete()

            data['questions'] += 1  # Счетчик вопросов
            await reply.edit_text(response)  # вопрос о сфере развития
            print(chat is data['chat'])