diff options
author | Evgeny Zinoviev <me@ch1p.io> | 2021-02-28 16:11:06 +0300 |
---|---|---|
committer | Evgeny Zinoviev <me@ch1p.io> | 2021-02-28 16:11:06 +0300 |
commit | 142869948c40900569f339a2177e95a3be3bbdfb (patch) | |
tree | 88011b401ce178767744bf6665d580c83d4e6ad3 /src/jobd-master.js | |
parent | 203fe6221b07784bd595cadd7fc7516020c683cb (diff) |
config refactor
Diffstat (limited to 'src/jobd-master.js')
-rwxr-xr-x | src/jobd-master.js | 18 |
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() } |