package main

import (
	"flag"
	"fmt"
	"github.com/zeromicro/go-zero/core/conf"
	"github.com/zeromicro/go-zero/core/logx"
	"github.com/zeromicro/go-zero/core/service"
	"paopaoimtask/internal/config"
	"paopaoimtask/internal/handler"
	"paopaoimtask/internal/svc"
	"paopaoimtask/pkg/log"
)

var configFile = flag.String("f", "etc/task-mq.yaml", "the config file")

func main() {
	flag.Parse()

	var c config.Config
	conf.MustLoad(*configFile, &c)

	if err := c.SetUp(); err != nil {
		panic(err)
	}

	ctx := svc.NewServiceContext(c)

	writer := log.NewZapWriter()
	logx.SetWriter(writer)

	listen := handler.NewListen(ctx)

	serviceGroup := service.NewServiceGroup()
	for _, s := range listen.Services() {
		serviceGroup.Add(s)
	}

	fmt.Printf("starting task server at %v....\n", c.ListenOn)
	serviceGroup.Start()
}