neoris/openvidu
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

backend: Add CRON_JOB_MIN_LOCK_TTL to internal config and use it in task scheduler

Browse Source
This commit is contained in:
Carlos Santos 2025-04-15 11:15:06 +02:00
parent cdc55d25ba
commit dbef4f6e21
2 changed files with 3 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
backend/src/config/internal-config.ts
View File

@ -28,6 +28,7 @@ const INTERNAL_CONFIG = {
RECORDING_STARTED_TIMEOUT: '30s' as StringValue, // Timeout for recording start RECORDING_STARTED_TIMEOUT: '30s' as StringValue, // Timeout for recording start
RECORDING_LOCK_GC_INTERVAL: '30m' as StringValue, // Garbage collection interval for recording locks RECORDING_LOCK_GC_INTERVAL: '30m' as StringValue, // Garbage collection interval for recording locks
CRON_JOB_MIN_LOCK_TTL: '59s' as StringValue, // Minimum TTL for cron job locks
// Additional intervals // Additional intervals
MIN_FUTURE_TIME_FOR_ROOM_AUTODELETION_DATE: '1h' as StringValue MIN_FUTURE_TIME_FOR_ROOM_AUTODELETION_DATE: '1h' as StringValue
}; };

3
backend/src/services/task-scheduler.service.ts
View File

@ -5,6 +5,7 @@ import { CronJob } from 'cron';
import { MutexService } from './mutex.service.js'; import { MutexService } from './mutex.service.js';
import { MeetLock } from '../helpers/redis.helper.js'; import { MeetLock } from '../helpers/redis.helper.js';
import ms from 'ms'; import ms from 'ms';
import INTERNAL_CONFIG from '../config/internal-config.js';
export type TaskType = 'cron' | 'timeout'; export type TaskType = 'cron' | 'timeout';
@ -72,7 +73,7 @@ export class TaskSchedulerService {
if (type === 'cron') { if (type === 'cron') {
this.logger.debug(`Scheduling cron task "${name}" with schedule "${scheduleOrDelay}"`); this.logger.debug(`Scheduling cron task "${name}" with schedule "${scheduleOrDelay}"`);
const cronExpression = this.msStringToCronExpression(scheduleOrDelay); const cronExpression = this.msStringToCronExpression(scheduleOrDelay);
const lockDuration = Math.max(ms(scheduleOrDelay) - ms('1m'), ms('59s')); const lockDuration = Math.max(ms(scheduleOrDelay) - ms('1m'), ms(INTERNAL_CONFIG.CRON_JOB_MIN_LOCK_TTL));
const job = new CronJob(cronExpression, async () => { const job = new CronJob(cronExpression, async () => {
try { try {