Komodo / komodo-center-smstools

Browse Code »

Commit 1d120a911060e042f9671582a46eced56b4d8446

Authored by Adhidarma Hadiwinoto 6 years ago

1 parent 788e8154b3

Exists in master

SMSTOOLS-CONFIG set single value

Showing 2 changed files with 61 additions and 0 deletions Inline Diff

lib/apiserver/routers/smstools-config.js
lib/smstools-config/setter.js

lib/apiserver/routers/smstools-config.js

Diff comments View file @ 1d120a9

 const childProcess = require('child_process');
 const express = require('express');
 const bodyParser = require('body-parser');
 const config = require('komodo-sdk/config');
 const smstoolsConfig = require('../../smstools-config');
 const smstoolsConfigCreator = require('../../smstools-config/creator');
 const smstoolsConfigSetter = require('../../smstools-config/setter');
 const smstoolsConfigData = require('../../smstools-config/config-file');
 const router = express.Router();
 module.exports = router;
 function pageIndex(req, res) {
     const configString = smstoolsConfigCreator();
     res.json({
         dirty: smstoolsConfig.config.dirty,
         config: smstoolsConfig.config,
         configStringLength: configString.length,
         configStringNrLines: (configString.match(/\n/g) || []).length,
         configString,
     });
 }
 function pageGenerate(req, res) {
     res.end(smstoolsConfigCreator());
 }
 async function pageModemList(req, res) {
     const modems = [];
     // eslint-disable-next-line no-restricted-syntax
     for (const [key, value] of Object.entries(smstoolsConfigData.modems || {})) {
         modems.push({
             label: `${key}: ${value.device}, INCOMING${value.outgoing ? ' and OUTGOING' : ''}`,
             value: key,
             data: value,
         });
     }
     res.json(modems);
 }
 async function pageSet(req, res) {
     const keyword = (req.params.keyword || req.query.keyword || '').trim();
     const value = (req.query.value || '').trim();
     if (!keyword) {
         res.end('Invalid keyword');
         return;
     }
     const result = await smstoolsConfigSetter.set(keyword, value);
     res.json({
         dirty: !!smstoolsConfigData.dirty,
         result,
     });
 }
 async function pageModemSet(req, res) {
     if (!req.body) {
         res.json({
             status: 'NOT OK',
             message: 'Empty body',
         });
         return;
     }
     const modemName = (req.params.modemName || '').trim();
     if (!modemName) {
         res.json({
             status: 'NOT OK',
             message: 'Invalid modem name',
         });
         return;
     }
     const result = await smstoolsConfigSetter.setModem(modemName, req.body);
     res.json({
         dirty: !!smstoolsConfigData.dirty,
         result,
     });
 }
+async function pageModemSetSingleValue(req, res) {
+    if (!req.body) {
+        res.json({
+            status: 'NOT OK',
+            message: 'Empty body',
+        });
+        return;
+    }
+    const modemName = (req.params.modemName || '').trim();
+    if (!modemName) {
+        res.json({
+            status: 'NOT OK',
+            message: 'Invalid modem name',
+        });
+        return;
+    }
+    const keyword = (req.body.keyword || '').trim();
+    if (!keyword) {
+        res.json({
+            status: 'NOT OK',
+            message: 'Invalid keyword',
+        });
+        return;
+    }
+    const { value } = req.body;
+    const result = await smstoolsConfigSetter.setModemSingleValue(modemName, keyword, value);
+    res.json({
+        dirty: !!smstoolsConfigData.dirty,
+        result,
+    });
+}
 async function pageModemDelete(req, res) {
     const modemName = (req.params.modemName || '').trim();
     if (!modemName) {
         res.json({
             status: 'NOT OK',
             message: 'Invalid modem name',
         });
         return;
     }
     const result = await smstoolsConfigSetter.delModem(modemName);
     res.json({
         dirty: !!smstoolsConfigData.dirty,
         result,
     });
 }
 function pageInstallConfig(req, res) {
     const fileToExec = `${process.cwd()}/bin/smstools-config-install`;
     childProcess.execFile(fileToExec, [config.smstools_config_file || '/etc/smsd.conf'], (err, stdout, stderr) => {
         res.json({
             err,
             stdout,
             stderr,
         });
     });
 }
 router.get('/', pageIndex);
 router.get('/generate', pageGenerate);
 router.get('/modems', pageModemList);
 router.get('/set/:keyword', pageSet);
 router.post('/modem/set/:modemName', bodyParser.json({ type: '*/json' }), pageModemSet);
