Update app.py

app.py

@@ -63,56 +63,30 @@ async def on_message(message):
                     await post_to_slack(message.author, message.content, message.channel.name, message.jump_url, slack_mention, trigger)
                     break
 
-    # ask-for-help
-    # discord.ForumChannel.last_message_id -> The last thread ID that was created on this forum.
-    # when message is posted
-    # fetch ask-for-help channel 
-    # if ask-for-help.last_message_id == message.id of on_message -> success
-    #--------------------------------------------------------------------------------------------------------------------
-    ask_for_help = await bot.fetch_channel(1019883044724822016)
-    if ask_for_help.last_message_id == message.channel.id:
-        content = message.content
-        try:
-            # title
-            response = slack_client.chat_postMessage(
-                channel=SLACK_CHANNEL_ID,
-                text=f"New post in #ask-for-help by {message.author}: *{message.channel.name}*\n{message.jump_url}"
-            )
-            # reply in thread
-            thread_ts = response['ts']
-            slack_client.chat_postMessage(
-                channel=SLACK_CHANNEL_ID,
-                text=content,
-                thread_ts=thread_ts
-            )
-        except SlackApiError as e:
-            print(f"Error posting to Slack: {e.response['error']}")
-    #--------------------------------------------------------------------------------------------------------------------
-
-
     ask_for_help = await bot.fetch_channel(1259415803879751700)
     if ask_for_help.last_message_id == message.channel.id:
         content = message.content
         thread_id = message.channel.id
 
         try:
+
             thread_ts = find_slack_thread_ts(thread_id)
 
             if thread_ts:
-                # if exists, post in existing thread (don't create new one)
+
                 slack_client.chat_postMessage(
                     channel=SLACK_CHANNEL_ID_TEST,
                     text=content,
                     thread_ts=thread_ts
                 )
             else:
-                # if not, create new thread
+
                 response = slack_client.chat_postMessage(
                     channel=SLACK_CHANNEL_ID_TEST,
                     text=f"New post in #ask-for-help by {message.author}: *{message.channel.name}*\n{message.jump_url}\n\nDiscord Thread ID: {thread_id}"
                 )
                 thread_ts = response['ts']
-                # first reply
+
                 slack_client.chat_postMessage(
                     channel=SLACK_CHANNEL_ID_TEST,
                     text=content,
@@ -121,15 +95,24 @@ async def on_message(message):
         except SlackApiError as e:
             print(f"Error posting to Slack: {e.response['error']}")
 
+
 def find_slack_thread_ts(thread_id):
-    # search for a Slack thread based on Discord thread_id"""
+    """Search for a Slack thread with the given Discord thread ID and return the thread_ts."""
     try:
         response = slack_client.conversations_history(
             channel=SLACK_CHANNEL_ID_TEST,
-            limit=1000  # adjustable
+            limit=200 
         )
         messages = response['messages']
 
+        while response['has_more']:
+            response = slack_client.conversations_history(
+                channel=SLACK_CHANNEL_ID_TEST,
+                limit=200,
+                cursor=response['response_metadata']['next_cursor']
+            )
+            messages.extend(response['messages'])
+
         for message in messages:
             if f"Discord Thread ID: {thread_id}" in message['text']:
                 return message['ts']
@@ -137,7 +120,7 @@ def find_slack_thread_ts(thread_id):
     except SlackApiError as e:
         print(f"Error fetching Slack messages: {e.response['error']}")
 
-    return None    
+    return None