Update ccc.py

ccc.py

@@ -0,0 +1,156 @@
+import aiohttp
+import time
+import asyncio
+import random
+import multiprocessing
+from dateutil import parser
+import os
+
+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/"
+
+assets_checked = multiprocessing.Value('i', 0)
+valid_assets_found = multiprocessing.Value('i', 0)
+
+last_used_ids = {}
+base_ids = {}
+
+async def send_to_discord(session, asset_id, name, creator_id, creator_name, creator_type, asset_type, created_date):
+    embed = {
+        "embeds": [
+            {
+                "url": f"https://www.roblox.com/library/{asset_id}",
+                "title": name or "Unknown Asset",
+                "thumbnail": {
+                    "url": f"https://rbxgleaks.pythonanywhere.com/asset/{asset_id}",
+                },
+                "fields": [
+                    {
+                        "name": "Creator Type",
+                        "value": creator_type or "Unknown",
+                        "inline": True
+                    },
+                    {
+                        "name": "Creator ID",
+                        "value": creator_id or "Unknown",
+                        "inline": True
+                    }
+                ],
+                "description": f"**Asset Type:** {asset_type}\n**ID:** ||{asset_id}||\n**Creator:** [{creator_name}](https://www.roblox.com/users/{creator_id}/profile)\n**Created:** {created_date}"
+            }
+        ],
+        "content": "",
+    }
+
+    try:
+        async with session.post(discord_webhook_url, json=embed) as response:
+            if response.status != 204:
+                print(f"Failed to send to Discord: {response.status}")
+    except Exception as e:
+        print(f"Failed to send to Discord: {e}")
+
+async def check_asset_batch(session, asset_ids):
+    global assets_checked, valid_assets_found
+    payload = [{"assetId": asset_id} for asset_id in asset_ids]
+
+    try:
+        async with session.post(api_batch_url, json=payload, headers={
+            'Content-Type': 'application/json',
+            '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
+
+                tasks = []
+                for asset_id in asset_ids:
+                    if any(result.get("assetId") == asset_id and not result.get("IsCopyrightProtected", True) for result in results):
+                        tasks.append(fetch_asset_info(session, asset_id))
+
+                await asyncio.gather(*tasks)
+
+    except Exception as e:
+        print(f"Failed to check asset batch: {e}")
+
+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)
+
+def parse_iso8601(date_str):
+    try:
+        return parser.isoparse(date_str)
+    except ValueError as e:
+        return None
+
+def generate_base_id():
+    base = random.randint(70000000000000, 140000000000000)
+    return str(base)
+
+def initialize_base_ids():
+    for digit in range(7, 15):
+        base_ids[digit] = generate_base_id()
+        last_used_ids[digit] = int(base_ids[digit])
+
+def generate_ids_batch(digit, batch_size=10000):
+    last_used_id = last_used_ids[digit]
+    offset = random.randint(-1000000, 1000000)
+    ids_batch = [str(last_used_id + offset + i) for i in range(batch_size)]
+    last_used_ids[digit] += batch_size
+    print(f"Generated batch for digit {digit} (first 4 IDs): {ids_batch[:4]} with offset {offset}")
+    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)
+
+async def print_status_periodically():
+    while True:
+        return
+
+def run_scanner_in_process(digit):
+    asyncio.run(run_scanner_instance(digit))
+
+if __name__ == "__main__":
+    initialize_base_ids()
+    processes = []
+    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()
+
+    asyncio.run(print_status_periodically())
+
+    for process in processes:
+        process.join()