daily pings test (content -> minimized to adjacent words, pings->put into a thread)

app.py

@@ -85,7 +85,7 @@ async def on_message(message):
 
     # notification bot
     print("on_message")
-    """
+
     huggingfolks_role = discord.utils.get(message.guild.roles, id=897376942817419265)
     bots_role = discord.utils.get(message.guild.roles, id=1258328471609016341)
     if huggingfolks_role not in message.author.roles: # no need for ping if we're already discussing
@@ -94,10 +94,11 @@ async def on_message(message):
             content = message.content.lower()
             
             for trigger, slack_mention in TRIGGERS.items():
-                if all(word in content for word in trigger):         
+                if all(word in content for word in trigger):     
+                    adjacent_words = extract_adjacent_words(message.content, trigger, 3)
                     daily_pings.append({
                         'author': str(message.author),
-                        'content': message.content,
+                        'content': adjacent_words,
                         'channel': message.channel.name,
                         'url': message.jump_url,
                         'mention': slack_mention,
@@ -106,7 +107,7 @@ async def on_message(message):
                     print(f"daily pings:{daily_pings}")
                     break    
     
-    """
+
 
 
     # Check if the message is in a thread
@@ -122,6 +123,14 @@ async def on_message(message):
     await bot.process_commands(message)
 
 
+def extract_adjacent_words(content, trigger, num_words=3):
+    pattern = r'\b(\w+\s+){0,' + str(num_words) + '}' + r'\b' + r'\b'.join(map(re.escape, trigger)) + r'\b' + r'(\s+\w+){0,' + str(num_words) + '}\b'
+    match = re.search(pattern, content, re.IGNORECASE)
+    if match:
+        return f"...{match.group(0)}..."
+    return content
+
+
 @bot.event
 async def on_thread_create(thread):
     # (discord) must be the child thread of the CORRECT forum channel(s) (not just any thread, or any forum channel)
@@ -230,27 +239,29 @@ def send_daily_pings():
     if daily_pings:
         print("sending daily pings...")
         # combine into one message
-        combined_message = '\n'.join(f"{ping['mention']} (for the keyword -> '{ping['trigger']}')\nFrom {ping['author']} in channel #{ping['channel']}: {ping['content']}\n{ping['url']}" for ping in daily_pings)
-        
-        response = slack_client.chat_postMessage(
-            channel=SLACK_CHANNEL_ID,
-            text=combined_message,
+        main_message = slack_client.chat_postMessage(
+            channel=SLACK_CHANNEL_ID_TEST,
+            text=f"DAILY PINGS FOR {datetime.now().strftime('%d/%m/%Y')}",
             unfurl_links=False,
-            unfurl_media=False            
-        )        
+            unfurl_media=False
+        )
+        main_ts = main_message['ts']
+        for ping in daily_pings:
+            slack_client.chat_postMessage(
+                channel=SLACK_CHANNEL_ID_TEST,
+                text=f"{ping['mention']} (for the keyword -> '{ping['trigger']}')\nFrom {ping['author']} in channel #{ping['channel']}: {ping['content']}\n{ping['url']}",
+                thread_ts=main_ts,
+                unfurl_links=False,
+                unfurl_media=False
+            )   
 
         daily_pings = []  # reset after posting
 
 # pings -------------------------------------------------------------------------------------------
-
-"""
-
 executor = ThreadPoolExecutor(max_workers=1)
 scheduler = BackgroundScheduler(executors={'default': executor})
-scheduler.add_job(send_daily_pings, trigger='interval', days=1)
+scheduler.add_job(send_daily_pings, trigger='interval', seconds=10)
 scheduler.start()
-"""
-
 
 
 # runs discord bot in thread = helps avoid blocking calls