index.js

import { getVideos } from "./components/getVideos.js";
import { checkChanges } from "./components/checkVideos.js";
import {
	getNewestFile,
	writeVideosToFile,
	deleteOldFiles,
} from "./components/fileManager.js";
import { sendWebhookMessages } from "./components/webhookManager.js";
import fs from "fs";
import dotenv from "dotenv";
dotenv.config();
const TOKEN = process.env.TOKEN;
const CHANNEL_ID = "UCpB959t8iPrxQWj7G6n0ctQ"; // channel id for the channel 'SSSniperwolf' aka. An awful freebooter
const TMP_MAX = 10; // max number of files to keep in the .tmp folder

async function main() {
	console.log("Running function...");

	// wait until the clock minutes are 0 or 30
	// then get the videos and repeat
	let videos = await getVideos(CHANNEL_ID, TOKEN).catch((error) =>
		console.error(error)
	);
	if (!videos) {
		throw new Error("No videos found");
	}

	// create .tmp folder if it doesn't exist
	if (!fs.existsSync(".tmp")) {
		fs.mkdirSync(".tmp");
	}

	// if no files exist in the .tmp folder, skip the compare part
	let files = fs.readdirSync(".tmp");
	if (files.length == 0) {
		console.log("no files in .tmp folder");
		writeVideosToFile(videos);
		return;
	}

	// get's the newest file in the .tmp folder
	let youngestFile = getNewestFile();
	let old_videos = JSON.parse(fs.readFileSync(`.tmp/${youngestFile}`));

	// write videos to a new json file in a .tmp folder with the name `videos_{timstamp}.json`
	writeVideosToFile(videos);

	console.log(`comparing 'old' file: ${youngestFile}`);
	let changes = await checkChanges(videos, old_videos);

	// once the files reach a certain number, delete the oldest file
	deleteOldFiles(TMP_MAX);

	// add new change data to the changes.json file
	let changedArray = JSON.parse(fs.readFileSync("models/changes.json"));
	const removedVideos = changes.removed;
	const durationVideos = changes.duration;

	const newChanges = removedVideos.concat(durationVideos);
	sendWebhookMessages(newChanges);
	changedArray = changedArray.concat(newChanges);

	fs.writeFile(
		"models/changes.json",
		JSON.stringify(changedArray, null, 2),
		(err) => {
			if (err) throw err;
			console.log("Data written to file");
		}
	);
	scheduleFunction();
}

function scheduleFunction() {
	var now = new Date();
	var delay = 30 - (now.getMinutes() % 30); // minutes until next half hour mark
	delay = delay * 60 * 1000 - now.getSeconds() * 1000 - now.getMilliseconds(); // convert to milliseconds and subtract seconds and milliseconds already passed in the current minute
	console.log(`Waiting ${delay / 1000} seconds until next run...`);
	setTimeout(main, delay);
}

//scheduleFunction();
scheduleFunction();

// request count: 190
// plan, check every 30 minutes