Update ccc.py

ccc.py

@@ -4,6 +4,7 @@ import random
 from dateutil import parser
 import os
 import logging
+import time
 
 # Disable all logging except for critical errors
 logging.basicConfig(level=logging.CRITICAL)
@@ -12,6 +13,8 @@ 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/"
 
+last_working_time = time.time()
+
 async def send_to_discord(session, asset_id, name, creator_id, creator_name, creator_type, asset_type, created_date):
     embed = {
         "embeds": [
@@ -110,10 +113,20 @@ async def run_scanner_instance(digit, semaphore):
                 await asyncio.sleep(1)
 
 async def print_status_periodically():
+    global last_working_time
     while True:
         print("Working")
+        last_working_time = time.time()
         await asyncio.sleep(60)
 
+async def check_restart():
+    global last_working_time
+    while True:
+        if time.time() - last_working_time > 180:  # 3 minutes
+            print("Restarting due to inactivity")
+            os._exit(1)  # Force restart
+        await asyncio.sleep(10)
+
 async def main():
     semaphore = asyncio.Semaphore(100)  # Limit concurrent tasks
     tasks = []
@@ -121,6 +134,7 @@ async def main():
         digit = 7 + (i % 8)
         tasks.append(run_scanner_instance(digit, semaphore))
     tasks.append(print_status_periodically())
+    tasks.append(check_restart())
     await asyncio.gather(*tasks)
 
 if __name__ == "__main__":