Instancia transcoder t2: snapshot

2026-07-13 15:20:15 +00:00
21 changed files with 2582 additions and 164 deletions
@@ -0,0 +1,10 @@
+# Copiar a .env y ajustar
+PORT=3000
+JWT_SECRET=cambia_esto_en_produccion
+
+# Backend Xtream (Dispatcharr en tu red)
+# Ejemplo: http://10.10.10.101:9191
+# En la UI de KiraTV añades una fuente Xtream con la misma URL y usuario/contraseña de Dispatcharr.
+
+# Opcional: si usas balanceador dedicado solo para /api/transcode, la app debe generar URLs absolutas
+# con ese host (requiere cambios en front); por defecto mismo origen vía reverse proxy en 10.10.10.115
@@ -46,7 +46,7 @@ nodecast-tv is a modern, web-based IPTV player featuring Live TV, EPG, Movies (V

 1.  Clone the repository:
    ```bash
-    git clone https://github.com/yourusername/nodecast-tv.git
+    git clone https://github.com/technomancer702/nodecast-tv.git
    cd nodecast-tv
    ```

@@ -114,7 +114,7 @@ Ensure you have the [NVIDIA Container Toolkit](https://docs.nvidia.com/datacente
          devices:
            - driver: nvidia
              count: 1
-              capabilities: [gpu]
+              capabilities: [gpu, utility, video, compute]
 ```

 **Verify:**
@@ -0,0 +1,869 @@
+diff --git a/public/index.html b/public/index.html
+index dd74211..9205ef7 100644
+--- a/public/index.html
+++ b/public/index.html
+@@ -9,7 +9,7 @@
+   <meta name="mobile-web-app-capable" content="yes">
+   <title>nodecast-tv | IPTV Player</title>
+   <meta name="description" content="Stream live TV, movies, and series with EPG support">
+-  <link rel="icon" type="image/svg+xml" href="/favicon.svg">
+  <link rel="icon" type="image/svg+xml" href="favicon.svg">
+   <link rel="stylesheet" href="css/main.css">
+   <link rel="preconnect" href="https://fonts.googleapis.com">
+   <link rel="preconnect" href="https://fonts.gstatic.com" crossorigin>
+@@ -1095,20 +1095,20 @@
+   </div>
+ 
+   <!-- JavaScript -->
+-  <script src="/js/icons.js"></script>
+-  <script src="/js/api.js?v=2"></script>
+-  <script src="/js/components/VideoPlayer.js?v=2"></script>
+-  <script src="/js/components/ChannelList.js?v=3"></script>
+-  <script src="/js/components/SourceManager.js?v=2"></script>
+-  <script src="/js/components/EpgGuide.js?v=2"></script>
+-  <script src="/js/pages/HomePage.js?v=2"></script>
+-  <script src="/js/pages/LivePage.js?v=2"></script>
+-  <script src="/js/pages/Guide.js?v=2"></script>
+-  <script src="/js/pages/MoviesPage.js?v=4"></script>
+-  <script src="/js/pages/SeriesPage.js?v=1"></script>
+-  <script src="/js/pages/Settings.js?v=2"></script>
+-  <script src="/js/pages/WatchPage.js?v=1"></script>
+-  <script src="/js/app.js?v=4"></script>
+  <script src="js/icons.js"></script>
+  <script src="js/api.js?v=2"></script>
+  <script src="js/components/VideoPlayer.js?v=2"></script>
+  <script src="js/components/ChannelList.js?v=3"></script>
+  <script src="js/components/SourceManager.js?v=2"></script>
+  <script src="js/components/EpgGuide.js?v=2"></script>
+  <script src="js/pages/HomePage.js?v=2"></script>
+  <script src="js/pages/LivePage.js?v=2"></script>
+  <script src="js/pages/Guide.js?v=2"></script>
+  <script src="js/pages/MoviesPage.js?v=4"></script>
+  <script src="js/pages/SeriesPage.js?v=1"></script>
+  <script src="js/pages/Settings.js?v=2"></script>
+  <script src="js/pages/WatchPage.js?v=1"></script>
+  <script src="js/app.js?v=4"></script>
+   <script>
+     // Check for SSO token in URL
+     (function () {
+@@ -1125,4 +1125,4 @@
+   </script>
+ </body>
+ 
+-</html>
+\ No newline at end of file
+</html>
+diff --git a/public/js/api.js b/public/js/api.js
+index 77b1306..ed4b354 100644
+--- a/public/js/api.js
+++ b/public/js/api.js
+@@ -24,7 +24,7 @@ const API = {
+             options.body = JSON.stringify(data);
+         }
+ 
+-        const response = await fetch(`/api${endpoint}`, options);
+        const response = await fetch(`api/${endpoint}`, options);
+ 
+         let result;
+         const contentType = response.headers.get('content-type');
+@@ -39,7 +39,7 @@ const API = {
+             // If unauthorized, redirect to login
+             if (response.status === 401) {
+                 localStorage.removeItem('authToken');
+-                window.location.href = '/login.html';
+                window.location.href = 'login.html';
+                 return;
+             }
+             throw new Error(result.error || `Server responded with ${response.status}`);
+@@ -50,37 +50,37 @@ const API = {
+ 
+     // Sources
+     sources: {
+-        getAll: () => API.request('GET', '/sources'),
+-        getByType: (type) => API.request('GET', `/sources/type/${type}`),
+-        getById: (id) => API.request('GET', `/sources/${id}`),
+-        create: (data) => API.request('POST', '/sources', data),
+-        update: (id, data) => API.request('PUT', `/sources/${id}`, data),
+-        delete: (id) => API.request('DELETE', `/sources/${id}`),
+-        toggle: (id) => API.request('POST', `/sources/${id}/toggle`),
+-        test: (id) => API.request('POST', `/sources/${id}/test`),
+-        sync: (id) => API.request('POST', `/sources/${id}/sync`), // Manual sync
+-        getStatus: () => API.request('GET', '/sources/status'), // Get all statuses
+-        estimate: (id) => API.request('GET', `/sources/${id}/estimate`), // Estimate M3U size
+-        estimateByUrl: (url, type) => API.request('POST', '/sources/estimate', { url, type }), // Estimate by URL (before creation)
+        getAll: () => API.request('GET', 'sources'),
+        getByType: (type) => API.request('GET', `sources/type/${type}`),
+        getById: (id) => API.request('GET', `sources/${id}`),
+        create: (data) => API.request('POST', 'sources', data),
+        update: (id, data) => API.request('PUT', `sources/${id}`, data),
+        delete: (id) => API.request('DELETE', `sources/${id}`),
+        toggle: (id) => API.request('POST', `sources/${id}/toggle`),
+        test: (id) => API.request('POST', `sources/${id}/test`),
+        sync: (id) => API.request('POST', `sources/${id}/sync`), // Manual sync
+        getStatus: () => API.request('GET', 'sources/status'), // Get all statuses
+        estimate: (id) => API.request('GET', `sources/${id}/estimate`), // Estimate M3U size
+        estimateByUrl: (url, type) => API.request('POST', 'sources/estimate', { url, type }), // Estimate by URL (before creation)
+     },
+ 
+     // Channels (hidden items)
+     channels: {
+-        getHidden: (sourceId = null) => API.request('GET', `/channels/hidden${sourceId ? `?sourceId=${sourceId}` : ''}`),
+-        hide: (sourceId, itemType, itemId) => API.request('POST', '/channels/hide', { sourceId, itemType, itemId }),
+-        show: (sourceId, itemType, itemId) => API.request('POST', '/channels/show', { sourceId, itemType, itemId }),
+-        isHidden: (sourceId, itemType, itemId) => API.request('GET', `/channels/hidden/check?sourceId=${sourceId}&itemType=${itemType}&itemId=${itemId}`),
+-        bulkHide: (items) => API.request('POST', '/channels/hide/bulk', { items }),
+-        bulkShow: (items) => API.request('POST', '/channels/show/bulk', { items }),
+        getHidden: (sourceId = null) => API.request('GET', `channels/hidden${sourceId ? `?sourceId=${sourceId}` : ''}`),
+        hide: (sourceId, itemType, itemId) => API.request('POST', 'channels/hide', { sourceId, itemType, itemId }),
+        show: (sourceId, itemType, itemId) => API.request('POST', 'channels/show', { sourceId, itemType, itemId }),
+        isHidden: (sourceId, itemType, itemId) => API.request('GET', `channels/hidden/check?sourceId=${sourceId}&itemType=${itemType}&itemId=${itemId}`),
+        bulkHide: (items) => API.request('POST', 'channels/hide/bulk', { items }),
+        bulkShow: (items) => API.request('POST', 'channels/show/bulk', { items }),
+         // Fast bulk operations - single SQL statement
+-        showAll: (sourceId, contentType) => API.request('POST', '/channels/show/all', { sourceId, contentType }),
+-        hideAll: (sourceId, contentType) => API.request('POST', '/channels/hide/all', { sourceId, contentType })
+        showAll: (sourceId, contentType) => API.request('POST', 'channels/show/all', { sourceId, contentType }),
+        hideAll: (sourceId, contentType) => API.request('POST', 'channels/hide/all', { sourceId, contentType })
+     },
+ 
+     // Favorites
+     favorites: {
+         getAll: (sourceId = null, itemType = null) => {
+-            let url = '/favorites';
+            let url = 'favorites';
+             const params = [];
+             if (sourceId) params.push(`sourceId=${sourceId}`);
+             if (itemType) params.push(`itemType=${itemType}`);
+@@ -88,84 +88,84 @@ const API = {
+             return API.request('GET', url);
+         },
+         add: (sourceId, itemId, itemType = 'channel') =>
+-            API.request('POST', '/favorites', { sourceId, itemId, itemType }),
+            API.request('POST', 'favorites', { sourceId, itemId, itemType }),
+         remove: (sourceId, itemId, itemType = 'channel') =>
+-            API.request('DELETE', '/favorites', { sourceId, itemId, itemType }),
+            API.request('DELETE', 'favorites', { sourceId, itemId, itemType }),
+         check: (sourceId, itemId, itemType = 'channel') =>
+-            API.request('GET', `/favorites/check?sourceId=${sourceId}&itemId=${itemId}&itemType=${itemType}`)
+            API.request('GET', `favorites/check?sourceId=${sourceId}&itemId=${itemId}&itemType=${itemType}`)
+     },
+ 
+     // Proxy
+     proxy: {
+         // Xtream
+         xtream: {
+-            auth: (sourceId) => API.request('GET', `/proxy/xtream/${sourceId}/auth`),
+            auth: (sourceId) => API.request('GET', `proxy/xtream/${sourceId}/auth`),
+             liveCategories: (sourceId, options = {}) => {
+                 const params = options.includeHidden ? '?includeHidden=true' : '';
+-                return API.request('GET', `/proxy/xtream/${sourceId}/live_categories${params}`);
+                return API.request('GET', `proxy/xtream/${sourceId}/live_categories${params}`);
+             },
+             liveStreams: (sourceId, categoryId = null, options = {}) => {
+                 const params = [];
+                 if (categoryId) params.push(`category_id=${categoryId}`);
+                 if (options.includeHidden) params.push('includeHidden=true');
+                 const query = params.length ? `?${params.join('&')}` : '';
+-                return API.request('GET', `/proxy/xtream/${sourceId}/live_streams${query}`);
+                return API.request('GET', `proxy/xtream/${sourceId}/live_streams${query}`);
+             },
+             vodCategories: (sourceId, options = {}) => {
+                 const params = options.includeHidden ? '?includeHidden=true' : '';
+-                return API.request('GET', `/proxy/xtream/${sourceId}/vod_categories${params}`);
+                return API.request('GET', `proxy/xtream/${sourceId}/vod_categories${params}`);
+             },
+             vodStreams: (sourceId, categoryId = null, options = {}) => {
+                 const params = [];
+                 if (categoryId) params.push(`category_id=${categoryId}`);
+                 if (options.includeHidden) params.push('includeHidden=true');
+                 const query = params.length ? `?${params.join('&')}` : '';
+-                return API.request('GET', `/proxy/xtream/${sourceId}/vod_streams${query}`);
+                return API.request('GET', `proxy/xtream/${sourceId}/vod_streams${query}`);
+             },
+             seriesCategories: (sourceId, options = {}) => {
+                 const params = options.includeHidden ? '?includeHidden=true' : '';
+-                return API.request('GET', `/proxy/xtream/${sourceId}/series_categories${params}`);
+                return API.request('GET', `proxy/xtream/${sourceId}/series_categories${params}`);
+             },
+             series: (sourceId, categoryId = null, options = {}) => {
+                 const params = [];
+                 if (categoryId) params.push(`category_id=${categoryId}`);
+                 if (options.includeHidden) params.push('includeHidden=true');
+                 const query = params.length ? `?${params.join('&')}` : '';
+-                return API.request('GET', `/proxy/xtream/${sourceId}/series${query}`);
+                return API.request('GET', `proxy/xtream/${sourceId}/series${query}`);
+             },
+             seriesInfo: (sourceId, seriesId) =>
+-                API.request('GET', `/proxy/xtream/${sourceId}/series_info?series_id=${seriesId}`),
+-            shortEpg: (sourceId, streamId) => API.request('GET', `/proxy/xtream/${sourceId}/short_epg?stream_id=${streamId}`),
+                API.request('GET', `proxy/xtream/${sourceId}/series_info?series_id=${seriesId}`),
+            shortEpg: (sourceId, streamId) => API.request('GET', `proxy/xtream/${sourceId}/short_epg?stream_id=${streamId}`),
+             getStreamUrl: (sourceId, streamId, type = 'live', container = 'm3u8') =>
+-                API.request('GET', `/proxy/xtream/${sourceId}/stream/${streamId}/${type}?container=${container}`)
+                API.request('GET', `proxy/xtream/${sourceId}/stream/${streamId}/${type}?container=${container}`)
+         },
+ 
+         // EPG
+         epg: {
+-            get: (sourceId) => API.request('GET', `/proxy/epg/${sourceId}`),
+-            getForChannels: (sourceId, channelIds) => API.request('POST', `/proxy/epg/${sourceId}/channels`, { channelIds })
+            get: (sourceId) => API.request('GET', `proxy/epg/${sourceId}`),
+            getForChannels: (sourceId, channelIds) => API.request('POST', `proxy/epg/${sourceId}/channels`, { channelIds })
+         },
+ 
+         // Cache management
+         cache: {
+-            clear: (sourceId) => API.request('DELETE', `/proxy/cache/${sourceId}`)
+            clear: (sourceId) => API.request('DELETE', `proxy/cache/${sourceId}`)
+         }
+     },
+ 
+     // Settings
+     settings: {
+-        get: () => API.request('GET', '/settings'),
+-        update: (data) => API.request('PUT', '/settings', data),
+-        reset: () => API.request('DELETE', '/settings'),
+-        getDefaults: () => API.request('GET', '/settings/defaults')
+        get: () => API.request('GET', 'settings'),
+        update: (data) => API.request('PUT', 'settings', data),
+        reset: () => API.request('DELETE', 'settings'),
+        getDefaults: () => API.request('GET', 'settings/defaults')
+     },
+ 
+     // Users (admin only)
+     users: {
+-        getAll: () => API.request('GET', '/auth/users'),
+-        create: (data) => API.request('POST', '/auth/users', data),
+-        update: (id, data) => API.request('PUT', `/auth/users/${id}`, data),
+-        delete: (id) => API.request('DELETE', `/auth/users/${id}`)
+        getAll: () => API.request('GET', 'auth/users'),
+        create: (data) => API.request('POST', 'auth/users', data),
+        update: (id, data) => API.request('PUT', `auth/users/${id}`, data),
+        delete: (id) => API.request('DELETE', `auth/users/${id}`)
+     }
+ };
+ 
+diff --git a/public/js/app.js b/public/js/app.js
+index c4d2f8c..f00dc38 100644
+--- a/public/js/app.js
+++ b/public/js/app.js
+@@ -169,13 +169,13 @@ class App {
+ 
+         if (!token) {
+             // No token, redirect to login (replace to avoid back button issues)
+-            window.location.replace('/login.html');
+            window.location.replace('login.html');
+             return;
+         }
+ 
+         try {
+             // Verify token with server
+-            const response = await fetch('/api/auth/me', {
+            const response = await fetch('api/auth/me', {
+                 headers: {
+                     'Authorization': `Bearer ${token}`
+                 }
+@@ -201,7 +201,7 @@ class App {
+         } catch (err) {
+             console.error('Authentication error:', err);
+             localStorage.removeItem('authToken');
+-            window.location.replace('/login.html');
+            window.location.replace('login.html');
+         }
+     }
+ 
+@@ -225,7 +225,7 @@ class App {
+ 
+             const token = localStorage.getItem('authToken');
+             if (token) {
+-                await fetch('/api/auth/logout', {
+                await fetch('api/auth/logout', {
+                     method: 'POST',
+                     headers: {
+                         'Authorization': `Bearer ${token}`
+@@ -234,7 +234,7 @@ class App {
+             }
+ 
+             localStorage.removeItem('authToken');
+-            window.location.replace('/login.html');
+            window.location.replace('login.html');
+         });
+ 
+         navbar.appendChild(logoutLink);
+@@ -283,7 +283,7 @@ document.addEventListener('DOMContentLoaded', () => {
+     window.app = new App();
+ 
+     // Fetch and display version badge
+-    fetch('/api/version')
+    fetch('api/version')
+         .then(res => res.json())
+         .then(data => {
+             const badge = document.getElementById('version-badge');
+diff --git a/public/js/components/ChannelList.js b/public/js/components/ChannelList.js
+index e8da5ad..2047dbf 100644
+--- a/public/js/components/ChannelList.js
+++ b/public/js/components/ChannelList.js
+@@ -33,10 +33,10 @@ class ChannelList {
+      * Only proxies HTTP URLs when on HTTPS page
+      */
+     getProxiedImageUrl(url) {
+-        if (!url || url.length === 0) return '/img/placeholder.png';
+        if (!url || url.length === 0) return 'img/placeholder.png';
+         // Only proxy if we're on HTTPS and the image is HTTP
+         if (window.location.protocol === 'https:' && url.startsWith('http://')) {
+-            return `/api/proxy/image?url=${encodeURIComponent(url)}`;
+            return `api/proxy/image?url=${encodeURIComponent(url)}`;
+         }
+         return url;
+     }
+@@ -510,7 +510,7 @@ class ChannelList {
+                data-render-id="${renderId}"
+                data-render-group="${renderGroup}">
+             <img class="channel-logo" src="${this.getProxiedImageUrl(channel.tvgLogo)}" 
+-                 alt="" onerror="this.onerror=null;this.src='/img/placeholder.png'">
+                 alt="" onerror="this.onerror=null;this.src='img/placeholder.png'">
+             <div class="channel-info">
+               <div class="channel-name">${this.escapeHtml(channel.name)}</div>
+               <div class="channel-program">${this.escapeHtml(this.getProgramInfo(channel) || '')}</div>
+@@ -623,7 +623,7 @@ class ChannelList {
+                data-render-id="${renderId}"
+                data-render-group="${renderGroup}">
+             <img class="channel-logo" src="${this.getProxiedImageUrl(channel.tvgLogo)}" 
+-                 alt="" onerror="this.onerror=null;this.src='/img/placeholder.png'">
+                 alt="" onerror="this.onerror=null;this.src='img/placeholder.png'">
+             <div class="channel-info">
+               <div class="channel-name">${this.escapeHtml(channel.name)}</div>
+               <div class="channel-program">${this.escapeHtml(this.getProgramInfo(channel) || '')}</div>
+@@ -1052,7 +1052,7 @@ class ChannelList {
+ 
+         div.innerHTML = `
+             <img class="channel-logo" src="${this.getProxiedImageUrl(channel.tvgLogo)}" 
+-                 alt="" onerror="this.onerror=null;this.src='/img/placeholder.png'">
+                 alt="" onerror="this.onerror=null;this.src='img/placeholder.png'">
+             <div class="channel-info">
+               <div class="channel-name">${this.escapeHtml(channel.name)}</div>
+               <div class="channel-program">${this.getProgramInfo(channel) || ''}</div>
+@@ -1305,7 +1305,7 @@ class ChannelList {
+             <div class="epg-info-modal">
+                 <div class="channel-details">
+                     <img class="channel-logo" src="${this.getProxiedImageUrl(channel.tvgLogo)}" 
+-                         onerror="this.onerror=null;this.src='/img/placeholder.png'" />
+                         onerror="this.onerror=null;this.src='img/placeholder.png'" />
+                     <div class="channel-meta">
+                         <p><strong>Group:</strong> ${this.escapeHtml(channel.groupTitle || 'Uncategorized')}</p>
+                         <p><strong>Source:</strong> ${channel.sourceType}</p>
+diff --git a/public/js/components/EpgGuide.js b/public/js/components/EpgGuide.js
+index ce4a01d..7b0da96 100644
+--- a/public/js/components/EpgGuide.js
+++ b/public/js/components/EpgGuide.js
+@@ -43,10 +43,10 @@ class EpgGuide {
+      * Only proxies HTTP URLs when on HTTPS page
+      */
+     getProxiedImageUrl(url) {
+-        if (!url || url.length === 0) return '/img/placeholder.png';
+        if (!url || url.length === 0) return 'img/placeholder.png';
+         // Only proxy if we're on HTTPS and the image is HTTP
+         if (window.location.protocol === 'https:' && url.startsWith('http://')) {
+-            return `/api/proxy/image?url=${encodeURIComponent(url)}`;
+            return `api/proxy/image?url=${encodeURIComponent(url)}`;
+         }
+         return url;
+     }
+@@ -212,7 +212,7 @@ class EpgGuide {
+         // Load EPG from ALL sources in parallel
+         const fetchPromises = sources.map(async (source) => {
+             try {
+-                const response = await fetch(`/api/proxy/epg/${source.id}${queryParams}`);
+                const response = await fetch(`api/proxy/epg/${source.id}${queryParams}`);
+                 if (!response.ok) throw new Error(`Status ${response.status}`);
+                 return await response.json();
+             } catch (e) {
+@@ -596,7 +596,7 @@ class EpgGuide {
+               ${isFavorite ? Icons.favorite : Icons.favoriteOutline}
+             </button>
+             <img class="epg-channel-logo" src="${logo}" 
+-                 alt="" onerror="this.onerror=null;this.src='/img/placeholder.png'">
+                 alt="" onerror="this.onerror=null;this.src='img/placeholder.png'">
+             <span class="epg-channel-name">${name}</span>
+             <div class="resize-handle"></div>
+           </div>
+diff --git a/public/js/components/VideoPlayer.js b/public/js/components/VideoPlayer.js
+index a089dab..ac3b71c 100644
+--- a/public/js/components/VideoPlayer.js
+++ b/public/js/components/VideoPlayer.js
+@@ -805,7 +805,7 @@ class VideoPlayer {
+     async startTranscodeSession(url, options = {}) {
+         try {
+             console.log('[Player] Starting HLS transcode session...', options);
+-            const res = await fetch('/api/transcode/session', {
+            const res = await fetch('api/transcode/session', {
+                 method: 'POST',
+                 headers: { 'Content-Type': 'application/json' },
+                 body: JSON.stringify({ url, ...options })
+@@ -817,7 +817,7 @@ class VideoPlayer {
+         } catch (err) {
+             console.error('[Player] Session start failed:', err);
+             // Fallback to direct transcode if session fails
+-            return `/api/transcode?url=${encodeURIComponent(url)}`;
+            return `api/transcode?url=${encodeURIComponent(url)}`;
+         }
+     }
+ 
+@@ -829,7 +829,7 @@ class VideoPlayer {
+             console.log('[Player] Stopping transcode session:', this.currentSessionId);
+             try {
+                 // Fire and forget cleanup
+-                fetch(`/api/transcode/${this.currentSessionId}`, { method: 'DELETE' });
+                fetch(`api/transcode/${this.currentSessionId}`, { method: 'DELETE' });
+             } catch (err) {
+                 console.error('Failed to stop session:', err);
+             }
+@@ -865,7 +865,7 @@ class VideoPlayer {
+             if (this.settings.autoTranscode) {
+                 console.log('[Player] Auto Transcode enabled. Probing stream...');
+                 try {
+-                    const probeRes = await fetch(`/api/probe?url=${encodeURIComponent(streamUrl)}`);
+                    const probeRes = await fetch(`api/probe?url=${encodeURIComponent(streamUrl)}`);
+                     const info = await probeRes.json();
+                     console.log(`[Player] Probe result: video=${info.video}, audio=${info.audio}, ${info.width}x${info.height}, compatible=${info.compatible}`);
+ 
+@@ -885,7 +885,7 @@ class VideoPlayer {
+                             track.kind = 'subtitles';
+                             track.label = sub.title;
+                             track.srclang = sub.language;
+-                            track.src = `/api/subtitle?url=${encodeURIComponent(streamUrl)}&index=${sub.index}`;
+                            track.src = `api/subtitle?url=${encodeURIComponent(streamUrl)}&index=${sub.index}`;
+                             this.video.appendChild(track);
+                         });
+ 
+@@ -925,7 +925,7 @@ class VideoPlayer {
+                         // Raw .ts container - use remux
+                         console.log('[Player] Auto: Using remux (.ts container)');
+                         this.updateTranscodeStatus('remuxing', 'Remux (Auto)');
+-                        const remuxUrl = `/api/remux?url=${encodeURIComponent(streamUrl)}`;
+                        const remuxUrl = `api/remux?url=${encodeURIComponent(streamUrl)}`;
+                         this.currentUrl = remuxUrl;
+                         this.video.src = remuxUrl;
+                         this.video.play().catch(e => {
+@@ -997,7 +997,7 @@ class VideoPlayer {
+                 // Probe to get video codec for HEVC tag handling
+                 let videoCodec = 'unknown';
+                 try {
+-                    const probeRes = await fetch(`/api/probe?url=${encodeURIComponent(streamUrl)}`);
+                    const probeRes = await fetch(`api/probe?url=${encodeURIComponent(streamUrl)}`);
+                     const info = await probeRes.json();
+                     videoCodec = info.video;
+                 } catch (e) { console.warn('Probe failed for force audio, assuming h264'); }
+@@ -1096,7 +1096,7 @@ class VideoPlayer {
+                             (data.type === Hls.ErrorTypes.MEDIA_ERROR && data.details === 'fragParsingError');
+ 
+                         // Don't proxy if it's already a local API URL
+-                        const isLocalApi = this.currentUrl.startsWith('/api/');
+                        const isLocalApi = this.currentUrl.startsWith('api/');
+ 
+                         if (isCorsLikely && !this.isUsingProxy && !isLocalApi) {
+                             console.log('CORS/Network error detected, retrying via proxy...', data.details);
+@@ -1344,14 +1344,14 @@ class VideoPlayer {
+      * Get proxied URL for a stream
+      */
+     getProxiedUrl(url) {
+-        return `/api/proxy/stream?url=${encodeURIComponent(url)}`;
+        return `api/proxy/stream?url=${encodeURIComponent(url)}`;
+     }
+ 
+     /**
+      * Get transcoded URL for a stream (audio transcoding for browser compatibility)
+      */
+     getTranscodeUrl(url) {
+-        return `/api/transcode?url=${encodeURIComponent(url)}`;
+        return `api/transcode?url=${encodeURIComponent(url)}`;
+     }
+ 
+     /**
+@@ -1359,7 +1359,7 @@ class VideoPlayer {
+      * Used for raw .ts streams that browsers can't play directly
+      */
+     getRemuxUrl(url) {
+-        return `/api/remux?url=${encodeURIComponent(url)}`;
+        return `api/remux?url=${encodeURIComponent(url)}`;
+     }
+ 
+     /**
+diff --git a/public/js/login.js b/public/js/login.js
+index a246d10..e2339f3 100644
+--- a/public/js/login.js
+++ b/public/js/login.js
+@@ -5,10 +5,10 @@ document.getElementById('login-form').addEventListener('submit', async (e) => {
+     const password = document.getElementById('password').value;
+ 
+     try {
+-        const response = await API.request('POST', '/auth/login', { username, password });
+        const response = await API.request('POST', 'auth/login', { username, password });
+         localStorage.setItem('sessionToken', response.token);
+-        window.location.href = '/';
+        window.location.href = 'index.html';
+     } catch (err) {
+         document.getElementById('login-error').textContent = 'Login failed: ' + err.message;
+     }
+-});
+\ No newline at end of file
+});
+diff --git a/public/js/pages/HomePage.js b/public/js/pages/HomePage.js
+index 6ddadc1..c8a1805 100644
+--- a/public/js/pages/HomePage.js
+++ b/public/js/pages/HomePage.js
+@@ -174,7 +174,7 @@ class HomePage {
+             await this.renderFavoriteChannels();
+ 
+             // 1. Load Watch History
+-            const history = await window.API.request('GET', '/history?limit=12');
+            const history = await window.API.request('GET', 'history?limit=12');
+             if (history && Array.isArray(history)) {
+                 this.renderHistory(history);
+             }
+@@ -197,7 +197,7 @@ class HomePage {
+ 
+         try {
+             // Fetch favorite channels for current user
+-            const favorites = await window.API.request('GET', '/favorites?itemType=channel');
+            const favorites = await window.API.request('GET', 'favorites?itemType=channel');
+ 
+             if (!favorites || favorites.length === 0) {
+                 list.innerHTML = '<div class="empty-state hint">Add channels to favorites from Live TV</div>';
+@@ -251,14 +251,14 @@ class HomePage {
+     }
+ 
+     createChannelTile(channel) {
+-        const logo = channel.tvgLogo || '/img/placeholder.png';
+-        const logoUrl = logo.startsWith('http') ? `/api/proxy/image?url=${encodeURIComponent(logo)}` : logo;
+        const logo = channel.tvgLogo || 'img/placeholder.png';
+        const logoUrl = logo.startsWith('http') ? `api/proxy/image?url=${encodeURIComponent(logo)}` : logo;
+         const name = channel.name || 'Unknown';
+ 
+         return `
+             <div class="channel-tile" data-channel-id="${channel.id}" data-source-id="${channel.sourceId}">
+                 <div class="tile-logo">
+-                    <img src="${logoUrl}" alt="${name}" loading="lazy" onerror="this.onerror=null;this.src='/img/placeholder.png'">
+                    <img src="${logoUrl}" alt="${name}" loading="lazy" onerror="this.onerror=null;this.src='img/placeholder.png'">
+                 </div>
+                 <div class="tile-name" title="${name}">${name}</div>
+             </div>
+@@ -352,7 +352,7 @@ class HomePage {
+         if (!list) return;
+ 
+         try {
+-            const movies = await window.API.request('GET', '/channels/recent?type=movie&limit=12');
+            const movies = await window.API.request('GET', 'channels/recent?type=movie&limit=12');
+             if (!movies || movies.length === 0) {
+                 list.innerHTML = '<div class="empty-state hint">No recently added movies found</div>';
+                 return;
+@@ -381,7 +381,7 @@ class HomePage {
+         if (!list) return;
+ 
+         try {
+-            const series = await window.API.request('GET', '/channels/recent?type=series&limit=12');
+            const series = await window.API.request('GET', 'channels/recent?type=series&limit=12');
+             if (!series || series.length === 0) {
+                 list.innerHTML = '<div class="empty-state hint">No recently added series found</div>';
+                 return;
+@@ -411,13 +411,13 @@ class HomePage {
+         const percent = Math.min(100, Math.round((progress / duration) * 100));
+ 
+         // Proxy the poster if it's an external URL
+-        const poster = data.poster || '/img/poster-placeholder.jpg';
+-        const posterUrl = poster.startsWith('http') ? `/api/proxy/image?url=${encodeURIComponent(poster)}` : poster;
+        const poster = data.poster || 'img/poster-placeholder.jpg';
+        const posterUrl = poster.startsWith('http') ? `api/proxy/image?url=${encodeURIComponent(poster)}` : poster;
+ 
+         return `
+             <div class="dashboard-card" data-id="${item_id}" data-type="${type}">
+                 <div class="card-image">
+-                    <img src="${posterUrl}" alt="${data.title || item.name}" loading="lazy" onerror="this.onerror=null;this.src='/img/poster-placeholder.jpg'">
+                    <img src="${posterUrl}" alt="${data.title || item.name}" loading="lazy" onerror="this.onerror=null;this.src='img/poster-placeholder.jpg'">
+                     <div class="progress-bar-container">
+                         <div class="progress-bar" style="width: ${percent}%"></div>
+                     </div>
+@@ -436,13 +436,13 @@ class HomePage {
+     createRecentCard(item) {
+         const { data, item_id } = item;
+         const type = item.type || item.item_type;
+-        const poster = item.stream_icon || data.poster || '/img/poster-placeholder.jpg';
+-        const posterUrl = poster.startsWith('http') ? `/api/proxy/image?url=${encodeURIComponent(poster)}` : poster;
+        const poster = item.stream_icon || data.poster || 'img/poster-placeholder.jpg';
+        const posterUrl = poster.startsWith('http') ? `api/proxy/image?url=${encodeURIComponent(poster)}` : poster;
+ 
+         return `
+             <div class="dashboard-card" data-id="${item_id}" data-type="${type}">
+                 <div class="card-image">
+-                    <img src="${posterUrl}" alt="${item.name}" loading="lazy" onerror="this.onerror=null;this.src='/img/poster-placeholder.jpg'">
+                    <img src="${posterUrl}" alt="${item.name}" loading="lazy" onerror="this.onerror=null;this.src='img/poster-placeholder.jpg'">
+                     <div class="play-icon-overlay">
+                         <svg viewBox="0 0 24 24" fill="currentColor"><path d="M8 5v14l11-7z"/></svg>
+                     </div>
+@@ -465,7 +465,7 @@ class HomePage {
+             const streamId = item.item_id;
+             const container = item.container_extension || (item.data && item.data.containerExtension) || 'mp4';
+ 
+-            const result = await window.API.request('GET', `/proxy/xtream/${sourceId}/stream/${streamId}/${streamType}?container=${container}`);
+            const result = await window.API.request('GET', `proxy/xtream/${sourceId}/stream/${streamId}/${streamType}?container=${container}`);
+ 
+             if (result && result.url) {
+                 const content = {
+@@ -488,7 +488,7 @@ class HomePage {
+                     // Fetch seriesInfo if we have a seriesId
+                     if (content.seriesId && sourceId) {
+                         try {
+-                            const seriesInfo = await window.API.request('GET', `/proxy/xtream/${sourceId}/series_info?series_id=${content.seriesId}`);
+                            const seriesInfo = await window.API.request('GET', `proxy/xtream/${sourceId}/series_info?series_id=${content.seriesId}`);
+                             if (seriesInfo) {
+                                 content.seriesInfo = seriesInfo;
+                             }
+diff --git a/public/js/pages/MoviesPage.js b/public/js/pages/MoviesPage.js
+index a5bb40f..c27fba6 100644
+--- a/public/js/pages/MoviesPage.js
+++ b/public/js/pages/MoviesPage.js
+@@ -278,7 +278,7 @@ class MoviesPage {
+             card.dataset.movieId = movie.stream_id;
+             card.dataset.sourceId = movie.sourceId;
+ 
+-            const poster = movie.stream_icon || movie.cover || '/img/placeholder.png';
+            const poster = movie.stream_icon || movie.cover || 'img/placeholder.png';
+             const year = movie.year || movie.releaseDate?.substring(0, 4) || '';
+             const rating = movie.rating ? `${Icons.star} ${movie.rating}` : '';
+ 
+@@ -287,7 +287,7 @@ class MoviesPage {
+             card.innerHTML = `
+                 <div class="movie-poster">
+                     <img src="${poster}" alt="${movie.name}" 
+-                         onerror="this.onerror=null;this.src='/img/placeholder.png'" loading="lazy">
+                         onerror="this.onerror=null;this.src='img/placeholder.png'" loading="lazy">
+                     <div class="movie-play-overlay">
+                         <span class="play-icon">${Icons.play}</span>
+                     </div>
+diff --git a/public/js/pages/SeriesPage.js b/public/js/pages/SeriesPage.js
+index 6b7a929..1a25f85 100644
+--- a/public/js/pages/SeriesPage.js
+++ b/public/js/pages/SeriesPage.js
+@@ -288,7 +288,7 @@ class SeriesPage {
+             card.dataset.seriesId = series.series_id;
+             card.dataset.sourceId = series.sourceId;
+ 
+-            const poster = series.cover || '/img/placeholder.png';
+            const poster = series.cover || 'img/placeholder.png';
+             const year = series.year || series.releaseDate?.substring(0, 4) || '';
+             const rating = series.rating ? `${Icons.star} ${series.rating}` : '';
+ 
+@@ -297,7 +297,7 @@ class SeriesPage {
+             card.innerHTML = `
+                 <div class="series-poster">
+                     <img src="${poster}" alt="${series.name}" 
+-                         onerror="this.onerror=null;this.src='/img/placeholder.png'" loading="lazy">
+                         onerror="this.onerror=null;this.src='img/placeholder.png'" loading="lazy">
+                     <div class="series-play-overlay">
+                         <span class="play-icon">${Icons.play}</span>
+                     </div>
+@@ -350,7 +350,7 @@ class SeriesPage {
+         this.detailsPanel.classList.remove('hidden');
+ 
+         // Set header info
+-        document.getElementById('series-poster').src = series.cover || '/img/placeholder.png';
+        document.getElementById('series-poster').src = series.cover || 'img/placeholder.png';
+         document.getElementById('series-title').textContent = series.name;
+         document.getElementById('series-plot').textContent = series.plot || '';
+ 
+diff --git a/public/js/pages/Settings.js b/public/js/pages/Settings.js
+index a47b5d7..437d7a5 100644
+--- a/public/js/pages/Settings.js
+++ b/public/js/pages/Settings.js
+@@ -259,7 +259,7 @@ class SettingsPage {
+         if (!container) return;
+ 
+         try {
+-            const response = await fetch('/api/settings/hw-info');
+            const response = await fetch('api/settings/hw-info');
+             if (!response.ok) throw new Error('Failed to fetch hardware info');
+             const hwInfo = await response.json();
+ 
+@@ -603,7 +603,7 @@ class SettingsPage {
+ 
+         try {
+             // Fetch last sync time from server
+-            const response = await fetch('/api/settings/sync-status');
+            const response = await fetch('api/settings/sync-status');
+             if (!response.ok) throw new Error('Failed to fetch sync status');
+             const data = await response.json();
+ 
+diff --git a/public/js/pages/WatchPage.js b/public/js/pages/WatchPage.js
+index b85ca63..2aecdfd 100644
+--- a/public/js/pages/WatchPage.js
+++ b/public/js/pages/WatchPage.js
+@@ -329,7 +329,7 @@ class WatchPage {
+     async startTranscodeSession(url, options = {}) {
+         try {
+             console.log('[WatchPage] Starting HLS transcode session...', options);
+-            const res = await fetch('/api/transcode/session', {
+            const res = await fetch('api/transcode/session', {
+                 method: 'POST',
+                 headers: { 'Content-Type': 'application/json' },
+                 body: JSON.stringify({
+@@ -345,7 +345,7 @@ class WatchPage {
+         } catch (err) {
+             console.error('[WatchPage] Session start failed:', err);
+             // Fallback to direct transcode if session fails
+-            return `/api/transcode?url=${encodeURIComponent(url)}`;
+            return `api/transcode?url=${encodeURIComponent(url)}`;
+         }
+     }
+ 
+@@ -357,7 +357,7 @@ class WatchPage {
+             console.log('[WatchPage] Stopping transcode session:', this.currentSessionId);
+             try {
+                 // Fire and forget cleanup
+-                fetch(`/api/transcode/${this.currentSessionId}`, { method: 'DELETE' });
+                fetch(`api/transcode/${this.currentSessionId}`, { method: 'DELETE' });
+             } catch (err) {
+                 console.error('Failed to stop session:', err);
+             }
+@@ -437,7 +437,7 @@ class WatchPage {
+             console.log('[WatchPage] Auto Transcode enabled. Probing stream...');
+             try {
+                 const ua = settings.userAgentPreset === 'custom' ? settings.userAgentCustom : settings.userAgentPreset;
+-                const probeRes = await fetch(`/api/probe?url=${encodeURIComponent(url)}&ua=${encodeURIComponent(ua || '')}`);
+                const probeRes = await fetch(`api/probe?url=${encodeURIComponent(url)}&ua=${encodeURIComponent(ua || '')}`);
+                 const info = await probeRes.json();
+                 console.log(`[WatchPage] Probe result: video=${info.video}, audio=${info.audio}, ${info.width}x${info.height}, compatible=${info.compatible}`);
+ 
+@@ -470,7 +470,7 @@ class WatchPage {
+                     // TODO: Move remux to session logic if seeking is needed for TS files
+                     console.log('[WatchPage] Auto: Using remux (.ts container)');
+                     this.updateTranscodeStatus('remuxing', 'Remux (Auto)');
+-                    const finalUrl = `/api/remux?url=${encodeURIComponent(url)}`;
+                    const finalUrl = `api/remux?url=${encodeURIComponent(url)}`;
+                     this.video.src = finalUrl;
+                     this.video.play().catch(e => {
+                         if (e.name !== 'AbortError') console.error('[WatchPage] Autoplay error:', e);
+@@ -509,7 +509,7 @@ class WatchPage {
+             let videoCodec = 'unknown';
+             try {
+                 const ua = settings.userAgentPreset === 'custom' ? settings.userAgentCustom : settings.userAgentPreset;
+-                const probeRes = await fetch(`/api/probe?url=${encodeURIComponent(url)}&ua=${encodeURIComponent(ua || '')}`);
+                const probeRes = await fetch(`api/probe?url=${encodeURIComponent(url)}&ua=${encodeURIComponent(ua || '')}`);
+                 const info = await probeRes.json();
+                 videoCodec = info.video;
+             } catch (e) { console.warn('Probe failed for force audio, assuming h264'); }
+@@ -528,7 +528,7 @@ class WatchPage {
+         if (settings.forceRemux && isRawTs) {
+             console.log('[WatchPage] Force Remux enabled');
+             this.updateTranscodeStatus('remuxing', 'Remux (Force)');
+-            const finalUrl = `/api/remux?url=${encodeURIComponent(url)}`;
+            const finalUrl = `api/remux?url=${encodeURIComponent(url)}`;
+             this.video.src = finalUrl;
+             this.video.play().catch(e => {
+                 if (e.name !== 'AbortError') console.error('[WatchPage] Autoplay error:', e);
+@@ -540,7 +540,7 @@ class WatchPage {
+         // Determine if proxy is needed
+         const proxyRequiredDomains = ['pluto.tv'];
+         const needsProxy = settings.forceProxy || proxyRequiredDomains.some(domain => url.includes(domain));
+-        const finalUrl = needsProxy ? `/api/proxy/stream?url=${encodeURIComponent(url)}` : url;
+        const finalUrl = needsProxy ? `api/proxy/stream?url=${encodeURIComponent(url)}` : url;
+ 
+         console.log('[WatchPage] Playing:', { url, needsProxy, looksLikeHls });
+ 
+@@ -600,9 +600,9 @@ class WatchPage {
+                 console.error('[WatchPage] HLS fatal error:', data);
+                 // Try proxy on CORS error (only if not already proxied/transcoded)
+                 // Note: Transcoded streams are local, so no CORS issues usually
+-                if (!url.startsWith('/api/') && (data.type === Hls.ErrorTypes.NETWORK_ERROR)) {
+                if (!url.startsWith('api/') && (data.type === Hls.ErrorTypes.NETWORK_ERROR)) {
+                     console.log('[WatchPage] Retrying via proxy...');
+-                    this.playHls(`/api/proxy/stream?url=${encodeURIComponent(this.currentUrl)}`);
+                    this.playHls(`api/proxy/stream?url=${encodeURIComponent(this.currentUrl)}`);
+                 } else {
+                     this.hls.destroy();
+                 }
+@@ -1030,7 +1030,7 @@ class WatchPage {
+         if (!this.content) return;
+ 
+         const isChannel = this.content.type === 'channel' || !this.content.type; // Default to channel if unknown
+-        const fallback = isChannel ? '/img/placeholder.png' : '/img/poster-placeholder.jpg';
+        const fallback = isChannel ? 'img/placeholder.png' : 'img/poster-placeholder.jpg';
+ 
+         this.posterEl.onerror = () => {
+             this.posterEl.onerror = null;
+@@ -1130,9 +1130,9 @@ class WatchPage {
+ 
+         this.recommendedGrid.innerHTML = movies.map(movie => `
+             <div class="watch-recommended-card" data-id="${movie.stream_id}" data-source="${sourceId}">
+-                <img src="${movie.stream_icon || movie.cover || '/img/placeholder.png'}" 
+                <img src="${movie.stream_icon || movie.cover || 'img/placeholder.png'}" 
+                      alt="${movie.name}" 
+-                     onerror="this.onerror=null;this.src='/img/placeholder.png'" loading="lazy">
+                     onerror="this.onerror=null;this.src='img/placeholder.png'" loading="lazy">
+                 <p>${movie.name}</p>
+             </div>
+         `).join('');
+@@ -1417,7 +1417,7 @@ class WatchPage {
+                 currentEpisode: this.currentEpisode || null
+             };
+ 
+-            await window.API.request('POST', '/history', {
+            await window.API.request('POST', 'history', {
+                 id: this.content.id,
+                 type: this.content.type === 'movie' ? 'movie' : 'episode',
+                 sourceId: this.content.sourceId,
+diff --git a/public/login.html b/public/login.html
+index 454acfe..34bcb46 100644
+--- a/public/login.html
+++ b/public/login.html
+@@ -5,7 +5,7 @@
+     <meta charset="UTF-8">
+     <meta name="viewport" content="width=device-width, initial-scale=1.0">
+     <title>Login - NodeCast TV</title>
+-    <link rel="icon" type="image/svg+xml" href="/favicon.svg">
+    <link rel="icon" type="image/svg+xml" href="favicon.svg">
+     <link rel="stylesheet" href="css/main.css">
+     <link href="https://fonts.googleapis.com/css2?family=Inter:wght@400;500;600;700&display=swap" rel="stylesheet">
+     <style>
+@@ -228,7 +228,7 @@
+     <script>
+         // Start SSO Login
+         document.getElementById('btn-sso-login').addEventListener('click', () => {
+-            window.location.href = '/api/auth/oidc/login';
+            window.location.href = 'api/auth/oidc/login';
+         });
+ 
+         // Check for URL Error params
+@@ -247,7 +247,7 @@
+ 
+         async function checkSetupRequired() {
+             try {
+-                const response = await fetch('/api/auth/setup-required');
+                const response = await fetch('api/auth/setup-required');
+                 const data = await response.json();
+ 
+                 if (data.setupRequired) {
+@@ -283,7 +283,7 @@
+             submitBtn.textContent = 'Please wait...';
+ 
+             try {
+-                const endpoint = isSetupMode ? '/api/auth/setup' : '/api/auth/login';
+                const endpoint = isSetupMode ? 'api/auth/setup' : 'api/auth/login';
+                 const response = await fetch(endpoint, {
+                     method: 'POST',
+                     headers: {
+@@ -302,7 +302,7 @@
+                 localStorage.setItem('authToken', data.token);
+ 
+                 // Redirect to main app (replace history to prevent back button issues)
+-                window.location.replace('/');
+                window.location.replace('index.html');
+ 
+             } catch (err) {
+                 errorMessage.textContent = err.message;
+@@ -317,4 +317,4 @@
+     </script>
+ </body>
+ 
+-</html>
+\ No newline at end of file
+</html>
@@ -1,12 +1,12 @@
 {
-    "name": "nodecast-tv",
-    "version": "2.1.4",
+    "name": "kiratv",
+    "version": "2.1.4-kira1",
    "lockfileVersion": 3,
    "requires": true,
    "packages": {
        "": {
-            "name": "nodecast-tv",
-            "version": "2.1.4",
+            "name": "kiratv",
+            "version": "2.1.4-kira1",
            "license": "GPL-3.0-only",
            "dependencies": {
                "@ffprobe-installer/ffprobe": "^2.1.2",
@@ -1,7 +1,7 @@
 {
-    "name": "nodecast-tv",
-    "version": "2.1.4",
-    "description": "Modern IPTV Player",
+    "name": "kiratv",
+    "version": "2.1.4-kira1",
+    "description": "KiraTV — reproductor IPTV para el navegador (fork de NodeCast)",
    "license": "GPL-3.0-only",
    "main": "server/index.js",
    "scripts": {
@@ -1,3 +1,11 @@
-<svg xmlns="http://www.w3.org/2000/svg" viewBox="0 0 187.63 210.6">
-  <path fill="#6366f1" d="M169.71,87.87c-4.77,0-9.1,1.88-12.31,4.92L35.3,22.3c.35-1.4.56-2.86.56-4.37C35.86,8.03,27.83,0,17.93,0S0,8.03,0,17.93c0,8.44,5.84,15.5,13.69,17.4v140c-7.71,2.01-13.41,8.99-13.41,17.33,0,9.9,8.03,17.93,17.93,17.93s17.93-8.03,17.93-17.93c0-1.56-.22-3.07-.6-4.51l121.21-69.98c3.26,3.42,7.86,5.55,12.95,5.55,9.9,0,17.93-8.03,17.93-17.93s-8.03-17.93-17.93-17.93ZM152.78,99.92c-.14.41-.27.83-.38,1.25h-51.47l-44.18-24.72L30.4,30.8c.33-.32.64-.65.94-.99l121.45,70.12ZM22.17,175.2V35.33c.23-.05.45-.11.67-.17l26.35,45.65-.34,50.04-25.74,44.59c-.31-.09-.63-.17-.95-.24ZM31.52,180.69c-.27-.3-.55-.6-.84-.89l25.48-44.13,44.64-25.78h51.47c.07.32.15.63.24.94L31.52,180.69Z"/>
+<svg xmlns="http://www.w3.org/2000/svg" viewBox="0 0 64 64" fill="none">
+  <defs>
+    <linearGradient id="g" x1="0" y1="0" x2="64" y2="64">
+      <stop offset="0%" stop-color="#7c3aed"/>
+      <stop offset="100%" stop-color="#4f46e5"/>
+    </linearGradient>
+  </defs>
+  <rect width="64" height="64" rx="14" fill="url(#g)"/>
+  <rect x="10" y="18" width="44" height="28" rx="4" stroke="#fff" stroke-width="3" fill="none"/>
+  <path d="M22 32 L28 38 L42 24" stroke="#fff" stroke-width="4" stroke-linecap="round" stroke-linejoin="round" fill="none"/>
 </svg>
@@ -1,5 +1,5 @@
 <!DOCTYPE html>
-<html lang="en">
+<html lang="es">

 <head>
  <meta charset="UTF-8">
@@ -7,8 +7,8 @@
  <meta name="apple-mobile-web-app-capable" content="yes">
  <meta name="apple-mobile-web-app-status-bar-style" content="black-translucent">
  <meta name="mobile-web-app-capable" content="yes">
-  <title>nodecast-tv | IPTV Player</title>
-  <meta name="description" content="Stream live TV, movies, and series with EPG support">
+  <title>KiraTV | Televisión en el navegador</title>
+  <meta name="description" content="TV en directo, películas y series con guía EPG — KiraTV">
  <link rel="icon" type="image/svg+xml" href="/favicon.svg">
  <link rel="stylesheet" href="css/main.css">
  <link rel="preconnect" href="https://fonts.googleapis.com">
@@ -29,7 +29,7 @@
            <path
              d="M169.71,87.87c-4.77,0-9.1,1.88-12.31,4.92L35.3,22.3c.35-1.4.56-2.86.56-4.37C35.86,8.03,27.83,0,17.93,0S0,8.03,0,17.93c0,8.44,5.84,15.5,13.69,17.4v140c-7.71,2.01-13.41,8.99-13.41,17.33,0,9.9,8.03,17.93,17.93,17.93s17.93-8.03,17.93-17.93c0-1.56-.22-3.07-.6-4.51l121.21-69.98c3.26,3.42,7.86,5.55,12.95,5.55,9.9,0,17.93-8.03,17.93-17.93s-8.03-17.93-17.93-17.93ZM152.78,99.92c-.14.41-.27.83-.38,1.25h-51.47l-44.18-24.72L30.4,30.8c.33-.32.64-.65.94-.99l121.45,70.12ZM22.17,175.2V35.33c.23-.05.45-.11.67-.17l26.35,45.65-.34,50.04-25.74,44.59c-.31-.09-.63-.17-.95-.24ZM31.52,180.69c-.27-.3-.55-.6-.84-.89l25.48-44.13,44.64-25.78h51.47c.07.32.15.63.24.94L31.52,180.69Z" />
          </svg></span>
-        <span class="brand-text">nodecast-tv</span>
+        <span class="brand-text">KiraTV</span>
        <span id="version-badge" class="version-badge"></span>
      </div>
      <button class="mobile-menu-toggle" id="mobile-menu-toggle" aria-label="Toggle menu">
@@ -1,5 +1,5 @@
 /**
- * NodeCast TV Application Entry Point
+ * KiraTV Application Entry Point
 */

 class App {
@@ -161,7 +161,7 @@ class App {
        const initialPage = hash && this.pages[hash] ? hash : 'home';
        this.navigateTo(initialPage, true); // true = replace history (don't add)

-        console.log('NodeCast TV initialized');
+        console.log('KiraTV initialized');
    }

    async checkAuth() {
@@ -46,7 +46,7 @@ class ChannelList {
     */
    loadCollapsedState() {
        try {
-            const saved = localStorage.getItem('nodecast_tv_collapsed_groups');
+            const saved = localStorage.getItem('kiratv_collapsed_groups');
            if (saved) {
                this.collapsedGroups = new Set(JSON.parse(saved));
                this._hasCollapsedState = true;
@@ -64,7 +64,7 @@ class ChannelList {
     */
    saveCollapsedState() {
        try {
-            localStorage.setItem('nodecast_tv_collapsed_groups', JSON.stringify([...this.collapsedGroups]));
+            localStorage.setItem('kiratv_collapsed_groups', JSON.stringify([...this.collapsedGroups]));
        } catch (err) {
            console.error('Error saving collapsed state:', err);
        }
@@ -28,6 +28,9 @@ class VideoPlayer {
        this.isUsingProxy = false;
        this.currentUrl = null;
        this.settingsLoaded = false;
+        this.switchInProgress = false;
+        this.queuedSwitch = null;
+        this.lastSwitchAt = 0;

        // Settings - start with defaults, load from server async
        this.settings = this.getDefaultSettings();
@@ -53,7 +56,7 @@ class VideoPlayer {
            forceTranscode: false,
            forceRemux: false,
            autoTranscode: true,
-            streamFormat: 'm3u8',
+            streamFormat: 'ts',
            epgRefreshInterval: '24'
        };
    }
@@ -71,7 +74,7 @@ class VideoPlayer {
            console.warn('[Player] Failed to load settings from server, using defaults:', err.message);
            // Fall back to localStorage for backwards compatibility
            try {
-                const saved = localStorage.getItem('nodecast_tv_player_settings');
+                const saved = localStorage.getItem('kiratv_player_settings');
                if (saved) {
                    this.settings = { ...this.getDefaultSettings(), ...JSON.parse(saved) };
                    console.log('[Player] Settings loaded from localStorage (fallback)');
@@ -93,7 +96,7 @@ class VideoPlayer {
            console.error('[Player] Error saving settings to server:', err);
            // Also save to localStorage as backup
            try {
-                localStorage.setItem('nodecast_tv_player_settings', JSON.stringify(this.settings));
+                localStorage.setItem('kiratv_player_settings', JSON.stringify(this.settings));
            } catch (localErr) {
                console.error('[Player] Error saving to localStorage:', localErr);
            }
@@ -813,37 +816,58 @@ class VideoPlayer {
     * Start a HLS transcode session
     */
    async startTranscodeSession(url, options = {}) {
-        try {
        console.log('[Player] Starting HLS transcode session...', options);
+        let lastError = null;
+
+        // Retry a couple of times to ride out provider-side 5xx/rate-limit spikes.
+        for (let attempt = 1; attempt <= 3; attempt++) {
+            try {
                const res = await fetch('/api/transcode/session', {
                    method: 'POST',
                    headers: { 'Content-Type': 'application/json' },
                    body: JSON.stringify({ url, ...options })
                });
-            if (!res.ok) throw new Error('Failed to start session');
+                if (!res.ok) {
+                    throw new Error(`Failed to start session (${res.status})`);
+                }
                const session = await res.json();
                this.currentSessionId = session.sessionId;
                return session.playlistUrl;
            } catch (err) {
-            console.error('[Player] Session start failed:', err);
-            // Fallback to direct transcode if session fails
-            return `/api/transcode?url=${encodeURIComponent(url)}`;
+                lastError = err;
+                console.warn(`[Player] Session start failed (attempt ${attempt}/3):`, err?.message || err);
+                if (attempt < 3) {
+                    await new Promise(resolve => setTimeout(resolve, 900));
                }
            }
+        }
+
+        // Avoid fallback to /api/transcode direct stream: it tends to overlap sessions
+        // and breaks providers with strict single-connection limits.
+        throw lastError || new Error('Failed to start transcode session');
+    }

    /**
     * Stop and cleanup current transcode session
     */
    async stopTranscodeSession() {
-        if (this.currentSessionId) {
-            console.log('[Player] Stopping transcode session:', this.currentSessionId);
+        if (!this.currentSessionId) return;
+
+        const sessionId = this.currentSessionId;
+        this.currentSessionId = null;
+        console.log('[Player] Stopping transcode session:', sessionId);
        try {
-                // Fire and forget cleanup
-                fetch(`/api/transcode/${this.currentSessionId}`, { method: 'DELETE' });
+            const controller = new AbortController();
+            const timer = setTimeout(() => controller.abort(), 1500);
+            await fetch(`/api/transcode/${sessionId}`, {
+                method: 'DELETE',
+                signal: controller.signal
+            });
+            clearTimeout(timer);
        } catch (err) {
+            if (err?.name !== 'AbortError') {
                console.error('Failed to stop session:', err);
            }
-            this.currentSessionId = null;
        }
    }

@@ -851,14 +875,26 @@ class VideoPlayer {
     * Play a channel
     */
    async play(channel, streamUrl) {
+        // Avoid overlapping channel changes; keep only the latest zap request.
+        if (this.switchInProgress) {
+            this.queuedSwitch = { channel, streamUrl };
+            return;
+        }
+        this.switchInProgress = true;
        this.currentChannel = channel;

        try {
            // Stop any WatchPage playback (movies/series) before starting Live TV
            window.app?.pages?.watch?.stop?.();

-            // Stop current playback
-            this.stop();
+            // Stop current playback (sends DELETE to worker → FFmpeg dies → Dispatcharr frees the slot)
+            await this.stop();
+
+            // Give Dispatcharr enough time to release the stream slot before probing the new channel.
+            // 2500ms covers most providers; retries in the probe endpoint handle the edge cases.
+            await new Promise(resolve => setTimeout(resolve, 2500));
+
+            this.lastSwitchAt = Date.now();
            this.updateTranscodeStatus('hidden');

            // Hide "select a channel" overlay
@@ -932,15 +968,18 @@ class VideoPlayer {
                        window.dispatchEvent(new CustomEvent('channelChanged', { detail: channel }));
                        return;
                    } else if (info.needsRemux) {
-                        // Raw .ts container - use remux
-                        console.log('[Player] Auto: Using remux (.ts container)');
-                        this.updateTranscodeStatus('remuxing', 'Remux (Auto)');
-                        const remuxUrl = `/api/remux?url=${encodeURIComponent(streamUrl)}`;
-                        this.currentUrl = remuxUrl;
-                        this.video.src = remuxUrl;
-                        this.video.play().catch(e => {
-                            if (e.name !== 'AbortError') console.log('[Player] Autoplay prevented:', e);
+                        // Algunos streams TS fallan en remux directo (ffmpeg mp4 mux errors).
+                        // En ese caso es mas estable usar sesion HLS con video copy.
+                        console.log('[Player] Auto: Using HLS transcode session (copy for remux-needed stream)');
+                        this.updateTranscodeStatus('transcoding', 'Transcoding (Auto)');
+                        const playlistUrl = await this.startTranscodeSession(streamUrl, {
+                            videoMode: 'copy',
+                            videoCodec: info.video,
+                            audioCodec: info.audio,
+                            audioChannels: info.audioChannels
                        });
+                        this.currentUrl = playlistUrl;
+                        this.playHls(playlistUrl);
                        this.updateNowPlaying(channel);
                        this.showNowPlayingOverlay();
                        this.fetchEpgData(channel);
@@ -1183,6 +1222,13 @@ class VideoPlayer {
        } catch (err) {
            console.error('Error playing channel:', err);
            this.showError('Failed to play channel');
+        } finally {
+            this.switchInProgress = false;
+            if (this.queuedSwitch) {
+                const next = this.queuedSwitch;
+                this.queuedSwitch = null;
+                this.play(next.channel, next.streamUrl);
+            }
        }
    }

@@ -1387,9 +1433,9 @@ class VideoPlayer {
    /**
     * Stop playback
     */
-    stop() {
+    async stop() {
        // Stop any running transcode session first
-        this.stopTranscodeSession();
+        await this.stopTranscodeSession();

        if (this.hls) {
            this.hls.destroy();
@@ -79,6 +79,11 @@ class WatchPage {
        this.isFavorite = false;
        this.returnPage = null;
        this.captionsMenuOpen = false;
+        this.sourceStreamUrl = null;
+        this.knownDurationSec = 0;
+        this.playbackBaseOffsetSec = 0;
+        this.isSessionMode = false;
+        this._heartbeatTimer = null;

        // Overlay timer
        this.overlayTimeout = null;
@@ -238,6 +243,20 @@ class WatchPage {
                this.scrollHint?.classList.remove('hidden');
            }
        });
+
+        // On page close/refresh: stop heartbeat so the 3-min idle timeout kicks in fast
+        window.addEventListener('beforeunload', () => {
+            this._stopHeartbeat();
+        });
+
+        // Also stop session when the page becomes hidden (tab switch, minimize)
+        document.addEventListener('visibilitychange', () => {
+            if (document.hidden) {
+                this._stopHeartbeat();
+            } else if (this.currentSessionId) {
+                this._startHeartbeat(this.currentSessionId);
+            }
+        });
    }

    /**
@@ -253,6 +272,9 @@ class WatchPage {
        this.currentEpisode = content.currentEpisode || null;
        this.resumeTime = content.resumeTime || 0;
        this.containerExtension = content.containerExtension || 'mp4';
+        this.knownDurationSec = this.parseDurationSeconds(content.durationSec || content.duration || content.runtime || '');
+        this.playbackBaseOffsetSec = 0;
+        this.isSessionMode = false;
        this.returnPage = content.type === 'movie' ? 'movies' : 'series';

        // Stop any Live TV playback before starting movie/series
@@ -271,6 +293,14 @@ class WatchPage {
        // Update title bar
        this.titleEl.textContent = content.title || '';
        this.subtitleEl.textContent = content.subtitle || '';
+        if (this.timeTotal) {
+            this.timeTotal.textContent = this.knownDurationSec > 0 ? this.formatTime(this.knownDurationSec) : '0:00';
+        }
+
+        // If duration is missing, fetch it from vod_info in the background
+        if (this.knownDurationSec === 0 && content.sourceId && (content.vodId || content.id)) {
+            this._fetchVodDuration(content.sourceId, content.vodId || content.id);
+        }

        // Load video
        await this.loadVideo(streamUrl);
@@ -308,7 +338,7 @@ class WatchPage {
        const indicator = document.getElementById('now-playing-indicator');
        const textEl = document.getElementById('now-playing-text');
        if (indicator && textEl) {
-            textEl.textContent = title || 'Now Playing';
+            textEl.textContent = title || 'Reproduciendo';
            indicator.classList.remove('hidden');
        }
    }
@@ -341,10 +371,22 @@ class WatchPage {
            if (!res.ok) throw new Error('Failed to start session');
            const session = await res.json();
            this.currentSessionId = session.sessionId;
+            this.isSessionMode = true;
+            this._startHeartbeat(session.sessionId);
+
+            // Use server-probed duration if we don't already have one
+            if (session.durationSec > 0 && this.knownDurationSec === 0) {
+                this.knownDurationSec = session.durationSec;
+                console.log(`[WatchPage] Duration from FFprobe: ${session.durationSec}s`);
+                if (this.timeTotal) {
+                    this.timeTotal.textContent = this.formatTime(session.durationSec);
+                }
+            }
+
            return session.playlistUrl;
        } catch (err) {
            console.error('[WatchPage] Session start failed:', err);
-            // Fallback to direct transcode if session fails
+            this.isSessionMode = true; // Still session-like for duration purposes
            return `/api/transcode?url=${encodeURIComponent(url)}`;
        }
    }
@@ -353,15 +395,21 @@ class WatchPage {
     * Stop and cleanup current transcode session
     */
    async stopTranscodeSession() {
+        this._stopHeartbeat();
        if (this.currentSessionId) {
            console.log('[WatchPage] Stopping transcode session:', this.currentSessionId);
+            const sid = this.currentSessionId;
+            this.currentSessionId = null;
            try {
-                // Fire and forget cleanup
-                fetch(`/api/transcode/${this.currentSessionId}`, { method: 'DELETE' });
+                // sendBeacon works even when the page is being unloaded
+                if (navigator.sendBeacon) {
+                    navigator.sendBeacon(`/api/transcode/${sid}/stop`, '{}');
+                }
+                // Also DELETE (for normal navigation)
+                fetch(`/api/transcode/${sid}`, { method: 'DELETE' }).catch(() => {});
            } catch (err) {
                console.error('Failed to stop session:', err);
            }
-            this.currentSessionId = null;
        }
    }

@@ -412,6 +460,7 @@ class WatchPage {
    async loadVideo(url) {
        // Store the URL for copy functionality
        this.currentUrl = url;
+        this.sourceStreamUrl = url;

        // Stop any existing playback
        this.stop();
@@ -419,6 +468,23 @@ class WatchPage {
        // Show loading spinner
        this.showLoading();

+        if (typeof window.kiratvPlayVodInNativePlayer === 'function' && window.kiratvDesktop?.isDesktopApp) {
+            this.hideLoading();
+            const absUrl = window.kiratvAbsolutePlaybackUrl(url);
+            try {
+                const result = await window.kiratvPlayVodInNativePlayer(absUrl);
+                if (!result?.ok) {
+                    console.error('[KiraTV Desktop] VOD mpv:', result?.error);
+                    this.updateTranscodeStatus('hidden');
+                } else {
+                    this.updateTranscodeStatus('direct', 'mpv nativo');
+                }
+            } catch (e) {
+                console.error('[KiraTV Desktop] VOD', e);
+            }
+            return;
+        }
+
        // Get settings for proxy/transcode
        let settings = {};
        try {
@@ -462,6 +528,7 @@ class WatchPage {
                        audioCodec: info.audio,
                        audioChannels: info.audioChannels
                    });
+                    this.playbackBaseOffsetSec = this.resumeTime || 0;
                    this.playHls(playlistUrl);
                    this.setVolumeFromStorage();
                    return;
@@ -481,8 +548,30 @@ class WatchPage {
                // Compatible - fall through to normal playback
                console.log('[WatchPage] Auto: Using normal playback (compatible)');
            } catch (err) {
-                console.warn('[WatchPage] Probe failed, using normal playback:', err.message);
-                // Continue with normal playback on probe failure
+                console.warn('[WatchPage] Probe failed:', err.message);
+                const vodLike =
+                    isDirectVideo ||
+                    url.includes('/movie/') ||
+                    url.includes('/series/');
+                if (vodLike) {
+                    console.warn(
+                        '[WatchPage] Auto: VOD-like URL after probe failure — HLS encode fallback (evita reproducir remux Jellyfin sin transcodificar)'
+                    );
+                    this.updateTranscodeStatus('transcoding', 'Transcoding (auto, probe fallback)');
+                    try {
+                        const playlistUrl = await this.startTranscodeSession(url, {
+                            videoMode: 'encode',
+                            seekOffset: this.resumeTime,
+                        });
+                        this.playbackBaseOffsetSec = this.resumeTime || 0;
+                        this.playHls(playlistUrl);
+                        this.setVolumeFromStorage();
+                        return;
+                    } catch (fallbackErr) {
+                        console.error('[WatchPage] Encode fallback failed:', fallbackErr);
+                    }
+                }
+                // Live u otro contenido: seguir reproducción directa habitual
            }
        }

@@ -496,6 +585,7 @@ class WatchPage {
                videoMode: 'encode',
                seekOffset: this.resumeTime
            });
+            this.playbackBaseOffsetSec = this.resumeTime || 0;
            this.playHls(playlistUrl);
            this.setVolumeFromStorage();
            return;
@@ -519,6 +609,7 @@ class WatchPage {
                videoCodec,
                seekOffset: this.resumeTime
            });
+            this.playbackBaseOffsetSec = this.resumeTime || 0;
            this.playHls(playlistUrl);
            this.setVolumeFromStorage();
            return;
@@ -530,6 +621,7 @@ class WatchPage {
            this.updateTranscodeStatus('remuxing', 'Remux (Force)');
            const finalUrl = `/api/remux?url=${encodeURIComponent(url)}`;
            this.video.src = finalUrl;
+            this.playbackBaseOffsetSec = 0;
            this.video.play().catch(e => {
                if (e.name !== 'AbortError') console.error('[WatchPage] Autoplay error:', e);
            });
@@ -547,10 +639,12 @@ class WatchPage {
        // Use HLS.js for HLS streams
        if (looksLikeHls && Hls.isSupported()) {
            this.updateTranscodeStatus('direct', 'Direct HLS');
+            this.playbackBaseOffsetSec = 0;
            this.playHls(finalUrl);
        } else {
            // Direct playback for mp4/mkv/avi
            this.updateTranscodeStatus('direct', 'Direct Play');
+            this.playbackBaseOffsetSec = 0;
            this.video.src = finalUrl;
            this.video.play().catch(e => {
                if (e.name !== 'AbortError') console.error('[WatchPage] Autoplay error:', e);
@@ -611,7 +705,7 @@ class WatchPage {
    }

    setVolumeFromStorage() {
-        const savedVolume = localStorage.getItem('nodecast-volume') || '80';
+        const savedVolume = localStorage.getItem('kiratv-volume') || '80';
        this.video.volume = parseInt(savedVolume) / 100;
        if (this.volumeSlider) this.volumeSlider.value = savedVolume;
    }
@@ -621,6 +715,13 @@ class WatchPage {
        this.stopHistoryTracking();
        this.saveProgress();

+        if (typeof window !== 'undefined' && window.kiratvDesktop?.stopExternalMpv) {
+            window.kiratvDesktop.stopExternalMpv().catch(() => {});
+        }
+        if (typeof window.kiratvDesktopClearEmbeddedChrome === 'function') {
+            window.kiratvDesktopClearEmbeddedChrome();
+        }
+
        // Cleanup transcode session if exists
        this.stopTranscodeSession();
        this.updateTranscodeStatus('hidden');
@@ -637,9 +738,13 @@ class WatchPage {
        }
        if (this.video) {
            this.video.pause();
+            // En modo escritorio el vídeo va a mpv: limpiar src dispararía un error
+            // inofensivo pero confuso (MEDIA_ELEMENT_ERROR: Empty src attribute).
+            if (!window.kiratvDesktop?.isDesktopApp) {
                this.video.src = '';
                this.video.load();
            }
+        }

        this.hideNowPlaying();
    }
@@ -655,15 +760,38 @@ class WatchPage {
    }

    skip(seconds) {
-        if (this.video) {
-            this.video.currentTime = Math.max(0, Math.min(this.video.currentTime + seconds, this.video.duration || 0));
+        if (!this.video) return;
+        const totalDuration = this.getTotalDuration();
+        const currentAbsolute = this.getAbsoluteCurrentTime();
+        if (totalDuration > 0) {
+            const target = Math.max(0, Math.min(currentAbsolute + seconds, totalDuration));
+            this.seekToAbsolute(target);
+        } else {
+            this.video.currentTime = Math.max(0, this.video.currentTime + seconds);
        }
    }

    seek(percent) {
-        if (this.video && this.video.duration) {
-            this.video.currentTime = (percent / 100) * this.video.duration;
+        const totalDuration = this.getTotalDuration();
+        if (!this.video || !totalDuration) return;
+        const target = (percent / 100) * totalDuration;
+        this.seekToAbsolute(target);
    }
+
+    seekToAbsolute(targetSec) {
+        if (!this.video) return;
+
+        if (this.isSessionMode && this.sourceStreamUrl) {
+            // Session-based HLS: the playlist only covers a window from the last seekOffset.
+            // Re-create the session from the new target position.
+            const offset = Math.max(0, Math.floor(targetSec));
+            this.playbackBaseOffsetSec = offset;
+            this.resumeTime = offset; // startTranscodeSession reads this for seekOffset
+            this.loadVideo(this.sourceStreamUrl);
+            return;
+        }
+
+        this.video.currentTime = Math.max(0, targetSec);
    }

    toggleMute() {
@@ -677,7 +805,7 @@ class WatchPage {
        if (this.video) {
            this.video.volume = value / 100;
            this.video.muted = false;
-            localStorage.setItem('nodecast-volume', value);
+            localStorage.setItem('kiratv-volume', value);
            this.updateVolumeUI();
        }
    }
@@ -768,18 +896,22 @@ class WatchPage {
    // === UI Updates ===

    updateProgress() {
-        if (!this.video || !this.video.duration) return;
+        if (!this.video) return;

-        const percent = (this.video.currentTime / this.video.duration) * 100;
-        this.progressSlider.value = percent;
-        this.timeCurrent.textContent = this.formatTime(this.video.currentTime);
+        const totalDuration = this.getTotalDuration();
+        if (!totalDuration) return;
+
+        const currentAbs = this.getAbsoluteCurrentTime();
+        const percent = (currentAbs / totalDuration) * 100;
+        this.progressSlider.value = Math.max(0, Math.min(100, percent));
+        this.timeCurrent.textContent = this.formatTime(currentAbs);

        // Show "Up Next" panel early for series (like streaming services do during credits)
        // Only show if auto-play next episode is enabled
        const autoPlayEnabled = this.app?.player?.settings?.autoPlayNextEpisode;
        if (autoPlayEnabled && this.contentType === 'series' && this.seriesInfo && !this.nextEpisodeShowing && !this.nextEpisodeDismissed) {
-            const duration = this.video.duration;
-            const currentTime = this.video.currentTime;
+            const duration = totalDuration;
+            const currentTime = currentAbs;

            // Only proceed if we have reliable duration data
            if (isFinite(duration) && duration >= 180 && currentTime >= 120) {
@@ -807,8 +939,10 @@ class WatchPage {
            this.updateQualityBadge();
        }

-        // Handle resumption
-        if (this.resumeTime > 0 && this.video) {
+        // Handle resumption (only for direct video, NOT session mode).
+        // In session mode FFmpeg already starts from the seekOffset, so
+        // video.currentTime=0 already represents the correct absolute position.
+        if (!this.isSessionMode && this.resumeTime > 0 && this.video) {
            const duration = this.video.duration;
            // Only resume if not near the end (95%)
            if (!duration || this.resumeTime < duration * 0.95) {
@@ -816,6 +950,14 @@ class WatchPage {
                this.video.currentTime = this.resumeTime;
            }
            this.resumeTime = 0; // Reset after use
+        } else if (this.isSessionMode) {
+            this.resumeTime = 0; // Clear so it's not applied again
+        }
+
+        // Update total duration label using known VOD runtime when browser reports Infinity/NaN
+        const totalDuration = this.getTotalDuration();
+        if (this.timeTotal && totalDuration > 0) {
+            this.timeTotal.textContent = this.formatTime(totalDuration);
        }
    }

@@ -852,12 +994,12 @@ class WatchPage {
    }

    onError(e) {
-        // Only log actual fatal errors, not benign stream recovery events
        const error = this.video?.error;
-        if (error && error.code) {
+        if (!error || !error.code) return;
+        // Ignorar error por src vacío (ocurre al limpiar el elemento tras parar)
+        if (error.code === 4 && (!this.video.src || this.video.src === window.location.href)) return;
        console.error('[WatchPage] Video error:', error.code, error.message);
    }
-    }

    updateVolumeUI() {
        const isMuted = this.video?.muted || this.video?.volume === 0;
@@ -876,6 +1018,90 @@ class WatchPage {
        return `${m}:${s.toString().padStart(2, '0')}`;
    }

+    parseDurationSeconds(value) {
+        if (!value) return 0;
+        if (typeof value === 'number' && Number.isFinite(value)) return Math.max(0, Math.floor(value));
+        const str = String(value).trim();
+        if (!str) return 0;
+
+        // HH:MM:SS or MM:SS (allow any number of digits in the first segment)
+        if (/^\d+:\d{1,2}(:\d{1,2})?$/.test(str)) {
+            const parts = str.split(':').map(n => parseInt(n, 10));
+            if (parts.length === 3) return parts[0] * 3600 + parts[1] * 60 + parts[2];
+            if (parts.length === 2) return parts[0] * 60 + parts[1];
+        }
+
+        // Plain seconds string
+        const asNum = parseInt(str, 10);
+        return Number.isFinite(asNum) ? Math.max(0, asNum) : 0;
+    }
+
+    _startHeartbeat(sessionId) {
+        this._stopHeartbeat();
+        // Ping every 90 seconds — well within the 3-minute idle timeout on the worker
+        this._heartbeatTimer = setInterval(async () => {
+            if (!sessionId) return;
+            try {
+                await fetch(`/api/transcode/${sessionId}/heartbeat`, { method: 'POST' });
+            } catch (_) { /* ignore */ }
+        }, 90_000);
+    }
+
+    _stopHeartbeat() {
+        if (this._heartbeatTimer) {
+            clearInterval(this._heartbeatTimer);
+            this._heartbeatTimer = null;
+        }
+    }
+
+    /**
+     * Fetch VOD/episode duration from the Xtream vod_info endpoint in the background.
+     * Updates knownDurationSec and the UI time label once the response arrives.
+     */
+    async _fetchVodDuration(sourceId, vodId) {
+        try {
+            const res = await fetch(`/api/proxy/xtream/${sourceId}/vod_info?vod_id=${vodId}`);
+            if (!res.ok) return;
+            const data = await res.json();
+            const raw = data?.info?.duration_secs
+                || data?.info?.duration
+                || data?.movie_data?.duration_secs
+                || data?.info?.runtime;
+            const secs = this.parseDurationSeconds(raw);
+            if (secs > 0 && secs > this.knownDurationSec) {
+                console.log(`[WatchPage] VOD duration from vod_info: ${secs}s`);
+                this.knownDurationSec = secs;
+                if (this.timeTotal) {
+                    this.timeTotal.textContent = this.formatTime(secs);
+                }
+            }
+        } catch (e) {
+            // Non-critical — silently ignore
+        }
+    }
+
+    getTotalDuration() {
+        // In session mode (HLS generated by our worker), video.duration only
+        // reflects the segments generated so far, NOT the full movie length.
+        // Always prefer the known VOD duration in this case.
+        if (this.isSessionMode && this.knownDurationSec > 0) {
+            return this.knownDurationSec;
+        }
+
+        const mediaDuration = this.video?.duration;
+        if (Number.isFinite(mediaDuration) && mediaDuration > 0) {
+            const total = mediaDuration + (this.playbackBaseOffsetSec || 0);
+            // Even outside session mode, pick whichever is larger
+            return (this.knownDurationSec > total) ? this.knownDurationSec : total;
+        }
+        return this.knownDurationSec || 0;
+    }
+
+    getAbsoluteCurrentTime() {
+        if (!this.video) return 0;
+        return (this.playbackBaseOffsetSec || 0) + (this.video.currentTime || 0);
+    }
+
    // === Loading Spinner ===

    showLoading() {
@@ -1417,7 +1643,7 @@ class WatchPage {
        try {
            const data = {
                title: this.content.title || 'Unknown Title',
-                subtitle: this.content.subtitle || (this.content.type === 'movie' ? 'Movie' : 'Series'),
+                subtitle: this.content.subtitle || (this.content.type === 'movie' ? 'Película' : 'Serie'),
                poster: this.content.poster,
                sourceId: this.content.sourceId,
                containerExtension: this.containerExtension,
@@ -1,10 +1,10 @@
 <!DOCTYPE html>
-<html lang="en">
+<html lang="es">

 <head>
    <meta charset="UTF-8">
    <meta name="viewport" content="width=device-width, initial-scale=1.0">
-    <title>Login - NodeCast TV</title>
+    <title>Iniciar sesión — KiraTV</title>
    <link rel="icon" type="image/svg+xml" href="/favicon.svg">
    <link rel="stylesheet" href="css/main.css">
    <link href="https://fonts.googleapis.com/css2?family=Inter:wght@400;500;600;700&display=swap" rel="stylesheet">
@@ -171,13 +171,13 @@
                    <path
                        d="M169.71,87.87c-4.77,0-9.1,1.88-12.31,4.92L35.3,22.3c.35-1.4.56-2.86.56-4.37C35.86,8.03,27.83,0,17.93,0S0,8.03,0,17.93c0,8.44,5.84,15.5,13.69,17.4v140c-7.71,2.01-13.41,8.99-13.41,17.33,0,9.9,8.03,17.93,17.93,17.93s17.93-8.03,17.93-17.93c0-1.56-.22-3.07-.6-4.51l121.21-69.98c3.26,3.42,7.86,5.55,12.95,5.55,9.9,0,17.93-8.03,17.93-17.93s-8.03-17.93-17.93-17.93ZM152.78,99.92c-.14.41-.27.83-.38,1.25h-51.47l-44.18-24.72L30.4,30.8c.33-.32.64-.65.94-.99l121.45,70.12ZM22.17,175.2V35.33c.23-.05.45-.11.67-.17l26.35,45.65-.34,50.04-25.74,44.59c-.31-.09-.63-.17-.95-.24ZM31.52,180.69c-.27-.3-.55-.6-.84-.89l25.48-44.13,44.64-25.78h51.47c.07.32.15.63.24.94L31.52,180.69Z" />
                </svg>
-                <h1>nodecast-tv</h1>
-                <p id="login-subtitle">Sign in to continue</p>
+                <h1>KiraTV</h1>
+                <p id="login-subtitle">Inicia sesión para continuar</p>
            </div>

            <div class="error-message" id="error-message"></div>
            <div class="setup-message" id="setup-message">
-                Welcome! Please create your admin account to get started.
+                Bienvenido. Crea tu cuenta de administrador para empezar.
            </div>

            <form id="login-form">
@@ -27,7 +27,14 @@ app.use(session({
 app.use(passport.initialize());
 app.use(passport.session());

-app.use(express.static(path.join(__dirname, '..', 'public')));
+// Serve static files with no-cache for JS/CSS so browser always loads the latest version
+app.use(express.static(path.join(__dirname, '..', 'public'), {
+    setHeaders(res, filePath) {
+        if (filePath.endsWith('.js') || filePath.endsWith('.css')) {
+            res.setHeader('Cache-Control', 'no-cache, must-revalidate');
+        }
+    }
+}));

 // FFMPEG Configuration (optional - for transcoding support)
 // Priority: 1. System FFmpeg (better Docker DNS support), 2. ffmpeg-static npm package
@@ -88,6 +95,86 @@ function findFFprobe() {
 app.locals.ffmpegPath = findFFmpeg();
 app.locals.ffprobePath = findFFprobe();

+// Dynamic services loader - collects exports from files in ./services
+const fs = require('fs');
+const services = {};
+try {
+    const servicesDir = path.join(__dirname, 'services');
+    const serviceFiles = fs.readdirSync(servicesDir).filter(f => f.endsWith('.js'));
+    for (const file of serviceFiles) {
+        const name = file.replace(/\.js$/, '');
+        try {
+            services[name] = require(path.join(servicesDir, file));
+        } catch (e) {
+            console.warn(`Failed to load service ${file}:`, e.message);
+        }
+    }
+} catch (e) {
+    console.warn('No services directory found or failed to read services:', e.message);
+}
+
+// Freeze services object to prevent plugins from mutating shared state
+Object.freeze(services);
+
+// Plugin loader: loads any .js file inside server/plugins and calls the
+// exported function with (app, services).
+// Supports both function exports and object exports with lifecycle hooks.
+const loadedPlugins = [];
+
+async function loadPlugins() {
+    try {
+        const pluginsDir = path.join(__dirname, 'plugins');
+        if (fs.existsSync(pluginsDir)) {
+            // Sort plugin files alphabetically for deterministic load order
+            const pluginFiles = fs.readdirSync(pluginsDir)
+                .filter(f => f.endsWith('.js'))
+                .sort();
+
+            for (const file of pluginFiles) {
+                const pluginPath = path.join(pluginsDir, file);
+                try {
+                    const plugin = require(pluginPath);
+
+                    // Support both function exports and object exports with lifecycle hooks
+                    if (typeof plugin === 'function') {
+                        // Direct function export (sync or async)
+                        await plugin(app, services);
+                        loadedPlugins.push({ name: file, plugin: null });
+                        console.log(`✓ Loaded plugin: ${file}`);
+                    } else if (plugin && typeof plugin.init === 'function') {
+                        // Object export with init/shutdown lifecycle
+                        await plugin.init(app, services);
+                        loadedPlugins.push({ name: file, plugin });
+                        console.log(`✓ Loaded plugin: ${file} (with lifecycle hooks)`);
+                    } else {
+                        console.warn(`⚠ Plugin ${file} does not export a function or object with init(), skipping.`);
+                    }
+                } catch (err) {
+                    console.error(`✗ Failed to load plugin ${file}:`, err);
+                }
+            }
+        }
+    } catch (err) {
+        console.warn('Plugin loader failed:', err.message);
+    }
+}
+
+// Graceful shutdown handler for plugins with shutdown hooks
+process.on('SIGTERM', async () => {
+    console.log('SIGTERM received, shutting down plugins...');
+    for (const { name, plugin } of loadedPlugins) {
+        if (plugin && typeof plugin.shutdown === 'function') {
+            try {
+                await plugin.shutdown();
+                console.log(`✓ Shutdown plugin: ${name}`);
+            } catch (err) {
+                console.error(`✗ Error shutting down plugin ${name}:`, err);
+            }
+        }
+    }
+    process.exit(0);
+});
+
 // API Routes
 app.use('/api/auth', require('./routes/auth'));
 app.use('/api/sources', require('./routes/sources'));
@@ -119,7 +206,12 @@ app.use((err, req, res, next) => {
 });

 app.listen(PORT, async () => {
-    console.log(`NodeCast TV server running on http://localhost:${PORT}`);
+    console.log(`KiraTV server running on http://localhost:${PORT}`);
+
+    // Load plugins
+    await loadPlugins().catch(err => {
+        console.error('Plugin initialization failed:', err);
+    });

    // Trigger background sync with delay to allow server to settle
    setTimeout(async () => {
@@ -0,0 +1,163 @@
+# nodecast-tv Plugin System
+
+This directory allows you to extend the functionality of **nodecast-tv** without modifying the core source code. The server automatically detects and loads any `.js` file placed in this folder at startup.
+
+---
+
+## How It Works
+
+The plugin loader in `server/index.js` scans this directory at startup and loads plugins in **alphabetical order** (sorted by filename). Each plugin file should export either:
+- A function (sync or async) that will be called during initialization
+- An object with `init()` and optionally `shutdown()` methods for lifecycle management
+
+When the server starts, it calls your plugin's initialization code and passes:
+- `app` - The Express application instance
+- `services` - A **frozen** (read-only) object containing all internal services
+
+---
+
+## Plugin Patterns
+
+### Pattern 1: Simple Function Export
+
+The simplest plugin pattern - just export a function:
+
+```javascript
+/**
+ * @param {Object} app - The Express application instance
+ * @param {Object} services - Frozen object containing all internal services
+ */
+module.exports = function(app, services) {
+    // Register routes, middleware, etc.
+    app.get('/api/my-route', (req, res) => {
+        res.json({ message: 'Hello from plugin!' });
+    });
+};
+```
+
+### Pattern 2: Async Function Export
+
+For plugins that need to perform async initialization (database connections, API calls, etc.):
+
+```javascript
+module.exports = async function(app, services) {
+    // Async initialization
+    await someAsyncSetup();
+    
+    // Access services
+    if (services.syncService) {
+        console.log('Sync service available');
+    }
+    
+    // Register routes
+    app.get('/api/my-route', (req, res) => {
+        res.json({ status: 'ready' });
+    });
+};
+```
+
+### Pattern 3: Lifecycle Hooks (Advanced)
+
+For plugins that need cleanup on shutdown:
+
+```javascript
+module.exports = {
+    /**
+     * Called during server startup
+     */
+    init: async (app, services) => {
+        // Setup code
+        this.interval = setInterval(() => {
+            console.log('Background task running...');
+        }, 60000);
+        
+        app.get('/api/status', (req, res) => {
+            res.json({ uptime: process.uptime() });
+        });
+    },
+    
+    /**
+     * Called on SIGTERM (graceful shutdown)
+     */
+    shutdown: async () => {
+        // Cleanup code
+        if (this.interval) {
+            clearInterval(this.interval);
+        }
+        console.log('Plugin cleaned up');
+    }
+};
+```
+
+---
+
+## Security & Permissions
+
+> [!WARNING]
+> Plugins run with **full Node.js permissions** and have access to the Express app and all services. Only install plugins from trusted sources.
+
+**Important notes:**
+- The `services` object is **frozen** - you cannot modify or delete services
+- Plugins can still mutate properties of service objects (e.g., `services.cache.set()`)
+- Plugins can register routes, middleware, and access the file system
+- This is appropriate for self-hosted applications where you control what plugins are installed
+
+---
+
+## Available Services
+
+The `services` object contains all modules from `server/services/`:
+
+| Service | Description |
+|---------|-------------|
+| `cache` | Caching utilities |
+| `epgParser` | EPG/XMLTV parsing |
+| `hwDetect` | Hardware acceleration detection |
+| `m3uParser` | M3U playlist parsing |
+| `m3uXtreamAdapter` | Xtream API adapter |
+| `syncService` | Channel/EPG synchronization |
+| `transcodeSession` | Transcoding session management |
+| `xtreamApi` | Xtream API client |
+
+**Example:**
+```javascript
+module.exports = async function(app, services) {
+    // Use the EPG parser service
+    const epgData = await services.epgParser.fetchAndParse('http://example.com/epg.xml');
+    console.log(`Loaded ${epgData.programmes.length} programmes`);
+};
+```
+
+---
+
+## Load Order
+
+Plugins are loaded in **alphabetical order** by filename. If you need specific ordering:
+
+```
+plugins/
+  01-database.js      # Loads first
+  02-api-client.js    # Loads second
+  99-cleanup.js       # Loads last
+```
+
+---
+
+## Testing Your Plugin
+
+1. Place your `.js` file in `server/plugins/`
+2. Restart the NodeCast TV server
+3. Check the console for plugin loading messages:
+   - `✓ Loaded plugin: your-plugin.js` - Success
+   - `⚠ Plugin your-plugin.js does not export...` - Wrong export format
+   - `✗ Failed to load plugin your-plugin.js` - Error during initialization
+
+---
+
+## Example Use Cases
+
+- **Custom scrapers** - Add support for new streaming sources
+- **Notification systems** - Send alerts when new content is available
+- **Analytics** - Track viewing patterns
+- **Custom APIs** - Expose additional endpoints for integrations
+- **Middleware** - Add authentication, logging, or rate limiting
@@ -0,0 +1,25 @@
+/**
+ * Example plugin demonstrating async initialization and service access
+ * This plugin registers a test route at /api/hello
+ */
+module.exports = async function (app, services) {
+    console.log("Plugin 'Hello' activated!");
+
+    // Example: Access loaded services
+    if (services.syncService) {
+        console.log("   - syncService is available");
+    }
+
+    // Simulate async initialization (e.g., database connection, API setup)
+    await new Promise(resolve => setTimeout(resolve, 100));
+
+    // Register a test route accessible at http://localhost:3000/api/hello
+    app.get('/api/hello', (req, res) => {
+        res.json({
+            message: "The plugin system is working!",
+            availableServices: Object.keys(services)
+        });
+    });
+
+    console.log("   - Registered route: GET /api/hello");
+};
@@ -1,6 +1,7 @@
 const express = require('express');
 const router = express.Router();
 const { spawn } = require('child_process');
+const streamInput = require('../utils/streamInput');

 /**
 * Probe endpoint - detects stream codecs and container
@@ -30,16 +31,27 @@ const BROWSER_AUDIO_CODECS = ['aac', 'mp3', 'opus', 'vorbis'];
 */
 function probeStream(url, ffprobePath, userAgent = null, timeout = 15000) {
    return new Promise((resolve, reject) => {
+        const sizing = streamInput.probeSizingForUrl(url);
+        const referer = streamInput.deriveRefererFromUrl(url);
+        const effectiveTimeout = sizing.heavy ? Math.max(timeout, 45000) : timeout;
+
        const args = [
            '-v', 'error',
-            '-user_agent', userAgent || 'Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/123.0.0.0 Safari/537.36',
+            '-user_agent', userAgent || 'Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/123.0.0.0 Safari/537.36'
+        ];
+
+        if (referer) {
+            args.push('-referer', referer);
+        }
+
+        args.push(
            '-print_format', 'json',
            '-show_streams',
            '-show_format',
-            '-probesize', '5000000',
-            '-analyzeduration', '5000000',
+            '-probesize', sizing.probesize,
+            '-analyzeduration', sizing.analyzeduration,
            url
-        ];
+        );

        const proc = spawn(ffprobePath, args);
        let stdout = '';
@@ -48,7 +60,7 @@ function probeStream(url, ffprobePath, userAgent = null, timeout = 15000) {
        const timer = setTimeout(() => {
            proc.kill('SIGKILL');
            reject(new Error('Probe timeout'));
-        }, timeout);
+        }, effectiveTimeout);

        proc.stdout.on('data', (data) => { stdout += data; });
        proc.stderr.on('data', (data) => { stderr += data; });
@@ -170,22 +182,46 @@ router.get('/', async (req, res) => {

    console.log(`[Probe] Probing: ${url.substring(0, 80)}... ${ua ? `(UA: ${ua})` : ''}`);

+    // Retry probe up to 3 times on 5XX errors (provider slot not released yet)
+    const MAX_PROBE_RETRIES = 3;
+    const PROBE_RETRY_DELAY_MS = 2500;
+    let lastErr = null;
+
+    for (let attempt = 1; attempt <= MAX_PROBE_RETRIES; attempt++) {
        try {
            const probeResult = await probeStream(url, ffprobePath, ua);
            const analysis = analyzeProbeResult(probeResult, url);

-        // Cache result
+            // Cache successful result
            probeCache.set(cacheKey, { result: analysis, timestamp: Date.now() });

-        console.log(`[Probe] Result: video=${analysis.video}, audio=${analysis.audio}, ` +
+            console.log(`[Probe] Result (attempt ${attempt}): video=${analysis.video}, audio=${analysis.audio}, ` +
                `container=${analysis.container}, compatible=${analysis.compatible}, ` +
                `needsRemux=${analysis.needsRemux}, needsTranscode=${analysis.needsTranscode}`);

-        res.json(analysis);
+            return res.json(analysis);
        } catch (err) {
-        console.error('[Probe] Failed:', err.message);
+            lastErr = err;
+            const is5xx = /5[0-9]{2}|Server Error/i.test(err.message);
+            if (is5xx && attempt < MAX_PROBE_RETRIES) {
+                console.warn(`[Probe] 5XX from provider (attempt ${attempt}/${MAX_PROBE_RETRIES}), retrying in ${PROBE_RETRY_DELAY_MS}ms...`);
+                await new Promise(r => setTimeout(r, PROBE_RETRY_DELAY_MS));
+                continue;
+            }
+            break;
+        }
+    }

-        // On error, assume transcode needed to be safe
+    console.error('[Probe] Failed after retries:', lastErr.message);
+
+    // If there's a stale cached result, use it rather than assuming needsTranscode
+    const stale = probeCache.get(cacheKey);
+    if (stale) {
+        console.warn('[Probe] Using stale cached result as fallback');
+        return res.json({ ...stale.result, stale: true });
+    }
+
+    // Final fallback: assume transcode needed
    res.json({
        video: 'unknown',
        audio: 'unknown',
@@ -193,9 +229,8 @@ router.get('/', async (req, res) => {
        compatible: false,
        needsRemux: false,
        needsTranscode: true,
-            error: err.message
+        error: lastErr.message
    });
-    }
 });

 module.exports = router;
@@ -1,10 +1,45 @@
 const express = require('express');
 const router = express.Router();
-const { spawn } = require('child_process');
+const { spawn, execFile } = require('child_process');
 const path = require('path');
 const fs = require('fs').promises;
 const db = require('../db');
 const transcodeSession = require('../services/transcodeSession');
+const streamInput = require('../utils/streamInput');
+
+/**
+ * Probe a stream URL with FFprobe to get its total duration in seconds.
+ * VOD pesado usa probes mayores y timeout más alto (MKV Jellyfin/remux).
+ */
+function probeDuration(url, ffprobePath, userAgent) {
+    return new Promise((resolve) => {
+        const sizing = streamInput.probeSizingForUrl(url);
+        const referer = streamInput.deriveRefererFromUrl(url);
+        const args = [
+            '-v', 'quiet',
+            '-print_format', 'json',
+            '-show_entries', 'format=duration',
+            '-user_agent', userAgent || 'Mozilla/5.0',
+            '-probesize', sizing.probesize,
+            '-analyzeduration', sizing.analyzeduration,
+        ];
+        if (referer) {
+            args.push('-referer', referer);
+        }
+        args.push(url);
+        const timeoutMs = sizing.heavy ? 45000 : 8000;
+        const proc = execFile(ffprobePath || 'ffprobe', args, { timeout: timeoutMs }, (err, stdout) => {
+            if (err) { resolve(0); return; }
+            try {
+                const data = JSON.parse(stdout);
+                const dur = parseFloat(data?.format?.duration);
+                resolve(Number.isFinite(dur) && dur > 0 ? Math.round(dur) : 0);
+            } catch { resolve(0); }
+        });
+        // Ensure the process is killed if execFile timeout fires
+        proc.on('error', () => resolve(0));
+    });
+}

 /**
 * Transcode Routes
@@ -40,38 +75,78 @@ router.post('/session', async (req, res) => {
    const userAgent = db.getUserAgent(settings);

    try {
-        const session = await transcodeSession.createSession(url, {
+        const ffprobePath = (ffmpegPath || 'ffmpeg').replace(/ffmpeg$/, 'ffprobe');
+
+        // Probe duration and start session in parallel (don't block on duration)
+        const [session, durationSec] = await Promise.all([
+            transcodeSession.createSession(url, {
                ffmpegPath,
                userAgent,
                seekOffset: seekOffset || 0,
                hwEncoder: settings.hwEncoder || 'software',
                maxResolution: settings.maxResolution || '1080p',
                quality: settings.quality || 'medium',
-            audioMixPreset: settings.audioMixPreset || 'auto', // Audio downmix preset
-            // Upscaling options
+                audioMixPreset: settings.audioMixPreset || 'auto',
                upscaleEnabled: settings.upscaleEnabled || false,
                upscaleMethod: settings.upscaleMethod || 'hardware',
                upscaleTarget: settings.upscaleTarget || '1080p',
-            videoMode: videoMode, // 'copy' or 'encode'
-            videoCodec: videoCodec, // 'h264', 'hevc', etc.
-            audioCodec: audioCodec, // 'aac', 'ac3', etc.
-            audioChannels: audioChannels // number of channels (2=stereo)
-        });
-
-        await session.start();
+                videoMode: videoMode,
+                videoCodec: videoCodec,
+                audioCodec: audioCodec,
+                audioChannels: audioChannels
+            }).then(async s => { await s.start(); return s; }),
+            probeDuration(url, ffprobePath, userAgent)
+        ]);

        // Wait for playlist to be ready (first segments generated)
-        const ready = await session.waitForPlaylist(15000);
+        // VOD pesado (4K HEVC/remux) puede tardar >15 s en generar el primer segmento
+        const waitTimeout = streamInput.isHeavyVodUrl(url) ? 60000 : 15000;
+        let ready = await session.waitForPlaylist(waitTimeout);
+
+        // Fallback a software si el encoder HW falla inmediatamente (error rápido)
+        if (!ready && session.status === 'error' && (settings.hwEncoder || 'software') !== 'software') {
+            console.warn(`[Transcode] HW encoder (${settings.hwEncoder}) falló, reintentando con software libx264...`);
+            await transcodeSession.removeSession(session.id);
+            const swSession = await transcodeSession.createSession(url, {
+                ffmpegPath,
+                userAgent,
+                seekOffset: seekOffset || 0,
+                hwEncoder: 'software',
+                maxResolution: settings.maxResolution || '1080p',
+                quality: settings.quality || 'medium',
+                audioMixPreset: settings.audioMixPreset || 'auto',
+                upscaleEnabled: false,
+                videoMode: videoMode,
+                videoCodec: videoCodec,
+                audioCodec: audioCodec,
+                audioChannels: audioChannels
+            });
+            await swSession.start();
+            ready = await swSession.waitForPlaylist(waitTimeout);
+            if (ready) {
+                console.log(`[Transcode] Software fallback OK → session ${swSession.id}`);
+                return res.json({
+                    sessionId: swSession.id,
+                    playlistUrl: `/api/transcode/${swSession.id}/stream.m3u8`,
+                    status: swSession.status,
+                    durationSec: durationSec || 0
+                });
+            }
+            await transcodeSession.removeSession(swSession.id);
+        }

        if (!ready) {
            await transcodeSession.removeSession(session.id);
            return res.status(500).json({ error: 'Transcoding failed to start', reason: 'Playlist not generated in time' });
        }

+        console.log(`[Transcode] Session ${session.id} ready. Source duration: ${durationSec}s`);
+
        res.json({
            sessionId: session.id,
            playlistUrl: `/api/transcode/${session.id}/stream.m3u8`,
-            status: session.status
+            status: session.status,
+            durationSec: durationSec || 0
        });

    } catch (err) {
@@ -144,6 +219,30 @@ router.delete('/:sessionId', async (req, res) => {
    }
 });

+/**
+ * Heartbeat — keeps a session alive while the player is active.
+ * POST /api/transcode/:sessionId/heartbeat
+ */
+router.post('/:sessionId/heartbeat', (req, res) => {
+    const session = transcodeSession.getSession(req.params.sessionId);
+    if (!session) return res.status(404).json({ error: 'Session not found' });
+    session.lastAccess = Date.now();
+    res.json({ ok: true });
+});
+
+/**
+ * Stop session via POST (for sendBeacon on page close)
+ * POST /api/transcode/:sessionId/stop
+ */
+router.post('/:sessionId/stop', async (req, res) => {
+    try {
+        await transcodeSession.removeSession(req.params.sessionId);
+        res.json({ success: true });
+    } catch (err) {
+        res.status(500).json({ error: 'Failed to remove session', details: err.message });
+    }
+});
+
 /**
 * List all active sessions (for debugging)
 * GET /api/transcode/sessions
@@ -175,6 +274,9 @@ router.get('/', async (req, res) => {
    console.log(`[Transcode] Using User-Agent: ${settings.userAgentPreset}`);
    console.log(`[Transcode] Using binary: ${ffmpegPath}`);

+    const sizing = streamInput.probeSizingForUrl(url);
+    const referer = streamInput.deriveRefererFromUrl(url);
+
    // FFmpeg arguments for transcoding
    // Optimized for VOD content with incompatible audio (Dolby/AC3/EAC3)
    // Also works for live streams with ad stitching (Pluto TV, etc.)
@@ -182,9 +284,13 @@ router.get('/', async (req, res) => {
        '-hide_banner',
        '-loglevel', 'warning',
        '-user_agent', userAgent,
-        // Faster startup - reduced probe/analyze for quicker first bytes
-        '-probesize', '2000000', // 2MB (reduced from 5MB)
-        '-analyzeduration', '3000000', // 3 seconds (reduced from 10s)
+    ];
+    if (referer) {
+        args.push('-referer', referer);
+    }
+    args.push(
+        '-probesize', sizing.probesize,
+        '-analyzeduration', sizing.analyzeduration,
        // Error resilience: generate timestamps, discard corrupt packets
        '-fflags', '+genpts+discardcorrupt+nobuffer',
        // Ignore errors in stream and continue
@@ -197,7 +303,9 @@ router.get('/', async (req, res) => {
        '-reconnect_delay_max', '3',
        // Prevent Range/HEAD requests that some providers reject with 405
        '-seekable', '0',
-        '-i', url,
+        '-i', url
+    );
+    args.push(
        // Map only first video and audio stream (avoid subtitle streams causing issues)
        '-map', '0:v:0',
        '-map', '0:a:0?', // ? makes audio optional if not present
@@ -218,7 +326,7 @@ router.get('/', async (req, res) => {
        '-movflags', 'frag_keyframe+empty_moov+default_base_moof+faststart',
        '-flush_packets', '1', // Send data immediately
        '-' // Output to stdout
-    ];
+    );

    console.log(`[Transcode] Full command: ${ffmpegPath} ${args.join(' ')}`);

@@ -228,16 +228,18 @@ async function detect() {
        detectAMF()
    ]);

-    // Determine recommended encoder (priority: NVENC > AMF > QSV > VAAPI > Software)
+    // Determine recommended encoder
+    // On Linux: prefer VAAPI over QSV — VAAPI is more reliable in LXC containers
+    // (QSV may fail to initialize the MFX device even when /dev/dri is passed through)
    let recommended = 'software';
    if (nvidia.available) {
        recommended = 'nvenc';
    } else if (amf.available) {
        recommended = 'amf';
-    } else if (qsv.available) {
-        recommended = 'qsv';
    } else if (vaapi.available) {
        recommended = 'vaapi';
+    } else if (qsv.available) {
+        recommended = 'qsv';
    }

    hwCapabilities = {
@@ -0,0 +1,781 @@
+/**
+ * Transcode Session Service
+ * 
+ * Manages HLS transcoding sessions with segment caching for VOD seeking.
+ * Each session transcodes a source URL to HLS segments on disk.
+ * 
+ * Key features:
+ * - Session-based transcoding with unique IDs
+ * - HLS segment output for seeking support
+ * - Segment caching for fast access
+ * - Session persistence for recovery after restart
+ * - Automatic cleanup of stale sessions
+ */
+
+const { spawn } = require('child_process');
+const path = require('path');
+const fs = require('fs').promises;
+const crypto = require('crypto');
+const EventEmitter = require('events');
+const hwDetect = require('./hwDetect');
+
+// Session storage
+const sessions = new Map();
+
+// Cache directory for transcoded segments
+const CACHE_DIR = path.join(process.cwd(), 'transcode-cache');
+
+// Session settings
+const SESSION_TIMEOUT_MS = 30 * 60 * 1000; // 30 minutes idle timeout
+const SEGMENT_DURATION = 4; // seconds per HLS segment
+const CLEANUP_INTERVAL_MS = 5 * 60 * 1000; // Check every 5 minutes
+
+/**
+ * Generate a unique session ID
+ */
+function generateSessionId() {
+    return crypto.randomBytes(8).toString('hex');
+}
+
+/**
+ * Ensure cache directory exists
+ */
+async function ensureCacheDir() {
+    try {
+        await fs.mkdir(CACHE_DIR, { recursive: true });
+    } catch (err) {
+        if (err.code !== 'EEXIST') throw err;
+    }
+}
+
+/**
+ * TranscodeSession class
+ * Manages a single transcoding session from source URL to HLS segments
+ */
+class TranscodeSession extends EventEmitter {
+    constructor(url, options = {}) {
+        super();
+        this.id = generateSessionId();
+        this.url = url;
+        this.dir = path.join(CACHE_DIR, this.id);
+        this.playlistPath = path.join(this.dir, 'stream.m3u8');
+        this.process = null;
+        this.segments = new Map(); // segment index -> { ready: boolean, path: string }
+        this.status = 'pending'; // pending | starting | running | stopped | error
+        this.error = null;
+        this.startTime = Date.now();
+        this.lastAccess = Date.now();
+        this.options = {
+            ffmpegPath: options.ffmpegPath || 'ffmpeg',
+            userAgent: options.userAgent || 'Mozilla/5.0',
+            seekOffset: options.seekOffset || 0,
+            hwEncoder: options.hwEncoder || 'software',
+            maxResolution: options.maxResolution || '1080p',
+            quality: options.quality || 'medium',
+            // Upscaling options
+            upscaleEnabled: options.upscaleEnabled || false,
+            upscaleMethod: options.upscaleMethod || 'hardware', // 'hardware' or 'software'
+            upscaleTarget: options.upscaleTarget || '1080p',
+            ...options
+        };
+    }
+
+    /**
+     * Start the transcoding process
+     */
+    async start() {
+        if (this.status === 'running') {
+            return;
+        }
+
+        this.status = 'starting';
+        console.log(`[TranscodeSession ${this.id}] Starting session for: ${this.url}`);
+
+        // Create session directory
+        try {
+            await fs.mkdir(this.dir, { recursive: true });
+        } catch (err) {
+            this.status = 'error';
+            this.error = err.message;
+            throw err;
+        }
+
+        // Build FFmpeg arguments for HLS output
+        const args = this.buildFFmpegArgs();
+
+        console.log(`[TranscodeSession ${this.id}] Command: ${this.options.ffmpegPath} ${args.join(' ')}`);
+
+        try {
+            this.process = spawn(this.options.ffmpegPath, args, {
+                cwd: this.dir,
+                windowsHide: true
+            });
+
+            this.status = 'running';
+
+            // Handle stdout (should be empty for file output)
+            this.process.stdout.on('data', (data) => {
+                console.log(`[TranscodeSession ${this.id}] stdout: ${data}`);
+            });
+
+            // Handle stderr (FFmpeg progress/errors)
+            let stderrBuffer = '';
+            this.process.stderr.on('data', (data) => {
+                stderrBuffer += data.toString();
+                // Log periodically to avoid spam
+                const lines = stderrBuffer.split('\n');
+                if (lines.length > 1) {
+                    lines.slice(0, -1).forEach(line => {
+                        if (line.trim()) {
+                            console.log(`[FFmpeg ${this.id}] ${line}`);
+                        }
+                    });
+                    stderrBuffer = lines[lines.length - 1];
+                }
+            });
+
+            // Handle process exit
+            this.process.on('exit', (code) => {
+                if (code === 0 || code === null) {
+                    console.log(`[TranscodeSession ${this.id}] FFmpeg completed successfully`);
+                    this.status = 'stopped';
+                } else if (code !== 255) { // 255 is often from SIGKILL
+                    console.error(`[TranscodeSession ${this.id}] FFmpeg exited with code ${code}`);
+                    this.status = 'error';
+                    this.error = `FFmpeg exited with code ${code}`;
+                }
+                this.process = null;
+                this.emit('exit', code);
+            });
+
+            // Handle spawn errors
+            this.process.on('error', (err) => {
+                console.error(`[TranscodeSession ${this.id}] FFmpeg error:`, err);
+                this.status = 'error';
+                this.error = err.message;
+                this.emit('error', err);
+            });
+
+            // Save session metadata
+            await this.persist();
+
+        } catch (err) {
+            this.status = 'error';
+            this.error = err.message;
+            throw err;
+        }
+    }
+
+    /**
+     * Build FFmpeg arguments for HLS output with optional GPU encoding
+     */
+    buildFFmpegArgs() {
+        const segmentPattern = path.join(this.dir, 'seg%04d.m4s');
+        const videoMode = this.options.videoMode || 'encode';
+
+        // Resolve 'auto' encoder to detected hardware, fallback to software
+        let encoder = this.options.hwEncoder || 'software';
+        if (encoder === 'auto') {
+            const hwCaps = hwDetect.getCapabilities();
+            encoder = hwCaps?.recommended || 'software';
+            console.log(`[TranscodeSession ${this.id}] Auto encoder resolved to: ${encoder}`);
+        }
+
+        const args = [
+            '-hide_banner',
+            '-loglevel', 'warning',
+            '-user_agent', this.options.userAgent,
+        ];
+
+        // Add hardware acceleration input options based on encoder (only if encoding)
+        if (videoMode === 'encode') {
+            this.addHwAccelInputArgs(args, encoder);
+        }
+
+        // Input options (common)
+        args.push(
+            '-probesize', '5000000',
+            '-analyzeduration', '5000000',
+            '-fflags', '+genpts+discardcorrupt',
+            '-err_detect', 'ignore_err',
+            '-reconnect', '1',
+            '-reconnect_streamed', '1',
+            '-reconnect_delay_max', '3'
+        );
+
+        args.push('-i', this.url);
+
+        // Add seek offset if specified (as output option to avoid Range requests)
+        if (this.options.seekOffset > 0) {
+            args.push('-ss', String(this.options.seekOffset));
+        }
+
+        // Map streams
+        args.push('-map', '0:v:0');
+        args.push('-map', '0:a:0?');
+
+        // Add video encoder and filters based on selected encoder OR copy
+        if (videoMode === 'copy') {
+            args.push('-c:v', 'copy');
+
+            // Critical for MKV/MP4 -> TS copy: Convert bitstream from AVCC/HVCC to Annex B
+            if (this.options.videoCodec === 'hevc' || this.options.videoCodec === 'h265') {
+                args.push('-bsf:v', 'hevc_mp4toannexb');
+            } else if (this.options.videoCodec === 'h264' || this.options.videoCodec === 'avc') {
+                // Keep Annex-B conversion and force parameter sets to be repeated.
+                // This helps players recover on streams where SPS/PPS appear sporadically,
+                // which often manifests as "audio OK, black video".
+                args.push('-bsf:v', 'h264_mp4toannexb,dump_extra');
+            } else {
+                // Fallback (e.g. unknown codec), try strict extraction
+                args.push('-bsf:v', 'dump_extra');
+            }
+        } else {
+            this.addVideoEncoderArgs(args, encoder);
+        }
+
+        // Audio: Apply mix preset
+        const audioCodec = this.options.audioCodec?.toLowerCase() || 'unknown';
+        const audioChannels = this.options.audioChannels || 0;
+        const audioMixPreset = this.options.audioMixPreset || 'auto';
+        const isStereoAac = audioCodec.includes('aac') && audioChannels === 2;
+
+        // Define pan filter presets for 5.1 -> Stereo downmix
+        const AUDIO_MIX_FILTERS = {
+            // ITU-R BS.775 Standard: Mathematically balanced, transparent
+            itu: 'pan=stereo|FL=FL+0.707*FC+0.707*BL+0.5*LFE|FR=FR+0.707*FC+0.707*BR+0.5*LFE',
+            // Night Mode: Heavy dialogue boost, reduced bass/surrounds for quiet viewing
+            night: 'pan=stereo|FL=0.5*FL+1.2*FC+0.3*BL+0.1*LFE|FR=0.5*FR+1.2*FC+0.3*BR+0.1*LFE',
+            // Cinematic: Wide soundstage, immersive (original "dialogue boost" mix)
+            cinematic: 'pan=stereo|FL=FC+0.80*FL+0.60*BL+0.5*LFE|FR=FC+0.80*FR+0.60*BR+0.5*LFE'
+        };
+
+        if (audioMixPreset === 'passthrough') {
+            // Passthrough: Always copy audio, no processing
+            console.log(`[TranscodeSession ${this.id}] Audio: Passthrough (copy)`);
+            args.push('-c:a', 'copy');
+        } else if (audioMixPreset === 'auto' && isStereoAac) {
+            // Auto + Stereo AAC source: Smart copy
+            console.log(`[TranscodeSession ${this.id}] Audio: Auto (Smart Copy) - Source is Stereo AAC`);
+            args.push('-c:a', 'copy');
+        } else {
+            // Transcode to AAC with selected mix preset (default to ITU for 'auto')
+            const mixPreset = (audioMixPreset === 'auto') ? 'itu' : audioMixPreset;
+            const panFilter = AUDIO_MIX_FILTERS[mixPreset] || AUDIO_MIX_FILTERS.itu;
+
+            console.log(`[TranscodeSession ${this.id}] Audio: ${mixPreset.toUpperCase()} mix (${audioCodec} ${audioChannels}ch -> Stereo AAC)`);
+            args.push(
+                '-c:a', 'aac',
+                '-ar', '48000',
+                '-b:a', '192k',
+                '-af', `${panFilter},aresample=async=1`
+            );
+        }
+
+        // HLS output options
+        args.push(
+            '-f', 'hls',
+            '-hls_time', String(SEGMENT_DURATION),
+            '-hls_list_size', '0', // Keep all segments in playlist
+            '-hls_flags', 'independent_segments+append_list',
+            '-hls_segment_type', 'mpegts',
+            '-hls_segment_filename', path.join(this.dir, 'seg%04d.ts'),
+            this.playlistPath
+        );
+
+        return args;
+    }
+
+    /**
+     * Add hardware acceleration input arguments
+     */
+    addHwAccelInputArgs(args, encoder) {
+        switch (encoder) {
+            case 'nvenc':
+                // NVIDIA CUDA/NVDEC hardware decoding
+                args.push(
+                    '-hwaccel', 'cuda',
+                    '-hwaccel_output_format', 'cuda'
+                );
+                break;
+            case 'vaapi':
+                // VAAPI hardware decoding (Linux)
+                args.push(
+                    '-hwaccel', 'vaapi',
+                    '-hwaccel_device', '/dev/dri/renderD128',
+                    '-hwaccel_output_format', 'vaapi'
+                );
+                break;
+            case 'qsv':
+                // Intel QuickSync hardware decoding
+                args.push(
+                    '-hwaccel', 'qsv',
+                    '-hwaccel_output_format', 'qsv'
+                );
+                break;
+            case 'amf':
+                // AMD AMF (no hwaccel input, AMF is encode-only)
+                // Decode on CPU, encode on GPU
+                break;
+            case 'software':
+            case 'auto':
+            default:
+                // No hardware acceleration for input
+                break;
+        }
+    }
+
+    /**
+     * Add video encoder arguments based on selected encoder
+     */
+    addVideoEncoderArgs(args, encoder) {
+        const resolution = this.getTargetHeight();
+        const quality = this.options.quality || 'medium';
+
+        // Quality presets mapping
+        const qualityPresets = {
+            'high': { nvenc: 18, vaapi: 18, qsv: 18, amf: 18, software: 18 },
+            'medium': { nvenc: 24, vaapi: 24, qsv: 24, amf: 24, software: 23 },
+            'low': { nvenc: 30, vaapi: 30, qsv: 30, amf: 30, software: 28 }
+        };
+        const qp = qualityPresets[quality] || qualityPresets.medium;
+
+        switch (encoder) {
+            case 'nvenc':
+                this.addNvencEncoderArgs(args, resolution, qp.nvenc);
+                break;
+            case 'amf':
+                this.addAmfEncoderArgs(args, resolution, qp.amf);
+                break;
+            case 'vaapi':
+                this.addVaapiEncoderArgs(args, resolution, qp.vaapi);
+                break;
+            case 'qsv':
+                this.addQsvEncoderArgs(args, resolution, qp.qsv);
+                break;
+            case 'software':
+            case 'auto':
+            default:
+                this.addSoftwareEncoderArgs(args, resolution, qp.software);
+                break;
+        }
+    }
+
+    /**
+     * Get target height based on maxResolution or upscaleTarget setting
+     * When upscaling is enabled, uses the upscaleTarget resolution.
+     * Otherwise, uses maxResolution to cap the output.
+     */
+    getTargetHeight() {
+        const resolutionMap = {
+            '4k': 2160,
+            '1080p': 1080,
+            '720p': 720,
+            '480p': 480
+        };
+
+        // When upscaling is enabled, use the upscale target resolution
+        if (this.options.upscaleEnabled) {
+            const target = resolutionMap[this.options.upscaleTarget] || 1080;
+            console.log(`[TranscodeSession ${this.id}] Upscale target height: ${target}p`);
+            return target;
+        }
+
+        // Otherwise, use max resolution as the cap
+        return resolutionMap[this.options.maxResolution] || 1080;
+    }
+
+    /**
+     * Build scale filter string based on encoder and upscaling settings
+     * @param {string} encoder - The encoder being used
+     * @param {number} height - Target height
+     */
+    buildScaleFilter(encoder, height) {
+        const useUpscale = this.options.upscaleEnabled;
+        const upscaleMethod = this.options.upscaleMethod || 'hardware';
+
+        // Log upscaling status
+        if (useUpscale) {
+            console.log(`[TranscodeSession ${this.id}] Upscaling: ${upscaleMethod} method to ${height}p`);
+        }
+
+        // Hardware scaling filters (for both upscale and downscale)
+        if (upscaleMethod === 'hardware' || !useUpscale) {
+            switch (encoder) {
+                case 'nvenc':
+                    // NVIDIA CUDA scaling with Lanczos
+                    // Force nv12 (8-bit) output to handle 10-bit inputs (fixes "10 bit encode not supported")
+                    return `scale_cuda=-2:${height}:interp_algo=lanczos:format=nv12`;
+                case 'vaapi':
+                    return `scale_vaapi=w=-2:h=${height}:format=nv12`;
+                case 'qsv':
+                    return `scale_qsv=w=-2:h=${height}:format=nv12`;
+                case 'amf':
+                    // AMF uses CPU decode, so use software scale
+                    return useUpscale ? `scale=-2:${height}:flags=lanczos` : `scale=-2:${height}`;
+                case 'software':
+                default:
+                    return useUpscale ? `scale=-2:${height}:flags=lanczos` : `scale=-2:${height}`;
+            }
+        }
+
+        // Software Lanczos scaling (high quality, slower)
+        return `scale=-2:${height}:flags=lanczos`;
+    }
+
+    /**
+     * NVIDIA NVENC encoder arguments
+     */
+    addNvencEncoderArgs(args, height, qp) {
+        // Video filter for scaling on GPU
+        args.push('-vf', this.buildScaleFilter('nvenc', height));
+
+        // NVENC encoder with quality settings
+        // Using portable options that work across FFmpeg builds
+        args.push(
+            '-c:v', 'h264_nvenc',
+            '-preset', 'p4',           // Balanced preset (p1=fastest, p7=best)
+            '-rc', 'constqp',          // Constant QP mode
+            '-qp', String(qp),
+            '-bf', '3'                 // B-frames for better compression
+        );
+    }
+
+    /**
+     * AMD AMF encoder arguments
+     */
+    addAmfEncoderArgs(args, height, qp) {
+        // CPU decoding + software scale + AMF encode
+        args.push('-vf', this.buildScaleFilter('amf', height));
+
+        args.push(
+            '-c:v', 'h264_amf',
+            '-quality', 'quality',     // Quality preset
+            '-rc', 'cqp',              // Constant QP
+            '-qp_i', String(qp),
+            '-qp_p', String(qp + 2),
+            '-qp_b', String(qp + 4),
+            '-pix_fmt', 'yuv420p'      // Force 8-bit output for compatibility
+        );
+    }
+
+    /**
+     * VAAPI encoder arguments (Linux)
+     */
+    addVaapiEncoderArgs(args, height, qp) {
+        // VAAPI filter chain:
+        // 1. scale_vaapi to resize on GPU
+        // 2. Ensure output format is nv12 for maximum encoder compatibility
+        // The format is handled automatically when using -hwaccel_output_format vaapi
+        args.push('-vf', this.buildScaleFilter('vaapi', height));
+
+        // VAAPI encoder with quality setting
+        // Note: -global_quality is the portable way to set quality for VAAPI
+        args.push(
+            '-c:v', 'h264_vaapi',
+            '-profile:v', 'main',      // Use main profile for compatibility
+            '-global_quality', String(qp),
+            '-bf', '3',
+            '-pix_fmt', 'yuv420p'      // Force 8-bit output for compatibility
+        );
+    }
+
+    /**
+     * Intel QuickSync encoder arguments
+     */
+    addQsvEncoderArgs(args, height, qp) {
+        // Scale on QSV
+        args.push('-vf', this.buildScaleFilter('qsv', height));
+
+        args.push(
+            '-c:v', 'h264_qsv',
+            '-preset', 'medium',
+            '-global_quality', String(qp),
+            '-look_ahead', '1',
+            '-look_ahead_depth', '40',
+            '-pix_fmt', 'yuv420p'      // Force 8-bit output for compatibility
+        );
+    }
+
+    /**
+     * Software encoder arguments (fallback)
+     */
+    addSoftwareEncoderArgs(args, height, crf) {
+        // Software scaling (use Lanczos for upscaling if enabled)
+        args.push('-vf', this.buildScaleFilter('software', height));
+
+        args.push(
+            '-c:v', 'libx264',
+            '-preset', 'veryfast',     // Fast for real-time
+            '-crf', String(crf),
+            '-profile:v', 'high',
+            '-level', '4.1',
+            '-pix_fmt', 'yuv420p'      // Force 8-bit output for compatibility (fixes 10-bit input errors)
+        );
+    }
+
+    /**
+     * Stop the transcoding process
+     */
+    stop() {
+        if (this.process) {
+            console.log(`[TranscodeSession ${this.id}] Stopping FFmpeg process`);
+            this.process.kill('SIGTERM');
+            // Force kill after 2 seconds if still running
+            setTimeout(() => {
+                if (this.process) {
+                    this.process.kill('SIGKILL');
+                }
+            }, 2000);
+        }
+        this.status = 'stopped';
+    }
+
+    /**
+     * Update last access time (prevents cleanup)
+     */
+    touch() {
+        this.lastAccess = Date.now();
+    }
+
+    /**
+     * Check if playlist exists and is ready
+     */
+    async isPlaylistReady() {
+        try {
+            await fs.access(this.playlistPath);
+            const content = await fs.readFile(this.playlistPath, 'utf8');
+            // Check if playlist has at least one segment
+            return content.includes('.ts');
+        } catch {
+            return false;
+        }
+    }
+
+    /**
+     * Wait for playlist to be ready (with timeout)
+     * Fast-fails if FFmpeg exited with an error before the timeout.
+     */
+    async waitForPlaylist(timeoutMs = 10000) {
+        const startTime = Date.now();
+        while (Date.now() - startTime < timeoutMs) {
+            if (await this.isPlaylistReady()) {
+                return true;
+            }
+            // Fast-fail: FFmpeg already exited with an error — no point waiting
+            if (this.status === 'error' && !this.process) {
+                console.log(`[TranscodeSession ${this.id}] Fast-fail: FFmpeg exited with error, aborting wait`);
+                return false;
+            }
+            await new Promise(resolve => setTimeout(resolve, 200));
+        }
+        return false;
+    }
+
+    /**
+     * Get the HLS playlist content
+     */
+    async getPlaylist() {
+        this.touch();
+        try {
+            return await fs.readFile(this.playlistPath, 'utf8');
+        } catch (err) {
+            return null;
+        }
+    }
+
+    /**
+     * Get a specific segment
+     */
+    async getSegment(segmentName) {
+        this.touch();
+        const segmentPath = path.join(this.dir, segmentName);
+        try {
+            await fs.access(segmentPath);
+            return segmentPath;
+        } catch {
+            return null;
+        }
+    }
+
+    /**
+     * Save session metadata to disk for recovery
+     */
+    async persist() {
+        const metadata = {
+            id: this.id,
+            url: this.url,
+            status: this.status,
+            startTime: this.startTime,
+            lastAccess: this.lastAccess,
+            options: this.options,
+            seekOffset: this.options.seekOffset
+        };
+        const metaPath = path.join(this.dir, 'session.json');
+        await fs.writeFile(metaPath, JSON.stringify(metadata, null, 2));
+    }
+
+    /**
+     * Restore a session from disk metadata
+     */
+    static async restore(sessionDir) {
+        const metaPath = path.join(sessionDir, 'session.json');
+        try {
+            const data = await fs.readFile(metaPath, 'utf8');
+            const metadata = JSON.parse(data);
+            const session = new TranscodeSession(metadata.url, metadata.options);
+            session.id = metadata.id;
+            session.dir = sessionDir;
+            session.playlistPath = path.join(sessionDir, 'stream.m3u8');
+            session.startTime = metadata.startTime;
+            session.lastAccess = metadata.lastAccess;
+            session.status = 'stopped'; // Not running after restart
+            return session;
+        } catch (err) {
+            console.error(`Failed to restore session from ${sessionDir}:`, err.message);
+            return null;
+        }
+    }
+
+    /**
+     * Delete session directory and all segments
+     */
+    async cleanup() {
+        this.stop();
+        try {
+            await fs.rm(this.dir, { recursive: true, force: true });
+            console.log(`[TranscodeSession ${this.id}] Cleaned up session directory`);
+        } catch (err) {
+            console.error(`[TranscodeSession ${this.id}] Failed to cleanup:`, err.message);
+        }
+    }
+}
+
+/**
+ * Session Manager
+ */
+
+/**
+ * Create a new transcode session
+ */
+async function createSession(url, options = {}) {
+    await ensureCacheDir();
+    const session = new TranscodeSession(url, options);
+    sessions.set(session.id, session);
+    return session;
+}
+
+/**
+ * Get an existing session by ID
+ */
+function getSession(sessionId) {
+    const session = sessions.get(sessionId);
+    if (session) {
+        session.touch();
+    }
+    return session;
+}
+
+/**
+ * Get or create a session for a URL (reuses existing if still valid)
+ */
+async function getOrCreateSession(url, options = {}) {
+    // Check for existing session with same URL
+    for (const session of sessions.values()) {
+        if (session.url === url && session.status === 'running') {
+            session.touch();
+            return session;
+        }
+    }
+    // Create new session
+    return createSession(url, options);
+}
+
+/**
+ * Stop and remove a session
+ */
+async function removeSession(sessionId) {
+    const session = sessions.get(sessionId);
+    if (session) {
+        await session.cleanup();
+        sessions.delete(sessionId);
+    }
+}
+
+/**
+ * Cleanup stale sessions (idle for too long)
+ */
+async function cleanupStaleSessions() {
+    const now = Date.now();
+    for (const [id, session] of sessions) {
+        if (now - session.lastAccess > SESSION_TIMEOUT_MS) {
+            console.log(`[TranscodeSession] Cleaning up stale session ${id}`);
+            await removeSession(id);
+        }
+    }
+}
+
+/**
+ * Recover sessions from disk after server restart
+ */
+async function recoverSessions() {
+    try {
+        await fs.access(CACHE_DIR);
+        const dirs = await fs.readdir(CACHE_DIR, { withFileTypes: true });
+
+        for (const dirent of dirs) {
+            if (dirent.isDirectory()) {
+                const sessionDir = path.join(CACHE_DIR, dirent.name);
+                const session = await TranscodeSession.restore(sessionDir);
+                if (session) {
+                    sessions.set(session.id, session);
+                    console.log(`[TranscodeSession] Recovered session ${session.id}`);
+                }
+            }
+        }
+    } catch (err) {
+        // Cache dir doesn't exist yet, that's fine
+        if (err.code !== 'ENOENT') {
+            console.error('[TranscodeSession] Error recovering sessions:', err.message);
+        }
+    }
+}
+
+/**
+ * Start cleanup interval
+ */
+let cleanupInterval = null;
+function startCleanupInterval() {
+    if (!cleanupInterval) {
+        cleanupInterval = setInterval(cleanupStaleSessions, CLEANUP_INTERVAL_MS);
+        cleanupInterval.unref(); // Don't prevent process exit
+    }
+}
+
+/**
+ * Get all active sessions (for debugging/monitoring)
+ */
+function getAllSessions() {
+    return Array.from(sessions.values()).map(s => ({
+        id: s.id,
+        url: s.url,
+        status: s.status,
+        startTime: s.startTime,
+        lastAccess: s.lastAccess,
+        idleMs: Date.now() - s.lastAccess
+    }));
+}
+
+module.exports = {
+    TranscodeSession,
+    createSession,
+    getSession,
+    getOrCreateSession,
+    removeSession,
+    cleanupStaleSessions,
+    recoverSessions,
+    startCleanupInterval,
+    getAllSessions,
+    CACHE_DIR,
+    SEGMENT_DURATION
+};
@@ -18,6 +18,7 @@ const fs = require('fs').promises;
 const crypto = require('crypto');
 const EventEmitter = require('events');
 const hwDetect = require('./hwDetect');
+const streamInput = require('../utils/streamInput');

 // Session storage
 const sessions = new Map();
@@ -26,9 +27,9 @@ const sessions = new Map();
 const CACHE_DIR = path.join(process.cwd(), 'transcode-cache');

 // Session settings
-const SESSION_TIMEOUT_MS = 30 * 60 * 1000; // 30 minutes idle timeout
+const SESSION_TIMEOUT_MS = 3 * 60 * 1000; // 3 minutes idle timeout (kills orphaned sessions quickly)
 const SEGMENT_DURATION = 4; // seconds per HLS segment
-const CLEANUP_INTERVAL_MS = 5 * 60 * 1000; // Check every 5 minutes
+const CLEANUP_INTERVAL_MS = 60 * 1000; // Check every 60 seconds

 /**
 * Generate a unique session ID
@@ -181,11 +182,17 @@ class TranscodeSession extends EventEmitter {
            console.log(`[TranscodeSession ${this.id}] Auto encoder resolved to: ${encoder}`);
        }

+        const sizing = streamInput.probeSizingForUrl(this.url);
+        const referer = streamInput.deriveRefererFromUrl(this.url);
+
        const args = [
            '-hide_banner',
            '-loglevel', 'warning',
            '-user_agent', this.options.userAgent,
        ];
+        if (referer) {
+            args.push('-referer', referer);
+        }

        // Add hardware acceleration input options based on encoder (only if encoding)
        if (videoMode === 'encode') {
@@ -194,8 +201,8 @@ class TranscodeSession extends EventEmitter {

        // Input options (common)
        args.push(
-            '-probesize', '5000000',
-            '-analyzeduration', '5000000',
+            '-probesize', sizing.probesize,
+            '-analyzeduration', sizing.analyzeduration,
            '-fflags', '+genpts+discardcorrupt',
            '-err_detect', 'ignore_err',
            '-reconnect', '1',
@@ -222,7 +229,10 @@ class TranscodeSession extends EventEmitter {
            if (this.options.videoCodec === 'hevc' || this.options.videoCodec === 'h265') {
                args.push('-bsf:v', 'hevc_mp4toannexb');
            } else if (this.options.videoCodec === 'h264' || this.options.videoCodec === 'avc') {
-                args.push('-bsf:v', 'h264_mp4toannexb');
+                // Keep Annex-B conversion and force parameter sets to be repeated.
+                // This helps players recover on streams where SPS/PPS appear sporadically,
+                // which often manifests as "audio OK, black video".
+                args.push('-bsf:v', 'h264_mp4toannexb,dump_extra');
            } else {
                // Fallback (e.g. unknown codec), try strict extraction
                args.push('-bsf:v', 'dump_extra');
@@ -296,12 +306,12 @@ class TranscodeSession extends EventEmitter {
                );
                break;
            case 'vaapi':
-                // VAAPI hardware decoding (Linux)
-                args.push(
-                    '-hwaccel', 'vaapi',
-                    '-hwaccel_device', '/dev/dri/renderD128',
-                    '-hwaccel_output_format', 'vaapi'
-                );
+                // Solo registramos el dispositivo VAAPI globalmente.
+                // Se usa decodificación SOFTWARE para máxima compatibilidad con
+                // cualquier codec de entrada (HEVC, VP9, etc.) — el GPU Intel
+                // puede no tener soporte de decodificación para todos ellos.
+                // El upload a memoria VAAPI se hace en el filtro de vídeo.
+                args.push('-vaapi_device', '/dev/dri/renderD128');
                break;
            case 'qsv':
                // Intel QuickSync hardware decoding
@@ -404,7 +414,9 @@ class TranscodeSession extends EventEmitter {
                    // Force nv12 (8-bit) output to handle 10-bit inputs (fixes "10 bit encode not supported")
                    return `scale_cuda=-2:${height}:interp_algo=lanczos:format=nv12`;
                case 'vaapi':
-                    return `scale_vaapi=w=-2:h=${height}:format=nv12`;
+                    // Software decode → scale → nv12 → hwupload → VAAPI encode
+                    // format=nv12 ANTES de hwupload es obligatorio para Intel iGPU en LXC
+                    return `scale=-2:${height},format=nv12,hwupload`;
                case 'qsv':
                    return `scale_qsv=w=-2:h=${height}:format=nv12`;
                case 'amf':
@@ -466,14 +478,11 @@ class TranscodeSession extends EventEmitter {
        // The format is handled automatically when using -hwaccel_output_format vaapi
        args.push('-vf', this.buildScaleFilter('vaapi', height));

-        // VAAPI encoder with quality setting
-        // Note: -global_quality is the portable way to set quality for VAAPI
+        // VAAPI encoder. No especificar -profile:v ni -pix_fmt (los gestiona el driver).
+        // -bf 3 puede causar problemas en algunos drivers Intel; se omite.
        args.push(
            '-c:v', 'h264_vaapi',
-            '-profile:v', 'main',      // Use main profile for compatibility
-            '-global_quality', String(qp),
-            '-bf', '3',
-            '-pix_fmt', 'yuv420p'      // Force 8-bit output for compatibility
+            '-global_quality', String(qp)
        );
    }

@@ -551,6 +560,7 @@ class TranscodeSession extends EventEmitter {

    /**
     * Wait for playlist to be ready (with timeout)
+     * Fast-fails if FFmpeg exited with an error before the timeout.
     */
    async waitForPlaylist(timeoutMs = 10000) {
        const startTime = Date.now();
@@ -558,6 +568,11 @@ class TranscodeSession extends EventEmitter {
            if (await this.isPlaylistReady()) {
                return true;
            }
+            // Fast-fail: FFmpeg already exited with an error — no point waiting
+            if (this.status === 'error' && !this.process) {
+                console.log(`[TranscodeSession ${this.id}] Fast-fail: FFmpeg exited with error, aborting wait`);
+                return false;
+            }
            await new Promise(resolve => setTimeout(resolve, 200));
        }
        return false;
@@ -0,0 +1,38 @@
+'use strict';
+
+/**
+ * Opciones de entrada HTTP para ffprobe/ffmpeg con orígenes tipo Xtream / Jellyfin (Dispatcharr).
+ * Muchos backends exigen Referer/origin coherentes además del User-Agent.
+ */
+
+function deriveRefererFromUrl(inputUrl) {
+    try {
+        const u = new URL(inputUrl);
+        return `${u.origin}/`;
+    } catch {
+        return null;
+    }
+}
+
+/** VOD pesado (Remux Jellyfin MKV/MP4, GOP largo) — probes más grandes. */
+function isHeavyVodUrl(url) {
+    if (!url || typeof url !== 'string') return false;
+    const u = url.toLowerCase();
+    if (u.includes('/movie/') || u.includes('/series/')) return true;
+    if (/\.mkv\b/i.test(url) || /\.mp4\b/i.test(url)) return true;
+    return false;
+}
+
+function probeSizingForUrl(url) {
+    if (isHeavyVodUrl(url)) {
+        /** Microseconds; VOD Jellyfin/remux pueden necesitar leer bastante antes del analyze */
+        return { probesize: '32000000', analyzeduration: '45000000', heavy: true };
+    }
+    return { probesize: '8000000', analyzeduration: '8000000', heavy: false };
+}
+
+module.exports = {
+    deriveRefererFromUrl,
+    isHeavyVodUrl,
+    probeSizingForUrl
+};