!7

cmodule StatementFulfillments > DynObjectTable<GazelleFulfillment> {
  transient ReliableSingleThread rstSearch = dm_rst(this, r search);
  transient Flag cancel;
  
  start {
    set fieldsInOrder;
    
    dm_vmBus_onMessage_q('newDiscordLine, voidfunc(O line) {
      new L<GazelleFulfillment> list;
      scanLines(ll(dm_discord_importLine(line)), list, 100, null);
      addAll(list);
    });
    
    dm_vmBus_onMessage('gazelleRuleCreated, rstSearch); // TODO: optimize
  }
  
  visualize {
    ret withCenteredButtons(super.visualize(), "Search Chat", rstSearch);
  }
  
  void search {
    new Flag cancel;
    this.cancel = cancel;
    new L<GazelleFulfillment> list;
    
    // "john doe is a guy"
    L<GazelleLine> lines = dm_discord_allLines();
    print("Scanning " + n2(lines, "line"));
    
    gazelle_gatherFulfillments(lines, list, maxEntries := 1000, +cancel);
    
    print("Scan yielded " + n2(list, "entry", "entries"));
    setList(list);
  }
  
  // API
  
  L<GazelleFulfillment> entriesForRule(S ruleID) {
    ret filterWhere(list(), rule := ruleID);
  }
}