Update ccc.py

ccc.py

@@ -47,7 +47,7 @@ async def send_to_discord(session, asset_id, name, creator_id, creator_name, cre
         async with session.post(discord_webhook_url, json=embed) as response:
             if response.status != 204:
                 pass
-    except Exception:
+    except (aiohttp.ClientError, ConnectionError):
         pass
 
 async def check_asset_batch(session, asset_ids):
@@ -60,10 +60,8 @@ async def check_asset_batch(session, asset_ids):
             'Requester': 'Client',
             'User-Agent': 'Roblox/WinInetRobloxApp'
         }) as response:
-
             if response.status == 200:
                 results = await response.json()
-
                 if not results or (isinstance(results, list) and all("errors" in result for result in results)):
                     return
 
@@ -73,35 +71,37 @@ async def check_asset_batch(session, asset_ids):
                         tasks.append(fetch_asset_info(session, asset_id))
 
                 await asyncio.gather(*tasks)
-
-    except Exception:
+    except (aiohttp.ClientError, ConnectionError):
         pass
 
 async def fetch_asset_info(session, asset_id):
     global assets_checked, valid_assets_found
-    with assets_checked.get_lock():
-        assets_checked.value += 1
-
-    async with session.get(f"{asset_info_url}{asset_id}/details") as asset_info_response:
-        if asset_info_response.status == 200:
-            asset_info = await asset_info_response.json()
-
-            name = asset_info.get("Name", "Unknown")
-            asset_type = asset_info.get("AssetTypeId", "Unknown")
-            creator = asset_info.get("Creator", {})
-            creator_id = creator.get("Id", "Unknown")
-            creator_name = creator.get("Name", "Unknown")
-            creator_type = creator.get("CreatorType", "Unknown")
-            created_date_str = asset_info.get("Created", "Unknown")
-            created_date = parse_iso8601(created_date_str)
-            if created_date:
-                created_date_formatted = created_date.strftime("%Y-%m-%d %H:%M:%S")
-            else:
-                created_date_formatted = "Unknown"
-
-            with valid_assets_found.get_lock():
-                valid_assets_found.value += 1
-            await send_to_discord(session, asset_id, name, creator_id, creator_name, creator_type, asset_type, created_date_formatted)
+    try:
+        with assets_checked.get_lock():
+            assets_checked.value += 1
+
+        async with session.get(f"{asset_info_url}{asset_id}/details") as asset_info_response:
+            if asset_info_response.status == 200:
+                asset_info = await asset_info_response.json()
+
+                name = asset_info.get("Name", "Unknown")
+                asset_type = asset_info.get("AssetTypeId", "Unknown")
+                creator = asset_info.get("Creator", {})
+                creator_id = creator.get("Id", "Unknown")
+                creator_name = creator.get("Name", "Unknown")
+                creator_type = creator.get("CreatorType", "Unknown")
+                created_date_str = asset_info.get("Created", "Unknown")
+                created_date = parse_iso8601(created_date_str)
+                if created_date:
+                    created_date_formatted = created_date.strftime("%Y-%m-%d %H:%M:%S")
+                else:
+                    created_date_formatted = "Unknown"
+
+                with valid_assets_found.get_lock():
+                    valid_assets_found.value += 1
+                await send_to_discord(session, asset_id, name, creator_id, creator_name, creator_type, asset_type, created_date_formatted)
+    except (aiohttp.ClientError, ConnectionError):
+        pass
 
 def parse_iso8601(date_str):
     try:
@@ -126,10 +126,13 @@ def generate_ids_batch(digit, batch_size=10000):
     return ids_batch
 
 async def run_scanner_instance(digit):
-    async with aiohttp.ClientSession() as session:
-        while True:
-            batch = generate_ids_batch(digit)
-            await check_asset_batch(session, batch)
+    while True:
+        try:
+            async with aiohttp.ClientSession() as session:
+                batch = generate_ids_batch(digit)
+                await check_asset_batch(session, batch)
+        except (aiohttp.ClientError, ConnectionError):
+            continue
 
 async def print_status_periodically():
     while True: