Northern_Lights/NapCatQQ
1
0
Fork 0
mirror of https://github.com/NapNeko/NapCatQQ.git synced 2026-02-11 23:40:24 +00:00
Code Issues Actions 2 Packages Projects Releases Wiki Activity

chore: HttpAdapter

Browse Source
This commit is contained in:
手瓜一十雪
2024-08-11 00:35:39 +08:00
parent bd0f63020f
commit f770dc7771
3 changed files with 16 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
src/onebot/network/index.ts
View File

@@ -20,7 +20,9 @@ export class OB11NetworkManager {
async getAllAdapters() {
return this.adapters;
}
async openAllAdapters() {
return Promise.all(this.adapters.map(adapter => adapter.open()));
}
async emitEvent(event: OB11EmitEventContent) {
// Mlikiowa V2.0.0 Refactor Todo
return Promise.all(this.adapters.map(adapter => adapter.onEvent(event)));

12
src/onebot/network/passive-http.ts
View File

@@ -3,6 +3,8 @@ import { OB11BaseEvent } from '@/onebot/event/OB11BaseEvent';
import BaseAction from '@/onebot/action/BaseAction';
import express, { Express, Request, Response } from 'express';
import http from 'http';
import { NapCatCore } from '@/core';
import { NapCatOneBot11Adapter } from '../main';
export class OB11PassiveHttpAdapter implements IOB11NetworkAdapter {
private app: Express | undefined;
@@ -12,10 +14,14 @@ export class OB11PassiveHttpAdapter implements IOB11NetworkAdapter {
private actionMap: Map<string, BaseAction<any, any>> = new Map();
private port: number;
token: string;
coreContext: NapCatCore;
onebotContext: NapCatOneBot11Adapter;
constructor(port: number, token: string) {
constructor(port: number, token: string, coreContext: NapCatCore, onebotContext: NapCatOneBot11Adapter) {
this.port = port;
this.token = token;
this.coreContext = coreContext;
this.onebotContext = onebotContext;
}
registerAction<T extends BaseAction<P, R>, P, R>(action: T) {
@@ -32,7 +38,7 @@ export class OB11PassiveHttpAdapter implements IOB11NetworkAdapter {
open() {
if (this.hasBeenClosed) {
throw new Error('Cannot open a closed HTTP server');
this.coreContext.context.logger.logError('Cannot open a closed HTTP server');
}
if (!this.isOpen) {
this.initializeServer();
@@ -49,7 +55,7 @@ export class OB11PassiveHttpAdapter implements IOB11NetworkAdapter {
this.app.all('*', this.handleRequest.bind(this));
this.server.listen(this.port, () => {
console.log(`HTTP server listening on port ${this.port}`);
this.coreContext.context.logger.log(`HTTP server listening on port ${this.port}`);
});
}