File size: 2,205 Bytes
f5957a1
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
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
import { Injectable, Logger } from '@nestjs/common';
import { InjectRepository } from '@nestjs/typeorm';
import { Repository } from 'typeorm';
import { ServerMonitoring } from '../entities/server-monitoring.entity';
import * as os from 'os';

@Injectable()
export class MonitoringService {
  private readonly logger = new Logger(MonitoringService.name);

  constructor(
    @InjectRepository(ServerMonitoring)
    private serverRepo: Repository<ServerMonitoring>,
  ) {}

  async getServers() {
    const data = await this.serverRepo.find({
      order: { checkedAt: 'DESC' },
    });
    return { data };
  }

  async getHealth() {
    const cpus = os.cpus();
    const totalMem = os.totalmem();
    const freeMem = os.freemem();
    const uptime = os.uptime();

    // Calculate CPU usage average
    let totalIdle = 0;
    let totalTick = 0;
    for (const cpu of cpus) {
      for (const type in cpu.times) {
        totalTick += cpu.times[type];
      }
      totalIdle += cpu.times.idle;
    }
    const cpuUsage = ((1 - totalIdle / totalTick) * 100).toFixed(2);
    const memoryUsage = (((totalMem - freeMem) / totalMem) * 100).toFixed(2);

    return {
      data: {
        hostname: os.hostname(),
        platform: os.platform(),
        arch: os.arch(),
        cpuCount: cpus.length,
        cpuUsage: parseFloat(cpuUsage),
        totalMemoryMB: Math.round(totalMem / 1024 / 1024),
        freeMemoryMB: Math.round(freeMem / 1024 / 1024),
        memoryUsage: parseFloat(memoryUsage),
        uptimeSeconds: uptime,
        uptimeFormatted: this.formatUptime(uptime),
        nodeVersion: process.version,
      },
    };
  }

  async getMetrics() {
    const health = await this.getHealth();
    const latestRecords = await this.serverRepo
      .createQueryBuilder('sm')
      .orderBy('sm.checked_at', 'DESC')
      .limit(50)
      .getMany();

    return {
      data: {
        current: health.data,
        history: latestRecords,
      },
    };
  }

  private formatUptime(seconds: number): string {
    const d = Math.floor(seconds / 86400);
    const h = Math.floor((seconds % 86400) / 3600);
    const m = Math.floor((seconds % 3600) / 60);
    return `${d}d ${h}h ${m}m`;
  }
}