BREAKING CHANGES: - Guard interface: Guard(ctx Ctx) error; returning error short-circuits (subsequent guards and the method no longer execute) - Wired[T]() (*T, error); New() may return error; failed wiring is sticky - BindService/BindGuard/BindRoute return error; routes accept guards (guards receive merged query/form params as Ctx.State) - registration panics after Start; Ctx.Ip honors X-Forwarded-For/X-Real-IP - internal errors sanitized to fixed client messages FIXES: - int64 precision loss: /cell data decoded from raw JSON bytes and responses serialized with json.Number (no float64 round-trip) - enum values range-checked before uint8 conversion (256 no longer truncates to 0 and slips through) - logger: files failing name parsing are no longer deleted; log channel never blocks request goroutines; ConfigLogger is race-free; logWriterWorker unlock bug fixed - stream writer panics recovered (process no longer crashes); streamDone closed exactly once - generated Go client emits definitions for pointer-to-enum/struct fields - anonymous structs rejected at registration; isPrivate safe on empty names - removed dead Result.Id and RequestInfo.Type ADDITIONS: - graceful shutdown (Shutdown), StartOn, server timeouts by default (Read 60s/Idle 120s/Write off), SetTimeouts/SetMaxConcurrency - big-int-safe JSON in the generated TS client (>2^53 as BigInt) - example/ demo services and cmd/genexample artifact generator
228 lines
6.3 KiB
Go
228 lines
6.3 KiB
Go
package fun
|
|
|
|
import (
|
|
"reflect"
|
|
"strings"
|
|
)
|
|
|
|
type GenGo struct {
|
|
template templateGo
|
|
}
|
|
|
|
func (ctx GenGo) typeToTemplateType(t reflect.Type) string {
|
|
text := ""
|
|
if t.Kind() == reflect.Ptr {
|
|
text += "*"
|
|
t = t.Elem()
|
|
}
|
|
switch t.Kind() {
|
|
case reflect.Slice:
|
|
text += "[]" + ctx.typeToTemplateType(t.Elem())
|
|
default:
|
|
text += t.Name()
|
|
}
|
|
return text
|
|
}
|
|
|
|
func (ctx GenGo) genService(svc *genSvc, serviceContext *genServiceType) {
|
|
for _, gm := range svc.methods {
|
|
var returnValueText string
|
|
var dtoText string
|
|
var argsText string
|
|
var genericTypeText string
|
|
|
|
// () error:无数据返回,客户端类型为 Void
|
|
if gm.sig.NumOut() == 1 && gm.sig.Out(0) == errorType {
|
|
genericTypeText = "Void"
|
|
returnValueText = "Result[Void]"
|
|
if gm.dtoType != nil {
|
|
v := ctx.typeToTemplateType(gm.dtoType)
|
|
if !strings.Contains(v, "[]") && strings.Contains(v, "[") {
|
|
dtoText += "dto " + getGenericTypeName(v) + parseGenericTypeParams(v)
|
|
} else {
|
|
dtoText += "dto " + v
|
|
}
|
|
argsText += ",dto"
|
|
ctx.genStruct(gm.dtoType)
|
|
}
|
|
serviceContext.GenMethodTypeList = append(serviceContext.GenMethodTypeList, &genMethodType{
|
|
MethodName: gm.name,
|
|
ReturnValueText: returnValueText,
|
|
DtoText: dtoText,
|
|
ArgsText: argsText,
|
|
GenericTypeText: genericTypeText,
|
|
})
|
|
continue
|
|
}
|
|
|
|
returnType := gm.sig.Out(0)
|
|
if gm.isStream {
|
|
serviceContext.IsIncludeStream = true
|
|
if returnType == streamType {
|
|
genericTypeText = "any"
|
|
returnValueText = "Void"
|
|
} else {
|
|
t := ctx.typeToTemplateType(returnType)
|
|
if !strings.Contains(t, "[]") && strings.Contains(t, "[") {
|
|
genericTypeText = getGenericTypeName(t) + parseGenericTypeParams(t)
|
|
} else {
|
|
genericTypeText = t
|
|
}
|
|
returnValueText = genericTypeText
|
|
ctx.genReturnTypes(returnType)
|
|
}
|
|
} else {
|
|
t := ctx.typeToTemplateType(returnType)
|
|
if !strings.Contains(t, "[]") && strings.Contains(t, "[") {
|
|
returnValueText = getGenericTypeName(t) + parseGenericTypeParams(t)
|
|
} else {
|
|
returnValueText = t
|
|
}
|
|
genericTypeText = returnValueText
|
|
ctx.genReturnTypes(returnType)
|
|
returnValueText = "Result[" + returnValueText + "]"
|
|
}
|
|
|
|
if gm.dtoType != nil {
|
|
v := ctx.typeToTemplateType(gm.dtoType)
|
|
if !strings.Contains(v, "[]") && strings.Contains(v, "[") {
|
|
dtoText += "dto " + getGenericTypeName(v) + parseGenericTypeParams(v)
|
|
} else {
|
|
dtoText += "dto " + v
|
|
}
|
|
argsText += ",dto"
|
|
ctx.genStruct(gm.dtoType)
|
|
}
|
|
|
|
serviceContext.GenMethodTypeList = append(serviceContext.GenMethodTypeList, &genMethodType{
|
|
MethodName: gm.name,
|
|
ReturnValueText: returnValueText,
|
|
DtoText: dtoText,
|
|
ArgsText: argsText,
|
|
GenericTypeText: genericTypeText,
|
|
IsStream: gm.isStream,
|
|
})
|
|
}
|
|
genCode(ctx.template.genServiceTemplate(), camelToSnake(svc.name), serviceContext, ctx.getName())
|
|
}
|
|
|
|
// genReturnTypes 递归生成返回类型涉及的 struct/enum 定义
|
|
func (ctx GenGo) genReturnTypes(returnType reflect.Type) {
|
|
if returnType.Kind() == reflect.Ptr {
|
|
returnType = returnType.Elem()
|
|
}
|
|
if returnType.Kind() == reflect.Struct {
|
|
ctx.genStruct(returnType)
|
|
}
|
|
if returnType.Kind() == reflect.Slice {
|
|
fieldType := returnType.Elem()
|
|
if fieldType.Kind() == reflect.Ptr {
|
|
fieldType = fieldType.Elem()
|
|
}
|
|
if fieldType.Kind() == reflect.Struct {
|
|
ctx.genStruct(fieldType)
|
|
}
|
|
}
|
|
if returnType.Kind() == reflect.Uint8 && (returnType.Implements(displayEnumType) || returnType.Implements(enumType)) {
|
|
ctx.getEnum(returnType)
|
|
}
|
|
}
|
|
|
|
func (ctx GenGo) genDefaultService() {
|
|
f := GetFun()
|
|
genContext := genType{GenServiceList: []*genServiceType{}}
|
|
|
|
for _, svc := range f.serviceGroups() {
|
|
serviceContext := &genServiceType{
|
|
ServiceName: svc.name,
|
|
GenMethodTypeList: []*genMethodType{},
|
|
}
|
|
genContext.GenServiceList = append(genContext.GenServiceList, serviceContext)
|
|
ctx.genService(svc, serviceContext)
|
|
}
|
|
genCode(ctx.template.genDefaultServiceTemplate(), "fun", genContext, ctx.getName())
|
|
}
|
|
|
|
func (ctx GenGo) genStruct(t reflect.Type) *genImportType {
|
|
var structTemplate genClassType
|
|
if !strings.Contains(t.String(), "[]") && strings.Contains(t.String(), "[") {
|
|
structTemplate = genClassType{
|
|
Name: getGenericTypeName(t.Name()) + parseGenericTypeParams(t.Name()),
|
|
}
|
|
} else {
|
|
structTemplate = genClassType{
|
|
Name: t.Name(),
|
|
}
|
|
}
|
|
|
|
for i := 0; i < t.NumField(); i++ {
|
|
field := t.Field(i)
|
|
fieldType := field.Type
|
|
jsType := ctx.typeToTemplateType(fieldType)
|
|
name := field.Name
|
|
tag := "`json:\"" + firstLetterToLower(name) + "\"`"
|
|
if !strings.Contains(jsType, "[]") && strings.Contains(jsType, "[") {
|
|
structTemplate.GenClassFieldType = append(structTemplate.GenClassFieldType, &genClassFieldType{
|
|
Name: name,
|
|
Type: getGenericTypeName(jsType) + parseGenericTypeParams(jsType),
|
|
Tag: tag,
|
|
})
|
|
} else {
|
|
structTemplate.GenClassFieldType = append(structTemplate.GenClassFieldType, &genClassFieldType{
|
|
Name: name,
|
|
Type: jsType,
|
|
Tag: tag,
|
|
})
|
|
}
|
|
|
|
// 指针字段解引用后再检查嵌套类型,与 TS 生成器一致:
|
|
// 否则 *Enum/*Struct 字段的定义文件会被漏生成(Kind 是 Ptr,三个分支全跳过)
|
|
if fieldType.Kind() == reflect.Ptr {
|
|
fieldType = fieldType.Elem()
|
|
}
|
|
if fieldType.Kind() == reflect.Struct {
|
|
ctx.genStruct(fieldType)
|
|
}
|
|
if fieldType.Kind() == reflect.Slice && fieldType.Elem().Kind() == reflect.Struct {
|
|
ctx.genStruct(fieldType.Elem())
|
|
}
|
|
if fieldType.Kind() == reflect.Uint8 && (fieldType.Implements(displayEnumType) || fieldType.Implements(enumType)) {
|
|
ctx.getEnum(fieldType)
|
|
}
|
|
}
|
|
|
|
genCode(
|
|
ctx.template.genStructTemplate(),
|
|
camelToSnake(structTemplate.Name),
|
|
structTemplate,
|
|
ctx.getName(),
|
|
)
|
|
return &genImportType{}
|
|
}
|
|
|
|
func (ctx GenGo) getEnum(t reflect.Type) *genImportType {
|
|
var enumTemplate genEnumType
|
|
statusValue := reflect.New(t).Elem()
|
|
if t.Implements(displayEnumType) {
|
|
enumValue := statusValue.Interface().(displayEnum)
|
|
enumTemplate.Names = enumValue.Names()
|
|
enumTemplate.DisplayNames = enumValue.DisplayNames()
|
|
} else {
|
|
enumValue := statusValue.Interface().(enum)
|
|
enumTemplate.Names = enumValue.Names()
|
|
}
|
|
enumTemplate.Name = t.Name()
|
|
|
|
genCode(
|
|
ctx.template.genEnumTemplate(),
|
|
camelToSnake(t.Name()),
|
|
enumTemplate,
|
|
ctx.getName(),
|
|
)
|
|
return &genImportType{}
|
|
}
|
|
|
|
func (ctx GenGo) getName() string {
|
|
return "go"
|
|
}
|