gotsrpc/servicereader.go

package gotsrpc

import (
	"errors"
	"fmt"
	"go/ast"
	"reflect"
)

func readServiceFile(file *ast.File, services map[string]*Service) error {
	for _, decl := range file.Decls {
		if reflect.ValueOf(decl).Type().String() == "*ast.FuncDecl" {
			funcDecl := decl.(*ast.FuncDecl)
			if funcDecl.Recv != nil {
				trace("that is a method named", funcDecl.Name)
				if len(funcDecl.Recv.List) == 1 {
					firstReceiverField := funcDecl.Recv.List[0]
					if "*ast.StarExpr" == reflect.ValueOf(firstReceiverField.Type).Type().String() {
						starExpr := firstReceiverField.Type.(*ast.StarExpr)
						if "*ast.Ident" == reflect.ValueOf(starExpr.X).Type().String() {
							ident := starExpr.X.(*ast.Ident)
							fmt.Println("	on sth:", ident.Name)

							service, ok := services[ident.Name]

							if ok {
								service.Methods = append(service.Methods, &Method{
									Name:   funcDecl.Name.Name,
									Args:   readFields(funcDecl.Type.Params.List),
									Return: readFields(funcDecl.Type.Results.List),
								})
							}
						}
					}
				}
			} else {
				trace("no receiver for", funcDecl.Name)
			}
		}
	}
	return nil
}

func readFields(astFields []*ast.Field) (fields []*Field) {
	fields = []*Field{}
	for _, param := range astFields {
		name, value, _ := readField(param)
		fields = append(fields, &Field{
			Name:  name,
			Value: value,
		})
	}
	return

}

func readServicesInPackage(pkg *ast.Package, serviceNames []string) (services map[string]*Service, err error) {
	services = map[string]*Service{}
	for _, serviceName := range serviceNames {
		services[serviceName] = &Service{
			Name:    serviceName,
			Methods: []*Method{},
		}
	}
	for _, file := range pkg.Files {
		err = readServiceFile(file, services)
		if err != nil {
			return
		}

	}
	return
}

func ReadServicesInPackage(goPath string, packageName string, serviceNames []string) (services map[string]*Service, err error) {
	if len(serviceNames) == 0 {
		err = errors.New("nothing to do service names are empty")
		return
	}
	pkg, err := parsePackage(goPath, packageName)
	if err != nil {
		return
	}
	return readServicesInPackage(pkg, serviceNames)
}