axioso.js

/*
 * Copyright: KHAOUITI ABDELHAKIM 2024
 * GitHub: khaouitiabdelhakim
 */

// Set logging mode
let LOGGING = true;
const axios = require("axios");
// Map of YouTube format codes to format details
const FORMAT_MAP = {
  251: {
    itag: 251,
    type: "webm",
    vCodec: "NONE",
    aCodec: "OPUS",
    bitrate: 160,
    adaptive: true,
  },
  250: {
    itag: 250,
    type: "webm",
    vCodec: "NONE",
    aCodec: "OPUS",
    bitrate: 64,
    adaptive: true,
  },
  249: {
    itag: 249,
    type: "webm",
    vCodec: "NONE",
    aCodec: "OPUS",
    bitrate: 48,
    adaptive: true,
  },
};

// Enumeration for factory state
const FactoryState = {
  SUCCESS: "SUCCESS",
  ERROR: "ERROR",
  LOADING: "LOADING",
  INIT: "INIT",
};

// Initialize variables to hold deciphered signature and related information
let decipheredSignature = null;
let decipherJsFileName = null;
let decipherFunctions = null;
let decipherFunctionName = null;

// User agent string for HTTP requests
const USER_AGENT =
  "Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/126.0.0.0 Safari/537.36";

const axiosInstance = axios.create({
  headers: {
    "User-Agent": USER_AGENT
  },
});

