fix: resolved this being undefined in plugin bug

packages/common/src/interfaces/plugin.interface.ts

@@ -43,13 +43,12 @@ export interface HandleMessagePlugin {
    * @param ctx The client context
    * @param message The incoming message
    * @param next The next function to call the next plugin
-   * @returns The result of the message handling
    */
   handleMessage(
     ctx: ClientContext,
     message: IncomingMessage,
     next: () => Promise<HandleMessageResult>,
-  ): Promise<HandleMessageResult> | HandleMessageResult;
+  ): Promise<HandleMessageResult>;
 }
 
 /**
@@ -72,11 +71,10 @@ export interface BroadcastPlugin {
    * @param ctx The client context
    * @param event The event to broadcast
    * @param next The next function to call the next plugin
-   * @returns void
    */
   broadcast(
     ctx: ClientContext,
     event: Event,
     next: () => Promise<void>,
-  ): Promise<void> | void;
+  ): Promise<void>;
 }

packages/core/src/services/plugin-manager.service.ts

@@ -63,11 +63,13 @@ export class PluginManagerService {
         return Promise.reject(new Error('next() called multiple times'));
       }
       index = i;
-      const fn = plugins[i]?.[funcName];
-      if (!fn) {
-        return next(...args);
+      const plugin = plugins[i];
+      if (!plugin || !plugin[funcName]) {
+        return Promise.resolve(next(...args));
       }
-      return Promise.resolve(fn(...args, dispatch.bind(null, i + 1)));
+      return Promise.resolve(
+        plugin[funcName](...args, dispatch.bind(null, i + 1)),
+      );
     }
   }