Update ccc.py

ccc.py

@@ -15,9 +15,9 @@ BASE_URL = "https://tidal.com/browse/track/"
 
 # Configuration - Edit these values as needed
 START_TRACK_ID = 20753858  # Change this to your desired starting track ID
-TRACK_CHECK_INTERVAL = 0.01  # Reduced interval for faster checking
-WEBHOOK_INTERVAL = 5  # Reduced interval for faster updates
-MAX_CONCURRENT_DOWNLOADS = 100  # Increased concurrent downloads
+TRACK_CHECK_INTERVAL = 0.5  # Speed of checking in seconds (lower = faster)
+WEBHOOK_INTERVAL = 10  # Send webhook messages every 10 seconds
+MAX_CONCURRENT_DOWNLOADS = 30  # Maximum number of concurrent downloads
 
 # Queue to store messages to be sent to webhook
 webhook_queue = deque()
@@ -69,7 +69,7 @@ async def check_tidal_track(track_id):
         }
         
         async with aiohttp.ClientSession() as session:
-            async with session.get(url, headers=headers, timeout=3) as response:
+            async with session.get(url, headers=headers, timeout=5) as response:
                 # Check status code first - 200 means it exists, 404 means it doesn't
                 if response.status == 200:
                     content = await response.text()
@@ -108,7 +108,7 @@ async def tidal_downloader(track_id, song_name, artist_name):
 
     try:
         async with aiohttp.ClientSession() as session:
-            async with session.post(api_url, json=payload, timeout=5) as response:
+            async with session.post(api_url, json=payload) as response:
                 if response.status == 200:
                     data = await response.json()
 
@@ -132,8 +132,7 @@ async def tidal_downloader(track_id, song_name, artist_name):
 
 async def download_file(url):
     try:
-        timeout = aiohttp.ClientTimeout(total=15)  # 15 second timeout for downloads
-        async with aiohttp.ClientSession(timeout=timeout) as session:
+        async with aiohttp.ClientSession() as session:
             async with session.get(url) as response:
                 if response.status == 200:
                     # Read the file content directly into memory
@@ -150,8 +149,7 @@ async def upload_to_service(file_content, song_name, artist_name):
     try:
         upload_url = "https://jerrrycans-wholemusic.hf.space/upload"
         
-        timeout = aiohttp.ClientTimeout(total=30)  # 30 second timeout for uploads
-        async with aiohttp.ClientSession(timeout=timeout) as session:
+        async with aiohttp.ClientSession() as session:
             # Create form data with the correct file name
             form = aiohttp.FormData()
             form.add_field('file', 
@@ -164,7 +162,7 @@ async def upload_to_service(file_content, song_name, artist_name):
             form.add_field('artist', artist_name)
             
             # Send the POST request with a timeout
-            async with session.post(upload_url, data=form) as response:
+            async with session.post(upload_url, data=form, timeout=60) as response:
                 if response.status == 200:
                     result = await response.json()
                     print(f"Upload successful: {result}")
@@ -228,17 +226,13 @@ async def main():
     # Tasks list to manage concurrent jobs
     tasks = []
     
-    # Create connection pool with higher limits
-    connector = aiohttp.TCPConnector(limit=0, force_close=True)
-    session = aiohttp.ClientSession(connector=connector)
-    
     try:
         while True:
             # Cleanup completed tasks
             tasks = [t for t in tasks if not t.done()]
             
             # Create new tasks up to the maximum allowed concurrency
-            while len(tasks) < MAX_CONCURRENT_DOWNLOADS * 3:  # Allow more tasks in queue to maximize throughput
+            while len(tasks) < MAX_CONCURRENT_DOWNLOADS * 2:  # Allow more tasks in queue than concurrent downloads
                 task = asyncio.create_task(process_track(current_track_id, semaphore))
                 tasks.append(task)
                 current_track_id += 1
@@ -254,24 +248,6 @@ async def main():
         # Wait for all tasks to complete
         if tasks:
             await asyncio.gather(*tasks, return_exceptions=True)
-            
-        # Close the session
-        await session.close()
 
 if __name__ == "__main__":
-    # Configure to use a higher limit of open files if on Linux
-    try:
-        import resource
-        resource.setrlimit(resource.RLIMIT_NOFILE, (65536, 65536))
-    except Exception:
-        pass
-    
-    # Use uvloop if available for better performance
-    try:
-        import uvloop
-        uvloop.install()
-        print("Using uvloop for better performance")
-    except ImportError:
-        pass
-    
     asyncio.run(main())