GuanM/NapCatQQ
1
0
Fork 0
mirror of https://github.com/NapNeko/NapCatQQ.git synced 2025-07-19 12:03:37 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

fix: remove redundant async calls

Browse Source
This commit is contained in:
Wesley F. Young
2024-08-11 17:24:29 +08:00
parent df4b84b4b9
commit eafc32a915
1 changed files with 8 additions and 8 deletions
Download Patch File Download Diff File Expand all files Collapse all files

16
src/onebot/main.ts
View File

@@ -1,7 +1,7 @@
import { InstanceContext, MsgListener, NapCatCore, RawMessage } from '@/core'; import { InstanceContext, MsgListener, NapCatCore, RawMessage } from '@/core';
import { OB11Config } from './helper/config'; import { OB11Config } from './helper/config';
import { NapCatPathWrapper } from '@/common/framework/napcat'; import { NapCatPathWrapper } from '@/common/framework/napcat';
import { OneBotApiContextType } from './types/adapter'; import { OneBotApiContextType } from '@/onebot/types';
import { OneBotFriendApi, OneBotGroupApi, OneBotUserApi } from './api'; import { OneBotFriendApi, OneBotGroupApi, OneBotUserApi } from './api';
import { OB11ActiveHttpAdapter, OB11ActiveWebSocketAdapter, OB11NetworkManager, OB11PassiveHttpAdapter, OB11PassiveWebSocketAdapter } from '@/onebot/network'; import { OB11ActiveHttpAdapter, OB11ActiveWebSocketAdapter, OB11NetworkManager, OB11PassiveHttpAdapter, OB11PassiveWebSocketAdapter } from '@/onebot/network';
import { OB11InputStatusEvent } from '@/onebot/event/notice/OB11InputStatusEvent'; import { OB11InputStatusEvent } from '@/onebot/event/notice/OB11InputStatusEvent';
@@ -55,28 +55,28 @@ export class NapCatOneBot11Adapter {
this.context.logger.log(`[Notice] [OneBot11] ${serviceInfo}`); this.context.logger.log(`[Notice] [OneBot11] ${serviceInfo}`);
//创建NetWork服务 //创建NetWork服务
let actions = createActionMap(this, this.core); const actions = createActionMap(this, this.core);
if (ob11Config.http.enable) { if (ob11Config.http.enable) {
await this.networkManager.registerAdapter(new OB11PassiveHttpAdapter( await this.networkManager.registerAdapter(new OB11PassiveHttpAdapter(
ob11Config.http.port, ob11Config.token, this.core, this ob11Config.http.port, ob11Config.token, this.core, this
)); ));
} }
if (ob11Config.http.enablePost) { if (ob11Config.http.enablePost) {
ob11Config.http.postUrls.forEach(async url => { ob11Config.http.postUrls.forEach(url => {
await this.networkManager.registerAdapter(new OB11ActiveHttpAdapter( this.networkManager.registerAdapter(new OB11ActiveHttpAdapter(
url, ob11Config.heartInterval, ob11Config.token, this.core, this url, ob11Config.heartInterval, ob11Config.token, this.core, this
)); ));
}); });
} }
if (ob11Config.ws.enable) { if (ob11Config.ws.enable) {
let OBPassiveWebSocketAdapter = new OB11PassiveWebSocketAdapter( const OBPassiveWebSocketAdapter = new OB11PassiveWebSocketAdapter(
ob11Config.ws.host, ob11Config.ws.port, ob11Config.heartInterval, ob11Config.token, this.core, this ob11Config.ws.host, ob11Config.ws.port, ob11Config.heartInterval, ob11Config.token, this.core, this
) );
await this.networkManager.registerAdapter(OBPassiveWebSocketAdapter); await this.networkManager.registerAdapter(OBPassiveWebSocketAdapter);
} }
if (ob11Config.reverseWs.enable) { if (ob11Config.reverseWs.enable) {
ob11Config.reverseWs.urls.forEach(async url => { ob11Config.reverseWs.urls.forEach(url => {
await this.networkManager.registerAdapter(new OB11ActiveWebSocketAdapter( this.networkManager.registerAdapter(new OB11ActiveWebSocketAdapter(
url, 5000, ob11Config.heartInterval, this.core, this url, 5000, ob11Config.heartInterval, this.core, this
)); ));
}); });