package main

import (
	"fmt"
	"git.beswell.com/gframe/application"
	"github.com/ZR233/glog/v2"
	"github.com/sirupsen/logrus"
	"log"
	"net"
	"sportfitness/base/api/grpc"
	pb "sportfitness/base/api/grpc/base"
	"sportfitness/base/assembly/base"
	hr "sportfitness/base/assembly/heartRate"
	hrs "sportfitness/base/assembly/heartRate/service"
)

func main() {
	glog.Init("sportfitness", "base")
	glog.Init("sportfitness", "heartRate")
	app := application.NewDefault()

	err := app.LogUseKafka()
	if err != nil {
		panic(err)
	}

	err = app.AddServiceGrpcClient("bsw/im")
	if err != nil {
		panic(err)
	}
	// MiddleWare的写法
	//app.Use(func(context *application.Context) {
	//	defer func() {
	//		if p := recover(); p != nil {
	//			err := p.(error)
	//			s, ok := status.FromError(err)
	//			if !ok {
	//				println(s) // not status
	//			}
	//			s.Code()
	//			//context.Set()   // 在context中增加key value
	//		}
	//	}()
	//	context.Next()
	//})
	//基础库初始化
	base.Init()
	hr.Init()

	hrs.CalculationUnit{}.Run()

	grpcServer := app.GRPCServer()

	lis, err := net.Listen("tcp", fmt.Sprintf(":%d", 19090))
	if err != nil {
		logrus.Fatalf("failed to listen: %s", err)
	}
	pb.RegisterApiServer(grpcServer, &grpc.Api{})

	logrus.Infof("listen :%d", 19090)
	err = grpcServer.Serve(lis)
	if err != nil {
		log.Fatal(err)
	}
}