event error process

Kokoro-js · Nov 23, 2024 · d322967 · d322967
1 parent 70216da
commit d322967
Show file tree

Hide file tree

Showing 2 changed files with 15 additions and 2 deletions.
diff --git a/packages/core/src/event-trigger.ts b/packages/core/src/event-trigger.ts
@@ -1,7 +1,9 @@
-import { Context } from './context';
+import { Context, Events } from './context';
 import { NoticeType, Session } from './types';
 import { KookEvent } from './events';
 import { createLogger } from './Logger';
+import { Bot } from './bot';
+import { GetEvents } from 'cordis';
 
 const logger = createLogger('Kook-Events');
 export function internalWebhook(ctx: Context, bot, data) {
@@ -65,9 +67,17 @@ function handleSpecialTypes(data, session, ctx, bot) {
   }
 }
 
-function processEvent(ctx, session, eventType, bot) {
+function processEvent(
+  ctx: Context,
+  session: Session<any>,
+  eventType: keyof GetEvents<Context>,
+  bot: Bot,
+) {
   ctx.parallel(session, eventType, bot, session).catch((e) => {
     logger.error(e, `Error processing event ${eventType}:`);
+    ctx.parallel(session, 'event/error', session, eventType, e).catch(() => {
+      logger.error(e, `Error processing error event ${eventType}:`);
+    });
   });
 }
 

diff --git a/packages/core/src/events.ts b/packages/core/src/events.ts
@@ -53,6 +53,8 @@ import {
 } from './services';
 import { Flags } from 'type-flag';
 import { Awaitable } from 'cosmokit';
+import { GetEvents } from 'cordis';
+import { Context } from './context';
 
 export interface KookEvent {
   'internal/webhook'(bot: Bot, payload: PayLoad): void;
@@ -112,6 +114,7 @@ export interface KookEvent {
 }
 
 export interface ServiceEvent {
+  'event/error'(session: any, eventType: keyof GetEvents<Context>, error: any): void;
   'middleware'(bot: Bot, data: MessageSession): void;
 
   'command/before-parse'(