package main

import (
	"context"
	"flag"
	"fmt"
	"github.com/longjoy/micro-go-course/section11/user/dao"
	"github.com/longjoy/micro-go-course/section11/user/endpoint"
	"github.com/longjoy/micro-go-course/section11/user/redis"
	"github.com/longjoy/micro-go-course/section11/user/service"
	"github.com/longjoy/micro-go-course/section11/user/transport"
	"log"
	"net/http"
	"os"
	"os/signal"
	"strconv"
	"syscall"
)

func main()  {


	var (
		// 服务地址和服务名
		servicePort = flag.Int("service.port", 10086, "service port")

		//waitTime = flag.Int("wait.time", 10, "wait time")

		mysqlAddr = flag.String("mysql.addr", "127.0.0.1", "mysql addr")

		mysqlPort = flag.String("mysql.port", "3306", "mysql port")


		redisAddr = flag.String("redis.addr", "127.0.0.1", "redis addr")

		redisPort = flag.String("redis.port", "6379", "redis port")


	)

	flag.Parse()

	ctx := context.Background()
	errChan := make(chan error)

	err := dao.InitMysql(*mysqlAddr, *mysqlPort, "root", "123456", "user")
	if err != nil{
		log.Fatal(err)
	}

	err = redis.InitRedis(*redisAddr, *redisPort, "" )
	if err != nil{
		log.Fatal(err)
	}

	userService := service.MakeUserServiceImpl(&dao.UserDAOImpl{})

	userEndpoints := &endpoint.UserEndpoints{
		endpoint.MakeRegisterEndpoint(userService),
		endpoint.MakeLoginEndpoint(userService),
	}

	r := transport.MakeHttpHandler(ctx, userEndpoints)



	go func() {
		errChan <- http.ListenAndServe(":"  + strconv.Itoa(*servicePort), r)
	}()

	go func() {
		// 监控系统信号，等待 ctrl + c 系统信号通知服务关闭
		c := make(chan os.Signal, 1)
		signal.Notify(c, syscall.SIGINT, syscall.SIGTERM)
		errChan <- fmt.Errorf("%s", <-c)
	}()

	error := <-errChan
	log.Println(error)

}