Update ccc.py

ccc.py

@@ -1,32 +1,15 @@
 import aiohttp
+import time
 import asyncio
 import random
 import multiprocessing
 from dateutil import parser
 import os
 import logging
-from fastapi import FastAPI
-import uvicorn
-from contextlib import asynccontextmanager
 
 # Disable all logging except for critical errors
 logging.basicConfig(level=logging.CRITICAL)
 
-@asynccontextmanager
-async def lifespan(app: FastAPI):
-    # Startup
-    initialize_base_ids()
-    asyncio.create_task(start_scanner())
-    yield
-    # Shutdown
-    # Add any cleanup code here if needed
-
-app = FastAPI(lifespan=lifespan)
-
-@app.get("/")
-async def root():
-    return {"status": "running"}
-
 discord_webhook_url = os.environ['webhook']
 api_batch_url = "https://epic-alligator-77.deno.dev/post"
 asset_info_url = "https://economy.roproxy.com/v2/assets/"
@@ -159,16 +142,21 @@ async def print_status_periodically():
         print("Working")
         await asyncio.sleep(60)
 
-async def start_scanner():
-    tasks = []
+def run_scanner_in_process(digit):
+    asyncio.run(run_scanner_instance(digit))
+
+if __name__ == "__main__":
+    initialize_base_ids()
+    processes = []
     instances_per_digit = 20000
     
     for i in range(instances_per_digit):
         digit = 7 + (i % 8)
-        tasks.append(run_scanner_instance(digit))
-    
-    tasks.append(print_status_periodically())
-    await asyncio.gather(*tasks)
+        process = multiprocessing.Process(target=run_scanner_in_process, args=(digit,))
+        processes.append(process)
+        process.start()
 
-if __name__ == "__main__":
-    uvicorn.run(app, host="0.0.0.0", port=7860)
+    asyncio.run(print_status_periodically())
+
+    for process in processes:
+        process.join()