Method waitForBotReply

kkp/kkp.ts:158–216

(
    client: any,
    botEntity: any,
    timeoutMs: number = 15000,
  )

      const cleanup = (result: Api.Message | null) => {
        if (isResolved) return;
        isResolved = true;

        const listener = this.messageListeners.get(listenerId);
        if (listener) {
          clearTimeout(listener.timeout);
          try {
            client.removeEventHandler(listener.handler, new NewMessage({}));
          } catch (error) {
            console.warn("[kkp] 移除事件监听器失败:", error);
          }
          this.messageListeners.delete(listenerId);
        }
        resolve(result);
      };

      const timeout = setTimeout(() => cleanup(null), timeoutMs);

      const messageHandler = (event: any) => {
        try {
          const message = event.message;
          if (!message) return;
          const senderId = message.senderId?.toString();
          const botId = botEntity.id.toString();

          if (senderId === botId && message.date * 1000 >= startTime - 1000) {
            if (this.isVideoMessage(message)) cleanup(message);
          }
        } catch (error) {
          console.error("[kkp] 消息处理失败:", error);
          cleanup(null);
        }
      };

      this.messageListeners.set(listenerId, {
        resolve,
        timeout,
        startTime,
        handler: messageHandler,
      });
      try {
        client.addEventHandler(messageHandler, new NewMessage({}));
      } catch (error) {
        console.error("[kkp] 添加事件监听器失败:", error);
        cleanup(null);
      }
    });
  }

  private async getRandomVideo(msg: Api.Message, client: any): Promise<void> {
    await msg.edit({ text: "🎲 正在获取随机视频...", parseMode: "html" });

    const botUsername = "SeSe3000Bot";
    try {
      const botEntity = await client.getEntity(botUsername);
      const recentMessages = await safeGetMessages(client, botEntity, { limit: 3 });

      if (recentMessages.length === 0) {
        await client.sendMessage(botEntity, { message: "/start" });