feat: add USERS_ONLINE_STATS metric for tracking distinct online user statistics

Author: kastov

libs/contract/constants/metrics/metric-names.constant.ts

@@ -2,6 +2,7 @@ export const METRIC_NAMES = {
     NODE_ONLINE_USERS: 'node_online_users',
     NODE_STATUS: 'node_status',
     USERS_STATUS: 'users_status',
+    USERS_ONLINE_STATS: 'users_online_stats',
     USERS_TOTAL: 'users_total',
     NODE_INBOUND_UPLOAD_BYTES: 'node_inbound_upload_bytes',
     NODE_INBOUND_DOWNLOAD_BYTES: 'node_inbound_download_bytes',

src/scheduler/metrics-providers.ts

@@ -18,6 +18,11 @@ export const METRIC_PROVIDERS = [
         help: 'Counter for users statuses, updated every 1 minute',
         labelNames: ['status'],
     }),
+    makeGaugeProvider({
+        name: METRIC_NAMES.USERS_ONLINE_STATS,
+        help: 'Counter for online stats of distinct users, updated every 1 minute',
+        labelNames: ['metricType'],
+    }),
     makeGaugeProvider({
         name: METRIC_NAMES.USERS_TOTAL,
         help: 'Total number of users, updated every 1 minute',

src/scheduler/tasks/export-metrics/export-metrics.task.ts

@@ -60,6 +60,7 @@ export class ExportMetricsTask {
 
     constructor(
         @InjectMetric(METRIC_NAMES.USERS_STATUS) public usersStatus: Gauge<string>,
+        @InjectMetric(METRIC_NAMES.USERS_ONLINE_STATS) public usersOnlineStats: Gauge<string>,
         @InjectMetric(METRIC_NAMES.USERS_TOTAL) public usersTotal: Gauge<string>,
         @InjectMetric(METRIC_NAMES.NODE_ONLINE_USERS) public nodeOnlineUsers: Gauge<string>,
         @InjectMetric(METRIC_NAMES.NODE_STATUS) public nodeStatus: Gauge<string>,
@@ -141,6 +142,10 @@ export class ExportMetricsTask {
                     this.usersStatus.set({ status }, count);
                 });
 
+                Object.entries(stats.onlineStats).forEach(([metricType, value]) => {
+                    this.usersOnlineStats.set({ metricType }, value);
+                });
+
                 this.usersTotal.set({ type: 'all' }, stats.statusCounts.totalUsers);
 
                 // this.logger.debug(