Feat: add VisualDataSubsystem

Author: yumao233

src/app.ts

@@ -51,6 +51,7 @@ import InstanceSubsystem from "./service/system_instance";
 import { initDependent } from "./service/install";
 import "./service/async_task_service";
 import "./service/async_task_service/quick_install";
+import "./service/system_visual_data";
 
 // Initialize HTTP service
 const koaApp = koa.initKoa();

src/routers/info_router.ts

@@ -12,6 +12,7 @@ import i18next from "i18next";
 import logger from "../service/log";
 import fs from "fs-extra";
 import { LOCAL_PRESET_LANG_PATH } from "../const";
+import VisualDataSubsystem from "../service/system_visual_data";
 
 // Get the basic information of the daemon system
 routerApp.on("info/overview", async (ctx) => {
@@ -33,7 +34,8 @@ routerApp.on("info/overview", async (ctx) => {
       running,
       total
     },
-    system: systemInfo()
+    system: systemInfo(),
+    cpuMemChart: VisualDataSubsystem.getSystemChartArray()
   };
   protocol.response(ctx, info);
 });

src/service/system_visual_data.ts

@@ -0,0 +1,87 @@
+// Copyright (C) 2023 MCSManager <[email protected]>
+
+import { systemInfo } from "../common/system_info";
+
+// Visual data subsystem: responsible for collecting system data and event data, and providing some methods to display them
+class LineQueue<T> {
+  private readonly arr = new Array<T>();
+
+  constructor(public readonly maxSize: number, defaultValue?: T) {
+    for (let index = 0; index < maxSize; index++) {
+      this.arr.push(defaultValue);
+    }
+  }
+
+  push(data: T) {
+    if (this.arr.length < this.maxSize) {
+      this.arr.push(data);
+    } else {
+      this.arr.shift();
+      this.arr.push(data);
+    }
+  }
+
+  getArray() {
+    return this.arr;
+  }
+}
+
+interface ISystemChartInfo {
+  cpu: number;
+  mem: number;
+}
+
+class VisualDataSubsystem {
+  public readonly countMap: Map<string, number> = new Map<string, number>();
+
+  public readonly systemChart = new LineQueue<ISystemChartInfo>(60, { cpu: 0, mem: 0 });
+
+  private requestCount = 0;
+
+  constructor() {
+    setInterval(() => {
+      const info = systemInfo();
+      if (info) {
+        this.systemChart.push({
+          cpu: Number((info.cpuUsage * 100).toFixed(0)),
+          mem: Number((info.memUsage * 100).toFixed(0))
+        });
+      } else {
+        this.systemChart.push({
+          cpu: 0,
+          mem: 0
+        });
+      }
+    }, 1000 * 10);
+  }
+
+  addRequestCount() {
+    this.requestCount++;
+  }
+
+  getSystemChartArray() {
+    return this.systemChart.getArray();
+  }
+
+  // Trigger counting event
+  emitCountEvent(eventName: string) {
+    const v = this.countMap.get(eventName);
+    if (v) {
+      this.countMap.set(eventName, v + 1);
+    } else {
+      this.countMap.set(eventName, 1);
+    }
+  }
+
+  // Trigger counting event
+  eventCount(eventName: string) {
+    return this.countMap.get(eventName);
+  }
+
+  // Trigger log event
+  emitLogEvent(eventName: string, source: any) {
+    const time = new Date().toLocaleString();
+  }
+}
+
+export default new VisualDataSubsystem();