aboutsummaryrefslogtreecommitdiff
path: root/src/jobd-master.js
diff options
context:
space:
mode:
authorEvgeny Zinoviev <me@ch1p.io>2021-02-28 16:11:06 +0300
committerEvgeny Zinoviev <me@ch1p.io>2021-02-28 16:11:06 +0300
commit142869948c40900569f339a2177e95a3be3bbdfb (patch)
tree88011b401ce178767744bf6665d580c83d4e6ad3 /src/jobd-master.js
parent203fe6221b07784bd595cadd7fc7516020c683cb (diff)
config refactor
Diffstat (limited to 'src/jobd-master.js')
-rwxr-xr-xsrc/jobd-master.js18
1 files changed, 7 insertions, 11 deletions
diff --git a/src/jobd-master.js b/src/jobd-master.js
index 54e2377..6604e05 100755
--- a/src/jobd-master.js
+++ b/src/jobd-master.js
@@ -1,11 +1,9 @@
#!/usr/bin/env node
const minimist = require('minimist')
const loggerModule = require('./logger')
-const configModule = require('./config')
+const config = require('./config')
const {Server, ResponseMessage, RequestMessage} = require('./server')
const WorkersList = require('./workers-list')
-const {masterConfig} = configModule
-
/**
* @type {Logger}
@@ -50,27 +48,25 @@ async function main() {
// read config
try {
- configModule.parseMasterConfig(argv.config)
+ config.parseMasterConfig(argv.config)
} catch (e) {
console.error(`config parsing error: ${e.message}`)
process.exit(1)
}
await loggerModule.init({
- file: masterConfig.log_file,
- levelFile: masterConfig.log_level_file,
- levelConsole: masterConfig.log_level_console,
+ file: config.get('log_file'),
+ levelFile: config.get('log_level_file'),
+ levelConsole: config.get('log_level_console'),
})
logger = loggerModule.getLogger('jobd-master')
- // console.log(masterConfig)
-
workers = new WorkersList()
// start server
server = new Server()
server.on('message', onMessage)
- server.start(masterConfig.port, masterConfig.host)
+ server.start(config.get('port'), config.get('host'))
logger.info('server started')
}
@@ -89,7 +85,7 @@ async function onMessage({message, connection}) {
if (message.requestType !== 'ping')
logger.info('onMessage:', message)
- if (masterConfig.password && message.password !== masterConfig.password) {
+ if (config.get('password') && message.password !== config.get('password')) {
connection.send(new ResponseMessage().setError('invalid password'))
return connection.close()
}