!7

cmodule TomiiBoiAnswers > DynPrintLogAndEnabled {
  switchable int port = 8080;
  switchable S frontendName = "tomiiBoiDiscordBot";
  
  transient CRUD<Category> categoriesCRUD;
  transient CRUD<Server> serversCRUD;
  transient CRUD<Channel> channelsCRUD;
  transient CRUD<ServerToCategory> serverToCategoryCRUD;

  start {
    init();
    categoriesCRUD = new CRUD(Category);
    serversCRUD = new CRUD(Server);
    serverToCategoryCRUD = new CRUD(ServerToCategory);
    channelsCRUD = new CRUD(Channel);

    thread {
      dm_serveHttpFromFunction(port, lambda2 html);
      print("Admin live at: http://localhost:" + port);
      dm_registerAs('tomiiBoiQA);
    }
  }
  
  visualize {
    JComponent c = super.visualize();
    addComponents(buttons,
      jbutton("Open admin in browser", rThread { openURLInBrowser("http://localhost:" + port) }),
      jPopDownButton_noText(
        "Import data...", rThreadEnter importData));
    c = jtabs(
      "Main", c,
      "Categories", categoriesCRUD.visualize(),
      "Servers", serversCRUD.visualize(),
      "Server-to-category", serverToCategoryCRUD.visualize(),
      "Channels", channelsCRUD.visualize());
    channelsCRUD.addButton("Update list", rThreadEnter grabChannels);
    ret c;
  }
  
  void importData {
    selectFile("Tomii Brain File", voidfunc(File f) enter {
      replaceConceptsWithTextFileOnNextStart(f);
      dm_reloadModule();
    });
  }

  void grabChannels {
    dm_call(frontendName, 'grabChannels);
  }

  // API

  Server addServer(S serverID, S name) {
    ret csetAndReturn(uniq Server(+serverID), +name);
  }

  Channel addChannel(Server server, S channelID, S name) {
    ret csetAndReturn(uniq Channel(+server, +channelID), +name);
  }

  Channel channelForID(S channelID) {
    ret conceptWhere Channel(+channelID);
  }
}

//sS mainBotID = #1026411;
static int maxTypos = 1;

sS adminTitle = "Tomii Boi Chat Bot Admin";
sS shortLink; // catchy link to admin if available

sS embedderLink; // where chat bot will go
sS goDaddyEmbedCode;

static Cache<Scorer<ConsistencyError>> consistencyCheckResult = new(lambda0 consistencyCheck);

concept Server {
  S serverID, name;

  toString { ret name; }
}

concept ServerToCategory {
  Server server;
  Category category;
  bool enabled;

  sS _fieldOrder = "server category enabled";
}

concept Channel {
  Server server;
  S channelID;
  S name;
  bool botEnabled = true;

  toString { ret name; }
  sS _fieldOrder = "botEnabled name server";
}

concept Category {
  int index;
  S name;
  bool onByDefault = true;

  toString { ret name; }
}

concept Language {
  int index;
  S code;
}

concept QA {
  int index;
  S questions; // line by line
  S patterns; // to be determined
  S answers; // one answer, or "random { answers separated by empty lines }"
  S category; // "business", "smalltalk" etc.

  transient MMOPattern parsedPattern;

  sS _fieldOrder = "category index questions patterns answers";
  
  void change {
    parsedPattern = null;
    super.change();
  }
  
  MMOPattern parsedPattern() {
    if (parsedPattern == null)
      parsedPattern = mmo_parsePattern(patterns);
    ret parsedPattern;
  }
}

// keep these because otherwise deserialization breaks
concept Settings {}
concept Defaults {}

svoid init {
  processConceptsOverwriteFile();
  //print("fieldOrder", getFieldOrder(QA));
  dbIndexing(Category, 'index, Channel, 'channelID);
  print("QA count: " + countConcepts(QA));
  
  // categories, default category
  int i = 0;
  for (S category : ll("business", "smalltalk", "btd"))
    cset(uniq(Category, name := category), index := i++);
  cset(conceptsWhere QA(category := null), category := "business");
  
  onConceptsChange(r { consistencyCheckResult.clear(); });
  reindexQAs();
}

html { try {
  print(+uri);
    
  // force auth
  /*try answer callHtmlMethod(getBot(mainBotID), "/auth-only", mapPlus(
params, uri := rawLink(uri)));*/
    
  if (eq(uri, "/download"))
    ret serveText(conceptsStructure());
    
  HCRUD_Concepts<QA> data = new HCRUD_Concepts<QA>(QA) {
    S itemName() { ret "question"; }
    
    S fieldHelp(S field) {
      if (eq(field, "index"))
        ret "lower index = higher matching precedence";
      if (eq(field, "patterns"))
        ret [[Phrases to match. Use "+" as "and" operator, commas as "or" operator. Round brackets for grouping. Quotes for special characters. Put exclamation mark after phrase to disable typo correction.]];
      if (eq(field, "answers"))
        ret "Text of answer. Use random { ... } for multiple answers (separated from each other by an empty line)";
      null;
    }
    
    Renderer getRenderer(S field) {
      if (eqOneOf(field, 'questions, 'answers))
        ret new TextArea(80, 10);
      if (eq(field, 'patterns))
        ret new TextField(80);
      if (eq(field, 'category))
        ret new ComboBox(collect name(conceptsSortedByField(Category, 'index)));
      ret super.getRenderer(field);
    }
    
    // sort for display
    L<QA> defaultSort(L<QA> l) {
      ret sortedByCalculatedField(l, q -> pair(lower(q.category), q.index));
    }
  };
  data.onCreateOrUpdate.add(qa -> reindexQAs());
  
  HCRUD crud = new(rawLink(), data) {
    S frame(S title, S contents) {
      title = ahref(or2(shortLink, rawLink("")), adminTitle) + " | " + title;
      ret hhtml(hhead_title_decode(title)
        + hbody(h2(title)
        + p(joinWithVBar(
          targetBlank(rawLink("download"), "export brain"),
          ))
        + contents));
    }
    
    S renderTable(bool withCmds) {
      Scorer<ConsistencyError> scorer = consistencyCheckResult!;
      ret (empty(scorer.errors)
        ? p("Pattern analysis: No problems found. " + nEntries(countConcepts(QA)) + ".")
        : joinMap(scorer.errors, lambda1 renderErrorAsParagraph))
        + super.renderTable(withCmds);
    }
    
    S renderErrorAsParagraph(ConsistencyError error) {
      S fix = error.renderFix();
      ret p("Error: " + htmlEncode2(error.msg) + " " +
        joinMap(error.items, qa -> ahref(editLink(qa.id), "[item]"))
        + (empty(fix) ? "" : " " + fix));
    }
    
    S renderValue(S field, O value) {
      S html = super.renderValue(field, value);
      if (eq(field, "questions")) html = b(html);
      ret html;
    }
  };
  
  // actions

  if (eqGet(params, action := 'reindex)) {
    long id = parseLong(params.get('id));
    int newIndex = parseInt(params.get('newIndex));
    QA qa = getConcept(QA, id);
    if (qa == null) ret crud.refreshWithMsgs("Item not found");
    cset(qa, index := newIndex);
    reindexQAs();
    ret crud.refreshWithMsgs("Index of item " + qa.id + " changed");
  }

  crud.tableClass = "responstable";
  ret hsansserif() + hcss_responstable() + crud.renderPage(params);
 } catch print e {
  ret "ERROR.";
 }
}

// main API function for other bots
sS answer(S s, O... _) {
  optPar Server server;
  QA qa = findMatchingQA(s, qasForServer(server));
  if (qa == null) null;
  S raw = qa.answers;
  S contents = extractKeywordPlusBracketed_keepComments("random", raw);
  if (contents != null)
    ret random(splitAtEmptyLines(contents));
  ret raw;
}

static L<QA> qasForServer(Server server) {
  Set<S> categories = asSet(categoriesForServer(server));
  ret sortQAs(filter(list(QA), qa -> contains(categories, qa.category)));
}

static QA findQAWithTypos(S s, Cl<QA> qas) {
  Lowest<QA> qa = findClosestQA(s, qas);
  if (!qa.has()) null;
  if (qa.score() > maxTypos) {
    print("Rejecting " + nTypos((int) qa.score()) + ": " + s + " / " + qa->patterns);
    null;
  }
  print("Accepting " + nTypos((int) qa.score()) + ": " + s + " / " + qa->patterns);
  ret qa!;
}

static QA findMatchingQA(S s, Cl<QA> qas, bool allowTypos) {
  try object QA qa = findMatchingQA(s, qas);
  if (allowTypos)
    try object QA qa = findQAWithTypos(s, qas);
  null;
}

static Lowest<QA> findClosestQA(S s, Cl<QA> qas) {
  time "findClosestQA" {
    new Lowest<QA> qa;
    findClosestQA(s, qa, qas);
  }
  ret qa;
}

static L<QA> sortQAs(Cl<QA> qas) {
  Map<S, Int> categoryToIndex = fieldToFieldIndex('name, 'index, list(Category));
  ret sortedByCalculatedField(qas, q -> pair(categoryToIndex.get(q.category), q.index));
}

svoid reindexQAs() {
  int index = 1;
  for (QA qa : sortQAs(list(QA)))
    cset(qa, index := index++);
}

static QA findMatchingQA(S s, Cl<QA> qas) {
  for (QA qa : sortQAs(qas))
    if (mmo_match_parsedPattern(qa.parsedPattern(), s))
      ret qa;
  null;
}

svoid findClosestQA(S s, Lowest<QA> best, Cl<QA> qas) {
  for (QA qa : sortQAs(qas)) {
    Int score = mmo_levenWithSwapsScore_parsedPattern(qa.parsedPattern(), s);
    if (score != null)
      best.put(qa, score);
  }
}

sclass ConsistencyError {
  S msg;
  L<QA> items;
  
  *(S *msg, QA... items) { this.items = asList(items); }
  
  S renderFix() { null; }
}

svoid checkLocalConsistency(QA qa, Scorer<ConsistencyError> scorer) {
  LS questions = tlft(qa.questions);
  for (S q : questions)
    if (mmo_match_parsedPattern(qa.parsedPattern(), q))
      scorer.ok();
    else
      scorer.error(ConsistencyError("Question " + quote(q) + " not matched by patterns " + quote(qa.patterns), qa));
}

svoid checkGlobalConsistency(QA qa, Cl<QA> qas, Scorer<ConsistencyError> scorer) {
  for (S q : tlft(qa.questions)) {
    QA found = findMatchingQA(q, qas);
    if (found != null && found != qa)
      scorer.error(new ConsistencyError("Question " + quote(q) + " (item " + qa.id + ") shadowed by patterns " + quote(found.patterns) + " (item " + found.id + ")", qa, found) {
        S renderFix() {
          ret ahref(rawLink("?action=reindex&id=" + qa.id + "&newIndex=" + (found.index-1)), "[fix by changing index]");
        }
      });
    else
      scorer.ok();
  }
}

static Scorer<ConsistencyError> consistencyCheck() {
  new Scorer<ConsistencyError> scorer;
  scorer.collectErrors();
  for (QA qa) checkLocalConsistency(qa, scorer);
  for (Server server) {
    L<QA> qas = qasForServer(server);
    for (QA qa : qas)
      checkGlobalConsistency(qa, qas, scorer);
  }
  ret scorer;
}

// server can be null
static Cl<S> categoriesForServer(Server server) {
  Set<Category> set = asSet(conceptsWhere Category(onByDefault := true));
  if (server != null) for (ServerToCategory link : conceptsWhere(ServerToCategory, +server))
    addOrRemove(set, link.category, link.enabled);
  ret collectAsSet name(set);
}


// API

svoid importQA(virtual QA qa_external) {
  QA qa = shallowCloneToUnlistedConcept QA(qa_external);
  uniq QA(allConceptFieldsAsParams(qa));
}

sS rawLink() { ret "/"; }
sS rawLink(S uri) { ret addSlashPrefix(uri) ; }