package main

import (
	"flag"
	_ "net/http/pprof"
	"vamicro/config"
	"vamicro/iotData-service/device"
	"vamicro/iotData-service/model"
	"vamicro/iotData-service/mqtt"
	"vamicro/iotData-service/webserver"

	"basic.com/valib/logger.git"
)

var (
	env     = flag.String("e", "pro", "")
	webPort = flag.String("p", "9000", "listen port")
)

func init() {
	flag.Parse()

	config.Init(*env)
	var logFile = config.LogConf.Path + "vamicro-" + "iotData-service" + ".log"
	logger.InitLogger(logFile, config.LogConf.Level, config.LogConf.MaxSize, config.LogConf.MaxBackups, config.LogConf.MaxAge)

	logger.Info("log init success !")
}

func main() {
	//go func() {
	//	logger.Info(http.ListenAndServe("0.0.0.0:6080", nil))
	//}()

	model.Init()

	mqtt.LoadConfig()

	mqtt.Client.Init(mqtt.Options.Broker, mqtt.Options.ClientId, mqtt.Options.Username, mqtt.Options.Password)

	go device.Collector()

	webserver.Serve(*webPort)
}