Theories Storing Bot (LIVE) [1002762]

!759

static PersistentMap<S, S> theories; // name -> text
static new MultiMap<S, S> signMap;

static new Map<S, S> icCache; // lower case name -> text

static class Sign {
  S user, theory, as;
  long since;
}

static new L<Sign> signList; // v2 of signMap

static boolean printTimings = false;

p {
  theories = new PersistentMap("theories");
  for (S name : getTheoryNames()) icCache.put(name.toLowerCase(), theories.get(name));
  load("signMap");
  load("signList");
}

static synchronized L<S> getTheoryNames() {
  ret new ArrayList(theories.keySet());
}

static synchronized boolean hasTheory(S name) {
  ret icCache.containsKey(name.toLowerCase());
}

static synchronized S getTheoryOpt(S name) {
  ret icCache.get(name.toLowerCase());
}

static synchronized S getTheory(S name) {
  S text = getTheoryOpt(name);
  if (text == null) fail("Theory * not found", name);
  ret text;
}

static synchronized L<S> getTheoriesSignedByAs(S user, S as) {
  new L<S> l;
  for (Sign s : signList)
    if (eq(s.user, user) && eq(s.as, as))
      l.add(s.theory);
  ret l;
}

static synchronized Sign findSigning(S user, S as, S theory) {
  for (Sign s : signList)
    if (eq(s.user, user) && eq(s.as, as) && eq(s.theory, theory))
      ret s;
  ret null;
}

static synchronized void theoriesPut(S name, S text) {
  theories.put(name, text);
  icCache.put(name.toLowerCase(), text);
}

static synchronized void theoriesRemove(S name) {
  theories.remove(name);
  icCache.remove(name.toLowerCase());
}

static S signTheory(S user, S theory, S as) {
  if (empty(user)) ret "go to slack please";
  if (!hasTheory(theory)) ret "Theory not found";
  if (getTheoriesSignedByAs(user, as).contains(theory))
    ret "You have already signed this theory as " + as + "!";
  new Sign sign;
  sign.user = user;
  sign.theory = theory;
  sign.as = as;
  sign.since = now();
  signList.add(sign);
  save("signList");
  ret format("OK, signed * as *!", theory, as);
}

static S unsignTheory(S user, S theory, S as) {
  if (empty(user)) ret "go to slack please";
  if (!hasTheory(theory)) ret "Theory not found";
  Sign sign = findSigning(user, as, theory);
  if (sign == null)
    ret "You have not signed this theory as " + as + ".";
  signList.remove(sign);
  save("signList");
  ret format("OK, unsigned * as *.", theory, as);
}

