fix: ReceiptManager shared singleton cyclic dependency

WuKongIM · Dec 11, 2024 · e344598 · e344598
1 parent 95887e5
commit e344598
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 6 deletions.
diff --git a/src/index.ts b/src/index.ts
@@ -45,7 +45,7 @@ export default class WKSDK {
         this.conversationManager = ConversationManager.shared()
         this.securityManager = SecurityManager.shared()
         this.reminderManager = ReminderManager.shared()
-        this.receiptManager = ReceiptManager.shared()
+        this.receiptManager = ReceiptManager.shared(this.config.receiptFlushInterval)
 
 
         this.registerFactor((contentType: number): MessageContent | undefined => {

diff --git a/src/receipt_manager.ts b/src/receipt_manager.ts
@@ -6,19 +6,19 @@ export type MessageReceiptListener = ((channel:Channel,message: Message[]) => vo
 export class ReceiptManager {
     private static instance: ReceiptManager
     listeners: MessageReceiptListener[] = new Array(); // 回执监听
-    private timer!:NodeJS.Timeout
-    public static shared() {
+    private timer!:NodeJS.Timeout | null | number
+    public static shared(flushInterval:number = 2000) {
         if (!this.instance) {
             this.instance = new ReceiptManager();
-            this.instance.setup()
+            this.instance.setup(flushInterval)
         }
         return this.instance;
     }
 
     private  channelMessagesMap = new Map<string,Message[]>();
 
-   private setup() {
-        this.timer = setInterval(this.flushLoop.bind(this),WKSDK.shared().config.receiptFlushInterval)
+   private setup(flushInterval:number) {
+        this.timer = setInterval(this.flushLoop.bind(this),flushInterval)
     }
 
     // 添加需要回执的消息