package server

import (
	"encoding/json"
	"log"

	"github.com/mikudos/mikudos-message-pusher/db"
	pb "github.com/mikudos/mikudos-message-pusher/proto/message-pusher"
)

// Handler Server instance
var Handler Server

func init() {
	Handler = Server{Mode: "group", Recv: make(chan *pb.Message), Returned: make(map[string]map[uint32]chan *pb.Response), GroupRecv: make(map[string]chan *pb.Message), EveryRecv: make(map[uint32]chan *pb.Message), SaveMsg: make(chan *pb.Message)}

	db.InitConfig()
	storage, err := db.InitStorage()
	if err != nil {
		log.Fatalf("InitStorage err: %v\n", err)
	}
	Handler.Storage = *storage

	initReadRoutine()
}

func initReadRoutine() {
	for index := 0; index < 1; index++ {
		go ReadSaveMsg(&Handler)
	}
}

// ReadSaveMsg ReadSaveMsg method
func ReadSaveMsg(h *Server) {
	for {
		msg := <-h.SaveMsg
		Handler.Storage.SaveChannel(msg.GetChannelId(), json.RawMessage(msg.GetMsg()), msg.GetMsgId(), uint(msg.GetExpire()))
	}
}