// Regular expressions for parsing HTML and JavaScript content
const patPlayerResponse = /var ytInitialPlayerResponse\s*=\s*(\{.+?\})\s*;/;
const patSigEncUrl = /url=(.+?)(\u0026|$)/;
const patSignature = /s=(.+?)(\u0026|$)/;
const patVariableFunction =
  /([{; =])([a-zA-Z$][a-zA-Z0-9$]{0,2})\.([a-zA-Z$][a-zA-Z0-9$]{0,2})\(/g;
const patFunction = /([{; =])([a-zA-Z\$_][a-zA-Z0-9$]{0,2})\(/g;
const patDecryptionJsFile = /\\\/s\\\\\/player\\\\\/([^\"]+?)\.js/g;
const patDecryptionJsFileWithoutSlash = /\/s\/player\/([^\"]+?)\.js/g;
const patSignatureDecFunction =
  /(?:\b|[^a-zA-Z0-9$])([a-zA-Z0-9$]{1,4})\s*=\s*function\(\s*a\s*\)\s*\{\s*a\s*=\s*a\.split\(\s*\"\"\s*\)/g;

// Function to fetch stream URLs for a given video ID
async function exract(videoID) {
  const encSignatures = new Map();
  let file = {}; // Initialize file as an empty object
  let pageHtml;
  const getUrl = `https://youtube.com/watch?v=${videoID}`;

  try {
    // Fetch the HTML content of the YouTube video page
    const response = await axiosInstance.get(getUrl);
    pageHtml = response.data;
  } catch (error) {
    console.error("Error fetching the page:", error);
  }

  // Extract ytInitialPlayerResponse object from HTML
  const mat = patPlayerResponse.exec(pageHtml);
  if (mat) {
    const ytPlayerResponse = JSON.parse(mat[1]);
    const streamingData = ytPlayerResponse.streamingData;

    const adaptiveFormats = streamingData.adaptiveFormats;
    parseFormats(
      adaptiveFormats,
      file,
      encSignatures,
      patSigEncUrl,
      patSignature
    );
  } else {
    if (LOGGING) console.log("ytPlayerResponse was not found");
  }

  if (encSignatures.size > 0) {
    let curJsFileName;
    let mat = patDecryptionJsFile.exec(pageHtml);
    if (!mat) mat = patDecryptionJsFileWithoutSlash.exec(pageHtml);
    if (mat) {
      curJsFileName = mat[0].replace(/\\\//g, "/");
      if (!decipherJsFileName || decipherJsFileName !== curJsFileName) {
        decipherFunctions = null;
        decipherFunctionName = null;
      }
      decipherJsFileName = curJsFileName;
    }
    if (LOGGING)
      console.log(`Decipher signatures: ${encSignatures.size}, video: ${file}`);

    if (await decipherSignature(encSignatures)) {
      if (LOGGING) console.log("Deciphered signature correctly");
    } else {
      if (LOGGING) console.error("Could not decipher signature");
    }

    const signature = decipheredSignature;
    if (!signature) {
      if (LOGGING) console.error("Could not decipher signature");
      return null;
    } else {
      const sigs = signature.split("\n").filter((s) => s.trim() !== "");
      let i = 0;
      for (let key of encSignatures.keys()) {
        let url = file.url;
        url += `&sig=${sigs[i]}`;
        file.type = FORMAT_MAP[key];
        file.url = url;
        i++;
      }
    }
  }

  if (file == null) {
    if (LOGGING) console.log(pageHtml);
    return null;
  }

  return file;
}

// Function to parse streaming formats
function parseFormats(
  formats,
  file,
  encSignatures,
  patSigEncUrl,
  patSignature
) {
  if (formats) {
    for (let i = 0; i < formats.length; i++) {
      const format = formats[formats.length - i - 1];
      const type = format.type;
      if (type === "FORMAT_STREAM_TYPE_OTF") continue;
      const itag = format.itag;
      if (FORMAT_MAP[itag]) {
        if (format.url) {
          let url = format.url.replace("\\u0026", "&");
          file.type = FORMAT_MAP[itag];
          file.url = url;
        } else if (format.signatureCipher) {
          const mat = patSigEncUrl.exec(format.signatureCipher);
          const matSig = patSignature.exec(format.signatureCipher);
          if (mat && matSig) {
            const url = decodeURIComponent(mat[1]);
            const signature = decodeURIComponent(matSig[1]);
            file.type = FORMAT_MAP[itag];
            file.url = url;
            if (LOGGING) console.log(`file: ${file.url}`);
            encSignatures.set(itag, signature);
          }
        }
        break;
      }
    }
  }
}

// Function to test HTTP status code 403
async function testHttp403Code(url) {
  try {
    const response = await axiosInstance.head(url); // Send a HEAD request using Axios instance
    if (response.status === 403) {
      return true;
    }
  } catch (error) {
    if (LOGGING) console.error("An error occurred:", error);
  }
  return false;
}

// Function to decipher signature using a WebView
async function decipherViaWebView(encSignatures) {
  let stb = `${decipherFunctions} function decipher(){return `;
  const keys = Array.from(encSignatures.keys());
  for (let i = 0; i < keys.length; i++) {
    const key = keys[i];
    if (i < keys.length - 1) {
      stb += `${decipherFunctionName}('` + encSignatures.get(key) + "')+'\\n'+";
    } else {
      stb += `${decipherFunctionName}('` + encSignatures.get(key) + "')";
    }
  }
  stb += "};decipher();";

  // Execute the JavaScript code using eval()
  try {
    const result = eval(stb);
    decipheredSignature = result;
  } catch (error) {
    if (LOGGING) console.error(error);
  }
}

// Function to decipher signature
async function decipherSignature(encSignatures) {
  // Assume the functions don't change that much
  if (!decipherFunctionName || !decipherFunctions) {
    const decipherFunctUrl = `https://youtube.com${decipherJsFileName}`;
    try {
      // Fetch the HTML content of the YouTube video page
      const response = await axiosInstance.get(decipherFunctUrl);
      const javascriptFile = response.data;

      if (LOGGING) console.log(`Decipher FunctURL: ${decipherFunctUrl}`);

      let mat = patSignatureDecFunction.exec(javascriptFile);
      if (mat) {
        decipherFunctionName = mat[1];

        if (LOGGING) console.log(`Decipher Functname: ${decipherFunctionName}`);

        const patMainVariable = new RegExp(
          `(var |\\s|,|;)${decipherFunctionName.replace(
            "$",
            "\\$"
          )}(=function\\((.{1,3})\\)\\{)`
        );
        mat = patMainVariable.exec(javascriptFile);
        let mainDecipherFunct;
        if (mat) {
          mainDecipherFunct = `var ${decipherFunctionName}${mat[2]}`;
        } else {
          const patMainFunction = new RegExp(
            `function ${decipherFunctionName.replace(
              "$",
              "\\$"
            )}(\\((.{1,3})\\)\\{)`
          );
          mat = patMainFunction.exec(javascriptFile);
          if (!mat) return false;
          mainDecipherFunct = `function ${decipherFunctionName}${mat[2]}`;
        }

        let startIndex = mat.index + mat[0].length;
        let braces = 1;
        let i = startIndex;
        while (i < javascriptFile.length) {
          if (braces === 0 && startIndex + 5 < i) {
            mainDecipherFunct += javascriptFile.substring(startIndex, i) + ";";
            break;
          }
          if (javascriptFile[i] === "{") braces++;
          else if (javascriptFile[i] === "}") braces--;
          i++;
        }
        decipherFunctions = mainDecipherFunct;

        if (LOGGING)
          console.log(`Main Decipher Function: ${mainDecipherFunct}`);

        // Search the main function for extra functions and variables needed for deciphering
        // Search for variables
        var max = 0;
        while ((mat = patVariableFunction.exec(mainDecipherFunct))) {
          const variableDef = `var ${mat[2]}={`;
          if (decipherFunctions.includes(variableDef)) {
            max++;
            if (max > 10) break;
            if (LOGGING) console.log(`variables: ${variableDef}`);
            continue;
          }
          let startIndex =
            javascriptFile.indexOf(variableDef) + variableDef.length;
          let bracesVariable = 1;
          let i1 = startIndex;
          while (i1 < javascriptFile.length) {
            if (bracesVariable === 0) {
              decipherFunctions += `${variableDef}${javascriptFile.substring(
                startIndex,
                i1
              )};`;
              break;
            }
            if (javascriptFile[i1] === "{") bracesVariable++;
            else if (javascriptFile[i1] === "}") bracesVariable--;
            i1++;
          }
        }

        // Search for functions
        while ((mat = patFunction.exec(mainDecipherFunct))) {
          const functionDef = `function ${mat[2]}(`;
          if (decipherFunctions.includes(functionDef)) {
            continue;
          }
          startIndex =
            javascriptFile.indexOf(functionDef, mat.index) + functionDef.length;
          let bracesFunction = 0;
          let i2 = startIndex;
          while (i2 < javascriptFile.length) {
            if (bracesFunction === 0 && startIndex + 5 < i2) {
              decipherFunctions += `${functionDef}${javascriptFile.substring(
                startIndex,
                i2
              )};`;
              break;
            }
            if (javascriptFile[i2] === "{") bracesFunction++;
            else if (javascriptFile[i2] === "}") bracesFunction--;
            i2++;
          }
        }

        if (LOGGING) console.log(`Decipher Functions: ${decipherFunctions}`);

        decipherViaWebView(encSignatures);
      } else {
        return false;
      }
    } catch (error) {
      if (LOGGING) console.error("An error occurred:", error);
      return false;
    }
  } else {
    decipherViaWebView(encSignatures);
  }
  return true;
}

async function getStreamUrl(videoID) {
  let ok = false;
  retry = 3;
  i = 0;
  try {
    while (!ok && i < retry) {
      const file = await exract(videoID);
      if (file) {
        if (testHttp403Code(file.url)) {
          if (LOGGING) console.log("file:", file);
          ok = true;
          return file;
        }
      } else {
        if (LOGGING) console.log("No YouTube files found.");
      }
      i++;
    }
  } catch (error) {
    if (LOGGING) console.error("An error occurred:", error);
  }
  return null;
}

module.exports = getStreamUrl;