From 8323eaa985dcac1152e62df28903c643ce2c9f45 Mon Sep 17 00:00:00 2001 From: kaotisk Date: Fri, 1 Mar 2024 00:34:50 +0200 Subject: Added ak-logthis wrapper in API --- api/config.js | 3 ++- api/index.js | 2 ++ api/lib/akLogThis/index.js | 28 ++++++++++++++++++++++++++++ 3 files changed, 32 insertions(+), 1 deletion(-) create mode 100644 api/lib/akLogThis/index.js diff --git a/api/config.js b/api/config.js index b26208c..68b66f9 100644 --- a/api/config.js +++ b/api/config.js @@ -19,7 +19,8 @@ const config = { pairsFile : env.AK_ZPAIRSFILE, peersFile : env.AK_ZPEERSFILE, cacheDir : env.AK_CACHEDIR, - minedBlocksDir: env.AK_MINEDBLOCKSDIR + minedBlocksDir: env.AK_MINEDBLOCKSDIR, + printDebug: env.AK_DEBUG } module.exports = config; diff --git a/api/index.js b/api/index.js index f572586..5fefe9f 100755 --- a/api/index.js +++ b/api/index.js @@ -7,10 +7,12 @@ */ const config = require('./config'); +const akLogThis = require('./lib/akLogThis'); const DEFAULT_PORT = 8610; const PORT = config.port || DEFAULT_PORT; +akLogThis("INFO", "Daemon started") /* * Split the prefix of each API call in segments for better management * diff --git a/api/lib/akLogThis/index.js b/api/lib/akLogThis/index.js new file mode 100644 index 0000000..8f8dded --- /dev/null +++ b/api/lib/akLogThis/index.js @@ -0,0 +1,28 @@ +const { spawn } = require('child_process'); +const config = require('../../config') + +module.exports = (type, message) => { + const command = spawn( + "ak-logthis", + ["", "["+type+"]", message] + ); + + var buffer = ""; + command.stdout.on("data", data => { + console.log(`stdout: ${data}`); + }); + + command.stderr.on("data", data => { + buffer = buffer + data; + }); + + command.on('error', (error) => { + console.log(`error: ${error.message}`); + }); + + command.on("close", code => { + // res.send(JSON.parse(buffer)); + if (config.printDebug === "yes") console.log(buffer); + console.log(`child process exited with code ${code}`); + }); +}; -- cgit v1.2.3