You can not select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
115 lines
3.4 KiB
115 lines
3.4 KiB
import schedule from 'node-schedule';
|
|
import downloadTracker from '../lib/downloadtracker';
|
|
import { plexFullScanner, plexRecentScanner } from '../lib/scanners/plex';
|
|
import { radarrScanner } from '../lib/scanners/radarr';
|
|
import { sonarrScanner } from '../lib/scanners/sonarr';
|
|
import type { JobId } from '../lib/settings';
|
|
import { getSettings } from '../lib/settings';
|
|
import logger from '../logger';
|
|
|
|
interface ScheduledJob {
|
|
id: JobId;
|
|
job: schedule.Job;
|
|
name: string;
|
|
type: 'process' | 'command';
|
|
interval: 'short' | 'long' | 'fixed';
|
|
running?: () => boolean;
|
|
cancelFn?: () => void;
|
|
}
|
|
|
|
export const scheduledJobs: ScheduledJob[] = [];
|
|
|
|
export const startJobs = (): void => {
|
|
const jobs = getSettings().jobs;
|
|
|
|
// Run recently added plex scan every 5 minutes
|
|
scheduledJobs.push({
|
|
id: 'plex-recently-added-scan',
|
|
name: 'Plex Recently Added Scan',
|
|
type: 'process',
|
|
interval: 'short',
|
|
job: schedule.scheduleJob(jobs['plex-recently-added-scan'].schedule, () => {
|
|
logger.info('Starting scheduled job: Plex Recently Added Scan', {
|
|
label: 'Jobs',
|
|
});
|
|
plexRecentScanner.run();
|
|
}),
|
|
running: () => plexRecentScanner.status().running,
|
|
cancelFn: () => plexRecentScanner.cancel(),
|
|
});
|
|
|
|
// Run full plex scan every 24 hours
|
|
scheduledJobs.push({
|
|
id: 'plex-full-scan',
|
|
name: 'Plex Full Library Scan',
|
|
type: 'process',
|
|
interval: 'long',
|
|
job: schedule.scheduleJob(jobs['plex-full-scan'].schedule, () => {
|
|
logger.info('Starting scheduled job: Plex Full Library Scan', {
|
|
label: 'Jobs',
|
|
});
|
|
plexFullScanner.run();
|
|
}),
|
|
running: () => plexFullScanner.status().running,
|
|
cancelFn: () => plexFullScanner.cancel(),
|
|
});
|
|
|
|
// Run full radarr scan every 24 hours
|
|
scheduledJobs.push({
|
|
id: 'radarr-scan',
|
|
name: 'Radarr Scan',
|
|
type: 'process',
|
|
interval: 'long',
|
|
job: schedule.scheduleJob(jobs['radarr-scan'].schedule, () => {
|
|
logger.info('Starting scheduled job: Radarr Scan', { label: 'Jobs' });
|
|
radarrScanner.run();
|
|
}),
|
|
running: () => radarrScanner.status().running,
|
|
cancelFn: () => radarrScanner.cancel(),
|
|
});
|
|
|
|
// Run full sonarr scan every 24 hours
|
|
scheduledJobs.push({
|
|
id: 'sonarr-scan',
|
|
name: 'Sonarr Scan',
|
|
type: 'process',
|
|
interval: 'long',
|
|
job: schedule.scheduleJob(jobs['sonarr-scan'].schedule, () => {
|
|
logger.info('Starting scheduled job: Sonarr Scan', { label: 'Jobs' });
|
|
sonarrScanner.run();
|
|
}),
|
|
running: () => sonarrScanner.status().running,
|
|
cancelFn: () => sonarrScanner.cancel(),
|
|
});
|
|
|
|
// Run download sync every minute
|
|
scheduledJobs.push({
|
|
id: 'download-sync',
|
|
name: 'Download Sync',
|
|
type: 'command',
|
|
interval: 'fixed',
|
|
job: schedule.scheduleJob(jobs['download-sync'].schedule, () => {
|
|
logger.debug('Starting scheduled job: Download Sync', {
|
|
label: 'Jobs',
|
|
});
|
|
downloadTracker.updateDownloads();
|
|
}),
|
|
});
|
|
|
|
// Reset download sync everyday at 01:00 am
|
|
scheduledJobs.push({
|
|
id: 'download-sync-reset',
|
|
name: 'Download Sync Reset',
|
|
type: 'command',
|
|
interval: 'long',
|
|
job: schedule.scheduleJob(jobs['download-sync-reset'].schedule, () => {
|
|
logger.info('Starting scheduled job: Download Sync Reset', {
|
|
label: 'Jobs',
|
|
});
|
|
downloadTracker.resetDownloadTracker();
|
|
}),
|
|
});
|
|
|
|
logger.info('Scheduled jobs loaded', { label: 'Jobs' });
|
|
};
|