chore:fix

This commit is contained in:
手瓜一十雪
2024-08-11 00:44:37 +08:00
parent e0478a2ffc
commit 87f513d9ed
7 changed files with 21 additions and 7 deletions

View File

@@ -28,7 +28,8 @@ export class OB11ActiveHttpAdapter implements IOB11NetworkAdapter {
registerHeartBeat() {
// HttpPost 心跳
}
registerActionMap(actionMap: Map<string, BaseAction<any, any>>) {
}
registerAction<T extends BaseAction<P, R>, P, R>(action: T) {
// Passive http adapter does not need to register actions
}

View File

@@ -24,7 +24,9 @@ export class OB11ActiveWebSocketAdapter implements IOB11NetworkAdapter {
this.coreContext = coreContext;
this.onebotContext = onebotContext;
}
registerActionMap(actionMap: Map<string, BaseAction<any, any>>) {
this.actionMap = actionMap;
}
registerHeartBeat() {
if (this.connection) {
this.heartbeatTimer = setInterval(() => {

View File

@@ -7,6 +7,8 @@ export type OB11EmitEventContent = OB11BaseEvent | OB11Message;
export interface IOB11NetworkAdapter {
registerAction<T extends BaseAction<P, R>, P, R>(action: T): void;
registerActionMap(actionMap: Map<string, BaseAction<any, any>>): void;
onEvent<T extends OB11EmitEventContent>(event: T): void;
open(): void | Promise<void>;
@@ -16,13 +18,15 @@ export interface IOB11NetworkAdapter {
export class OB11NetworkManager {
adapters: IOB11NetworkAdapter[] = [];
async getAllAdapters() {
return this.adapters;
}
async openAllAdapters() {
return Promise.all(this.adapters.map(adapter => adapter.open()));
}
async registerAllActions(actions: Map<string,BaseAction<any, any>>) {
return Promise.all(this.adapters.map(adapter => adapter.registerActionMap(actions)));
}
async emitEvent(event: OB11EmitEventContent) {
// Mlikiowa V2.0.0 Refactor Todo
return Promise.all(this.adapters.map(adapter => adapter.onEvent(event)));

View File

@@ -27,7 +27,9 @@ export class OB11PassiveHttpAdapter implements IOB11NetworkAdapter {
registerAction<T extends BaseAction<P, R>, P, R>(action: T) {
this.actionMap.set(action.actionName, action);
}
registerActionMap(actionMap: Map<string, BaseAction<any, any>>) {
this.actionMap = actionMap;
}
registerHeartBeat() {
//空心跳
}
@@ -52,7 +54,7 @@ export class OB11PassiveHttpAdapter implements IOB11NetworkAdapter {
this.app.use(express.json());
this.app.all('*', this.handleRequest.bind(this));
this.app.all('/*', this.handleRequest.bind(this));
this.server.listen(this.port, () => {
this.coreContext.context.logger.log(`HTTP server listening on port ${this.port}`);

View File

@@ -44,7 +44,9 @@ export class OB11PassiveWebSocketAdapter implements IOB11NetworkAdapter {
});
});
}
registerActionMap(actionMap: Map<string, BaseAction<any, any>>) {
this.actionMap = actionMap;
}
registerAction<T extends BaseAction<P, R>, P, R>(action: T) {
this.actionMap.set(action.actionName, action);
}