<br />
<b>Warning</b>:  session_start(): open(/var/lib/php/sessions/sess_cbip6b4dcbg5vpqaemtpbs4ui9, O_RDWR) failed: No space left on device (28) in <b>/var/www/tb-usercake/models/config.php</b> on line <b>51</b><br />
<br />
<b>Warning</b>:  session_start(): Failed to read session data: files (path: /var/lib/php/sessions) in <b>/var/www/tb-usercake/models/config.php</b> on line <b>51</b><br />
!7

sclass Entry {
  S pattern;
  Map params; // null if not matched
  
  sS _fieldOrder = "pattern params";
}

cmodule MatchingInputPatterns > DynObjectTable<Entry> {
  transient S input;
  transient LinkedHashSet<S> processedGroupings;
  
  start {
    set fieldsInOrder;
    dm_onTopInput_q(vf<S> process);
    process(dm_topInput());
    dm_vmBus_onMessage_q('newInputGroupings, voidfunc(O mod, S _input, LS groupings) {
      print("Got groupings");
      S topInput = dm_topInput();
      if (neq(topInput, input)) process(topInput);
      if (neq(_input, input)) ret;
      for (S s : groupings) process2(s);
    });
  }
  
  // happens in queue
  void process(S s) {
    clear();
    input = s;
    processedGroupings = new LinkedHashSet;
    process2(s);
  }
  
  void process2(S s) {
    if (!processedGroupings.add(s)) ret;
    
    LS patterns = collect pattern((L) dm_requireAndCallModule("#1020518/InputPatterns", 'data));
    print("Processing input " + quote(s) + " with " + n2(patterns, "pattern") + ": " + patterns);
    new Matches m;
    for (S pat : patterns)
      if (match3_plusBrackets(pat, s, m)) {
        add(nu(Entry, pattern := pat, params := matchesToMap(m)));
        print("Data length: " + l(data));
      }
  }
}