synchronized answer {
  //if (!attn()) ret null;
  
  if "count theories"
    ret lstr(theories);
    
  if "list theories"
    ret structure(keys(theories));
    
  if "show theory *" exceptionToUser {
    ret showTheories(litlist(m.unq(0)));
  }
  
  if (matchStart("show theories", s, m)) exceptionToUser {
    ret showTheories(codeTokensOnly(javaTok(m.rest())));
  }
  
  if "modify theory * *" exceptionToUser {
    S name = m.unq(0), text = m.unq(1);
    ret saveTheory(name, text, true);
  }
  
  if "add theory * *" exceptionToUser {
    S name = m.unq(0), text = m.unq(1);
    ret saveTheory(name, text, false);
  }
  
  S line = firstLine(s).trim();
  if (startsWithIgnoreCase(line, "theory ") && l(toLines(s)) > 1) exceptionToUser {
    line = dropPrefixIgnoreCase("theory ", line);
    line = dropSuffix(":", line).trim();
    S name = unquote(line), text = dropFirstLine(s);
    ret saveTheory(name, text, false);
  }
  
  if (match("inc theory * *", s, m) || match("increment theory * *", s, m)) exceptionToUser {
    S name = m.unq(0), text = m.unq(1);
    ret incrementTheory(name, text);
  }
  
  if "sign theory *" exceptionToUser {
    S user = getUserName();
    ret signTheory(user, m.unq(0), "default");
  }
  
  if "unsign theory *" exceptionToUser {
    S user = getUserName();
    ret unsignTheory(user, m.unq(0), "default");
  }
  
  if "sign theory * as *" exceptionToUser {
    S user = getUserName();
    ret signTheory(user, m.unq(0), m.unq(1));
  }
  
  if "unsign theory * as *" exceptionToUser {
    S user = getUserName();
    ret unsignTheory(user, m.unq(0), m.unq(1));
  }
  
  if "my signed theories" exceptionToUser {
    S user = getUserName();
    if (empty(user)) ret "go to slack please";
    ret structure(getTheoriesSignedByAs(user, "default"));
  }

  if "my theories signed as *" exceptionToUser {
    S user = getUserName();
    if (empty(user)) ret "go to slack please";
    ret structure(getTheoriesSignedByAs(user, m.unq(0)));
  }

  if "theories signed by *" exceptionToUser {
    S user = m.unq(0);
    ret structure(getTheoriesSignedByAs(user, "default"));
  }
  
  if (match("theories page", s) || match("theories url", s))
    ret getBotURL();

  if (!master()) ret null;
  
  if "delete theory *" exceptionToUser {
    S name = m.unq(0);
    if (hasTheory(name)) {
      S text = getTheoryOpt(name);
      logMap("deleted", "name", name, "text", text, "time", now(), "signers", signMap.get(name));
      logMap("deleted", "name", name, "signers", signMap.get(name));
      theoriesRemove(name);
      
      signMap.remove(name);
      save("signMap");
      
      ret format("Theory * backed up & deleted", name);
    } else
      ret format("Theory * not found", name);
  }
  
  if "rename theory * to *" exceptionToUser {
    S name = m.unq(0), newName = m.unq(1);
    if (hasTheory(newName))
      ret format("A theory named * already exists", newName);
    if (hasTheory(name)) {
      S text = getTheoryOpt(name);
      theoriesPut(newName, text);
      theoriesRemove(name);

      // update signMap
      L<S> signers = signMap.get(name);
      signMap.addAll(newName, signers);
      signMap.remove(name);
      save("signMap");
      
      ret format("Theory * renamed to *", name, newName);
    } else
      ret format("Theory * not found", name);
  }
}

static S showTheories(L<S> theoryNames) {
  new StringBuilder buf;
  for (S name: theoryNames) {
    if (!hasTheory(name))
      buf.append(format("Theory * not found\n", name));
    else {
      buf.append(quote(name) + "\n" + slackSnippet(getTheoryOpt(name)) + "\n\n");
    }
  }
  ret str(buf).trim();
}

static S html(S uri, Map<S, S> params) {
  if (eq(uri, "/signList"))
    ret htmlencode(structure(signList));
  
  if (eq(uri, "/theories"))
    ret htmlencode(structure(theories));
    
  if (eq(uri, "/theoriesInc")) {
    int n = parseInt(or(params.get("n"), "0"));
    S id = params.get("id");
    
    if (nempty(id) && neq(id, theories.id()))
      n = 0;
      
    int m = (int) theories.file.length();
    S text = unnull(loadTextFileStartingFrom(theories.file, n));
    //text = substr(text, n);
    ret theories.id() + "\n" + m + "\n" + htmlencode(text);
  }

  boolean showMulti = false;
  new L data;
  MultiMap<S, Sign> signs = getSigningsByTheory();
  for (S name : getTheoryNames()) {
    S text = unnull(getTheoryOpt(name));
    boolean multi = false;
    Exception error = null;
    L<Sign> signings = signs.get(name);
    new L<S> bla;
    for (Sign sign : signings)
      bla.add(sign.user + " as " + sign.as);
    Map map = litmap(
      "Name", htmlencode(name),
      "Theory", pre(htmlencode(minitrim(rtrim(text)))),
      "Signed by", htmlencode(join(", ", bla)));
    if (showMulti) {
      map.put("Multiple rules?", multi);
      try {
        multi = nlIsMultipleStatements(text);
      } catch (Exception e) {
        error = e;
      }
    }
    if (error != null)
      map.put("Parse Error", str(error));
    data.add(map);
  }
  ret h3("Theories!") + htmlTable(data, false);
}

// preserves formatting of first line
static S minitrim(S s) {
  L<S> l = toLines(s);
  while (!empty(l) && empty(trim(first(l))))
    l.remove(0);
  ret autoUnindent(fromLines(l));
}

static S saveTheory(S name, S text, boolean autoModify) {
  boolean has = hasTheory(name);
  S oldText = getTheoryOpt(name);
  S origName = name;
  int counter = 0;
  while (has && !autoModify) {
    name = origName + "." + (char) (((int) 'a') + (++counter));
    has = hasTheory(name);
  }
  logMap(has ? "modified" : "added", "name", name, "text", text, "time", now(), "oldText", oldText);
  theoriesPut(name, text);
  ret format((has ? "OK, modified theory *" : "OK, added theory *"), name);
}

