Fix agent channel emitting

Oneirocom · Nov 22, 2024 · 828c6ce · 828c6ce
1 parent 7e94545
commit 828c6ce
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/packages/server/agents/src/lib/Agent.ts b/packages/server/agents/src/lib/Agent.ts
@@ -96,6 +96,7 @@ type ChannelEvents = {
 class Channel extends (EventEmitter as new () => TypedEmitter<ChannelEvents>) {
   constructor(private channelId: string, private agent: Agent) {
     super()
+    this.agent = agent
   }
 
   emit<K extends keyof ChannelEvents>(
@@ -106,7 +107,7 @@ class Channel extends (EventEmitter as new () => TypedEmitter<ChannelEvents>) {
       ...data,
       channel: this.channelId,
     }
-    return super.emit(event, ...([eventData] as Parameters<ChannelEvents[K]>))
+    return this.agent.emit(event, eventData)
   }
 }