27 KiB
unarr CLI agent — roadmap del diferenciador
Estado de partida: v0.9.19 beta (~26k LOC fuente / ~18k test). Objetivo estratégico: el agente CLI es el soporte real y diferenciador de unarr — un servidor de streaming personal que la web sola no puede ser. Compite en profundidad, no en anchura (no apps nativas por dispositivo: el agente sirve a un único web-player responsive vía navegador).
La visión en 6 puntos
- Hospeda localmente toda la biblioteca.
- Debrid para reproducir cualquier cosa cache-fast.
- Play-anything sin callejones (local | debrid | descarga-y-reproduce, con fallback mid-stream).
- Transcodifica según el dispositivo (direct-play cuando ya es compatible).
- Sirve a un web-player universal en cualquier dispositivo vía navegador.
- Acceso remoto seguro al agente.
Mapa de partida (qué TIENE el agente hoy)
Sólido salvo nota:
- Descarga torrent (anacrolix): mmap, DHT warm-start, 30 trackers, pause/cancel,
selección vídeo+subs
[engine/torrent.go]. Stream-while-download con reader responsive +PrioritizeTail[engine/stream.go]. - Usenet completo: NNTP pool, yEnc, ensamblado
WriteAt, resume por segmento, par2 repair, unrar/7z[usenet/*]. - Debrid downloader: GET con Range/resume
[engine/debrid.go]— pero solo DESCARGA (no streaming). Resolución server-side. - HLS transcode fMP4 + seek real + supervisor
[engine/hls.go], caché HLS LRU[engine/hls_cache.go], HW accel NVENC/QSV/VAAPI/VideoToolbox[engine/hwaccel.go]. - Servidor HTTP persistente: range/seek, rate-limit 2×bitrate, CORS
[engine/stream_server.go]. - Library scan + ffprobe (codec/HDR/tracks), parse título/temporada
[library/, mediainfo/]. - Red: CloudFlare Quick Tunnel
[funnel/], WireGuard userspace split-tunnel[vpn/], NAT-PMP + UPnP[engine/upnp.go]. Web hace de broker de URLs (LAN/Tailscale/Public/Funnel). - Agente: daemon cobra, sync HTTP long-poll +
/wake, auto-upgrade opt-in, config.toml exhaustivo.
Huecos (de más crítico a más bajo)
Hueco #1 — Auth de stream ✅ CERRADO (2026-05-31) / ver estado abajo
/stream y /hls se sirven sin autenticación (solo CORS+rate-limit). Con
funnel/UPnP el stream queda público en internet. Plan previo
Docs/plans/security-stream-token.md (deferido, sin código).
Hueco #2 — Debrid en el path de streaming 🔵 DISEÑADO (ver estado abajo)
Hoy debrid es solo descarga, resuelto server-side; el streaming es 100% torrent. La promesa "play instantáneo cache-fast" no ocurre. Falta: source debrid en el path de streaming + cache-availability + fallback torrent↔debrid mid-stream. Diseño por fases (2a direct-play / 2b HLS-desde-URL / 2c fallback) en el estado abajo.
Hueco #3 — Device-profile + direct-play + ABR 🔵 EN CURSO (ver estado abajo)
El path HLS siempre re-encoda (incluso mp4 h264/aac ya compatible). DecideAction
(passthrough/remux) existe pero muerto en el path browser. Sin negociación por
capacidades del dispositivo. Sin ABR multi-bitrate.
Diseño por fases (3a direct-play / 3b remux-HLS / 3c capability-negotiation / 3d ABR)
en el estado abajo. Fase 3a CERRADA (CLI c8d7c4b + web 636fbe59); 3b/3c/3d pendientes.
Hueco #4 — Pre-transcode (transcode-on-download) 🔵 DISEÑADO (ver estado abajo)
Al completar una descarga/import, transcodificar/remuxar en background para que el
PRIMER play sea instantáneo (direct o cache-HIT), sin transcode en vivo.
Optimización, nunca bloqueante: si no terminó a tiempo → fallback a transcode en
vivo (HLS actual). Reaprovecha hls_cache.go (cache-HIT ya sirve instantáneo) +
el pipeline de prewarm (ya hace encode de la siguiente ep) — generaliza prewarm a
"todo download, configurable" y puebla también el artefacto direct-play. Configurable
desde la web. Diseño + set de opciones en el estado abajo.
Huecos medios ⬜
- Sin gestión de espacio en disco (
Statfs) → disco lleno revienta a mitad. - Resume de torrent NO persiste reinicio del daemon (usenet sí).
- Sin seeding/ratio lifecycle (flags existen, nadie los aplica).
- Reproducir-mientras-baja: readahead estático 5MB, sin playhead→prioridad dinámica.
- HDR→SDR sin tonemap (zscale/zimg) → HDR desaturado.
- Sin thumbnails/sprites/trickplay.
- Subtítulos bitmap (PGS/DVB) sin burn-in.
- Audio siempre downmix estéreo AAC (sin passthrough 5.1).
- Mediaserver solo DETECTA Plex/Jellyfin/Emby — no biblioteca navegable propia.
- TLS solo vía funnel; LAN/Tailscale/UPnP = HTTP plano (mixed-content desde web HTTPS).
- Funnel = SPOF CloudFlare (rota ~6h), sin relay propio.
- "Tailscale Funnel" mal nombrado (no usa tsnet/Funnel real).
- Dos clientes HTTP divergentes (go-client vs agent client).
- Long-poll en vez de WS/SSE.
Deuda puntual
makeReadable parchea mmap 0000 (frágil NFS) · par2/unrar degradan en silencio si
falta binario · VAAPI workarounds por host · cloudflared sin verificación de firma ·
WireGuard endpoint sin pin · sesión única (1 viewer).
Mejoras detectadas durante el trabajo (backlog)
Se rellena a medida que se trabaja cada hueco. Cada entrada: qué, por qué, prioridad.
- Clock-skew en verificación de token (baja):
verifyStreamTokenno tolera skew; con TTL 6h y NTP es irrelevante, pero el HLS lo mintea el web y lo verifica el agente (relojes distintos). Considerar ~60s de gracia si aparecen 404 espurios. - Secreto de stream en claro en DB (baja):
agent_registration.stream_secretes una clave HMAC viva (por arranque) en la DB central; quien lea la DB puede mintear tokens HLS de cualquier agente. Inherente al diseño (el web debe mintear HLS). Mitigado por regeneración por arranque. Excluir esta columna de cualquier JSON admin/usuario. - Refrescar/limpiar streamUrl al re-registrar (baja): tras reinicio del daemon el secreto cambia; URLs
?t=ya guardadas endownload_task.streamUrlquedan stale hasta re-stream. Es auto-curativo, pero el web podría limpiar streamUrl en el re-register del agente. - gofmt preexistente en
internal/agent/types.go(StreamSession) yhls.go/torrent.go/stream_source.go(no introducido por este trabajo) — chore aparte. - Funnel = SPOF CloudFlare (ya en huecos medios): el funnel sigue siendo trycloudflare; relay propio pendiente.
ESTADO POR HUECO
Hueco #1 — Auth de stream
Estado: 🟡 en progreso (iniciado 2026-05-31).
Enfoque elegido (mejora sobre el plan previo, menor blast radius — sin migración DB):
token HMAC stateless minteado por el propio agente. El agente ya construye las
stream URLs que reporta a la web (daemon.go → streamSrv.URLsJSON()), así que
puede firmar el token, embeberlo en la URL, y verificarlo en cada request — la web
es passthrough (cambio web ~nulo).
- Secreto: 32 bytes random en memoria del daemon (rota al reiniciar).
- Token:
<expUnix>.<hexHMAC(secret, scope:exp)>, TTL 6h. /stream+ VLC: token en query?t=; scope"stream"./hls: token en path/hls/<sessionID>/<token>/<resource>; scope"hls:<sessionID>". Los URIs hijos de los playlists son relativos → el token se propaga solo a segmentos/subs sin reescribir playlists.- Loopback exento (mpv/vlc local + health-probe siguen funcionando; el token solo gatea acceso remoto LAN/Tailscale/Public/funnel).
- Config
require_stream_token(default true, seguro por defecto).
Hecho (CERRADO 2026-05-31):
CLI (torrentclaw-cli):
internal/engine/stream_token.go(nuevo):mintStreamToken/verifyStreamToken(HMAC-SHA256, constant-time),newStreamSecret(32 bytes; fail-hard si crypto/rand falla, sin fallback débil).internal/engine/stream_server.go: secreto +requireTokenen StreamServer;/streamy/hlsverifican el token;URLsJSON/hlsBaseURLs/URL()tokenizan;StreamSecretHex(); sin exención de loopback;/playlist.m3uya no auto-mintea (cerrado el oracle).internal/config/config.go:require_stream_token(default true).internal/agent/{types,daemon}.go+internal/cmd/daemon.go: el agente reporta el secreto en register solo si enforcing.- Tests:
stream_token_test.go(mint/verify/expiry/tamper/scope/secret, handler /stream + /hls, vector de paridad cross-lenguaje).
WEB (torrentclaw-web):
src/lib/stream-token.ts(nuevo): minter HMAC en TS (paridad byte a byte con Go, guard de clave 64-hex).src/app/api/internal/stream/session/route.ts:buildHlsUrlsinyecta el token de path usando el secreto del agente.src/lib/db/schema.ts+ migración0134_grey_chat.sql: columnaagent_registration.stream_secret(ADD COLUMN nullable, segura).src/app/api/internal/agent/register/route.ts+src/lib/services/agent.ts: valida (64-hex) + persiste + expone engetAgentHealth.- Tests:
tests/unit/stream-token.test.ts(paridad + guard).
Revisión adversarial (workflow 4 dimensiones) → 1 crítico + 3 high corregidos antes de cerrar:
- CRÍTICO: la exención de loopback dejaba el funnel CloudFlare sin protección (cloudflared proxya tráfico público vía
localhost→ todo el funnel llegaba como loopback). Fix: eliminada la exención. Toda URL entregada ya va tokenizada, así que ningún cliente legítimo se rompe; el funnel ahora lleva el token en la URL y verifica. - HIGH
/playlist.m3uera oracle de tokens (fallback self-minting) → fix: 404 sin streamUrl. - HIGH gate de version-skew mal señalizado (el agente reportaba el secreto aunque enforcement=off) → fix: reportar solo si enforcing.
- HIGH new-agent+old-web rompe HLS remoto → mitigación por orden de deploy (ver abajo), sin tolerar tokenless (no reabrir el agujero).
Verificación: CLI go build/vet/test ./... ✓; WEB typecheck+lint+2325 unit ✓; paridad cross-lenguaje verificada en ambos sentidos.
⚠️ ORDEN DE DEPLOY (obligatorio): desplegar primero el WEB (columna
stream_secret+ minteo HLS), luego publicar el binario del agente. Un agente nuevo (enforce por defecto) contra un web viejo (sin minteo HLS) rompería el HLS remoto. El web es retrocompatible (agente viejo sin secreto → URLs sin token). Smoke real de extremo a extremo (daemon + funnel + navegador) pendiente de hacer con un agente desplegado — los tests cubren mint/verify/handlers y la paridad, no el round-trip cloudflared en vivo.
Hueco #2 — Debrid en el path de streaming
Estado: 🔵 DISEÑADO (2026-05-31), listo para implementar en sesión fresca.
Problema (confirmado en el análisis): hoy debrid es solo descarga
(engine/debrid.go baja la DirectURL HTTPS resuelta server-side). El
streaming es 100% torrent: daemon.OnStreamSession arma el provider desde
sess.FilePath/sess.InfoHash/sess.TaskID y StreamSession no lleva
DirectURL. La promesa "play instantáneo cache-fast por debrid" no ocurre.
Arquitectura de providers (lo que ya hay): FileProvider{ NewFileReader(ctx) io.ReadSeekCloser; FileName(); FileSize() }. Implementaciones: torrentFileProvider,
diskFileProvider, StreamEngine. El /stream sirve un FileProvider via
http.ServeContent (range/seek). El HLS arranca una HLSSession desde una ruta
de fichero (ffmpeg -i <path>).
Diseño por fases (de menos a más riesgo):
-
Fase 2a — debrid como fuente de /stream (direct-play). Slice completo y acotado.
- Añadir
DirectURL stringaStreamSession(web→agente) y a su validación. - Nuevo
debridFileProvider(FileProvider):NewFileReaderdevuelve unio.ReadSeekCloserque hace GET con Range contra laDirectURL(debrid ya soporta Range, verdebrid.go);FileSizevia HEAD osess.FileSize;Seektraducido aRange:. Reutilizar la lógica dedebrid.go(416, Content-Range, reintentos). - En
OnStreamSession: sisess.DirectURLpresente →debridFileProvider→SetFile. (Direct-play; el navegador hace range sobre el provider.) - Web: al crear la sesión de stream, si el contenido está cacheado en
debrid, resolver la
DirectURLserver-side (como en descargas) e incluirla en elStreamSession. Señal de cache:debridCacheStatusfresh (ya existe). - Tests:
debridFileProvidercon un httptest server que sirve Range; round-trip /stream con provider debrid.
- Añadir
-
Fase 2b — HLS desde URL (transcode de fuentes debrid no-compatibles). ffmpeg lee HTTP directo (
-i https://…), así queHLSSessionpuede aceptar una URL como source en vez de una ruta. Mayor cambio en el pipeline HLS (timeouts, reintentos de red, headers). Permite transcodear contenido debrid. -
Fase 2c — selección cache-fast + fallback mid-stream ("sin callejones").
- Conciencia de cache en el agente o señal del web para preferir debrid
cacheado sobre torrent cuando aplique (hoy
resolve.go:22pone torrent primero). - Fallback mid-stream: si la fuente activa muere (peers a 0 / 5xx debrid), cambiar a la otra sin cortar la reproducción. Complejo (estado de sesión, re-seek). Es lo que de verdad cierra "play-anything sin callejones".
- Conciencia de cache en el agente o señal del web para preferir debrid
cacheado sobre torrent cuando aplique (hoy
Ficheros a tocar: CLI internal/engine/{stream_server.go (provider), debrid.go, hls.go (2b)}, internal/agent/types.go (+DirectURL), internal/cmd/daemon.go
(wiring). WEB src/app/api/internal/stream/session/route.ts (resolver DirectURL +
cache), src/lib/services/agent.ts.
Partes difíciles / riesgos: ranged reader robusto sobre HTTP (reconexión, timeouts), HLS-desde-URL (red dentro de ffmpeg), y el fallback mid-stream (estado). Empezar por 2a (valor inmediato, riesgo bajo), 2b y 2c como iteraciones.
Mejora detectada: resolve.go:22 ordena torrent > debrid > usenet; para el
diferenciador cache-fast convendría que, cuando hay cache debrid confirmada,
el orden de STREAMING (no el de descarga) prefiera debrid.
Hueco #3 — Device-profile + direct-play + ABR
Estado: 🔵 EN CURSO (2026-05-31). Análisis cerrado; fase 3a en implementación.
Problema (confirmado en el análisis):
- El path browser usa HLS y SIEMPRE re-encoda:
buildHLSFFmpegArgsAt(engine/hls.go) pone-c:v libx264|nvenc|…+ cadena de filtros completa (scale/format/setparams) + AAC, sin rama de copia. Un mp4 h264/aac 8-bit SDR que el navegador reproduciría tal cual se transcodifica entero. Coste de CPU puro desperdicio. DecideAction+diskFileSource/transcodeSource(engine/probe.go,engine/stream_source.go) son código muerto: cero callers en producción, solo tests. Distinguenpassthrough/remux/remux-audio/transcode-videoy detectan 10-bit/HDR — la lógica de decisión ya existe, no está cableada.
Lo que ya hay y se reaprovecha:
- El agente ya expone dos paths en el StreamServer (puerto 11818):
/stream→ sirve el fichero crudo conhttp.ServeContent(HTTP Range completo, sin ffmpeg, ya tokenizado). Direct-play ya es posible aquí./hls/<id>/…→ transcode HLS.
- El web construye las URLs (HLS hoy) desde la info de red del agente
(
streamPort,tailscaleIp,lanIp,funnelUrl,streamSecret) y puede mintear tokens (mintStreamToken, scopestreames constante). O sea: el web puede construir la URL/stream?t=…de direct-play él mismo. libraryItemya guarda del scan:videoCodec,audioCodec,bitDepth,hdr,resolution. Con el contenedor (extensión defileName), el web tiene todo para decidir direct-play SIN re-probar.
Diseño por fases (de menos a más riesgo):
-
Fase 3a — direct-play passthrough para items de biblioteca. El web decide. Slice acotado, ambos sentidos de version-skew seguros vía gate de versión.
- WEB
decidePlayMethod({videoCodec,audioCodec,bitDepth,hdr,container})→"direct" | "hls"(espeja la rama passthrough de GoDecideAction: solomp4/m4v+h264+aac+ 8-bit + SDR → direct; todo lo demás → hls). - WEB gate:
supportsDirectPlay(agentVersion)(constante de versión mínima). Direct-play solo si el agente la soporta; si no → hls (sin regresión). - WEB sesión: en la rama
libraryItemPublicId, seleccionar los campos codec; calcularplayMethod(gated); persistirlo enstreamingSession.play_method(migración aditiva,db:generate); devolverplayMethod+streamUrls(/stream?t=minteadas por el web, lan/ts/funnel) en la respuesta. - WEB sync:
getPendingStreamSessionsemiteplayMethodal agente. - CLI:
StreamSession.PlayMethod string; enOnStreamSession, siPlayMethod=="direct"→streamSrv.SetFile(NewDiskFileProvider(path))+MarkSessionReady(sin ffmpeg). Else →StartHLSSession(actual). - WEB player (
HlsStreamPlayer.tsx): sidata.playMethod==="direct"→ usardata.streamUrls+ attach nativo<video src>(mp4 = reproducible en todo navegador, sin hls.js). Else → flujo HLS actual.
- Limitación honesta: solo cubre items de biblioteca (escaneados, con
metadata codec). Raw
infoHash/taskId→ hls (sin probe). Cubrir esos casos = fase 3a-bis (el agente decide tras probar, reportando playMethod porMarkSessionReady— requiere extender el payload + SSE + diferir el attach del player al evento ready). Diferido por mayor superficie.
- WEB
-
Fase 3b — remux HLS (
-c:v copy) para contenedores no-mp4 compatibles. Casomkvh264/aac (no direct-playable por contenedor).-c:v copyevita el re-encode de vídeo. Parte difícil: con-c copyffmpeg corta segmentos en keyframes del GOP origen → duraciones variables que NO casan con el manifiesto pre-renderizado uniforme (renderVideoPlaylist) → rompe seek/playback. Hay que servir el manifiesto que genera ffmpeg (no el pre-render) o reescribir el seek. Mayor que 3a. -
Fase 3c — capability negotiation (device-profile). El web envía
{maxHeight, codecs:[h264,hevc,av1], containers}(de UA +canPlayType).decidePlayMethodse hace device-aware: p.ej. Safari/AppleTV que reproduce HEVC nativo → passthrough HEVC en vez de transcode HEVC→h264. Reemplaza el heurístico UA-burdo deresolveAutoQuality. Web+CLI. -
Fase 3d — ABR multi-bitrate. Ladder de renditions en el master playlist + N pipelines ffmpeg / segmentos por rendition. Alto esfuerzo, baja prioridad; el modelo single-viewer reduce su valor. Último.
Ficheros a tocar (3a): CLI internal/agent/types.go (+PlayMethod),
internal/cmd/daemon.go (branch SetFile vs HLS). WEB
src/lib/services/agent-version-compare.ts (gate), src/lib/stream/play-method.ts
(nuevo), src/lib/stream-token.ts (scope stream), src/lib/db/schema.ts +
migración (streamingSession.play_method), src/app/api/internal/stream/session/route.ts
(decisión + URLs), src/lib/services/agent.ts (getPendingStreamSessions emite
playMethod), src/components/stream/HlsStreamPlayer.tsx (attach nativo).
Seguridad de version-skew (3a):
- Web nuevo + agente viejo: gate
supportsDirectPlayve versión vieja → hls. ✓ - Web viejo + agente nuevo: web nunca manda
direct→ agente hls. ✓ - Campo
PlayMethoddesconocido en agente viejo = ignorado por el unmarshal. ✓
Empezar por 3a (valor inmediato — el caso primario de unarr es la biblioteca local escaneada; mp4-h264-aac es común en web-dl/YIFY). 3b/3c/3d como iteraciones.
Hecho (Fase 3a CERRADA 2026-05-31):
- CLI (
feat/unarr-agentc8d7c4b):StreamSession.PlayMethod;OnStreamSessionramificadirect→SetFile(NewDiskFileProvider)+MarkSessionReady(sin ffmpeg, antes del check de ffmpeg para funcionar con transcode off).go buildvet+ tests verdes.
- WEB (
feat/unarr-brand636fbe59):decidePlayMethod()(espeja la rama passthrough de Go, conservador) + test unitario; gatesupportsDirectPlay(DIRECT_PLAY_MIN_VERSION = 0.10.0); decisión en la ruta de sesión (solo library item + sin downscale +audioIndex == -1);buildStreamUrlsmintea token scopestream(paridad Go);streaming_session.play_method(migración 0135) emitido al agente víagetPendingStreamSessions; player ramifica a<video src>nativo. lint + typecheck:all + 2333 unit + build (brand unarr) OK. - Revisión adversarial (correctness + security/parity, 2 agentes): 0 hallazgos bloqueantes. Token parity y version-skew (ambos sentidos) confirmados.
Correcciones de la revisión propia (3a): direct-play exige audioIndex == -1
(servir el fichero entero no respeta una pista de audio no-default elegida por el
usuario → esos casos van a HLS con -map 0:a:N).
Smoke e2e (3a) — PASADO 2026-05-31 (agente dev 0.10.0 build local + item de
biblioteca mp4-h264-aac /mnt/nas/peliculas/.../Tangled.Ever.After...mp4 + browser):
- POST
/api/internal/stream/session→playMethod: direct,streamUrlscon/stream?t=(token web scopestream),hlsUrls: null. ✓ - Agente:
[stream …] direct-play: Tangled…mp4(SetFile, sin ffmpeg). ✓ /stream: HEAD 200video/mp4Content-Length 128321419; GET Range 0-1023 → 206 + bytes mp4 reales (ftyp isom…avc1). Token web verificado por Go → paridad cross-lenguaje confirmada en vivo (sin token → 404). ✓- CORS desde origen browser (
localhost:3030): ACAO correcto, preflight 204. ✓ - Browser:
<video>.currentSrc=/stream?t=…(NO/hls),readyState 4, reproduciéndose, 1920×1080 nativo, 13 reqs/stream, 0/hls, attach nativo ([hls] (native) loadedmetadata, sin hls.js). Telemetría metric/progress OK. ✓
Bug pre-existente encontrado + arreglado durante el smoke (web 764f5b01): el
allow-list de la marca unarr (src/lib/branding/routes.ts) NO incluía
/api/internal/agent ni /api/internal/stream → en unarr el agente daba 404 al
registrar y el player 404 al crear sesión. El streaming + agente de unarr estaban
rotos de raíz. Añadidos al allow-list (superficie del agente/media propio del
usuario, cero superficie torrent).
Nota de release: versión bumpeada a 0.10.0 (version.go, CLI 944d652) — solo
binario local para el smoke, sin publicar nada. DIRECT_PLAY_MIN_VERSION = 0.10.0
(web 52d958f0). Al publicar la release real del CLI, debe ser >= 0.10.0.
Backlog detectado en 3a (baja prioridad):
streaming_session.transportqueda"hls"también para sesiones direct (el enumTRANSPORT_VALUESsolo tiene"hls"); telemetría imprecisa, no bug. Añadir"direct"al vocabulario cuando se toque la métrica.- Modelo single-viewer: dos plays direct simultáneos → el último
SetFilegana; el tab viejo reproduciría contenido nuevo en silencio (HLS al menos 404ea). - Direct-play no aplica
audioIndexni extrae subs a WebVTT (usa pistas embebidas vía<video>nativo); subs bitmap no se ven. Aceptable en 3a. - Listener
loadedmetadata {once:true}del attach nativo no se limpia explícitamente en cleanup (idempotente, impacto nulo).
Hueco #4 — Pre-transcode (transcode-on-download)
Estado: 🔵 DISEÑADO (2026-05-31), pendiente de implementar.
Qué es: al completar una descarga (o import a biblioteca), procesar en background para que la reproducción sea instantánea sin transcode en vivo. Es una optimización: si no terminó cuando el usuario da play → fallback al transcode en vivo (HLS actual). Nunca bloquea.
Sinergia con lo existente (clave — gran parte de la infra ya está):
hls_cache.go: un encode HLS completo se cachea y el cache-HIT lo sirve instantáneo (cero ffmpeg). Pre-transcode = poblar esa cache antes del play.stream-prewarm.ts+createPrewarmSession: ya lanza un encode HLS de la siguiente ep en background. Pre-transcode = generalizar prewarm a "cualquier download, configurable", + producir también el artefacto direct-play (3a).- Por tanto el trabajo NUEVO es: (1) disparador on-download-complete, (2) superficie de config en web, (3) gobernanza de recursos + cola, (4) decisión "qué producir" (remux mp4 para 3a vs HLS cache vs nada si ya es native).
Opciones a exponer en la web (set propuesto):
-
Activación + disparador
- Toggle global on/off (default OFF — CPU/disco intensivo).
- Disparador: al completar descarga / al escanear-importar / manual ("optimizar ahora" por item) / programado (ventana horaria).
- Default recomendado: on-download-complete, pero solo en ventana idle + sin stream en vivo activo.
-
Qué producir (target) — modo Auto recomendado (por probe):
- ya browser-native (mp4 h264/aac 8-bit SDR) → nada (3a lo sirve crudo).
- solo contenedor incompatible (mkv h264/aac) → remux a mp4 (barato, sin re-encode; habilita 3a direct-play). (necesita 3b para el manifiesto.)
- codec incompatible (HEVC/AV1/10-bit/HDR) → transcode a H.264 (caro).
- Modos: solo-remux / remux+transcode / forzar H.264 universal.
- Formato salida: mp4 direct-play (seek nativo) vs HLS cache (multi-network) vs ambos. Recomendado: mp4 si compatible, HLS si requiere transcode.
-
Calidad
- Mantener original (passthrough cuando se pueda) / cap 1080p / ladder ABR (480/720/1080/original — encaja con 3d).
- "Solo transcodear si ayuda" (no tocar lo ya compatible).
-
Selección / alcance
- Todo / solo biblioteca (pelis+series) / solo lo problemático (p.ej. solo 4K HEVC, dejar h264).
- Solo watchlist / recién añadido / todo. Reglas por carpeta de biblioteca.
-
Gobernanza de recursos (lo más importante — es pesado):
- Concurrencia (N transcodes paralelos, default 1).
- HW accel si disponible (nvenc/qsv/vaapi); cap de threads CPU.
- Ventana horaria (solo idle, p.ej. 02:00–08:00).
- Pausar cuando hay stream en vivo (no pelear por CPU con la reproducción).
- Prioridad de cola (watchlist primero / más pequeño primero / más nuevo).
- (Laptops) solo con AC / no en batería.
-
Disco / retención (liga con el hueco medio de espacio en disco):
- Dónde guardar (cache dir) + tamaño máx + evicción LRU (ya parcial en cache).
- Mantener SIEMPRE el original; el transcode es artefacto adicional.
- TTL: borrar pre-transcode no visto en N días; pin a visto/favorito.
- Re-transcodear al cambiar la config de calidad (invalidación).
-
UX / estado
- Cola + progreso por item en la web ("Optimizando para reproducción instantánea…"). Badge en library card: "listo para play instantáneo" vs "se transcodificará al reproducir". Notificación al terminar (opcional).
-
Fallback / límites
- Si no terminó a tiempo → transcode en vivo (HLS). Nunca bloquea el play.
- Solo ficheros locales en disco (no debrid/torrent sin bajar).
MVP recomendado (fase 4a): toggle on/off + disparador on-download-complete +
modo Auto (remux-si-compatible / transcode-si-no) + concurrencia 1 +
pausar-si-stream-activo + reusar hls_cache + badge "listo". El resto (ladder
ABR, ventanas horarias, reglas por carpeta, TTL avanzado, formato mp4 vs HLS
configurable) en fases 4b/4c.
Dependencias: el camino mp4/remux depende del hueco #3 (3a ya hecho; 3b para
el remux-a-mp4 con manifiesto correcto). El camino HLS-cache es implementable ya
(reusa cache + prewarm). La gobernanza (pausar-si-stream) necesita señal de
"stream activo" en el daemon (la hay: streamSrv.HasFile() + registro HLS).