Upload 9 files

episodes.js

@@ -1,55 +1,95 @@
-import axios from 'axios';
 import cloudscraper from 'cloudscraper';
 import * as cheerio from 'cheerio';
-import { getStream, getEpisodes } from './streams.js'; // Importa sia getStream che getEpisodes
+import { getStream, getEpisodes } from './streams.js';
+
+const DEBUG_MODE = process.env.DEBUG === 'true';
+const CLOUDFLARE_RETRIES = process.env.CLOUDFLARE_RETRIES || 3;
+const META_CACHE_TTL = 3600000; // 1 ora
 
-// Lista di User-Agent
 const userAgents = [
-    'Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/74.0.3729.169 Safari/537.3',
-    'Mozilla/5.0 (Windows NT 10.0; Win64; x64; rv:66.0) Gecko/20100101 Firefox/66.0',
-    'Mozilla/5.0 (Macintosh; Intel Mac OS X 10_14_4) AppleWebKit/605.1.15 (KHTML, like Gecko) Version/12.1 Safari/605.1.15'
+    'Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/123.0.6312.122 Safari/537.36',
+    'Mozilla/5.0 (Windows NT 10.0; rv:125.0) Gecko/20100101 Firefox/125.0',
+    'Mozilla/5.0 (Macintosh; Intel Mac OS X 14_5) AppleWebKit/605.1.15 (KHTML, like Gecko) Version/17.4 Safari/605.1.15',
+    'Mozilla/5.0 (Linux; Android 14; SM-S928U) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/123.0.6312.140 Mobile Safari/537.36'
 ];
 
