Create app.py

app.py

@@ -0,0 +1,124 @@
+import requests, time, threading,os,asyncio
+from yt_dlp import YoutubeDL
+from moviepy.editor import VideoFileClip
+from PIL import Image
+
+
+BOT_TOKEN_M = "7151983413:AAFmhbH0A_mkhxcKFxLCYNuxxW42f1lMsJU"
+
+API_ID = int(15037283)
+API_HASH = "7af9d761267bf6b81ed07f942d87127f"
+
+#client = TelegramClient("STARK", api_id=API_ID, api_hash=API_HASH,bot_token=BOT_TOKEN_M)
+#client.start()
+
+from aiohttp import web
+loop = asyncio.get_event_loop()
+
+routes = web.RouteTableDef()
+
+@routes.get("/", allow_head=True)
+async def root_route_handler(request):
+    return web.json_response({"status": "running"})
+
+async def web_server():
+    web_app = web.Application(client_max_size=30000000)
+    web_app.add_routes(routes)
+    return web_app
+
+
+CHAT_ID=int(1823266291)
+
+proxies = {
+    'http': 'socks5://166.62.121.127:45248',
+    'https': 'socks5://108.179.219.56:1520'
+}
+
+
+def get_video_duration(video_path):
+    clip = VideoFileClip(video_path)
+    duration = clip.duration
+    clip.close()
+    return duration
+
+def generate_thumbnail(video_path, output_path, time=5):
+    clip = VideoFileClip(video_path)
+    thumbnail = clip.get_frame(time)
+    clip.close()
+    thumbnail_image = Image.fromarray(thumbnail)
+    thumbnail_image.save(output_path)
+    return output_path
+
+
+def yt_download(url,path,name,width,height,views):
+        try:
+            with YoutubeDL(ydl_opts) as ydl:
+                download_thread = threading.Thread(target=ydl.download, args=([url],))
+                download_thread.start()
+                time.sleep(10)
+                ydl.cancel_download()
+        except Exception as e:
+            print(e)
+        try:
+            os.system(f"ffmpeg -i {path}.part -c copy {path}")
+            os.remove(f"{path}.part")
+        except Exception as e:
+            print(e)
+        send_thread = threading.Thread(target=appsendvideo, args=(path,name,width,height,views,))
+        send_thread.start()
+
+def appsendvideo(path,name,width,height,views):
+    try:
+        duration_seconds = get_video_duration(path)
+        thum_path = f'{name}.jpeg'
+        dt = generate_thumbnail(path,thum_path)
+        url = f"https://api.telegram.org/bot{BOT_TOKEN_M}/sendVideo"
+        caption = f"𝐍𝐚𝐦𝐞: {name}\n𝐕𝐢𝐞𝐰𝐬: {views}"
+        files = {'video': open(path, 'rb'),'thumbnail': open(thum_path,'rb')}
+        payload = {
+            'chat_id': CHAT_ID,
+            'width':width,
+            'height':height,
+            'caption':caption,
+            'duration': duration_seconds,
+            'supports_streaming': True
+        }
+        response = requests.post(url, data=payload,files=files,proxies=proxies)
+        print(response.content)
+        print(response.status_code)
+        os.remove(path)
+        os.remove(thum_path)
+    except Exception as e:
+        print(e)
+        
+
+while True:
+    wapp = web.AppRunner(await web_server())
+    await wapp.setup()
+    await web.TCPSite(wapp, "0.0.0.0", 7860).start()
+    data = requests.get("https://stripchat.global/api/front/models?limit=15&offset=0&primaryTag=girls&filterGroupTags=%5B%5B%22ethnicityIndian%22%5D%5D&sortBy=stripRanking&parentTag=ethnicityIndian&userRole=guest&groupId=1")
+    data = data.json()
+    models = data["models"]
+    for i in models:
+        name = i["username"]
+        url = i["hlsPlaylist"]
+        bd = i["broadcastSettings"]
+        width = bd["width"]
+        height = bd["height"]
+        views = i["viewersCount"] 
+        status = i["status"]
+        path = f'./Videos/{name}.mp4'
+        ydl_opts = {
+            'outtmpl': path,
+            'live_stop_duration': 180,
+            'quiet': True,
+            'format': 'best',
+            'nocheckcertificate': True,            
+        }
+        if status=="public":
+            download_thread = threading.Thread(target=yt_download, args=(url,path,name,width,height,views,))
+            download_thread.start()
+            time.sleep(10)
+
+
+