2017-07-22 23:39:14 +02:00
"use strict" ;
Object . defineProperty ( exports , "__esModule" , { value : true } ) ;
const log = require ( "./log" ) ;
2017-08-09 00:24:22 +02:00
const mqtt = require ( "./mqttdispatcher" ) ;
2017-08-25 15:02:50 +02:00
const fs = require ( "fs" ) ;
const cmdargs = require ( "command-line-args" ) ;
2017-08-23 15:52:37 +02:00
const EspThermToJson = require ( "./espthermtojson" ) ;
const MongoSave = require ( "./mongosave" ) ;
2017-08-09 11:37:22 +02:00
log . info ( "Dispatcher starting" ) ;
2017-08-25 15:02:50 +02:00
const optionDefinitions = [
{ name : 'verbose' , alias : 'v' , type : Boolean } ,
{ name : 'config' , alias : 'c' , type : String , defaultValue : '~/mqttDispatcher.conf' }
] ;
const OPTIONS = cmdargs ( optionDefinitions ) ;
log . info ( ` OPTIONS.config ` ) ;
const CONFIG = JSON . parse ( fs . readFileSync ( OPTIONS . config , "utf8" ) ) ;
let dispatcher = new mqtt . MqttDispatcher ( CONFIG . brokerUrl , CONFIG . brokerUser , CONFIG . brokerPass , CONFIG . brokerCa ) ;
2017-08-23 15:52:37 +02:00
dispatcher . register ( 'IoT/espThermometer2/#' , 'toJson' , EspThermToJson . espThermToJson ) ;
2017-08-25 14:17:26 +02:00
let mongoUrl = "mongodb://localhost/hottis" ;
// let mongoUrl = "mongodb://receiver:esp8266.@cluster0-shard-00-00-7qduq.mongodb.net:27017,cluster0-shard-00-01-7qduq.mongodb.net:27017,cluster0-shard-00-02-7qduq.mongodb.net:27017/hottis?ssl=true&replicaSet=Cluster0-shard-0&authSource=admin"
2017-08-25 15:02:50 +02:00
let mongo = new MongoSave . MongoSave ( CONFIG . mongoDbUrl ) ;
2017-08-23 15:52:37 +02:00
dispatcher . register ( 'IoT/espThermometer2/#' , 'MongoSave' , mongo ) ;
dispatcher . exec ( ) ;
2017-08-09 11:37:22 +02:00
log . info ( "Dispatcher running" ) ;
2017-07-22 23:39:14 +02:00
//# sourceMappingURL=main.js.map