Method handleIncomingMessage

src/runtime/adapters/feishu.ts:208–326

(message: NormalizedMessage)

    }
  }

  private async handleIncomingMessage(message: NormalizedMessage): Promise<void> {
    if (!this.channel || !this.agent) {
      return;
    }

    const decision = normalizeFeishuMessage(message);
    if (decision.action === "ignore") {
      return;
    }

    await this.tryAckReaction(message.messageId);

    const channelId = `feishu-${message.chatId}`;
    if (decision.action === "unsupported") {
      await this.sendSafe(message.chatId, UNSUPPORTED_MESSAGE_REPLY, message.messageId);
      return;
    }

    const userText = decision.text;
    const attachments = await this.extractResourceAttachments(message, channelId);
    if (
      userText === ATTACHMENT_MESSAGE_TEXT &&
      this.hasSupportedResources(message) &&
      attachments.length === 0
    ) {
      await this.sendSafe(message.chatId, ATTACHMENT_DOWNLOAD_FAILED_REPLY, message.messageId);
      return;
    }

    this.ipcBroadcaster?.broadcastInbound(
      channelId,
      "feishu",
      {
        id: message.senderId,
        username: message.senderName || message.senderId,
      },
      userText,
    );

    const command = this.resolveCommand(userText);
    if (command) {
      const result = await this.agent.handleCommand(command, channelId);
      await this.sendSafe(
        message.chatId,
        result.message || `/${command} executed.`,
        message.messageId,
      );
      return;
    }

    let finalText = "";
    let hasError = false;
    let errorMessage = "";
    const pendingFiles: Array<{ filePath: string; caption?: string }> = [];

    const onEvent = (event: AgentEvent) => {
      switch (event.type) {