debug process forwarded group media

Author: bjkawecki

src/app/handlers/logic/media_group.py

@@ -21,7 +21,7 @@ def handle_media_group(post, media_group_id, BOT_TOKEN, forwarded=False):
         return {"statusCode": 200, "body": json.dumps({"message": "Waiting"})}
 
     posts = [item["post"] for item in items]
-    payload = process_media_group_payload(posts)
+    payload = process_media_group_payload(posts, forwarded)
     url = prepare_url("sendMediaGroup", BOT_TOKEN)
     response = requests.post(url, json=payload)
     print("Sent media group:", response.status_code)

src/app/telegram/formatting.py

@@ -0,0 +1,12 @@
+import re
+
+
+def escape_markdown(text: str) -> str:
+    escape_chars = r"_*\[\]()~`>#+-=|{}.!"
+    return re.sub(f"([{re.escape(escape_chars)}])", r"\\\1", text)
+
+
+def make_clickable_forwarded_text(original_channel: str, text: str) -> str:
+    escaped_text = escape_markdown(text)
+    escaped_channel = escape_markdown(original_channel)
+    return f"*[🔁 Weitergeleitet aus {escaped_channel}](https://t.me/{original_channel})*\n\n{escaped_text}"

src/app/telegram/groups/payload_builder.py

@@ -1,7 +1,8 @@
 from app.config.constants import TARGET_CHAT_ID
+from app.telegram.formatting import make_clickable_forwarded_text
 
 
-def process_media_group_payload(posts):
+def process_media_group_payload(posts, forwarded=False):
     """Erstellt das Payload für Telegrams sendMediaGroup-Methode."""
     if not posts:
         print("Leere MediaGroup – überspringe.")
@@ -41,6 +42,16 @@ def process_media_group_payload(posts):
 
         if i == 0 and p.get("caption"):
             media_item["caption"] = p["caption"]
+            if forwarded:
+                original_channel = p["chat"].get("title", "Quelle")
+                original_channel = (
+                    p.get("forward_origin", {}).get("chat", {}).get("title")
+                )
+                text = p.get("text", "")
+                media_item["parse_mode"] = "MarkdownV2"
+                media_item["caption"] = make_clickable_forwarded_text(
+                    original_channel, text
+                )
             if p.get("caption_entities"):
                 media_item["caption_entities"] = p["caption_entities"]
 

src/app/telegram/payloads/single.py

@@ -1,17 +1,5 @@
 from app.config.constants import TARGET_CHAT_ID
-
-import re
-
-
-def escape_markdown(text: str) -> str:
-    escape_chars = r"_*\[\]()~`>#+-=|{}.!"
-    return re.sub(f"([{re.escape(escape_chars)}])", r"\\\1", text)
-
-
-def make_clickable_forwarded_text(original_channel: str, text: str) -> str:
-    escaped_text = escape_markdown(text)
-    escaped_channel = escape_markdown(original_channel)
-    return f"{escaped_text}\n\n*[🔁 Weitergeleitet aus {escaped_channel}](https://t.me/{original_channel})*"
+from app.telegram.formatting import make_clickable_forwarded_text
 
 
 def process_photo_payload(post, forwarded=False):