package impl

import (
	"gitee.com/penghengben/devcloud-mini/mcenter/apps/role"
	"gitee.com/penghengben/devcloud-mini/mcenter/conf"
	"github.com/infraboard/mcube/ioc"
	"go.mongodb.org/mongo-driver/mongo"
	"google.golang.org/grpc"
)

func init() {
	ioc.RegistryController(&impl{})
}

// 显示的约束对象接口
var _ role.Service = (*impl)(nil)

type impl struct {
	// 继承GRPC 服务方法模板
	role.UnimplementedRpcServer
	// ioc
	ioc.IocObjectImpl
	// mongo
	col *mongo.Collection
}

func (i *impl) Init() error {
	// 补充Mongo依赖
	db, err := conf.C().MongoDB.GetDB()
	if err != nil {
		panic(err)
	}
	// 缺少事物补充,但是问题不大,如果删除后注册失败,再重新注册还是可以正常使用
	// sess, err := db.Client().StartSession()
	// sess.StartTransaction()
	// sess.Client().Database("dd").Collection("xx").InsertMany(ctx,xxx)
	// sess.CommitTransaction()
	// sess.EndSession()

	i.col = db.Collection(role.AppName)
	return nil
}

func (i *impl) Name() string {
	return role.AppName
}

func (i *impl) Registry(server *grpc.Server) {
	role.RegisterRpcServer(server, i)
}