From 5a5257294bcde55187426e82ef880da74528ad09 Mon Sep 17 00:00:00 2001 From: "Wesley F. Young" Date: Sat, 10 Aug 2024 19:33:34 +0800 Subject: [PATCH] optimize: an ActiveHttpAdapter does not need to register actions --- src/onebot/network/active-http.ts | 15 +++++++-------- 1 file changed, 7 insertions(+), 8 deletions(-) diff --git a/src/onebot/network/active-http.ts b/src/onebot/network/active-http.ts index dbc1114d..08def382 100644 --- a/src/onebot/network/active-http.ts +++ b/src/onebot/network/active-http.ts @@ -7,14 +7,15 @@ import { QuickAction, QuickActionEvent } from '../types'; import { NapCatCore } from '@/core'; import { NapCatOneBot11Adapter } from '../main'; import { handleQuickOperation } from '../helper/quick'; + export class OB11ActiveHttpAdapter implements IOB11NetworkAdapter { url: string; - private actionMap: Map> = new Map(); heartbeatInterval: number; secret: string | undefined; coreContext: NapCatCore; onebotContext: NapCatOneBot11Adapter; logger: LogWrapper; + constructor(url: string, heartbeatInterval: number, secret: string | undefined, coreContext: NapCatCore, onebotContext: NapCatOneBot11Adapter) { this.heartbeatInterval = heartbeatInterval; this.url = url; @@ -23,12 +24,13 @@ export class OB11ActiveHttpAdapter implements IOB11NetworkAdapter { this.onebotContext = onebotContext; this.logger = coreContext.context.logger; } + registerHeartBeat() { - //HttpPost心跳 + // HttpPost 心跳 } registerAction, P, R>(action: T) { - this.actionMap.set(action.actionName, action); + // Passive http adapter does not need to register actions } onEvent(event: T) { @@ -38,13 +40,11 @@ export class OB11ActiveHttpAdapter implements IOB11NetworkAdapter { }; const msgStr = JSON.stringify(event); if (this.secret && this.secret.length > 0) { - const hmac = createHmac('sha1', this.secret); hmac.update(msgStr); const sig = hmac.digest('hex'); headers['x-signature'] = 'sha1=' + sig; } - fetch(this.url, { method: 'POST', headers, @@ -63,8 +63,7 @@ export class OB11ActiveHttpAdapter implements IOB11NetworkAdapter { } catch (e: any) { this.logger.logError('新消息事件HTTP上报返回快速操作失败', e); } - - }) + }); } async open() { @@ -76,4 +75,4 @@ export class OB11ActiveHttpAdapter implements IOB11NetworkAdapter { // HTTP adapter does not need to close a persistent connection console.log('HTTP adapter does not maintain a persistent connection.'); } -} \ No newline at end of file +}