All files / src/routes report.js

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
/**
 * Routes Rapport Mensuel — Configuration du rapport PDF mensuel.
 *
 * Permet a l'utilisateur d'activer/configurer la generation mensuelle de rapport PDF.
 *
 * Endpoints :
 *   GET    /report       — Lire la config rapport
 *   PATCH  /report       — Activer/modifier la config rapport
 *   POST   /report/generate — Generer manuellement un rapport (preview)
 *
 * @module routes/report
 */
 
const express = require('express');
const { pool: db } = require('../db');
const { requireAuth } = require('../middleware/auth');
const { requireFeature } = require('../middleware/planLimits');
 
const router = express.Router();
 
router.use(requireAuth);
 
// ─── GET /report ─────────────────────────────────────────────────────────────
 
router.get('/', async (req, res, next) => {
  try {
    const { rows } = await db.query(
      `SELECT report_enabled, report_hour, report_last_sent
       FROM users WHERE id = $1`,
      [req.user.id],
    );
 
    if (rows.length === 0) {
      return res.status(404).json({ error: 'Utilisateur introuvable.' });
    }
 
    res.json({
      enabled: rows[0].report_enabled || false,
      hour: rows[0].report_hour ?? 8,
      lastSent: rows[0].report_last_sent || null,
    });
  } catch (err) {
    next(err);
  }
});
 
// ─── PATCH /report ───────────────────────────────────────────────────────────
 
router.patch('/', requireFeature('monthly_report'), async (req, res, next) => {
  try {
    const { enabled, hour } = req.body;
 
    // Validation
    if (enabled !== undefined && typeof enabled !== 'boolean') {
      return res.status(400).json({ error: 'Le champ enabled doit etre un booleen.' });
    }
    if (hour !== undefined) {
      const h = Number(hour);
      if (!Number.isInteger(h) || h < 0 || h > 23) {
        return res.status(400).json({ error: 'L\'heure doit etre un entier entre 0 et 23 (UTC).' });
      }
    }
 
    // Construire dynamiquement le SET
    const fields = [];
    const values = [];
    let idx = 1;
 
    if (enabled !== undefined) { fields.push(`report_enabled = $${idx++}`); values.push(enabled); }
    if (hour !== undefined) { fields.push(`report_hour = $${idx++}`); values.push(Number(hour)); }
 
    if (fields.length === 0) {
      return res.status(400).json({ error: 'Aucun champ a mettre a jour.' });
    }
 
    values.push(req.user.id);
    const { rows } = await db.query(
      `UPDATE users SET ${fields.join(', ')}
       WHERE id = $${idx}
       RETURNING report_enabled, report_hour, report_last_sent`,
      values,
    );
 
    res.json({
      enabled: rows[0].report_enabled,
      hour: rows[0].report_hour,
      lastSent: rows[0].report_last_sent,
    });
  } catch (err) {
    next(err);
  }
});
 
// ─── POST /report/generate — Generation manuelle ────────────────────────────
 
router.post('/generate', requireFeature('monthly_report'), async (req, res, next) => {
  try {
    const { sendReportForUser } = require('../services/reportScheduler');
 
    // Recuperer les infos utilisateur
    const { rows } = await db.query(
      'SELECT id, email, plan FROM users WHERE id = $1',
      [req.user.id],
    );
 
    if (rows.length === 0) {
      return res.status(404).json({ error: 'Utilisateur introuvable.' });
    }
 
    await sendReportForUser(rows[0]);
 
    res.json({ message: 'Rapport genere et envoye par email.' });
  } catch (err) {
    next(err);
  }
});
 
module.exports = router;