automated bill payment

app.ts

@@ -12,6 +12,8 @@ import { upload } from './middleware/upload';
 import { uploadDocument } from './controllers/DocumentController';
 import { getDashboardData, generateReport, exportData } from './controllers/AnalyticsController';
 import { applyPaymentSecurity, processPayment, getPaymentHistory, validatePayment } from './controllers/PaymentController';
+import { createRecurring, listRecurring, cancelRecurring } from './controllers/RecurringController';
+import { paymentScheduler } from './services/PaymentScheduler';
 import { setupRateLimitRoutes } from './routes/rateLimitRoutes';
 
 const app = express();
@@ -136,6 +138,11 @@ app.post('/api/payment/process', ...applyPaymentSecurity, processPayment);
 app.get('/api/payment/history', apiKeyAuth, getPaymentHistory);
 app.post('/api/payment/validate', ...applyPaymentSecurity, validatePayment);
 
+// Recurring payment endpoints
+app.post('/api/recurring', authenticate, createRecurring);
+app.get('/api/recurring', authenticate, listRecurring);
+app.delete('/api/recurring/:id', authenticate, cancelRecurring);
+
 // Example protected route
 /**
  * @openapi
@@ -209,4 +216,11 @@ app.get('/api/analytics/export', apiKeyAuth, exportData);
 
 
 
-export default app;
+export default app;
+
+// Start background scheduler (cron) when the app module is loaded
+try {
+  paymentScheduler.start();
+} catch (err) {
+  console.error('Failed to start payment scheduler:', err);
+}

controllers/RecurringController.ts

@@ -0,0 +1,58 @@
+import { Request, Response } from 'express';
+import { recurringPaymentService } from '../services/RecurringPaymentService';
+
+export const createRecurring = async (req: Request, res: Response) => {
+  try {
+    const userId = (req as any).user?.id;
+    if (!userId) return res.status(401).json({ status: 401, error: 'Auth required' });
+
+    const { utilityId, billId, amount, cronExpression, startAt, maxRetries, baseRetryDelaySeconds } = req.body;
+
+    if (!amount || !cronExpression) {
+      return res.status(400).json({ status: 400, error: 'amount and cronExpression required' });
+    }
+
+    const rp = await recurringPaymentService.createRecurringPayment({
+      userId,
+      utilityId,
+      billId,
+      amount: Number(amount),
+      cronExpression,
+      startAt: startAt ? new Date(startAt) : undefined,
+      maxRetries,
+      baseRetryDelaySeconds
+    });
+
+    res.status(201).json({ status: 201, data: rp });
+  } catch (err) {
+    console.error('createRecurring error', err);
+    res.status(500).json({ status: 500, error: 'Failed to create recurring payment' });
+  }
+};
+
+export const cancelRecurring = async (req: Request, res: Response) => {
+  try {
+    const userId = (req as any).user?.id;
+    if (!userId) return res.status(401).json({ status: 401, error: 'Auth required' });
+
+    const id = req.params.id;
+    await recurringPaymentService.cancelRecurringPayment(id, userId);
+    res.status(200).json({ status: 200, message: 'Cancelled' });
+  } catch (err: any) {
+    console.error('cancelRecurring error', err);
+    res.status(500).json({ status: 500, error: err.message || 'Failed to cancel' });
+  }
+};
+
+export const listRecurring = async (req: Request, res: Response) => {
+  try {
+    const userId = (req as any).user?.id;
+    if (!userId) return res.status(401).json({ status: 401, error: 'Auth required' });
+
+    const list = await recurringPaymentService.listForUser(userId);
+    res.status(200).json({ status: 200, data: list });
+  } catch (err) {
+    console.error('listRecurring error', err);
+    res.status(500).json({ status: 500, error: 'Failed to list recurring payments' });
+  }
+};