aboutsummaryrefslogtreecommitdiff
path: root/src/server/ApiManagers/UtilManager.ts
blob: ad8119bf40796eba1a097b72b5e7b2e14510cb8c (plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
import ApiManager, { Registration } from "./ApiManager";
import { Method } from "../RouteManager";
import { exec } from 'child_process';
import RouteSubscriber from "../RouteSubscriber";
import { red } from "colors";
// import { IBM_Recommender } from "../../client/apis/IBM_Recommender";
// import { Recommender } from "../Recommender";

// const recommender = new Recommender();
// recommender.testModel();
import executeImport from "../../scraping/buxton/final/BuxtonImporter";

export default class UtilManager extends ApiManager {

    protected initialize(register: Registration): void {

        register({
            method: Method.GET,
            subscription: new RouteSubscriber("environment").add("key"),
            secureHandler: ({ req, res }) => {
                const { key } = req.params;
                const value = process.env[key];
                if (!value) {
                    console.log(red(`process.env.${key} is not defined.`));
                }
                return res.send(value);
            }
        });

        // register({
        //     method: Method.POST,
        //     subscription: "/IBMAnalysis",
        //     secureHandler: async ({ req, res }) => res.send(await IBM_Recommender.analyze(req.body))
        // });

        // register({
        //     method: Method.POST,
        //     subscription: "/recommender",
        //     secureHandler: async ({ req, res }) => {
        //         const keyphrases = req.body.keyphrases;
        //         const wordvecs = await recommender.vectorize(keyphrases);
        //         let embedding: Float32Array = new Float32Array();
        //         if (wordvecs && wordvecs.dataSync()) {
        //             embedding = wordvecs.dataSync() as Float32Array;
        //         }
        //         res.send(embedding);
        //     }
        // });


        register({
            method: Method.GET,
            subscription: "/pull",
            secureHandler: async ({ res }) => {
                return new Promise<void>(resolve => {
                    exec('"C:\\Program Files\\Git\\git-bash.exe" -c "git pull"', err => {
                        if (err) {
                            res.send(err.message);
                            return;
                        }
                        res.redirect("/");
                        resolve();
                    });
                });
            }
        });

        register({
            method: Method.GET,
            subscription: "/version",
            secureHandler: ({ res }) => {
                return new Promise<void>(resolve => {
                    exec('"C:\\Program Files\\Git\\bin\\git.exe" rev-parse HEAD', (err, stdout) => {
                        if (err) {
                            res.send(err.message);
                            return;
                        }
                        res.send(stdout);
                    });
                    resolve();
                });
            }
        });

    }

}