Adding token extractor

Author: cryshin22

src/helper/token.helper.js

@@ -0,0 +1,71 @@
+import axios from 'axios';
+import * as cheerio from 'cheerio';
+import { v1_base_url } from '../utils/base_v1.js';
+
+export default async function extractToken(url) {
+  try {
+    const { data: html } = await axios.get(url, {
+      headers: {
+        Referer: `https://${v1_base_url}/`
+      }
+    });
+
+    const $ = cheerio.load(html);
+    const results = {};
+
+    // 1. Meta tag
+    const meta = $('meta[name="_gg_fb"]').attr('content');
+    if (meta) results.meta = meta;
+
+    // 2. Data attribute
+    const dpi = $('[data-dpi]').attr('data-dpi');
+    if (dpi) results.dataDpi = dpi;
+
+    // 3. Nonce from empty script
+    const nonceScript = $('script[nonce]').filter((i, el) => {
+      return $(el).text().includes('empty nonce script');
+    }).attr('nonce');
+    if (nonceScript) results.nonce = nonceScript;
+
+    // 4. JS string assignment: window.<key> = "value";
+    const stringAssignRegex = /window\.(\w+)\s*=\s*["']([\w-]+)["']/g;
+    const stringMatches = [...html.matchAll(stringAssignRegex)];
+    for (const [_, key, value] of stringMatches) {
+      results[`window.${key}`] = value;
+    }
+
+    // 5. JS object assignment: window.<key> = { ... };
+    const objectAssignRegex = /window\.(\w+)\s*=\s*(\{[\s\S]*?\});/g;
+    const matches = [...html.matchAll(objectAssignRegex)];
+    for (const [_, varName, rawObj] of matches) {
+      try {
+        const parsedObj = eval('(' + rawObj + ')'); 
+        if (parsedObj && typeof parsedObj === 'object') {
+          const stringValues = Object.values(parsedObj).filter(val => typeof val === 'string');
+          const concatenated = stringValues.join('');
+          if (concatenated.length >= 20) {
+            results[`window.${varName}`] = concatenated;
+          }
+        }
+      } catch (e) {
+        // Skip invalid object
+      }
+    }
+
+    // 6. HTML comment: <!-- _is_th:... -->
+    $('*').contents().each(function () {
+      if (this.type === 'comment') {
+        const match = this.data.trim().match(/^_is_th:([\w-]+)$/);
+        if (match) {
+          results.commentToken = match[1].trim();
+        }
+      }
+    });
+
+    const token = Object.values(results)[0];
+    return token || null;
+  } catch (err) {
+    console.error('Error:', err.message);
+    return null;
+  }
+}

src/parsers/decryptors/decrypt_v1.decryptor.js

@@ -2,6 +2,7 @@ import axios from "axios";
 import CryptoJS from "crypto-js";
 import { v1_base_url } from "../../utils/base_v1.js";
 import { fallback_1, fallback_2 } from "../../utils/fallback.js";
+import extractToken from "../../helper/token.helper.js";
 
 export async function decryptSources_v1(epID, id, name, type) {
   try {
@@ -25,15 +26,13 @@ export async function decryptSources_v1(epID, id, name, type) {
     let rawSourceData = {};
 
     try {
-      const { data } = await axios.get(`${baseUrl}/getSources?id=${sourceId}`);
+      const token = await extractToken(`${baseUrl}/${sourceId}?k=1&autoPlay=0&oa=0&asi=1`);
+      const { data } = await axios.get(`${baseUrl}/getSources?id=${sourceId}&_k=${token}`);
       rawSourceData = data;
-
       const encrypted = rawSourceData?.sources;
       if (!encrypted) throw new Error("Encrypted source missing");
-
       const decrypted = CryptoJS.AES.decrypt(encrypted, key.trim()).toString(CryptoJS.enc.Utf8);
       if (!decrypted) throw new Error("Failed to decrypt source");
-
       decryptedSources = JSON.parse(decrypted);
     } catch (decryptionError) {
       try {
@@ -62,9 +61,15 @@ export async function decryptSources_v1(epID, id, name, type) {
         );
 
         decryptedSources = [{ file: fallback_data.sources.file }];
-        rawSourceData.tracks = fallback_data.tracks ?? [];
-        rawSourceData.intro = fallback_data.intro ?? null;
-        rawSourceData.outro = fallback_data.outro ?? null;
+        if (!rawSourceData.tracks || rawSourceData.tracks.length === 0) {
+          rawSourceData.tracks = fallback_data.tracks ?? [];
+        }
+        if (!rawSourceData.intro) {
+          rawSourceData.intro = fallback_data.intro ?? null;
+        }
+        if (!rawSourceData.outro) {
+          rawSourceData.outro = fallback_data.outro ?? null;
+        }
       } catch (fallbackError) {
         throw new Error("Fallback failed: " + fallbackError.message);
       }