sclass WebBotTester implements AutoCloseable {

  S botURL; // without the "/incremental"

  S cookie = "test_" + aGlobalID();

  int n; // number of messages grabbed

  Thread grabThread;

  volatile bool closed;

  LS allHtml = syncList();

  new L<WebChatBotMsg> msgs;

  double readTimeout = 120.0, sendTimeout = 20.0;

  double waitForMessagesTimeout = 20.0;

  SS params = new LinkedHashMap;

  *(S botID) { botURL = "https://botcompany.de/" + psI(botID) + "/raw"; }

  public void close {

    set closed;

    cancelAndInterruptThread(grabThread);

  }

  selfType start() {

    if (grabThread == null)

      grabThread = startThread(r _grabLoop);

    this;

  }

  void _grabLoop {

    while (!closed) {

      S html = loadPageWithTimeout(botURL + "/incremental" + hquery(mapPlus(params, +cookie, a := n)), readTimeout);

      allHtml.add(html);

      printWithIndent("> ", html);

      msgs.addAll(webBotTester_extractMsgs(html));

      S comment = first(getHTMLComments(html));

      int n = parseFirstIntOrMinus1(comment);

      if (n >= 0) this.n = n;

      sleepSeconds(1);

    }

  }

  void sendMsg(S message) {

    print(doPostWithTimeout(mapPlus(params, +cookie, +message), botURL + "/msg", toMS_int(sendTimeout)));

  }

  void waitForMessages(int n) {

    waitUntil(50, waitForMessagesTimeout, () -> l(msgs) >= n);

  }

}