package main

import (
	"gitee.com/aywc_1/aywc_judge/src/appinit"
	"gitee.com/aywc_1/aywc_judge/src/configuration"
	"gitee.com/aywc_1/aywc_judge/src/lib"
	"gitee.com/aywc_1/aywc_judge_notice/src/websocket2"
	log "github.com/sirupsen/logrus"
	"net/http"
)

//var Addr=flag.String("addr",":8083","websocket service address")
func main() {
	configuration.InitLog("notice")
	log.Info("Starting websocket application...")
	err := appinit.DBInit()
	if err != nil {
		log.Fatal(err)
	}
	lib.NewMQ()
	client := lib.GetMQ()
	err = client.Channel.Qos(10, 0, false)
	if err != nil {
		log.Fatal(err)
	}
	port := configuration.GetYamlValue([]string{"config", "websocket", "port"}, 0, ":8083").(string)
	go websocket2.Manager.Start()
	go websocket2.Manager.GetMQData(client)

	http.HandleFunc("/ws/echo", websocket2.Echo)
	http.HandleFunc("/ws/exit", websocket2.Exit)
	log.Info(port)
	http.ListenAndServe(port, nil)

}