#!/usr/bin/env python3
"""Ultimate Stream - search & play movies via browser.
Usage: python3 stream.py [port]
Then open http://192.168.1.50:8800 from any device."""
import os, sys, json, html, re, urllib.request, urllib.parse
from http.server import HTTPServer, BaseHTTPRequestHandler
HOST = '0.0.0.0'
PORT = int(sys.argv[1]) if len(sys.argv) > 1 else 8800
# TorrServer
TS_HOST = '127.0.0.1'
TS_PORT = 8090
# Torrentio API (free, no account needed)
TORRENTIO = 'https://torrentio.stremio.fun'
HEADERS = {'User-Agent': 'UltimateStream/1.0'}
def ts_get(path):
try:
r = urllib.request.urlopen(f'http://{TS_HOST}:{TS_PORT}{path}', timeout=10)
return r.read()
except: return b''
def ts_post_json(path, data):
try:
req = urllib.request.Request(f'http://{TS_HOST}:{TS_PORT}{path}',
data=json.dumps(data).encode(), headers={'Content-Type':'application/json'})
return urllib.request.urlopen(req, timeout=10).read()
except: return b''
def ts_alive():
try:
r = urllib.request.urlopen(f'http://{TS_HOST}:{TS_PORT}/echo', timeout=2)
return bool(r.read())
except: return False
def search_torrentio(imdb_id, media_type='movie'):
"""Search via Torrentio API by IMDb ID"""
typ = 'movie' if media_type == 'movie' else 'series'
url = f'{TORRENTIO}/sort=seeders&quality=*&stream/{typ}/{imdb_id}.json'
try:
r = urllib.request.urlopen(urllib.request.Request(url, headers=HEADERS), timeout=15)
data = json.loads(r.read())
streams = data.get('streams', [])
results = []
for s in streams:
ih = s.get('infoHash', '')
title = s.get('title', 'Unknown')
name = s.get('name', '')
if not ih: continue
results.append({'hash': ih, 'title': title, 'name': name,
'size': s.get('size', 0), 'seeders': s.get('seeders', 0)})
return results
except: return None
def search_tmdb(query):
"""Search TMDB for a movie/TV show to get IMDb ID"""
q = urllib.parse.quote(query)
url = f'https://api.tmdb.org/3/search/movie?api_key=7e4d48e68abb9a4f2c86a1cc143cd8b5&query={q}'
try:
r = urllib.request.urlopen(urllib.request.Request(url, headers=HEADERS), timeout=10)
data = json.loads(r.read())
return [{
'id': m['id'],
'title': m.get('title', m.get('name', '')),
'year': (m.get('release_date') or '')[:4],
'imdb': '', # Will need separate IMDB lookup
'poster': f"https://image.tmdb.org/t/p/w154{m['poster_path']}" if m.get('poster_path') else '',
'overview': (m.get('overview') or '')[:200],
} for m in data.get('results', [])[:10]]
except: return None
def search_tmdb_tv(query):
q = urllib.parse.quote(query)
url = f'https://api.tmdb.org/3/search/tv?api_key=7e4d48e68abb9a4f2c86a1cc143cd8b5&query={q}'
try:
r = urllib.request.urlopen(urllib.request.Request(url, headers=HEADERS), timeout=10)
data = json.loads(r.read())
return [{
'id': m['id'],
'title': m.get('name', ''),
'year': (m.get('first_air_date') or '')[:4],
'imdb': '',
'poster': f"https://image.tmdb.org/t/p/w154{m['poster_path']}" if m.get('poster_path') else '',
'overview': (m.get('overview') or '')[:200],
} for m in data.get('results', [])[:10]]
except: return None
def get_imdb_id(tmdb_id, media_type='movie'):
"""Get IMDb ID from TMDB ID"""
url = f'https://api.themoviedb.org/3/{media_type}/{tmdb_id}/external_ids?api_key=7e4d48e68abb9a4f2c86a1cc143cd8b5'
try:
r = urllib.request.urlopen(urllib.request.Request(url, headers=HEADERS), timeout=10)
data = json.loads(r.read())
return data.get('imdb_id', '')
except: return ''
def detect_quality(title):
t = title.lower()
if any(x in t for x in ['2160', '4k', 'uhd']): return '4K'
if '1080' in t: return '1080p'
if '720' in t: return '720p'
return 'SD'
def fmt_size(b):
if not b: return '?'
g = b / 1073741824
return f'{g:.2f} GB' if g >= 1 else f'{b/1048576:.0f} MB'
# ── Clean shutdown ──
class Handler(BaseHTTPRequestHandler):
def do_GET(self):
parsed = urllib.parse.urlparse(self.path)
params = urllib.parse.parse_qs(parsed.query)
path = parsed.path
if path == '/player':
return self.serve_player(params.get('hash', [''])[0],
params.get('title', ['Movie'])[0])
if path == '/stream':
return self.proxy_stream(params)
if path == '/torrents':
return self.list_torrents()
if path.startswith('/ts/'):
return self.proxy_ts(path[4:])
self.serve_index(params)
def serve_index(self, params):
query = params.get('q', [''])[0]
media_type = params.get('type', ['movie'])[0]
ts_ok = ts_alive()
ts_s = '● Live' if ts_ok else '● Offline'
results_html = ''
search_results = []
if query:
if media_type == 'movie':
search_results = search_tmdb(query)
else:
search_results = search_tmdb_tv(query)
if search_results:
rows = []
for r in search_results:
poster = r.get('poster', '')
yr = r.get('year', '')
overview = html.escape(r.get('overview', ''))
rows.append(f'''
{html.escape(r['title'])} ({yr})
{overview}
→
''')
results_html = '
' + ''.join(rows) + '
'
elif query:
results_html = '
No results found
'
# TorrServer torrents list
torrents_html = ''
if ts_ok:
try:
tlist = json.loads(ts_post_json('/torrents', {"action":"list"}) or '[]')
if isinstance(tlist, list) and tlist:
items = []
for t in tlist[:20]:
h = t.get('hash', '')[:16]
nm = html.escape(t.get('title', t.get('name', h))[:40])
st = t.get('status', '')
items.append(f'
{results_html}
{torrents_html}
'''
self.send_response(200)
self.send_header('Content-Type', 'text/html; charset=utf-8')
self.end_headers()
self.wfile.write(page.encode())
def serve_player(self, hash_val, title):
if not hash_val and not title:
self.send_response(302); self.send_header('Location', '/'); self.end_headers(); return
# If we have a hash, add to TorrServer and get stream URL
stream_url = ''
ts_ok = ts_alive()
if hash_val and ts_ok:
# Add magnet to TorrServer
magnet = f'magnet:?xt=urn:btih:{hash_val}'
try:
ts_post_json('/torrents', {"action":"add","link":magnet,"save_to_db":True})
except: pass
stream_url = f'/ts/play?hash={hash_val}&file_id=0'
page = f'''
{html.escape(title)} - Ultimate Stream
{'' if stream_url else 'Connecting to TorrServer... '}
'''
hack = '''
let h = new URL(location).searchParams.get('hash');
if(h && !document.getElementById('v')) {
let check = setInterval(() => {
fetch('/ts/play?hash='+h+'&file_id=0', {method:'HEAD'}).then(r => {
if(r.ok || r.status==206) {
clearInterval(check);
document.querySelector('.player-wrap').innerHTML =
"";
document.getElementById('s').textContent = 'Stream ready!';
}
}).catch(()=>{});
}, 2000);
}'''
self.send_response(200)
self.send_header('Content-Type', 'text/html; charset=utf-8')
self.end_headers()
self.wfile.write(page.encode())
def proxy_stream(self, params):
"""Proxy stream from TorrServer through us (avoids CORS issues)"""
hash_val = params.get('hash', [''])[0]
file_id = params.get('file_id', ['0'])[0]
if not hash_val:
self.send_response(400); self.end_headers(); return
ts_url = f'http://{TS_HOST}:{TS_PORT}/play?hash={hash_val}&file_id={file_id}'
try:
ts_resp = urllib.request.urlopen(urllib.request.Request(ts_url, headers=HEADERS), timeout=30)
self.send_response(200)
self.send_header('Content-Type', ts_resp.headers.get('Content-Type', 'video/mp4'))
self.send_header('Content-Length', ts_resp.headers.get('Content-Length', ''))
self.send_header('Accept-Ranges', 'bytes')
self.end_headers()
while True:
chunk = ts_resp.read(65536)
if not chunk: break
self.wfile.write(chunk)
except Exception as e:
self.send_response(502)
self.send_header('Content-Type', 'text/plain')
self.end_headers()
self.wfile.write(f'Stream error: {e}'.encode())
def proxy_ts(self, path):
"""Generic proxy to TorrServer API"""
try:
ts_resp = urllib.request.urlopen(
urllib.request.Request(f'http://{TS_HOST}:{TS_PORT}/{path}', headers=HEADERS), timeout=30)
data = ts_resp.read()
ct = ts_resp.headers.get('Content-Type', 'application/octet-stream')
self.send_response(200)
self.send_header('Content-Type', ct)
self.send_header('Content-Length', str(len(data)))
self.send_header('Accept-Ranges', 'bytes')
self.send_header('Access-Control-Allow-Origin', '*')
self.end_headers()
self.wfile.write(data)
except Exception as e:
self.send_response(502)
self.end_headers()
self.wfile.write(str(e).encode())
def list_torrents(self):
ts_ok = ts_alive()
page = f'''
Torrents - Ultimate Stream
Torrents on Server
'''
if ts_ok:
try:
tlist = json.loads(ts_post_json('/torrents', {"action":"list"}) or '[]')
if isinstance(tlist, list):
for t in tlist[:50]:
h = t.get('hash','')[:16]
nm = html.escape(t.get('title',t.get('name','Unknown'))[:50])
st = t.get('status','')
page += f'