Komodo / komodo-center-smstools

1

const childProcess = require('child_process');

1

const childProcess = require('child_process');

2

const express = require('express');

2

const express = require('express');

3

const escapeQuotes = require('escape-quotes');

3

const escapeQuotes = require('escape-quotes');

4

5

const config = require('komodo-sdk/config');

5

const config = require('komodo-sdk/config');

6

const logger = require('komodo-sdk/logger');

6

const logger = require('komodo-sdk/logger');

7

8

const smstoolsUtil = require('../../smstools-util');

8

const smstoolsUtil = require('../../smstools-util');

9

const smstoolsStatus = require('../../smstools-status');

9

const smstoolsStatus = require('../../smstools-status');

10

const smstoolsStatusParsed = require('../../smstools-status-parsed');

10

const smstoolsStatusParsed = require('../../smstools-status-parsed');

11

12

const router = express.Router();

12

const router = express.Router();

13

module.exports = router;

13

module.exports = router;

14

15

async function pageStatus(req, res) {

15

async function pageStatus(req, res) {

16

const filename = config.smstools_status_file || '//var/log/smsd/smsd_stats/status';

16

const filename = config.smstools_status_file || '//var/log/smsd/smsd_stats/status';

17

const status = await smstoolsStatusParsed(filename);

17

const status = await smstoolsStatusParsed(filename);

18

res.json(status);

18

res.json(status);

19

}

19

}

20

21

async function pageStatusRaw(req, res) {

21

async function pageStatusRaw(req, res) {

22

const filename = config.smstools_status_file || '//var/log/smsd/smsd_stats/status';

22

const filename = config.smstools_status_file || '//var/log/smsd/smsd_stats/status';

23

const statusContent = await smstoolsStatus(filename);

23

const statusContent = await smstoolsStatus(filename);

24

res.end(statusContent);

24

res.end(statusContent);

25

}

25

}

26

27

async function pageRestart(req, res) {

27

async function pageRestart(req, res) {

28

res.json(await smstoolsUtil.restart());

28

res.json(await smstoolsUtil.restart());

29

}

29

}

30

31

function pageLog(req, res) {

31

function pageLog(req, res) {

32

const maxLines = (Number(req.query.max) || 200);

32

const maxLines = (Number(req.query.max) || 200);

33

const keyword = req.query.keyword && escapeQuotes(req.query.keyword, '\'\n"&|*<>[];$ ');

33

const keyword = req.query.keyword && escapeQuotes(req.query.keyword, '\'\n"&|*<>[];$ ');

34

const cmd = req.query.keyword ? `tail -n ${maxLines * 50} /var/log/smsd/smsd.log | grep --ignore-case ${keyword} | tail -n ${maxLines} | tac`

34

const cmd = req.query.keyword ? `tail -n ${maxLines * 50} /var/log/smsd/smsd.log | grep --ignore-case ${keyword} | tail -n ${maxLines} | tac`

35

: `tail -n ${maxLines} /var/log/smsd/smsd.log | tac`;

35

: `tail -n ${maxLines} /var/log/smsd/smsd.log | tac`;

36

37

logger.verbose('ROUTER-SMSTOOLS: Getting log', { keyword, maxLines, cmd });

37

logger.verbose('ROUTER-SMSTOOLS: Getting log', { keyword, maxLines, cmd });

38

childProcess.exec(cmd, (err, stdout, stderr) => {

38

childProcess.exec(cmd, (err, stdout, stderr) => {

39

res.json({

39

res.json({

40

err,

40

err,

41

stdout,

41

stdout,

42

stderr,

42

stderr,

43

});

43

});

44

});

44

});

45

}

45

}

46

47

async function pageSpoolCount(req, res) {

48

const outgoingCount = await smstoolsUtil.fileCountOnDir('/var/spool/sms/outgoing');

49

const checkedCount = await smstoolsUtil.fileCountOnDir('/var/spool/sms/checked');

50

51

res.json({

52

outgoingCount,

53

checkedCount,

54

totalQueueCount: Number(outgoingCount) + Number(checkedCount),

55

});

56

}

57

47

router.get('/status', pageStatus);

58

router.get('/status', pageStatus);

48

router.get('/status/raw', pageStatusRaw);

59

router.get('/status/raw', pageStatusRaw);

49

router.get('/restart', pageRestart);

60

router.get('/restart', pageRestart);

50

router.get('/log', pageLog);

61

router.get('/log', pageLog);

62

router.get('/spool-count', pageSpoolCount);

51

63

GITLAB

Komodo / komodo-center-smstools

spoolCount

 const childProcess = require('child_process');
 const express = require('express');
 const escapeQuotes = require('escape-quotes');
 const config = require('komodo-sdk/config');
 const logger = require('komodo-sdk/logger');
 const smstoolsUtil = require('../../smstools-util');
 const smstoolsStatus = require('../../smstools-status');
 const smstoolsStatusParsed = require('../../smstools-status-parsed');
 const router = express.Router();
 module.exports = router;
 async function pageStatus(req, res) {
     const filename = config.smstools_status_file || '//var/log/smsd/smsd_stats/status';
     const status = await smstoolsStatusParsed(filename);
     res.json(status);
 }
 async function pageStatusRaw(req, res) {
     const filename = config.smstools_status_file || '//var/log/smsd/smsd_stats/status';
     const statusContent = await smstoolsStatus(filename);
     res.end(statusContent);
 }
 async function pageRestart(req, res) {
     res.json(await smstoolsUtil.restart());
 }
 function pageLog(req, res) {
     const maxLines = (Number(req.query.max) || 200);
     const keyword = req.query.keyword && escapeQuotes(req.query.keyword, '\'\n"&|*<>[];$ ');
     const cmd = req.query.keyword ? `tail -n ${maxLines * 50} /var/log/smsd/smsd.log | grep --ignore-case ${keyword} | tail -n ${maxLines} | tac`
         : `tail -n ${maxLines} /var/log/smsd/smsd.log | tac`;
     logger.verbose('ROUTER-SMSTOOLS: Getting log', { keyword, maxLines, cmd });
     childProcess.exec(cmd, (err, stdout, stderr) => {
         res.json({
             err,
             stdout,
             stderr,
         });
     });
 }
+async function pageSpoolCount(req, res) {
+    const outgoingCount = await smstoolsUtil.fileCountOnDir('/var/spool/sms/outgoing');
+    const checkedCount = await smstoolsUtil.fileCountOnDir('/var/spool/sms/checked');
+    res.json({
+        outgoingCount,
+        checkedCount,
+        totalQueueCount: Number(outgoingCount) + Number(checkedCount),
+    });
+}
 router.get('/status', pageStatus);
 router.get('/status/raw', pageStatusRaw);
 router.get('/restart', pageRestart);
 router.get('/log', pageLog);
+router.get('/spool-count', pageSpoolCount);

+const fs = require('fs');
 const childProcess = require('child_process');
 const config = require('komodo-sdk/config');
 exports.restart = () => new Promise((resolve) => {
     const fileToExec = config.restart_smstools_wrapper || '/var/lib/smstools/centers/smstools/bin/restart-smstools';
     childProcess.execFile(fileToExec, (err, stdout, stderr) => {
         resolve({
             err,
             stdout,
             stderr,
         });
     });
 });
+exports.fileCountOnDir = async (dirname) => {
+    try {
+        const files = fs.promises.readdir(dirname);
+        return files.filter((item) => item.search(/LOCK$/) >= 0).length;
+    } catch (e) {
+        return null;
+    }
+};