static synchronized long getTheoryCounter(S name) {
  S text = getTheoryOpt(name + ".count");
  ret isEmpty(text) ? 0 : parseLong(text);
}

// returns inc'ed value
static synchronized long incTheoryCounter(S name) {
  long c = getTheoryCounter(name);
  ++c;
  theoriesPut(name + ".count", str(c));
  ret c;
}

// returned list might include null elements
static L<S> getIncrements(S name) {
  new L<S> l;
  long n = getTheoryCounter(name);
  for (long i = 1; i <= n; i++)
    l.add(getTheoryOpt(name + "." + i));
  ret l;
}

static synchronized S incrementTheory(S name, S newText) {
  long n = incTheoryCounter(name);
  ret saveTheory(name + "." + n, newText, false);
}

static synchronized MultiMap<S, Sign> getSigningsByTheory() {
  new MultiMap<S, Sign> map;
  for (Sign s : signList)
    map.put(s.theory, s);
  ret map;
}

Travelled to 13 computer(s): aoiabmzegqzx, bhatertpkbcr, cbybwowwnfue, cfunsshuasjs, gwrvuhgaqvyk, ishqpsrjomds, lpdgvwnxivlt, mqqgnosmbjvj, pyentgdyhuwx, pzhvpgtvlbxg, tslmcundralx, tvejysmllsmz, vouqrxazstgt

Snippet ID:	#1002762
Snippet name:	Theories Storing Bot (LIVE)
Eternal ID of this version:	#1002762/1
Text MD5:	f235db8b76b3e31ef4b3667e35e7c40d
Transpilation MD5:	141fc2f9712f7d8c8756b98e3aab8911
Author:	stefan
Category:	eleu / nl
Type:	JavaX source code
Public (visible to everyone):	Yes
Archived (hidden from active list):	No
Created/modified:	2016-03-24 19:55:37
Source code size:	9189 bytes / 328 lines
Pitched / IR pitched:	No / No
Views / Downloads:	1017 / 2194
Referenced in:	[show references]

< > BotCompany Repo | #1002762 // Theories Storing Bot (LIVE)

JavaX source code [tags: use-pretranspiled] - run with: x30.jar

