Spaces:
Sleeping
Sleeping
| export class SimpleAgentRuntime { | |
| agentName; | |
| respondToAllBubbleMessages; | |
| enableVoiceReplies; | |
| hooks; | |
| disclosedSessions = new Set(); | |
| constructor(options = {}) { | |
| this.agentName = options.agentName ?? process.env.WA_AGENT_NAME ?? "AI Agent"; | |
| this.respondToAllBubbleMessages = options.respondToAllBubbleMessages ?? process.env.WA_AGENT_RESPOND_TO_ALL === "true"; | |
| this.enableVoiceReplies = options.enableVoiceReplies ?? process.env.WA_AGENT_ENABLE_VOICE !== "false"; | |
| this.hooks = options.hooks ?? []; | |
| } | |
| async handleObservation(session, observation, enqueue, synthesizeSpeech) { | |
| for (const hook of this.hooks) { | |
| await hook.afterObservation?.(observation, session); | |
| } | |
| if (observation.type !== "chatMessage" || observation.scope !== "bubble") { | |
| return; | |
| } | |
| if (!this.shouldRespond(observation)) { | |
| return; | |
| } | |
| const reply = this.makeReply(session.id, observation); | |
| await this.enqueueWithHooks({ type: "startTyping", channel: "bubble" }, session, enqueue); | |
| await new Promise((resolve) => setTimeout(resolve, Math.min(900, Math.max(250, reply.length * 12)))); | |
| await this.enqueueWithHooks({ type: "say", channel: "bubble", text: reply }, session, enqueue); | |
| await this.enqueueWithHooks({ type: "stopTyping", channel: "bubble" }, session, enqueue); | |
| if (this.enableVoiceReplies && synthesizeSpeech) { | |
| try { | |
| await synthesizeSpeech(reply); | |
| } | |
| catch (error) { | |
| console.error("Failed to synthesize voice reply", error); | |
| } | |
| } | |
| } | |
| shouldRespond(observation) { | |
| const authorName = observation.author?.name?.toLowerCase(); | |
| if (authorName && authorName === this.agentName.toLowerCase()) { | |
| return false; | |
| } | |
| if (this.respondToAllBubbleMessages) { | |
| return true; | |
| } | |
| const normalized = observation.message.toLowerCase(); | |
| return normalized.includes(this.agentName.toLowerCase()) || normalized.includes("@agent") || normalized.includes("ai agent"); | |
| } | |
| makeReply(sessionId, observation) { | |
| const prefix = this.disclosedSessions.has(sessionId) ? "" : "I am an AI agent. "; | |
| this.disclosedSessions.add(sessionId); | |
| const author = observation.author?.name ? `${observation.author.name}, ` : ""; | |
| return `${prefix}${author}I heard: "${observation.message}". This prototype is wired for WorkAdventure text and voice responses.`; | |
| } | |
| async enqueueWithHooks(action, session, enqueue) { | |
| let nextAction = action; | |
| for (const hook of this.hooks) { | |
| if (!nextAction) { | |
| return; | |
| } | |
| if (hook.beforeAction) { | |
| nextAction = await hook.beforeAction(nextAction, session); | |
| } | |
| } | |
| if (nextAction) { | |
| enqueue(nextAction); | |
| } | |
| } | |
| } | |
| //# sourceMappingURL=simpleAgent.js.map |