All files / src/routes digest.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
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
/**
 * Routes Digest Email — Configuration du resume periodique par email.
 *
 * Permet a l'utilisateur d'activer/configurer son digest quotidien ou hebdomadaire.
 *
 * Endpoints :
 *   GET    /digest       — Lire la config digest de l'utilisateur
 *   PATCH  /digest       — Activer/modifier la config digest
 *
 * @module routes/digest
 */
 
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);
 
// Frequences autorisees
const FREQUENCIES = ['daily', 'weekly'];
 
// ─── GET /digest ─────────────────────────────────────────────────────────────
 
router.get('/', async (req, res, next) => {
  try {
    const { rows } = await db.query(
      `SELECT digest_enabled, digest_frequency, digest_hour
       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].digest_enabled || false,
      frequency: rows[0].digest_frequency || 'daily',
      hour: rows[0].digest_hour ?? 8,
    });
  } catch (err) {
    next(err);
  }
});
 
// ─── PATCH /digest ───────────────────────────────────────────────────────────
 
router.patch('/', requireFeature('email_digest'), async (req, res, next) => {
  try {
    const { enabled, frequency, hour } = req.body;
 
    // Validation
    if (enabled !== undefined && typeof enabled !== 'boolean') {
      return res.status(400).json({ error: 'Le champ enabled doit etre un booleen.' });
    }
    if (frequency !== undefined && !FREQUENCIES.includes(frequency)) {
      return res.status(400).json({
        error: `Frequence invalide. Valeurs acceptees : ${FREQUENCIES.join(', ')}`,
      });
    }
    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(`digest_enabled = $${idx++}`); values.push(enabled); }
    if (frequency !== undefined) { fields.push(`digest_frequency = $${idx++}`); values.push(frequency); }
    if (hour !== undefined) { fields.push(`digest_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 digest_enabled, digest_frequency, digest_hour`,
      values,
    );
 
    res.json({
      enabled: rows[0].digest_enabled,
      frequency: rows[0].digest_frequency,
      hour: rows[0].digest_hour,
    });
  } catch (err) {
    next(err);
  }
});
 
module.exports = router;