package proxy

import (
	"log"
	pb "git.loafle.net/overflow/overflow_api_db/build/golang"
	"google.golang.org/grpc"
	"golang.org/x/net/context"
	"git.loafle.net/overflow/overflow_proxy_service/proxy/member"
)


func InvokeDB(targetDb, methodName string, param map[string]string) (string) {

	in := &pb.DBInput{}
	in.TargetDao = targetDb
	in.Method = methodName
	in.Param = param

	conn, err := grpc.Dial(":50006", grpc.WithInsecure())

	if err != nil {
		log.Fatal("Rpc Error: ", err)
	}
	defer conn.Close()

	client := pb.NewDBClient(conn)
	out, err := client.Exec(context.Background(), in)
	if err != nil {
		log.Fatal("Rpc Client Error: ", err)
	}
	log.Print(out)

	return out.Result
}

//FIXME:: test session member
func GetSessionMember() *member.Member {

	m := member.NewMember()
	m.Id = "1";

	return m;
}