Method runAgent

src/runtime/adapters/slack.ts:293–364

(
    channelId: string,
    text: string,
    client: any,
    route: SlackRoute,
    attachments: ChannelAttachment[] = [],
  )

  // -------------------------------------------------------------------------

  private async runAgent(
    channelId: string,
    text: string,
    client: any,
    route: SlackRoute,
    attachments: ChannelAttachment[] = [],
  ): Promise<void> {
    if (!this.agent) return;

    let finalText = "";
    let hasError = false;
    let errorMessage = "";
    const pendingFiles: Array<{ filePath: string; caption?: string }> = [];
    const placeholder = await this.sendPlaceholderMessage(client, route);

    const onEvent = (event: AgentEvent) => {
      if (event.type === "text_delta") {
        finalText += event.delta;
      } else if (event.type === "file_output") {
        pendingFiles.push({
          filePath: event.filePath,
          caption: event.caption,
        });
      }
      this.ipcBroadcaster?.broadcastAgentEvent(channelId, event);
    };

    try {
      const result = await this.agent.handleMessage(
        "slack",
        channelId,
        text,
        onEvent,
        attachments.length > 0 ? attachments : undefined,
      );
      if (result.errorMessage) {
        hasError = true;
        errorMessage = result.errorMessage;
      }
    } catch (err) {
      hasError = true;
      errorMessage = this.getErrorMessage(err);
    }

    if (hasError) {
      await this.sendOrUpdateSafe(
        client,
        route,
        `❌ Error: ${errorMessage}`,
        placeholder,
      );
      return;
    }

    if (finalText.trim()) {
      await this.sendLongMessage(client, route, finalText, placeholder);
    } else if (pendingFiles.length === 0) {
      await this.sendOrUpdateSafe(