Update app.py

app.py

@@ -249,6 +249,24 @@ async def top_gradio(ctx, channel_id):
         top_list = "\n".join([f"{member.name}: {count}" for member, count in sorted_users[:50]])
         print(f"Message count per user in the channel:\n{top_list}")
 
+
+@bot.command()
+async def top_gradio_threads(ctx, channel_id):
+    if ctx.author.id == 811235357663297546:    
+        message_counts = {}
+        try:
+            channel = await bot.fetch_channel(channel_id)
+            threads = await channel.fetch_threads(limit=None)
+            for thread in threads:
+                async for message in thread.history(limit=None):
+                    message_counts[message.author] = message_counts.get(message.author, 0) + 1
+        except discord.Forbidden:
+            print(f"Missing access to read messages in {channel.name}")
+
+        sorted_users = sorted(message_counts.items(), key=lambda x: x[1], reverse=True)
+        top_list = "\n".join([f"{member.name}: {count}" for member, count in sorted_users[:50]])
+        print(f"Message count per user in the channel:\n{top_list}")
+
         
 """"""
 DISCORD_TOKEN = os.environ.get("DISCORD_TOKEN", None)