static double stefansChat_onLine_safetyDelay = 1; // seconds

static double stefansChat_onLine_shortSafetyDelay = 0.1;

static double stefansChat_onLine_errorDelay = 10;

static int stefansChat_onLine_lookback = 0;

static int stefansChat_onLine_firstRead = -1;

static new ThreadLocal<Map> stefansChat_onLine_fullParams;

static new ThreadLocal stefansChat_onLine_onHistoryRead;

static void stefansChat_onLine(int lookback, O f) {

  stefansChat_onLine_lookback = lookback;

  stefansChat_onLine(f);

}

static void stefansChat_onLine(fO f) {

  fO hr = getAndClearThreadLocal(stefansChat_onLine_onHistoryRead);

  thread "Stefan's Chat" {

    int a = stefansChat_onLine_firstRead = max(0, stefansChat_n()-stefansChat_onLine_lookback);

    bool first = true;

    while licensed { pcall {

      S s = loadPageWithTimeout("http://botcompany.de/1008998/raw/incremental?json=1&a=" + a, 120*1000);

      if (empty(trim(s))) {

        sleepSeconds(stefansChat_onLine_safetyDelay);

        //print("Re-polling.");

        continue;

      }

      try {

        Map map = safeUnstructMap(s);

        int n = getInt n(map);

        L msgs = cast get(map, 'msgs);

        for (O msg : msgs)

          try {

            stefansChat_onLine_fullParams.set(mapPlus((Map) msg, chatName := "Stefan's Chat"));

            pcallF(f, getString(msg, 'text));

          } finally {

            stefansChat_onLine_fullParams.set(null);

          }

        sleepSeconds(stefansChat_onLine_shortSafetyDelay);

        a = n;

      } catch e {

        printException(e);

        sleepSeconds(stefansChat_onLine_errorDelay);

      }

      if (first) {

        pcallF(hr);

        first = false;

      }

    }} // end pcall, while licensed

  }

}