Update ccc.py

ccc.py

@@ -5,6 +5,10 @@ import random
 import multiprocessing
 from dateutil import parser
 import os
+import logging
+
+# Disable all logging except for critical errors
+logging.basicConfig(level=logging.CRITICAL)
 
 discord_webhook_url = os.environ['webhook']
 api_batch_url = "https://epic-alligator-77.deno.dev/post"
@@ -45,9 +49,8 @@ async def send_to_discord(session, asset_id, name, creator_id, creator_name, cre
 
     try:
         async with session.post(discord_webhook_url, json=embed) as response:
-            if response.status != 204:
-                pass
-    except (aiohttp.ClientError, ConnectionError):
+            await response.text()
+    except (aiohttp.ClientError, asyncio.TimeoutError, ConnectionError):
         pass
 
 async def check_asset_batch(session, asset_ids):
@@ -71,7 +74,7 @@ async def check_asset_batch(session, asset_ids):
                         tasks.append(fetch_asset_info(session, asset_id))
 
                 await asyncio.gather(*tasks)
-    except (aiohttp.ClientError, ConnectionError):
+    except (aiohttp.ClientError, asyncio.TimeoutError, ConnectionError):
         pass
 
 async def fetch_asset_info(session, asset_id):
@@ -100,7 +103,7 @@ async def fetch_asset_info(session, asset_id):
                 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):
+    except (aiohttp.ClientError, asyncio.TimeoutError, ConnectionError):
         pass
 
 def parse_iso8601(date_str):
@@ -131,8 +134,8 @@ async def run_scanner_instance(digit):
             async with aiohttp.ClientSession() as session:
                 batch = generate_ids_batch(digit)
                 await check_asset_batch(session, batch)
-        except (aiohttp.ClientError, ConnectionError):
-            continue
+        except (aiohttp.ClientError, asyncio.TimeoutError, ConnectionError):
+            await asyncio.sleep(1)  # Add a small delay before retrying
 
 async def print_status_periodically():
     while True: