openflow/OpenFlowNodeRED/src/nodeclient/cliutil.ts at 021dcd89413d90fc2ddddd6c72011554350a50f4 · ITCSsDeveloper/openflow · GitHub

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
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
import { Logger } from "../Logger";
import { Config } from "../Config";
import * as fs from "fs";
export const logger = Logger.configure();
const cp = require('child_process');
const spawn = cp.spawn;
const path = require('path');
const envfile = require('envfile')
export const envfilename = ".env";
export const envfilepathname = "";
export var servicename = "service-name-not-set";
const service = require("os-service");

export function isWin() {
    return process.platform === "win32";
}
export function isMac() {
    return process.platform === "darwin";
}
export function isOpenFlow() {
    const check1 = path.join(__dirname, "..", "DatabaseConnection.ts");
    const check2 = path.join(__dirname, "..", "DatabaseConnection.js");
    if (fs.existsSync(check1) || fs.existsSync(check2)) return true;
    return false;
}
export function StartService(servicename: string) {
    try {
        if (isWin()) {
            cp.execSync(`net start ${servicename}`);
        } else if (isMac()) {
            // https://medium.com/craftsmenltd/building-a-cross-platform-background-service-in-node-js-791cfcd3be60
            // cp.execSync(`sudo launchctl load ${LAUNCHD_PLIST_PATH}`);
        } else {
            cp.execSync(`service ${servicename} start`);
        }
    } catch (error) {
        logger.info(error.message ? error.message : error);
    }
}
export function StopService(servicename: string) {
    try {
        if (isWin()) {
            cp.execSync(`net stop ${servicename}`);
        } else if (isMac()) {
            // https://medium.com/craftsmenltd/building-a-cross-platform-background-service-in-node-js-791cfcd3be60
            // cp.execSync(`sudo launchctl unload ${LAUNCHD_PLIST_PATH}`);
        } else {
            cp.execSync(`service ${servicename} stop`);
        }
    } catch (error) {
        logger.info(error.message ? error.message : error);
    }
}
export function RestartService(servicename: string) {
    try {
        if (isWin()) {
            // cp.execSync(`start "restart" "cmd.exe" "/c net stop ${servicename} & net start ${servicename}"`);
            // cp.exec(`start "restart" "cmd.exe" "/c net stop ${servicename} & net start ${servicename}"`);
            // var child = spawn("powershell.exe", ["-Command", `Restart-Service ${servicename}`, "-NoExit"], {
            var child = spawn("cmd", [`start "restart" "cmd.exe" "/c net stop ${servicename} & net start ${servicename}"`], {
                shell: true, detached: true,
                stdio: ['ignore', 'ignore', 'ignore']
            });
            child.unref();
        } else if (isMac()) {
            // https://medium.com/craftsmenltd/building-a-cross-platform-background-service-in-node-js-791cfcd3be60
            // cp.execSync(`sudo launchctl unload ${LAUNCHD_PLIST_PATH}`);
        } else {
            // cp.execSync(`service ${servicename} restart`);
            // var child = spawn(`service ${servicename} restart`, [], {
            var child = spawn("service", [`${servicename} restart`], {
                shell: true, detached: true,
                stdio: ['ignore', 'ignore', 'ignore']
            });
            child.unref();

        }
    } catch (error) {
        logger.info(error.message ? error.message : error);
    }
}
export function RemoveService(servicename: string) {
    StopService(servicename);
    logger.info("Uninstalling service" + servicename);
    service.remove(servicename, function (error) {
        if (error) { logger.info(error.message ? error.message : error); return }
        logger.info("Service" + servicename + " uninstalled");
    });
}
export function InstallService(servicename: string, configfile: string) {
    logger.info("Installing service" + servicename);
    service.add(servicename, { programArgs: [servicename, "--run", "--config", configfile] }, function (error) {
        if (error) { logger.info(error.message ? error.message : error); return }
        logger.info("Service" + servicename + " installed");
        StartService(servicename);
    });
}
export function RunService(callback: any) {
    service.run(function () {
        logger.info("Service" + servicename + " stopping");
        if (callback != null) callback();
        service.stop(0);
    });
}
// use and copy current env file, unless we have a /config folder in root
export function getlocaldir(): string {
    let local = __dirname;
    if (fs.existsSync(path.join(local, "..", "config"))) {
        local = path.join(local, "..", "config");
    } else if (fs.existsSync(path.join(local, "..", "..", "config"))) {
        local = path.join(local, "..", "..", "config");
    } else if (fs.existsSync(path.join(local, "..", "..", "..", "config"))) {
        local = path.join(local, "..", "..", "..", "config");
    } else {
        local = process.cwd();
    }
    return local;
}
export function haslocalenv(): boolean {
    const localenv = path.join(getlocaldir(), envfilename);
    return fs.existsSync(localenv);
}
// set source to location of source files, unless we have a /config folder in root
export function getsourcedir(): string {
    let source = __dirname;
    if (fs.existsSync(path.join(source, "..", "config"))) {
        source = path.join(source, "..", "config");
    } else if (fs.existsSync(path.join(source, "..", "..", "config"))) {
        source = path.join(source, "..", "..", "config");
    } else if (fs.existsSync(path.join(source, "..", "..", "..", "config"))) {
        source = path.join(source, "..", "..", "..", "config");
    }
    return source;
}
export function hassourceenv(): boolean {
    const sourceenv = path.join(getsourcedir(), envfilename);
    return fs.existsSync(sourceenv);
}

// export function copyenv() {
//     const source = getsourcedir();
//     const local = getlocaldir();


//     const localenv = path.join(local, envfilename);
//     const sourceenv = path.join(source, envfilename);
//     if (localenv != sourceenv && fs.existsSync(localenv)) {
//         logger.info("localenv : " + localenv);
//         logger.info("sourceenv: " + sourceenv);
//         logger.info("copy local " + envfilename + " file to " + source);
//         fs.copyFileSync(localenv, sourceenv);
//     }
//     loadenv();
// }
export function loadenv() {
    logger.info("NodeJS version " + process.version + " Config " + envfilepathname);
    let parsedFile = envfile.parse(fs.readFileSync(envfilepathname));
    for (const k in parsedFile) {
        process.env[k] = parsedFile[k];
        // logger.verbose(k + " = " + parsedFile[k]);
    }
    Config.reload();
}