package base

import (
	"context"
	"fmt"
	"gitee.com/micro-tools/micro/module"
	"gitee.com/micro-tools/wf/extend/utils/ggrpc"
	"gitee.com/micro-tools/wf/extend/utils/gmicro/registry"
	"google.golang.org/grpc"
)

type serverSession struct {
	node   *registry.Node
	name   string
	client *grpc.ClientConn
	app    module.App
}

// NewServerSession 创建一个节点实例
func NewServerSession(app module.App, name string, node *registry.Node) (module.ServerSession, error) {
	var err error
	session := &serverSession{
		name: name,
		node: node,
		app:  app,
	}

	cli := ggrpc.Client{
		Name: app.Options().Tracing.Name,
		Config: ggrpc.ClientConfig{
			Address:   fmt.Sprintf("%s:%d", node.Address, node.Port),
			AutoClose: false,
			Timeout:   -1,
			Tracing:   app.Options().Tracing.Status,
		},
		Client: nil,
	}
	err = cli.NewClient(func(conn *grpc.ClientConn, ctx context.Context) (err error) {
		session.client = conn
		return nil
	})
	return session, err
}

func (c *serverSession) GetID() string {
	return c.node.Id
}

func (c *serverSession) GetName() string {
	return c.name
}

func (c *serverSession) GetClient() *grpc.ClientConn {
	return c.client
}

//func (c *serverSession) GetRPC() wurpc.RPCClient {
//	return c.rpc
//}

func (c *serverSession) GetApp() module.App {
	return c.app
}
func (c *serverSession) GetNode() *registry.Node {
	return c.node
}

func (c *serverSession) SetNode(node *registry.Node) (err error) {
	c.node = node
	return
}

/**
消息请求
*/
func (c *serverSession) Call(serviceName string, fnc func(*grpc.ClientConn, context.Context)) error {
	return nil
}