Update app.py

app.py

@@ -4,12 +4,15 @@ from fastapi import FastAPI
 import uvicorn
 import asyncio
 import os
+import aiohttp
+from datetime import datetime
 
 app = FastAPI()
 
 TOKEN = os.environ['TOKEN']
 SERVER_ID = 1128366741995659296
 CHANNEL_ID = 1296102118326931596
+API_URL = "https://bloxfruitsapi.cloudflarescanner.workers.dev/"
 
 intents = discord.Intents.default()
 intents.message_content = True
@@ -18,6 +21,39 @@ tree = app_commands.CommandTree(bot)
 
 api_data = {}
 
+async def fetch_and_post():
+    channel = bot.get_channel(CHANNEL_ID)
+    if not channel:
+        return
+
+    async with aiohttp.ClientSession() as session:
+        try:
+            async with session.get(API_URL) as response:
+                if response.status == 200:
+                    data = await response.json()
+                    
+                    message = []
+                    
+                    if "normal" in data and data["normal"]:
+                        message.append("Normal")
+                        message.extend(data["normal"])
+                        message.append("")
+                    
+                    if "mirage" in data and data["mirage"]:
+                        message.append("Mirage")
+                        message.extend(data["mirage"])
+                    
+                    formatted_message = "\n".join(message)
+                    await channel.send(formatted_message)
+                    
+        except Exception as e:
+            print(f"errer: {e}")
+
+async def schedule_api_updates():
+    while True:
+        await fetch_and_post()
+        await asyncio.sleep(7200)
+
 @app.get("/")
 async def read_root():
     return api_data
@@ -26,32 +62,7 @@ async def read_root():
 async def on_ready():
     await tree.sync()
     print(f"{bot.user} is now online!")
-
-@bot.event
-async def on_message(message):
-    if message.author == bot.user or message.guild.id != SERVER_ID or message.channel.id != CHANNEL_ID:
-        return
-
-    content = message.content.strip().split('\n')
-    current_category = None
-    updated = False
-
-    # Clear existing data
-    api_data.clear()
-
-    for line in content:
-        line = line.strip()
-        if line.lower() in ["normal", "mirage"]:
-            current_category = line.lower()
-            if current_category not in api_data:
-                api_data[current_category] = []
-            updated = True
-        elif current_category and line:
-            api_data[current_category].append(line)
-            updated = True
-
-    if updated:
-        await message.channel.send("Posted in API")
+    asyncio.create_task(schedule_api_updates())
 
 @tree.command(name="clear", description="clear api")
 async def clear_api(interaction: discord.Interaction):
@@ -59,6 +70,11 @@ async def clear_api(interaction: discord.Interaction):
     api_data.clear()
     await interaction.response.send_message("cleared")
 
+@tree.command(name="forceupdate", description="force stock/ update")
+async def force_update(interaction: discord.Interaction):
+    await fetch_and_post()
+    await interaction.response.send_message("completed")
+
 async def run_bot():
     await bot.start(TOKEN)