Add animepahe/animepahe.js

animepahe/animepahe.js

@@ -0,0 +1,421 @@
+async function searchResults(keyword) {
+    try {
+        const encodedKeyword = encodeURIComponent(keyword);
+        const ddosInterceptor = new DdosGuardInterceptor();
+        const responseText = await ddosInterceptor.fetchWithBypass(`https://animepahe.si/api?m=search&q=${encodedKeyword}`);
+        const dataText = await responseText.text();
+        console.log(dataText);
+        const data = JSON.parse(dataText);
+        const transformedResults = data.data.map(result => {
+            return {
+                title: result.title,
+                image: result.poster,
+                href: `https://animepahe.si/anime/${result.session}`
+            };
+        });
+
+        return JSON.stringify(transformedResults);
+    } catch (error) {
+        console.log("Fetch error in searchResults: " + error);
+        return JSON.stringify([{ title: "Error", image: "", href: "" }]);
+    }
+}
+
+async function extractDetails(url) {
+    try {
+        const ddosInterceptor = new DdosGuardInterceptor();
+        const responseText = await ddosInterceptor.fetchWithBypass(url);
+        const dataText = await responseText.text();
+
+        const descMatch = dataText.match(/<div class="anime-synopsis">(.*?)<\/div>/s);
+        const description = descMatch ? descMatch[1].replace(/<br\s*\/?>/gi, '\n').trim() : 'N/A';
+
+        const aliasMatch = dataText.match(/<strong>Synonyms: <\/strong>(.*?)<\/p>/);
+        const aliases = aliasMatch ? aliasMatch[1].trim() : 'N/A';
+
+        const airMatch = dataText.match(/<strong>Aired:<\/strong>(.*?)<\/p>/s);
+        const airdate = airMatch ? airMatch[1].replace(/\s+/g, ' ').trim() : 'N/A';
+
+        return JSON.stringify([{
+            description,
+            aliases,
+            airdate
+        }]);
+    } catch (err) {
+        return JSON.stringify([{
+            description: "Error",
+            aliases: "Error",
+            airdate: "Error"
+        }]);
+    }
+}
+
+async function extractEpisodes(url) {
+    const results = [];
+    try {
+        const uuidMatch = url.match(/\/anime\/([^\/]+)/);
+        if (!uuidMatch) throw new Error("Invalid URL");
+        const id = uuidMatch[1];
+
+        const ddosInterceptor = new DdosGuardInterceptor();  
+
+        let page = 1;
+        const apiUrl1 = `https://animepahe.si/api?m=release&id=${id}&sort=episode_asc&page=${page}`;
+        const response1 = await ddosInterceptor.fetchWithBypass(apiUrl1);
+        const dataText1 = await response1.text();
+        const data1 = JSON.parse(dataText1);
+
+        for (const item of data1.data) {
+            results.push({
+                href: `https://animepahe.si/play/${id}/${item.session}`,
+                number: item.episode
+            });
+        }
+
+        const lastPage = data1.last_page;
+        if (lastPage > 1) {
+            const promises = [];
+            for (let p = 2; p <= lastPage; p++) {
+                const apiUrl = `https://animepahe.si/api?m=release&id=${id}&sort=episode_asc&page=${p}`;
+                promises.push(ddosInterceptor.fetchWithBypass(apiUrl).then(response => response.text()).then(text => JSON.parse(text)));
+            }
+            const datas = await Promise.all(promises);
+            for (const data of datas) {
+                for (const item of data.data) {
+                    results.push({
+                        href: `https://animepahe.si/play/${id}/${item.session}`,
+                        number: item.episode
+                    });
+                }
+            }
+        }
+
+        return JSON.stringify(results);
+    } catch (err) {
+        return JSON.stringify([{
+            href: "Error",
+            number: "Error"
+        }]);
+    }
+}
+
+async function extractStreamUrl(url) {
+    try {
+        const ddosInterceptor = new DdosGuardInterceptor();
+        const responseText = await ddosInterceptor.fetchWithBypass(url);
+        const dataText = await responseText.text();
+
+        const buttonMatches = dataText.match(/<button[^>]*data-src="([^"]*)"[^>]*>/g);
+        if (!buttonMatches) {
+            return JSON.stringify({ streams: [], subtitle: "" });
+        }
+        
+        const streams = [];
+        
+        for (const buttonHtml of buttonMatches) {
+            const srcMatch = buttonHtml.match(/data-src="([^"]*)"/);
+            const resMatch = buttonHtml.match(/data-resolution="([^"]*)"/);
+            const audioMatch = buttonHtml.match(/data-audio="([^"]*)"/);
+            const fansubMatch = buttonHtml.match(/data-fansub="([^"]*)"/);
+            
+            if (!srcMatch || !srcMatch[1].includes('kwik.cx')) continue;
+            
+            const kwikUrl = srcMatch[1];
+            const resolution = resMatch ? resMatch[1] : "Unknown";
+            const audio = audioMatch ? audioMatch[1] : "jpn";
+            const fansub = fansubMatch ? fansubMatch[1] : "Unknown";
+            
+            try {
+                const html = await fetchv2(kwikUrl).then(r => r.text());
+                const scriptMatch = html.match(/<script>(.*?)<\/script>/s);
+                
+                if (scriptMatch) {
+                    const scriptContent = scriptMatch[1];
+                    let unpacked = null;
+                    
+                    if (scriptContent.includes('));eval(')) {
+                        const parts = scriptContent.split('));eval(');
+                        if (parts.length === 2) {
+                            const layer2Packed = parts[1].substring(0, parts[1].length - 1);
+                            unpacked = unpack(layer2Packed);
+                        }
+                    } else {
+                        unpacked = unpack(scriptContent);
+                    }
+                    
+                    if (unpacked) {
+                        const urlMatch = unpacked.match(/const source=\\?['"]([^'"]+)['"]/) || 
+                                        unpacked.match(/https:\/\/[^\s'";]+\.m3u8/);
+                        
+                        if (urlMatch) {
+                            const hlsUrl = urlMatch[1] || urlMatch[0];
+                            const audioType = audio === "eng" ? "Dub" : "Hardsub";
+                            const title = `${resolution}p • ${audioType}`;
+                            
+                            streams.push({
+                                title: title,
+                                streamUrl: hlsUrl,
+                                headers: {
+                                    "Referer": "https://kwik.cx/",
+                                    "Origin": "https://kwik.cx"
+                                }
+                            });
+                        }
+                    }
+                }
+            } catch (e) {
+                continue;
+            }
+        }
+        
+        return JSON.stringify({
+            streams: streams,
+            subtitle: ""
+        });
+    } catch (err) {
+        return JSON.stringify({ streams: [], subtitle: "" });
+    }
+}
+
+// Fixed DDOS Bypass
+class DdosGuardInterceptor {
+    constructor() {
+        this.errorCodes = [403]; 
+        this.serverCheck = ["ddos-guard"]; 
+        this.cookieStore = {}; 
+    }
+
+    async fetchWithBypass(url, options = {}) {
+        let response = await this.fetchWithCookies(url, options);
+
+        const isBlocked = await this.isBlockedResponse(response);
+        
+        if (!isBlocked) {
+            return response;
+        }
+
+
+        if (this.cookieStore["__ddg2_"]) {
+            return this.fetchWithCookies(url, options);
+        }
+
+        const newCookie = await this.getNewCookie(url);
+        if (!newCookie) {
+            return response;
+        }
+        
+        return this.fetchWithCookies(url, options);
+    }
+
+    async fetchWithCookies(url, options) {
+        const cookieHeader = this.getCookieHeader();
+        const headers = { ...options.headers, Cookie: cookieHeader };
+
+        const response = await fetchv2(url,  headers );
+
+        const setCookieHeader = response.headers["Set-Cookie"];
+        if (setCookieHeader) {
+            this.storeCookies(setCookieHeader);
+        }
+
+        return response;
+    }
+
+    isDdosGuard(response) {
+        const serverHeader = response.headers["Server"];
+        return serverHeader && this.serverCheck.includes(serverHeader.toLowerCase());
+    }
+
+    async isBlockedResponse(response) {
+        if (this.errorCodes.includes(response.status)) {
+            return true;
+        }
+        
+        const clonedResponse = response.clone();
+        const text = await clonedResponse.text();
+        
+        if (text.includes('ddos-guard/js-challenge') || 
+            text.includes('DDoS-Guard') || 
+            text.includes('data-ddg-origin')) {
+            return true;
+        }
+        
+        return false;
+    }
+
+    storeCookies(setCookieString) {
+        const cookies = Array.isArray(setCookieString) ? setCookieString : [setCookieString];
+
+        cookies.forEach(cookieHeader => {
+            const parts = cookieHeader.split(";");
+            if (parts.length > 0) {
+                const [key, value] = parts[0].split("=");
+                if (key) {
+                    this.cookieStore[key.trim()] = value?.trim() || "";
+                }
+            }
+        });
+    }
+
+    getCookieHeader() {
+        return Object.entries(this.cookieStore)
+            .map(([key, value]) => `${key}=${value}`)
+            .join("; ");
+    }
+
+    async getNewCookie(targetUrl) {
+        try {
+            const wellKnownResponse = await fetchv2("https://check.ddos-guard.net/check.js");
+            const wellKnownText = await wellKnownResponse.text();
+
+            const paths = wellKnownText.match(/['"](\/\.well-known\/ddos-guard\/[^'"]+)['"]/g);
+            const checkPaths = wellKnownText.match(/['"]https:\/\/check\.ddos-guard\.net\/[^'"]+['"]/g);
+
+            if (!paths || paths.length === 0) {
+                return null;
+            }
+
+            const localPath = paths[0].replace(/['"]/g, '');
+
+            const match = targetUrl.match(/^(https?:\/\/[^\/]+)/);
+            if (!match) {
+                return null;
+            }
+            const baseUrl = match[1];
+
+            const localUrl = `${baseUrl}${localPath}`;
+
+            const localResponse = await fetchv2(localUrl, {
+                headers: {
+                    'User-Agent': 'Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36',
+                    'Accept': 'image/avif,image/webp,image/apng,image/svg+xml,image/*,*/*;q=0.8',
+                    'Referer': targetUrl
+                }
+            });
+
+            let setCookie = localResponse.headers["set-cookie"] ||
+                           localResponse.headers["Set-Cookie"] ||
+                           (localResponse.headers.raw && localResponse.headers.raw()['set-cookie']) ||
+                           (localResponse.headers.get && localResponse.headers.get('set-cookie'));
+            if (setCookie) {
+                this.storeCookies(setCookie);
+            }
+
+            if (checkPaths && checkPaths.length > 0) {
+                const checkUrl = checkPaths[0].replace(/['"]/g, '');
+
+                const checkResponse = await fetchv2(checkUrl, {
+                    headers: {
+                        'User-Agent': 'Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36',
+                        'Accept': 'image/avif,image/webp,image/apng,image/svg+xml,image/*,*/*;q=0.8',
+                        'Referer': targetUrl
+                    }
+                });
+
+                setCookie = checkResponse.headers["set-cookie"] ||
+                           checkResponse.headers["Set-Cookie"] ||
+                           (checkResponse.headers.raw && checkResponse.headers.raw()['set-cookie']) ||
+                           (checkResponse.headers.get && checkResponse.headers.get('set-cookie'));
+                if (setCookie) {
+                    this.storeCookies(setCookie);
+                }
+            }
+
+            if (this.cookieStore["__ddg2_"]) {
+                return this.cookieStore["__ddg2_"];
+            }
+
+            return null;
+        } catch (error) {
+            return null;
+        }
+    }
+}
+
+// Fixed deobfuscator:
+class Unbaser {
+    constructor(base) {
+        this.ALPHABET = {
+            62: "0123456789abcdefghijklmnopqrstuvwxyzABCDEFGHIJKLMNOPQRSTUVWXYZ",
+            95: "' !\"#$%&'()*+,-./0123456789:;<=>?@ABCDEFGHIJKLMNOPQRSTUVWXYZ[\\]^_`abcdefghijklmnopqrstuvwxyz{|}~'",
+        };
+        this.dictionary = {};
+        this.base = base;
+        if (36 < base && base < 62) {
+            this.ALPHABET[base] = this.ALPHABET[base] || this.ALPHABET[62].substr(0, base);
+        }
+        if (2 <= base && base <= 36) {
+            this.unbase = (value) => parseInt(value, base);
+        } else {
+            try {
+                [...this.ALPHABET[base]].forEach((cipher, index) => {
+                    this.dictionary[cipher] = index;
+                });
+            } catch (er) {
+                throw Error("Unsupported base encoding.");
+            }
+            this.unbase = this._dictunbaser;
+        }
+    }
+    
+    _dictunbaser(value) {
+        let ret = 0;
+        [...value].reverse().forEach((cipher, index) => {
+            ret = ret + ((Math.pow(this.base, index)) * this.dictionary[cipher]);
+        });
+        return ret;
+    }
+}
+
+function unpack(source) {
+    function _filterargs(source) {
+        const juicers = [
+            /}\('(.*)', *(\d+|\[\]), *(\d+), *'(.*)'\.split\('\|'\), *(\d+), *(.*)\)\)/,
+            /}\('(.*)', *(\d+|\[\]), *(\d+), *'(.*)'\.split\('\|'\)/,
+        ];
+        for (const juicer of juicers) {
+            const args = juicer.exec(source);
+            if (args) {
+                let a = args;
+                try {
+                    return {
+                        payload: a[1],
+                        symtab: a[4].split("|"),
+                        radix: parseInt(a[2]),
+                        count: parseInt(a[3]),
+                    };
+                } catch (ValueError) {
+                    throw Error("Corrupted p.a.c.k.e.r. data.");
+                }
+            }
+        }
+        throw Error("Could not make sense of p.a.c.k.e.r data (unexpected code structure)");
+    }
+    
+    let { payload, symtab, radix, count } = _filterargs(source);
+    
+    if (count != symtab.length) {
+        throw Error("Malformed p.a.c.k.e.r. symtab.");
+    }
+    
+    let unbase;
+    try {
+        unbase = new Unbaser(radix);
+    } catch (e) {
+        throw Error("Unknown p.a.c.k.e.r. encoding.");
+    }
+    
+    function lookup(match) {
+        const word = match;
+        let word2;
+        if (radix == 1) {
+            word2 = symtab[parseInt(word)];
+        } else {
+            word2 = symtab[unbase.unbase(word)];
+        }
+        return word2 || word;
+    }
+    
+    source = payload.replace(/\b\w+\b/g, lookup);
+    return source;
+}