float.ts

import { initProm } from "./lib/prometheus.js";
import { quickStart, validatePlexSettings } from "./quickStart.js";
import { settings, fApi, args, DownloaderVersion } from "./lib/helpers/index.js";
import { fetchFFMPEG } from "./lib/helpers/fetchFFMPEG.js";
import { defaultSettings } from "./lib/defaults.js";

import { loginFloatplane, User } from "./logins.js";
import chalk from "chalk-template";

import type { ContentPost } from "floatplane/content";
import { fetchSubscriptions } from "./subscriptionFetching.js";

import semver from "semver";
const { gt, diff } = semver;

import { Self } from "floatplane/user";

async function* seekAndDestroy(): AsyncGenerator<ContentPost, void, unknown> {
	while (settings.floatplane.seekAndDestroy.length > 0) {
		const guid = settings.floatplane.seekAndDestroy.pop();
		if (guid === undefined) continue;
		console.log(chalk`Seek and Destroy: {red ${guid}}`);
		yield fApi.content.post(guid);
	}
}

/**
 * Main function that triggeres everything else in the script
 */
const downloadNewVideos = async () => {
	const userSubs = fetchSubscriptions();
	const inProgress = [];
	for await (const contentPost of seekAndDestroy()) {
		for await (const subscription of userSubs) {
			if (contentPost.creator.id === subscription.creatorId) {
				for await (const video of subscription.seekAndDestroy(contentPost)) inProgress.push(video.download());
			}
		}
	}

	for await (const subscription of userSubs) {
		await subscription.deleteOldVideos();
		for await (const video of subscription.fetchNewVideos()) inProgress.push(video.download());
	}

	await Promise.all(inProgress);

	// Enforce search limits after searching once.
	settings.floatplane.videosToSearch = defaultSettings.floatplane.videosToSearch;

	if (settings.floatplane.waitForNewVideos === true) {
		console.log(`Checking for new videos in 5 minutes...`);
		setTimeout(downloadNewVideos, 5 * 60 * 1000);
	}
};

// Fix for docker
process.on("SIGTERM", () => process.exit(143));

(async () => {
	if (!args.headless) {
		console.log(chalk`\n{red ///}{grey ===} {cyan Console} {grey ===}{red \\\\\\}`);
	}

	if (args.updateCheck) {
		const latest = await fApi
			.got("https://raw.githubusercontent.com/Inrixia/Floatplane-Downloader/master/package.json")
			.json<{ version: string }>()
			.catch(() => ({ version: DownloaderVersion }));

		if (gt(latest.version, DownloaderVersion))
			console.log(
				chalk`There is a ${diff(latest.version, DownloaderVersion)} update available! ${DownloaderVersion} > ${
					latest.version
				}.\nHead to {cyanBright https://github.com/Inrixia/Floatplane-Downloader/releases} to update!\n`,
			);
	}

	if (args.sanityCheck) {
		console.log("Sanity check passed!");
		process.exit(0);
	}

	// Earlybird functions, these are run before script start and not run again if script repeating is enabled.
	await fetchFFMPEG();
	if (settings.runQuickstartPrompts) {
		if (args.headless) console.log("headless is set to true! Skipping quickstart prompts.");
		else await quickStart();
	}
	settings.runQuickstartPrompts = false;

	// Get Plex details if not saved
	await validatePlexSettings();

	// Get Floatplane credentials if not saved
	let user: Self | User;
	try {
		user = await fApi.user.self();
	} catch (err) {
		console.log(`Unable to authenticate with floatplane... ${(<Error>err).message}\nPlease login to floatplane...`);
		user = await loginFloatplane();
	}
	await initProm(user!.id);

	console.log(chalk`Initalized! Running version {cyan ${DownloaderVersion}} instance {magenta ${user!.id}}`);

	await downloadNewVideos();
})();