🐛 修复GM_addValueChangeListener问题 #404

Author: CodFrm

example/gm_value/listener_change.js

@@ -0,0 +1,23 @@
+// ==UserScript==
+// @name         gm value listener change
+// @namespace    https://bbs.tampermonkey.net.cn/
+// @version      0.1.0
+// @description  监听脚本数据变更
+// @author       You
+// @match        https://bbs.tampermonkey.net.cn/
+// @run-at       document-start
+// @grant        GM_getValue
+// @grant        GM_addValueChangeListener
+// @grant        GM_listValues
+// @grant        GM_setValue
+// ==/UserScript==
+
+GM_addValueChangeListener("test_set", function (name, oldval, newval, remote) {
+    console.log("test_set change", name, oldval, newval, remote);
+});
+
+setInterval(() => {
+    console.log("test_set: ", GM_getValue("test_set"));
+    console.log("value list:", GM_listValues());
+    GM_setValue("test_set", (new Date()).getTime());
+}, 2000);

src/app/service/content/gm_api.ts

@@ -8,6 +8,7 @@ import LoggerCore from "@App/app/logger/core";
 import { connect, sendMessage } from "@Packages/message/client";
 import EventEmitter from "eventemitter3";
 import { getStorageName } from "@App/pkg/utils/utils";
+import { MessageRequest } from "../service_worker/gm_api";
 
 interface ApiParam {
   depend?: string[];
@@ -74,7 +75,8 @@ export default class GMApi {
       uuid: this.scriptRes.uuid,
       api,
       params,
-    });
+      runFlag: this.runFlag,
+    } as MessageRequest);
   }
 
   // 长连接使用,connect只用于接受消息,不发送消息
@@ -83,7 +85,8 @@ export default class GMApi {
       uuid: this.scriptRes.uuid,
       api,
       params,
-    });
+      runFlag: this.runFlag,
+    } as MessageRequest);
   }
 
   public valueUpdate(data: ValueUpdateData) {

src/app/service/service_worker/value.ts

@@ -46,7 +46,7 @@ export class ValueService {
     const storageName = getStorageName(script);
     let oldValue;
     // 使用事务来保证数据一致性
-    await Cache.getInstance().tx("setValue:" + storageName, async () => {
+    const flag = await Cache.getInstance().tx("setValue:" + storageName, async () => {
       const valueModel = await this.valueDAO.get(storageName);
       if (!valueModel) {
         await this.valueDAO.save(storageName, {
@@ -57,6 +57,10 @@ export class ValueService {
           updatetime: Date.now(),
         });
       } else {
+        // 值没有发生变化, 不进行操作
+        if (valueModel.data[key] === value) {
+          return false;
+        }
         oldValue = valueModel.data[key];
         if (value === undefined) {
           delete valueModel.data[key];
@@ -67,7 +71,9 @@ export class ValueService {
       }
       return true;
     });
-    this.pushValueToTab(oldValue, key, value, uuid, storageName, sender);
+    if (flag) {
+      this.pushValueToTab(oldValue, key, value, uuid, storageName, sender);
+    }
   }
 
   // 推送值到tab