Stellar-MicroPay/backend/src/controllers/analyticsController.js at main · OpenSourceCOntr/Stellar-MicroPay · GitHub

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
/**
 * src/controllers/analyticsController.js
 * Handles analytics endpoints for transaction volume insights.
 */

"use strict";

const analyticsService = require("../services/analyticsService");

/**
 * GET /api/analytics/:publicKey/summary
 * Returns: total sent, received, unique counterparties, avg transaction size.
 */
async function getSummary(req, res, next) {
  try {
    const { publicKey } = req.params;
    const data = await analyticsService.getSummary(publicKey);
    res.json({ success: true, data });
  } catch (err) {
    next(err);
  }
}

/**
 * GET /api/analytics/:publicKey/top-recipients
 * Returns: top 5 addresses by total XLM sent.
 */
async function getTopRecipients(req, res, next) {
  try {
    const { publicKey } = req.params;
    const data = await analyticsService.getTopRecipients(publicKey);
    res.json({ success: true, data });
  } catch (err) {
    next(err);
  }
}

/**
 * GET /api/analytics/:publicKey/activity
 * Returns: payment count by day of week (all 7 days).
 */
async function getActivityByDay(req, res, next) {
  try {
    const { publicKey } = req.params;
    const data = await analyticsService.getActivityByDay(publicKey);
    res.json({ success: true, data });
  } catch (err) {
    next(err);
  }
}

/**
 * POST /api/analytics/:publicKey/export-schedule
 * Set up recurring email export.
 */
async function scheduleExport(req, res, next) {
  try {
    const { publicKey } = req.params;
    const { email, frequency } = req.body;
    const data = analyticsService.scheduleExport(publicKey, email, frequency);
    res.status(201).json({ success: true, data, message: "Recurring export scheduled successfully" });
  } catch (err) {
    next(err);
  }
}

/**
 * GET /api/analytics/:publicKey/export-schedule
 * Get scheduled export configuration.
 */
async function getExportSchedule(req, res, next) {
  try {
    const { publicKey } = req.params;
    const data = analyticsService.getExportSchedule(publicKey);
    res.json({ success: true, data });
  } catch (err) {
    next(err);
  }
}

/**
 * POST /api/analytics/:publicKey/export-trigger
 * Manually trigger sending export email.
 */
async function triggerExport(req, res, next) {
  try {
    const { publicKey } = req.params;
    const data = await analyticsService.triggerEmailExport(publicKey);
    res.json({ success: true, data, message: "Export email sent" });
  } catch (err) {
    next(err);
  }
}

module.exports = {
  getSummary,
  getTopRecipients,
  getActivityByDay,
  scheduleExport,
  getExportSchedule,
  triggerExport,
};