mirror of
				https://github.com/cdryzun/tg_bot_collections.git
				synced 2025-11-04 16:56:43 +08:00 
			
		
		
		
	feat: skip update duplicate message
This commit is contained in:
		@ -15,6 +15,7 @@ from telebot.util import smart_split
 | 
			
		||||
import telegramify_markdown
 | 
			
		||||
from telegramify_markdown.customize import markdown_symbol
 | 
			
		||||
from urlextract import URLExtract
 | 
			
		||||
from expiringdict import ExpiringDict
 | 
			
		||||
 | 
			
		||||
markdown_symbol.head_level_1 = "📌"  # If you want, Customizing the head level 1 symbol
 | 
			
		||||
markdown_symbol.link = "🔗"  # If you want, Customizing the link symbol
 | 
			
		||||
@ -23,6 +24,8 @@ T = TypeVar("T", bound=Callable)
 | 
			
		||||
 | 
			
		||||
BOT_MESSAGE_LENGTH = 4000
 | 
			
		||||
 | 
			
		||||
REPLY_MESSAGE_CACHE = ExpiringDict(max_len=1000, max_age_seconds=300)
 | 
			
		||||
 | 
			
		||||
 | 
			
		||||
def bot_reply_first(message: Message, who: str, bot: TeleBot) -> Message:
 | 
			
		||||
    """Create the first reply message which make user feel the bot is working."""
 | 
			
		||||
@ -44,6 +47,11 @@ def bot_reply_markdown(
 | 
			
		||||
    it will fallback to plain text in case of any failure
 | 
			
		||||
    """
 | 
			
		||||
    try:
 | 
			
		||||
        cache_key = f"{reply_id.chat.id}_{reply_id.message_id}"
 | 
			
		||||
        if cache_key in REPLY_MESSAGE_CACHE and REPLY_MESSAGE_CACHE[cache_key] == text:
 | 
			
		||||
            print(f"Skipping duplicate message for {cache_key}")
 | 
			
		||||
            return True
 | 
			
		||||
        REPLY_MESSAGE_CACHE[cache_key] = text
 | 
			
		||||
        if len(text.encode("utf-8")) <= BOT_MESSAGE_LENGTH or not split_text:
 | 
			
		||||
            bot.edit_message_text(
 | 
			
		||||
                f"*{who}*:\n{telegramify_markdown.convert(text)}",
 | 
			
		||||
 | 
			
		||||
		Reference in New Issue
	
	Block a user