GuanM/NapCatQQ
1
0
Fork 0
mirror of https://github.com/NapNeko/NapCatQQ.git synced 2024-11-21 09:36:35 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

chore: lint & style

Browse Source
This commit is contained in:
Wesley F. Young 2024-08-26 12:44:44 +08:00
parent a22ef67486
commit af6ac26664
1 changed files with 10 additions and 12 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

22
src/common/framework/event-legacy.ts
View File

@ -11,18 +11,13 @@ interface InternalMapKey {
export type ListenerClassBase = Record<string, string>; export type ListenerClassBase = Record<string, string>;
export interface ListenerIBase {
new(listener: any): ListenerClassBase;
[key: string]: any;
}
export class LegacyNTEventWrapper { export class LegacyNTEventWrapper {
private WrapperSession: NodeIQQNTWrapperSession | undefined; //WrapperSession private WrapperSession: NodeIQQNTWrapperSession | undefined; //WrapperSession
private listenerManager: Map<string, ListenerClassBase> = new Map<string, ListenerClassBase>(); //ListenerName-Unique -> Listener实例 private listenerManager: Map<string, ListenerClassBase> = new Map<string, ListenerClassBase>(); //ListenerName-Unique -> Listener实例
private EventTask = new Map<string, Map<string, Map<string, InternalMapKey>>>(); //tasks ListenerMainName -> ListenerSubName-> uuid -> {timeout,createtime,func} private EventTask = new Map<string, Map<string, Map<string, InternalMapKey>>>(); //tasks ListenerMainName -> ListenerSubName-> uuid -> {timeout,createtime,func}
constructor( constructor(
wrapperSession: NodeIQQNTWrapperSession wrapperSession: NodeIQQNTWrapperSession,
) { ) {
this.WrapperSession = wrapperSession; this.WrapperSession = wrapperSession;
} }
@ -115,15 +110,17 @@ export class LegacyNTEventWrapper {
const id = randomUUID(); const id = randomUUID();
let complete = 0; let complete = 0;
let retData: Parameters<ListenerType> | undefined = undefined; let retData: Parameters<ListenerType> | undefined = undefined;
const databack = () => {
function sendDataCallback() {
if (complete == 0) { if (complete == 0) {
reject(new Error(' ListenerName:' + ListenerName + ' timeout')); reject(new Error(' ListenerName:' + ListenerName + ' timeout'));
} else { } else {
resolve(retData!); resolve(retData!);
} }
}; }
const timeoutRef = setTimeout(databack, timeout);
const eventCallbak = { const timeoutRef = setTimeout(sendDataCallback, timeout);
const eventCallback = {
timeout: timeout, timeout: timeout,
createtime: Date.now(), createtime: Date.now(),
checker: checker, checker: checker,
@ -132,7 +129,7 @@ export class LegacyNTEventWrapper {
retData = args; retData = args;
if (complete >= waitTimes) { if (complete >= waitTimes) {
clearTimeout(timeoutRef); clearTimeout(timeoutRef);
databack(); sendDataCallback();
} }
}, },
}; };
@ -142,7 +139,7 @@ export class LegacyNTEventWrapper {
if (!this.EventTask.get(ListenerMainName)?.get(ListenerSubName)) { if (!this.EventTask.get(ListenerMainName)?.get(ListenerSubName)) {
this.EventTask.get(ListenerMainName)?.set(ListenerSubName, new Map()); this.EventTask.get(ListenerMainName)?.set(ListenerSubName, new Map());
} }
this.EventTask.get(ListenerMainName)?.get(ListenerSubName)?.set(id, eventCallbak); this.EventTask.get(ListenerMainName)?.get(ListenerSubName)?.set(id, eventCallback);
this.createListenerFunction(ListenerMainName); this.createListenerFunction(ListenerMainName);
}); });
} }
@ -173,6 +170,7 @@ export class LegacyNTEventWrapper {
let complete = 0; let complete = 0;
let retData: Parameters<ListenerType> | undefined = undefined; let retData: Parameters<ListenerType> | undefined = undefined;
let retEvent: any = {}; let retEvent: any = {};
function sendDataCallback() { function sendDataCallback() {
if (complete == 0) { if (complete == 0) {
reject( reject(