diff --git a/backend/jobs/payoutProcessor.js b/backend/jobs/payoutProcessor.js deleted file mode 100644 index 6930f1a..0000000 --- a/backend/jobs/payoutProcessor.js +++ /dev/null @@ -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; diff --git a/backend/package-lock.json b/backend/package-lock.json index dec37a5..5714016 100644 --- a/backend/package-lock.json +++ b/backend/package-lock.json @@ -30,7 +30,6 @@ "jsdom": "^27.0.0", "jsonwebtoken": "^9.0.2", "morgan": "^1.10.1", - "node-cron": "^3.0.3", "pg": "^8.16.3", "sequelize": "^6.37.7", "sequelize-cli": "^6.6.3", @@ -9510,27 +9509,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": { "version": "1.0.0", "resolved": "https://registry.npmjs.org/node-domexception/-/node-domexception-1.0.0.tgz", diff --git a/backend/package.json b/backend/package.json index a0a112d..fb70621 100644 --- a/backend/package.json +++ b/backend/package.json @@ -55,7 +55,6 @@ "jsdom": "^27.0.0", "jsonwebtoken": "^9.0.2", "morgan": "^1.10.1", - "node-cron": "^3.0.3", "pg": "^8.16.3", "sequelize": "^6.37.7", "sequelize-cli": "^6.6.3",