package service

import (
	"context"
	"errors"
	"fmt"
	"github.com/sirupsen/logrus"
	"hy2xs-admin/util"
	"net/http"
	"time"
)

var server *http.Server

func InitServer(addr string, handler http.Handler) {
	server = &http.Server{
		Addr:    addr,
		Handler: handler,
	}
}

func StartServer(crtPath string, keyPath string) error {
	if crtPath != "" && keyPath != "" {
		return server.ListenAndServeTLS(crtPath, keyPath)
	}
	return server.ListenAndServe()
}

func StopServer() error {
	ctx, cancel := context.WithTimeout(context.Background(), 3*time.Second)
	defer cancel()
	if err := server.Shutdown(ctx); err != nil {
		logrus.Errorf("failed to shutdown server: %v", err)
		return errors.New("failed to shutdown server")
	}

	return nil
}

func GetServerPortAndCert() (int64, string, string, error) {
	port, crtPath, keyPath, err := GetPortAndCert()
	if err != nil {
		return 0, "", "", err
	}

	if !util.IsPortAvailable(uint(port), "tcp") {
		errMsg := fmt.Sprintf("port %d is taken", port)
		logrus.Errorf(errMsg)
		return 0, "", "", errors.New(errMsg)
	}

	if crtPath != "" && !util.Exists(crtPath) {
		errMsg := fmt.Sprintf("crt path: %s does not exist", crtPath)
		logrus.Errorf(errMsg)
		return 0, "", "", errors.New(errMsg)
	}

	if keyPath != "" && !util.Exists(keyPath) {
		errMsg := fmt.Sprintf("key path: %s does not exist", keyPath)
		logrus.Errorf(errMsg)
		return 0, "", "", errors.New(errMsg)
	}

	return port, crtPath, keyPath, nil
}