package cRpc

import (
	"github.com/gin-gonic/gin"
	"log"
	"net/http"
	"reflect"
)

type RpcController struct {
}

func (c *RpcController) ControllerName() string {
	return "RpcController"
}

func (c *RpcController) Handler(ctx *gin.Context) (int, interface{}) {
	defer ctx.Abort()
	rpcApp := ctx.Request.Header.Get(Header_Rpc_App)
	rpcService := ctx.Request.Header.Get(Header_Rpc_Service)
	rpcMethod := ctx.Request.Header.Get(Header_Rpc_Method)

	instance := GetService(rpcApp, rpcService)
	if instance == nil {
		return 590, nil
	}

	caller := reflect.ValueOf(instance).MethodByName(rpcMethod)
	if !caller.IsValid() {
		return 591, nil
	}

	paramType := caller.Type().In(1)
	param := reflect.New(paramType)

	err := ctx.BindJSON(param.Interface())
	if err != nil {
		log.Printf("%#v", err)
		return 592, nil
	}

	responseValues := caller.Call([]reflect.Value{reflect.ValueOf(ctx), param.Elem()})
	if !responseValues[1].IsNil() {
		return 593, nil
	}

	return http.StatusOK, responseValues[0].Interface()
}