aboutsummaryrefslogtreecommitdiff
path: root/src/server/ApiManagers
diff options
context:
space:
mode:
Diffstat (limited to 'src/server/ApiManagers')
-rw-r--r--src/server/ApiManagers/ApiManager.ts7
-rw-r--r--src/server/ApiManagers/SearchManager.ts49
-rw-r--r--src/server/ApiManagers/UserManager.ts40
-rw-r--r--src/server/ApiManagers/UtilManager.ts54
4 files changed, 150 insertions, 0 deletions
diff --git a/src/server/ApiManagers/ApiManager.ts b/src/server/ApiManagers/ApiManager.ts
new file mode 100644
index 000000000..264c78a17
--- /dev/null
+++ b/src/server/ApiManagers/ApiManager.ts
@@ -0,0 +1,7 @@
+import RouteManager from "../RouteManager";
+
+export default abstract class ApiManager {
+
+ public abstract register(router: RouteManager): void;
+
+} \ No newline at end of file
diff --git a/src/server/ApiManagers/SearchManager.ts b/src/server/ApiManagers/SearchManager.ts
new file mode 100644
index 000000000..15b87204c
--- /dev/null
+++ b/src/server/ApiManagers/SearchManager.ts
@@ -0,0 +1,49 @@
+import ApiManager from "./ApiManager";
+import RouteManager, { Method } from "../RouteManager";
+import { Search } from "../Search";
+var findInFiles = require('find-in-files');
+import * as path from 'path';
+import { uploadDirectory } from "..";
+
+export default class SearchManager extends ApiManager {
+
+ public register(router: RouteManager): void {
+
+ router.addSupervisedRoute({
+ method: Method.GET,
+ subscription: "/textsearch",
+ onValidation: async ({ req, res }) => {
+ let q = req.query.q;
+ if (q === undefined) {
+ res.send([]);
+ return;
+ }
+ let results = await findInFiles.find({ 'term': q, 'flags': 'ig' }, uploadDirectory + "text", ".txt$");
+ let resObj: { ids: string[], numFound: number, lines: string[] } = { ids: [], numFound: 0, lines: [] };
+ for (var result in results) {
+ resObj.ids.push(path.basename(result, ".txt").replace(/upload_/, ""));
+ resObj.lines.push(results[result].line);
+ resObj.numFound++;
+ }
+ res.send(resObj);
+ }
+ });
+
+ router.addSupervisedRoute({
+ method: Method.GET,
+ subscription: "/search",
+ onValidation: async ({ req, res }) => {
+ const solrQuery: any = {};
+ ["q", "fq", "start", "rows", "hl", "hl.fl"].forEach(key => solrQuery[key] = req.query[key]);
+ if (solrQuery.q === undefined) {
+ res.send([]);
+ return;
+ }
+ let results = await Search.Instance.search(solrQuery);
+ res.send(results);
+ }
+ });
+
+ }
+
+} \ No newline at end of file
diff --git a/src/server/ApiManagers/UserManager.ts b/src/server/ApiManagers/UserManager.ts
new file mode 100644
index 000000000..bb8837dc6
--- /dev/null
+++ b/src/server/ApiManagers/UserManager.ts
@@ -0,0 +1,40 @@
+import ApiManager from "./ApiManager";
+import RouteManager, { Method } from "../RouteManager";
+import { WebSocket } from "../Websocket/Websocket";
+
+export default class UserManager extends ApiManager {
+
+ public register(router: RouteManager): void {
+ router.addSupervisedRoute({
+ method: Method.GET,
+ subscription: "/whosOnline",
+ onValidation: ({ res }) => {
+ let users: any = { active: {}, inactive: {} };
+ const now = Date.now();
+
+ const { timeMap } = WebSocket;
+ for (const user in timeMap) {
+ const time = timeMap[user];
+ const key = ((now - time) / 1000) < (60 * 5) ? "active" : "inactive";
+ users[key][user] = `Last active ${this.msToTime(now - time)} ago`;
+ }
+
+ res.send(users);
+ }
+ });
+ }
+
+ private msToTime(duration: number) {
+ let milliseconds = Math.floor((duration % 1000) / 100),
+ seconds = Math.floor((duration / 1000) % 60),
+ minutes = Math.floor((duration / (1000 * 60)) % 60),
+ hours = Math.floor((duration / (1000 * 60 * 60)) % 24);
+
+ let hoursS = (hours < 10) ? "0" + hours : hours;
+ let minutesS = (minutes < 10) ? "0" + minutes : minutes;
+ let secondsS = (seconds < 10) ? "0" + seconds : seconds;
+
+ return hoursS + ":" + minutesS + ":" + secondsS + "." + milliseconds;
+ }
+
+} \ No newline at end of file
diff --git a/src/server/ApiManagers/UtilManager.ts b/src/server/ApiManagers/UtilManager.ts
new file mode 100644
index 000000000..79b904e8a
--- /dev/null
+++ b/src/server/ApiManagers/UtilManager.ts
@@ -0,0 +1,54 @@
+import ApiManager from "./ApiManager";
+import RouteManager, { Method } from "../RouteManager";
+import { exec } from 'child_process';
+import { command_line } from "../ActionUtilities";
+
+export default class UtilManager extends ApiManager {
+
+ public register(router: RouteManager): void {
+
+ router.addSupervisedRoute({
+ method: Method.GET,
+ subscription: "/pull",
+ onValidation: ({ res }) => {
+ exec('"C:\\Program Files\\Git\\git-bash.exe" -c "git pull"', err => {
+ if (err) {
+ res.send(err.message);
+ return;
+ }
+ res.redirect("/");
+ });
+ }
+ });
+
+ router.addSupervisedRoute({
+ method: Method.GET,
+ subscription: "/buxton",
+ onValidation: ({ res }) => {
+ let cwd = '../scraping/buxton';
+
+ let onResolved = (stdout: string) => { console.log(stdout); res.redirect("/"); };
+ let onRejected = (err: any) => { console.error(err.message); res.send(err); };
+ let tryPython3 = () => command_line('python3 scraper.py', cwd).then(onResolved, onRejected);
+
+ command_line('python scraper.py', cwd).then(onResolved, tryPython3);
+ },
+ });
+
+ router.addSupervisedRoute({
+ method: Method.GET,
+ subscription: "/version",
+ onValidation: ({ res }) => {
+ exec('"C:\\Program Files\\Git\\bin\\git.exe" rev-parse HEAD', (err, stdout) => {
+ if (err) {
+ res.send(err.message);
+ return;
+ }
+ res.send(stdout);
+ });
+ }
+ });
+
+ }
+
+} \ No newline at end of file