!7

concept GFulfillment {
  !include #1022288
}

cmodule StatementFulfillments > DynCRUD<GFulfillment> {
  transient ReliableSingleThread rstSearch = dm_rst(this, r search);
  transient Flag cancel;
  
  transient GazelleContextCache_v2 contextCache;
  
  start {
    addCountToName();

    print("Making cache");
    time "Made cache" {
      contextCache = new GazelleContextCache_v2(this);
      contextCache.grabRules = func -> L<T3<S>> { dm_gazelle_rulesOnFacts() };
      ownResource(contextCache.listenToMessages());
      contextCache.fill();
    }

    dm_vmBus_onMessage_q('newDiscordLine, voidfunc(O line) {
      new L<GazelleFulfillment> list;
      gazelle_gatherFulfillments(ll(dm_discord_importLine(line)), list, maxEntries := 100);
      toConcepts(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, ctx := contextCache!);
    
    L preprocessed = cast dm_call(gazelle_preprocessedLinesCRUD(), 'concepts);
    L<GazelleLine> preprocessedLines = map gazelle_importPreprocessedLine(preprocessed);
    new L<GazelleFulfillment> list2;
    gazelle_gatherFulfillments(preprocessedLines, list2, maxEntries := 1000, +cancel, ctx := contextCache!);
    for (GazelleFulfillment f : list2)
      f.context += " (preprocessed)";
    
    print("Scan yielded " + n2(list, "entry", "entries"));
    deleteConcepts(GFulfillment);
    toConcepts(list);
    toConcepts(list2);
  }
  
  void toConcepts(L<GazelleFulfillment> l) {
    Collection<S> fields = conceptFields(GFulfillment);
    if (l != null) for (GazelleFulfillment f : l) {
      GFulfillment c = ccopyFields2_fromGen(f, new GFulfillment, fields);
      assertSame(c._concepts, conceptsObject());
    }
  }

  // API
  
  L<GFulfillment> entriesForRule(S ruleID) {
    ret conceptsWhere GFulfillment(rule := ruleID);
  }
  
  L<GFulfillment> entriesForContext(S context) {
    ret conceptsWhere GFulfillment(+context);
  }
  
  void triggerSearch {
    rstSearch.trigger();
  }
}

Began life as a copy of #1021745