team2_server/webtool/main.js

//##############################################################################
//                             config panel
//##############################################################################
require("./createAPPJson");

const os = require('os');
const PORT = 3001;
const USER = 'admin';
const PASS = 'admin';
const SESSTION_AGE = 10 * 60000; // 10 minutes

//##############################################################################
//                             inital packages
//##############################################################################

const path = require('path');
const express = require('express');
const app = express();
const exec = require("child_process").exec;
const fs = require('fs');

var session = require('express-session');

// Use the session middleware
app.use(session({ secret: 'keyboard cat', cookie: { maxAge: SESSTION_AGE } }));

// add assets path
app.use('/assets', express.static(path.join(__dirname, 'assets')));

// for parse post
app.use(express.json());       // to support JSON-encoded bodies
app.use(express.urlencoded()); // to support URL-encoded bodies
//
//##############################################################################
//                             rounting urls
//##############################################################################

app.get('/', function (req, res) {
    // check is login
    if (req.session.islogin) {
        // show index page
        res.sendFile(path.join(__dirname, 'www/index.html'));
    } else {
        // redirect to login page
        res.writeHead(302, {
            'Location': '/login'
        });
        res.end();
    }

});

app.get('/login', function (req, res) {

    // render login page
    res.sendFile(path.join(__dirname, 'www/login.html'));
});

app.post('/loginCheck', function (req, res) {
    // check username and password 
    if (req.body.username === USER && req.body.passwd == PASS) {
        // login process
        req.session.islogin = true;
        // redirect to panel
        res.writeHead(302, {
            'Location': '/'
        });
    } else {
        // user or password incrrect go back to login
        res.writeHead(302, {
            'Location': '/login'

        });
    }
    res.end();
});



app.get('/getProccess', function (req, res) {
    // check is user logined
    if (!req.session.islogin) {
        res.writeHead(302, {
            'Location': '/login'
        });
        res.end();

    } else {
        // send json header
        res.writeHead(200, {
            'Content-Type': 'application/json'
        });
        // get json list from the json
        exec("pm2 jlist", (error, stdout, stderr) => {
            //do whatever here
            res.write(stdout);
            res.end();
        });
    }
});
app.post('/addProccess', function (req, res) {
    // check is user logined
    if (!req.session.islogin) {
        res.writeHead(302, {
            'Location': '/login'
        });
        res.end();

    } else {

        // get json list from the json
        if (req.body.path === undefined) {
            res.writeHead(302, {
                'Location': '/'
            });
            res.end();
            return false;
        }

        // check is file exists
        if (fs.existsSync(req.body.path)) {
            // add process
            exec('pm2 start "' + req.body.path + '" ' + req.body.args + '', (error, stdout, stderr) => {
                // save notificarion
                // req.session.notication = error + '\n--------\n' + stdout + '\n--------\n' + stderr;
                if (error != null) {
                    req.session.notication = error + stderr;
                } else {
                    req.session.notication = '进程：' + req.body.path + '启动成功';
                }
                res.writeHead(302, {
                    'Location': '/'
                });
                res.end();
                return true;
            });
        } else {

            // go back
            res.writeHead(302, {
                'Location': '/'
            });
            res.end();
            return false;
        }

    }
});

app.get('/restart', function (req, res) {
    // send json header
    if (!req.session.islogin) {
        res.writeHead(302, {
            'Location': '/login'
        });
        res.end();

    } else {
        // check id exits 
        if (req.query.id) {
            // restart the process
            exec("pm2 restart " + req.query.id, (error, stdout, stderr) => {
                res.writeHead(302, {
                    'Location': '/'
                });
                // req.session.notication = error + '\n--------\n' + stdout + '\n--------\n' + stderr;
                if (error != null) {
                    req.session.notication = error + stderr;
                } else {
                    req.session.notication = '进程：' + req.query.id + '重启成功';
                }
                res.end();
            });

        }

    }
});

app.get('/start', function (req, res) {
    // send json header
    if (!req.session.islogin) {
        res.writeHead(302, {
            'Location': '/login'
        });
        res.end();

    } else {
        // check id exits 
        if (req.query.id) {
            // start the process
            exec("pm2 start " + req.query.id, (error, stdout, stderr) => {
                res.writeHead(302, {
                    'Location': '/'
                });
                // req.session.notication = error + '\n--------\n' + stdout + '\n--------\n' + stderr;
                if (error != null) {
                    req.session.notication = error + stderr;
                } else {
                    req.session.notication = '进程：' + req.query.id + '启动成功';
                }
                res.end();
            });

        }

    }
});

app.get('/stop', function (req, res) {
    // send json header
    if (!req.session.islogin) {
        res.writeHead(302, {
            'Location': '/login'
        });
        res.end();

    } else {
        // check id exits 
        if (req.query.id) {
            // stop the process
            exec("pm2 stop " + req.query.id, (error, stdout, stderr) => {
                res.writeHead(302, {
                    'Location': '/'
                });
                // req.session.notication = error + '\n--------\n' + stdout + '\n--------\n' + stderr;
                if (error != null) {
                    req.session.notication = error + stderr;
                } else {
                    req.session.notication = '进程：' + req.query.id + '停止成功';
                }
                res.end();
            });

        }

    }
});

app.get('/delete', function (req, res) {
    // send json header
    if (!req.session.islogin) {
        res.writeHead(302, {
            'Location': '/login'
        });
        res.end();

    } else {
        // check id exits 
        if (req.query.id) {
            // delete the process
            exec("pm2 delete " + req.query.id, (error, stdout, stderr) => {
                res.writeHead(302, {
                    'Location': '/'
                });
                // req.session.notication = error + '\n--------\n' + stdout + '\n--------\n' + stderr;
                if (error != null) {
                    req.session.notication = error + stderr;
                } else {
                    req.session.notication = '进程：' + req.query.id + '关闭成功';
                }
                res.end();
            });

        }

    }
});

app.get('/dump', function (req, res) {
    // send json header
    if (!req.session.islogin) {
        res.writeHead(302, {
            'Location': '/login'
        });
        res.end();

    } else {
        // save process
        exec("pm2 save", (error, stdout, stderr) => {
            res.writeHead(302, {
                'Location': '/'
            });
            //req.session.notication = error + '\n--------\n' + stdout + '\n--------\n' + stderr;
            if (error != null) {
                req.session.notication = error + stderr;
            } else {
                req.session.notication = '当前进程保存成功';
            }
            res.end();
        });


    }
});

app.get('/deleteall', function (req, res) {
    // send json header
    if (!req.session.islogin) {
        res.writeHead(302, {
            'Location': '/login'
        });
        res.end();

    } else {
        // save process
        exec("pm2 delete all", (error, stdout, stderr) => {
            res.writeHead(302, {
                'Location': '/'
            });
            //req.session.notication = error + '\n--------\n' + stdout + '\n--------\n' + stderr;
            if (error != null) {
                req.session.notication = error + stderr;
            } else {
                req.session.notication = '所有进程已经关闭';
            }
            res.end();
        });
    }
});

app.get('/flush', function (req, res) {
    // send json header
    if (!req.session.islogin) {
        res.writeHead(302, {
            'Location': '/login'
        });
        res.end();

    } else {
        // save process
        exec("pm2 flush", (error, stdout, stderr) => {
            res.writeHead(302, {
                'Location': '/'
            });
            //req.session.notication = error + '\n--------\n' + stdout + '\n--------\n' + stderr;
            if (error != null) {
                req.session.notication = error + stderr;
            } else {
                req.session.notication = '清空日志成功';
            }
            res.end();
        });
    }
});

