Update ccc.py

ccc.py

@@ -1,15 +1,22 @@
 import aiohttp
-import time
 import asyncio
 import random
 import multiprocessing
 from dateutil import parser
 import os
 import logging
+from fastapi import FastAPI
+import uvicorn
 
 # Disable all logging except for critical errors
 logging.basicConfig(level=logging.CRITICAL)
 
+app = FastAPI()
+
+@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/"
@@ -142,21 +149,38 @@ async def print_status_periodically():
         print("Working")
         await asyncio.sleep(60)
 
-def run_scanner_in_process(digit):
-    asyncio.run(run_scanner_instance(digit))
-
-if __name__ == "__main__":
+async def scanner_main():
     initialize_base_ids()
-    processes = []
+    tasks = []
     instances_per_digit = 20000
     
     for i in range(instances_per_digit):
         digit = 7 + (i % 8)
-        process = multiprocessing.Process(target=run_scanner_in_process, args=(digit,))
-        processes.append(process)
-        process.start()
+        tasks.append(run_scanner_instance(digit))
+    
+    tasks.append(print_status_periodically())
+    await asyncio.gather(*tasks)
 
-    asyncio.run(print_status_periodically())
+def run_server_and_scanner():
+    loop = asyncio.new_event_loop()
+    asyncio.set_event_loop(loop)
+    
+    scanner_task = loop.create_task(scanner_main())
+    api_task = loop.create_task(
+        uvicorn.run(
+            app,
+            host="0.0.0.0",
+            port=7860,
+            loop=loop
+        )
+    )
+    
+    try:
+        loop.run_forever()
+    except KeyboardInterrupt:
+        pass
+    finally:
+        loop.close()
 
-    for process in processes:
-        process.join()
+if __name__ == "__main__":
+    run_server_and_scanner()