rpc-go/registry/rpc-registry.go

package registry

import (
	"reflect"

	"git.loafle.net/commons/rpc-go/protocol"
	cus "git.loafle.net/commons/util-go/service"
)

// NewRPCRegistry returns a new RPC registry.
func NewRPCRegistry() RPCRegistry {
	return &rpcRegistry{
		serviceRegistry: new(cus.ServiceRegistry),
	}
}

type RPCRegistry interface {
	RPCInvoker
	GetService(name string) interface{}
	RegisterService(receiver interface{}, name string) error
	RegisterServices(receivers ...interface{}) error
	RegisterServiceMap(keysAndValues map[string]interface{}) error
}

// RPCRegistry serves registered RPC services using registered codecs.
type rpcRegistry struct {
	serviceRegistry *cus.ServiceRegistry
}

// RegisterService adds a new service to the server.
//
// The name parameter is optional: if empty it will be inferred from
// the receiver type name.
//
// Methods from the receiver will be extracted if these rules are satisfied:
//
//    - The receiver is exported (begins with an upper case letter) or local
//      (defined in the package registering the service).
//    - The method name is exported.
//    - The method has two arguments: *args, *reply.
//    - All two arguments are pointers.
//    - The first and second arguments are exported or local.
//    - The method has return type error.
//
// All other methods are ignored.
func (rr *rpcRegistry) RegisterService(receiver interface{}, name string) error {
	return rr.serviceRegistry.Register(receiver, name)
}

func (rr *rpcRegistry) RegisterServices(receivers ...interface{}) error {
	if nil == receivers || 0 == len(receivers) {
		return nil
	}

	for _, receiver := range receivers {
		if err := rr.serviceRegistry.Register(receiver, ""); nil != err {
			return err
		}
	}
	return nil
}

func (rr *rpcRegistry) RegisterServiceMap(keysAndValues map[string]interface{}) error {
	if nil == keysAndValues || 0 == len(keysAndValues) {
		return nil
	}

	for name, receiver := range keysAndValues {
		if err := rr.serviceRegistry.Register(receiver, name); nil != err {
			return err
		}
	}
	return nil
}

func (rr *rpcRegistry) GetService(name string) interface{} {
	return rr.serviceRegistry.GetService(name)
}

// HasMethod returns true if the given method is registered.
//
// The method uses a dotted notation as in "Service.Method".
func (rr *rpcRegistry) HasMethod(method string) bool {
	if _, _, err := rr.serviceRegistry.Get(method); err == nil {
		return true
	}
	return false
}

// Invoke execute a method.
//
// Codecs are defined to process a given serialization scheme, e.g., JSON or
// XML. A codec is chosen based on the "Content-Type" header from the request,
// excluding the charset definition.
func (rr *rpcRegistry) Invoke(codec protocol.RegistryCodec, leadingParams ...interface{}) (result interface{}, err error) {
	serviceSpec, methodSpec, errGet := rr.serviceRegistry.Get(codec.Method())
	if nil != errGet {
		return nil, errGet
	}
	// Decode the args.

	var in []reflect.Value
	pValues, pInstances := methodSpec.ParamValues()

	lParamLen := 0
	if nil != leadingParams {
		lParamLen = len(leadingParams)
	}

	if nil != pInstances && 0 < len(pInstances) {
		if errRead := codec.ReadParams(pInstances[lParamLen:]); errRead != nil {
			return nil, errRead
		}

		pCount := len(pInstances)
		in = make([]reflect.Value, pCount+1)

		for indexI := lParamLen; indexI < pCount; indexI++ {
			if pValues[indexI].Type().Kind() == reflect.Ptr && pValues[indexI].Type().Elem().Kind() != reflect.Struct {
				in[indexI+1] = reflect.Indirect(pValues[indexI])
			} else {
				in[indexI+1] = pValues[indexI]
			}
		}
	} else {
		in = make([]reflect.Value, 1)
	}
	in[0] = serviceSpec.ReceiverValue()

	for indexI := 0; indexI < lParamLen; indexI++ {
		in[indexI+1] = reflect.ValueOf(leadingParams[indexI])
	}

	// Call the service method.
	returnValues := methodSpec.Call(in)

	if nil != methodSpec.ReturnType() {
		result = returnValues[0].Interface()
		if nil != returnValues[1].Interface() {
			err = returnValues[1].Interface().(error)
		}
	} else {
		if nil != returnValues[0].Interface() {
			err = returnValues[0].Interface().(error)
		}
	}

	return
}

// func convertValues(values []interface{}, types []reflect.Type) []reflect.Value {
// 	c := len(values)
// 	vs := make([]reflect.Value, c)
// 	for indexI := 0; indexI < c; indexI++ {
// 		vs[indexI] = convertValue(&values[indexI], types[indexI])
// 	}
// 	return vs
// }

// func convertValue(v *interface{}, t reflect.Type) reflect.Value {
// 	switch t.Kind() {
// 	case reflect.Bool:
// 		return reflect.ValueOf(*v).Convert(t)
// 	case reflect.Float32, reflect.Float64:
// 		return reflect.ValueOf(*v).Convert(t)
// 	case reflect.Int, reflect.Int32, reflect.Int64:
// 		return reflect.ValueOf(*v).Convert(t)
// 	case reflect.Interface:
// 		// When we see an interface, we make our own thing
// 		return reflect.ValueOf(*v).Convert(t)
// 	case reflect.Map:
// 		return reflect.ValueOf(*v).M
// 		return d.decodeMap(name, node, result)
// 	case reflect.Ptr:
// 		return d.decodePtr(name, node, result)
// 	case reflect.Slice:
// 		return d.decodeSlice(name, node, result)
// 	case reflect.String:
// 		return d.decodeString(name, node, result)
// 	case reflect.Struct:
// 		return d.decodeStruct(name, node, result)
// 	default:
// 		return &parser.PosError{
// 			Pos: node.Pos(),
// 			Err: fmt.Errorf("%s: unknown kind to decode into: %s", name, k.Kind()),
// 		}
// 	}
// }