package room

import (
	"context"
	v1 "git.gz.internal.jumaiyx.cn/jm/jmproto/room/v1"
	"git.gz.internal.jumaiyx.cn/pkg/k8s-client"
	"git.gz.internal.jumaiyx.cn/pkg/kubediscovery"
	"git.gz.internal.jumaiyx.cn/pkg/log"
)

func NewRoomService(log log.Logger) (v1.RoomClient, error) {
	discovery, err := kubediscovery.Discovery(context.TODO(), log, "room-service", kubediscovery.Namespace(k8sclient.DevNamespace))
	if err != nil {
		log.Errorf("Connect room service failed:%v", err)
		return nil, err
	}
	return v1.NewRoomClient(discovery), nil
}