testing daily pings

app.py

@@ -5,6 +5,8 @@ import gradio as gr
 from discord.ext import commands
 from slack_sdk import WebClient
 from slack_sdk.errors import SlackApiError
+import aiojobs
+from datetime import datetime, timedelta
 
 DISCORD_TOKEN = os.getenv('DISCORD_TOKEN')
 SLACK_BOT_TOKEN = os.getenv('BOT_USER_OAUTH_TOKEN_HF')
@@ -12,6 +14,7 @@ SLACK_BOT_TOKEN = os.getenv('BOT_USER_OAUTH_TOKEN_HF')
 # real = os.getenv('SLACK_CHANNEL_ID_HF')
 # test = 'C07B4KNU5BQ'
 SLACK_CHANNEL_ID = os.getenv('SLACK_CHANNEL_ID_HF')
+SLACK_CHANNEL_ID_TEST = 'C07B4KNU5BQ'
 # 1259415803879751700    = test forum
 # 1019883044724822016    = ask for help
 ASK_FOR_HELP_CHANNEL_ID = 1019883044724822016
@@ -42,6 +45,8 @@ TRIGGERS = {
     ("dataset", "feedback"): "<@U0768RCHCRY>", # ben burtenshaw
 }
 
+daily_pings = []
+
 intents = discord.Intents.all()
 intents.messages = True
 bot = commands.Bot(command_prefix='!', intents=intents)
@@ -64,13 +69,20 @@ async def on_message(message):
     # notification bot
     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
-        if bots_role not in message.author.roles: # bots shouldn't trigger pings for this
-            content = message.content.lower()
-            for trigger, slack_mention in TRIGGERS.items():
-                if all(word in content for word in trigger):         
-                    await post_to_slack(message.author, message.content, message.channel.name, message.jump_url, slack_mention, trigger)
-                    break
+    #if huggingfolks_role not in message.author.roles: # no need for ping if we're already discussing
+    if bots_role not in message.author.roles: # bots shouldn't trigger pings for this
+        content = message.content.lower()
+        for trigger, slack_mention in TRIGGERS.items():
+            if all(word in content for word in trigger):         
+                daily_pings.append({
+                    'author': str(message.author),
+                    'content': message.content,
+                    'channel': message.channel.name,
+                    'url': message.jump_url,
+                    'mention': slack_mention,
+                    'trigger': trigger
+                })
+                break
 
     # Check if the message is in a thread
     if isinstance(message.channel, discord.Thread):
@@ -127,8 +139,27 @@ def post_to_slack_create_thread(channel, text, thread_ts=None):
         print(f"Error posting to Slack: {e.response['error']}")
         return None        
 
-    #----------------------------------------------------------------------------------------------
+#----------------------------------------------------------------------------------------------
+async def collect_pings():
+    await bot.wait_until_ready()
+    while not bot.is_closed():
+        await aiojobs.create_scheduler().spawn(send_daily_pings())
+        await asyncio.sleep(60)
+
+async def send_daily_pings():
+    global daily_pings
+    if daily_pings:
+        # combine into one message
+        combined_message = '\n'.join(f"{ping['author']} in #{ping['channel']} said: {ping['content']} (link: {ping['url']})" for ping in daily_pings)
+        await post_to_slack(None, combined_message, SLACK_CHANNEL_ID_TEST, None, None, None)
+        daily_pings = []  # reset after posting
+
+
+
+
+
 
+# pings -------------------------------------------------------------------------------------------
 
 async def post_to_slack(author, content, channel, url, slack_mention, trigger):
     try:
@@ -142,6 +173,7 @@ async def post_to_slack(author, content, channel, url, slack_mention, trigger):
 
 # runs discord bot in thread = helps avoid blocking calls
 def run_bot():
+    bot.loop.create_task(collect_pings())
     bot.run(DISCORD_TOKEN)
 threading.Thread(target=run_bot).start()
 def greet(name):