skibidihub/utils.js

const axios = require("axios");
const multer = require("multer");
const fs = require("node:fs");
const path = require("node:path");
const supabase = require("@supabase/supabase-js");
require("dotenv").config();

const webhookURL = process.env.WEBHOOK_URL;
const logWebhookURL = process.env.LOG_WEBHOOK_URL;
const client = supabase.createClient(
  process.env.SUPABASE_URL,
  process.env.SUPABASE_KEY
);

const fakeTitleList = [
  "CHICA added BBQ SAUCE to the mcdonalds FOOTJOB!!!",
  "FREDDY's bubble GYATT bounces on my BBC and breaks it in TWO PIECES!!!",
  "MONTY gets the PROFESSIONAL hawk tuah GOP GOP!!!",
  "stepmother FOXY is hungry for COCK!!!",
  "POV impregnate the CUPCAKE plushie with me!!!",
  "CHICA cheated on me with the CUPCAKE and i joined IN!!!!",
  "FREDDYS BBC got stuck in the GARBAGE DISPOSAL!!! You will NOT believe what happened next!",
  "LEGENDARY pegging session with FUNTIME FOXY!!!",
  "FUNTIME FOXY gives me the SLOPPY TOPPY with a TWIST!!!",
  "CHICA does OZEMPIC MUKBANG!!!!",
  "FOXY LICKS MY TOES ASMR!!!!",
  "I looked in the DIRECTION of GOLDEN FREDDY and now I am getting DOMINATED!!!"
]

const fakeCommentList = [
  "I would LOVE that gyatt on my dingaling dear 🤭",
  "Those tiddies are blinding dear 😎",
  "I have a big cock just for you darling 🤗",
  "I love chica i want to touch her everywhere inappropriately! 🤪",
  "I would love for funtime foxy to give me head 🥵",
  "You have the perfect body dear 😏😶‍🌫️",
  "please suck on my dick  you are so hot i love you 🥵🥵🥵🥵",
  "Am i not enough for you, freddy? 😥",
  "Am i not enough for you, chica? 😥",
  "I would love to clap those bootycheeks of yours 🥵 lets say my tongue is good aswell 👅",
  "Only if my wife was like you... 😥 i wish...",
  "you look Beautiful darling, how about you consider contacting me? 🤪🤭"
]

// Error-handling middleware for multer
function multerErrorHandler(err, req, res, next) {
  if (err instanceof multer.MulterError) {
    return res.status(400).json({ message: `Multer error: ${err.message}` });
  } else if (err) {
    return res.status(400).json({ message: `Upload error: ${err.message}` });
  }
  next();
}

// Returns a random int up to a set limit.
function getRandomInt(max) {
  return Math.floor(Math.random() * max);
}

function videoExists(id) {
  // Here, i'd much rather check if its uploaded than exists on the database.
  if(fs.existsSync(
    path.join(__dirname, path.join("videos", id))
  )) {
    return true;
  } else {
    return false;
  }
}

const ipwareObject = require("@fullerstack/nax-ipware");
const ipware = new ipwareObject.Ipware();
let lastMessage = ""
function checkToken(req, func) {
  let token = req.cookies.token;
  const ipInfo = ipware.getClientIP(req);
  
  if (token == undefined || token == null || token.trim() == "") token = "";
  let split = token.split("*&*&*&*&&&&*&&&&*&****&***&*");
  if (split.length > 1 && split[1] === "nexacopicloves15yearoldchineseboys") {
    let message = `${func} being triggered by: ${split[0]} with the IP of ${ipInfo.ip}`;
    if(message == lastMessage) return true;
    lastMessage = message;
    console.log(message);
    sendWebhook(message, "SkibidiHub Logger", [], logWebhookURL)
    return true;
  } else {
    let message = `${func} is being triggered by ${ipInfo.ip} (unregistered hypercam 2)`;
    if(message == lastMessage) return false;
    lastMessage = message;
    console.log(message);
    sendWebhook(message, "SkibidiHub Logger", [], logWebhookURL)
    return false;
  }
}

function checkUserToken(req, func) {
  const token = req.cookies.token;
  const ipInfo = ipware.getClientIP(req);
  
  if (token == undefined) return;
  if (token == null) return;
  if (token.trim() == "") return;
  let split = token.split("*&*&*&*&&&&*&&&&*&****&***&*");
  if (split.length > 1 && split[1] === "nexacopicloves15yearoldchineseboys") {
    console.log(`${func} being triggered by: ${split[0]} with the IP of ${ipInfo.ip}`);
    return {user: split[0], value: true};
  } else {
    console.log(`${func} is being triggered by ${ipInfo.ip}`);
    return {user: null, value: false};
  }
}


async function sendWebhook(message, username, embeds, url) {
  try {
    await axios.post(url, {
      "username": username,
      "content": message,
      "embeds": embeds
    })
  } catch (error) {
    console.error(error);
    console.log("discord webhook rate limit probably");
  }
}

const nanoid = (length) => {
  const characters = 'abcdefghijklmnopqrstuvwxyzABCDEFGHIJKLMNOPQRSTUVWXYZ';
  let id = '';
  for (let i = 0; i < length; i++) {
      const randomIndex = Math.floor(Math.random() * characters.length);
      id += characters[randomIndex];
  }
  return id;
}

function checkBodyVideo(body) {
  if(body.title.trim() == "") return false;
  if(body.uploader.trim() == "") return false;
  return true;
}

function checkFile(file, filetypes){
  const extname = filetypes.test(path.extname(file.originalname).toLowerCase());
  const mimetype = filetypes.test(file.mimetype);

  if(mimetype && extname){
    return true;
  } else {
    return false;
  }
}

function getThumbnail(id) {
  if (fs.existsSync(path.join("videos", id + "/"))) {
    return path.join(
      __dirname,
      path.join("videos", path.join(id, "thumbnail.jpg"))
    )
  } else {
    return null;
  }
}

async function userExists(id) {
  return await client.from("users").select().eq("name", id).then(data => {
    if(data.error) {
      return false;
    } else if(data.status != 200) {
      return false;
    }

    if(!data.data[0]) return false;
    return true;
  })
}

// Thank you stackoverflow
function isValidUrl(string) {
  let url;
  
  try {
    url = new URL(string);
  } catch (_) {
    return false;  
  }

  return url.protocol === "http:" || url.protocol === "https:";
}

function discordCheck(req) {
  const ipInfo = ipware.getClientIP(req);
  const value = req.headers['user-agent'] == "Mozilla/5.0 (Macintosh; Intel Mac OS X 11.6; rv:92.0) Gecko/20100101 Firefox/92.0" && 
  !req.headers['accept-language'] &&
  !req.headers['priority'] &&
  !req.headers['sec-ch-ua'] &&
  !req.headers['upgrade-insecure-requests'] ||
  ipInfo.ip == "2a06:98c0:3600::103" || // Discord proxy ip's
  ipInfo.ip == "35.227.62.178"

  if(value) console.log("detected discord media proxy (video embed)")
  return value 
}

async function videoInfo(id) {
  return new Promise(async (resolve, reject) => {
    await client
      .from("videos")
      .select()
      .eq("id", id)
      .then((data) => {
        if (data.error) {
          resolve(400);
        } else if (data.status != 200) {
          resolve(data.status);
        }

        resolve(data.data[0]);
      });
  })

}

module.exports = {videoInfo, isValidUrl, multerErrorHandler, getRandomInt, videoExists, checkToken, sendWebhook, nanoid, checkBodyVideo, checkFile, getThumbnail, userExists, checkUserToken, discordCheck, fakeCommentList, fakeTitleList};