FM / scripts

/home/techb158/cosmic-risk.abdallabala.com/scripts/

/home/techb158/cosmic-risk.abdallabala.com/scripts

Name	Size	Mode	Actions
auto-deploy.sh	2145	0644	edit dl rm
backup-db.sh	1103	0644	edit dl rm
check-config.js	1081	0644	edit dl rm
create-users.js	1728	0644	edit dl rm
deploy-prod.sh	2709	0644	edit dl rm
monitor-health.sh	1485	0644	edit dl rm
run-scheduled-reports.js	1724	0644	edit dl rm
setup-backup-cron.sh	1189	0644	edit dl rm
setup-monitoring-cron.sh	592	0644	edit dl rm
setup-supabase.sh	1280	0644	edit dl rm

Edit: /home/techb158/cosmic-risk.abdallabala.com/scripts/run-scheduled-reports.js (1724B)

const { PrismaClient } = require("@prisma/client");
const { getReport } = require("../src/services/reporting-service");
const { sendEmail } = require("../src/lib/email");

const prisma = new PrismaClient();

async function run() {
  const now = new Date();
  const due = await prisma.scheduledReport.findMany({
    where: { enabled: true, nextRunAt: { lte: now } },
    include: { project: true }
  });

for (const schedule of due) {
    try {
      const report = await getReport(schedule.projectId, schedule.reportType);
      const recipients = schedule.recipients;
      if (recipients.length > 0 && report) {
        for (const email of recipients) {
          await sendEmail({
            to: email,
            subject: `Scheduled Report: ${schedule.project.name} - ${schedule.reportType}`,
            text: `Attached is your scheduled report for ${schedule.project.name}.`,
            attachments: report.contentType.includes("csv")
              ? [{ filename: schedule.reportType, content: report.body }]
              : undefined
          });
        }
      }

const intervalMap = { "0 8 * * 1": 7, "0 8 * * *": 1, "0 8 1 * *": 30 };
      const days = intervalMap[schedule.cronExpr] || 7;
      const nextRun = new Date(now.getTime() + days * 86400000);

await prisma.scheduledReport.update({
        where: { id: schedule.id },
        data: { lastRunAt: now, nextRunAt: nextRun }
      });
      console.log(`Report sent: ${schedule.id} (${schedule.project.name})`);
    } catch (error) {
      console.error(`Failed to run schedule ${schedule.id}:`, error.message);
    }
  }

await prisma.$disconnect();
}

run().catch(error => {
  console.error("Fatal:", error);
  process.exit(1);
});

const { PrismaClient } = require("@prisma/client"); const { getReport } = require("../src/services/reporting-service"); const { sendEmail } = require("../src/lib/email"); const prisma = new PrismaClient(); async function run() { const now = new Date(); const due = await prisma.scheduledReport.findMany({ where: { enabled: true, nextRunAt: { lte: now } }, include: { project: true } }); for (const schedule of due) { try { const report = await getReport(schedule.projectId, schedule.reportType); const recipients = schedule.recipients; if (recipients.length > 0 && report) { for (const email of recipients) { await sendEmail({ to: email, subject: `Scheduled Report: ${schedule.project.name} - ${schedule.reportType}`, text: `Attached is your scheduled report for ${schedule.project.name}.`, attachments: report.contentType.includes("csv") ? [{ filename: schedule.reportType, content: report.body }] : undefined }); } } const intervalMap = { "0 8 * * 1": 7, "0 8 * * *": 1, "0 8 1 * *": 30 }; const days = intervalMap[schedule.cronExpr] || 7; const nextRun = new Date(now.getTime() + days * 86400000); await prisma.scheduledReport.update({ where: { id: schedule.id }, data: { lastRunAt: now, nextRunAt: nextRun } }); console.log(`Report sent: ${schedule.id} (${schedule.project.name})`); } catch (error) { console.error(`Failed to run schedule ${schedule.id}:`, error.message); } } await prisma.$disconnect(); } run().catch(error => { console.error("Fatal:", error); process.exit(1); });