<br />
<b>Warning</b>:  session_start(): open(/var/lib/php/sessions/sess_6bagb52euv0efbfpvtiq0ctnpr, 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 />
abstract sclass AbstractSayAndInputBot2 extends AbstractSayAndInputBot implements Runnable {
  LS inputQueue = synchroLinkedList();
  Set<Thread> activeThreads = synchroSet();
  
  // functions taking a string and returning a string or collection of strings
  L preprocessors = synchroList();
  
  F1<S, Bool> isYes = f<S, Bool> isYes_1;
  new LinkedHashSet<S> facts;
  new LinkedHashSet<S> assumptions;
  
  L<Attractor> standardAttractors = synchroList();
  L<Attractor> activeAttractors = synchroList();
  L<Attractor> lowPrioAttractors = synchroList();
    
  abstract class Attractor implements IAttractor, Runnable {}

  *() {
    input = f<S> getInput;
  }
    
  void remember(S fact) {
    if (facts.add(fact))
      print("[Bot learned:] " + fact);
  }
  
  void assume(S fact) {
    if (assumptions.add(fact))
      print("[Bot assumes:] " + fact);
  }
  
  S getInput() {
    while (empty(inputQueue))
      sleep(10);
    ret trim(popFirst(inputQueue));
  }
  
  bool yes() {
    ret callF(isYes, input());
  }
  
  // call this instead of run() so thread is marked
  void run_public() {
    temp tempAddToCollection(activeThreads, currentThread());
    run();
  }
  
  void addInput(S s) {
    inputQueue.add(s);
    if (empty(activeThreads))
      attractorBattle();
  }
  
  void attractorBattle {
    if (empty(inputQueue)) ret;
    S input = getInput();
    print("Input: " + input);
    
    // high prio active, then standing attractors, then low prio active
    L<Attractor> attractors = getAndClearList(activeAttractors);
    addAll(attractors, standardAttractors);
    addAll(attractors, getAndClearList(lowPrioAttractors));
    
    if (empty(attractors)) ret with print("No attractors, ignoring input");
    new L<Attractor> matchingAttractors;
    for (Attractor a : attractors) pcall {
      if (a.matches(input))
        matchingAttractors.add(a);
    }
    if (empty(matchingAttractors))
      ret with print("No matching attractors, ignoring input");
    print("Got " + n2(matchingAttractors, "matching attractor") + ": " + matchingAttractors);
    Attractor winner = first(matchingAttractors);
    if (l(matchingAttractors) > 1) print("Choosing first attractor");
    winner.run();
  }
  
  void addAttractor(Attractor a) { addAttractors(a); }
  void addAttractors(Attractor... attractors) {
    addAll(activeAttractors, attractors);
  }
  
  void addLowPrioAttractor(Attractor a) { add(lowPrioAttractors, a); }
  
  void standardAttractors(Attractor... attractors) {
    addAll(standardAttractors, attractors);
  }
  
  void addPreprocessors(O... l) {
    addAll(preprocessors, l);
  }
}