testing threads

app.py

@@ -9,6 +9,7 @@ from slack_sdk.errors import SlackApiError
 DISCORD_TOKEN = os.getenv('DISCORD_TOKEN')
 SLACK_BOT_TOKEN = os.getenv('BOT_USER_OAUTH_TOKEN_HF')
 SLACK_CHANNEL_ID = os.getenv('SLACK_CHANNEL_ID_HF')
+SLACK_CHANNEL_ID_TEST = 'C07B4KNU5BQ'
 
 TRIGGERS = {
     "discord bot": "<@U051DB2754M>", # Adam
@@ -67,7 +68,7 @@ async def on_message(message):
     # 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
@@ -86,6 +87,63 @@ async def on_message(message):
             )
         except SlackApiError as e:
             print(f"Error posting to Slack: {e.response['error']}")
+    #--------------------------------------------------------------------------------------------------------------------
+
+
+    ask_for_help = await bot.fetch_channel(1019883044724822016)
+    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,
+                    thread_ts=thread_ts
+                )
+        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"""
+        try:
+            response = slack_client.conversations_history(
+                channel=SLACK_CHANNEL_ID_TEST,
+                limit=1000  # adjustable
+            )
+            messages = response['messages']
+    
+            for message in messages:
+                if f"Discord Thread ID: {thread_id}" in message['text']:
+                    return message['ts']
+    
+        except SlackApiError as e:
+            print(f"Error fetching Slack messages: {e.response['error']}")
+    
+        return None    
+
+
+
+    #----------------------------------------------------------------------------------------------
+
+
 
 
 async def post_to_slack(author, content, channel, url, slack_mention, trigger):
@@ -97,6 +155,7 @@ async def post_to_slack(author, content, channel, url, slack_mention, trigger):
     except SlackApiError as e:
         print(f"Error posting to Slack: {e.response['error']}")
 
+
 # runs discord bot in thread = helps avoid blocking calls
 def run_bot():
     bot.run(DISCORD_TOKEN)