app.get('/notification', function (req, res) {
    // send json header
    if (!req.session.islogin) {
        res.writeHead(302, {
            'Location': '/login'
        });
        res.end();
        return false;
    } else {
        if (!req.session.notication) {
            res.write('-');
        } else {
            var message = req.session.notication;
            delete req.session.notication;
            res.write(message);
        }
        res.end();
    }
});

app.get('/sysInfo', function (req, res) {
    // send json header
    if (!req.session.islogin) {
        res.writeHead(302, {
            'Location': '/login'
        });
        res.end();
        return false;
    } else {
        var message = "";
        message += `主机 - ${os.hostname()}\n`;
        message += `操作系统 - ${os.platform()}\n`;
        message += `系统版本 - ${os.release()}\n`;
        message += `CPU架构 - ${os.arch()}\n`;
        message += `总内存 - ${(os.totalmem() / 1024 / 1024).toFixed(2)}MB\n`;
        message += `空闲内存 - ${(os.freemem() / 1024 / 1024).toFixed(2)}MB\n`;
        message += `内存占比 - ${(os.freemem() / os.totalmem() * 100).toFixed(2)}%`;
        res.write(message);
        res.end();
    }
});



/// get folder list
app.get('/folder', function (req, res) {

    // check is login ?
    if (!req.session.islogin) {
        res.writeHead(302, {
            'Location': '/login'
        });
        res.end();

    } else {
        // check path and set default tab
        if (req.query.path === undefined) {
            var chossedPath = '/';
        } else {
            var chossedPath = req.query.path;
        }
        // send json header
        res.writeHead(200, {
            'Content-Type': 'application/json'
        });

        // check choosed is exists
        if (fs.existsSync(chossedPath)) {
            // read folder
            fs.readdir(chossedPath, (err, files) => {

                // creat list
                var lst = [];
                chossedPath = chossedPath + '/';
                chossedPath = chossedPath.replace('//', '/');
                // set back folder in list
                var e = path.join(chossedPath, '..');
                lst.push({ 'name': '..', 'path': e });
                files.forEach(file => {
                    var tmp = { 'name': file, 'path': chossedPath + file };
                    lst.push(tmp);
                });
                // send buffer
                res.write(JSON.stringify(lst));
                res.end();
            });

        } else {

            res.write('[]');
            res.end();

        }
    }

});



app.get('/logout', function (req, res) {

    // remover session
    delete req.session.islogin;
    // redirect to login page
    res.writeHead(302, {
        'Location': '/login'
    });
    res.end();
});

app.get('/log', function (req, res) {
    // send json header
    if (!req.session.islogin) {
        res.writeHead(302, {
            'Location': '/login'
        });
        res.end();

    } else {
        // check id exits 
        if (req.query.id) {
            // log of the process
            var proc = require('child_process').spawn("pm2", ['log', req.query.id], {
                shell: process.platform === 'win32'
            });

            req.session.notication = '';
            proc.stdout.on('data', (data) => {
                req.session.notication = req.session.notication + data;
            });

            setTimeout(function () {
                proc.stdin.end();
                res.writeHead(302, {
                    'Location': '/'
                });
                res.end();
            }, 2000);

        }

    }
});

app.get('/pinfo', function (req, res) {
    // send json header
    if (!req.session.islogin) {
        res.writeHead(302, {
            'Location': '/login'
        });
        res.end();

    } else {
        // check id exits 
        if (req.query.id) {
            // log of the process
            var proc = require('child_process').spawn("pm2", ['info', req.query.id], {
                shell: process.platform === 'win32'
            });

            req.session.notication = '';
            proc.stdout.on('data', (data) => {
                req.session.notication = req.session.notication + data;
            });

            setTimeout(function () {
                proc.stdin.end();
                res.writeHead(302, {
                    'Location': '/'
                });
                res.end();
            }, 2000);

        }

    }
});


//##############################################################################
//                              finazle
//##############################################################################

app.listen(PORT, function () {
    console.log('游戏服务管理面板开始监听：' + PORT + ' \n 首页: http://localhost:' + PORT);
});