Andreas/wekan
1
0
Fork 0
mirror of https://github.com/wekan/wekan.git synced 2026-03-04 04:40:16 +01:00
Code Issues Projects Releases Packages Wiki Activity Actions 1

Migrate from percolate:synced-cron to quave:synced-cron

Browse source
This commit is contained in:
Harry Adel 2026-01-20 17:56:52 +02:00
parent 997b9a7c76
commit 526251397e
7 changed files with 35 additions and 16 deletions
Download patch file Download diff file Expand all files Collapse all files

37
server/cronMigrationManager.js
View file

@ -4,7 +4,7 @@
*/
import { Meteor } from 'meteor/meteor';
import { SyncedCron } from 'meteor/percolate:synced-cron';
import { SyncedCron } from 'meteor/quave:synced-cron';
import { ReactiveVar } from 'meteor/reactive-var';
import { cronJobStorage } from './cronJobStorage';
@ -28,6 +28,7 @@ class CronMigrationManager {
this.isRunning = false;
this.jobProcessor = null;
this.processingInterval = null;
this.pausedJobs = new Map(); // Store paused job configs for per-job pause/resume
}
/**
@ -797,7 +798,7 @@ class CronMigrationManager {
*/
async startCronJob(cronName) {
// Change schedule to run once
const job = SyncedCron.jobs.find(j => j.name === cronName);
const job = SyncedCron._entries?.[cronName];
if (job) {
job.schedule = 'once';
SyncedCron.start();
@ -832,9 +833,20 @@ class CronMigrationManager {
/**
* Pause a specific cron job
* Note: quave:synced-cron only has global pause(), so we implement per-job pause
* by storing the job config and removing it, then re-adding on resume.
*/
pauseCronJob(cronName) {
SyncedCron.pause(cronName);
const entry = SyncedCron._entries?.[cronName];
if (entry) {
// Store the job config before removing
this.pausedJobs.set(cronName, {
name: entry.name,
schedule: entry.schedule,
job: entry.job
});
SyncedCron.remove(cronName);
}
const step = this.migrationSteps.find(s => s.cronName === cronName);
if (step) {
step.status = 'paused';
@ -844,9 +856,15 @@ class CronMigrationManager {
/**
* Resume a specific cron job
* Note: quave:synced-cron doesn't have resume(), so we re-add the stored job config.
*/
resumeCronJob(cronName) {
SyncedCron.resume(cronName);
const pausedJob = this.pausedJobs.get(cronName);
if (pausedJob) {
SyncedCron.add(pausedJob);
this.pausedJobs.delete(cronName);
SyncedCron.start();
}
const step = this.migrationSteps.find(s => s.cronName === cronName);
if (step) {
step.status = 'running';
@ -902,14 +920,15 @@ class CronMigrationManager {
* Update cron jobs list
*/
updateCronJobsList() {
// Check if SyncedCron is available and has jobs
if (!SyncedCron || !SyncedCron.jobs || !Array.isArray(SyncedCron.jobs)) {
// Check if SyncedCron is available and has entries
const entries = SyncedCron?._entries;
if (!entries || typeof entries !== 'object') {
// SyncedCron not available or no jobs yet
cronJobs.set([]);
return;
}
const jobs = SyncedCron.jobs.map(job => {
const jobs = Object.values(entries).map(job => {
const step = this.migrationSteps.find(s => s.cronName === job.name);
return {
name: job.name,
@ -1332,8 +1351,8 @@ class CronMigrationManager {
clearAllCronJobs() {
try {
// Stop all existing cron jobs
if (SyncedCron && SyncedCron.jobs) {
SyncedCron.jobs.forEach(job => {
if (SyncedCron?._entries) {
Object.values(SyncedCron._entries).forEach(job => {
try {
SyncedCron.remove(job.name);
} catch (error) {