torrentProcessor.js

import { handleAddedTorrent } from "./handleAddedTorrent.js";
import { handleFinishedTorrent } from "./handleFinishedTorrent.js";
import { logMessage } from "./sharedFunctions.js";

// Initialize logging
const now = new Date();
const currentDateTime = now.toISOString(); // Gets the date and time in ISO format

await logMessage("\n\n");
await logMessage("--------" + currentDateTime + "--------\n");

// Command line arguments
const args = Deno.args;
const torrentName = args[0];
const category = args[1];
const tags = args[2];
const contentPath = args[3];
const rootPath = args[4];
const savePath = args[5];
const numberOfFiles = args[6];
const torrentSize = args[7];
const currentTracker = args[8];
const v1hash = args[9];
const v2hash = args[10];
const torrentId = args[11];
const programStatus = args[12];

await logMessage("Starting torrent processing with the following parameters:");
await logMessage(`torrentName: ${torrentName}`);
await logMessage(`category: ${category}`);
await logMessage(`tags: ${tags}`);
await logMessage(`contentPath: ${contentPath}`);
await logMessage(`rootPath: ${rootPath}`);
await logMessage(`savePath: ${savePath}`);
await logMessage(`numberOfFiles: ${numberOfFiles}`);
await logMessage(`torrentSize: ${torrentSize}`);
await logMessage(`currentTracker: ${currentTracker}`);
await logMessage(`v1hash: ${v1hash}`);
await logMessage(`v2hash: ${v2hash}`);
await logMessage(`torrentId: ${torrentId}`);
await logMessage(`programStatus: ${programStatus}`);
await logMessage("\n\n");

await logMessage(args);

// Process based on program status
switch (programStatus) {
    case "added":
        await logMessage("Processing added torrent");
        const addedSuccess = await handleAddedTorrent(torrentId);
        if (!addedSuccess) {
            await logMessage("Failed to process added torrent");
        }
        break;

    case "finished":
        await logMessage("Processing finished torrent");
        const finishedSuccess = await handleFinishedTorrent(torrentId, torrentName, contentPath);
        if (!finishedSuccess) {
            await logMessage("Failed to process finished torrent");
        }
        break;

    default:
        await logMessage("Nothing to do here");
        break;
}