Как сделать обработчик, который обрабатывает отсутствия ответа от пользователя?

Question

[EnotShow]

Мне нужно написать обработчик, который в случае отсутствия ответа от пользователя в течении какого-то времени закрывает программу. Как написать такой обработчик ?

Comments

[hayesdas]

Может при задаче вопроса запустить таймер и как только он выйдет закрыть программу?
(Просто предположение)

[Алан Гибизов]

[Vindicar]

Было бы неплохо написать, как ты получаешь ответ от пользователя.
Потому что реализация от этого зависит примерно полностью.

[EnotShow]

hayesdas, Ну в теории, то понятно, но как это на практике сделать ?

[EnotShow]

Vindicar, я пишу бота на aiogram, и мне нужно что бы после того как выполнилась функция обработчика, запустился таймер и если по истечению работы таймера следующая функция не вызвана, тогда будет вызываться обработчик который обрывает выполнения текущего состояния для данного пользователя.
Пример :

async def next_find_questionnaire(message: types.Message, state: FSMContext):
    if message.text == like.text:
        async with state.proxy() as data:
            if is_liked(message.from_user.id, data['user']):
                await bot.send_message(message.from_user.id, f'{tfind1}')
            else:
                add_to_like_list(message.from_user.id, message.from_user.username, data['user'])
                await bot.send_message(data['user'], f'{tfind2}')

            related_users = get_related_users(message.from_user.id)
            user_questionnaire = random.choice(related_users)
            data['user'] = user_questionnaire.user_id
        await bot.send_photo(
            message.chat.id,
            user_questionnaire.photo,
            caption=f'''{user_questionnaire.about}''',
            reply_markup=fbuttons)

    if message.text == like_with_message.text:
        async with state.proxy() as data:
            if is_liked(message.from_user.id, data['user']):
                await bot.send_message(message.from_user.id, f'{tfind1}')
            else:
                await FSMFind.next()
                await bot.send_message(
                    message.from_user.id,
                    f'{tfind3}',
                    reply_markup=ReplyKeyboardRemove()
                )

    if message.text == dislike.text:
        related_users = get_related_users(message.from_user.id)
        user_questionnaire = random.choice(related_users)
        async with state.proxy() as data:
            data['user'] = user_questionnaire.user_id
        await bot.send_photo(
            message.chat.id,
            user_questionnaire.photo,
            caption=f'''{user_questionnaire.about}''',
            reply_markup=fbuttons)

    if message.text == complain.text:
        await bot.send_message(message.from_user.id, f'{tfind4}')
        related_users = get_related_users(message.from_user.id)
        user_questionnaire = random.choice(related_users)
        async with state.proxy() as data:
            await send_report(data["user"], message.from_user.username)
            data['user'] = user_questionnaire.user_id
        await bot.send_photo(
            message.chat.id,
            user_questionnaire.photo,
            caption=f'''{user_questionnaire.about}''',
            reply_markup=fbuttons)

    if message.text == exit_query.text:
        await state.finish()
        await FSMMenu.status.set()
        await bot.send_message(message.from_user.id, f'{tfind5}', reply_markup=main_manu_buttons)

Я так понимаю это должен быть асинхронный таймер, который запускается в конце функции, но как это правильно сделать ?

[shurshur]

EnotShow, да, например aioschedule. Ставим таймер, который отреагирует через N времени, если пользователь ответил раньше - отменяем таймер...

[EnotShow]

shurshur, спасибо, попробуем

Answer 1

[Daniil Igumenshev]

async def start_bot(message: types.Message):
    if message.text == '/start':
        await message.answer(text="Отправь мне свое имя")
        await Add.test_state.set() # Ваш state
        await asyncio.sleep(5) # 5 сек спим
        try:
            data = await state.get_data()
            if data['get_name'] == 'true':
                pass
        except KeyError: 
            # Если пользователь не ответил или за это время state завершился, получаем KeyError
            await message.answer(f'Жаль, что ты не ответил')
            await state.finish()

Пример кода, дальше думаю додумаете как применить

Comments

[shurshur]

Ага, пользователь не успел прочитать, что от него хотят, или отвлёкся на звонок, а время уже вышло. А если поставить минуту ожидания, то пользователь через 3 секунды ввёл имя, а потом ещё 57 секунд думает не угодила ли в бота неуправляемая ракета с ядерным боезарядом...

[Daniil Igumenshev]

shurshur, добавь условие, при получении ответа ожидание заканчивается, в чем проблема? if и else в помощь так же while и работа с состояниями, я дал ответ на поставленный вопрос, я не интернет и не знаю что конкретно хотел человек