-// Funzione per ottenere headers casuali
-function getRandomHeaders() {
-    const userAgent = userAgents[Math.floor(Math.random() * userAgents.length)];
-    return {
-        'User-Agent': userAgent,
-        'Referer': 'https://ramaorientalfansub.tv/paese/corea-del-sud/',
-        'Accept-Language': 'en-US,en;q=0.9'
-    };
+const metaCache = new Map();
+
+function debugLog(message) {
+    if (DEBUG_MODE) {
+        console.log(`[EPISODES][${new Date().toISOString()}] ${message}`);
+    }
 }
 
-// Istanza di Axios con headers casuali
-const axiosInstance = axios.create({
-    headers: getRandomHeaders()
-});
-export { axiosInstance, axios, cloudscraper, cheerio };
-// Cache per i metadati delle serie
-const metaCache = new Map();
+async function fetchWithCloudscraper(url, retries = 2) {
+    const userAgents = [
+        'Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/123.0.6312.122 Safari/537.36',
+        'Mozilla/5.0 (Windows NT 10.0; rv:125.0) Gecko/20100101 Firefox/125.0',
+        'Mozilla/5.0 (Macintosh; Intel Mac OS X 14_5) AppleWebKit/605.1.15 (KHTML, like Gecko) Version/17.4 Safari/605.1.15',
+        'Mozilla/5.0 (Linux; Android 14; SM-S928U) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/123.0.6312.140 Mobile Safari/537.36',
+        'Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) HeadlessChrome/123.0.6312.122'
+    ];
 
-async function fetchWithCloudscraper(url) {
-    try {
-        const data = await cloudscraper.get({
-            uri: url,
-            headers: getRandomHeaders() // Aggiungi headers casuali anche qui
-        });
-        return data;
-    } catch (error) {
-        console.error("Errore con Cloudscraper:", error);
-        return null;
+    function getRandomHeaders() {
+        return {
+            'User-Agent': userAgents[Math.floor(Math.random() * userAgents.length)],
+            'Referer': 'https://ramaorientalfansub.tv',
+            'Accept-Language': 'en-US,en;q=0.9',
+            'Upgrade-Insecure-Requests': '1',
+            'Cache-Control': 'no-cache',
+            'Pragma': 'no-cache',
+            'Connection': 'keep-alive'
+        };
+    }
+
+    for (let i = 0; i < retries; i++) {
+        try {
+            console.log(`[${i + 1}/${retries}] Tentativo di scraping: ${url}`);
+            const response = await cloudscraper.get({
+                uri: url,
+                headers: getRandomHeaders(),
+                followAllRedirects: true,
+                maxRedirects: 5,
+                timeout: 30000,
+                resolveWithFullResponse: true // Aggiungi questa opzione
+            });
+
+            if (response.statusCode === 404) {
+                console.warn(`[${i + 1}/${retries}] Errore 404 per ${url}. Interrompo i tentativi.`);
+                return null; // Interrompi immediatamente se l'episodio non esiste
+            }
+
+            if (response && response.statusCode >= 200 && response.statusCode < 300) {
+                console.log(`[${i + 1}/${retries}] Scraping riuscito: ${url}`);
+                return response.body; // Restituisci il corpo della risposta
+            } else {
+                console.warn(`[${i + 1}/${retries}] Errore ${response.statusCode} per ${url}. Riprovo...`);
+                await new Promise(resolve => setTimeout(resolve, 5000));
+            }
+        } catch (error) {
+            console.error(`[${i + 1}/${retries}] Errore Cloudscraper per ${url}: ${error.message}`);
+            if (error.message.includes('Cloudflare')) {
+                console.warn(`[${i + 1}/${retries}] Rilevato Cloudflare. Attendo 15 secondi...`);
+                await new Promise(resolve => setTimeout(resolve, 15000));
+            } else {
+                console.warn(`[${i + 1}/${retries}] Errore generico. Attendo 5 secondi...`);
+                await new Promise(resolve => setTimeout(resolve, 5000));
+            }
+        }
     }
+    console.error(`[FETCH_FAILED] Impossibile recuperare ${url} dopo ${retries} tentativi.`);
+    return null;
 }
 
+
 async function getMeta(id) {
     const meta = { id, type: 'series', name: '', poster: '', episodes: [] };
-    const cleanId = id.replace(/,/g, '').replace(/\s+/g, '-').toLowerCase();
+    const cleanId = id.replace(/,/g, '-').toLowerCase();
     const baseId = cleanId.replace(/-\d{4}$/, '');
     const seriesLink = `https://ramaorientalfansub.tv/drama/${baseId}/`;
-    // Verifica se i metadati sono in cache
+
     if (metaCache.has(id)) {
-        console.log(`Caricamento metadati dalla cache per ${id}`);
-        return { meta: metaCache.get(id) }; // Restituisci direttamente i metadati dalla cache
+        return { meta: metaCache.get(id) };
     }
 
     try {
@@ -60,28 +100,32 @@ async function getMeta(id) {
         }
 
         const $ = cheerio.load(data);
-        // Carica i metadati (name, poster, description)
         meta.name = $('a.text-accent').text().trim();
         meta.poster = $('img.wp-post-image').attr('src');
-        let description = $('div.font-light > div:nth-child(1)').text().trim(); // Recupera la descrizione
-        // Aggiungi il tag alla descrizione se presente
+        let description = $('div.font-light > div:nth-child(1)').text().trim();
         if (meta.extra && meta.extra.tag) {
             description += ` [${meta.extra.tag.toUpperCase()}]`;
         }
+        meta.description = description;
+
+        // Recupera gli episodi
+        meta.episodes = await getEpisodes(seriesLink, $);
+
+        // Aggiungi i link degli episodi alla descrizione
+        if (meta.episodes && meta.episodes.length > 0) {
+            description += "\n\nEpisodi:\n";
+            meta.episodes.forEach(episode => {
+                description += `- ${episode.title}: ${episode.streams[0].url}\n`;
+            });
+        }
 
-        meta.description = description; // Assegna la descrizione modificata a meta.description
-        // Carica gli episodi
-        meta.episodes = await getEpisodes(seriesLink, $); // Passa l'oggetto cheerio
-        console.log('Episodi trovati:', meta.episodes);
-        // Salva i metadati nella cache (CON gli episodi)
         metaCache.set(id, meta);
-        console.log(`Metadati salvati nella cache per ${id}`);
     } catch (error) {
         console.error('Errore nel caricamento dei dettagli della serie:', error);
     }
 
-    console.log('Meta finale:', meta);
     return { meta };
 }
 
-export { getMeta };
+
+export { getMeta };

main.js

@@ -4,106 +4,89 @@ import filmsCatalog from './rama_films.js';
 import { getMeta } from './episodes.js';
 
 const { addonBuilder, serveHTTP } = pkg;
+const META_CACHE_TTL = 3600000; // 1 ora
 
 const manifest = {
     "id": "community.ramaorientalfansub",
-    "version": "1.0.5",
-    "name": "Rama Oriental Fansub",
-    "description": "Addon per visualizzare serie e film coreani dal sito Rama Oriental Fansub",
+    "version": "1.0.6",
+    "name": "Rama Oriental Fansub+",
+    "description": "Addon migliorato con scraper avanzato",
     "catalogs": [
         {
             "type": "series",
             "id": "rama_series",
-            "name": "Serie Coreane",
+            "name": "Serie Coreane+",
             "extra": [{ "name": "skip" }]
         },
         {
             "type": "movie",
             "id": "rama_films",
-            "name": "Film Coreani",
+            "name": "Film Coreani+",
             "extra": [{ "name": "skip" }]
         }
     ],
-    "resources": ["catalog", "meta", "stream"],
-    "types": ["series", "movie"],
-    "logo": "https://ramaorientalfansub.tv/wp-content/uploads/2023/10/cropped-Logo-1.png",
-    "background": "https://ramaorientalfansub.tv/wp-content/uploads/2023/10/2860055-e1696595653601.jpg"
+   "resources": ["catalog", "meta", "stream"],
+  "types": ["series", "movie"],
+  "logo": "https://ramaorientalfansub.tv/wp-content/uploads/2023/10/cropped-Logo-1.png",
+  "background": "https://ramaorientalfansub.tv/wp-content/uploads/2023/10/2860055-e1696595653601.jpg"
 };
 
 const builder = new addonBuilder(manifest);
 const metaCache = new Map();
 
-builder.defineStreamHandler(async ({ type, id }) => {
-    if (type !== "series") {
-        return Promise.resolve({ streams: [] });
-    }
 
-    console.log(`Richiesta stream per ID: ${id}`);
-    let meta = null;
+builder.defineStreamHandler(async ({ type, id }) => {
+    try {
+        if (type !== "series") return { streams: [] };
 
-    if (metaCache.has(id)) {
-        console.log(`Caricamento metadati dalla cache per ${id}`);
-        meta = metaCache.get(id);
-    } else {
-        try {
-            const metaResult = await getMeta(id);
-            meta = metaResult.meta;
-            metaCache.set(id, meta);
-        } catch (error) {
-            console.error(`Errore nel caricamento dei metadati per ${id}:`, error);
-            return Promise.resolve({ streams: [] });
+        let meta = metaCache.get(id);
+        if (!meta || Date.now() - meta.timestamp > META_CACHE_TTL) {
+            const result = await getMeta(id);
+            meta = result.meta;
+            metaCache.set(id, { ...meta, timestamp: Date.now() });
         }
-    }
 
-    if (!meta || !meta.episodes || meta.episodes.length === 0) {
-        console.warn(`Nessun episodio trovato per ${id}`);
-        return Promise.resolve({ streams: [] });
+        return {
+            streams: meta.episodes?.flatMap(ep => 
+                ep.streams.map(stream => ({
+                    title: `${ep.title} - ${stream.title}`,
+                    url: stream.url,
+                    type: "video/mp4",
+                    behaviorHints: { bingeGroup: id }
+                }))
+            ) || []
+        };
+    } catch (error) {
+        console.error(`Handler Error: ${error.message}`);
+        return { streams: [] };
     }
-
-    const streams = meta.episodes.flatMap(ep =>
-        ep.streams.map(stream => ({
-            title: `${ep.title} - ${stream.title}`,
-            url: stream.url,
-            type: "video/mp4",
-            behaviorHints: {
-                bingeGroup: id,
-                notWebReady: false
-            }
-        }))
-    );
-
-    return Promise.resolve({ streams });
 });
 
 builder.defineCatalogHandler(async (args) => {
+    console.log("Catalog Handler chiamato con:", args); // Aggiungi questo log
     if (args.type === 'series' && args.id === 'rama_series') {
-        return seriesCatalog(args);
+      return seriesCatalog(args);
     } else if (args.type === 'movie' && args.id === 'rama_films') {
-        return filmsCatalog(args);
+      return filmsCatalog(args);
     }
-});
-
-builder.defineMetaHandler(async (args) => {
-    let meta = null;
-
-    if (metaCache.has(args.id)) {
-        console.log(`Caricamento metadati dalla cache per ${args.id}`);
-        meta = { meta: metaCache.get(args.id) };
-    } else {
-        try {
-            const metaResult = await getMeta(args.id);
-            meta = metaResult.meta;
-            metaCache.set(args.id, meta);
-        } catch (error) {
-            console.error(`Errore nel caricamento dei metadati per ${args.id}:`, error);
-            return { meta: null };
-        }
+    return { metas: [] }; // Aggiungi un return di default
+  });
+  
+  builder.defineMetaHandler(async (args) => {
+    let meta = metaCache.get(args.id);
+    if (!meta) {
+      try {
+        const metaResult = await getMeta(args.id);
+        meta = metaResult.meta;
+        metaCache.set(args.id, meta);
+      } catch (error) {
+        console.error(`Errore nel caricamento dei metadati per ${args.id}:`, error);
+        return { meta: null };
+      }
     }
-
+  
     return { meta: { ...meta, extra: meta.extra } };
-});
-
-export default builder.getInterface();
-
-serveHTTP(builder.getInterface(), { port: 7000 });
-console.log(`Addon server is running at http://localhost:7000/manifest.json`);
+  });
+  
+  serveHTTP(builder.getInterface(), { port: 7000 });
+  console.log(`Addon server is running at http://localhost:7000/manifest.json`);

manifest.json

@@ -1,6 +1,6 @@
 {
   "id": "community.ramaorientalfansub",
-  "version": "1.0.5",
+  "version": "1.0.6",
   "name": "Rama Oriental Fansub",
   "description": "Addon per visualizzare serie e film coreani dal sito Rama Oriental Fansub",
   "catalogs": [

package.json

@@ -1,23 +1,28 @@
 {
-  "name": "stremio-rama-addon",
-  "version": "1.0.0",
-  "type": "module",
-  "description": "Addon per Stremio per visualizzare serie e film coreani dal sito Rama Oriental Fansub",
-  "main": "main.js",
-  "scripts": {
-    "start": "node main.js"
-  },
-  "author": "Il tuo nome",
-  "license": "ISC",
-  "dependencies": {
-    "axios": "^1.5.0",
-    "cheerio": "^1.0.0-rc.12",
-    "cloudscraper": "4.6.0",
-    "puppeteer": "24.3.1",
-    "puppeteer-core": "^24.3.1",
-    "puppeteer-extra": "^3.3.6",
-    "puppeteer-extra-plugin-recaptcha": "^3.6.8",
-    "puppeteer-extra-plugin-stealth": "^2.11.2",
-    "stremio-addon-sdk": "^1.6.10"
-  }
-}
+    "name": "stremio-rama-addon",
+    "version": "1.0.6",
+    "main": "main.js",
+    "type": "module",
+    "scripts": {
+      "start": "node main.js",
+      "postinstall": "npx npm-force-resolutions"
+    },
+    "dependencies": {
+      "axios": "^1.6.2",
+      "cheerio": "^1.0.0",
+      "cloudscraper": "^4.1.4",
+      "stremio-addon-sdk": "^1.6.10",
+      "uuid": "^9.0.1"
+    },
+    "resolutions": {
+      "har-validator": "5.1.5",
+      "request": "2.88.2",
+      "tough-cookie": "^4.1.3"
+    },
+    "overrides": {
+      "cloudscraper": {
+        "request": "2.88.2",
+        "request-promise": "4.2.6"
+      }
+    }
+  }  

rama_series.js

@@ -1,16 +1,16 @@
 import cloudscraper from 'cloudscraper';
 import * as cheerio from 'cheerio';
 
+
 const userAgents = [
-    'Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/74.0.3729.169 Safari/537.3',
-    'Mozilla/5.0 (Windows NT 10.0; Win64; x64; rv:66.0) Gecko/20100101 Firefox/66.0',
-    'Mozilla/5.0 (Macintosh; Intel Mac OS X 10_14_4) AppleWebKit/605.1.15 (KHTML, like Gecko) Version/12.1 Safari/605.1.15'
+    'Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/123.0.0.0 Safari/537.36',
+    'Mozilla/5.0 (Windows NT 10.0; Win64; x64; rv:125.0) Gecko/20100101 Firefox/125.0',
+    'Mozilla/5.0 (Macintosh; Intel Mac OS X 14_5) AppleWebKit/605.1.15 (KHTML, like Gecko) Version/17.4 Safari/605.1.15'
 ];
 
 function getRandomHeaders() {
-    const userAgent = userAgents[Math.floor(Math.random() * userAgents.length)];
     return {
-        'User-Agent': userAgent,
+        'User-Agent': userAgents[Math.floor(Math.random() * userAgents.length)],
         'Referer': 'https://ramaorientalfansub.tv/paese/corea-del-sud/',
         'Accept-Language': 'en-US,en;q=0.9'
     };
@@ -20,7 +20,10 @@ async function fetchWithCloudscraper(url) {
     try {
         const data = await cloudscraper.get({
             uri: url,
-            headers: getRandomHeaders()
+            headers: getRandomHeaders(),
+            followAllRedirects: true,
+            maxRedirects: 5,
+            timeout: 30000,
         });
         return data;
     } catch (error) {
@@ -41,17 +44,14 @@ async function getCatalog(skip = 0) {
 
     while (catalog.length < itemsToLoad && pageNumber <= MAX_PAGES) {
         const pageUrl = `${BASE_URL}page/${pageNumber}/`;
-        console.log(`Richiedendo pagina: ${pageNumber}`);
-
         let data;
+
         if (catalogCache.has(pageUrl)) {
-            console.log(`Caricamento pagina ${pageNumber} dalla cache.`);
             data = catalogCache.get(pageUrl);
         } else {
             try {
                 data = await fetchWithCloudscraper(pageUrl);
                 if (!data) {
-                    console.warn(`Nessun dato ricevuto per ${pageUrl}`);
                     pageNumber++;
                     continue;
                 }
@@ -68,7 +68,7 @@ async function getCatalog(skip = 0) {
 
         $('div.w-full.bg-gradient-to-t.from-primary').each((index, element) => {
             if (catalog.length >= itemsToLoad) {
-                return false; // Interrompe il ciclo .each()
+                return false;
             }
 
             const titleElement = $(element).find('a.text-sm.line-clamp-2.font-medium.leading-snug.lg\\:leading-normal');
@@ -85,38 +85,35 @@ async function getCatalog(skip = 0) {
                 extraTag = 'simulcast';
             }
 
-            if (tagText.includes('tv')) {
-                if (title && link) {
-                    const formattedTitle = title.replace(/\s+/g, '-').toLowerCase().replace(/[()]/g, '');
-                    const meta = {
-                        id: formattedTitle,
-                        type: 'series',
-                        name: title,
-                        poster,
-                        description: title,
-                        imdbRating: "N/A",
-                        released: 2024,
-                    };
-
-                    if (extraTag) {
-                        meta.extra = { tag: extraTag };
-                    }
-
-                    catalog.push(meta);
-                    foundItemsOnPage++;
+            if (title && link) {
+                const formattedTitle = title.replace(/\s+/g, '-').toLowerCase().replace(/[()]/g, '');
+                const meta = {
+                    id: formattedTitle,
+                    type: 'series',
+                    name: title,
+                    poster,
+                    description: title,
+                    imdbRating: "N/A",
+                    released: 2024,
+                };
+
+                if (extraTag) {
+                    meta.extra = { tag: extraTag };
                 }
+
+                catalog.push(meta);
+                foundItemsOnPage++;
             }
         });
 
-        console.log(`Pagina ${pageNumber}: trovati ${foundItemsOnPage} elementi.`);
         pageNumber++;
     }
 
-    console.log(`Totale elementi raccolti: ${catalog.length}`);
     return catalog;
 }
 
 export default async function (args) {
     const skip = args.extra?.skip || 0;
-    return { metas: await getCatalog(skip) };
-};
+    const metas = await getCatalog(skip);
+    return { metas };
+};

streams.js

@@ -1,42 +1,74 @@
 import cloudscraper from 'cloudscraper';
 import * as cheerio from 'cheerio';
 
-// Lista di User-Agent
 const userAgents = [
-    'Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/74.0.3729.169 Safari/537.3',
-    'Mozilla/5.0 (Windows NT 10.0; Win64; x64; rv:66.0) Gecko/20100101 Firefox/66.0',
-    'Mozilla/5.0 (Macintosh; Intel Mac OS X 10_14_4) AppleWebKit/605.1.15 (KHTML, like Gecko) Version/12.1 Safari/605.1.15'
+    'Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/123.0.6312.122 Safari/537.36',
+    'Mozilla/5.0 (Windows NT 10.0; rv:125.0) Gecko/20100101 Firefox/125.0',
+    'Mozilla/5.0 (Macintosh; Intel Mac OS X 14_5) AppleWebKit/605.1.15 (KHTML, like Gecko) Version/17.4 Safari/605.1.15',
+    'Mozilla/5.0 (Linux; Android 14; SM-S928U) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/123.0.6312.140 Mobile Safari/537.36'
 ];
 
-// Funzione per ottenere headers casuali
-function getRandomHeaders() {
-    const userAgent = userAgents[Math.floor(Math.random() * userAgents.length)];
-    return {
-        'User-Agent': userAgent,
-        'Referer': 'https://ramaorientalfansub.tv', // Assicurati che il referer sia corretto
-        'Accept-Language': 'en-US,en;q=0.9'
-    };
-}
+// Modifica fetchWithCloudscraper per accettare l'URL come parametro
+async function fetchWithCloudscraper(url, retries = 2) {
+    const userAgents = [
+        'Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/123.0.6312.122 Safari/537.36',
+        'Mozilla/5.0 (Windows NT 10.0; rv:125.0) Gecko/20100101 Firefox/125.0',
+        'Mozilla/5.0 (Macintosh; Intel Mac OS X 14_5) AppleWebKit/605.1.15 (KHTML, like Gecko) Version/17.4 Safari/605.1.15',
+        'Mozilla/5.0 (Linux; Android 14; SM-S928U) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/123.0.6312.140 Mobile Safari/537.36',
+        'Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) HeadlessChrome/123.0.6312.122'
+    ];
 
-async function fetchWithCloudscraper(url) {
-    try {
-        const data = await cloudscraper.get({
-            uri: url,
-            headers: getRandomHeaders() // Aggiungi headers casuali
-        });
-        return data;
-    } catch (error) {
-        console.error("Errore con Cloudscraper:", error);
-        // Gestisci l'errore e restituisci null o un valore appropriato
-        return null;
+    function getRandomHeaders() {
+        return {
+            'User-Agent': userAgents[Math.floor(Math.random() * userAgents.length)],
+            'Referer': 'https://ramaorientalfansub.tv',
+            'Accept-Language': 'en-US,en;q=0.9',
+            'Upgrade-Insecure-Requests': '1',
+            'Cache-Control': 'no-cache',
+            'Pragma': 'no-cache',
+            'Connection': 'keep-alive'
+        };
     }
+
+    for (let i = 0; i < retries; i++) {
+        try {
+            console.log(`[${i + 1}/${retries}] Tentativo di scraping: ${url}`);
+            const response = await cloudscraper.get({
+                uri: url,
+                headers: getRandomHeaders(),
+                followAllRedirects: true,
+                maxRedirects: 5,
+                timeout: 30000,
+                resolveWithFullResponse: true // Aggiungi questa opzione
+            });
+
+            if (response.statusCode === 404) {
+                console.warn(`[${i + 1}/${retries}] Errore 404 per ${url}. Interrompo i tentativi.`);
+                return null; // Interrompi immediatamente se l'episodio non esiste
+            }
+
+            if (response && response.statusCode >= 200 && response.statusCode < 300) {
+                console.log(`[${i + 1}/${retries}] Scraping riuscito: ${url}`);
+                return response.body; // Restituisci il corpo della risposta
+            } else {
+                console.warn(`[${i + 1}/${retries}] Errore ${response.statusCode} per ${url}. Riprovo...`);
+                await new Promise(resolve => setTimeout(resolve, 5000));
+            }
+        } catch (error) {
+            console.error(`[${i + 1}/${retries}] Errore Cloudscraper per ${url}: ${error.message}`);
+            if (error.message.includes('Cloudflare')) {
+                console.warn(`[${i + 1}/${retries}] Rilevato Cloudflare. Attendo 15 secondi...`);
+                await new Promise(resolve => setTimeout(resolve, 15000));
+            } else {
+                console.warn(`[${i + 1}/${retries}] Errore generico. Attendo 5 secondi...`);
+                await new Promise(resolve => setTimeout(resolve, 5000));
+            }
+        }
+    }
+    console.error(`[FETCH_FAILED] Impossibile recuperare ${url} dopo ${retries} tentativi.`);
+    return null;
 }
 
-/**
- * Recupera il link dello stream per un episodio specifico.
- * @param {string} episodeLink - URL della pagina dell'episodio.
- * @returns {string|null} - URL dello stream o null se non trovato.
- */
 async function getStream(episodeLink) {
     let iframeSrc = null;
     try {
@@ -50,7 +82,6 @@ async function getStream(episodeLink) {
         iframeSrc = $('iframe').attr('src');
         if (iframeSrc) {
             iframeSrc = encodeURI(iframeSrc);
-            console.log(`Stream trovato: ${decodeURI(iframeSrc)}`);
             if (iframeSrc.startsWith('https://server1.streamingrof.online/02-DRAMACOREANI')) {
                 return iframeSrc;
             } else {
@@ -62,30 +93,20 @@ async function getStream(episodeLink) {
             return null;
         }
     } catch (err) {
-        console.log(`Analizzando stream per: ${episodeLink}`);
-        console.log('Iframe trovato:', iframeSrc);
         console.error(`Errore durante il recupero dello stream per ${episodeLink}:`, err);
         return null;
     }
 }
 
-/**
- * Recupera la lista degli episodi e i rispettivi stream per una serie.
- * @param {string} seriesLink - URL della pagina della serie.
- * @param {CheerioStatic} $ - Oggetto Cheerio caricato con la pagina della serie.
- * @returns {Array} - Lista di episodi con titolo, thumbnail e link allo stream.
- */
 async function getEpisodes(seriesLink, $) {
     try {
         const episodes = [];
         const baseEpisodeUrl = seriesLink.replace('/drama/', '/watch/');
-        console.log('Chiamata a getEpisodes con URL:', seriesLink);
         let seriesId = seriesLink.split('/').filter(Boolean).pop();
-        console.log('ID della serie estratto prima della pulizia:', seriesId);
-        seriesId = seriesId.replace(/,/g, '').replace(/\s+/g, '-').toLowerCase();
-        console.log('ID della serie dopo la pulizia:', seriesId);
+        seriesId = seriesId.replace(/,/g, '-').toLowerCase();
+        seriesId = seriesId.replace(/--+/g, '-');
+
         let seriesYear = null;
-        // Estrai l'anno dalla pagina della serie (se presente)
         try {
             const titleText = $('title').text();
             const yearMatch = titleText.match(/\b(19|20)\d{2}\b/);
@@ -96,23 +117,19 @@ async function getEpisodes(seriesLink, $) {
             console.error('Errore durante il recupero dell\'anno della serie:', error);
         }
 
-        console.log('Anno serie:', seriesYear);
-        // Invece di cercare il numero massimo di episodi, proviamo semplicemente a caricarli in sequenza
         let episodeNumber = 1;
         while (true) {
             const episodeId = seriesYear ? `${seriesId}-${seriesYear}` : seriesId;
             const episodeLink = `https://ramaorientalfansub.tv/watch/${episodeId}-episodio-${episodeNumber}/`;
-            console.log(`URL dell'episodio generato: ${episodeLink}`);
             try {
                 const stream = await getStream(episodeLink);
                 if (!stream) {
-                    console.log(`Stream non trovato per l'episodio ${episodeNumber}, interrompendo la ricerca.`);
-                    break; // Interrompi il ciclo se lo stream non viene trovato
+                    console.warn(`Nessuno stream trovato per ${episodeLink}. Interrompo.`);
+                    break; // Interrompi il ciclo while
                 }
-
                 episodes.push({
                     id: `episodio-${episodeNumber}`,
-                    title: `${episodeNumber}`,
+                    title: `Episodio ${episodeNumber}`,
                     thumbnail: 'div.swiper-slide:nth-child(1) > a:nth-child(1) > div:nth-child(1)',
                     streams: [{
                         title: `Episodio ${episodeNumber}`,
@@ -120,17 +137,13 @@ async function getEpisodes(seriesLink, $) {
                         type: "video/mp4"
                     }]
                 });
-                // Aggiungi un ritardo tra le richieste per ogni episodio
-                await new Promise(resolve => setTimeout(resolve, 1000)); // Aspetta 1 secondo
+                // await new Promise(resolve => setTimeout(resolve, 1000)); // Rimuovi questo delay
             } catch (error) {
-                console.error(`Errore durante il recupero dello stream per ${episodeLink}:`, err);
-                break; // Interrompi il ciclo anche in caso di errore
+                console.error(`Errore durante il recupero dello stream per ${episodeLink}:`, error);
+                break; // Interrompi il ciclo while anche in caso di errore
             }
-
             episodeNumber++;
         }
-
-        console.log('Episodi trovati:', JSON.stringify(episodes, null, 2));
         return episodes;
     } catch (err) {
         console.error('Errore durante il recupero degli episodi:', err);
@@ -138,4 +151,4 @@ async function getEpisodes(seriesLink, $) {
     }
 }
 
-export { getEpisodes, getStream }; // Esporta anche getStream
+export { getEpisodes, getStream };