1import {
2  BaseAgentParticipant,
3  Participant,
4  ContextItem,
5  UserMessageItem,
6  FunctionCallItem,
7} from "@mozaik-ai/core"
8
9export class ReactiveAgent extends BaseAgentParticipant {
10  async onContextItem(
11    source: Participant,
12    item: ContextItem,
13  ): Promise<void> {
14    if (source === this) return
15
16    this.context.addContextItem(item)
17
18    if (item instanceof UserMessageItem) {
19      this.runInference(this.environment, this.context, this.model)
20      return
21    }
22
23    if (item instanceof FunctionCallItem) {
24      this.executeFunctionCall(this.environment, item)
25      return
26    }
27  }
28}