test

app.py

@@ -43,6 +43,9 @@ bot = commands.Bot(command_prefix='!', intents=intents)
 
 slack_client = WebClient(token=SLACK_BOT_TOKEN)
 
+thread_mapping = {}
+FORUM_CHANNEL_ID = 123456789012345678
+
 @bot.event
 async def on_ready():
     print(f'Logged in as {bot.user}')
@@ -63,64 +66,47 @@ 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 = 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:
+    # Check if the message is in a thread
+    if isinstance(message.channel, discord.Thread):
+        discord_thread_id = message.channel.id
+
+        # Check if there's an existing Slack thread for this Discord thread
+        if discord_thread_id in thread_mapping:
+            slack_thread_ts = thread_mapping[discord_thread_id]
+        else:
+            # If not, create a new Slack thread and update the mapping
+            slack_thread_ts = post_to_slack_forum_version('#discord-slackbot-test', f"Thread started: {message.channel.name}")
+            if slack_thread_ts:
+                thread_mapping[discord_thread_id] = slack_thread_ts
 
-                slack_client.chat_postMessage(
-                    channel=SLACK_CHANNEL_ID_TEST,
-                    text=content,
-                    thread_ts=thread_ts
-                )
-            else:
+        # Post the message to the existing Slack thread
+        post_to_slack_forum_version('#discord-slackbot-test', message.content, thread_ts=slack_thread_ts)
 
-                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']
 
-                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']}")
+@bot.event
+async def on_thread_create(thread):
+    if isinstance(thread.parent, discord.ForumChannel) and thread.parent.id == FORUM_CHANNEL_ID:
+        discord_thread_id = thread.id
+        slack_thread_ts = post_to_slack_forum_version('#discord-slackbot-test', f"New forum thread started: {thread.name}")
+        if slack_thread_ts:
+            thread_mapping[discord_thread_id] = slack_thread_ts
 
 
-def find_slack_thread_ts(thread_id):
-    """Search for a Slack thread with the given Discord thread ID and return the thread_ts."""
+def post_to_slack_forum_version(channel, text, thread_ts=None):
     try:
-        response = slack_client.conversations_history(
-            channel=SLACK_CHANNEL_ID_TEST,
-            limit=200 
+        response = slack_client.chat_postMessage(
+            channel=channel,
+            text=text,
+            thread_ts=thread_ts
         )
-        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']
-
+        return response['ts']  # Return the Slack message timestamp (thread ID)
     except SlackApiError as e:
-        print(f"Error fetching Slack messages: {e.response['error']}")
+        print(f"Error posting to Slack: {e.response['error']}")
+        return None
 
-    return None