removed the cron jobs
This commit is contained in:
@@ -1,57 +0,0 @@
|
|||||||
const cron = require("node-cron");
|
|
||||||
const PayoutService = require("../services/payoutService");
|
|
||||||
|
|
||||||
// Daily retry job for failed payouts (hourly job removed - payouts are now triggered immediately on completion)
|
|
||||||
const retrySchedule = "0 7 * * *"; // Retry failed payouts once daily at 7 AM
|
|
||||||
|
|
||||||
class PayoutProcessor {
|
|
||||||
static startScheduledPayouts() {
|
|
||||||
console.log("Starting payout retry processor...");
|
|
||||||
|
|
||||||
const retryJob = cron.schedule(
|
|
||||||
retrySchedule,
|
|
||||||
async () => {
|
|
||||||
console.log("Running failed payout retry process...");
|
|
||||||
|
|
||||||
try {
|
|
||||||
const results = await PayoutService.retryFailedPayouts();
|
|
||||||
|
|
||||||
if (results.totalProcessed > 0) {
|
|
||||||
console.log(
|
|
||||||
`Retry batch completed: ${results.successful.length} successful, ${results.failed.length} still failed`
|
|
||||||
);
|
|
||||||
}
|
|
||||||
} catch (error) {
|
|
||||||
console.error("Error in retry payout processing:", error);
|
|
||||||
}
|
|
||||||
},
|
|
||||||
{
|
|
||||||
scheduled: false,
|
|
||||||
timezone: "America/New_York",
|
|
||||||
}
|
|
||||||
);
|
|
||||||
|
|
||||||
// Start the job
|
|
||||||
retryJob.start();
|
|
||||||
|
|
||||||
console.log("Payout processor jobs scheduled:");
|
|
||||||
console.log("- Daily retry processing: " + retrySchedule);
|
|
||||||
|
|
||||||
return {
|
|
||||||
retryJob,
|
|
||||||
|
|
||||||
stop() {
|
|
||||||
retryJob.stop();
|
|
||||||
console.log("Payout processor jobs stopped");
|
|
||||||
},
|
|
||||||
|
|
||||||
getStatus() {
|
|
||||||
return {
|
|
||||||
retryJobRunning: retryJob.getStatus() === "scheduled",
|
|
||||||
};
|
|
||||||
},
|
|
||||||
};
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
module.exports = PayoutProcessor;
|
|
||||||
22
backend/package-lock.json
generated
22
backend/package-lock.json
generated
@@ -30,7 +30,6 @@
|
|||||||
"jsdom": "^27.0.0",
|
"jsdom": "^27.0.0",
|
||||||
"jsonwebtoken": "^9.0.2",
|
"jsonwebtoken": "^9.0.2",
|
||||||
"morgan": "^1.10.1",
|
"morgan": "^1.10.1",
|
||||||
"node-cron": "^3.0.3",
|
|
||||||
"pg": "^8.16.3",
|
"pg": "^8.16.3",
|
||||||
"sequelize": "^6.37.7",
|
"sequelize": "^6.37.7",
|
||||||
"sequelize-cli": "^6.6.3",
|
"sequelize-cli": "^6.6.3",
|
||||||
@@ -9510,27 +9509,6 @@
|
|||||||
"node": ">= 0.6"
|
"node": ">= 0.6"
|
||||||
}
|
}
|
||||||
},
|
},
|
||||||
"node_modules/node-cron": {
|
|
||||||
"version": "3.0.3",
|
|
||||||
"resolved": "https://registry.npmjs.org/node-cron/-/node-cron-3.0.3.tgz",
|
|
||||||
"integrity": "sha512-dOal67//nohNgYWb+nWmg5dkFdIwDm8EpeGYMekPMrngV3637lqnX0lbUcCtgibHTz6SEz7DAIjKvKDFYCnO1A==",
|
|
||||||
"license": "ISC",
|
|
||||||
"dependencies": {
|
|
||||||
"uuid": "8.3.2"
|
|
||||||
},
|
|
||||||
"engines": {
|
|
||||||
"node": ">=6.0.0"
|
|
||||||
}
|
|
||||||
},
|
|
||||||
"node_modules/node-cron/node_modules/uuid": {
|
|
||||||
"version": "8.3.2",
|
|
||||||
"resolved": "https://registry.npmjs.org/uuid/-/uuid-8.3.2.tgz",
|
|
||||||
"integrity": "sha512-+NYs2QeMWy+GWFOEm9xnn6HCDp0l7QBD7ml8zLUmJ+93Q5NF0NocErnwkTkXVFNiX3/fpC6afS8Dhb/gz7R7eg==",
|
|
||||||
"license": "MIT",
|
|
||||||
"bin": {
|
|
||||||
"uuid": "dist/bin/uuid"
|
|
||||||
}
|
|
||||||
},
|
|
||||||
"node_modules/node-domexception": {
|
"node_modules/node-domexception": {
|
||||||
"version": "1.0.0",
|
"version": "1.0.0",
|
||||||
"resolved": "https://registry.npmjs.org/node-domexception/-/node-domexception-1.0.0.tgz",
|
"resolved": "https://registry.npmjs.org/node-domexception/-/node-domexception-1.0.0.tgz",
|
||||||
|
|||||||
@@ -55,7 +55,6 @@
|
|||||||
"jsdom": "^27.0.0",
|
"jsdom": "^27.0.0",
|
||||||
"jsonwebtoken": "^9.0.2",
|
"jsonwebtoken": "^9.0.2",
|
||||||
"morgan": "^1.10.1",
|
"morgan": "^1.10.1",
|
||||||
"node-cron": "^3.0.3",
|
|
||||||
"pg": "^8.16.3",
|
"pg": "^8.16.3",
|
||||||
"sequelize": "^6.37.7",
|
"sequelize": "^6.37.7",
|
||||||
"sequelize-cli": "^6.6.3",
|
"sequelize-cli": "^6.6.3",
|
||||||
|
|||||||
Reference in New Issue
Block a user