patch b2f8fe9251a26c43e16ba1aadff8d71e64a5a7e9
Author: E. Bosch <presidev@AT@gmail.com>
Date:   Fri Sep 27 11:05:53 CEST 2024
  * telegram: Add handler for next reactions (2nd, 3rd, etc.) that don't come from
  the same events as 1st (why?!)
diff -rN -u old-irgramd/telegram.py new-irgramd/telegram.py
--- old-irgramd/telegram.py	2024-11-22 10:09:26.472219865 +0100
+++ new-irgramd/telegram.py	2024-11-22 10:09:26.476219858 +0100
@@ -503,6 +503,24 @@
         self.sorted_len_usernames.append(username)
         self.sorted_len_usernames.sort(key=lambda k: len(k), reverse=True)
 
+    def format_reaction(self, msg, message_rendered, edition_case, reaction):
+        if len(message_rendered) > self.quote_len and not msg.is_reply:
+            text_old = '{}...'.format(message_rendered[:self.quote_len])
+            text_old = fix_braces(text_old)
+        else:
+            text_old = message_rendered
+
+        if edition_case == 'react-add':
+            user = self.get_irc_user_from_telegram(reaction.peer_id.user_id)
+            emoji = reaction.reaction.emoticon
+            react_action = '+'
+            react_icon = e.emo[emoji] if emoji in e.emo else emoji
+        elif edition_case == 'react-del':
+            user = self.get_irc_user_from_telegram(event.sender_id)
+            react_action = '-'
+            react_icon = ''
+        return text_old, '{}{}'.format(react_action, react_icon), user
+
     async def handle_telegram_edited(self, event):
         self.logger.debug('Handling Telegram Message Edited: %s', pretty(event))
 
@@ -537,22 +555,7 @@
         # Reactions
         else:
             action = 'React'
-            if len(message_rendered) > self.quote_len and not event.message.is_reply:
-                text_old = '{}...'.format(message_rendered[:self.quote_len])
-                text_old = fix_braces(text_old)
-            else:
-                text_old = message_rendered
-
-            if edition_case == 'react-add':
-                user = self.get_irc_user_from_telegram(reaction.peer_id.user_id)
-                emoji = reaction.reaction.emoticon
-                react_action = '+'
-                react_icon = e.emo[emoji] if emoji in e.emo else emoji
-            elif edition_case == 'react-del':
-                user = self.get_irc_user_from_telegram(event.sender_id)
-                react_action = '-'
-                react_icon = ''
-            edition_react = '{}{}'.format(react_action, react_icon)
+            text_old, edition_react, user = self.format_reaction(event.message, message_rendered, edition_case, reaction)
 
         text = '|{} {}| {}'.format(action, text_old, edition_react)
 
@@ -561,6 +564,26 @@
         self.to_cache(id, mid, message, message_rendered, user, chan, event.message.media)
         self.to_volatile_cache(self.prev_id, id, text, user, chan, current_date())
 
+    async def handle_next_reaction(self, event):
+        self.logger.debug('Handling Telegram Next Reaction (2nd, 3rd, ...): %s', pretty(event))
+
+        reactions = event.reactions.recent_reactions
+        react = max(reactions, key=lambda y: y.date)
+        id = event.msg_id
+        msg = await self.telegram_client.get_messages(entity=event.peer, ids=id)
+        mid = self.mid.num_to_id_offset(msg.peer_id, id)
+        message = self.filters(msg.message)
+        message_rendered = await self.render_text(msg, mid, upd_to_webpend=None)
+
+        text_old, edition_react, user = self.format_reaction(msg, message_rendered, edition_case='react-add', reaction=react)
+
+        text = '|React {}| {}'.format(text_old, edition_react)
+
+        chan = await self.relay_telegram_message(msg, user, text)
+
+        self.to_cache(id, mid, message, message_rendered, user, chan, msg.media)
+        self.to_volatile_cache(self.prev_id, id, text, user, chan, current_date())
+
     async def handle_telegram_deleted(self, event):
         self.logger.debug('Handling Telegram Message Deleted: %s', pretty(event))
 
@@ -584,6 +607,9 @@
             if message:
                 await self.handle_telegram_message(event=None, message=message, upd_to_webpend=update.webpage)
 
+        elif isinstance(update, tgty.UpdateMessageReactions):
+            await self.handle_next_reaction(update)
+
     async def handle_telegram_message(self, event, message=None, upd_to_webpend=None, history=False):
         self.logger.debug('Handling Telegram Message: %s', pretty(event or message))