✨ 日志定时清理逻辑

Author: CodFrm

src/app/repo/logger.ts

@@ -25,4 +25,8 @@ export class LoggerDAO extends DAO<Logger> {
 
     return ret.sort((a, b) => b.createtime - a.createtime);
   }
+
+  deleteBefore(time: number) {
+    return this.table.where("createtime").below(time).delete();
+  }
 }

src/app/service/system/manager.ts

@@ -6,6 +6,7 @@ import { ScriptDAO } from "@App/app/repo/scripts";
 import { SystemConfig } from "@App/pkg/config/config";
 import { prepareScriptByCode } from "@App/pkg/utils/script";
 import Logger from "@App/app/logger/logger";
+import { LoggerDAO } from "@App/app/repo/logger";
 import Manager from "../manager";
 import ScriptManager from "../script/manager";
 
@@ -20,11 +21,14 @@ export class SystemManager extends Manager {
 
   wsVscode?: WebSocket;
 
+  loggerDAO: LoggerDAO;
+
   constructor(message: MessageHander, systemConfig: SystemConfig) {
     super(message, "system");
     this.scriptDAO = new ScriptDAO();
     this.systemConfig = systemConfig;
     this.scriptManager = IoC.instance(ScriptManager) as ScriptManager;
+    this.loggerDAO = new LoggerDAO();
   }
 
   init() {
@@ -96,6 +100,9 @@ export class SystemManager extends Manager {
     this.listenEvent("connectVSCode", this.connectVSCode.bind(this));
 
     this.reconnectVSCode();
+
+    // 定时清理日志
+    this.clearLogger();
   }
 
   reconnectVSCode() {
@@ -189,6 +196,25 @@ export class SystemManager extends Manager {
       });
     });
   }
+
+  clearLogger() {
+    setInterval(() => {
+      // 取出上一次清理时间
+      chrome.storage.local.get(["lastClearLoggerTime"], (items) => {
+        const lastClearLoggerTime = items.lastClearLoggerTime || 0;
+        const now = new Date().getTime();
+        if (now - lastClearLoggerTime > 60 * 60 * 1000) {
+          chrome.storage.local.set({ lastClearLoggerTime: now });
+          // 清理7天前的日志
+          this.loggerDAO.deleteBefore(
+            new Date(
+              now - this.systemConfig.logCleanCycle * 24 * 60 * 60 * 1000
+            ).getTime()
+          );
+        }
+      });
+    }, 60 * 1000);
+  }
 }
 
 export default SystemManager;

src/pages/options/routes/Logger.tsx

@@ -16,6 +16,8 @@ import LogLabel, { Labels, Query } from "@App/pages/components/LogLabel";
 import { IconPlus } from "@arco-design/web-react/icon";
 import { useSearchParams } from "react-router-dom";
 import { formatUnixTime } from "@App/pkg/utils/utils";
+import { SystemConfig } from "@App/pkg/config/config";
+import IoC from "@App/app/ioc";
 
 function Subscribe() {
   const [labels, setLabels] = React.useState<Labels>({});
@@ -30,6 +32,7 @@ function Subscribe() {
   );
   const [endTime, setEndTime] = React.useState(dayjs().unix());
   const loggerDAO = new LoggerDAO();
+  const systemConfig = IoC.instance(SystemConfig) as SystemConfig;
 
   const onQueryLog = () => {
     const newQueryLogs: Logger[] = [];
@@ -262,6 +265,20 @@ function Subscribe() {
             title="日志"
             extra={
               <Space>
+                <Space>
+                  <span>定时清理</span>
+                  <Input
+                    defaultValue={systemConfig.logCleanCycle.toString()}
+                    style={{
+                      width: "60px",
+                    }}
+                    type="number"
+                    onChange={(e) => {
+                      systemConfig.logCleanCycle = parseInt(e, 10);
+                    }}
+                  />
+                  <span>天前的日志</span>
+                </Space>
                 <Button
                   type="primary"
                   status="warning"

src/pkg/config/config.ts

@@ -211,4 +211,13 @@ export class SystemConfig {
       Message.error(err.toString());
     }
   }
+
+  // 日志清理周期
+  get logCleanCycle() {
+    return <number>this.cache.get("log_clean_cycle") || 7;
+  }
+
+  set logCleanCycle(val: number) {
+    this.set("log_clean_cycle", val);
+  }
 }