package main

import (
	"net/http"
    "flag"
	_ "net/http/pprof"
    "time"

	"github.com/long/taskpubsub/camera"
	"github.com/long/taskpubsub/sdk"
	"github.com/long/taskpubsub/tasktag"
	"github.com/long/taskpubsub/util"
    "github.com/long/taskpubsub/logger"

)

var initchan = make(chan bool)

func init(){
    var logFile = "./taskpubsub.log"
    var logSaveDays    =    15
    
    // 日志初始化
    logger.Config(logFile, logger.InfoLevel)
    logger.SetSaveDays(logSaveDays)
    logger.Info("loginit success !")
}     
        
func     main() {
    flag.Parse()
    time.Sleep(time.Second)

	// pprof 用于分析性能
	go func() {
		logger.Info(http.ListenAndServe("0.0.0.0:6061", nil))
	}()

	go util.Init(initchan)

	logger.Info("init ok !!!!, start sdk, task, camera init process ....", <-initchan)
	sdk.Init()        //  获取所有算法id ,建立 sdk 主题， 建立sdk server(send, recv 运行)
	tasktag.Init()   // 获取所有任务，建立任务标签， 在数据进入时， 打标签
	camera.Init()   //获取cid, taskid, sdkid ,关系
	select {}
}