package main

import (
	"lc/common/mqtt"
	"lc/common/util"
	"os"
	"path/filepath"
	"runtime"
)

var FromMQTTConfig util.MQTTConfig
var ToMQTTConfig util.MQTTConfig

func ReadConfig() bool {
	dir, _ := os.Getwd() //filepath.Abs(filepath.Dir(os.Args[0]))
	fpath := dir + string(filepath.Separator) + "conf" + string(filepath.Separator)
	//fmt.Printf("fpath = %v \n", fpath)
	errA := FromMQTTConfig.ReadConfig(fpath, "FromBroker")
	errB := ToMQTTConfig.ReadConfig(fpath, "ToBroker")
	return errA && errB
}

func main() {
	runtime.GOMAXPROCS(runtime.NumCPU())
	util.InitLogrus("release")
	if !ReadConfig() {
		println("config err")
		return
	}
	println("mqttforward runing ... ")
	GetMQTTMgr().Subscribe("000000/its/#", mqtt.AtMostOnce, GetMQTTMgr().HandlerData)
	select {}
}