package rslogger

import (
	"encoding/json"
	"os"
	"time"

	"github.com/gofiber/fiber/v2"
	"github.com/rs/zerolog"
	"github.com/rs/zerolog/log"
)

var usedLogManagerServerUrl string

func InitLogger(debug bool, colorizedOutput bool, logManagerServerUrl string) {
	zerolog.TimeFieldFormat = zerolog.TimeFormatUnix

	if debug {
		zerolog.SetGlobalLevel(zerolog.DebugLevel)
	} else {
		zerolog.SetGlobalLevel(zerolog.InfoLevel)
	}

	if colorizedOutput {
		log.Logger = log.Output(zerolog.ConsoleWriter{Out: os.Stderr, TimeFormat: "15:04:05"})
	}

	if logManagerServerUrl != "" {
		usedLogManagerServerUrl = logManagerServerUrl
	}
}

func GetTime() string {
	return time.Now().Format("15:04:05 02-01-2006") + " "
}

type LogManagerRequestBody struct {
	Type string
	Logs []string
}

func LogManagerRequestClient(requestMethod string, body interface{}) {
	if usedLogManagerServerUrl == "" {
		log.Error().Msgf("Log manager server url is not set, skipping request")
		return
	}

	a := fiber.AcquireAgent()

	req := a.Request()
	req.Header.SetMethod(requestMethod)
	req.SetRequestURI(usedLogManagerServerUrl + "/v1/log")
	req.Header.SetContentType("application/json")

	reqestBodyBytes, err := json.Marshal(body)

	if err != nil {
		log.Error().Msgf("Failed to marshal request body, err: %s", err)
		return
	}

	req.SetBody(reqestBodyBytes)

	if err := a.Parse(); err != nil {
		log.Error().Msgf("Failed to parse request, err: %s", err)
		return
	}

	code, body, _ := a.Bytes()

	log.Debug().Msgf("Log manager request, code: %d, body: %s", code, body)
}