package core

import (
	"fmt"
	"os"
	"os/signal"
	"sync"
	"syscall"

	"github.com/infraboard/mcube/logger"
	"github.com/infraboard/mcube/logger/zap"

	"gitee.com/player1111/restful-api-demo.git/http"
)

type Manager struct {
	httpService    *http.HttpService
	handlerService http.HandlerService
	wg             sync.WaitGroup
	log            logger.Logger
}

func NewManager() *Manager {
	return &Manager{
		handlerService: http.NewHandlerService(),
		httpService:    http.NewHttpService(),
		log:            zap.L().Named("Manager"),
	}
}

func (m *Manager) Start() error {
	/*	m.handlerService = http.NewHandlerService()
		m.httpService = http.NewHttpService()*/

	// 启动handlerService

	if err := m.handlerService.Start(); err != nil {
		fmt.Printf("Failed to start HandlerService: %v\n", err)
		return fmt.Errorf("Failed to start HandlerService: %v\n", err)
	}

	// 启动httpService
	if err := m.httpService.Start(); err != nil {
		fmt.Printf("Failed to start HttpService: %v\n", err)
		return fmt.Errorf("Failed to start HttpService: %v\n", err)
	}
	return nil
}

func (m *Manager) Stop() error {
	var err error
	if err = m.handlerService.Stop(); err != nil {
		fmt.Printf("Failed to stop HandlerService: %v\n", err)
	}
	if err = m.httpService.Stop(); err != nil {
		fmt.Printf("Failed to stop HttpService: %v\n", err)
	}
	return err
}

// 处理来自外部的中断信号
func (m *Manager) WaitStop() {
	ch := make(chan os.Signal, 1)
	signal.Notify(ch, syscall.SIGTERM, syscall.SIGQUIT, syscall.SIGHUP, syscall.SIGINT)

	sig := <-ch
	m.log.Infof("received signal:%s\n", sig)
	if err := m.httpService.Stop(); err != nil {
		m.log.Warnf("http Service shutdown failed:%v", err)
	}
}