pixies

1import * as pauseController from '../controller/pause.js';
2import * as config from '../controller/config.js';
3import schedule from 'node-schedule';
4import { isValidCron } from "cron-validator";
5import { CronExpressionParser } from "cron-parser";
6import { create as createSpeedtest } from './speedtest.js';
7
8let job;
9let currentCron;
10
11const calculateMaxDelay = (cron) => {
12    try {
13        const parser = CronExpressionParser.parse(cron);
14        const next1 = parser.next().getTime();
15        const next2 = parser.next().getTime();
16        const intervalMs = next2 - next1;
17        const intervalMinutes = intervalMs / 60000;
18
19        if (intervalMinutes <= 1) {
20            return 30 * 1000; // 30 seconds
21        } else if (intervalMinutes <= 30) {
22            return 2 * 60 * 1000; // 2 minutes
23        } else if (intervalMinutes <= 60) {
24            return 3 * 60 * 1000; // 3 minutes
25        } else {
26            return 5 * 60 * 1000; // 5 minutes
27        }
28    } catch {
29        return 2 * 60 * 1000; // Default to 2 minutes if parsing fails
30    }
31};
32
33const getRandomDelay = (cron) => {
34    const minDelay = 30 * 1000;
35    const maxDelay = calculateMaxDelay(cron);
36    return Math.floor(Math.random() * (maxDelay - minDelay + 1)) + minDelay;
37};
38
39export const startTimer = (cron) => {
40    if (!isValidCron(cron)) return;
41    currentCron = cron;
42    job = schedule.scheduleJob(cron, () => runTask());
43};
44
45export const runTask = async () => {
46    if (pauseController.currentState) {
47        console.warn("Speedtests currently paused. Trying again later...");
48        return;
49    }
50
51    const scheduleOffset = await config.getValue("scheduleOffset");
52    
53    if (scheduleOffset === "true" && currentCron) {
54        const delay = getRandomDelay(currentCron);
55        console.log(`Schedule offset enabled. Delaying speedtest by ${Math.round(delay / 1000)} seconds...`);
56        await new Promise(resolve => setTimeout(resolve, delay));
57
58        if (pauseController.currentState) {
59            console.warn("Speedtests paused during delay. Skipping this test...");
60            return;
61        }
62    }
63
64    await createSpeedtest("auto");
65};
66
67export const stopTimer = () => {
68    if (job !== undefined) {
69        job.cancel();
70        job = undefined;
71    }
72};
73
74export { job };