// We're also using some of stefansChat_onLine's variables
please include function stefansChat_onLine.

static double smartBotsChat_onLine_safetyDelay = 1; // seconds
static double smartBotsChat_onLine_shortSafetyDelay = 0.1;
static double smartBotsChat_onLine_errorDelay = 10;
static int smartBotsChat_onLine_lookback = 0;
static int smartBotsChat_onLine_firstRead = -1;
static new ThreadLocal smartBotsChat_onLine_onHistoryRead;

static void smartBotsChat_onLine(int lookback, O f) {
  smartBotsChat_onLine_lookback = lookback;
  smartBotsChat_onLine(f);
}

static void smartBotsChat_onLine(fO f) {
  fO hr = getAndClearThreadLocal(smartBotsChat_onLine_onHistoryRead);
  thread "Smart Bot's Chat" {
    int a = smartBotsChat_onLine_firstRead = max(0, smartBotsChat_n() - smartBotsChat_onLine_lookback);
    bool first = true;
    while licensed { pcall {
      S s = loadPageWithTimeout("http://botcompany.de/1011975/raw/incremental?json=1&a=" + a, 120*1000);
      if (empty(trim(s))) {
        sleepSeconds(smartBotsChat_onLine_safetyDelay);
        //print("Re-polling.");
        continue;
      }
      try {
        Map map = safeUnstructMap(s);
        int n = getInt(map, 'n);
        L msgs = cast get(map, 'msgs);
        for (O msg : msgs)
          try {
            stefansChat_onLine_fullParams.set(mapPlus((Map) msg, chatName := "Smart Bot's Chat"));
            pcallF(f, getString(msg, 'text));
          } finally {
            stefansChat_onLine_fullParams.set(null);
          }
        sleepSeconds(smartBotsChat_onLine_shortSafetyDelay);
        a = n;
      } catch e {
        printException(e);
        sleepSeconds(smartBotsChat_onLine_errorDelay);
      }
      
      if (first) {
        pcallF(hr);
        first = false;
      }
    }} // end pcall, while licensed
  }
}