"""
@app.route('/')
def home(): return render_template_string(HTML_TEMPLATE)
@app.route('/api/extract', methods=['POST'])
def run():
def gen():
u = request.json.get('url')
yield f"data: {json.dumps({'type':'log','msg':'Initializing VIP Tunnel...'})}\\n\\n"
# --- VIP BYPASS OPTIONS ---
opts = {
'quiet': True,
'no_warnings': True,
'format': 'best',
'nocheckcertificate': True,
'ignoreerrors': True,
'no_color': True,
# TikTok & YouTube Bypass Headers
'http_headers': {
'User-Agent': 'Mozilla/5.0 (iPhone; CPU iPhone OS 17_4 like Mac OS X) AppleWebKit/605.1.15 (KHTML, like Gecko) Version/17.4 Mobile/15E148 Safari/604.1',
'Accept': 'text/html,application/xhtml+xml,application/xml;q=0.9,*/*;q=0.8',
'Accept-Language': 'en-US,en;q=0.9',
'Referer': 'https://www.google.com/',
}
}
try:
yield f"data: {json.dumps({'type':'log','msg':'Injecting Anti-Bot Headers...'})}\\n\\n"
with yt_dlp.YoutubeDL(opts) as ydl:
info = ydl.extract_info(u, download=False)
if not info:
raise Exception("Target platform blocked the extraction. Server IP blacklisted.")
yield f"data: {json.dumps({'type':'log','msg':'Parsing High-Quality Streams...'})}\\n\\n"
fmts = []
seen = set()
# Platform specific parsing
raw_fmts = info.get('formats', [])
if not raw_fmts:
fmts.append({'q': 'Original Quality', 'e': info.get('ext','mp4'), 'url': info.get('url')})
else:
for f in raw_fmts:
if f.get('url'):
# Filter for video+audio or just video for Instagram/TikTok
is_video = f.get('vcodec') != 'none' or info.get('extractor') in ['instagram', 'tiktok']
if is_video:
q = str(f.get('format_note') or f.get('resolution') or '720p')
if q not in seen:
fmts.append({'q': q, 'e': f.get('ext','mp4'), 'url': f.get('url')})
seen.add(q)
yield f"data: {json.dumps({'type':'res','title':info.get('title','VIP Video'),'thumb':info.get('thumbnail',''),'ext':info.get('extractor_key',''),'fmts':fmts[:6]})}\\n\\n"
except Exception as e:
err_msg = str(e)
if "status code 0" in err_msg or "Video not available" in err_msg:
err_msg = "TikTok/YouTube blocked Hugging Face. Try a different link or refresh."
yield f"data: {json.dumps({'type':'err','msg':err_msg})}\\n\\n"
return Response(stream_with_context(gen()), mimetype='text-event-stream')
if __name__ == '__main__':
app.run(host='0.0.0.0', port=7860)