Warning : session_start(): open(/var/lib/php/sessions/sess_f65n4h35d1qke1r2kec4s3i4im, O_RDWR) failed: No space left on device (28) in /var/www/tb-usercake/models/config.php on line 51 Warning : session_start(): Failed to read session data: files (path: /var/lib/php/sessions) in /var/www/tb-usercake/models/config.php on line 51 dynamicObjectIsLoading_threadLocal() {
return DynamicObject_loading;
}
static public class BEACalculations {
public GazelleBEA mod;
public BEACalculations(GazelleBEA mod) {
this.mod = mod;
}
transient public int liveOutputDelay = 1000;
transient public double algoTimeout = 30.0;
public void reactAllInputsWithSomePatterns() {
for (BEAObject input : mod.beaObjectsOfType("input")) {
ReactInputWithSomePatterns r = new ReactInputWithSomePatterns();
r.input = input;
r.ccOut = db_mainConcepts();
r.max = 10;
r.start();
stepAllWithTimeout(10.0, r);
}
}
public void reactAllInputsWithAllSyntacticPatterns() {
for (BEAObject input : mod.beaList("input")) {
ping();
for (BEAObject pattern : mod.beaList("Syntactic Pattern")) {
ping();
{
if (patternAlwaysMatches(pattern))
continue;
}
reactInputWithPattern(input, pattern);
}
}
}
public void reactAllInputsWithPattern(BEAObject pattern) {
for (BEAObject input : mod.beaList("input")) {
ping();
reactInputWithPattern(input, pattern);
}
}
public boolean patternAlwaysMatches(BEAObject pat) {
return isTrue_getOpt("alwaysMatches", pat);
}
public class ReactInputWithSomePatterns implements Steppable {
public BEAObject input;
public Concepts ccOut;
public int max = 3, n;
public Iterator patterns;
public void start() {
n = countConceptsWhereIC(ccOut, BEAObject.class, "input", input, "type", "match");
patterns = iterator(sortByConceptID(conceptsWhereIC(BEAObject.class, "type", "Pattern")));
}
public boolean step() {
if (n >= max)
return false;
if (!patterns.hasNext())
return false;
if (reactInputWithPattern(input, patterns.next(), ccOut) != null)
++n;
return true;
}
}
public Pair> matchInputWithPatternList(String text, BEAObject patternList) {
List patterns = (List) (cget("patterns", patternList));
for (BEAObject pattern : unnullForIteration(patterns)) {
Map mapping = matchInputWithPattern(text, pattern);
if (mapping != null)
return pair(pattern, mapping);
}
return null;
}
public ThreadLocal matchInput_droppedPunctuation = new ThreadLocal();
public Map matchInputWithPattern(BEAObject input, BEAObject pattern) {
String text = getString("text", input);
return matchInputWithPattern(text, pattern);
}
public Map matchInputWithPattern(String text, BEAObject pattern) {
String pat = getString("text", pattern);
boolean punctuationOnly = isTrue_getOpt("punctuationOnly", pattern);
if (pattern.typeIs("Syntactic Pattern"))
return matchInputWithSyntacticPattern(text, pat, punctuationOnly);
else if (eqic_gen(getOpt("subType", pattern), "PhraseCache"))
return phraseCache(pat, text) ? litmap() : null;
else
return matchInputWithPattern(text, pat, punctuationOnly);
}
public Map matchInputWithSyntacticPattern(String text, String pat) {
return matchInputWithSyntacticPattern(text, pat, false);
}
public Map matchInputWithSyntacticPattern(String text, String pat, boolean punctuationOnly) {
pat = starsToAngleBracketedNumbers(pat);
return matchInputWithPattern(text, pat, punctuationOnly);
}
public Map matchInputWithPattern(String text, String pat) {
return matchInputWithPattern(text, pat, false);
}
public Map matchInputWithPattern(String text, String pat, boolean punctuationOnly) {
Map mapping = flexMatchAngleBracketVarsIC_honorPunctuation_noBrackets_first(pat, text);
if (mapping != null || punctuationOnly)
return mapping;
return null;
}
public BEAObject reactInputWithPattern(BEAObject input, BEAObject pattern) {
return reactInputWithPattern(input, pattern, db_mainConcepts());
}
public BEAObject reactInputWithPattern(BEAObject input, BEAObject pattern, Concepts ccOut) {
if (input == null || pattern == null)
return null;
matchInput_droppedPunctuation.set(false);
Map mapping = matchInputWithPattern(input, pattern);
if (mapping == null)
return null;
BEAObject match = uniqCI(ccOut, BEAObject.class, "type", "Match", "input", input, "pattern", pattern);
cset(match, "mapping", mapping, "droppedPunctuation", trueOrNull(matchInput_droppedPunctuation.get()));
return match;
}
public Object serveAnalyzeInput(GazelleBEA.Req req) {
Concepts ccOut = new Concepts();
BEAObject input = getConcept(BEAObject.class, parseLong(req.get("id")));
if (input == null)
input = cnew(ccOut, BEAObject.class, "type", "Input", "text", req.get("q"));
String text = getString("text", input);
ReactInputWithSomePatterns r = new ReactInputWithSomePatterns();
r.input = input;
r.ccOut = ccOut;
r.max = 1000;
r.start();
stepAllWithTimeout(10.0, r);
List matches = conceptsWhereIC(ccOut, BEAObject.class, "type", "Match");
return h1_title("Analyze Input") + p("Input: " + b(htmlEncode_nlToBr_withIndents(text))) + p(empty(matches) ? "No matches" : "Matches") + ul_htmlEncode(matches);
}
public Object serveQueryPage(GazelleBEA.Req req) {
return serveQueryPage(req, false);
}
public Object serveQueryPage(GazelleBEA.Req req, boolean withFrame) {
String q = req.get("q"), algorithm = req.get("algorithm");
boolean dontRun = eq(req.get("dontRun"), "1");
boolean liveOutput = eq(req.get("liveOutput"), "1");
if (liveOutput)
req.noSpam();
if (eqic(algorithm, "process input"))
algorithm = "Process new input v3";
Map> algorithms = litorderedmap("Process new input v3", (IF0) () -> new ProcessNewInput_v3(), "Process new input v2", (IF0) () -> new ProcessNewInput_v2(), "Process new input", (IF0) () -> new ProcessNewInput(), "Run pattern", (IF0) () -> new RunPattern(), "Find rewrites for match", (IF0) () -> new FindRewrites(), "Reverse input (test algorithm)", (IF0) () -> new ReverseInput(), "Timeout test", (IF0) () -> new TimeoutTest(), "Syntactic pattern from input", (IF0) () -> new SyntacticPatternFromInput(), "Apply all text functions", (IF0) () -> new ApplyTextFunctions(), "Find Path", (IF0) () -> new FindPath(), "Execute text query", (IF0) () -> new ExecuteTextQuery(), "Make syntactic patterns for all patterns in DB", (IF0) () -> new MakeSyntacticPatterns(), "Input summary", (IF0) () -> new InputSummary(), "Apply pattern list", (IF0) () -> new ApplyPatternList(), "Apply regular expression replacement to all inputs", (IF0) () -> new ApplyRegExpReplacement(), "Match input with all pattern lists", (IF0) () -> new MatchInputWithAllPatternLists(), "Apply algorithm object", (IF0) () -> new ApplyAlgorithmObject(), "Run test cases on code post", (IF0) () -> new RunTestCasesOnCodePost());
String output = empty(algorithm) || dontRun ? null : doAlgorithm(algorithms, algorithm, q, liveOutput);
if (liveOutput)
return jsonEncode(litorderedmap("answer", output));
String right = withFrame ? "" : mod.html_loggedIn();
Algorithm alg = callF(lookupPossiblyCI(algorithms, algorithm));
if (alg != null) {
alg.q = q;
alg.req = mod.currentReq.get();
}
String centered = (withFrame ? "" : htitle_h2(ahref(mod.baseLink + "/", "Gazelle") + " Query" + htmlEncode2((empty(q) ? "" : ": " + q) + appendSquareBracketed(algorithm)))) + hscript(replaceVars("\r\n var sugLoading = false, sugTriggerAgain = false;\r\n\r\n function sugTrigger() {\r\n console.log(\"sugTrigger\");\r\n if (sugLoading) { sugTriggerAgain = true; return; }\r\n\r\n // get form data as JSON\r\n \r\n var data = {\r\n \"liveOutput\" : \"1\",\r\n \"q\": $(\"textarea[name=q]\").val(),\r\n \"algorithm\": $(\"select[name=algorithm]\").val(),\r\n \"algorithmID\": $(\"select[name=algorithmID]\").val(), // XXX: do this for all additional alg parameters\r\n };\r\n \r\n const url = \"/query\";\r\n console.log(\"Loading \" + url + \" with \" + data);\r\n sugLoading = true;\r\n $.post(url, data,\r\n function(result) {\r\n console.log(\"Suggestor result: \" + result);\r\n const answer = !result ? \"\" : JSON.parse(result).answer;\r\n if (answer) {\r\n $(\"#liveResult .sectionContents\").html(answer);\r\n $(\"#liveResult\").show();\r\n } else\r\n $(\"#liveResult\").hide();\r\n //$(\"#suggestorResult\").html(answer ? \"Suggestor says: \" + answer : \"\");\r\n }\r\n ).always(function() {\r\n console.log(\"sug loading done\");\r\n setTimeout(function() {\r\n sugLoading = false;\r\n if (sugTriggerAgain) { sugTriggerAgain = false; sugTrigger(); }\r\n }, liveOutputDelay);\r\n });\r\n }\r\n\r\n $(document).ready(function() {\r\n $(\"textarea[name=q], input[name=q], select[name=algorithm]\").on('input propertychange change', sugTrigger);\r\n sugTrigger();\r\n });\r\n ", "liveOutputDelay", liveOutputDelay)) + hform(p("Query (Ctrl+Enter): " + htextarea(q, "id", "mainInput", "name", "q", "class", "auto-expand", "style", "width: 300px", "onkeydown", jquery_submitFormOnCtrlEnter(), "autofocus", dontRun || empty(q) ? true : null) + " " + (alg == null ? "" : alg.additionalInputs()) + " Algorithm: " + hselect_list(keys(algorithms), algorithm, "name", "algorithm") + " " + hbutton("Go")));
String content = (empty(right) ? "" : div_alignRight(right)) + div_center(centered) + htitledSectionWithDiv("Live Result", "", "id", "liveResult", "style", "display: none", "innerDivStyle", "max-height: 150px; overflow: auto") + (output == null ? "" : h3(algorithm) + output);
if (withFrame) {
req.framer.addInHead(hjs_handleScrollToAnchor());
req.framer.add(content);
return mod.completeFrame(req);
} else
return hhtml(hhead(hmobilefix() + hsansserif() + loadJQuery2() + hjs_handleScrollToAnchor() + hjs_autoExpandingTextAreas() + mod.webSocketHeadStuff(req) + hNotificationPopups()) + hbody(content));
}
public String doAlgorithm(Map> algorithms, String algorithm, String q, boolean liveMode) {
GazelleBEA.Req req = mod.currentReq.get();
StringBufferWithMaxSize out = new StringBufferWithMaxSize(1000000);
IF0 algo = lookupPossiblyCI(algorithms, algorithm);
if (algo == null)
out.append("Algorithm not found: " + algorithm);
else {
if (isB(evalWithTimeout(algoTimeout, new Runnable() {
public void run() {
try {
AutoCloseable __15 = mod.enter();
try {
AutoCloseable __16 = tempSetTL(mod.currentReq, req);
try {
Algorithm alg = algo.get();
alg.liveMode = liveMode;
alg.out = out;
alg.q = q;
alg.req = mod.currentReq.get();
alg.runIt();
} finally {
_close(__16);
}
} finally {
_close(__15);
}
} catch (Exception __e) {
throw rethrow(__e);
}
}
public String toString() {
return "temp mod.enter();\r\n temp tempSetTL(mod.currentReq, req);\r\n Algo...";
}
})))
out.append("\n[algorithm timeout]");
}
return str(out);
}
public class Algorithm implements Runnable {
public String q;
public GazelleBEA.Req req;
public Appendable out;
public boolean liveMode = false;
public Concepts localConcepts = db_mainConcepts();
public List nonMatches;
public void run() {
}
public void runLiveMode() {
}
public String additionalInputs() {
return "";
}
public void appendHTML(String html) {
appendHTML(this.out, html);
}
public void appendHTML(Appendable out, String html) {
try {
if (empty(html))
return;
html = wrapInDiv(html, "style", "margin-top: 0.5em");
out.append(html).append("\n");
} catch (Exception __e) {
throw rethrow(__e);
}
}
public void appendHTML_raw(String html) {
try {
out.append(html).append("\n");
} catch (Exception __e) {
throw rethrow(__e);
}
}
public void appendText(String text) {
appendText(this.out, text);
}
public void appendText(Appendable out, String text) {
try {
if (empty(text))
return;
out.append(hpre_htmlencode(rtrim(text)));
} catch (Exception __e) {
throw rethrow(__e);
}
}
public void appendTextBold(String text) {
appendTextBold(this.out, text);
}
public void appendTextBold(Appendable out, String text) {
try {
if (empty(text))
return;
out.append(b(hpre_htmlencode(rtrim(text))));
} catch (Exception __e) {
throw rethrow(__e);
}
}
public void allowSuggestingAnswer(BEAObject input) {
if (input == null)
return;
String text = input.text();
String url = mod.baseLink + "/saveAnswer";
appendHTML(hpostform("Suggest an answer to " + htmlEncode_quote(text) + ": " + htextarea(text, "id", "suggestAnswer", "name", "text", "class", "auto-expand", "style", "width: 300px") + hhidden("inputID", input.id) + hhidden("redirect", "") + " " + hsubmit("Save answer") + " [Optional rewrite type: " + hinputfield("rewriteType", "style", "width: 100px") + " ]", "action", url, "onsubmit", js_setRedirect()));
}
public void allowSuggestingPattern(BEAObject input) {
if (input == null)
return;
String text = input.text();
String url = mod.baseLink + "/savePattern";
appendHTML(hpostform("Suggest a pattern (with angle bracket vars): " + htextarea(text, "name", "text", "class", "auto-expand", "style", "width: 300px") + hhidden("fromInput", conceptIDOrNull(input)) + hhidden("userTyped", true) + hhidden("redirect", "") + " " + hsubmit("Save pattern"), "action", url, "onsubmit", js_setRedirect()));
}
public void allowSuggestingSyntacticPattern(BEAObject input) {
if (input == null)
return;
String text = input.text();
String url = mod.baseLink + "/saveSyntacticPattern";
appendHTML(hpostform("Suggest a syntactic pattern (with * vars): " + htextarea(text, "name", "text", "class", "auto-expand", "style", "width: 300px") + hhidden("fromInput", conceptIDOrNull(input)) + hhidden("userTyped", true) + hhidden("redirect", "") + " " + hsubmit("Save syntactic pattern"), "action", url, "onsubmit", js_setRedirect()));
}
public BEAObject saveInput(String q) {
Pair p = uniqCI2(BEAObject.class, "type", "Input", "text", q);
BEAObject input = p.a;
mod.saveUserAgent(input);
if (p.b) {
csetIfUnset(input, "createdBy", mod.user(mod.currentReq.get()));
appendHTML("Input saved");
}
return input;
}
public void runNonMatches() {
if (nempty(nonMatches)) {
appendHTML(hr());
callFAll(nonMatches);
}
}
public void addNonMatch(Runnable r) {
add(nonMatches, r);
}
public void runIt() {
if (liveMode)
runLiveMode();
else
run();
runNonMatches();
}
}
public class ReverseInput extends Algorithm {
public void run() {
appendText(reversed(q));
}
public void runLiveMode() {
run();
}
}
public class TimeoutTest extends Algorithm {
public void run() {
sleepSeconds(120);
}
}
public class RunPattern extends Algorithm {
public void run() {
BEAObject pattern = mod.beaGet(parseFirstLong(q));
if (pattern == null) {
appendText("Pattern not found");
return;
}
appendText("Pattern: " + pattern);
for (BEAObject input : mod.beaList("Input")) {
String text = input.text();
Map mapping = matchInputWithPattern(input, pattern);
if (mapping == null)
addNonMatch(new Runnable() {
public void run() {
try {
appendText("Checking Input: " + input + " - No match");
} catch (Exception __e) {
throw rethrow(__e);
}
}
public String toString() {
return "appendText(\"Checking Input: \" + input + \" - No match\");";
}
});
else {
String result = "\n" + renderMappingAsText(mapping);
appendText("Checking Input: " + input + result);
allowStoringMatch(this, input, pattern, mapping);
}
}
}
}
public String renderMappingAsText(Map mapping) {
return indent(formatDoubleArrowMap_horizontallyAligned(mapping));
}
public class FindRewrites extends Algorithm {
public void run() {
BEAObject match = mod.beaGet(parseFirstLong(q));
if (match == null || !match.typeIs("Match")) {
appendText("Match not found");
return;
}
BEAObject pattern = (BEAObject) (cget("pattern", match));
BEAObject input = (BEAObject) (cget("input", match));
Map mapping = (Map) (get("mapping", match));
appendText("Match: " + match);
appendText("Input: " + input);
appendText("Pattern: " + pattern);
appendText("Mapping:\n" + renderMappingAsText(mapping));
appendRewrites(this, input, input.text(), pattern, match, mapping);
}
}
public List appendRewrites(Algorithm algo, BEAObject input, String inputText, BEAObject pattern, BEAObject match, Map mapping) {
Collection rewrites = mod.beaBackRefs(pattern, "Rewrite");
List texts = new ArrayList();
for (BEAObject r : rewrites) {
String text = r.text();
String textWithVars = text;
if (pattern.typeIs("Syntactic pattern"))
textWithVars = starsToAngleBracketedNumbers(text);
String text2 = replaceAngleBracketVars_curly(textWithVars, mapping);
algo.appendText(" Using pattern rewrite: " + text);
algo.appendTextBold(" " + inputText + "\n" + " => " + text2);
texts.add(text2);
BEAObject existing = match == null || input == null ? null : conceptWhereIC(BEAObject.class, "type", "Rewrite", "input", input, "text", text2, "match", match, "patternRewrite", r, "label", "good");
if (existing != null)
algo.appendHTML("Rewrite exists: " + mod.beaLinkHTML(existing));
else if (match == null)
algo.appendText("[Can't save, no match]");
else if (input == null)
algo.appendText("[Can't save, no input object]");
else
algo.appendHTML(hinlinepostform(hhiddenMulti("action", "create", "f_type", "Rewrite", "f_text", text2, "f_input", input.id, "metaInfo_input", "concept", "f_match", match.id, "metaInfo_match", "concept", "f_patternRewrite", r.id, "metaInfo_patternRewrite", "concept", "f_label", "good") + hbutton("Good rewrite"), "target", "_blank", "action", mod.crudLink(BEAObject.class)));
}
return texts;
}
public class ProcessNewInput extends Algorithm {
public void run() {
BEAObject input = handleInput(this, q = trim(q), false);
for (BEAObject pattern : mod.beaListAny("Pattern", "Syntactic Pattern")) {
checkPattern(this, input, q, pattern);
}
}
}
public void checkPattern(Algorithm algo, BEAObject input, String q, BEAObject pattern) {
Map mapping = matchInputWithPattern(q, pattern);
if (mapping == null)
algo.addNonMatch(new Runnable() {
public void run() {
try {
algo.appendText("Checking Pattern: " + pattern + " - No match");
} catch (Exception __e) {
throw rethrow(__e);
}
}
public String toString() {
return "algo.appendText(\"Checking Pattern: \" + pattern + \" - No match\");";
}
});
else {
String result = "\n" + renderMappingAsText(mapping);
algo.appendText("Checking Pattern: " + pattern + result);
if (input == null) {
} else
allowStoringMatch(algo, input, pattern, mapping);
appendRewrites(algo, input, q, pattern, null, mapping);
}
}
public class ProcessNewInput_v2 extends Algorithm {
public void run() {
q = trim(q);
saveInput(q);
BEAObject input = handleInput(this, q, false);
if (input != null) {
Collection rewrites = mod.beaBackRefs(input, "Rewrite");
BEAObject rewrite = random(rewrites);
if (rewrite != null)
appendHTML("My answer: " + b(htmlEncode2(rewrite.text())) + " " + ahref(mod.beaShortURL(rewrite), "[source]"));
}
allowSuggestingAnswer(input);
allowSuggestingPattern(input);
allowSuggestingSyntacticPattern(input);
for (BEAObject pattern : syntacticPatternsSortedBySpecificityDesc()) {
{
if (patternAlwaysMatches(pattern))
continue;
}
Map mapping = matchInputWithPattern(q, pattern);
if (mapping == null)
addNonMatch(new Runnable() {
public void run() {
try {
appendHTML("Checking Syntactic Pattern: " + mod.beaLinkHTML(pattern) + " - No match");
} catch (Exception __e) {
throw rethrow(__e);
}
}
public String toString() {
return "appendHTML(\"Checking Syntactic Pattern: \" + mod.beaLinkHTML(pattern) + \" - No...";
}
});
else {
String result = "Grouped as: " + replaceAngleBracketVars_curly(starsToAngleBracketedNumbers(pattern.text()), mapping) + "\n" + renderMappingAsText(mapping);
appendHTML(hr());
appendHTML("Checking Syntactic Pattern: " + mod.beaLinkHTML(pattern));
appendText(result);
BEAObject match = null;
if (input == null) {
} else
match = allowStoringMatch(this, input, pattern, mapping);
MultiMap subInputRewrites = ciMultiMap();
for (String subInput : uniquifyCI(values(mapping))) if (!eqic(subInput, q)) {
BEAObject subInputObj = handleInput(this, subInput, "Sub-Input", true);
if (subInputObj != null) {
List subRewrites = concatLists(conceptsWhereCI(BEAObject.class, "type", "Rewrite", "input", subInputObj), conceptsWhereCI(BEAObject.class, "type", "Rewrite", "isRewriteOf", subInputObj));
for (BEAObject r : subRewrites) appendHTML(" Sub-Rewrite found: " + r);
subInputRewrites.putAll(subInput, subRewrites);
}
}
appendRewrites(this, input, q, pattern, match, mapping);
Map rewrittenMapping = mapValues(mapping, s -> {
BEAObject rewrite = random(subInputRewrites.get(s));
return rewrite == null ? s : uncurly(rewrite.text());
});
String randomRewrite = replaceAngleBracketVars_curly(starsToAngleBracketedNumbers(pattern.text()), rewrittenMapping);
if (neq(randomRewrite, q))
appendText("Random rewrite from sub-inputs: " + randomRewrite);
}
}
}
}
public class ProcessNewInput_v3 extends Algorithm {
public void run() {
q = trim(q);
saveInput(q);
BEAObject input = handleInput(this, q, false);
HTMLTabs tabs = new HTMLTabs();
{
StringBuffer toTab = new StringBuffer();
Algorithm alg = new ProcessNewInput_v2();
alg.q = q;
alg.out = toTab;
alg.runIt();
tabs.add("Match input with patterns", toTab);
}
{
StringBuffer toTab = new StringBuffer();
Algorithm alg = new SyntacticPatternFromInput();
alg.q = q;
alg.out = toTab;
alg.runIt();
tabs.add("Make syntactic pattern", toTab);
}
appendHTML(tabs.html());
}
}
public BEAObject allowStoringMatch(Algorithm algo, BEAObject input, BEAObject pattern, Map mapping) {
BEAObject match = conceptWhereCI(BEAObject.class, "type", "Match", "pattern", pattern, "input", input, "mapping", mapping);
if (match != null) {
algo.appendHTML("Match exists: " + mod.beaLinkHTML(match));
return match;
}
algo.appendHTML(joinWithSpace(storeMatchForm(input, pattern, "good"), storeMatchForm(input, pattern, "bad")));
return null;
}
public String storeMatchForm(BEAObject input, BEAObject pattern, String label) {
return hinlinepostform(hhiddenMulti("pattern", pattern.id, "input", input.id, "label", label, "redirect", "") + hbutton(firstToUpper(label) + " match"), "action", mod.baseLink + "/storeMatch", "onsubmit", js_redirectAutoScroll2());
}
public class MakeSyntacticPatterns extends Algorithm implements Runnable {
public void run() {
for (BEAObject p : mod.beaList("Pattern")) {
appendText(p + " => " + makeSyntacticPattern(p));
}
}
}
public String syntacticPatternText(BEAObject p) {
return simpleSpacesTrim_javaTok(angleBracketVarsToStars(p.text()));
}
public BEAObject makeSyntacticPattern(BEAObject p) {
if (p == null || !p.typeIs("Pattern") || empty(p.text()))
return null;
String text = syntacticPatternText(p);
BEAObject sp = uniqCI(BEAObject.class, "type", "Syntactic Pattern", "text", text);
cset(p, "syntacticPattern", sp);
return sp;
}
public String processInputURL(String q) {
return addParamsToURL(mod.baseLink + "/query", "q", q, "algorithm", "process input");
}
public BEAObject handleInput(Algorithm algo, String q, boolean showProcessLink) {
return handleInput(algo, q, "Input", showProcessLink);
}
public BEAObject handleInput(Algorithm algo, String q, String desc, boolean showProcessLink) {
algo.appendHTML(hSingleRowTable_withSpacing((desc + ":"), tt(htmlEncode_nlToBr_withIndents(q)), !showProcessLink ? "" : targetBlank(processInputURL(q), "Process")));
BEAObject input = mod.findInput(q);
algo.appendHTML(inputHTML(input, desc, q));
return input;
}
public String inputHTML(BEAObject input, String q) {
return inputHTML(input, "Input", q);
}
public String inputHTML(BEAObject input, String desc, String q) {
return input != null ? (desc + " exists: ") + mod.beaLinkHTML(input) : !mod.requestAuthed() && !mod.allowAnonymousInputUpload ? null : hinlinepostform(hhiddenMulti("text", q, "redirect", "") + hbutton(("Save " + desc)), "action", mod.baseLink + "/saveInput", "onsubmit", js_setRedirect());
}
public String syntacticPatternLinkHTML(BEAObject obj, String text) {
return syntacticPatternLinkHTML(obj, text, null);
}
public String syntacticPatternLinkHTML(BEAObject obj, String text, BEAObject fromInput) {
String desc = "Syntactic pattern";
return obj != null ? mod.beaLinkHTML(obj) : !mod.requestAuthed() ? null : hinlinepostform(hhiddenMulti("text", text, "fromInput", conceptIDOrNull(fromInput), "redirect", "") + hbutton(("Save " + (firstToLower(desc)))), "action", mod.baseLink + "/saveSyntacticPattern", "onsubmit", js_setRedirect());
}
public class SyntacticPatternFromInput extends Algorithm implements Runnable {
public void run() {
BEAObject input = handleInput(this, q, false);
if (countTokens(q) > 10) {
appendText("Input too long to extract syntactic patterns");
return;
}
String q2 = dropPunctuation(q);
List data = new ArrayList();
for (String pat : sortedIC(gazelle_allSyntacticPatternsFromInput(q))) {
Map mapping = matchInputWithSyntacticPattern(q2, pat);
BEAObject obj = conceptWhereIC(BEAObject.class, "type", "Syntactic Pattern", "text", pat);
Map row = litorderedmap("Syntactic Pattern", htmlEncode2(pat), "In database", syntacticPatternLinkHTML(obj, pat, input));
for (Map.Entry __13 : _entrySet(mapping)) {
String key = __13.getKey();
String val = __13.getValue();
row.put("Argument " + key, htmlEncode2(val));
}
data.add(row);
}
appendHTML(htmlTable2_noHtmlEncode(data));
}
}
public class ApplyTextFunctions extends Algorithm {
public void run() {
q = trim(q);
saveInput(q);
BEAObject input = handleInput(this, q, false);
LinkedHashSet objectsMade = new LinkedHashSet();
for (BEAObject f : mod.beaList("JavaX Standard Function")) {
try {
addIfNotNull(objectsMade, reactFunctionWithInput(this, f, input));
} catch (Throwable __e) {
_handleException(__e);
}
}
appendHTML(h3("Results of function calls"));
HCRUD crud = mod.makeCRUD(BEAObject.class, mod.currentReq.get());
HCRUD_Concepts crudData = (HCRUD_Concepts) (crud.data);
crudData.listConcepts_firstStep = () -> objectsMade;
appendHTML(crud.renderTable(true));
}
}
public class FindPath extends Algorithm {
public BreadthFirstPathFinder_withLinkType pathFinder = new BreadthFirstPathFinder_withLinkType();
public BEAObject start, dest;
public void run() {
start = mod.beaGet(parseFirstLong(q));
dest = mod.beaGet(parseSecondLong(q));
if (start == null || dest == null) {
appendText("Please supply object IDs of start and end");
return;
}
appendHTML("Looking for path from " + mod.beaToHTML(start) + " to " + mod.beaToHTML(dest));
pathFinder.getChildren = o -> cForwardAndBackRefsWithFieldIndicator(BEAObject.class, o);
pathFinder.add(start);
while (!pathFinder.nodeReached(dest) && pathFinder.step()) {
}
List> path = pathFinder.examplePathWithTypes(start, dest);
if (path == null)
appendText("No path found!");
else {
appendHTML(b("Path found!"));
appendHTML(ol(map(path, p -> {
String html = mod.beaHTML(p.a);
if (p.b == null)
return html;
String arrow = ifThenElse(p.b.forward, ">>", "<<");
return html + " " + htmlEncode2(joinNemptiesWithSpace(arrow, p.b.field, arrow));
})));
}
}
}
public class ExecuteTextQuery extends Algorithm {
public void run() {
saveInput(q = trim(q));
appendHTML(h3("Result"));
appendHTML(htmlEncode2(strOrEmpty(executeTextQuery(q))));
}
}
public class InputSummary extends Algorithm {
public void run() {
BEAObject mainInput = saveInput(q = trim(q));
Collection inputs = conceptsWhere(BEAObject.class, "type", "Input", "text", q);
if (l(inputs) > 1)
appendHTML("Note: Input appears " + l(inputs) + " times in the database: " + joinWithSpace(map(o -> mod.beaToHTML(o), inputs)));
for (BEAObject input : inputs) {
if (input != mainInput) {
appendHTML(hr());
appendHTML("Input: " + input);
}
Collection rewrites = mod.beaBackRefs(input, "Rewrite");
if (empty(rewrites))
appendHTML(h3("No rewrites"));
else
for (Pair __11 : iterateWithIndex1(rewrites)) {
int i = pairA(__11);
BEAObject r = pairB(__11);
appendHTML("Rewrite " + i + ": " + ahref(mod.beaURL(r), tok_dropCurlyBrackets(r.text())));
}
}
}
}
public class ApplyPatternList extends Algorithm {
public String additionalInputs() {
return hselect("patternListID", mapToKey(__44 -> conceptID(__44), mod.beaList("Pattern List")), req.get("patternListID"));
}
public void run() {
BEAObject input = handleInput(this, q = trim(q), false);
BEAObject patternList = mod.beaGet("patternListID", req);
if (patternList == null)
return;
List patterns = (List) (cget("patterns", patternList));
appendHTML("Pattern list: " + mod.beaHTML(patternList));
for (BEAObject pattern : unnullForIteration(patterns)) {
appendText("Trying pattern " + pattern);
checkPattern(this, input, q, pattern);
}
}
}
public class ApplyAlgorithmObject extends Algorithm {
public String additionalInputs() {
return hselect("algorithmID", mapToKey(__45 -> conceptID(__45), concatLists(wideningListCast(Concept.class, list(BEARegExpReplacement.class)), wideningListCast(Concept.class, conceptsWhereIC(UserPost.class, "type", "JavaX Code (HTML Bot)")))), req.get("algorithmID"));
}
public void runLiveMode() {
Concept algo = getConcept(parseLongOpt(req.get("algorithmID")));
appendHTML("Algorithm object: " + htmlEncode2_nlToBr(str(algo)));
if (algo instanceof UserPost) {
Object result = mod.callHtmlBot_dropMadeByComment(((UserPost) algo).id, req.params());
appendText("Result: " + result);
} else if (algo instanceof BEARegExpReplacement) {
Object result = ((BEARegExpReplacement) algo).apply(q);
appendText("Result: " + result);
} else if (algo == null)
appendText("Algorithm object not found");
else
appendText("Unknown algorithm object type: " + _className(algo));
}
}
public class ApplyRegExpReplacement extends Algorithm {
public void run() {
BEARegExpReplacement regExpReplacement = (BEARegExpReplacement) (mod.beaGet(q));
if (regExpReplacement == null) {
appendText("Please enter reg exp replacement ID");
return;
}
appendHTML("Applying " + beaHTML(regExpReplacement));
for (BEAObject input : sortedByConceptIDDesc(mod.beaList("Input"))) {
String text = input.text();
String replaced = regExpReplacement.apply(text);
if (neq(text, replaced)) {
appendHTML(hr());
appendText(" " + text + "\n=> " + replaced);
appendPossibleRewrite(this, input, replaced, litmap("f_regularExpression", regExpReplacement.id, "metaInfo_regularExpression", "concept"));
}
}
}
}
public class BackEndAlgorithm extends Algorithm {
public String prefix() {
return shortClassName(this) + ": ";
}
@Override
public void appendText(String s) {
printWithIndent(prefix(), s);
}
@Override
public void appendHTML(String s) {
appendText(htmlDecode_dropTags(s));
}
@Override
public void addNonMatch(Runnable r) {
r.run();
}
}
public class MatchInputWithAllPatternLists extends Algorithm {
public void run() {
BEAObject input = saveInput(q);
for (BEAObject patternList : sortedByConceptIDDesc(beaList("Pattern List"))) reactInputWithPatternList(this, input, q, patternList, 1, 2);
}
}
public class RunTestCasesOnCodePost extends Algorithm {
public String additionalInputs() {
MultiSet ms = distinctCIFieldValuesOfConcepts_multiSet(BEAObject.class, "type");
List types = filter(pairsA(multiSetToPairsByPopularity(ms)), type -> cic(type, "test case"));
return "Test case type: " + hselect_list("testCaseType", types, req.get("testCaseType")) + " " + hselect("algorithmID", mapToKey(__46 -> conceptID(__46), conceptsWhereIC(UserPost.class, "type", "JavaX Code (HTML Bot)")), req.get("algorithmID"));
}
public void run() {
String testCaseType = req.get("testCaseType");
Concept algo = getConcept(parseLongOpt(req.get("algorithmID")));
Collection testCases = beaList(testCaseType);
appendText(n2(testCases, "test case") + " found for type " + quote(testCaseType));
appendHTML("Algorithm object: " + htmlEncode2_nlToBr(str(algo)));
if (!(algo instanceof UserPost))
return;
Scorer scorer = new Scorer();
for (BEAObject testCase : testCases) {
ping();
Map fields = toCIMap(objectToMap(testCase));
String input = str(getAny(fields, "input"));
String expected = str(getAny(fields, "output", "result"));
String result = str(mod.callHtmlBot_dropMadeByComment(algo.id, litmap("q", input)));
boolean ok = eq(result, expected);
appendText((ok ? "OK" : "BAD") + ": Input: " + quote(input) + ", expected output: " + quote(expected) + ", result: " + quote(result));
scorer.add(ok);
}
appendText(str(scorer));
}
}
public void reactInputWithPatternList(Algorithm algo, BEAObject input, String text, BEAObject patternList, int level, int recursionLevels) {
Pair> match = matchInputWithPatternList(text, patternList);
algo.appendHTML(hr());
algo.appendHTML(joinNemptiesWithColon(level == 1 ? beaHTML(patternList) : null, stringIf(match == null, "No match")));
if (match != null) {
BEAObject pattern = match.a;
Map mapping = match.b;
algo.appendHTML("Matched as " + beaHTML(pattern));
algo.appendText(renderMappingAsText(mapping));
if (input != null) {
BEAObject matchObj = uniqCI(algo.localConcepts, BEAObject.class, "type", "Match", "input", input, "patternList", patternList, "winningPattern", pattern, "mapping", mapping);
algo.appendHTML("Match saved as: " + beaHTML(matchObj));
}
if (level < recursionLevels) {
algo.appendHTML_raw("");
for (Map.Entry __12 : _entrySet(mapping)) {
String key = __12.getKey();
String subInput = __12.getValue();
if (!eqic(key, text)) {
algo.appendHTML_raw("");
algo.appendText("Processing sub-Input: " + subInput);
reactInputWithPatternList(algo, null, subInput, patternList, level + 1, recursionLevels);
algo.appendHTML_raw(" ");
}
}
algo.appendHTML_raw(" ");
}
}
}
public int patternSpecificity(BEAObject pattern) {
return countWordsWithoutAngleBracketedAndStars(pattern.text());
}
public List syntacticPatternsSortedBySpecificityDesc() {
return sortedByCalculatedFieldDesc(__33 -> patternSpecificity(__33), mod.beaList("Syntactic Pattern"));
}
public Object executeTextQuery(String s) {
Matches m = new Matches();
if (match3_withIntsAndIDs("all references in field of object ", s, m)) {
Object value = cget(mod.beaGet(m.unq(1)), m.unq(0));
return value instanceof Collection ? instancesOf(BEAObject.class, (Collection) value) : value instanceof BEAObject ? ll((BEAObject) value) : ll();
}
return new QueryNotUnderstood(s);
}
static public class QueryNotUnderstood implements IFieldsToList {
public String s;
public QueryNotUnderstood() {
}
public QueryNotUnderstood(String s) {
this.s = s;
}
public String toString() {
return shortClassName(this) + "(" + s + ")";
}
public boolean equals(Object o) {
if (!(o instanceof QueryNotUnderstood))
return false;
QueryNotUnderstood __17 = (QueryNotUnderstood) o;
return eq(s, __17.s);
}
public int hashCode() {
int h = 1528655894;
h = boostHashCombine(h, _hashCode(s));
return h;
}
public Object[] _fieldsToList() {
return new Object[] { s };
}
}
public String beaToHTML(BEAObject o) {
return mod.beaToHTML(o);
}
public String beaHTML(BEAObject o) {
return mod.beaHTML(o);
}
public String beaURL(BEAObject o) {
return mod.beaURL(o);
}
public boolean isSyntacticPattern(BEAObject pat) {
return pat != null && pat.typeIs("Syntactic pattern");
}
public String patternTextWithAngleBracketVars(BEAObject pat) {
String text = pat.text();
return isSyntacticPattern(pat) ? starsToAngleBracketedNumbers(text) : text;
}
public boolean isCommentOrFeedback(BEAObject o) {
return o != null && o.typeIsOneOf("Comment", "Useful", "Feedback");
}
public String feedbackHTML(BEAObject o) {
Collection l = filter(__34 -> isCommentOrFeedback(__34), mod.beaBackRefs(o));
return joinWithBR(map(l, c -> c.typeIs("Comment") ? ahref(beaURL(c), htmlEncode2(c.text())) : beaHTML(c)));
}
public String bestInputURL(String text) {
text = trim(text);
BEAObject input = mod.findInput(text);
return input != null ? beaURL(input) : processInputURL(text);
}
public String bestInputHTML(String text) {
if (empty(text))
return "";
return ahref(bestInputURL(text), span(htmlEncode2(text), "style", "background-color: #ccc"));
}
public String performRewrite(BEAObject rewrite, Map mapping) {
String rewriteText = starsToAngleBracketedNumbers(rewrite.text());
return replaceAngleBracketVars(rewriteText, mapping);
}
public Pair exampleForPatternRewrite(BEAObject pattern, BEAObject rewrite) {
String patText = patternTextWithAngleBracketVars(pattern);
Set vars = collectAngleBracketVars(patText);
Map mapping = mapToValues_ciMap(vars, var -> "$" + var);
return pair(replaceAngleBracketVars(patText, mapping), performRewrite(rewrite, mapping));
}
public class RegExpToPossibleSubInputs extends Algorithm implements IFieldsToList {
public BEAObject input;
public BEAObject regExp;
public RegExpToPossibleSubInputs() {
}
public RegExpToPossibleSubInputs(BEAObject input, BEAObject regExp) {
this.regExp = regExp;
this.input = input;
}
public String toString() {
return shortClassName(this) + "(" + input + ", " + regExp + ")";
}
public boolean equals(Object o) {
if (!(o instanceof RegExpToPossibleSubInputs))
return false;
RegExpToPossibleSubInputs __10 = (RegExpToPossibleSubInputs) o;
return eq(input, __10.input) && eq(regExp, __10.regExp);
}
public int hashCode() {
int h = -208954156;
h = boostHashCombine(h, _hashCode(input));
h = boostHashCombine(h, _hashCode(regExp));
return h;
}
public Object[] _fieldsToList() {
return new Object[] { input, regExp };
}
public void run() {
String text = input.text();
String pat = regExp.text();
for (IntRange r : regexpFindRangesIC(pat, text)) appendHTML(beaHTML(csetAndReturn(uniq(localConcepts, BEAObject.class, "type", "Possible Sub-Input", "input", input, "characterRange", r, "text", substring(text, r)), "regExp", regExp, "byAlgorithm", shortName(this))));
}
}
public void appendPossibleRewrite(Algorithm algo, BEAObject input, String text) {
appendPossibleRewrite(algo, input, text, null);
}
public void appendPossibleRewrite(Algorithm algo, BEAObject input, String text, Map moreInfo) {
BEAObject existing = input == null ? null : conceptWhereIC(BEAObject.class, "type", "Rewrite", "input", input, "text", text, "label", "good");
if (existing != null)
algo.appendHTML("Rewrite exists: " + mod.beaLinkHTML(existing));
else if (input != null)
algo.appendHTML(joinWithSpace(map(ll("good", "bad"), label -> hinlinepostform(hhiddenMulti("action", "create", "f_type", "Rewrite", "f_text", text, "f_input", input.id, "metaInfo_input", "concept", "f_label", label, "redirectAfterSave", "") + hhiddenMulti(moreInfo) + hbutton(firstToUpper(label) + " rewrite", "onclick", js_redirectAutoScroll2()), "action", mod.crudLink(BEAObject.class)))));
}
public BEAObject reactFunctionWithInput(Algorithm algo, BEAObject f, BEAObject input) {
String fName = getString("name", f);
if (!isIdentifier(fName))
return null;
if (!isSafeStandardFunction(fName)) {
{
if (algo != null)
algo.addNonMatch(new Runnable() {
public void run() {
try {
algo.appendText("Function " + fName + " not safe");
} catch (Exception __e) {
throw rethrow(__e);
}
}
public String toString() {
return "algo.appendText(\"Function \" + fName + \" not safe\");";
}
});
}
return null;
}
BEAObject o = cnew(algo.localConcepts, BEAObject.class, "type", "Function Result", "function", f, "functionCalled", fName, "input", input, "calculating", true);
print("Function result: " + o);
try {
Object holder = getStandardFunctionHolder(fName);
Object result = evalWithTimeoutOrFail(10.0, () -> call(holder, fName, input.text()));
if (!(result instanceof List) && isStringCollection(result))
result = asList((Collection) result);
if (result == null)
cset(o, "resultType", "null");
else if (result instanceof String)
cset(o, "resultType", "string", "result", result);
else if (isStringList(result))
cset(o, "resultType", "list of strings", "result", result);
else
cset(o, "result", "other" + appendRoundBracketed(className(result)), "result", shorten(1000, str(result)));
} catch (Throwable e) {
cset(o, "resultType", "error", "error", getStackTrace(e));
}
cset(o, "calculating", null);
return o;
}
public BEAObject convertSyntacticToSemanticMatch(BEAObject match, BEAObject semanticPattern) {
BEAObject syntacticPattern = beaGet("pattern", match);
BEAObject input = beaGet("input", match);
String pat2 = syntacticPattern.text();
String pat1 = semanticPattern.text();
List vars = new ArrayList();
String pat2b = angleBracketVarsToStars(pat1, vars);
String warning = eq(pat2, pat2b) ? null : "Patterns don't match: " + quote(pat2) + " / " + quote(pat2b);
Map mapping = (Map) (cget("mapping", match));
Map mapping2 = mapKeys(mapping, key -> or(_get(vars, parseInt(key) - 1), key));
mapping2 = putKeysFirst(vars, mapping2);
BEAObject match2 = uniqCI(BEAObject.class, "type", "Match", "input", input, "pattern", semanticPattern, "fromSyntacticMatch", match);
cset(match2, "mapping", mapping2);
return match2;
}
public Collection convertSyntacticToSemanticMatches(BEAObject match) {
List out = new ArrayList();
BEAObject syntacticPattern = beaGet("pattern", match);
for (BEAObject semanticPattern : mod.beaList("Pattern", "syntacticPattern", syntacticPattern)) {
try {
out.add(convertSyntacticToSemanticMatch(match, semanticPattern));
} catch (Throwable __e) {
_handleException(__e);
}
}
return out;
}
public Collection convertSyntacticToSemanticMatchesForWholePattern(BEAObject pattern) {
if (pattern.typeIs("Syntactic Pattern"))
return concatMap_lists(__47 -> convertSyntacticToSemanticMatches(__47), mod.beaList("Match", "pattern", pattern));
else {
List out = new ArrayList();
BEAObject syntacticPattern = beaGet("syntacticPattern", pattern);
if (syntacticPattern != null)
for (BEAObject match : mod.beaList("Match", "pattern", syntacticPattern)) out.add(convertSyntacticToSemanticMatch(match, pattern));
return out;
}
}
public BEAObject beaGet(String field, BEAObject o) {
return mod.beaGet(field, o);
}
public Collection beaList(String type, Object... params) {
return mod.beaList(type, params);
}
public int simpleObjectScore(BEAObject o) {
int score = 0;
if (eqic_gen(getOpt("label", o), "good"))
++score;
else if (eqic_gen(getOpt("label", o), "bad"))
--score;
Collection l = findBackRefsWithField(BEAObject.class, "object", o);
score += countWhereCI(l, "type", "Useful");
score -= countWhereCI(l, "type", "Bad");
return score;
}
public List sortedBySimpleObjectScore(int minScore, Collection l) {
return sortedByCalculatedFieldDesc(__35 -> simpleObjectScore(__35), filter(l, o -> simpleObjectScore(o) >= minScore));
}
public BEAObject createPatternListFromUsefulSyntacticPatterns() {
List patterns = sortedBySimpleObjectScore(0, beaList("Syntactic Pattern"));
return mod.autoMigrateToCustomClass(uniqCI(BEAObject.class, "type", "Pattern List", "byFunction", "createPatternListFromUsefulSyntacticPatterns", "patterns", patterns));
}
}
static public class GazelleBEA extends DynGazelleRocks {
static public boolean _switchableField_mirrorBEAObjects = true;
public boolean mirrorBEAObjects = false;
static public boolean _switchableField_enableAutoRuns = true;
public boolean enableAutoRuns = true;
static public boolean _switchableField_enableNewBEAObjectNotis = true;
public boolean enableNewBEAObjectNotis = true;
static public boolean _switchableField_printAllConceptChanges = true;
public boolean printAllConceptChanges = false;
static public boolean _switchableField_useShadowLogger = true;
public boolean useShadowLogger = true;
static public boolean _switchableField_autoActivateDynamicObjects = true;
public boolean autoActivateDynamicObjects = true;
transient public ReliableSingleThread_Multi rstAutoRuns = new ReliableSingleThread_Multi<>(1000, __29 -> performAutoRuns(__29));
transient public Q notificationQ;
transient public ReliableSingleThread_Multi rstDistributeNewObject = new ReliableSingleThread_Multi<>(1000, __30 -> distributeNewObject_impl(__30));
transient public Set newObjectsDistributed = weakSet();
transient public ReliableSingleThread_Multi rstUpdateBEAMirrors = new ReliableSingleThread_Multi<>(100, c -> {
AutoCloseable __25 = enter();
try {
c.updateMirrorPost();
} finally {
_close(__25);
}
});
transient public ReliableSingleThread_Multi rstAutoActivateDynamicObjects = new ReliableSingleThread_Multi<>(100, c -> {
AutoCloseable __26 = enter();
try {
autoActivateDynamicObject(c);
} finally {
_close(__26);
}
});
transient public BEACalculations calculations = new BEACalculations(this);
transient public BEACalculations calc = calculations;
transient public int newFieldsToShow = 3;
transient public boolean allowAnonymousInputUpload = true;
static public boolean _switchableField_maxInputLength = true;
public int maxInputLength = 50000;
transient public ConceptClassesDependentValue inputsWithoutRewrites;
transient public ConceptClassesDependentValue inputsWithoutMatches;
transient public ConceptClassesDependentValue syntacticPatternsWithoutRewrites;
transient public boolean quickDBReloadEnabled = false;
public Concepts _getReloadData() {
return db_mainConcepts();
}
public void _setReloadData_early(Object data) {
quickImportMainConcepts(data, () -> quickDBReloadEnabled);
}
public void init() {
super.init();
botName = heading = adminName = "Gazelle BEA";
enableVars = true;
showTalkToBotLink = false;
phoneNumberSpecialInputField = false;
showMetaBotOnEveryPage = false;
}
public void startDB() {
db();
db_mainConcepts().useBackRefsForSearches = true;
inputsWithoutRewrites = new ConceptClassesDependentValue(litset(BEAObject.class), () -> countPred(beaList("Input"), c -> empty(beaBackRefs(c, "Rewrite"))));
inputsWithoutMatches = new ConceptClassesDependentValue(litset(BEAObject.class), () -> countPred(beaList("Input"), c -> empty(beaBackRefs(c, "Match"))));
syntacticPatternsWithoutRewrites = new ConceptClassesDependentValue(litset(BEAObject.class), () -> countPred(beaList("Syntactic Pattern"), c -> empty(beaBackRefs(c, "Rewrite"))));
if (useShadowLogger) {
ConceptsShadowLogger shadowLogger = new ConceptsShadowLogger(db_mainConcepts());
shadowLogger.install();
shadowLogger.writer = filePrintWriter_append(programFile("shadow.log"));
dm_doEvery(10.0, new Runnable() {
public void run() {
try {
shadowLogger.flush();
} catch (Exception __e) {
throw rethrow(__e);
}
}
public String toString() {
return "shadowLogger.flush();";
}
});
ownResource(shadowLogger);
}
if (printAllConceptChanges)
printAllConceptChanges();
}
public void start() {
assertEquals(BEAObject.class, callF(defaultDefaultClassFinder(), "main$BEAObject"));
assertEquals(ConceptWithGlobalID.class, callF(defaultDefaultClassFinder(), "main$ConceptWithGlobalID"));
seedDBFrom("#1030602");
botDisabled = true;
storeBaseClassesInStructure = true;
super.start();
print("main concepts: " + db_mainConcepts() + ", count: " + db_mainConcepts().countConcepts());
print(renderConceptClassesWithCount(db_mainConcepts()));
print("Inputs: " + n2(beaCount("Input")));
showCRUDToEveryone = true;
dm_onSnippetTranspiled(new VF1() {
public void get(String snippetID) {
try {
if (sameSnippetID(snippetID, "#1030952"))
dm_reloadModule();
} catch (Exception __e) {
throw rethrow(__e);
}
}
public String toString() {
return "if (sameSnippetID(snippetID, #1030952))\r\n dm_reloadModule();";
}
});
if (!enabled)
return;
rstUpdateBEAMirrors.addAll(list(BEAObject.class));
newObjectsDistributed.addAll(list(BEAObject.class));
onIndividualConceptChange_notOnAllChanged(BEAObject.class, o -> {
if (enableAutoRuns)
rstAutoRuns.add(o);
if (enableNewBEAObjectNotis && newObjectsDistributed.add(o))
rstDistributeNewObject.add(o);
});
notificationQ = dm_startQ();
dm_doEvery(5 * 60.0, new Runnable() {
public void run() {
try {
{
AutoCloseable __27 = enter();
try {
print(new ConceptsRefChecker(db_mainConcepts()).runAndFixAll());
} finally {
_close(__27);
}
}
} catch (Exception __e) {
throw rethrow(__e);
}
}
public String toString() {
return "{ temp enter();\r\n print(ConceptsRefChecker(db_mainConcepts()).runAndFixA...";
}
});
}
public void makeIndices() {
super.makeIndices();
indexConceptFieldDesc(BEAObject.class, "_modified");
indexConceptFieldIC(BEAObject.class, "type");
indexConceptFieldIC(BEAObject.class, "text");
}
public List crudClasses(Req req) {
return listPlus(super.crudClasses(req), BEAObject.class);
}
public Set hiddenCrudClasses() {
Set set = super.hiddenCrudClasses();
addAll(set, Conversation.class, ExecutedStep.class, InputHandled.class);
return set;
}
public String authFormHeading() {
return h3("Gazelle BEA");
}
public void makeFramer(Req req) {
super.makeFramer(req);
req.framer.addInHead(hjs_autoExpandingTextAreas());
}
public HCRUD_Concepts crudData(Class c, Req req) {
HCRUD_Concepts cc = super.crudData(c, req);
if (c == BEAObject.class) {
cc.humanizeFieldNames = false;
cc.convertConceptValuesToRefs = true;
cc.itemName = () -> "BEA Object";
cc.onCreate.add(o -> cset(o, "createdBy", currentUser()));
cc.getObjectForDuplication = id -> {
Map item = cc.getObjectForDuplication_base(id);
item.put("createdBy", req.auth.user.get());
item.put("createdFrom", getConcept(toLong(id)));
return item;
};
cc.emptyObject = () -> {
Map item = cc.emptyObject_base();
item.put("type", "");
return item;
};
Set deletableRefs = litciset("Match");
cc.objectCanBeDeleted = id -> {
BEAObject o = (BEAObject) (cc.conceptForID(id));
return userCanEditObject(user(req), o) && all(findBackRefs(BEAObject.class, o), x -> contains(deletableRefs, x.type()));
};
cc.actuallyDeleteConcept = o -> {
deleteConcepts(filter(findBackRefs(BEAObject.class, o), o2 -> contains(deletableRefs, o2.type())));
cdelete(o);
};
}
return cc;
}
public HCRUD makeCRUD(Class c, Req req, HTMLFramer1 framer) {
HCRUD crud = super.makeCRUD(c, req, framer);
HCRUD_Concepts data = (HCRUD_Concepts) (crud.data);
crud.showOnlySelected = true;
crud.showSearchField = true;
if (data.customFilter == null)
crud.descending = true;
crud.cleanItemIDs = true;
if (c == BEAObject.class) {
crud.cellColumnToolTips = true;
crud.unshownFields = litset("mirrorPost", "globalID");
crud.showTextFieldsAsAutoExpandingTextAreas = true;
HCRUD_Concepts cc = (HCRUD_Concepts) (crud.data);
String typeFilter = req.get("type");
if (nempty(typeFilter))
cc.addCIFilter("type", typeFilter);
crud.renderCmds = map -> {
BEAObject o = getConcept(BEAObject.class, crud.itemIDAsLong(map));
List cmds = new ArrayList();
if (nempty(o.text()))
cmds.add(targetBlank(addParamsToURL(baseLink + "/query", "q", o.text(), "algorithm", "process input"), "Use text as query"));
if (o.typeIs("Input")) {
cmds.add(ahref(addParamsToURL(crudLink(BEAObject.class), "cmd", "new", "title", "Add Pattern For Input", "f_type", "Pattern", "f_text", getStringOpt("text", o), "f_shouldMatch", o.id, "metaInfo_shouldMatch", "concept"), "Add pattern"));
cmds.add(ahref(appendParamsToURL(baseLink + "/query", "q", o.text(), "algorithm", "Apply all text functions"), "Apply all text functions"));
}
if (o.typeIs("Pattern"))
cmds.add(ahref(appendParamsToURL(baseLink + "/query", "q", o.id, "algorithm", "Run pattern"), "Try-run pattern against all inputs"));
if (o.typeIsOneOf("Pattern", "Syntactic Pattern")) {
cmds.add(ahref(appendParamsToURL(baseLink + "/reactAllInputsWithPattern", "patternID", o.id), "React pattern with all inputs"));
cmds.add(ahref(appendParamsToURL(baseLink + "/convertSyntacticToSemanticMatchesForWholePattern", "patternID", o.id), "Convert all syntactic matches to semantic matches"));
}
if (o.typeIs("Match")) {
cmds.add(ahref(appendParamsToURL(baseLink + "/query", "q", o.id, "algorithm", "Find rewrites for match"), "Find rewrites"));
if (beaTypeIs(beaGet("pattern", o), "Syntactic Pattern"))
cmds.add(ahref(appendParamsToURL(baseLink + "/convertSyntacticToSemanticMatches", "matchID", o.id), "Convert to semantic matches"));
}
cmds.add(ahref(addParamsToURL(baseLink + "/markUseful", "redirect", beaShortURL(o), "objectID", o.id), "Mark useful"));
cmds.add(ahref(addParamsToURL(baseLink + "/markBad", "redirect", beaShortURL(o), "objectID", o.id), "Mark bad"));
cmds.add(addCommentHTML(o));
if (o.typeIsOneOf("Script", "Step in script") || eqic(beforeVerticalBar(o.type()), "Instruction"))
cmds.add(ahref(addParamsToURL(baseLink + "/runInstruction", "instruction", o.id), "Run"));
if (o.typeIs("Function Result")) {
if (eqic(cget("resultType", o), "string"))
cmds.add(ahref(addParamsToURL(baseLink + "/convertResultToInput", "result", o.id), "Convert to input"));
}
if (o.typeIs("Auto Run"))
cmds.add(ahref(addParamsToURL(baseLink + "/performAutoRunOnAllObjects", "autoRun", o.id), "Run on all objects"));
if (o.getClass() != BEAObject.class)
cmds.add(ahref(addParamsToURL(baseLink + "/migrateToBase", "id", o.id), "Migrate to BEAObject"));
cmds.add(ahref(addParamsToURL(baseLink + "/performAutoRuns", "onObject", o.id), "Perform auto runs on this object"));
framer.addInHead(hjs_copyToClipboard());
cmds.add(ahref_onClick(formatFunctionCall("copyToClipboard", jsQuote(o.globalIDStr())), "Copy global ID [" + o.globalIDStr() + "]"));
List items = llNempties(crud.renderCmds_base(map), !o.typeIsOneOf("Input", "Pattern", "Syntactic Pattern") ? null : addRewriteHTML(o), !canAutoMigrate(o) ? null : ahref(addParamsToURL(baseLink + "/autoMigrate", "id", o.id), "Auto-migrate to " + shortClassName(defaultCustomClass(o))));
if (isObjectWithCode(o) && isMasterAuthed(req))
items.add(ahref(baseLink + "/activateDynamicObject?id=" + o.id, "Activate custom code"));
if (fileNotEmpty(javaSourceFileForObject(o)))
cmds.add(ahref(baseLink + "/javaSource?id=" + o.id, "Show Java source"));
addAll(items, o.directCmds());
items.add(hPopDownButton(cmds));
return joinNemptiesWithVBar(items);
};
cc.massageItemMapForList = (item, map) -> {
BEAObject o = (BEAObject) item;
if (o.typeIs("Input")) {
Collection matches = objectsWhereNotIC(objectsWhereCI(findBackRefs(o, BEAObject.class), "type", "match"), "label", "bad");
((Map) map).put("Best Matches", new HTML(hparagraphs(lmap(__36 -> matchDescHTML(__36), takeFirst(3, matches)))));
}
String idField = crud.idField();
Object id = ((Map) map).get(idField);
if (id instanceof String)
((Map) map).put(idField, new HTML(ahref(beaShortURL(o), id)));
if (o.typeIs("Function Result")) {
Object value = getOpt("result", o);
((Map) map).put("result", new HTML(javaValueToHTML(value)));
}
if (o.typeIs("Match")) {
Map mapping = o.mapping();
if (mapping != null)
((Map) map).put("mapping", new HTML(joinWithBR(map(mapping, (k, v) -> htmlEncode2(k) + "=" + calculations.bestInputHTML(v)))));
}
if (o.getClass() != BEAObject.class)
((Map) map).put("Java Class", shortClassName(o));
if (eq(req.get("showSimpleObjectScore"), "1"))
((Map) map).put("Simple object score", calculations.simpleObjectScore(o));
};
crud.massageFormMatrix = (map, matrix) -> {
for (int i = 1; i <= newFieldsToShow; i++) {
String nf = "newField" + i;
String refSelector = crud.renderInput((nf + "_conceptValue"), cc.makeConceptsComboBox((nf + "_conceptValue"), BEAObject.class), null) + hjs("$(\"[name=" + nf + "_conceptValue]\").hide()");
String userSelector = crud.renderInput((nf + "_userValue"), cc.makeConceptsComboBox((nf + "_userValue"), User.class), null) + hjs("$(\"[name=" + nf + "_userValue]\").hide()");
List types = ll("String", "BEAObject", "Bool", "User");
String typeSelector = hselect_list(types, "name", (nf + "_type"), "onchange", "\r\n var value = this.value;\r\n $(\"[name=" + nf + "_value]\").toggle(value == \"String\" || value == \"Bool\");\r\n $(\"#" + nf + "_refBox\").toggle(value == \"BEAObject\");\r\n $(\"#" + nf + "_userSel\").toggle(value == \"User\");\r\n ");
matrix.add(ll("Add field: objects;
while (true) {
objects = changedAfter == 0 ? list(BEAObject.class) : conceptsWithFieldGreaterThan_sorted(BEAObject.class, "_modified", changedAfter);
if (nempty(objects) || pollFor == 0 || elapsedSeconds_sysNow(startTime) >= pollFor)
return serveJSON_breakAtLevels(2, "result", map(objects, obj -> litorderedmap("gid", str(obj.globalID()), "struct", obj.structureString())));
sleep(bot_pollInterval);
}
}
return super.serveBotFunction(req, function, data, user);
}
public Object serveOtherPage2(Req req) {
printVars_str("serveOtherPage2", "uri", req.uri);
{
Object __24 = super.serveOtherPage2(req);
if (__24 != null)
return __24;
}
String uri = dropTrailingSlashIfNemptyAfterwards(req.uri);
Matches m = new Matches();
if (swic_notSame(uri, "/beaCRUD/", m))
return renderBEAObjectTable(req, urldecode(m.rest()));
if (eq(uri, "/inputs"))
return renderBEAObjectTable(req, "input");
if (eq(uri, "/syntacticMatchesTable"))
return hrefresh(baseLink + "/matchesTable?syntacticOnly=1");
if (eq(uri, "/matchesTable")) {
boolean syntacticOnly = eq("1", req.get("syntacticOnly"));
List list = new ArrayList();
for (BEAObject match : beaList("Match")) {
BEAObject input = cgetOpt(BEAObject.class, match, "input");
BEAObject pat = cgetOpt(BEAObject.class, match, "pattern");
if (syntacticOnly && !calculations.isSyntacticPattern(pat))
continue;
{
if (calculations.patternAlwaysMatches(pat))
continue;
}
Map mapping = match.mapping();
if (input == null || pat == null || mapping == null)
continue;
list.add(match);
}
list = sortedByCalculatedFieldDesc(list, match -> conceptID(cgetBEA("input", match)));
HTMLPaginator paginator = new HTMLPaginator();
paginator.processParams(req.params());
paginator.baseLink = addParamsToURL(baseLink, filterKeys(req.params(), p -> eq(p, "syntacticOnly")));
paginator.max = l(list);
req.framer.add(divUnlessEmpty(paginator.renderNav()));
list = subList(list, paginator.visibleRange());
List data = new ArrayList();
for (BEAObject match : list) {
BEAObject input = cgetOpt(BEAObject.class, match, "input");
BEAObject pat = cgetOpt(BEAObject.class, match, "pattern");
Map mapping = match.mapping();
String patText = calculations.patternTextWithAngleBracketVars(pat);
List tok = javaTokWithAngleBrackets(patText);
BitSet bs = new BitSet();
tok = replaceAngleBracketVars(tok, mapping, bs);
for (Pair __20 : bitSetStreaksAndNonStreaks(bs, l(tok))) {
IntRange r = pairA(__20);
boolean b = pairB(__20);
String t = joinSubList(tok, r);
replaceTokens(tok, r, b ? formatSubInput(input, t, "obj" + match.id) : htmlEncode2(t));
}
String boldenedInput = join(tok);
data.add(litorderedmap("Input", aname("obj" + match.id, joinWithBR(ahref(beaURL(input), htmlEncode2_str(call(input, "text"))), boldenedInput)), "Pattern", ahref(beaURL(pat), htmlEncode2(pat.text())), "DB object", beaHTML_justID(match), "Feedback", joinNemptiesWithSpace(calculations.feedbackHTML(match), addCommentHTML(match, "defaultComment", "good match", "redirectAfterSave", req.uriWithParams(), "text", "+"))));
}
req.framer.title = syntacticOnly ? "Syntactic matches table" : "Matches table";
req.framer.add(p());
req.framer.add(htmlTable2_noHtmlEncode(data));
return completeFrame(req);
}
if (eq(uri, "/rewritesTable")) {
List data = new ArrayList();
for (BEAObject input : beaList("Input")) for (BEAObject r : beaBackRefs(input, "Rewrite")) data.add(litorderedmap("Input", input.text(), "Rewrite", tok_dropCurlyBrackets(r.text()), "Rewrite Type", getOpt("rewriteType", r)));
req.framer.title = "Rewrites table";
req.framer.add(p());
req.framer.add(htmlTable2(data));
return completeFrame(req);
}
if (eq(uri, "/patternRewritesTable")) {
List data = new ArrayList();
for (BEAObject pat : beaListAny("Pattern", "Syntactic Pattern")) for (BEAObject r : beaBackRefs(pat, "Rewrite")) if (cget("isRewriteOf", r) == pat) {
Pair example = calculations.exampleForPatternRewrite(pat, r);
data.add(litorderedmap("Pattern", ahref(beaURL(pat), htmlEncode2(pat.text())), "Rewrite", ahref(beaURL(r), htmlEncode2(tok_dropCurlyBrackets(r.text()))), "Example", joinWithBR(htmlEncode2(example.a), htmlEncode2("=> " + example.b)), "Rewrite Type", htmlEncode2_str(getOpt("rewriteType", r)), "Cmds", hPopDownButton(targetBlank(conceptEditLink(r), "Edit"))));
}
req.framer.title = "Pattern rewrites table";
req.framer.add(p());
req.framer.add(htmlTable2_noHtmlEncode(data));
return completeFrame(req);
}
if (eq(uri, "/syntacticPatternsWithoutRewrites")) {
HCRUD crud = makeBEAObjectCRUD(req, "Syntactic Pattern");
HCRUD_Concepts data = (HCRUD_Concepts) (crud.data);
IF1 prev = data.customFilter;
data.customFilter = list -> {
list = filter(list, c -> empty(beaBackRefs(c, "Rewrite")));
return postProcess(prev, list);
};
crud.customTitle = "Syntactic patterns without rewrites";
return serveCRUD(req, BEAObject.class, crud);
}
if (eq(uri, "/inputsWithoutRewrites")) {
HCRUD crud = makeBEAObjectCRUD(req, "input");
HCRUD_Concepts data = (HCRUD_Concepts) (crud.data);
IF1 prev = data.customFilter;
data.customFilter = list -> {
list = filter(list, c -> empty(beaBackRefs(c, "Rewrite")));
return postProcess(prev, list);
};
crud.customTitle = "Inputs without rewrites";
return serveCRUD(req, BEAObject.class, crud);
}
if (eq(uri, "/inputsWithRewrites")) {
HCRUD crud = makeBEAObjectCRUD(req, "input");
HCRUD_Concepts data = (HCRUD_Concepts) (crud.data);
IF1 prev = data.customFilter;
data.customFilter = list -> {
list = filter(list, c -> nempty(beaBackRefs(c, "Rewrite")));
return postProcess(prev, list);
};
crud.customTitle = "Inputs with rewrites";
return serveCRUD(req, BEAObject.class, crud);
}
if (eq(uri, "/inputsWithoutMatches")) {
HCRUD crud = makeBEAObjectCRUD(req, "input");
HCRUD_Concepts data = (HCRUD_Concepts) (crud.data);
IF1 prev = data.customFilter;
data.customFilter = list -> {
list = filter(list, c -> empty(beaBackRefs(c, "Match")));
return postProcess(prev, list);
};
crud.customTitle = "Inputs without matches";
return serveCRUD(req, BEAObject.class, crud);
}
if (eq(uri, "/patterns"))
return renderBEAObjectTable(req, "pattern");
if (eq(uri, "/syntacticPatterns"))
return renderBEAObjectTable(req, "Syntactic Pattern");
if (eq(uri, "/matches"))
return renderBEAObjectTable(req, "match");
if (eq(uri, "/rewrites"))
return renderBEAObjectTable(req, "rewrite");
if (eq(uri, "/aiTasks"))
return renderBEAObjectTable(req, "AI Task");
if (eq(uri, "/query"))
return calculations.serveQueryPage(req);
if (eq(uri, "/saveInput")) {
String text = trim(req.get("text"));
String info = trim(req.get("info"));
if (empty(text))
return subBot_serve500("Input empty");
if (l(text) > maxInputLength)
return subBot_serve500("Input too long");
BEAObject input = uniqCI(BEAObject.class, "type", "Input", "text", text, "createdBy", user(req));
saveUserAgent(input);
if (nempty(info))
uniqCI(BEAObject.class, "type", "Input Source", "input", input, "source", info);
return hrefresh(or2(req.get("redirect"), baseLink + "/"));
}
if (eq(uri, "/markUseful")) {
BEAObject o = beaGet("objectID", req);
if (o == null)
return subBot_serve500("Object not found");
uniqCI(BEAObject.class, "type", "Useful", "object", o, "createdBy", user(req));
return hrefresh(or2(req.get("redirect"), baseLink + "/"));
}
if (eq(uri, "/markBad")) {
BEAObject o = beaGet("objectID", req);
if (o == null)
return subBot_serve500("Object not found");
uniqCI(BEAObject.class, "type", "Bad", "object", o, "createdBy", user(req));
return hrefresh(or2(req.get("redirect"), baseLink + "/"));
}
if (eq(uri, "/saveAnswer")) {
String text = trim(req.get("text"));
String rewriteType = or2(trim(req.get("rewriteType")), "Suggested Answer");
long inputID = toLong(req.get("inputID"));
BEAObject input = beaGet(inputID);
if (input == null)
return subBot_serve500("Input not found");
if (empty(text))
return subBot_serve500("Text empty");
if (l(text) > maxInputLength)
return subBot_serve500("Text too long");
uniqCI(BEAObject.class, "type", "Rewrite", "text", text, "isRewriteOf", input, "rewriteType", rewriteType, "createdBy", user(req));
return hrefresh(or2(req.get("redirect"), baseLink + "/"));
}
if (eq(uri, "/javaSource")) {
BEAObject o = beaGet("id", req);
return serveText(loadTextFile(javaSourceFileForObject(o)));
}
if (!inMasterMode(req))
return null;
if (eq(uri, "/uploadInputs"))
return serveUploadTexts(req, "Input");
if (eq(uri, "/uploadPatterns"))
return serveUploadTexts(req, "Pattern");
if (eq(uri, "/analyzeInput"))
return calculations.serveAnalyzeInput(req);
if (eq(uri, "/allBEATypes")) {
return h2_title("All object types") + ul(renderObjectTypes());
}
if (eq(uri, "/storeMatch")) {
BEAObject pattern = beaGet(req.get("pattern"));
BEAObject input = beaGet(req.get("input"));
String label = req.get("label");
BEAObject match = calculations.reactInputWithPattern(input, pattern);
if (match == null)
return "Couldn't match";
cset(match, "label", label);
return hrefresh(or2(req.get("redirect"), beaObjectURL(match)));
}
if (eq(uri, "/saveSyntacticPattern") || eq(uri, "/savePattern")) {
String type = cic(uri, "syntactic") ? "Syntactic Pattern" : "Pattern";
String text = req.get("text");
BEAObject fromInput = beaGet(req.get("fromInput"));
BEAObject pat = uniqCI(BEAObject.class, "type", type, "text", text, "createdBy", user(req));
csetIfUnset(pat, "fromInput", fromInput);
if (fromInput != null)
calculations.reactInputWithPattern(fromInput, pat);
return hrefresh(or2(req.get("redirect"), baseLink + "/"));
}
if (eq(uri, "/runInstruction")) {
BEAObject o = beaGet(req.get("instruction"));
runInstruction(o);
return hrefresh(beaObjectURL(o));
}
if (eq(uri, "/convertResultToInput")) {
BEAObject result = beaGet(req.get("result"));
if (result == null)
return subBot_serve500("Object not found");
String text = unquote(getString("result", result));
if (l(text) > maxInputLength)
return subBot_serve500("Input too long");
BEAObject input = uniqCI(BEAObject.class, "type", "Input", "text", text);
uniqCI(BEAObject.class, "type", "Input Source", "input", input, "source", result);
return hrefresh(beaShortURL(input));
}
if (eq(uri, "/setWordType")) {
BEAObject r = beaGet(req.get("resultID"));
String wordType = assertNempty(req.get("wordType"));
List result = assertStringList(cget("result", r));
for (String s : result) uniqCI(BEAObject.class, "type", "Word type", "word", s, "wordType", wordType);
return "OK";
}
if (eq(uri, "/reload")) {
dm_reloadModuleIn(3);
return "Reloading module in 3";
}
if (eq(uri, "/performAutoRuns")) {
BEAObject o = beaGet(req.get("onObject"));
if (o == null)
return "Object not found";
rstAutoRuns.add(o);
return hrefresh(beaURL(o));
}
if (eq(uri, "/reactAllInputsWithAllSyntacticPatterns")) {
return str(returnTimed(new Runnable() {
public void run() {
try {
calculations.reactAllInputsWithAllSyntacticPatterns();
} catch (Exception __e) {
throw rethrow(__e);
}
}
public String toString() {
return "calculations.reactAllInputsWithAllSyntacticPatterns();";
}
}));
}
if (eq(uri, "/reactAllInputsWithPattern")) {
BEAObject pat = beaGet(req.get("patternID"));
if (pat == null)
return "Pattern not found";
return str(returnTimed(new Runnable() {
public void run() {
try {
calculations.reactAllInputsWithPattern(pat);
} catch (Exception __e) {
throw rethrow(__e);
}
}
public String toString() {
return "calculations.reactAllInputsWithPattern(pat);";
}
}));
}
if (eq(uri, "/storeSubInput")) {
BEAObject input = beaGet(req.get("input"));
if (input == null)
return "Input not found";
String text = req.get("text");
String type = eqic(req.get("label"), "good") ? "Sub-Input" : "Bad Sub-Input";
BEAObject o = uniqCI(BEAObject.class, "type", type, "input", input, "text", text, "createdBy", currentUser());
return hrefresh(or2(req.get("redirect"), beaURL(o)));
}
if (eq(uri, "/performAutoRunOnAllObjects")) {
BEAObject autoRun = beaGet("autoRun", req);
performAutoRunOnAllObjects(autoRun);
return "OK";
}
if (eq(uri, "/autoMigrate")) {
BEAObject o = beaGet("id", req);
if (o == null)
return "Object not found";
String url = beaURL(o);
return hsansserif() + "Migrated " + beaHTML(o) + " to " + className(autoMigrateToCustomClass(o)) + hrefresh(1.0, url);
}
if (eq(uri, "/migrateToBase")) {
BEAObject o = beaGet("id", req);
if (o == null)
return "Object not found";
String url = beaURL(o);
return hsansserif() + "Migrated " + beaHTML(o) + " to " + className(autoMigrateToBase(o)) + hrefresh(1.0, url);
}
if (eq(uri, "/convertSyntacticToSemanticMatches")) {
BEAObject match = beaGet("matchID", req);
if (match == null)
return "Match not found";
return ul_htmlEncode2(calculations.convertSyntacticToSemanticMatches(match));
}
if (eq(uri, "/convertSyntacticToSemanticMatchesForWholePattern")) {
BEAObject pat = beaGet("patternID", req);
if (pat == null)
return "Pattern not found";
return ul_htmlEncode2(calculations.convertSyntacticToSemanticMatchesForWholePattern(pat));
}
if (eq(uri, "/createPatternListFromUsefulSyntacticPatterns"))
return hrefresh(beaURL(calc.createPatternListFromUsefulSyntacticPatterns()));
if (eq(uri, "/createConceptShadows"))
return createConceptShadows();
if (eq(uri, "/compareConceptShadows")) {
if (conceptShadows == null)
return createConceptShadows();
List newShadows = allConceptShadows();
List> diff = diffConceptShadows(conceptShadows, newShadows);
return subBot_serveText(nDiffs(diff) + ":\n\n" + pnlToString(diff));
}
if (eq(uri, "/includeScript")) {
String snippetID = req.get("id");
Object wired = hotwire(snippetID);
return "Wired: " + wired;
}
if (eq(uri, "/activateDynamicObject")) {
BEAObject o = beaGet("id", req);
if (o == null)
return "Object not found";
activateDynamicObject(o);
o = beaGet("id", req);
String url = beaURL(o);
return hsansserif() + "Migrated " + beaHTML(o) + " to " + className(o) + hrefresh(3.0, url);
}
if (eq(uri, "/callAnyMethod")) {
BEAObject o = beaGet("id", req);
if (o == null)
return "Object not found";
String name = req.get("name");
List args = new ArrayList();
for (Map.Entry __21 : _entrySet(req.params())) {
String key = __21.getKey();
String val = __21.getValue();
int idx = parseIntOpt(regexpExtractGroup("^conceptArg(\\d+)$", key));
if (idx > 0)
listSet(args, idx - 1, getConcept(parseLong(val)));
}
Object result = call(o, name, toObjectArray(args));
return serveText("Result of " + o.id + "." + name + "(" + joinWithComma(args) + "):\n" + result);
}
return null;
}
transient public List conceptShadows;
public Object createConceptShadows() {
long _startTime_22 = sysNow();
String profile = profileThisThreadToString(new Runnable() {
public void run() {
try {
conceptShadows = allConceptShadows();
} catch (Exception __e) {
throw rethrow(__e);
}
}
public String toString() {
return "conceptShadows = allConceptShadows();";
}
});
done2_always("Make shadows", _startTime_22);
return subBot_serveText(n2(conceptShadows, "shadow") + " made in " + lastTiming_formatted() + "\n\n" + profile);
}
public HCRUD makeBEAObjectCRUD(Req req, String type) {
HCRUD crud = makeCRUD(BEAObject.class, req);
crud.baseLink = req.uri();
HCRUD_Concepts data = (HCRUD_Concepts) (crud.data);
data.itemName = () -> firstToUpper(type);
data.addCIFilter("type", eqic(type, "(no type)") ? null : type);
if (eqicOneOf(type, "Input", "Pattern", "AI Task")) {
IF0> prev = data.emptyObject;
data.emptyObject = () -> {
Map item = data.emptyObject_fallback(prev);
item.put("text", "");
return item;
};
}
return crud;
}
public Object renderBEAObjectTable(Req req, String type) {
HCRUD crud = makeBEAObjectCRUD(req, type);
return serveCRUD(req, BEAObject.class, crud);
}
public Object serveUploadTexts(Req req, String type) {
String inputs = req.get("text");
List output = new ArrayList();
if (nempty(inputs)) {
for (String text : tlft(inputs)) {
Pair p = uniqCI2_sync(BEAObject.class, "type", type, "text", text);
if (cget("uploadedBy", p.a) == null)
cset(p.a, "uploadedBy", req.auth.user);
output.add(type + " " + (p.b ? "added" : "exists") + " (ID " + p.a.id + "): " + text);
}
}
return h2("Upload " + plural(type)) + hpostform(p(plural(type) + " (one per line):") + p(htextarea(inputs, "name", "text")) + pIfNempty(htmlEncode_nlToBR(lines(output))) + hsubmit("Upload " + plural(type)));
}
public Collection beaObjectsOfType(String type) {
return conceptsWhereCI(BEAObject.class, "type", type);
}
public void reactAllInputsWithSomePatterns() {
calculations.reactAllInputsWithSomePatterns();
}
public String navDiv() {
HCRUD crud = makeCRUD(BEAObject.class, currentReq.get());
long time = sysNow();
int inputsWithoutRewrites = this.inputsWithoutRewrites.get();
int inputsWithoutMatches = this.inputsWithoutMatches.get();
int syntacticPatternsWithoutRewrites = this.syntacticPatternsWithoutRewrites.get();
done2_always("Count Things", time);
return joinNemptiesWithVBar(ahref(baseLink + "/query", "Query"), beaNavLink("Input", crud), beaNavLink("Pattern", crud), beaNavLink("Syntactic Pattern", crud), ahref(baseLink + "/syntacticPatternsWithoutRewrites", n2(syntacticPatternsWithoutRewrites) + " Syntactic patterns w/o rewrites"), beaNavLink("Match", crud), beaNavLink("Rewrite", crud), beaNavLink("AI Task", crud), ahref(baseLink + "/inputsWithoutMatches", n2(inputsWithoutMatches) + " Inputs w/o matches"), ahref(baseLink + "/inputsWithoutRewrites", n2(inputsWithoutRewrites) + " Inputs w/o rewrites"), hPopDownButtonWithText("Bot Forum", navLinks("flat", true, "withStats", false)), new HTMLPopDownButton(ahref(baseLink + "/allBEATypes", "All object types") + " " + hPopDownButton(renderObjectTypes()), ahref(baseLink + "/stats", "Stats"), !inMasterMode(currentReq.get()) ? null : ahref(baseLink + "/refchecker", "Reference checker"), ahref(baseLink + "/inputsWithRewrites", "Inputs with rewrites"), ahref(baseLink + "/rewritesTable", "Rewrites table"), ahref(baseLink + "/patternRewritesTable", "Pattern rewrites table"), ahref(baseLink + "/matchesTable", "Matches table"), ahref(baseLink + "/matchesTable?syntacticOnly=1", "Syntactic matches table"), ahref("https://gazelle.rocks/htmlBot/238410", "Classic Gazelle")).width(350).height(500).html());
}
public String beaNavLink(String type, HCRUD crud) {
return beaNavLink(type, crud, beaCount(type));
}
public String beaNavLink(String type, HCRUD crud, int count) {
String plural = firstToLower(plural(type));
String link = baseLink + "/" + camelCase(plural);
return ahref(link, n2(count) + " " + firstToUpper(plural)) + (!crud.actuallyAllowCreate() ? "" : " " + ahref(addParamToURL(link, "cmd", "new"), "+"));
}
public String beaObjectURL(BEAObject o) {
return conceptLink(o, currentReq.get());
}
public String matchDescHTML(BEAObject m) {
try {
BEAObject pat = cget("pattern", m);
Map mapping = (Map) (cget("mapping", m));
return ahref_undecorated(crudLink(m), htmlEncode2(quote(getString("text", pat))) + " beaList(String type, Object... params) {
return conceptsWhereCI(BEAObject.class, paramsPlus_inFront(params, "type", type));
}
public Collection beaListAny(String... types) {
return concatLists(lmap(__37 -> beaList(__37), litciset(types)));
}
public BEAObject beaGet(long id) {
return getConceptOpt(BEAObject.class, id);
}
public BEAObject beaGet(String id) {
return beaGet(parseFirstLong(id));
}
public BEAObject beaNew(Object... __) {
__ = prependParamIfOddCount("type", __);
return cnew(BEAObject.class, __);
}
public boolean beaTypeIs(BEAObject o, String type) {
return o != null && o.typeIs(type);
}
public BEAObject beaGet(String key, Req req) {
return beaGet(req.get(key));
}
public BEAObject beaGet(String field, BEAObject o) {
return cgetBEA(field, o);
}
public BEAObject cgetBEA(String field, BEAObject o) {
return (BEAObject) cget(field, o);
}
public BEAObject beaGet(BEAObject o, String field) {
return cgetBEA(o, field);
}
public BEAObject cgetBEA(BEAObject o, String field) {
return cgetBEA(field, o);
}
public String beaToHTML(BEAObject o) {
return beaLinkHTML(o);
}
public String beaHTML(BEAObject o) {
return beaLinkHTML(o);
}
public String beaLinkHTML(BEAObject o) {
return o == null ? null : ahref(conceptLink(o), htmlEncode2_nlToBr(str(o)));
}
public String beaHTML_justID(BEAObject o) {
return o == null ? null : ahref(beaShortURL(o), o.id);
}
public String beaURL(BEAObject o) {
return beaShortURL(o);
}
public String beaShortURL(BEAObject o) {
return o == null ? null : baseLink + "/" + o.id;
}
public Collection beaBackRefs(BEAObject o, String type) {
return objectsWhereCI(findBackRefs(BEAObject.class, o), "type", type);
}
public Collection beaBackRefs(BEAObject o) {
return findBackRefs(BEAObject.class, o);
}
public Object serveDefaultPage(Req req) {
HTMLFramer1 framer = req.framer;
framer.add(hcenter3(hsnippetimg_scaleToWidth(200, "#1102967", 200, 110, "title", "Gazelle"), "style", "margin-top: 100px"));
return completeFrame(req);
}
public String html_loggedIn() {
User user = user(currentReq.get());
return user == null ? ahref(baseLink + "/", "Log in") : "Logged in as " + htmlEncode2(user.name);
}
public void distributeNewObject_impl(BEAObject o) {
if (o.typeIs("Match"))
return;
distributeNotification("New object: " + o);
}
public void performAutoRuns(BEAObject o) {
AutoCloseable __28 = enter();
try {
print("performAutoRuns", o);
for (BEAObject autoRun : beaList("Auto Run")) {
if (!isTrue(getOpt("enabled", autoRun))) {
print("Not enabled: " + autoRun);
continue;
}
performAutoRunOnObject(autoRun, o);
}
} finally {
_close(__28);
}
}
public void performAutoRunOnAllObjects(BEAObject autoRun) {
for (BEAObject o : list(BEAObject.class)) performAutoRunOnObject(autoRun, o);
}
public void performAutoRunOnObject(BEAObject autoRun, BEAObject o) {
ping();
String type = getString("onChangedObjectOfType", autoRun);
if (!o.typeIs(type)) {
print("Wrong type: " + type);
return;
}
print("Running " + autoRun);
BEAObject procedure = (BEAObject) (cget("procedure", autoRun));
String internalCode = getString("internalCode", procedure);
printVars_str("internalCode", internalCode, "o", o);
if (eqic(internalCode, "convertInputToPattern")) {
String text = o.text();
if (!containsAngleBracketVars(text)) {
print("No angle bracket vars");
return;
}
BEAObject p = uniqCI_returnIfNew(BEAObject.class, "type", "Pattern", "text", text);
cset(p, "fromInput", o, "byProcedure", procedure, "byAutoRun", autoRun);
print("p", p);
} else if (eqic(internalCode, "convertInputToSyntacticPattern")) {
String text = o.text();
if (!containsStars(text)) {
print("No stars");
return;
}
BEAObject p = uniqCI_returnIfNew(BEAObject.class, "type", "Syntactic Pattern", "text", text);
cset(p, "fromInput", o, "byProcedure", procedure, "byAutoRun", autoRun);
print("p", p);
} else if (eqic(internalCode, "dropPunctuationFromPattern")) {
String text = o.text();
String text2 = dropPunctuation(text);
if (eq(text, text2))
return;
BEAObject p = uniqCI(BEAObject.class, "type", o.type(), "text", text2);
cset(o, "withoutPunctuation", p);
} else if (eqic(internalCode, "makeSyntacticPattern")) {
print("sp", calculations.makeSyntacticPattern(o));
} else if (eqic(internalCode, "runFunctionOnInput")) {
print("runFunctionOnInput");
BEAObject function = beaGet(o, "function");
BEAObject input = beaGet(o, "input");
if (function == null || input == null) {
print("Missing parameters");
return;
}
if (cget("result", o) != null) {
print("Has result");
return;
}
BEAObject result = calculations.reactFunctionWithInput(calculations.new BackEndAlgorithm(), function, input);
print("result", result);
if (result != null) {
cset(result, "request", o);
cset(o, "result", result);
}
} else
print("Unknown internal code");
}
public BEAObject findInput(String text) {
return conceptWhereIC(BEAObject.class, "type", "Input", "text", text);
}
public String addRewriteHTML(BEAObject o) {
return ahref(addParamsToURL(crudLink(BEAObject.class), "cmd", "new", "title", "Add Rewrite", "f_type", "Rewrite", "f_text", getStringOpt("text", o), "f_isRewriteOf", o.id, "metaInfo_isRewriteOf", "concept"), "Add Rewrite");
}
public Object serveIntegerLink(Req req, long id) {
BEAObject o = getConceptOpt(BEAObject.class, id);
if (o != null)
return htitle(str(o)) + hrefresh(conceptLink(o));
return super.serveIntegerLink(req, id);
}
public void distributeTestNotification() {
distributeNotification("It is " + localTimeWithSeconds());
}
public void distributeNotification(String text) {
notificationQ.add(new Runnable() {
public void run() {
try {
for (Pair p : syncMapToPairs(webSockets)) {
String jsCode = "window.createNotification({ theme: 'success', showDuration: 3000 })(" + jsonEncodeMap("message", text) + ");";
call(p.a, "send", jsonEncodeMap("eval", jsCode));
}
} catch (Exception __e) {
throw rethrow(__e);
}
}
public String toString() {
return "/*for (User user)\r\n if (nemptyAfterTrim(user.notificationSetting))\r\n ...";
}
});
}
public void runInstruction(BEAObject o) {
if (o == null)
return;
try {
BEAObject instruction = o;
if (o.typeIs("Step in script"))
instruction = (BEAObject) cget(o, "instruction");
if (instruction.typeIs("Instruction | List objects by type")) {
saveInstructionResult(o, beaList(getString("typeToList", instruction)));
return;
}
if (instruction.typeIs("Instruction | List object types")) {
saveInstructionResult(o, distinctCIFieldValuesOfConcepts(BEAObject.class, "type"));
return;
}
if (instruction.typeIs("Instruction | Filter list by text starting with")) {
BEAObject scriptRun = cgetBEA("scriptRun", o);
if (scriptRun == null)
throw fail("Need to be run as part of script");
List steps = scriptRunSteps(scriptRun);
int idx = indexOf(steps, o);
if (idx < 0)
throw fail("Step not found in script run");
List list = firstNotNull(map(reversed(takeFirst(steps, idx)), step -> optCast(List.class, cget("data", cgetBEA("result", step)))));
String prefix = getString("prefix", instruction);
List filtered = filter(list, obj -> swic(obj.text(), prefix));
saveInstructionResult(o, filtered);
return;
}
if (instruction.typeIs("Script")) {
BEAObject script = instruction;
BEAObject scriptRun = cnew(BEAObject.class, "type", "Script Run", "script", script);
int i = 0;
List steps = new ArrayList();
while ((instruction = (BEAObject) cget(instruction, "step" + (++i))) != null) {
BEAObject step = cnew(BEAObject.class, "type", "Step in script", "step", i, "scriptRun", scriptRun, "instruction", instruction);
steps.add(step);
}
cset(scriptRun, "steps", steps);
return;
}
cnew(BEAObject.class, "type", "Instruction Error", "instruction", o, "error", "Unknown instruction type");
} catch (Throwable e) {
cnew(BEAObject.class, "type", "Instruction Error", "instruction", o, "error", getStackTrace(e));
}
}
public BEAObject saveInstructionResult(BEAObject instruction, Object data) {
BEAObject result = cnew(BEAObject.class, "type", "Instruction Result", "instruction", instruction, "data", data);
cset(instruction, "result", result);
return result;
}
public List scriptRunSteps(BEAObject scriptRun) {
return (List) cget("steps", scriptRun);
}
public String addCommentHTML(BEAObject o, Object... __) {
String redirectAfterSave = (String) (optPar("redirectAfterSave", __));
String defaultComment = (String) (optPar("defaultComment", __));
String text = optPar("text", __, "Add comment");
return ahref(addParamsToURL(crudLink(BEAObject.class), "cmd", "new", "title", "Add Comment", "f_type", "Comment", "f_on", o.id, "f_text", unnull(defaultComment), "redirectAfterSave", redirectAfterSave, "autofocus", "f_text", "metaInfo_on", "concept"), text);
}
public String formatSubInput(BEAObject input, String text, String anchor) {
String redirect = addAnchorToURL(currentReq.get().uriWithParams(), anchor);
int goodCount = countConceptsCI(BEAObject.class, "type", "Sub-Input", "input", input, "text", text);
int badCount = countConceptsCI(BEAObject.class, "type", "Bad Sub-Input", "input", input, "text", text);
return calculations.bestInputHTML(text) + " " + small(joinNemptiesWithSpace(ahref(addParamsToURL(baseLink + "/storeSubInput", "label", "good", "text", text, "input", input.id, "redirect", redirect), unicode_thumbsUp()), goodCount == 0 ? "" : n2(goodCount), ahref(addParamsToURL(baseLink + "/storeSubInput", "label", "bad", "text", text, "input", input.id, "redirect", redirect), unicode_thumbsDown()), badCount == 0 ? "" : n2(badCount)));
}
public List renderObjectTypes() {
MultiSet ms = distinctCIFieldValuesOfConcepts_multiSet(BEAObject.class, "type");
return mapPairs(multiSetToPairsByPopularity(ms), (type, count) -> {
String _type = or2(type, "(no type)");
return n2(count) + " " + ahref(baseLink + "/beaCRUD/" + urlencode(_type), htmlEncode2(_type));
});
}
public BEAObject autoMigrateToBase(BEAObject o) {
return autoMigrateToClass(o, BEAObject.class);
}
public BEAObject autoMigrateToCustomClass(BEAObject o) {
return autoMigrateToClass(o, defaultCustomClass(o));
}
public BEAObject autoMigrateToClass(BEAObject o, Class targetClass) {
try {
if (o == null || o._concepts != db_mainConcepts())
return null;
if (targetClass != null && targetClass != _getClass(o))
return replaceConceptAndUpdateRefs(o, unlistedCopyToClass(targetClass, o));
} catch (Throwable __e) {
_handleException(__e);
}
return o;
}
public void setCodeState(BEAObject o, long timestamp, String codeHash, Object state) {
if (empty(state))
state = null;
else
state = "[" + formatGMTWithMilliseconds_24(timestamp) + "] " + (empty(codeHash) ? "" : "Code hash: " + codeHash + ". ") + state;
cset(o, "meta_codeState", state);
}
public String codeForObject(BEAObject o) {
String code = getString("meta_code", o);
BEAObject prototype = beaGet("meta_prototype", o);
if (prototype != null)
code = getString("meta_code", o);
return code;
}
public void activateDynamicObject(BEAObject o) {
try {
ClassLoader cl = getClassLoader(module());
print("cl", cl);
long timestamp = now();
setCodeState(o, timestamp, null, "Compiling");
String codeHash = null;
transpileAndCompileForHotwiring_src.set(null);
try {
String code = codeForObject(o);
codeHash = empty(code) ? null : md5(code);
cset(o, "meta_codeHash", codeHash);
if (empty(code)) {
o = autoMigrateToBase(o);
setCodeState(o, timestamp, null, null);
return;
}
cset(o, "meta_codeSafety", codeSafetyCheckResult(code));
String id = aGlobalID();
String mcName = "main_" + id;
String prelude = "!include early #1031282\n\n";
String src = prelude + "mainClassName " + mcName + "\n" + "concept " + id + " extends main.BEAObject {\n" + code + "\n}";
print("SRC> ", src);
javaCompileToJar_localLibraries.set(filesFromClassLoader(cl));
dm_mediumRefreshTranspiler();
File bytecode = transpileAndCompileForHotwiring(src);
copyFile(bytecode, byteCodeFileForObject(o));
dm_addByteCodePathToModuleClassLoader(bytecode);
String fullName = mcName + "$" + id;
Class targetClass = cl.loadClass(fullName);
print("targetClass", targetClass);
assertNotNull("Class not found: " + fullName, targetClass);
o = autoMigrateToClass(o, targetClass);
setCodeState(o, timestamp, codeHash, "Custom code loaded");
} catch (Throwable e) {
_handleException(e);
setCodeState(o, timestamp, codeHash, exceptionToStringShort(e));
}
saveTextFile(javaSourceFileForObject(o), transpileAndCompileForHotwiring_src.get());
} catch (Exception __e) {
throw rethrow(__e);
}
}
public File javaSourceFileForObject(BEAObject o) {
return programFile("BEA Java Sources/" + o.id + ".java");
}
public File byteCodeFileForObject(BEAObject o) {
return programFile("Object ByteCode/" + o.id + ".jar");
}
public BEAObject autoMigrateUnlistedOrKeep(BEAObject o) {
return canAutoMigrate(o) ? unlistedCopyToClass(defaultCustomClass(o), o) : o;
}
public boolean canAutoMigrate(BEAObject o) {
return o != null && !eqOneOf(defaultCustomClass(o), _getClass(o), null);
}
public Class defaultCustomClass(BEAObject o) {
if (o == null)
return null;
BEAObject entry = conceptWhereCI(BEAObject.class, "type", "Auto Custom Class", "forType", o.type());
if (entry == null)
return null;
String className = getString("toClassName", entry);
Class c = findClassThroughDefaultClassFinder(className);
return c;
}
public String queryLink(String algorithm, String q) {
return addParamsToURL(baseLink + "/query", "algorithm", algorithm, "q", q);
}
public String currentUserAgent() {
Req req = currentReq.get();
if (req == null)
return null;
return mapGet(req.webRequest.headers(), "user-agent");
}
public void saveUserAgent(BEAObject input) {
String userAgent = currentUserAgent();
if (nempty(userAgent))
uniqCI2(BEAObject.class, "type", "Input Source", "input", input, "userAgent", userAgent);
}
public boolean isObjectWithCode(BEAObject o) {
return o != null && (cget("meta_code", o) != null || cget("meta_prototype", o) != null);
}
public boolean createdByMasterUser(BEAObject o) {
User user = optCast(User.class, cget("createdBy", o));
return user != null && user.isMaster;
}
public void autoActivateDynamicObject(BEAObject o) {
if (!autoActivateDynamicObjects)
return;
if (!createdByMasterUser(o))
return;
String codeState = getString("meta_codeState", o);
String time = leadingAngleBracketStuff(codeState);
long timestamp = empty(time) ? 0 : parseDateWithMillisecondsGMT(time);
if (o._modified <= timestamp)
return;
String hash = getString("meta_codeHash", o);
if (eq(hash, md5(codeForObject(o))))
return;
print("Auto-activating dynamic object: " + o);
activateDynamicObject(o);
sleepSeconds(1);
}
}
static public boolean _moduleClass_GazelleBEA = true;
static public class BEAObject extends ConceptWithGlobalID {
public UserPost mirrorPost() {
return (UserPost) cget("mirrorPost", this);
}
public void change() {
super.change();
var mod = beaMod();
mod.rstUpdateBEAMirrors.add(this);
if (mod.autoActivateDynamicObjects)
mod.rstAutoActivateDynamicObjects.add(this);
}
public void delete() {
cdelete(mirrorPost());
super.delete();
}
public void updateMirrorPost() {
GazelleBEA mod = beaMod();
if (isDeleted() || !mod.mirrorBEAObjects)
return;
if (mirrorPost() == null)
cset(this, "mirrorPost", cnew(UserPost.class, "type", "BEA Object", "creator", mod.internalUser(), "botInfo", "BEA Mirror Bot"));
String text = structureString();
cset(mirrorPost(), "title", str(this), "text", text);
}
public String structureString() {
String text = "Error";
try {
structure_Data data = new structure_Data() {
public structure_ClassInfo newClass(Class c) {
structure_ClassInfo info = super.newClass(c);
if (c == Concept.Ref.class) {
info.special = true;
info.serializeObject = o -> {
Concept cc = (Concept) (deref((Concept.Ref) o));
if (cc instanceof BEAObject)
append("CRef(gid=" + quote(((BEAObject) cc).globalID()) + ")", 6);
else if (cc != null)
append("CRef(id=" + cc.id + ")", 6);
else
append("CRef", 1);
};
}
return info;
}
public void setFields(structure_ClassInfo info, List fields) {
if (isSubclassOf(info.c, BEAObject.class)) {
removeAll(fields, getField(BEAObject.class, "refs"), getField(BEAObject.class, "backRefs"));
}
super.setFields(info, fields);
}
};
String struct = structure(this, data);
struct = dropLoadableUtilsPackageFromStruct(struct);
text = indentStructureString_firstLevels(1, struct);
} catch (Throwable __e) {
_handleException(__e);
}
return text;
}
public String toString() {
return shorten(toString_long());
}
public String toString_long() {
String type = strOrNull(cget("type", this));
String s = super.toString();
if (nempty(type)) {
s = type + " " + id;
s += appendBracketed(strOrNull(getOpt("label", this)));
if (eqic(type, "Match"))
s += " " + getOpt("mapping", this);
}
boolean enabled = eq(true, getOpt("enabled", this));
if (enabled)
s += " [enabled]";
String text = or2(text(), getStringOpt("name", this), getStringOpt("internalCode", this));
if (text != null)
s += " " + quote(text);
Object fc = getOpt("functionCalled", this);
if (fc != null)
s += " " + fc;
Object result = getOpt("result", this);
if (result != null)
s += " = " + shorten_str(result);
return s;
}
public String type() {
return getStringOpt("type", this);
}
public boolean typeIs(String type) {
return eqic(type(), type);
}
public boolean typeIsAny(String... types) {
return typeIsOneOf(types);
}
public boolean typeIsOneOf(String... types) {
return eqicOneOf(type(), types);
}
public String text() {
return getStringOpt("text", this);
}
public BEAObject input() {
return (BEAObject) cget("input", this);
}
public BEAObject isRewriteOf() {
return (BEAObject) cget("isRewriteOf", this);
}
public String inputText() {
BEAObject input = or(input(), isRewriteOf());
return input == null ? null : input.text();
}
public Map mapping() {
return keysAndValuesToString(cgetOpt(Map.class, this, "mapping"));
}
public List directCmds() {
return ll();
}
public Collection allObjects() {
return list(_concepts, BEAObject.class);
}
public String baseLink() {
return beaMod().baseLink;
}
public BEAObject beaGet(String field, BEAObject o) {
return beaMod().beaGet(field, o);
}
public BEAObject beaGet(long id) {
return beaMod().beaGet(id);
}
public BEAObject beaGet(String field) {
return beaMod().beaGet(field, this);
}
public Object beaCall(Concept.Ref ref, String method, Object... args) {
return cCall(ref, method, args);
}
public Object beaCall(long id, String method, Object... args) {
return call(beaMod().beaGet(id), method, args);
}
public Object beaCallOpt(long id, String method, Object... args) {
return callOpt(beaMod().beaGet(id), method, args);
}
public gazelle.main.GazelleBEA beaMod() {
return _concepts == null ? null : (GazelleBEA) _concepts.miscMapGet(DynNewBot2.class);
}
public Collection beaList() {
return beaMod().beaList();
}
public Collection beaListAny(String... types) {
return beaMod().beaListAny(types);
}
public Collection beaList(String type, Object... params) {
return beaMod().beaList(type, params);
}
public String beaHTML(BEAObject o) {
return beaMod().beaHTML(o);
}
public String beaURL(BEAObject o) {
return beaShortURL(o);
}
public String beaShortURL(BEAObject o) {
return beaMod().beaURL(o);
}
public String htmlFixer(String html) {
return fixHTML(html);
}
public String fixHTML(String html) {
return beaMod().callHTMLFixer(this, html);
}
}
static public class BEARegExp extends BEAObject {
static final public String _fieldOrder = "text caseInsensitive";
public String text;
public boolean caseInsensitive = true;
public boolean valid() {
return nempty(text);
}
public java.util.regex.Pattern compile() {
return compileRegexpPossiblyIC_unicodeCase(text, caseInsensitive);
}
}
static public class BEARegExpReplacement extends BEARegExp {
public String replacement;
public String apply(String text) {
try {
return regexpReplace_directWithRefs(compile().matcher(text), unnull(replacement));
} catch (Throwable e) {
throw fail(format_quoted("Was searching * in * ", this.text, text));
}
}
public List directCmds() {
return listPlus(super.directCmds(), !valid() ? "Note: not valid" : targetBlank(beaMod().queryLink("Apply regular expression replacement to all inputs", str(id)), "Apply to all inputs"));
}
}
static public class BEAPatternList extends BEAObject {
public RefL patterns = new RefL();
public String toString() {
return super.toString() + ": " + nPatterns(patterns);
}
}
static public GazelleBEA beaMod() {
return (GazelleBEA) botMod();
}
static public JavaXClassLoader hotwire_makeClassLoader(List files) {
ClassLoader cl = myClassLoader();
return new JavaXClassLoaderWithParent2(null, files, cl, ll());
}
static public AutoCloseable tempInterceptPrintIfNotIntercepted(F1 f) {
return print_byThread().get() == null ? tempInterceptPrint(f) : null;
}
static volatile public Concepts mainConcepts;
static public Concepts db_mainConcepts() {
if (mainConcepts == null)
mainConcepts = newConceptsWithClassFinder(getDBProgramID());
return mainConcepts;
}
static public void cleanMeUp_concepts() {
if (db_mainConcepts() != null)
db_mainConcepts().cleanMeUp();
}
static public String unnullForIteration(String s) {
return s == null ? "" : s;
}
static public Collection unnullForIteration(Collection l) {
return l == null ? immutableEmptyList() : l;
}
static public List unnullForIteration(List l) {
return l == null ? immutableEmptyList() : l;
}
static public int[] unnullForIteration(int[] l) {
return l == null ? emptyIntArray() : l;
}
static public char[] unnullForIteration(char[] l) {
return l == null ? emptyCharArray() : l;
}
static public double[] unnullForIteration(double[] l) {
return l == null ? emptyDoubleArray() : l;
}
static public Map unnullForIteration(Map l) {
return l == null ? immutableEmptyMap() : l;
}
static public Iterable unnullForIteration(Iterable i) {
return i == null ? immutableEmptyList() : i;
}
static public A[] unnullForIteration(A[] a) {
return a == null ? (A[]) emptyObjectArray() : a;
}
static public BitSet unnullForIteration(BitSet b) {
return b == null ? new BitSet() : b;
}
static public Pt unnullForIteration(Pt p) {
return p == null ? new Pt() : p;
}
static public Pair unnullForIteration(Pair p) {
return p != null ? p : new Pair(null, null);
}
static public long unnullForIteration(Long l) {
return l == null ? 0L : l;
}
static public Map flexMatchAngleBracketVarsIC_honorPunctuation_noBrackets_first(String pat, String input) {
return grabValueAndCancel(new VF1>>() {
public void get(VF1> onMatch) {
try {
flexMatchAngleBracketVarsIC_honorPunctuation_noBrackets_iterate(pat, input, onMatch);
} catch (Exception __e) {
throw rethrow(__e);
}
}
public String toString() {
return "flexMatchAngleBracketVarsIC_honorPunctuation_noBrackets_iterate(pat, input, o...";
}
});
}
static public String appendSquareBracketed(String b) {
return empty(b) ? "" : "" + " [" + b + "]";
}
static public String appendSquareBracketed(String a, String b) {
return empty(b) ? a : a + appendSquareBracketed(b);
}
static public String jquery_submitFormOnCtrlEnter() {
return "if ((event.keyCode == 10 || event.keyCode == 13) && event.ctrlKey) $(this).closest('form').submit();";
}
static public String hjs_handleScrollToAnchor() {
return hjs("\r\n $(window).on(\"load\", function() {\r\n var anchor = window.location.hash.substr(1);\r\n var match = anchor.match(/^scrollTo(\\d+)$/);\r\n if (match) {\r\n var y = parseInt(match[1]);\r\n console.log(\"Scrolling to \" + y);\r\n window.scrollTo(0, y);\r\n }\r\n });\r\n ");
}
static public String js_redirectAutoScroll2() {
return "$(\"input[name=redirect], input[name=redirectAfterSave]\").val(window.location.toString().replace(/(#.+?)$/, \"\") + (window.scrollY == 0 ? \"\" : \"#scrollTo\" + Math.round(window.scrollY)));";
}
static public String hSingleRowTable_withSpacing(Object... elements) {
return hSingleRowTable_withSpacing(10, elements);
}
static public String hSingleRowTable_withSpacing(int spacing, Object... elements) {
return tag("table", tr(join("() {
public String get(Object x) {
try {
return td_top(x);
} catch (Exception __e) {
throw rethrow(__e);
}
}
public String toString() {
return "td_top(x)";
}
}, nonNulls(elements)))));
}
static public String tok_dropCurlyBrackets(String s) {
return join(tok_dropCurlyBrackets(javaTok(s)));
}
static public List tok_dropCurlyBrackets(List tok) {
for (int i = 1; i < l(tok); i += 2) {
while (eqGetOneOf(tok, i, "{", "}")) {
tokAppend(tok, i - 1, tok.get(i + 1));
removeSubList(tok, i, i + 2);
}
}
return tok;
}
static public Map mapToKey(Iterable l, IF1 f) {
return mapToKeys(l, f);
}
static public Map mapToKey(IF1 f, Iterable l) {
return mapToKeys(f, l);
}
static public List wideningListCast(Class c, List l) {
return (List) l;
}
static public String _className(Object o) {
return className(o);
}
static public String htmlDecode_dropTags(String html) {
return htmldecode_dropAllTags(html);
}
static public MultiSet distinctCIFieldValuesOfConcepts_multiSet(Class c, String field) {
return distinctCIFieldValuesOfConcepts_multiSet(db_mainConcepts(), c, field);
}
static public MultiSet distinctCIFieldValuesOfConcepts_multiSet(Concepts concepts, Class c, String field) {
IFieldIndex index = concepts.getCIFieldIndex(c, field);
if (index != null)
return index.allValues_multiSet();
MultiSet set = ciMultiSet();
for (A x : concepts.list(c)) set.add((String) getOpt(x, field));
return set;
}
static public TreeMap toCIMap(Map map) {
return asCIMap(map);
}
static public B getAny(Map map, A... keys) {
for (A a : unnullForIteration(keys)) {
B b = map.get(a);
if (b != null)
return b;
}
return null;
}
static public Set collectAngleBracketVars(String s) {
return collectAngleBracketVars(javaTokWithAngleBrackets(s));
}
static public Set collectAngleBracketVars(List tok) {
Set set = ciSet();
for (int i = 0; i < l(tok); i++) if (isAngleBracketVar(tok.get(i)))
set.add(deAngleBracket(tok.get(i)));
return set;
}
static public Map mapToValues_ciMap(Iterable l, Object f) {
return mapToValues_ciMap(f, l);
}
static public Map mapToValues_ciMap(Object f, Iterable l) {
Map map = ciMap();
if (l != null)
for (String o : l) map.put(o, callF(f, o));
return map;
}
static public Map mapToValues_ciMap(Iterable l, IF1 f) {
return mapToValues_ciMap(f, l);
}
static public List regexpFindRangesIC(String pat, String s) {
Matcher m = regexpMatcherIC(pat, s);
List l = new ArrayList();
while (m.find()) l.add(new IntRange(m.start(), m.end()));
return l;
}
static public A csetAndReturn(A c, Object... values) {
cset(c, values);
return c;
}
static public Object getStandardFunctionHolder(String functionName) {
for (Object o : mcAndUtils()) if (hasMethodNamed(o, functionName))
return o;
return loadFunction_cached(functionName);
}
static public Map putKeysFirst(Map map, Object... keys) {
Map m2 = litorderedmap();
Map remaining = cloneMap(map);
for (Object key : keys) {
if (remaining.containsKey(key)) {
m2.put(key, remaining.get(key));
remaining.remove(key);
}
}
m2.putAll(remaining);
return m2;
}
static public Map putKeysFirst(List keys, Map map) {
return putKeysFirst(map, toObjectArray(keys));
}
static public List concatMap_lists(Object f, Iterable l) {
return concatMap(f, l);
}
static public List concatMap_lists(Iterable l, Object f) {
return concatMap(l, f);
}
static public List concatMap_lists(Object f, Object[] l) {
return concatMap(f, l);
}
static public List concatMap_lists(Object[] l, Object f) {
return concatMap(l, f);
}
static public > List concatMap_lists(Iterable l, IF1 f) {
return concatMap(l, f);
}
static public > List concatMap_lists(IF1 f, Iterable l) {
return concatMap(f, l);
}
static public List findBackRefsWithField(Concept c, Class type, String field) {
return filter(findBackRefs(c, type), o -> cget(o, field) == c);
}
static public List findBackRefsWithField(Class type, Concept c, String field) {
return findBackRefsWithField(c, type, field);
}
static public List findBackRefsWithField(Class type, String field, Concept c) {
return findBackRefsWithField(c, type, field);
}
static public int countWhereCI(Collection c, Object... data) {
int n = 0;
if (c != null)
for (Object x : c) if (checkFieldsIC(x, data))
++n;
return n;
}
static public void quickImportMainConcepts(Object oldConcepts) {
quickImportMainConcepts(oldConcepts, null);
}
static public void quickImportMainConcepts(Object oldConcepts, IF0 enabled) {
if (!shortNameIs(oldConcepts, "Concepts"))
return;
Concepts concepts = db_mainConcepts();
concepts.miscMapPut("dbGrabber", new F0() {
public Boolean get() {
try {
concepts.miscMapRemove("dbGrabber");
try {
if (isFalse(callF(enabled)))
return false;
concepts.idCounter = getLong("idCounter", oldConcepts);
printVars_str("idCounter", concepts.idCounter);
Map oldMap = (Map) (_get("concepts", oldConcepts));
printVars_str("oldMap", oldMap);
RealmCopy rc = new RealmCopy();
rc.nonTransientOnly = true;
rc.fullCopy = true;
rc.overrideCollectionOrMapCopy = o -> {
rc.classMap.put(_getClass(o), _getClass(o));
return false;
};
{
AutoCloseable __1 = tempSetTL(dynamicObjectIsLoading_threadLocal(), true);
try {
concepts.concepts.putAll((Map) rc.copy(oldMap));
} finally {
_close(__1);
}
}
pnl("quickImportDB", mapSortedByFunctionOnKey(__48 -> str(__48), rc.classMap));
concepts.assignConceptsToUs();
print(nConcepts(countConcepts()) + " quick-imported");
return true;
} catch (Throwable __e) {
_handleException(__e);
}
return false;
} catch (Exception __e) {
throw rethrow(__e);
}
}
public String toString() {
return "concepts.miscMapRemove(\"dbGrabber\");\r\n pcall {\r\n if (isFalse(callF(en...";
}
});
}
static public void db() {
conceptsAndBot();
}
static public void db(Integer autoSaveInterval) {
conceptsAndBot(autoSaveInterval);
}
static public PrintWriter filePrintWriter_append(File f) {
return printWriter(bufferedFileOutputStream_append(f));
}
static public void printAllConceptChanges() {
printAllConceptChanges(db_mainConcepts());
}
static public void printAllConceptChanges(Concepts cc) {
cc.addConceptIndex(new IConceptIndex() {
public void update(Concept c) {
print("Updated: " + c);
}
public void remove(Concept c) {
print("Removed: " + c);
}
});
cc.onAllChanged.add(new Runnable() {
public void run() {
try {
print("General concepts change");
} catch (Exception __e) {
throw rethrow(__e);
}
}
public String toString() {
return "print(\"General concepts change\");";
}
});
}
static public Object defaultDefaultClassFinder() {
return new F1() {
public Class get(String name) {
Class c = get2(name);
return c;
}
public Class get2(String name) {
if (eq(name, ""))
return mc();
{
Class c = findClass_fullName(name);
if (c != null)
return c;
}
if (startsWithAny(name, "loadableUtils.utils$", "main$", mcDollar()))
for (String pkg : ll("loadableUtils.utils$", mcDollar())) {
String newName = pkg + afterDollar(name);
{
Class c = findClass_fullName(newName);
if (c != null)
return c;
}
}
return null;
}
};
}
static public void seedDBFrom(String progID) {
bootstrapConceptsFrom(progID);
}
static public String renderConceptClassesWithCount(Concepts cc) {
MultiSet ms = new MultiSet();
for (Concept c : values(cc.concepts)) ms.add(dynamicShortName(c));
return renderMultiSet(ms);
}
static public void dm_onSnippetTranspiled(VF1 r) {
dm_requireSnippetUpdatesModule();
final DynModule m = dm_current_mandatory();
dm_vmBus_onMessage("snippetUpdate", new VF1() {
public void get(final List l) {
try {
m.q().add(new Runnable() {
public void run() {
try {
String uri = getString(l, 1);
Matches m = new Matches();
if (swic(uri, "/transpileOK/", m)) {
String snippetID = fsI(firstIntAsString(m.rest()));
callF(r, snippetID);
}
} catch (Exception __e) {
throw rethrow(__e);
}
}
public String toString() {
return "String uri = getString(l, 1);\r\n new Matches m;\r\n if (swic(uri, \"/transp...";
}
});
} catch (Exception __e) {
throw rethrow(__e);
}
}
public String toString() {
return "switch to m.q();\r\n S uri = getString(l, 1);\r\n new Matches m;\r\n if (s...";
}
});
}
static public void dm_onSnippetTranspiled(String snippetID, Runnable r) {
if (empty(snippetID) || r == null)
return;
dm_onSnippetTranspiled(new VF1() {
public void get(String snippetID2) {
try {
if (sameSnippetID(snippetID, snippetID2))
r.run();
} catch (Exception __e) {
throw rethrow(__e);
}
}
public String toString() {
return "if (sameSnippetID(snippetID, snippetID2))\r\n r.run();";
}
});
}
static public void dm_reloadModule(Object module) {
dm_reloadModuleInBackground(module);
}
static public void dm_reloadModule() {
dm_reloadModuleInBackground();
}
static public List llNempties(String... a) {
ArrayList l = new ArrayList(a.length);
if (a != null)
for (String x : a) if (nempty(x))
l.add(x);
return l;
}
static public List objectsWhereNotIC(Collection c, Object... data) {
if (c == null)
return null;
List l = new ArrayList();
for (A x : c) if (!checkFieldsIC(x, data))
l.add(x);
return l;
}
static public A cgetOpt(Class type, Concept c, String field) {
return optCast(type, cget(c, field));
}
static public List> bitSetStreaksAndNonStreaks(BitSet bs, int n) {
int start = 0;
Boolean last = null;
List> out = new ArrayList();
for (int i = 0; i < n; i++) {
Boolean result = bs.get(i);
if (last != null && neq(result, last)) {
out.add(pair(intRange(start, i), last));
start = i;
}
last = result;
}
if (start < n)
out.add(pair(intRange(start, n), last));
return out;
}
static public String aname(String anchor, Object contents, Object... params) {
return tag("a", contents, concatArrays(new Object[] { "name", anchor }, params));
}
static public String htmlEncode2_str(Object o) {
return htmlEncode2_gen(o);
}
static public A assertNempty(A a) {
return assertNempty("empty", a);
}
static public A assertNempty(String msg, A a) {
if (empty(a))
throw fail(msg + ": " + a);
return a;
}
static public List assertStringList(Object o) {
if (!(o instanceof List))
throw fail("Not a list: " + className(o));
List l = (List) o;
for (Object x : l) if (!(x instanceof String))
throw fail("Not a string: " + className(x));
return l;
}
static public void dm_reloadModuleIn(double seconds) {
Object mod = dm_current_generic();
if (mod == null)
return;
print("Reloading module in " + seconds);
doAfter(seconds, new Runnable() {
public void run() {
try {
dm_reloadModule(mod);
} catch (Exception __e) {
throw rethrow(__e);
}
}
public String toString() {
return "dm_reloadModule(mod)";
}
});
}
static public Timed returnTimed(IF0 f) {
long time = sysNow();
A a = f.get();
return new Timed(a, sysNow() - time);
}
static public Timed returnTimed(Runnable r) {
return returnTimed(runnableToIF0(r));
}
static public String ul_htmlEncode2(String... list) {
return ul_htmlEncode(list);
}
static public String ul_htmlEncode2(Collection list, Object... params) {
return ul_htmlEncode(list, params);
}
static public List allConceptShadows() {
return allConceptShadows(db_mainConcepts());
}
static public List allConceptShadows(Concepts cc) {
if (cc == null)
return null;
List l = asList(cc.allConcepts());
assertTrue("Concepts are sorted by id", isSortedListByCalculatedField(__49 -> conceptID(__49), l));
return lmap(__50 -> conceptShadow(__50), l);
}
static public List> diffConceptShadows(List l1, List l2) {
List> diffs = new ArrayList();
int i1 = 0, i2 = 0;
while (i1 < l(l1) && i2 < l(l2)) {
ConceptShadow s1 = l1.get(i1), s2 = l2.get(i2);
long id1 = s1.id(), id2 = s2.id();
if (id1 < id2) {
diffs.add(new CreatedDeletedChanged.Deleted(s1));
++i1;
} else if (id1 > id2) {
diffs.add(new CreatedDeletedChanged.Created(s2));
++i2;
} else {
if (!eq(s1, s2))
diffs.add(new CreatedDeletedChanged.Changed(s1, s2));
++i1;
++i2;
}
}
while (i1 < l(l1)) diffs.add(new CreatedDeletedChanged.Deleted(l1.get(i1++)));
while (i2 < l(l2)) diffs.add(new CreatedDeletedChanged.Created(l2.get(i2++)));
return diffs;
}
static public Object subBot_serveText(Object s) {
return call(getMainBot(), "serveByteArray", toUtf8(str(s)), "text/plain; charset=utf8");
}
static public String nDiffs(long n) {
return n2(n, "diff");
}
static public String nDiffs(Collection l) {
return nDiffs(l(l));
}
static public String nDiffs(Map map) {
return nDiffs(l(map));
}
static public String regexpExtractGroup(String pat, String s) {
if (s == null)
return null;
Matcher m = regexpMatcher(pat, s);
return m.find() ? m.group(1) : null;
}
static public String profileThisThreadToString(Runnable r) {
poorMansProfiling(currentThread());
try {
r.run();
} catch (Throwable __e) {
_handleException(__e);
}
return poorMansProfiling_stopAndRenderResults();
}
static public Pair profileThisThreadToString(IF0 f) {
Var var = new Var();
String profile = profileThisThreadToString(new Runnable() {
public void run() {
try {
var.set(callF(f));
} catch (Exception __e) {
throw rethrow(__e);
}
}
public String toString() {
return "var.set(callF(f))";
}
});
return pair(var.get(), profile);
}
static public String lastTiming_formatted() {
return renderElapsedTimePleasantly(lastTiming());
}
static public Object[] prependParamIfOddCount(Object x, Object[] params) {
if (odd(l(params)))
return itemPlusObjectArray(x, params);
return params;
}
static public boolean containsStars(String s) {
return containsStars(javaTok_cached(s));
}
static public boolean containsStars(List tok) {
for (int i = 1; i < l(tok); i += 2) if (eq(tok.get(i), "*"))
return true;
return false;
}
static public String unicode_thumbsUp() {
return unicodeFromCodePoint(0x1F44D);
}
static public String unicode_thumbsDown() {
return unicodeFromCodePoint(0x1F44E);
}
static public A replaceConceptAndUpdateRefs(Concept a, A b) {
assertTrue("object to replace with must be unlisted", isUnlisted(b));
Concepts cc = a.concepts();
assertTrue("object to replace must be listed", cc != null);
List refs = allBackRefObjects(a);
b.id = a.id;
deleteConcept(a);
cc.register_phase2(b);
for (Concept.Ref ref : refs) ref.set(b);
return b;
}
static public A unlistedCopyToClass(Class c, Concept a) {
if (a == null)
return null;
A b = unlisted(c);
ccopyFields(a, b);
return b;
}
static public String formatGMTWithMilliseconds_24() {
return formatGMTWithMilliseconds_24(now());
}
static public String formatGMTWithMilliseconds_24(long time) {
var sdf = simpleDateFormat("HH:mm:ss''SSSS", TimeZone.getTimeZone("GMT"));
return sdf.format(time) + " GMT";
}
static public String codeSafetyCheckResult(String code) {
String safety = joinWithComma(getCodeFragmentSafety(code));
if (neq(safety, "safe")) {
Set unknown = codeAnalysis_getUnknownIdentifiers(code);
if (nempty(unknown))
safety += ". Unknown identifiers: " + joinWithComma(unknown);
}
return safety;
}
static public List filesFromClassLoader(Class c) {
return filesFromClassLoader(getClassLoader(c));
}
static public List filesFromClassLoader(ClassLoader cl) {
Collection l = filesFromClassLoader_new(cl);
return l == null ? null : asList(l);
}
static public void dm_mediumRefreshTranspiler() {
dm_call(dm_moduleOfType("#1017065/Transpiler"), "mediumRefresh");
}
static public ThreadLocal transpileAndCompileForHotwiring_src = new ThreadLocal();
static public File transpileAndCompileForHotwiring(String src) {
return transpileAndCompileForHotwiring(src, null);
}
static public File transpileAndCompileForHotwiring(String src, List libs) {
transpileAndCompileForHotwiring_src.set(null);
libs = cloneList(libs);
src = transpileRaw(src);
transpileAndCompileForHotwiring_src.set(src);
src = findTranslators2(src, libs);
String dehlibs = join(" ", libs);
File bytecode = javaCompile_overInternalBot(src, dehlibs);
print("bytecode", bytecode);
print("Files: " + listZip(bytecode));
return bytecode;
}
static public void dm_addByteCodePathToModuleClassLoader(File bytecode) {
try {
ClassLoader cl = getClassLoader(dm_current_mandatory_generic());
print("Adding to class loader " + cl + ": " + bytecode);
call(cl, "addFile", bytecode);
} catch (Exception __e) {
throw rethrow(__e);
}
}
static public Class findClassThroughDefaultClassFinder(String shortName) {
return shortName == null ? null : (Class) callF(_defaultClassFinder(), "main$" + shortName);
}
static public String leadingAngleBracketStuff(String s) {
if (!startsWith(s, ']'))
return null;
return substring(s, 1, smartIndexOf(s, ']'));
}
static public long parseDateWithMillisecondsGMT(String s) {
try {
return simpleDateFormat_GMT("yyyy/MM/dd HH:mm:ss''SSSS").parse(dropSuffix(" GMT", s)).getTime();
} catch (Exception __e) {
throw rethrow(__e);
}
}
static public String shorten_str(Object o) {
return shorten(str(o));
}
static public Map keysAndValuesToString(Map map) {
return mapKeysAndValues(__51 -> str(__51), map);
}
static public Object cCall(Concept.Ref ref, String method, Object... args) {
return ccall(ref, method, args);
}
static public Object cCall(Object object, String method, Object... args) {
return ccall(object, method, args);
}
static public String fixHTML(Object contents) {
String s = str(contents);
return hhtml(hbody(s));
}
static public java.util.regex.Pattern compileRegexpPossiblyIC_unicodeCase(String pat, boolean ic) {
return ic ? compileRegexpIC_unicodeCase(pat) : compileRegexp(pat);
}
static public String regexpReplace_directWithRefs(String s, String pat, String replacement) {
Matcher m = regexp(pat, s);
return regexpReplace_direct(m, replacement);
}
static public String regexpReplace_directWithRefs(Matcher m, String replacement) {
StringBuffer buf = new StringBuffer();
while (m.find()) m.appendReplacement(buf, replaceDollarVars2_dyn(replacement, v -> !isInteger(v) ? null : matcherGroup(m, parseInt(v))));
m.appendTail(buf);
return str(buf);
}
static public String format_quoted(String pat, Object... args) {
return format_quoteAll(pat, args);
}
static public String nPatterns(long n) {
return n2(n, "pattern");
}
static public String nPatterns(Collection l) {
return nPatterns(l(l));
}
static public String nPatterns(Map map) {
return nPatterns(l(map));
}
static public Concepts newConceptsWithClassFinder(String progID) {
Concepts cc = new Concepts(progID);
cc.classFinder = _defaultClassFinder();
return cc;
}
static public List immutableEmptyList() {
return Collections.emptyList();
}
static public Map immutableEmptyMap() {
return Collections.emptyMap();
}
static public void flexMatchAngleBracketVarsIC_honorPunctuation_noBrackets_iterate(String pat, String input, VF1> onMatch) {
List vars = new ArrayList();
String starsPat = angleBracketVarsToStars(pat, vars);
flexMatchIC_iterate(starsPat, javaTok(starsPat), javaTok(input), new VF1() {
public void get(Matches m) {
try {
Map map = matchesToMapUsingVarList_ciMap(m, vars);
if (map != null)
callF(onMatch, map);
} catch (Exception __e) {
throw rethrow(__e);
}
}
public String toString() {
return "SS map = matchesToMapUsingVarList_ciMap(m, vars);\r\n if (map != null) callF...";
}
});
}
static public String td_top(Object contents, Object... params) {
return tdTop(contents, params);
}
static public void tokAppend(List tok, int i, String s) {
tok.set(i, tok.get(i) + s);
}
static public Map mapToKeys(Iterable