Прекратить слушать старые сообщения Python Telegram Bot - PullRequest
Новая
       90

Прекратить слушать старые сообщения Python Telegram Bot

1 голос
/ 03 августа 2020

Я сделал простой код python, чтобы открыть свой автоматический c гейт, вот код: 

#!/usr/bin/env python

"""
open my automatic gate
"""
import gpiozero
import time
import logging
from functools import wraps
from telegram.ext import Updater, CommandHandler, MessageHandler, Filters

# log
logging.basicConfig(format='%(asctime)s - %(name)s - %(levelname)s - %(message)s', level=logging.INFO)
logger = logging.getLogger(__name__)

#user id
id = [XXXXX, YYYYY, ZZZZZ, WWWWW] #riccardo, papà, letizia, mamma

#relay object
relay = gpiozero.OutputDevice(4, active_high=True, initial_value=False)

# access restricted                                                                                                                                                                            def restricted(func):
    @wraps(func)
    def wrapped(update, context, *args, **kwargs):
        user_id = update.effective_user.id
        if user_id not in id:
            print("accesso non autorizzato per {}.".format(user_id))
            update.message.reply_text('Utente non autorizzato')
            return
        return func(update, context, *args, **kwargs)
    return wrapped

# open the gate
@restricted
def apri(update, context):
    relay.on()
    time.sleep(1)
    relay.off()
    update.message.reply_text('Apro il cancello!')
    time.sleep(30)
    update.message.reply_text('Cancello aperto!')
    time.sleep(82)
    update.message.reply_text('Chiudo il cancello')
    time.sleep(30)
    relay.off()
    update.message.reply_text('Cancello chiuso!')

# help
def aiuto(update, context):
    update.message.reply_text('Digitare /apri per aprire il cancello di casa. Solo utenti autorizzati')

# echo all other messages
def echo(update, context):
    update.message.reply_text(update.message.text)

# main                                                                                                                                                                                                         def main():
    """start the bot"""
    updater = Updater("TOKEN_HERE", use_context=True)

    #register
    dp = updater.dispatcher

    #message handler
    dp.add_handler(CommandHandler("apri", apri))
    dp.add_handler(CommandHandler("aiuto", aiuto))
    dp.add_handler(MessageHandler(Filters.text & ~Filters.command, echo))

    #listening
    updater.start_polling()

    # exiting
    updater.idle()


if __name__ == '__main__':
    main()

Проблема в том, что если по какой-то причине мой Raspberry Pi отключается, все сообщения полученные при выключенном состоянии выполняются в очереди в тот момент, когда я перезапускаю ее в результате нежелательного поведения. Есть ли способ проверить дату, когда пользователь отправляет сообщение, и выполнить его только в течение ограниченного времени? Например: Пользователь A отправляет команду OPEN Если мой сценарий получил ее в течение 1 минуты с момента отправки: ВЫПОЛНИТЬ КОМАНДУ Иначе Отменить сообщение

Надеюсь, я ясно выразился.

С уважением

Риккардо

1 Ответ

0 голосов
/ 04 августа 2020

Мне удалось получить время сообщения, так что я могу сравнить его с фактическим временем и отбросить старое сообщение.

Всем спасибо

Riccardo

...