+router.post('/modem/set-single-value/:modemName', bodyParser({ type: '*/json' }), pageModemSetSingleValue);
 router.get('/modem/delete/:modemName', pageModemDelete);
 router.get('/install-config', pageInstallConfig);

lib/smstools-config/setter.js

Diff comments View file @ 1d120a9

 const fs = require('fs');
 const logger = require('komodo-sdk/logger');
 const smstoolsConfigData = require('./config-file');
 const creator = require('./creator');
 async function writeConfig() {
     const data = smstoolsConfigData;
     data.ts = new Date();
     const configFilename = 'config.smstools.json';
     try {
         await fs.promises.writeFile(configFilename, JSON.stringify(data || {}, 0, 4));
     } catch (e) {
         logger.warn('SMSTOOLS-CONFIG/setter: Exception on writeConfig', { filename: configFilename, e });
         return e;
     }
     const newSmsdConfFilename = 'smsd.conf.tmp';
     const newSmsdConf = await creator();
     try {
         await fs.promises.writeFile(newSmsdConfFilename, newSmsdConf);
     } catch (e) {
         logger.warn('SMSTOOLS-CONFIG/setter: Exception on writeConfig', { filename: newSmsdConfFilename, e });
         return e;
     }
     return null;
 }
 exports.set = async (keyword, value) => {
     if (!keyword) return smstoolsConfigData;
     smstoolsConfigData[keyword] = value;
     smstoolsConfigData.dirty = true;
     await writeConfig();
     return smstoolsConfigData;
 };
 function getModemByDevice(device) {
     let modemName = null;
     if (!device) return modemName;
     // eslint-disable-next-line no-restricted-syntax
     for (const [key, value] of Object.entries(smstoolsConfigData.modems || {})) {
         if (value.device === device) {
             modemName = key;
         }
     }
     return modemName;
 }
 exports.setModem = async (modemName, data) => {
     if (!modemName) return smstoolsConfigData;
     if (data.device) {
         const modemWithSameDevice = getModemByDevice(data.device);
         if (modemWithSameDevice && modemWithSameDevice !== modemName) {
             return smstoolsConfigData;
         }
     }
     if (!smstoolsConfigData.modems) {
         smstoolsConfigData.modems = {};
     }
     if (!smstoolsConfigData.modems[modemName]) {
         smstoolsConfigData.modems[modemName] = {};
     }
     smstoolsConfigData.modems[modemName] = data;
     smstoolsConfigData.dirty = true;
     await writeConfig();
     return smstoolsConfigData;
 };
+exports.setModemSingleValue = async (modemName, keyword, value) => {
+    if (!modemName) return smstoolsConfigData;
+    if (keyword === 'device') {
+        const modemWithSameDevice = getModemByDevice(value);
+        if (modemWithSameDevice && modemWithSameDevice !== modemName) {
+            return smstoolsConfigData;
+        }
+    }
+    if (!smstoolsConfigData.modems) {
+        smstoolsConfigData.modems = {};
+    }
+    if (!smstoolsConfigData.modems[modemName]) {
+        smstoolsConfigData.modems[modemName] = {};
+    }
+    smstoolsConfigData.modems[modemName][keyword] = value;
+    smstoolsConfigData.dirty = true;
+    await writeConfig();
+    return smstoolsConfigData;
+};
 exports.delModem = async (modemName) => {
     if (!modemName) return smstoolsConfigData;
     if (!smstoolsConfigData.modems) {
         return smstoolsConfigData;
     }
     if (!smstoolsConfigData.modems[modemName]) {
         return smstoolsConfigData;
     }
     delete smstoolsConfigData.modems[modemName];
     smstoolsConfigData.dirty = true;
     await writeConfig();
     return smstoolsConfigData;
 };