Instancia transcoder t3: snapshot

2026-07-13 15:21:03 +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",
+    "name": "kiratv",
-    "version": "2.1.4",
+    "version": "2.1.4-kira1",
    "lockfileVersion": 3,
    "requires": true,
    "packages": {
        "": {
-            "name": "nodecast-tv",
+            "name": "kiratv",
-            "version": "2.1.4",
+            "version": "2.1.4-kira1",
            "license": "GPL-3.0-only",
            "dependencies": {
                "@ffprobe-installer/ffprobe": "^2.1.2",
@@ -1,7 +1,7 @@
 {
-    "name": "nodecast-tv",
+    "name": "kiratv",
-    "version": "2.1.4",
+    "version": "2.1.4-kira1",
-    "description": "Modern IPTV Player",
+    "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">
+<svg xmlns="http://www.w3.org/2000/svg" viewBox="0 0 64 64" fill="none">
-  <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"/>
+  <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>
+  <title>KiraTV | Televisión en el navegador</title>
-  <meta name="description" content="Stream live TV, movies, and series with EPG support">
+  <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);
-            console.log('[Player] Starting HLS transcode session...', options);
+        let lastError = null;
-            const res = await fetch('/api/transcode/session', {
+
-                method: 'POST',
+        // Retry a couple of times to ride out provider-side 5xx/rate-limit spikes.
-                headers: { 'Content-Type': 'application/json' },
+        for (let attempt = 1; attempt <= 3; attempt++) {
-                body: JSON.stringify({ url, ...options })
+            try {
-            });
+                const res = await fetch('/api/transcode/session', {
-            if (!res.ok) throw new Error('Failed to start session');
+                    method: 'POST',
-            const session = await res.json();
+                    headers: { 'Content-Type': 'application/json' },
-            this.currentSessionId = session.sessionId;
+                    body: JSON.stringify({ url, ...options })
-            return session.playlistUrl;
+                });
-        } catch (err) {
+                if (!res.ok) {
-            console.error('[Player] Session start failed:', err);
+                    throw new Error(`Failed to start session (${res.status})`);
-            // Fallback to direct transcode if session fails
+                }
-            return `/api/transcode?url=${encodeURIComponent(url)}`;
+                const session = await res.json();
                this.currentSessionId = session.sessionId;
                return session.playlistUrl;
            } catch (err) {
                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) {
+        if (!this.currentSessionId) return;
-            console.log('[Player] Stopping transcode session:', this.currentSessionId);
+
-            try {
+        const sessionId = this.currentSessionId;
-                // Fire and forget cleanup
+        this.currentSessionId = null;
-                fetch(`/api/transcode/${this.currentSessionId}`, { method: 'DELETE' });
+        console.log('[Player] Stopping transcode session:', sessionId);
-            } catch (err) {
+        try {
            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
+            // Stop current playback (sends DELETE to worker → FFmpeg dies → Dispatcharr frees the slot)
-            this.stop();
+            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
+                        // Algunos streams TS fallan en remux directo (ffmpeg mp4 mux errors).
-                        console.log('[Player] Auto: Using remux (.ts container)');
+                        // En ese caso es mas estable usar sesion HLS con video copy.
-                        this.updateTranscodeStatus('remuxing', 'Remux (Auto)');
+                        console.log('[Player] Auto: Using HLS transcode session (copy for remux-needed stream)');
-                        const remuxUrl = `/api/remux?url=${encodeURIComponent(streamUrl)}`;
+                        this.updateTranscodeStatus('transcoding', 'Transcoding (Auto)');
-                        this.currentUrl = remuxUrl;
+                        const playlistUrl = await this.startTranscodeSession(streamUrl, {
-                        this.video.src = remuxUrl;
+                            videoMode: 'copy',
-                        this.video.play().catch(e => {
+                            videoCodec: info.video,
-                            if (e.name !== 'AbortError') console.log('[Player] Autoplay prevented:', e);
+                            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
+                // sendBeacon works even when the page is being unloaded
-                fetch(`/api/transcode/${this.currentSessionId}`, { method: 'DELETE' });
+                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);
+                console.warn('[WatchPage] Probe failed:', err.message);
-                // Continue with normal playback on probe failure
+                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,8 +738,12 @@ class WatchPage {
        }
        if (this.video) {
            this.video.pause();
-            this.video.src = '';
+            // En modo escritorio el vídeo va a mpv: limpiar src dispararía un error
-            this.video.load();
+            // 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) {
+        if (!this.video) return;
-            this.video.currentTime = Math.max(0, Math.min(this.video.currentTime + seconds, this.video.duration || 0));
+        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) {
+        const totalDuration = this.getTotalDuration();
-            this.video.currentTime = (percent / 100) * this.video.duration;
+        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;
+        const totalDuration = this.getTotalDuration();
-        this.progressSlider.value = percent;
+        if (!totalDuration) return;
-        this.timeCurrent.textContent = this.formatTime(this.video.currentTime);
+
        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 duration = totalDuration;
-            const currentTime = this.video.currentTime;
+            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
+        // Handle resumption (only for direct video, NOT session mode).
-        if (this.resumeTime > 0 && this.video) {
+        // 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,11 +994,11 @@ 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;
-            console.error('[WatchPage] Video error:', error.code, error.message);
+        // 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() {
@@ -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>
+                <h1>KiraTV</h1>
-                <p id="login-subtitle">Sign in to continue</p>
+                <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',
+            '-probesize', sizing.probesize,
-            '-analyzeduration', '5000000',
+            '-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,32 +182,55 @@ router.get('/', async (req, res) => {
    console.log(`[Probe] Probing: ${url.substring(0, 80)}... ${ua ? `(UA: ${ua})` : ''}`);
-    try {
+    // Retry probe up to 3 times on 5XX errors (provider slot not released yet)
-        const probeResult = await probeStream(url, ffprobePath, ua);
+    const MAX_PROBE_RETRIES = 3;
-        const analysis = analyzeProbeResult(probeResult, url);
+    const PROBE_RETRY_DELAY_MS = 2500;
    let lastErr = null;
-        // Cache result
+    for (let attempt = 1; attempt <= MAX_PROBE_RETRIES; attempt++) {
-        probeCache.set(cacheKey, { result: analysis, timestamp: Date.now() });
+        try {
            const probeResult = await probeStream(url, ffprobePath, ua);
            const analysis = analyzeProbeResult(probeResult, url);
-        console.log(`[Probe] Result: video=${analysis.video}, audio=${analysis.audio}, ` +
+            // Cache successful result
-            `container=${analysis.container}, compatible=${analysis.compatible}, ` +
+            probeCache.set(cacheKey, { result: analysis, timestamp: Date.now() });
            `needsRemux=${analysis.needsRemux}, needsTranscode=${analysis.needsTranscode}`);
-        res.json(analysis);
+            console.log(`[Probe] Result (attempt ${attempt}): video=${analysis.video}, audio=${analysis.audio}, ` +
-    } catch (err) {
+                `container=${analysis.container}, compatible=${analysis.compatible}, ` +
-        console.error('[Probe] Failed:', err.message);
+                `needsRemux=${analysis.needsRemux}, needsTranscode=${analysis.needsTranscode}`);
-        // On error, assume transcode needed to be safe
+            return res.json(analysis);
-        res.json({
+        } catch (err) {
-            video: 'unknown',
+            lastErr = err;
-            audio: 'unknown',
+            const is5xx = /5[0-9]{2}|Server Error/i.test(err.message);
-            container: 'unknown',
+            if (is5xx && attempt < MAX_PROBE_RETRIES) {
-            compatible: false,
+                console.warn(`[Probe] 5XX from provider (attempt ${attempt}/${MAX_PROBE_RETRIES}), retrying in ${PROBE_RETRY_DELAY_MS}ms...`);
-            needsRemux: false,
+                await new Promise(r => setTimeout(r, PROBE_RETRY_DELAY_MS));
-            needsTranscode: true,
+                continue;
-            error: err.message
+            }
-        });
+            break;
        }
    }
    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',
        container: 'unknown',
        compatible: false,
        needsRemux: false,
        needsTranscode: true,
        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');
            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
            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();
+        // 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',
                upscaleEnabled: settings.upscaleEnabled || false,
                upscaleMethod: settings.upscaleMethod || 'hardware',
                upscaleTarget: settings.upscaleTarget || '1080p',
                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)
+    if (referer) {
-        '-analyzeduration', '3000000', // 3 seconds (reduced from 10s)
+        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',
+            '-probesize', sizing.probesize,
-            '-analyzeduration', '5000000',
+            '-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)
+                // Solo registramos el dispositivo VAAPI globalmente.
-                args.push(
+                // Se usa decodificación SOFTWARE para máxima compatibilidad con
-                    '-hwaccel', 'vaapi',
+                // cualquier codec de entrada (HEVC, VP9, etc.) — el GPU Intel
-                    '-hwaccel_device', '/dev/dri/renderD128',
+                // puede no tener soporte de decodificación para todos ellos.
-                    '-hwaccel_output_format', 'vaapi'
+                // 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
+        // VAAPI encoder. No especificar -profile:v ni -pix_fmt (los gestiona el driver).
-        // Note: -global_quality is the portable way to set quality for VAAPI
+        // -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)
            '-global_quality', String(qp),
            '-bf', '3',
            '-pix_fmt', 'yuv420p'      // Force 8-bit output for compatibility
        );
    }
@@ -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
 };