Update web.ts

web.ts

@@ -65,7 +65,7 @@ function createApiErrorObject(errorMessage: string, statusProviderName: string =
   };
 }
 function createProviderErrorObject(providerName: string, errorMessage: string): ProviderErrorResult {
-    return createApiErrorObject(errorMessage, providerName);
+  return createApiErrorObject(errorMessage, providerName);
 }
 
 function stringAtob(input: string): string {
@@ -105,17 +105,19 @@ function getSizeQuality(url: string): number {
 // --- Provider Specific Logic ---
 
 // == EmbedSu Provider ==
-const EMBED_SU_DOMAIN = "https://iqslgbok.deploy.cx/param/User-Agent=" + encodeURIComponent(USER_AGENT) + "/param/Origin="+ encodeURIComponent("https://embed.su") +"/param/Referer="+ encodeURIComponent("https://embed.su/") +"/https://embed.su";
+const EMBED_SU_DOMAIN = "https://embed.su";
+const EMBED_SU_PROXY = "https://iqslgbok.deploy.cx/param/User-Agent=" + encodeURIComponent(USER_AGENT) + "/param/Origin=" + encodeURIComponent(EMBED_SU_DOMAIN) + "/param/Referer=" + encodeURIComponent(EMBED_SU_DOMAIN) + "/";
+
 const EMBED_SU_HEADERS = {
   'User-Agent': USER_AGENT,
-  'Referer': "https://embed.su/",//EMBED_SU_DOMAIN
-  'Origin': "https://embed.su",//EMBED_SU_DOMAIN
+  'Referer': EMBED_SU_DOMAIN,//EMBED_SU_DOMAIN
+  'Origin': EMBED_SU_DOMAIN,//EMBED_SU_DOMAIN
 };
 
 async function getEmbedSu(tmdb_id: string, s?: string, e?: string): Promise<ProviderFunctionReturn> {
   const providerName = PROVIDERS.embedsu.displayName;
   try {
-    const urlSearch = s && e ? `${EMBED_SU_DOMAIN}/embed/tv/${tmdb_id}/${s}/${e}` : `${EMBED_SU_DOMAIN}/embed/movie/${tmdb_id}`;
+    const urlSearch = s && e ? `${EMBED_SU_PROXY}${EMBED_SU_DOMAIN}/embed/tv/${tmdb_id}/${s}/${e}` : `${EMBED_SU_PROXY}${EMBED_SU_DOMAIN}/embed/movie/${tmdb_id}`;
     const htmlSearchResponse = await fetch(urlSearch, { method: 'GET', headers: EMBED_SU_HEADERS });
     if (!htmlSearchResponse.ok) return createProviderErrorObject(providerName, `Failed to fetch initial page: HTTP ${htmlSearchResponse.status}`);
 
@@ -146,7 +148,7 @@ async function getEmbedSu(tmdb_id: string, s?: string, e?: string): Promise<Prov
     for (const item of secondDecode) {
       try {
         if (!item || !item.hash) continue;
-        const urlDirect = `${EMBED_SU_DOMAIN}/api/e/${item.hash}`;
+        const urlDirect = `${EMBED_SU_PROXY}${EMBED_SU_DOMAIN}/api/e/${item.hash}`;
         const dataDirect = await requestGet(urlDirect, { "Referer": EMBED_SU_DOMAIN, "User-Agent": USER_AGENT, "Origin": EMBED_SU_DOMAIN });
         if (!dataDirect || !dataDirect.source) { console.warn(`${providerName}: No source found for hash ${item.hash}`); continue; }
 
@@ -154,7 +156,7 @@ async function getEmbedSu(tmdb_id: string, s?: string, e?: string): Promise<Prov
           url: sub.file, lang: sub.label ? sub.label.split('-')[0].trim().toLowerCase() : 'en'
         })).filter((track: Subtitle) => track.url);
 
-        const requestDirectSize = await fetch(dataDirect.source.replace("https://embed.su",EMBED_SU_DOMAIN), { headers: EMBED_SU_HEADERS, method: "GET" });
+        const requestDirectSize = await fetch(EMBED_SU_PROXY + dataDirect.source, { headers: EMBED_SU_HEADERS, method: "GET" });
         if (!requestDirectSize.ok) { console.warn(`${providerName}: Failed to fetch source ${dataDirect.source}: HTTP ${requestDirectSize.status}`); continue; }
 
         const parseRequest = await requestDirectSize.text();
@@ -163,7 +165,7 @@ async function getEmbedSu(tmdb_id: string, s?: string, e?: string): Promise<Prov
         const directQuality: MediaFile[] = patternSize.map(patternItem => {
           try {
             const sizeQuality = getSizeQuality(patternItem);
-            let dURL = `${EMBED_SU_DOMAIN}${patternItem}`;
+            let dURL = `${EMBED_SU_PROXY}${EMBED_SU_DOMAIN}${patternItem}`;
             dURL = dURL.replace(".png", ".m3u8");
             const fileObj: MediaFile = { file: dURL, type: 'hls', quality: `${sizeQuality}p`, lang: 'en' };
             if (s && e) { // Add season and episode if they exist (TV show)
@@ -176,7 +178,7 @@ async function getEmbedSu(tmdb_id: string, s?: string, e?: string): Promise<Prov
 
         if (!directQuality.length) { console.warn(`${providerName}: No valid qualities found for source ${dataDirect.source}`); continue; }
 
-        return { source: { provider: providerName, files: directQuality, subtitles: tracks, headers: { "Referer": "https://embed.su", "User-Agent": USER_AGENT, "Origin": "https://embed.su" } } };
+        return { source: { provider: providerName, files: directQuality, subtitles: tracks, headers: { "Referer": EMBED_SU_DOMAIN, "User-Agent": USER_AGENT, "Origin": EMBED_SU_DOMAIN } } };
       } catch (error) { console.error(`${providerName}: Error processing item ${item.hash}:`, error); }
     }
     return createProviderErrorObject(providerName, "No valid sources found after processing all available items");
@@ -187,21 +189,20 @@ async function getEmbedSu(tmdb_id: string, s?: string, e?: string): Promise<Prov
 }
 
 // == VidSrc.SU Provider ==
-// const VIDSRC_SU_DOMAIN = "https://vidsrc.su/";
-const VIDSRC_SU_DOMAIN = "https://iqslgbok.deploy.cx/param/User-Agent=" + encodeURIComponent(USER_AGENT) + "/param/Origin="+ encodeURIComponent("https://vidsrc.su") +"/param/Referer="+ encodeURIComponent("https://vidsrc.su/") +"/https://vidsrc.su/";
-const VIDSRC_SU_HEADERS = { 'User-Agent': USER_AGENT, 'Referer': "https://vidsrc.su/", 'Origin': "https://vidsrc.su" };
+const VIDSRC_SU_DOMAIN = "https://vidsrc.su/";
+const VIDSRC_SU_HEADERS = { 'User-Agent': USER_AGENT, 'Referer': VIDSRC_SU_DOMAIN, 'Origin': VIDSRC_SU_DOMAIN };
 
 async function getVidSrcSu(tmdb_id: string, s?: string, e?: string): Promise<ProviderFunctionReturn> {
   const providerName = PROVIDERS.vidsrcsu.displayName;
   const embedUrl = s && e ? `${VIDSRC_SU_DOMAIN}embed/tv/${tmdb_id}/${s}/${e}` : `${VIDSRC_SU_DOMAIN}embed/movie/${tmdb_id}`;
-  console.log(embedUrl)
+
   try {
     const response = await fetch(embedUrl, { headers: VIDSRC_SU_HEADERS });
     if (!response.ok) return createProviderErrorObject(providerName, `Failed to fetch embed page: HTTP ${response.status}`);
-    
+
     const html = await response.text();
     let subtitles: Subtitle[] = [];
-    
+
     const servers: MediaFile[] = [...html.matchAll(/label: 'Server (?:[^']*)', url: '(https?:\/\/[^']+\.m3u8[^']*)'/gi)].map(match => {
       const fileObj: MediaFile = { file: match[1], type: "hls", lang: "en" };
       if (s && e) { // Add season and episode if they exist
@@ -225,7 +226,7 @@ async function getVidSrcSu(tmdb_id: string, s?: string, e?: string): Promise<Pro
     }
 
     if (servers.length === 0) return createProviderErrorObject(providerName, "No valid video streams found in embed page");
-    return { source: { provider: providerName, files: servers, subtitles: subtitles, headers: { "Referer": "https://vidsrc.su", "User-Agent": USER_AGENT, "Origin": "https://vidsrc.su" } } };
+    return { source: { provider: providerName, files: servers, subtitles: subtitles, headers: { "Referer": VIDSRC_SU_DOMAIN, "User-Agent": USER_AGENT, "Origin": VIDSRC_SU_DOMAIN } } };
   } catch (error) {
     console.error(`${providerName}: Unexpected error:`, error);
     return createProviderErrorObject(providerName, `Unexpected error: ${error.message}`);
@@ -238,117 +239,117 @@ const AUTOEMBED_API_URL_BASE = "https://tom.autoembed.cc/api/getVideoSource";
 
 // Modified parseAutoEmbedM3U8 to accept s and e
 function parseAutoEmbedM3U8(m3u8Content: string, s?: string, e?: string, m3u8Url?: string): MediaFile[] {
-    try {
-        const lines = m3u8Content.split('\n');
-        const sources: MediaFile[] = [];
-        let currentQuality: string | undefined = undefined;
-        
-        let baseUrl = '';
-        let domain = '';
-        if (m3u8Url) {
-            try {
-                const urlObj = new URL(m3u8Url);
-                domain = `${urlObj.protocol}//${urlObj.hostname}`;
-                
-                // Get base URL by removing the filename from the full URL
-                const urlPath = m3u8Url.split('/');
-                urlPath.pop(); // Remove the filename
-                baseUrl = urlPath.join('/') + '/';
-            } catch (error) {
-                console.error('AutoEmbed: Error extracting URL information:', error);
-            }
-        }
+  try {
+    const lines = m3u8Content.split('\n');
+    const sources: MediaFile[] = [];
+    let currentQuality: string | undefined = undefined;
 
-        for (let i = 0; i < lines.length; i++) {
-            const trimmedLine = lines[i].trim();
-            if (trimmedLine.startsWith('#EXT-X-STREAM-INF:')) {
-                const resolutionMatch = trimmedLine.match(/RESOLUTION=\d+x(\d+)/);
-                currentQuality = resolutionMatch && resolutionMatch[1] ? `${resolutionMatch[1]}p` : undefined;
-                for (let j = i + 1; j < lines.length; j++) {
-                    const nextLineTrimmed = lines[j].trim();
-                    if (nextLineTrimmed && !nextLineTrimmed.startsWith('#')) {
-                      // Handle different types of paths
-                        let filePath = nextLineTrimmed;
-                        
-                        // Skip URLs that already have protocol
-                        if (!nextLineTrimmed.match(/^https?:\/\//)) {
-                            if (nextLineTrimmed.startsWith('/')) {
-                                // Absolute path starting with '/'
-                                if (domain) {
-                                    filePath = `${domain}${nextLineTrimmed}`;
-                                }
-                            } else {
-                                // Relative path
-                                if (baseUrl) {
-                                    filePath = `${baseUrl}${nextLineTrimmed}`;
-                                }
-                            }
-                        }
-                        const fileObj: MediaFile = {
-                            file: filePath, type: "hls",
-                            quality: currentQuality || 'unknown', lang: "en"
-                        };
-                        if (s && e) { // Add season and episode if they exist
-                            fileObj.season = s;
-                            fileObj.episode = e;
-                        }
-                        sources.push(fileObj);
-                        i = j; break;
-                    }
-                    if (nextLineTrimmed.startsWith('#EXT')) break;
+    let baseUrl = '';
+    let domain = '';
+    if (m3u8Url) {
+      try {
+        const urlObj = new URL(m3u8Url);
+        domain = `${urlObj.protocol}//${urlObj.hostname}`;
+
+        // Get base URL by removing the filename from the full URL
+        const urlPath = m3u8Url.split('/');
+        urlPath.pop(); // Remove the filename
+        baseUrl = urlPath.join('/') + '/';
+      } catch (error) {
+        console.error('AutoEmbed: Error extracting URL information:', error);
+      }
+    }
+
+    for (let i = 0; i < lines.length; i++) {
+      const trimmedLine = lines[i].trim();
+      if (trimmedLine.startsWith('#EXT-X-STREAM-INF:')) {
+        const resolutionMatch = trimmedLine.match(/RESOLUTION=\d+x(\d+)/);
+        currentQuality = resolutionMatch && resolutionMatch[1] ? `${resolutionMatch[1]}p` : undefined;
+        for (let j = i + 1; j < lines.length; j++) {
+          const nextLineTrimmed = lines[j].trim();
+          if (nextLineTrimmed && !nextLineTrimmed.startsWith('#')) {
+            // Handle different types of paths
+            let filePath = nextLineTrimmed;
+
+            // Skip URLs that already have protocol
+            if (!nextLineTrimmed.match(/^https?:\/\//)) {
+              if (nextLineTrimmed.startsWith('/')) {
+                // Absolute path starting with '/'
+                if (domain) {
+                  filePath = `${domain}${nextLineTrimmed}`;
+                }
+              } else {
+                // Relative path
+                if (baseUrl) {
+                  filePath = `${baseUrl}${nextLineTrimmed}`;
                 }
-                currentQuality = undefined;
+              }
+            }
+            const fileObj: MediaFile = {
+              file: filePath, type: "hls",
+              quality: currentQuality || 'unknown', lang: "en"
+            };
+            if (s && e) { // Add season and episode if they exist
+              fileObj.season = s;
+              fileObj.episode = e;
             }
+            sources.push(fileObj);
+            i = j; break;
+          }
+          if (nextLineTrimmed.startsWith('#EXT')) break;
         }
-        return sources;
-    } catch (error) { console.error('AutoEmbed: Error parsing m3u8:', error); return []; }
+        currentQuality = undefined;
+      }
+    }
+    return sources;
+  } catch (error) { console.error('AutoEmbed: Error parsing m3u8:', error); return []; }
 }
 
 function mapAutoEmbedSubtitles(apiSubtitles: any[]): Subtitle[] {
-    if (!apiSubtitles || !Array.isArray(apiSubtitles)) return [];
-    try {
-        return apiSubtitles.map(subtitle => {
-            const lang = (subtitle.label || 'unknown').split(' ')[0].toLowerCase();
-            const fileUrl = subtitle.file || '';
-            if (!fileUrl) return null;
-            const fileExtension = fileUrl.split('.').pop()?.toLowerCase();
-            const type = fileExtension === 'vtt' ? 'vtt' : (fileExtension === 'srt' ? 'srt' : undefined);
-            return { url: fileUrl, lang: lang, type: type };
-        }).filter((sub): sub is Subtitle => sub !== null && !!sub.url);
-    } catch (error) { console.error('AutoEmbed: Error mapping subtitles:', error); return []; }
+  if (!apiSubtitles || !Array.isArray(apiSubtitles)) return [];
+  try {
+    return apiSubtitles.map(subtitle => {
+      const lang = (subtitle.label || 'unknown').split(' ')[0].toLowerCase();
+      const fileUrl = subtitle.file || '';
+      if (!fileUrl) return null;
+      const fileExtension = fileUrl.split('.').pop()?.toLowerCase();
+      const type = fileExtension === 'vtt' ? 'vtt' : (fileExtension === 'srt' ? 'srt' : undefined);
+      return { url: fileUrl, lang: lang, type: type };
+    }).filter((sub): sub is Subtitle => sub !== null && !!sub.url);
+  } catch (error) { console.error('AutoEmbed: Error mapping subtitles:', error); return []; }
 }
 
 async function getAutoEmbed(tmdb_id: string, s?: string, e?: string): Promise<ProviderFunctionReturn> {
-    const providerName = PROVIDERS.autoembed.displayName;
-    const params = new URLSearchParams();
-    if (s && e) { params.append("type", "tv"); params.append("id", `${tmdb_id}/${s}/${e}`); }
-    else { params.append("type", "movie"); params.append("id", tmdb_id); }
-    const apiUrl = `${AUTOEMBED_API_URL_BASE}?${params.toString()}`;
-
-    try {
-        const response = await fetch(apiUrl, { headers: { 'Referer': AUTOEMBED_DOMAIN, 'User-Agent': USER_AGENT } });
-        if (!response.ok) {
-            let errorBody = ""; try { errorBody = await response.text(); } catch (_) {}
-            return createProviderErrorObject(providerName, `API request failed: HTTP ${response.status}. ${errorBody}`);
-        }
-        const data = await response.json();
-        if (data.error || !data.videoSource) return createProviderErrorObject(providerName, data.error || "No videoSource found in API response");
-
-        const m3u8Url = data.videoSource;
-        const m3u8Response = await fetch(m3u8Url, { headers: { 'Referer': AUTOEMBED_DOMAIN, 'User-Agent': USER_AGENT } });
-        if (!m3u8Response.ok) return createProviderErrorObject(providerName, `Failed to fetch m3u8 from ${m3u8Url}: HTTP ${m3u8Response.status}`);
-
-        const m3u8Content = await m3u8Response.text();
-        // Pass s and e to the M3U8 parser
-        const files = parseAutoEmbedM3U8(m3u8Content, s, e, m3u8Url);
-        if (files.length === 0) return createProviderErrorObject(providerName, "No valid streams found after parsing m3u8");
-
-        const subtitles = data.subtitles ? mapAutoEmbedSubtitles(data.subtitles) : [];
-        return { source: { provider: providerName, files: files, subtitles: subtitles, headers: { "Referer": AUTOEMBED_DOMAIN, "User-Agent": USER_AGENT, "Origin": AUTOEMBED_DOMAIN } } };
-    } catch (error) {
-        console.error(`${providerName}: Unexpected error - `, error);
-        return createProviderErrorObject(providerName, `Network or processing error: ${error.message}`);
+  const providerName = PROVIDERS.autoembed.displayName;
+  const params = new URLSearchParams();
+  if (s && e) { params.append("type", "tv"); params.append("id", `${tmdb_id}/${s}/${e}`); }
+  else { params.append("type", "movie"); params.append("id", tmdb_id); }
+  const apiUrl = `${AUTOEMBED_API_URL_BASE}?${params.toString()}`;
+
+  try {
+    const response = await fetch(apiUrl, { headers: { 'Referer': AUTOEMBED_DOMAIN, 'User-Agent': USER_AGENT } });
+    if (!response.ok) {
+      let errorBody = ""; try { errorBody = await response.text(); } catch (_) { }
+      return createProviderErrorObject(providerName, `API request failed: HTTP ${response.status}. ${errorBody}`);
     }
+    const data = await response.json();
+    if (data.error || !data.videoSource) return createProviderErrorObject(providerName, data.error || "No videoSource found in API response");
+
+    const m3u8Url = data.videoSource;
+    const m3u8Response = await fetch(m3u8Url, { headers: { 'Referer': AUTOEMBED_DOMAIN, 'User-Agent': USER_AGENT } });
+    if (!m3u8Response.ok) return createProviderErrorObject(providerName, `Failed to fetch m3u8 from ${m3u8Url}: HTTP ${m3u8Response.status}`);
+
+    const m3u8Content = await m3u8Response.text();
+    // Pass s and e to the M3U8 parser
+    const files = parseAutoEmbedM3U8(m3u8Content, s, e, m3u8Url);
+    if (files.length === 0) return createProviderErrorObject(providerName, "No valid streams found after parsing m3u8");
+
+    const subtitles = data.subtitles ? mapAutoEmbedSubtitles(data.subtitles) : [];
+    return { source: { provider: providerName, files: files, subtitles: subtitles, headers: { "Referer": AUTOEMBED_DOMAIN, "User-Agent": USER_AGENT, "Origin": AUTOEMBED_DOMAIN } } };
+  } catch (error) {
+    console.error(`${providerName}: Unexpected error - `, error);
+    return createProviderErrorObject(providerName, `Network or processing error: ${error.message}`);
+  }
 }
 
 // --- Provider Configuration ---