1	!759
2
3	static PersistentMap<S, S> theories; // name -> text
4	static new MultiMap<S, S> signMap;
5
6	static new Map<S, S> icCache; // lower case name -> text
7
8	static class Sign {
9	S user, theory, as;
10	long since;
11	}
12
13	static new L<Sign> signList; // v2 of signMap
14
15	static boolean printTimings = false;
16
17	p {
18	theories = new PersistentMap("theories");
19	for (S name : getTheoryNames()) icCache.put(name.toLowerCase(), theories.get(name));
20	load("signMap");
21	load("signList");
22	}
23
24	static synchronized L<S> getTheoryNames() {
25	ret new ArrayList(theories.keySet());
26	}
27
28	static synchronized boolean hasTheory(S name) {
29	ret icCache.containsKey(name.toLowerCase());
30	}
31
32	static synchronized S getTheoryOpt(S name) {
33	ret icCache.get(name.toLowerCase());
34	}
35
36	static synchronized S getTheory(S name) {
37	S text = getTheoryOpt(name);
38	if (text == null) fail("Theory * not found", name);
39	ret text;
40	}
41
42	static synchronized L<S> getTheoriesSignedByAs(S user, S as) {
43	new L<S> l;
44	for (Sign s : signList)
45	if (eq(s.user, user) && eq(s.as, as))
46	l.add(s.theory);
47	ret l;
48	}
49
50	static synchronized Sign findSigning(S user, S as, S theory) {
51	for (Sign s : signList)
52	if (eq(s.user, user) && eq(s.as, as) && eq(s.theory, theory))
53	ret s;
54	ret null;
55	}
56
57	static synchronized void theoriesPut(S name, S text) {
58	theories.put(name, text);
59	icCache.put(name.toLowerCase(), text);
60	}
61
62	static synchronized void theoriesRemove(S name) {
63	theories.remove(name);
64	icCache.remove(name.toLowerCase());
65	}
66
67	static S signTheory(S user, S theory, S as) {
68	if (empty(user)) ret "go to slack please";
69	if (!hasTheory(theory)) ret "Theory not found";
70	if (getTheoriesSignedByAs(user, as).contains(theory))
71	ret "You have already signed this theory as " + as + "!";
72	new Sign sign;
73	sign.user = user;
74	sign.theory = theory;
75	sign.as = as;
76	sign.since = now();
77	signList.add(sign);
78	save("signList");
79	ret format("OK, signed * as *!", theory, as);
80	}
81
82	static S unsignTheory(S user, S theory, S as) {
83	if (empty(user)) ret "go to slack please";
84	if (!hasTheory(theory)) ret "Theory not found";
85	Sign sign = findSigning(user, as, theory);
86	if (sign == null)
87	ret "You have not signed this theory as " + as + ".";
88	signList.remove(sign);
89	save("signList");
90	ret format("OK, unsigned * as *.", theory, as);
91	}
92
93	synchronized answer {
94	//if (!attn()) ret null;
95
96	if "count theories"
97	ret lstr(theories);
98
99	if "list theories"
100	ret structure(keys(theories));
101
102	if "show theory *" exceptionToUser {
103	ret showTheories(litlist(m.unq(0)));
104	}
105
106	if (matchStart("show theories", s, m)) exceptionToUser {
107	ret showTheories(codeTokensOnly(javaTok(m.rest())));
108	}
109
110	if "modify theory * *" exceptionToUser {
111	S name = m.unq(0), text = m.unq(1);
112	ret saveTheory(name, text, true);
113	}
114
115	if "add theory * *" exceptionToUser {
116	S name = m.unq(0), text = m.unq(1);
117	ret saveTheory(name, text, false);
118	}
119
120	S line = firstLine(s).trim();
121	if (startsWithIgnoreCase(line, "theory ") && l(toLines(s)) > 1) exceptionToUser {
122	line = dropPrefixIgnoreCase("theory ", line);
123	line = dropSuffix(":", line).trim();
124	S name = unquote(line), text = dropFirstLine(s);
125	ret saveTheory(name, text, false);
126	}
127
128	if (match("inc theory * ", s, m) \|\| match("increment theory *", s, m)) exceptionToUser {
129	S name = m.unq(0), text = m.unq(1);
130	ret incrementTheory(name, text);
131	}
132
133	if "sign theory *" exceptionToUser {
134	S user = getUserName();
135	ret signTheory(user, m.unq(0), "default");
136	}
137
138	if "unsign theory *" exceptionToUser {
139	S user = getUserName();
140	ret unsignTheory(user, m.unq(0), "default");
141	}
142
143	if "sign theory * as *" exceptionToUser {
144	S user = getUserName();
145	ret signTheory(user, m.unq(0), m.unq(1));
146	}
147
148	if "unsign theory * as *" exceptionToUser {
149	S user = getUserName();
150	ret unsignTheory(user, m.unq(0), m.unq(1));
151	}
152
153	if "my signed theories" exceptionToUser {
154	S user = getUserName();
155	if (empty(user)) ret "go to slack please";
156	ret structure(getTheoriesSignedByAs(user, "default"));
157	}
158
159	if "my theories signed as *" exceptionToUser {
160	S user = getUserName();
161	if (empty(user)) ret "go to slack please";
162	ret structure(getTheoriesSignedByAs(user, m.unq(0)));
163	}
164
165	if "theories signed by *" exceptionToUser {
166	S user = m.unq(0);
167	ret structure(getTheoriesSignedByAs(user, "default"));
168	}
169
170	if (match("theories page", s) \|\| match("theories url", s))
171	ret getBotURL();
172
173	if (!master()) ret null;
174
175	if "delete theory *" exceptionToUser {
176	S name = m.unq(0);
177	if (hasTheory(name)) {
178	S text = getTheoryOpt(name);
179	logMap("deleted", "name", name, "text", text, "time", now(), "signers", signMap.get(name));
180	logMap("deleted", "name", name, "signers", signMap.get(name));
181	theoriesRemove(name);
182
183	signMap.remove(name);
184	save("signMap");
185
186	ret format("Theory * backed up & deleted", name);
187	} else
188	ret format("Theory * not found", name);
189	}
190
191	if "rename theory * to *" exceptionToUser {
192	S name = m.unq(0), newName = m.unq(1);
193	if (hasTheory(newName))
194	ret format("A theory named * already exists", newName);
195	if (hasTheory(name)) {
196	S text = getTheoryOpt(name);
197	theoriesPut(newName, text);
198	theoriesRemove(name);
199
200	// update signMap
201	L<S> signers = signMap.get(name);
202	signMap.addAll(newName, signers);
203	signMap.remove(name);
204	save("signMap");
205
206	ret format("Theory * renamed to *", name, newName);
207	} else
208	ret format("Theory * not found", name);
209	}
210	}
211
212	static S showTheories(L<S> theoryNames) {
213	new StringBuilder buf;
214	for (S name: theoryNames) {
215	if (!hasTheory(name))
216	buf.append(format("Theory * not found\n", name));
217	else {
218	buf.append(quote(name) + "\n" + slackSnippet(getTheoryOpt(name)) + "\n\n");
219	}
220	}
221	ret str(buf).trim();
222	}
223
224	static S html(S uri, Map<S, S> params) {
225	if (eq(uri, "/signList"))
226	ret htmlencode(structure(signList));
227
228	if (eq(uri, "/theories"))
229	ret htmlencode(structure(theories));
230
231	if (eq(uri, "/theoriesInc")) {
232	int n = parseInt(or(params.get("n"), "0"));
233	S id = params.get("id");
234
235	if (nempty(id) && neq(id, theories.id()))
236	n = 0;
237
238	int m = (int) theories.file.length();
239	S text = unnull(loadTextFileStartingFrom(theories.file, n));
240	//text = substr(text, n);
241	ret theories.id() + "\n" + m + "\n" + htmlencode(text);
242	}
243
244	boolean showMulti = false;
245	new L data;
246	MultiMap<S, Sign> signs = getSigningsByTheory();
247	for (S name : getTheoryNames()) {
248	S text = unnull(getTheoryOpt(name));
249	boolean multi = false;
250	Exception error = null;
251	L<Sign> signings = signs.get(name);
252	new L<S> bla;
253	for (Sign sign : signings)
254	bla.add(sign.user + " as " + sign.as);
255	Map map = litmap(
256	"Name", htmlencode(name),
257	"Theory", pre(htmlencode(minitrim(rtrim(text)))),
258	"Signed by", htmlencode(join(", ", bla)));
259	if (showMulti) {
260	map.put("Multiple rules?", multi);
261	try {
262	multi = nlIsMultipleStatements(text);
263	} catch (Exception e) {
264	error = e;
265	}
266	}
267	if (error != null)
268	map.put("Parse Error", str(error));
269	data.add(map);
270	}
271	ret h3("Theories!") + htmlTable(data, false);
272	}
273
274	// preserves formatting of first line
275	static S minitrim(S s) {
276	L<S> l = toLines(s);
277	while (!empty(l) && empty(trim(first(l))))
278	l.remove(0);
279	ret autoUnindent(fromLines(l));
280	}
281
282	static S saveTheory(S name, S text, boolean autoModify) {
283	boolean has = hasTheory(name);
284	S oldText = getTheoryOpt(name);
285	S origName = name;
286	int counter = 0;
287	while (has && !autoModify) {
288	name = origName + "." + (char) (((int) 'a') + (++counter));
289	has = hasTheory(name);
290	}
291	logMap(has ? "modified" : "added", "name", name, "text", text, "time", now(), "oldText", oldText);
292	theoriesPut(name, text);
293	ret format((has ? "OK, modified theory " : "OK, added theory "), name);
294	}
295
296	static synchronized long getTheoryCounter(S name) {
297	S text = getTheoryOpt(name + ".count");
298	ret isEmpty(text) ? 0 : parseLong(text);
299	}
300
301	// returns inc'ed value
302	static synchronized long incTheoryCounter(S name) {
303	long c = getTheoryCounter(name);
304	++c;
305	theoriesPut(name + ".count", str(c));
306	ret c;
307	}
308
309	// returned list might include null elements
310	static L<S> getIncrements(S name) {
311	new L<S> l;
312	long n = getTheoryCounter(name);
313	for (long i = 1; i <= n; i++)
314	l.add(getTheoryOpt(name + "." + i));
315	ret l;
316	}
317
318	static synchronized S incrementTheory(S name, S newText) {
319	long n = incTheoryCounter(name);
320	ret saveTheory(name + "." + n, newText, false);
321	}
322
323	static synchronized MultiMap<S, Sign> getSigningsByTheory() {
324	new MultiMap<S, Sign> map;
325	for (Sign s : signList)
326	map.put(s.theory, s);
327	ret map;
328	}