chiyi
41df889a1a
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
67 lines
1.7 KiB
Go
67 lines
1.7 KiB
Go
package fun
|
|
|
|
import (
|
|
"fmt"
|
|
"reflect"
|
|
)
|
|
|
|
const (
|
|
successCode uint8 = iota
|
|
cellErrorCode
|
|
errorCode
|
|
)
|
|
|
|
type Result[T any] struct {
|
|
Code *uint16 `json:"code,omitempty"`
|
|
Data *T `json:"data,omitempty"`
|
|
Msg *string `json:"msg,omitempty"`
|
|
Status uint8 `json:"status"`
|
|
}
|
|
|
|
// Error 让 Result 实现 error 接口，业务方法可直接返回，Code/Msg/Status 随结果透传
|
|
func (r Result[T]) Error() string {
|
|
if r.Msg != nil {
|
|
return *r.Msg
|
|
}
|
|
if r.Code != nil {
|
|
return fmt.Sprintf("code=%d", *r.Code)
|
|
}
|
|
return "fun: unknown error"
|
|
}
|
|
|
|
// Error 构造带错误码的错误响应，作为 error 返回
|
|
// 用法：return "", fun.Error(4001, "登录失败")
|
|
func Error(code uint16, msg string) error {
|
|
return Result[any]{Code: &code, Msg: &msg, Status: errorCode}
|
|
}
|
|
|
|
func callError(err error) Result[any] {
|
|
return Result[any]{Msg: new(err.Error()), Status: cellErrorCode}
|
|
}
|
|
|
|
// internalError 框架内部错误脱敏：客户端只收到固定提示，
|
|
// 完整错误（JSON 解析细节、Go 类型名等）记服务端日志，不外泄
|
|
func internalError(clientMsg string, err error) Result[any] {
|
|
ErrorLogger("fun: internal error: ", err.Error())
|
|
return Result[any]{Msg: &clientMsg, Status: cellErrorCode}
|
|
}
|
|
|
|
// success 构造成功响应,空切片规范化为 [] 而不是 null
|
|
func success(data any) Result[any] {
|
|
return Result[any]{Data: nonNil(data), Status: successCode}
|
|
}
|
|
|
|
// nonNil 返回 data 的指针;空切片会重建为同类型的非 nil 空切片,
|
|
// 保证 JSON 序列化输出 [] 而不是 null
|
|
func nonNil(data any) *any {
|
|
if data == nil {
|
|
return nil
|
|
}
|
|
|
|
v := reflect.ValueOf(data)
|
|
if v.Kind() == reflect.Slice && v.Len() == 0 {
|
|
return new(reflect.MakeSlice(v.Type(), 0, 0).Interface())
|
|
}
|
|
return &data
|
|
}
|