!7

cmodule FluidTextFileSpike > DynPrintLog {
  srecord Entry(S header, S text, SS params) {
    S actualText() { ret unquote(text); }
  }
  
  switchable int maxRefLength = 8;

  int maxFileSize() {
    ret rangeOfNHexNumberWithNDigits(maxRefLength);
  }
  
  transient S demoContent = autoUnindent_mls([=[
    refs="at *", name="index" [[
      entry 1 at abc
      entry 2 at def
    ]]
    i=abc [[hello]]
    i=def [[world]]
  ]=]);

  start-thread {
    print(demoContent);
    Producer<S> p = javaTok_onReader(stringReader(demoContent));
    new StringBuilder buf;
    new L<Entry> entries;
    S t;
    p.next(); // skip initial white space
    while ((t = p.next()) != null) {
      if (isMLS(t)) {
        S header = getAndClearStringBuilder(buf);
        entries.add(new Entry(header, t, parseEqualsCommaProperties(header)));
        p.next(); // skip white space
      } else
        buf.append(t); // part of entry header
    }
    pnlStruct(entries);

    long idx = 0; // index into file
    for (Entry e : entries) {
      S line = entryToString(e, idx);
      print_noNewLine(line);
      idx += lUtf8(line);
    }

  }

  S entryToString(Entry e, long idx) {
    SS params = litorderedmap(
      i := longToHex_flexLength(idx),
      l := intToHex_flexLength(l(e.text)));
    mapPutAll_noOverwrite(params, e.params);
    ret renderEqualsCommaProperties(params) + " " + e.text + "\n";
  }  

  int pessimisticEntryLength(Entry e) {
    SS params = cloneMap(e.params);
    params.put("i", rep('0', maxRefLength));
    ret l(entryToString(cloneSetAll(e, +params)));
  }

  S replaceRefs(Entry e, IF1<S> f) {
    LS tok = javaTok(e.actualText());
    for (int i : jfindAll(tok, "at *")) {
      S x = f.get(tok.get(i));
      if (nempty(x))
        tok.set(i, x);
    }
    ret multiLineQuote(join(tok));
  }
}