From fe96dde120cc4a9e8b899c7fc60ca5ffecd95027 Mon Sep 17 00:00:00 2001 From: Kevin Franklin Kim Date: Mon, 23 Mar 2026 06:54:05 +0100 Subject: [PATCH] fix: stats check --- example/basic/service/gotsrpc_gen.go | 256 ++++++++++----------- example/monitor/service/gotsrpc_gen.go | 8 +- internal/codegen/gocode.go | 8 +- tests/aliases/server/gotsrpc_gen.go | 60 ++--- tests/context/server/gotsrpc_gen.go | 28 +-- tests/errors/server/gotsrpc_gen.go | 56 ++--- tests/nullable/server/gotsrpc_gen.go | 36 +-- tests/time/server/gotsrpc_gen.go | 12 +- tests/types/server/gotsrpc_gen.go | 296 ++++++++++++------------- tests/union/server/gotsrpc_gen.go | 20 +- 10 files changed, 390 insertions(+), 390 deletions(-) diff --git a/example/basic/service/gotsrpc_gen.go b/example/basic/service/gotsrpc_gen.go index a7bf7fc..bf9a0ad 100644 --- a/example/basic/service/gotsrpc_gen.go +++ b/example/basic/service/gotsrpc_gen.go @@ -103,8 +103,8 @@ func (p *ServiceGoTSRPCProxy) ServeHTTP(w http.ResponseWriter, r *http.Request) defer io.Copy(io.Discard, r.Body) // Drain Request Body funcName := gotsrpc.GetCalledFunc(r, p.EndPoint) - callStats, _ := gotsrpc.GetStatsForRequest(r) - if callStats != nil { + callStats, callStatsOk := gotsrpc.GetStatsForRequest(r) + if callStatsOk { callStats.Func = funcName callStats.Package = "github.com/foomo/gotsrpc/v2/example/basic/service" callStats.Service = "Service" @@ -124,11 +124,11 @@ func (p *ServiceGoTSRPCProxy) ServeHTTP(w http.ResponseWriter, r *http.Request) return } var executionStart time.Time - if callStats != nil { + if callStatsOk { executionStart = time.Now() } boolRet := p.service.Bool(arg_v) - if callStats != nil { + if callStatsOk { callStats.Execution = time.Since(executionStart) } rets = []any{boolRet} @@ -152,11 +152,11 @@ func (p *ServiceGoTSRPCProxy) ServeHTTP(w http.ResponseWriter, r *http.Request) return } var executionStart time.Time - if callStats != nil { + if callStatsOk { executionStart = time.Now() } boolPtrRet := p.service.BoolPtr(arg_v) - if callStats != nil { + if callStatsOk { callStats.Execution = time.Since(executionStart) } rets = []any{boolPtrRet} @@ -180,11 +180,11 @@ func (p *ServiceGoTSRPCProxy) ServeHTTP(w http.ResponseWriter, r *http.Request) return } var executionStart time.Time - if callStats != nil { + if callStatsOk { executionStart = time.Now() } boolSliceRet := p.service.BoolSlice(arg_v) - if callStats != nil { + if callStatsOk { callStats.Execution = time.Since(executionStart) } rets = []any{boolSliceRet} @@ -200,12 +200,12 @@ func (p *ServiceGoTSRPCProxy) ServeHTTP(w http.ResponseWriter, r *http.Request) rets []any ) var executionStart time.Time - if callStats != nil { + if callStatsOk { executionStart = time.Now() } rw := gotsrpc.ResponseWriter{ResponseWriter: w} p.service.Context(&rw, r) - if callStats != nil { + if callStatsOk { callStats.Execution = time.Since(executionStart) } if rw.Status() == http.StatusOK { @@ -223,11 +223,11 @@ func (p *ServiceGoTSRPCProxy) ServeHTTP(w http.ResponseWriter, r *http.Request) rets []any ) var executionStart time.Time - if callStats != nil { + if callStatsOk { executionStart = time.Now() } p.service.Empty() - if callStats != nil { + if callStatsOk { callStats.Execution = time.Since(executionStart) } rets = []any{} @@ -251,11 +251,11 @@ func (p *ServiceGoTSRPCProxy) ServeHTTP(w http.ResponseWriter, r *http.Request) return } var executionStart time.Time - if callStats != nil { + if callStatsOk { executionStart = time.Now() } float32Ret := p.service.Float32(arg_v) - if callStats != nil { + if callStatsOk { callStats.Execution = time.Since(executionStart) } rets = []any{float32Ret} @@ -279,11 +279,11 @@ func (p *ServiceGoTSRPCProxy) ServeHTTP(w http.ResponseWriter, r *http.Request) return } var executionStart time.Time - if callStats != nil { + if callStatsOk { executionStart = time.Now() } float32MapRet := p.service.Float32Map(arg_v) - if callStats != nil { + if callStatsOk { callStats.Execution = time.Since(executionStart) } rets = []any{float32MapRet} @@ -307,11 +307,11 @@ func (p *ServiceGoTSRPCProxy) ServeHTTP(w http.ResponseWriter, r *http.Request) return } var executionStart time.Time - if callStats != nil { + if callStatsOk { executionStart = time.Now() } float32SliceRet := p.service.Float32Slice(arg_v) - if callStats != nil { + if callStatsOk { callStats.Execution = time.Since(executionStart) } rets = []any{float32SliceRet} @@ -335,11 +335,11 @@ func (p *ServiceGoTSRPCProxy) ServeHTTP(w http.ResponseWriter, r *http.Request) return } var executionStart time.Time - if callStats != nil { + if callStatsOk { executionStart = time.Now() } float32TypeRet := p.service.Float32Type(arg_v) - if callStats != nil { + if callStatsOk { callStats.Execution = time.Since(executionStart) } rets = []any{float32TypeRet} @@ -363,11 +363,11 @@ func (p *ServiceGoTSRPCProxy) ServeHTTP(w http.ResponseWriter, r *http.Request) return } var executionStart time.Time - if callStats != nil { + if callStatsOk { executionStart = time.Now() } float32TypeMapRet := p.service.Float32TypeMap(arg_v) - if callStats != nil { + if callStatsOk { callStats.Execution = time.Since(executionStart) } rets = []any{float32TypeMapRet} @@ -391,11 +391,11 @@ func (p *ServiceGoTSRPCProxy) ServeHTTP(w http.ResponseWriter, r *http.Request) return } var executionStart time.Time - if callStats != nil { + if callStatsOk { executionStart = time.Now() } float32TypeMapTypedRet := p.service.Float32TypeMapTyped(arg_v) - if callStats != nil { + if callStatsOk { callStats.Execution = time.Since(executionStart) } rets = []any{float32TypeMapTypedRet} @@ -419,11 +419,11 @@ func (p *ServiceGoTSRPCProxy) ServeHTTP(w http.ResponseWriter, r *http.Request) return } var executionStart time.Time - if callStats != nil { + if callStatsOk { executionStart = time.Now() } float64Ret := p.service.Float64(arg_v) - if callStats != nil { + if callStatsOk { callStats.Execution = time.Since(executionStart) } rets = []any{float64Ret} @@ -447,11 +447,11 @@ func (p *ServiceGoTSRPCProxy) ServeHTTP(w http.ResponseWriter, r *http.Request) return } var executionStart time.Time - if callStats != nil { + if callStatsOk { executionStart = time.Now() } float64MapRet := p.service.Float64Map(arg_v) - if callStats != nil { + if callStatsOk { callStats.Execution = time.Since(executionStart) } rets = []any{float64MapRet} @@ -475,11 +475,11 @@ func (p *ServiceGoTSRPCProxy) ServeHTTP(w http.ResponseWriter, r *http.Request) return } var executionStart time.Time - if callStats != nil { + if callStatsOk { executionStart = time.Now() } float64SliceRet := p.service.Float64Slice(arg_v) - if callStats != nil { + if callStatsOk { callStats.Execution = time.Since(executionStart) } rets = []any{float64SliceRet} @@ -503,11 +503,11 @@ func (p *ServiceGoTSRPCProxy) ServeHTTP(w http.ResponseWriter, r *http.Request) return } var executionStart time.Time - if callStats != nil { + if callStatsOk { executionStart = time.Now() } float64TypeRet := p.service.Float64Type(arg_v) - if callStats != nil { + if callStatsOk { callStats.Execution = time.Since(executionStart) } rets = []any{float64TypeRet} @@ -531,11 +531,11 @@ func (p *ServiceGoTSRPCProxy) ServeHTTP(w http.ResponseWriter, r *http.Request) return } var executionStart time.Time - if callStats != nil { + if callStatsOk { executionStart = time.Now() } float64TypeMapRet := p.service.Float64TypeMap(arg_v) - if callStats != nil { + if callStatsOk { callStats.Execution = time.Since(executionStart) } rets = []any{float64TypeMapRet} @@ -559,11 +559,11 @@ func (p *ServiceGoTSRPCProxy) ServeHTTP(w http.ResponseWriter, r *http.Request) return } var executionStart time.Time - if callStats != nil { + if callStatsOk { executionStart = time.Now() } float64TypeMapTypedRet := p.service.Float64TypeMapTyped(arg_v) - if callStats != nil { + if callStatsOk { callStats.Execution = time.Since(executionStart) } rets = []any{float64TypeMapTypedRet} @@ -587,11 +587,11 @@ func (p *ServiceGoTSRPCProxy) ServeHTTP(w http.ResponseWriter, r *http.Request) return } var executionStart time.Time - if callStats != nil { + if callStatsOk { executionStart = time.Now() } intRet := p.service.Int(arg_v) - if callStats != nil { + if callStatsOk { callStats.Execution = time.Since(executionStart) } rets = []any{intRet} @@ -615,11 +615,11 @@ func (p *ServiceGoTSRPCProxy) ServeHTTP(w http.ResponseWriter, r *http.Request) return } var executionStart time.Time - if callStats != nil { + if callStatsOk { executionStart = time.Now() } int32Ret := p.service.Int32(arg_v) - if callStats != nil { + if callStatsOk { callStats.Execution = time.Since(executionStart) } rets = []any{int32Ret} @@ -643,11 +643,11 @@ func (p *ServiceGoTSRPCProxy) ServeHTTP(w http.ResponseWriter, r *http.Request) return } var executionStart time.Time - if callStats != nil { + if callStatsOk { executionStart = time.Now() } int32MapRet := p.service.Int32Map(arg_v) - if callStats != nil { + if callStatsOk { callStats.Execution = time.Since(executionStart) } rets = []any{int32MapRet} @@ -671,11 +671,11 @@ func (p *ServiceGoTSRPCProxy) ServeHTTP(w http.ResponseWriter, r *http.Request) return } var executionStart time.Time - if callStats != nil { + if callStatsOk { executionStart = time.Now() } int32SliceRet := p.service.Int32Slice(arg_v) - if callStats != nil { + if callStatsOk { callStats.Execution = time.Since(executionStart) } rets = []any{int32SliceRet} @@ -699,11 +699,11 @@ func (p *ServiceGoTSRPCProxy) ServeHTTP(w http.ResponseWriter, r *http.Request) return } var executionStart time.Time - if callStats != nil { + if callStatsOk { executionStart = time.Now() } int32TypeRet := p.service.Int32Type(arg_v) - if callStats != nil { + if callStatsOk { callStats.Execution = time.Since(executionStart) } rets = []any{int32TypeRet} @@ -727,11 +727,11 @@ func (p *ServiceGoTSRPCProxy) ServeHTTP(w http.ResponseWriter, r *http.Request) return } var executionStart time.Time - if callStats != nil { + if callStatsOk { executionStart = time.Now() } int32TypeMapRet := p.service.Int32TypeMap(arg_v) - if callStats != nil { + if callStatsOk { callStats.Execution = time.Since(executionStart) } rets = []any{int32TypeMapRet} @@ -755,11 +755,11 @@ func (p *ServiceGoTSRPCProxy) ServeHTTP(w http.ResponseWriter, r *http.Request) return } var executionStart time.Time - if callStats != nil { + if callStatsOk { executionStart = time.Now() } int32TypeMapTypedRet := p.service.Int32TypeMapTyped(arg_v) - if callStats != nil { + if callStatsOk { callStats.Execution = time.Since(executionStart) } rets = []any{int32TypeMapTypedRet} @@ -783,11 +783,11 @@ func (p *ServiceGoTSRPCProxy) ServeHTTP(w http.ResponseWriter, r *http.Request) return } var executionStart time.Time - if callStats != nil { + if callStatsOk { executionStart = time.Now() } int64Ret := p.service.Int64(arg_v) - if callStats != nil { + if callStatsOk { callStats.Execution = time.Since(executionStart) } rets = []any{int64Ret} @@ -811,11 +811,11 @@ func (p *ServiceGoTSRPCProxy) ServeHTTP(w http.ResponseWriter, r *http.Request) return } var executionStart time.Time - if callStats != nil { + if callStatsOk { executionStart = time.Now() } int64MapRet := p.service.Int64Map(arg_v) - if callStats != nil { + if callStatsOk { callStats.Execution = time.Since(executionStart) } rets = []any{int64MapRet} @@ -839,11 +839,11 @@ func (p *ServiceGoTSRPCProxy) ServeHTTP(w http.ResponseWriter, r *http.Request) return } var executionStart time.Time - if callStats != nil { + if callStatsOk { executionStart = time.Now() } int64SliceRet := p.service.Int64Slice(arg_v) - if callStats != nil { + if callStatsOk { callStats.Execution = time.Since(executionStart) } rets = []any{int64SliceRet} @@ -867,11 +867,11 @@ func (p *ServiceGoTSRPCProxy) ServeHTTP(w http.ResponseWriter, r *http.Request) return } var executionStart time.Time - if callStats != nil { + if callStatsOk { executionStart = time.Now() } int64TypeRet := p.service.Int64Type(arg_v) - if callStats != nil { + if callStatsOk { callStats.Execution = time.Since(executionStart) } rets = []any{int64TypeRet} @@ -895,11 +895,11 @@ func (p *ServiceGoTSRPCProxy) ServeHTTP(w http.ResponseWriter, r *http.Request) return } var executionStart time.Time - if callStats != nil { + if callStatsOk { executionStart = time.Now() } int64TypeMapRet := p.service.Int64TypeMap(arg_v) - if callStats != nil { + if callStatsOk { callStats.Execution = time.Since(executionStart) } rets = []any{int64TypeMapRet} @@ -923,11 +923,11 @@ func (p *ServiceGoTSRPCProxy) ServeHTTP(w http.ResponseWriter, r *http.Request) return } var executionStart time.Time - if callStats != nil { + if callStatsOk { executionStart = time.Now() } int64TypeMapTypedRet := p.service.Int64TypeMapTyped(arg_v) - if callStats != nil { + if callStatsOk { callStats.Execution = time.Since(executionStart) } rets = []any{int64TypeMapTypedRet} @@ -951,11 +951,11 @@ func (p *ServiceGoTSRPCProxy) ServeHTTP(w http.ResponseWriter, r *http.Request) return } var executionStart time.Time - if callStats != nil { + if callStatsOk { executionStart = time.Now() } intMapRet := p.service.IntMap(arg_v) - if callStats != nil { + if callStatsOk { callStats.Execution = time.Since(executionStart) } rets = []any{intMapRet} @@ -979,11 +979,11 @@ func (p *ServiceGoTSRPCProxy) ServeHTTP(w http.ResponseWriter, r *http.Request) return } var executionStart time.Time - if callStats != nil { + if callStatsOk { executionStart = time.Now() } intSliceRet := p.service.IntSlice(arg_v) - if callStats != nil { + if callStatsOk { callStats.Execution = time.Since(executionStart) } rets = []any{intSliceRet} @@ -1007,11 +1007,11 @@ func (p *ServiceGoTSRPCProxy) ServeHTTP(w http.ResponseWriter, r *http.Request) return } var executionStart time.Time - if callStats != nil { + if callStatsOk { executionStart = time.Now() } intTypeRet := p.service.IntType(arg_v) - if callStats != nil { + if callStatsOk { callStats.Execution = time.Since(executionStart) } rets = []any{intTypeRet} @@ -1035,11 +1035,11 @@ func (p *ServiceGoTSRPCProxy) ServeHTTP(w http.ResponseWriter, r *http.Request) return } var executionStart time.Time - if callStats != nil { + if callStatsOk { executionStart = time.Now() } intTypeMapRet := p.service.IntTypeMap(arg_v) - if callStats != nil { + if callStatsOk { callStats.Execution = time.Since(executionStart) } rets = []any{intTypeMapRet} @@ -1063,11 +1063,11 @@ func (p *ServiceGoTSRPCProxy) ServeHTTP(w http.ResponseWriter, r *http.Request) return } var executionStart time.Time - if callStats != nil { + if callStatsOk { executionStart = time.Now() } intTypeMapTypedRet := p.service.IntTypeMapTyped(arg_v) - if callStats != nil { + if callStatsOk { callStats.Execution = time.Since(executionStart) } rets = []any{intTypeMapTypedRet} @@ -1091,11 +1091,11 @@ func (p *ServiceGoTSRPCProxy) ServeHTTP(w http.ResponseWriter, r *http.Request) return } var executionStart time.Time - if callStats != nil { + if callStatsOk { executionStart = time.Now() } interfaceRet := p.service.Interface(arg_v) - if callStats != nil { + if callStatsOk { callStats.Execution = time.Since(executionStart) } rets = []any{interfaceRet} @@ -1119,11 +1119,11 @@ func (p *ServiceGoTSRPCProxy) ServeHTTP(w http.ResponseWriter, r *http.Request) return } var executionStart time.Time - if callStats != nil { + if callStatsOk { executionStart = time.Now() } interfaceSliceRet := p.service.InterfaceSlice(arg_v) - if callStats != nil { + if callStatsOk { callStats.Execution = time.Since(executionStart) } rets = []any{interfaceSliceRet} @@ -1147,11 +1147,11 @@ func (p *ServiceGoTSRPCProxy) ServeHTTP(w http.ResponseWriter, r *http.Request) return } var executionStart time.Time - if callStats != nil { + if callStatsOk { executionStart = time.Now() } nestedTypeRet := p.service.NestedType(arg_v) - if callStats != nil { + if callStatsOk { callStats.Execution = time.Since(executionStart) } rets = []any{nestedTypeRet} @@ -1175,11 +1175,11 @@ func (p *ServiceGoTSRPCProxy) ServeHTTP(w http.ResponseWriter, r *http.Request) return } var executionStart time.Time - if callStats != nil { + if callStatsOk { executionStart = time.Now() } stringRet := p.service.String(arg_v) - if callStats != nil { + if callStatsOk { callStats.Execution = time.Since(executionStart) } rets = []any{stringRet} @@ -1203,11 +1203,11 @@ func (p *ServiceGoTSRPCProxy) ServeHTTP(w http.ResponseWriter, r *http.Request) return } var executionStart time.Time - if callStats != nil { + if callStatsOk { executionStart = time.Now() } stringMapRet := p.service.StringMap(arg_v) - if callStats != nil { + if callStatsOk { callStats.Execution = time.Since(executionStart) } rets = []any{stringMapRet} @@ -1231,11 +1231,11 @@ func (p *ServiceGoTSRPCProxy) ServeHTTP(w http.ResponseWriter, r *http.Request) return } var executionStart time.Time - if callStats != nil { + if callStatsOk { executionStart = time.Now() } stringSliceRet := p.service.StringSlice(arg_v) - if callStats != nil { + if callStatsOk { callStats.Execution = time.Since(executionStart) } rets = []any{stringSliceRet} @@ -1259,11 +1259,11 @@ func (p *ServiceGoTSRPCProxy) ServeHTTP(w http.ResponseWriter, r *http.Request) return } var executionStart time.Time - if callStats != nil { + if callStatsOk { executionStart = time.Now() } stringTypeRet := p.service.StringType(arg_v) - if callStats != nil { + if callStatsOk { callStats.Execution = time.Since(executionStart) } rets = []any{stringTypeRet} @@ -1287,11 +1287,11 @@ func (p *ServiceGoTSRPCProxy) ServeHTTP(w http.ResponseWriter, r *http.Request) return } var executionStart time.Time - if callStats != nil { + if callStatsOk { executionStart = time.Now() } stringTypeMapRet := p.service.StringTypeMap(arg_v) - if callStats != nil { + if callStatsOk { callStats.Execution = time.Since(executionStart) } rets = []any{stringTypeMapRet} @@ -1315,11 +1315,11 @@ func (p *ServiceGoTSRPCProxy) ServeHTTP(w http.ResponseWriter, r *http.Request) return } var executionStart time.Time - if callStats != nil { + if callStatsOk { executionStart = time.Now() } stringTypeMapTypedRet := p.service.StringTypeMapTyped(arg_v) - if callStats != nil { + if callStatsOk { callStats.Execution = time.Since(executionStart) } rets = []any{stringTypeMapTypedRet} @@ -1343,11 +1343,11 @@ func (p *ServiceGoTSRPCProxy) ServeHTTP(w http.ResponseWriter, r *http.Request) return } var executionStart time.Time - if callStats != nil { + if callStatsOk { executionStart = time.Now() } structRet := p.service.Struct(arg_v) - if callStats != nil { + if callStatsOk { callStats.Execution = time.Since(executionStart) } rets = []any{structRet} @@ -1371,11 +1371,11 @@ func (p *ServiceGoTSRPCProxy) ServeHTTP(w http.ResponseWriter, r *http.Request) return } var executionStart time.Time - if callStats != nil { + if callStatsOk { executionStart = time.Now() } uIntRet := p.service.UInt(arg_v) - if callStats != nil { + if callStatsOk { callStats.Execution = time.Since(executionStart) } rets = []any{uIntRet} @@ -1399,11 +1399,11 @@ func (p *ServiceGoTSRPCProxy) ServeHTTP(w http.ResponseWriter, r *http.Request) return } var executionStart time.Time - if callStats != nil { + if callStatsOk { executionStart = time.Now() } uInt32Ret := p.service.UInt32(arg_v) - if callStats != nil { + if callStatsOk { callStats.Execution = time.Since(executionStart) } rets = []any{uInt32Ret} @@ -1427,11 +1427,11 @@ func (p *ServiceGoTSRPCProxy) ServeHTTP(w http.ResponseWriter, r *http.Request) return } var executionStart time.Time - if callStats != nil { + if callStatsOk { executionStart = time.Now() } uInt32MapRet := p.service.UInt32Map(arg_v) - if callStats != nil { + if callStatsOk { callStats.Execution = time.Since(executionStart) } rets = []any{uInt32MapRet} @@ -1455,11 +1455,11 @@ func (p *ServiceGoTSRPCProxy) ServeHTTP(w http.ResponseWriter, r *http.Request) return } var executionStart time.Time - if callStats != nil { + if callStatsOk { executionStart = time.Now() } uInt32SliceRet := p.service.UInt32Slice(arg_v) - if callStats != nil { + if callStatsOk { callStats.Execution = time.Since(executionStart) } rets = []any{uInt32SliceRet} @@ -1483,11 +1483,11 @@ func (p *ServiceGoTSRPCProxy) ServeHTTP(w http.ResponseWriter, r *http.Request) return } var executionStart time.Time - if callStats != nil { + if callStatsOk { executionStart = time.Now() } uInt32TypeRet := p.service.UInt32Type(arg_v) - if callStats != nil { + if callStatsOk { callStats.Execution = time.Since(executionStart) } rets = []any{uInt32TypeRet} @@ -1511,11 +1511,11 @@ func (p *ServiceGoTSRPCProxy) ServeHTTP(w http.ResponseWriter, r *http.Request) return } var executionStart time.Time - if callStats != nil { + if callStatsOk { executionStart = time.Now() } uInt32TypeMapRet := p.service.UInt32TypeMap(arg_v) - if callStats != nil { + if callStatsOk { callStats.Execution = time.Since(executionStart) } rets = []any{uInt32TypeMapRet} @@ -1539,11 +1539,11 @@ func (p *ServiceGoTSRPCProxy) ServeHTTP(w http.ResponseWriter, r *http.Request) return } var executionStart time.Time - if callStats != nil { + if callStatsOk { executionStart = time.Now() } uInt32TypeMapTypedRet := p.service.UInt32TypeMapTyped(arg_v) - if callStats != nil { + if callStatsOk { callStats.Execution = time.Since(executionStart) } rets = []any{uInt32TypeMapTypedRet} @@ -1567,11 +1567,11 @@ func (p *ServiceGoTSRPCProxy) ServeHTTP(w http.ResponseWriter, r *http.Request) return } var executionStart time.Time - if callStats != nil { + if callStatsOk { executionStart = time.Now() } uInt64Ret := p.service.UInt64(arg_v) - if callStats != nil { + if callStatsOk { callStats.Execution = time.Since(executionStart) } rets = []any{uInt64Ret} @@ -1595,11 +1595,11 @@ func (p *ServiceGoTSRPCProxy) ServeHTTP(w http.ResponseWriter, r *http.Request) return } var executionStart time.Time - if callStats != nil { + if callStatsOk { executionStart = time.Now() } uInt64MapRet := p.service.UInt64Map(arg_v) - if callStats != nil { + if callStatsOk { callStats.Execution = time.Since(executionStart) } rets = []any{uInt64MapRet} @@ -1623,11 +1623,11 @@ func (p *ServiceGoTSRPCProxy) ServeHTTP(w http.ResponseWriter, r *http.Request) return } var executionStart time.Time - if callStats != nil { + if callStatsOk { executionStart = time.Now() } uInt64SliceRet := p.service.UInt64Slice(arg_v) - if callStats != nil { + if callStatsOk { callStats.Execution = time.Since(executionStart) } rets = []any{uInt64SliceRet} @@ -1651,11 +1651,11 @@ func (p *ServiceGoTSRPCProxy) ServeHTTP(w http.ResponseWriter, r *http.Request) return } var executionStart time.Time - if callStats != nil { + if callStatsOk { executionStart = time.Now() } uInt64TypeRet := p.service.UInt64Type(arg_v) - if callStats != nil { + if callStatsOk { callStats.Execution = time.Since(executionStart) } rets = []any{uInt64TypeRet} @@ -1679,11 +1679,11 @@ func (p *ServiceGoTSRPCProxy) ServeHTTP(w http.ResponseWriter, r *http.Request) return } var executionStart time.Time - if callStats != nil { + if callStatsOk { executionStart = time.Now() } uInt64TypeMapRet := p.service.UInt64TypeMap(arg_v) - if callStats != nil { + if callStatsOk { callStats.Execution = time.Since(executionStart) } rets = []any{uInt64TypeMapRet} @@ -1707,11 +1707,11 @@ func (p *ServiceGoTSRPCProxy) ServeHTTP(w http.ResponseWriter, r *http.Request) return } var executionStart time.Time - if callStats != nil { + if callStatsOk { executionStart = time.Now() } uInt64TypeMapTypedRet := p.service.UInt64TypeMapTyped(arg_v) - if callStats != nil { + if callStatsOk { callStats.Execution = time.Since(executionStart) } rets = []any{uInt64TypeMapTypedRet} @@ -1735,11 +1735,11 @@ func (p *ServiceGoTSRPCProxy) ServeHTTP(w http.ResponseWriter, r *http.Request) return } var executionStart time.Time - if callStats != nil { + if callStatsOk { executionStart = time.Now() } uIntMapRet := p.service.UIntMap(arg_v) - if callStats != nil { + if callStatsOk { callStats.Execution = time.Since(executionStart) } rets = []any{uIntMapRet} @@ -1763,11 +1763,11 @@ func (p *ServiceGoTSRPCProxy) ServeHTTP(w http.ResponseWriter, r *http.Request) return } var executionStart time.Time - if callStats != nil { + if callStatsOk { executionStart = time.Now() } uIntSliceRet := p.service.UIntSlice(arg_v) - if callStats != nil { + if callStatsOk { callStats.Execution = time.Since(executionStart) } rets = []any{uIntSliceRet} @@ -1791,11 +1791,11 @@ func (p *ServiceGoTSRPCProxy) ServeHTTP(w http.ResponseWriter, r *http.Request) return } var executionStart time.Time - if callStats != nil { + if callStatsOk { executionStart = time.Now() } uIntTypeRet := p.service.UIntType(arg_v) - if callStats != nil { + if callStatsOk { callStats.Execution = time.Since(executionStart) } rets = []any{uIntTypeRet} @@ -1819,11 +1819,11 @@ func (p *ServiceGoTSRPCProxy) ServeHTTP(w http.ResponseWriter, r *http.Request) return } var executionStart time.Time - if callStats != nil { + if callStatsOk { executionStart = time.Now() } uIntTypeMapRet := p.service.UIntTypeMap(arg_v) - if callStats != nil { + if callStatsOk { callStats.Execution = time.Since(executionStart) } rets = []any{uIntTypeMapRet} @@ -1847,11 +1847,11 @@ func (p *ServiceGoTSRPCProxy) ServeHTTP(w http.ResponseWriter, r *http.Request) return } var executionStart time.Time - if callStats != nil { + if callStatsOk { executionStart = time.Now() } uIntTypeMapTypedRet := p.service.UIntTypeMapTyped(arg_v) - if callStats != nil { + if callStatsOk { callStats.Execution = time.Since(executionStart) } rets = []any{uIntTypeMapTypedRet} diff --git a/example/monitor/service/gotsrpc_gen.go b/example/monitor/service/gotsrpc_gen.go index 19313db..ff3f345 100644 --- a/example/monitor/service/gotsrpc_gen.go +++ b/example/monitor/service/gotsrpc_gen.go @@ -41,8 +41,8 @@ func (p *ServiceGoTSRPCProxy) ServeHTTP(w http.ResponseWriter, r *http.Request) defer io.Copy(io.Discard, r.Body) // Drain Request Body funcName := gotsrpc.GetCalledFunc(r, p.EndPoint) - callStats, _ := gotsrpc.GetStatsForRequest(r) - if callStats != nil { + callStats, callStatsOk := gotsrpc.GetStatsForRequest(r) + if callStatsOk { callStats.Func = funcName callStats.Package = "github.com/foomo/gotsrpc/v2/example/monitor/service" callStats.Service = "Service" @@ -62,11 +62,11 @@ func (p *ServiceGoTSRPCProxy) ServeHTTP(w http.ResponseWriter, r *http.Request) return } var executionStart time.Time - if callStats != nil { + if callStatsOk { executionStart = time.Now() } helloRet := p.service.Hello(arg_v) - if callStats != nil { + if callStatsOk { callStats.Execution = time.Since(executionStart) } rets = []any{helloRet} diff --git a/internal/codegen/gocode.go b/internal/codegen/gocode.go index 320b9a0..915179e 100644 --- a/internal/codegen/gocode.go +++ b/internal/codegen/gocode.go @@ -195,8 +195,8 @@ func renderTSRPCServiceProxies(services model.ServiceList, fullPackageName strin `) g.L("funcName := gotsrpc.GetCalledFunc(r, p.EndPoint)") - g.L("callStats, _ := gotsrpc.GetStatsForRequest(r)") - g.L("if callStats != nil {") + g.L("callStats, callStatsOk := gotsrpc.GetStatsForRequest(r)") + g.L("if callStatsOk {") g.Ind(1) g.L("callStats.Func = funcName") g.L("callStats.Package = \"" + fullPackageName + "\"") @@ -279,7 +279,7 @@ func renderTSRPCServiceProxies(services model.ServiceList, fullPackageName strin } g.L("var executionStart time.Time") - g.L("if callStats != nil {") + g.L("if callStatsOk {") g.Ind(1) g.L("executionStart = time.Now()") g.Ind(-1) @@ -299,7 +299,7 @@ func renderTSRPCServiceProxies(services model.ServiceList, fullPackageName strin g.App("p.service." + method.Name + "(" + strings.Join(callArgs, ", ") + ")") g.NL() - g.L("if callStats != nil {") + g.L("if callStatsOk {") g.Ind(1) g.L("callStats.Execution = time.Since(executionStart)") g.Ind(-1) diff --git a/tests/aliases/server/gotsrpc_gen.go b/tests/aliases/server/gotsrpc_gen.go index 4005f65..69a3d4e 100644 --- a/tests/aliases/server/gotsrpc_gen.go +++ b/tests/aliases/server/gotsrpc_gen.go @@ -54,8 +54,8 @@ func (p *ServiceGoTSRPCProxy) ServeHTTP(w http.ResponseWriter, r *http.Request) defer io.Copy(io.Discard, r.Body) // Drain Request Body funcName := gotsrpc.GetCalledFunc(r, p.EndPoint) - callStats, _ := gotsrpc.GetStatsForRequest(r) - if callStats != nil { + callStats, callStatsOk := gotsrpc.GetStatsForRequest(r) + if callStatsOk { callStats.Func = funcName callStats.Package = "github.com/foomo/gotsrpc/v2/tests/aliases/server" callStats.Service = "Service" @@ -75,11 +75,11 @@ func (p *ServiceGoTSRPCProxy) ServeHTTP(w http.ResponseWriter, r *http.Request) return } var executionStart time.Time - if callStats != nil { + if callStatsOk { executionStart = time.Now() } categoryValueRet := p.service.CategoryValue(r.Context(), arg_v) - if callStats != nil { + if callStatsOk { callStats.Execution = time.Since(executionStart) } rets = []any{categoryValueRet} @@ -103,11 +103,11 @@ func (p *ServiceGoTSRPCProxy) ServeHTTP(w http.ResponseWriter, r *http.Request) return } var executionStart time.Time - if callStats != nil { + if callStatsOk { executionStart = time.Now() } dataRecordNilRet := p.service.DataRecordNil(r.Context(), arg_v) - if callStats != nil { + if callStatsOk { callStats.Execution = time.Since(executionStart) } rets = []any{dataRecordNilRet} @@ -131,11 +131,11 @@ func (p *ServiceGoTSRPCProxy) ServeHTTP(w http.ResponseWriter, r *http.Request) return } var executionStart time.Time - if callStats != nil { + if callStatsOk { executionStart = time.Now() } dataRecordValueRet := p.service.DataRecordValue(r.Context(), arg_v) - if callStats != nil { + if callStatsOk { callStats.Execution = time.Since(executionStart) } rets = []any{dataRecordValueRet} @@ -159,11 +159,11 @@ func (p *ServiceGoTSRPCProxy) ServeHTTP(w http.ResponseWriter, r *http.Request) return } var executionStart time.Time - if callStats != nil { + if callStatsOk { executionStart = time.Now() } detailValueRet := p.service.DetailValue(r.Context(), arg_v) - if callStats != nil { + if callStatsOk { callStats.Execution = time.Since(executionStart) } rets = []any{detailValueRet} @@ -187,11 +187,11 @@ func (p *ServiceGoTSRPCProxy) ServeHTTP(w http.ResponseWriter, r *http.Request) return } var executionStart time.Time - if callStats != nil { + if callStatsOk { executionStart = time.Now() } entriesValueRet := p.service.EntriesValue(r.Context(), arg_v) - if callStats != nil { + if callStatsOk { callStats.Execution = time.Since(executionStart) } rets = []any{entriesValueRet} @@ -215,11 +215,11 @@ func (p *ServiceGoTSRPCProxy) ServeHTTP(w http.ResponseWriter, r *http.Request) return } var executionStart time.Time - if callStats != nil { + if callStatsOk { executionStart = time.Now() } entryValueRet := p.service.EntryValue(r.Context(), arg_v) - if callStats != nil { + if callStatsOk { callStats.Execution = time.Since(executionStart) } rets = []any{entryValueRet} @@ -243,11 +243,11 @@ func (p *ServiceGoTSRPCProxy) ServeHTTP(w http.ResponseWriter, r *http.Request) return } var executionStart time.Time - if callStats != nil { + if callStatsOk { executionStart = time.Now() } indexValueRet := p.service.IndexValue(r.Context(), arg_v) - if callStats != nil { + if callStatsOk { callStats.Execution = time.Since(executionStart) } rets = []any{indexValueRet} @@ -271,11 +271,11 @@ func (p *ServiceGoTSRPCProxy) ServeHTTP(w http.ResponseWriter, r *http.Request) return } var executionStart time.Time - if callStats != nil { + if callStatsOk { executionStart = time.Now() } labelMapValueRet := p.service.LabelMapValue(r.Context(), arg_v) - if callStats != nil { + if callStatsOk { callStats.Execution = time.Since(executionStart) } rets = []any{labelMapValueRet} @@ -299,11 +299,11 @@ func (p *ServiceGoTSRPCProxy) ServeHTTP(w http.ResponseWriter, r *http.Request) return } var executionStart time.Time - if callStats != nil { + if callStatsOk { executionStart = time.Now() } mapOfEntriesRet := p.service.MapOfEntries(r.Context(), arg_v) - if callStats != nil { + if callStatsOk { callStats.Execution = time.Since(executionStart) } rets = []any{mapOfEntriesRet} @@ -327,11 +327,11 @@ func (p *ServiceGoTSRPCProxy) ServeHTTP(w http.ResponseWriter, r *http.Request) return } var executionStart time.Time - if callStats != nil { + if callStatsOk { executionStart = time.Now() } priorityValueRet := p.service.PriorityValue(r.Context(), arg_v) - if callStats != nil { + if callStatsOk { callStats.Execution = time.Since(executionStart) } rets = []any{priorityValueRet} @@ -355,11 +355,11 @@ func (p *ServiceGoTSRPCProxy) ServeHTTP(w http.ResponseWriter, r *http.Request) return } var executionStart time.Time - if callStats != nil { + if callStatsOk { executionStart = time.Now() } ratingValueRet := p.service.RatingValue(r.Context(), arg_v) - if callStats != nil { + if callStatsOk { callStats.Execution = time.Since(executionStart) } rets = []any{ratingValueRet} @@ -383,11 +383,11 @@ func (p *ServiceGoTSRPCProxy) ServeHTTP(w http.ResponseWriter, r *http.Request) return } var executionStart time.Time - if callStats != nil { + if callStatsOk { executionStart = time.Now() } registryValueRet := p.service.RegistryValue(r.Context(), arg_v) - if callStats != nil { + if callStatsOk { callStats.Execution = time.Since(executionStart) } rets = []any{registryValueRet} @@ -411,11 +411,11 @@ func (p *ServiceGoTSRPCProxy) ServeHTTP(w http.ResponseWriter, r *http.Request) return } var executionStart time.Time - if callStats != nil { + if callStatsOk { executionStart = time.Now() } statusValueRet := p.service.StatusValue(r.Context(), arg_v) - if callStats != nil { + if callStatsOk { callStats.Execution = time.Since(executionStart) } rets = []any{statusValueRet} @@ -439,11 +439,11 @@ func (p *ServiceGoTSRPCProxy) ServeHTTP(w http.ResponseWriter, r *http.Request) return } var executionStart time.Time - if callStats != nil { + if callStatsOk { executionStart = time.Now() } tagsValueRet := p.service.TagsValue(r.Context(), arg_v) - if callStats != nil { + if callStatsOk { callStats.Execution = time.Since(executionStart) } rets = []any{tagsValueRet} diff --git a/tests/context/server/gotsrpc_gen.go b/tests/context/server/gotsrpc_gen.go index 8c80eed..e0852ad 100644 --- a/tests/context/server/gotsrpc_gen.go +++ b/tests/context/server/gotsrpc_gen.go @@ -46,8 +46,8 @@ func (p *ServiceGoTSRPCProxy) ServeHTTP(w http.ResponseWriter, r *http.Request) defer io.Copy(io.Discard, r.Body) // Drain Request Body funcName := gotsrpc.GetCalledFunc(r, p.EndPoint) - callStats, _ := gotsrpc.GetStatsForRequest(r) - if callStats != nil { + callStats, callStatsOk := gotsrpc.GetStatsForRequest(r) + if callStatsOk { callStats.Func = funcName callStats.Package = "github.com/foomo/gotsrpc/v2/tests/context/server" callStats.Service = "Service" @@ -67,11 +67,11 @@ func (p *ServiceGoTSRPCProxy) ServeHTTP(w http.ResponseWriter, r *http.Request) return } var executionStart time.Time - if callStats != nil { + if callStatsOk { executionStart = time.Now() } customErrorRet := p.service.CustomError(r.Context(), arg_msg) - if callStats != nil { + if callStatsOk { callStats.Execution = time.Since(executionStart) } rets = []any{gotsrpc.ErrorReply(customErrorRet)} @@ -95,11 +95,11 @@ func (p *ServiceGoTSRPCProxy) ServeHTTP(w http.ResponseWriter, r *http.Request) return } var executionStart time.Time - if callStats != nil { + if callStatsOk { executionStart = time.Now() } errorRet := p.service.Error(r.Context(), arg_msg) - if callStats != nil { + if callStatsOk { callStats.Execution = time.Since(executionStart) } rets = []any{gotsrpc.ErrorReply(errorRet)} @@ -123,11 +123,11 @@ func (p *ServiceGoTSRPCProxy) ServeHTTP(w http.ResponseWriter, r *http.Request) return } var executionStart time.Time - if callStats != nil { + if callStatsOk { executionStart = time.Now() } helloRet := p.service.Hello(r.Context(), arg_msg) - if callStats != nil { + if callStatsOk { callStats.Execution = time.Since(executionStart) } rets = []any{helloRet} @@ -151,11 +151,11 @@ func (p *ServiceGoTSRPCProxy) ServeHTTP(w http.ResponseWriter, r *http.Request) return } var executionStart time.Time - if callStats != nil { + if callStatsOk { executionStart = time.Now() } joinedErrorRet := p.service.JoinedError(r.Context(), arg_msg) - if callStats != nil { + if callStatsOk { callStats.Execution = time.Since(executionStart) } rets = []any{gotsrpc.ErrorReply(joinedErrorRet)} @@ -179,11 +179,11 @@ func (p *ServiceGoTSRPCProxy) ServeHTTP(w http.ResponseWriter, r *http.Request) return } var executionStart time.Time - if callStats != nil { + if callStatsOk { executionStart = time.Now() } pkgErrorRet := p.service.PkgError(r.Context(), arg_msg) - if callStats != nil { + if callStatsOk { callStats.Execution = time.Since(executionStart) } rets = []any{gotsrpc.ErrorReply(pkgErrorRet)} @@ -207,11 +207,11 @@ func (p *ServiceGoTSRPCProxy) ServeHTTP(w http.ResponseWriter, r *http.Request) return } var executionStart time.Time - if callStats != nil { + if callStatsOk { executionStart = time.Now() } wrappedErrorRet := p.service.WrappedError(r.Context(), arg_msg) - if callStats != nil { + if callStatsOk { callStats.Execution = time.Since(executionStart) } rets = []any{gotsrpc.ErrorReply(wrappedErrorRet)} diff --git a/tests/errors/server/gotsrpc_gen.go b/tests/errors/server/gotsrpc_gen.go index 5508c13..b38d4d2 100644 --- a/tests/errors/server/gotsrpc_gen.go +++ b/tests/errors/server/gotsrpc_gen.go @@ -53,8 +53,8 @@ func (p *ServiceGoTSRPCProxy) ServeHTTP(w http.ResponseWriter, r *http.Request) defer io.Copy(io.Discard, r.Body) // Drain Request Body funcName := gotsrpc.GetCalledFunc(r, p.EndPoint) - callStats, _ := gotsrpc.GetStatsForRequest(r) - if callStats != nil { + callStats, callStatsOk := gotsrpc.GetStatsForRequest(r) + if callStatsOk { callStats.Func = funcName callStats.Package = "github.com/foomo/gotsrpc/v2/tests/errors/server" callStats.Service = "Service" @@ -66,12 +66,12 @@ func (p *ServiceGoTSRPCProxy) ServeHTTP(w http.ResponseWriter, r *http.Request) rets []any ) var executionStart time.Time - if callStats != nil { + if callStatsOk { executionStart = time.Now() } rw := gotsrpc.ResponseWriter{ResponseWriter: w} customErrorE := p.service.CustomError(&rw, r) - if callStats != nil { + if callStatsOk { callStats.Execution = time.Since(executionStart) } if rw.Status() == http.StatusOK { @@ -89,12 +89,12 @@ func (p *ServiceGoTSRPCProxy) ServeHTTP(w http.ResponseWriter, r *http.Request) rets []any ) var executionStart time.Time - if callStats != nil { + if callStatsOk { executionStart = time.Now() } rw := gotsrpc.ResponseWriter{ResponseWriter: w} errorE := p.service.Error(&rw, r) - if callStats != nil { + if callStatsOk { callStats.Execution = time.Since(executionStart) } if rw.Status() == http.StatusOK { @@ -112,12 +112,12 @@ func (p *ServiceGoTSRPCProxy) ServeHTTP(w http.ResponseWriter, r *http.Request) rets []any ) var executionStart time.Time - if callStats != nil { + if callStatsOk { executionStart = time.Now() } rw := gotsrpc.ResponseWriter{ResponseWriter: w} errorsE1, errorsE2 := p.service.Errors(&rw, r) - if callStats != nil { + if callStatsOk { callStats.Execution = time.Since(executionStart) } if rw.Status() == http.StatusOK { @@ -135,12 +135,12 @@ func (p *ServiceGoTSRPCProxy) ServeHTTP(w http.ResponseWriter, r *http.Request) rets []any ) var executionStart time.Time - if callStats != nil { + if callStatsOk { executionStart = time.Now() } rw := gotsrpc.ResponseWriter{ResponseWriter: w} multiScalarE := p.service.MultiScalar(&rw, r) - if callStats != nil { + if callStatsOk { callStats.Execution = time.Since(executionStart) } if rw.Status() == http.StatusOK { @@ -158,12 +158,12 @@ func (p *ServiceGoTSRPCProxy) ServeHTTP(w http.ResponseWriter, r *http.Request) rets []any ) var executionStart time.Time - if callStats != nil { + if callStatsOk { executionStart = time.Now() } rw := gotsrpc.ResponseWriter{ResponseWriter: w} scalarE := p.service.Scalar(&rw, r) - if callStats != nil { + if callStatsOk { callStats.Execution = time.Since(executionStart) } if rw.Status() == http.StatusOK { @@ -181,12 +181,12 @@ func (p *ServiceGoTSRPCProxy) ServeHTTP(w http.ResponseWriter, r *http.Request) rets []any ) var executionStart time.Time - if callStats != nil { + if callStatsOk { executionStart = time.Now() } rw := gotsrpc.ResponseWriter{ResponseWriter: w} scalarErrorE := p.service.ScalarError(&rw, r) - if callStats != nil { + if callStatsOk { callStats.Execution = time.Since(executionStart) } if rw.Status() == http.StatusOK { @@ -204,12 +204,12 @@ func (p *ServiceGoTSRPCProxy) ServeHTTP(w http.ResponseWriter, r *http.Request) rets []any ) var executionStart time.Time - if callStats != nil { + if callStatsOk { executionStart = time.Now() } rw := gotsrpc.ResponseWriter{ResponseWriter: w} structE := p.service.Struct(&rw, r) - if callStats != nil { + if callStatsOk { callStats.Execution = time.Since(executionStart) } if rw.Status() == http.StatusOK { @@ -227,12 +227,12 @@ func (p *ServiceGoTSRPCProxy) ServeHTTP(w http.ResponseWriter, r *http.Request) rets []any ) var executionStart time.Time - if callStats != nil { + if callStatsOk { executionStart = time.Now() } rw := gotsrpc.ResponseWriter{ResponseWriter: w} structErrorE := p.service.StructError(&rw, r) - if callStats != nil { + if callStatsOk { callStats.Execution = time.Since(executionStart) } if rw.Status() == http.StatusOK { @@ -250,12 +250,12 @@ func (p *ServiceGoTSRPCProxy) ServeHTTP(w http.ResponseWriter, r *http.Request) rets []any ) var executionStart time.Time - if callStats != nil { + if callStatsOk { executionStart = time.Now() } rw := gotsrpc.ResponseWriter{ResponseWriter: w} typedCustomErrorE := p.service.TypedCustomError(&rw, r) - if callStats != nil { + if callStatsOk { callStats.Execution = time.Since(executionStart) } if rw.Status() == http.StatusOK { @@ -273,12 +273,12 @@ func (p *ServiceGoTSRPCProxy) ServeHTTP(w http.ResponseWriter, r *http.Request) rets []any ) var executionStart time.Time - if callStats != nil { + if callStatsOk { executionStart = time.Now() } rw := gotsrpc.ResponseWriter{ResponseWriter: w} typedErrorE := p.service.TypedError(&rw, r) - if callStats != nil { + if callStatsOk { callStats.Execution = time.Since(executionStart) } if rw.Status() == http.StatusOK { @@ -296,12 +296,12 @@ func (p *ServiceGoTSRPCProxy) ServeHTTP(w http.ResponseWriter, r *http.Request) rets []any ) var executionStart time.Time - if callStats != nil { + if callStatsOk { executionStart = time.Now() } rw := gotsrpc.ResponseWriter{ResponseWriter: w} typedScalarErrorE := p.service.TypedScalarError(&rw, r) - if callStats != nil { + if callStatsOk { callStats.Execution = time.Since(executionStart) } if rw.Status() == http.StatusOK { @@ -319,12 +319,12 @@ func (p *ServiceGoTSRPCProxy) ServeHTTP(w http.ResponseWriter, r *http.Request) rets []any ) var executionStart time.Time - if callStats != nil { + if callStatsOk { executionStart = time.Now() } rw := gotsrpc.ResponseWriter{ResponseWriter: w} typedWrappedErrorE := p.service.TypedWrappedError(&rw, r) - if callStats != nil { + if callStatsOk { callStats.Execution = time.Since(executionStart) } if rw.Status() == http.StatusOK { @@ -342,12 +342,12 @@ func (p *ServiceGoTSRPCProxy) ServeHTTP(w http.ResponseWriter, r *http.Request) rets []any ) var executionStart time.Time - if callStats != nil { + if callStatsOk { executionStart = time.Now() } rw := gotsrpc.ResponseWriter{ResponseWriter: w} wrappedErrorE := p.service.WrappedError(&rw, r) - if callStats != nil { + if callStatsOk { callStats.Execution = time.Since(executionStart) } if rw.Status() == http.StatusOK { diff --git a/tests/nullable/server/gotsrpc_gen.go b/tests/nullable/server/gotsrpc_gen.go index d178914..d8a062e 100644 --- a/tests/nullable/server/gotsrpc_gen.go +++ b/tests/nullable/server/gotsrpc_gen.go @@ -48,8 +48,8 @@ func (p *ServiceGoTSRPCProxy) ServeHTTP(w http.ResponseWriter, r *http.Request) defer io.Copy(io.Discard, r.Body) // Drain Request Body funcName := gotsrpc.GetCalledFunc(r, p.EndPoint) - callStats, _ := gotsrpc.GetStatsForRequest(r) - if callStats != nil { + callStats, callStatsOk := gotsrpc.GetStatsForRequest(r) + if callStatsOk { callStats.Func = funcName callStats.Package = "github.com/foomo/gotsrpc/v2/tests/nullable/server" callStats.Service = "Service" @@ -69,11 +69,11 @@ func (p *ServiceGoTSRPCProxy) ServeHTTP(w http.ResponseWriter, r *http.Request) return } var executionStart time.Time - if callStats != nil { + if callStatsOk { executionStart = time.Now() } variantAR1 := p.service.VariantA(r.Context(), arg_i1) - if callStats != nil { + if callStatsOk { callStats.Execution = time.Since(executionStart) } rets = []any{variantAR1} @@ -97,11 +97,11 @@ func (p *ServiceGoTSRPCProxy) ServeHTTP(w http.ResponseWriter, r *http.Request) return } var executionStart time.Time - if callStats != nil { + if callStatsOk { executionStart = time.Now() } variantBR1 := p.service.VariantB(r.Context(), arg_i1) - if callStats != nil { + if callStatsOk { callStats.Execution = time.Since(executionStart) } rets = []any{variantBR1} @@ -125,11 +125,11 @@ func (p *ServiceGoTSRPCProxy) ServeHTTP(w http.ResponseWriter, r *http.Request) return } var executionStart time.Time - if callStats != nil { + if callStatsOk { executionStart = time.Now() } variantCR1 := p.service.VariantC(r.Context(), arg_i1) - if callStats != nil { + if callStatsOk { callStats.Execution = time.Since(executionStart) } rets = []any{variantCR1} @@ -153,11 +153,11 @@ func (p *ServiceGoTSRPCProxy) ServeHTTP(w http.ResponseWriter, r *http.Request) return } var executionStart time.Time - if callStats != nil { + if callStatsOk { executionStart = time.Now() } variantDR1 := p.service.VariantD(r.Context(), arg_i1) - if callStats != nil { + if callStatsOk { callStats.Execution = time.Since(executionStart) } rets = []any{variantDR1} @@ -181,11 +181,11 @@ func (p *ServiceGoTSRPCProxy) ServeHTTP(w http.ResponseWriter, r *http.Request) return } var executionStart time.Time - if callStats != nil { + if callStatsOk { executionStart = time.Now() } variantER1 := p.service.VariantE(r.Context(), arg_i1) - if callStats != nil { + if callStatsOk { callStats.Execution = time.Since(executionStart) } rets = []any{variantER1} @@ -209,11 +209,11 @@ func (p *ServiceGoTSRPCProxy) ServeHTTP(w http.ResponseWriter, r *http.Request) return } var executionStart time.Time - if callStats != nil { + if callStatsOk { executionStart = time.Now() } variantFR1 := p.service.VariantF(r.Context(), arg_i1) - if callStats != nil { + if callStatsOk { callStats.Execution = time.Since(executionStart) } rets = []any{variantFR1} @@ -237,11 +237,11 @@ func (p *ServiceGoTSRPCProxy) ServeHTTP(w http.ResponseWriter, r *http.Request) return } var executionStart time.Time - if callStats != nil { + if callStatsOk { executionStart = time.Now() } variantGR1 := p.service.VariantG(r.Context(), arg_i1) - if callStats != nil { + if callStatsOk { callStats.Execution = time.Since(executionStart) } rets = []any{variantGR1} @@ -268,11 +268,11 @@ func (p *ServiceGoTSRPCProxy) ServeHTTP(w http.ResponseWriter, r *http.Request) return } var executionStart time.Time - if callStats != nil { + if callStatsOk { executionStart = time.Now() } variantHR1, variantHR2, variantHR3, variantHR4 := p.service.VariantH(r.Context(), arg_i1, arg_i2, arg_i3, arg_i4) - if callStats != nil { + if callStatsOk { callStats.Execution = time.Since(executionStart) } rets = []any{variantHR1, variantHR2, variantHR3, variantHR4} diff --git a/tests/time/server/gotsrpc_gen.go b/tests/time/server/gotsrpc_gen.go index 1fdc44d..4858fe5 100644 --- a/tests/time/server/gotsrpc_gen.go +++ b/tests/time/server/gotsrpc_gen.go @@ -42,8 +42,8 @@ func (p *ServiceGoTSRPCProxy) ServeHTTP(w http.ResponseWriter, r *http.Request) defer io.Copy(io.Discard, r.Body) // Drain Request Body funcName := gotsrpc.GetCalledFunc(r, p.EndPoint) - callStats, _ := gotsrpc.GetStatsForRequest(r) - if callStats != nil { + callStats, callStatsOk := gotsrpc.GetStatsForRequest(r) + if callStatsOk { callStats.Func = funcName callStats.Package = "github.com/foomo/gotsrpc/v2/tests/time/server" callStats.Service = "Service" @@ -63,11 +63,11 @@ func (p *ServiceGoTSRPCProxy) ServeHTTP(w http.ResponseWriter, r *http.Request) return } var executionStart time.Time - if callStats != nil { + if callStatsOk { executionStart = time.Now() } timeRet := p.service.Time(arg_v) - if callStats != nil { + if callStatsOk { callStats.Execution = time.Since(executionStart) } rets = []any{timeRet} @@ -91,11 +91,11 @@ func (p *ServiceGoTSRPCProxy) ServeHTTP(w http.ResponseWriter, r *http.Request) return } var executionStart time.Time - if callStats != nil { + if callStatsOk { executionStart = time.Now() } timeStructRet := p.service.TimeStruct(arg_v) - if callStats != nil { + if callStatsOk { callStats.Execution = time.Since(executionStart) } rets = []any{timeStructRet} diff --git a/tests/types/server/gotsrpc_gen.go b/tests/types/server/gotsrpc_gen.go index bed82a6..47384d7 100644 --- a/tests/types/server/gotsrpc_gen.go +++ b/tests/types/server/gotsrpc_gen.go @@ -114,8 +114,8 @@ func (p *ServiceGoTSRPCProxy) ServeHTTP(w http.ResponseWriter, r *http.Request) defer io.Copy(io.Discard, r.Body) // Drain Request Body funcName := gotsrpc.GetCalledFunc(r, p.EndPoint) - callStats, _ := gotsrpc.GetStatsForRequest(r) - if callStats != nil { + callStats, callStatsOk := gotsrpc.GetStatsForRequest(r) + if callStatsOk { callStats.Func = funcName callStats.Package = "github.com/foomo/gotsrpc/v2/tests/types/server" callStats.Service = "Service" @@ -135,11 +135,11 @@ func (p *ServiceGoTSRPCProxy) ServeHTTP(w http.ResponseWriter, r *http.Request) return } var executionStart time.Time - if callStats != nil { + if callStatsOk { executionStart = time.Now() } allScalarMapsStructRet := p.service.AllScalarMapsStruct(r.Context(), arg_v) - if callStats != nil { + if callStatsOk { callStats.Execution = time.Since(executionStart) } rets = []any{allScalarMapsStructRet} @@ -163,11 +163,11 @@ func (p *ServiceGoTSRPCProxy) ServeHTTP(w http.ResponseWriter, r *http.Request) return } var executionStart time.Time - if callStats != nil { + if callStatsOk { executionStart = time.Now() } allScalarPointersStructRet := p.service.AllScalarPointersStruct(r.Context(), arg_v) - if callStats != nil { + if callStatsOk { callStats.Execution = time.Since(executionStart) } rets = []any{allScalarPointersStructRet} @@ -191,11 +191,11 @@ func (p *ServiceGoTSRPCProxy) ServeHTTP(w http.ResponseWriter, r *http.Request) return } var executionStart time.Time - if callStats != nil { + if callStatsOk { executionStart = time.Now() } allScalarSlicesStructRet := p.service.AllScalarSlicesStruct(r.Context(), arg_v) - if callStats != nil { + if callStatsOk { callStats.Execution = time.Since(executionStart) } rets = []any{allScalarSlicesStructRet} @@ -219,11 +219,11 @@ func (p *ServiceGoTSRPCProxy) ServeHTTP(w http.ResponseWriter, r *http.Request) return } var executionStart time.Time - if callStats != nil { + if callStatsOk { executionStart = time.Now() } allScalarsStructRet := p.service.AllScalarsStruct(r.Context(), arg_v) - if callStats != nil { + if callStatsOk { callStats.Execution = time.Since(executionStart) } rets = []any{allScalarsStructRet} @@ -247,11 +247,11 @@ func (p *ServiceGoTSRPCProxy) ServeHTTP(w http.ResponseWriter, r *http.Request) return } var executionStart time.Time - if callStats != nil { + if callStatsOk { executionStart = time.Now() } boolRet := p.service.Bool(r.Context(), arg_v) - if callStats != nil { + if callStatsOk { callStats.Execution = time.Since(executionStart) } rets = []any{boolRet} @@ -275,11 +275,11 @@ func (p *ServiceGoTSRPCProxy) ServeHTTP(w http.ResponseWriter, r *http.Request) return } var executionStart time.Time - if callStats != nil { + if callStatsOk { executionStart = time.Now() } boolPtrRet := p.service.BoolPtr(r.Context(), arg_v) - if callStats != nil { + if callStatsOk { callStats.Execution = time.Since(executionStart) } rets = []any{boolPtrRet} @@ -303,11 +303,11 @@ func (p *ServiceGoTSRPCProxy) ServeHTTP(w http.ResponseWriter, r *http.Request) return } var executionStart time.Time - if callStats != nil { + if callStatsOk { executionStart = time.Now() } byteSliceRet := p.service.ByteSlice(r.Context(), arg_v) - if callStats != nil { + if callStatsOk { callStats.Execution = time.Since(executionStart) } rets = []any{byteSliceRet} @@ -323,11 +323,11 @@ func (p *ServiceGoTSRPCProxy) ServeHTTP(w http.ResponseWriter, r *http.Request) rets []any ) var executionStart time.Time - if callStats != nil { + if callStatsOk { executionStart = time.Now() } emptyRet := p.service.Empty(r.Context()) - if callStats != nil { + if callStatsOk { callStats.Execution = time.Since(executionStart) } rets = []any{emptyRet} @@ -351,11 +351,11 @@ func (p *ServiceGoTSRPCProxy) ServeHTTP(w http.ResponseWriter, r *http.Request) return } var executionStart time.Time - if callStats != nil { + if callStatsOk { executionStart = time.Now() } float32Ret := p.service.Float32(r.Context(), arg_v) - if callStats != nil { + if callStatsOk { callStats.Execution = time.Since(executionStart) } rets = []any{float32Ret} @@ -379,11 +379,11 @@ func (p *ServiceGoTSRPCProxy) ServeHTTP(w http.ResponseWriter, r *http.Request) return } var executionStart time.Time - if callStats != nil { + if callStatsOk { executionStart = time.Now() } float32PtrRet := p.service.Float32Ptr(r.Context(), arg_v) - if callStats != nil { + if callStatsOk { callStats.Execution = time.Since(executionStart) } rets = []any{float32PtrRet} @@ -407,11 +407,11 @@ func (p *ServiceGoTSRPCProxy) ServeHTTP(w http.ResponseWriter, r *http.Request) return } var executionStart time.Time - if callStats != nil { + if callStatsOk { executionStart = time.Now() } float32SliceRet := p.service.Float32Slice(r.Context(), arg_v) - if callStats != nil { + if callStatsOk { callStats.Execution = time.Since(executionStart) } rets = []any{float32SliceRet} @@ -435,11 +435,11 @@ func (p *ServiceGoTSRPCProxy) ServeHTTP(w http.ResponseWriter, r *http.Request) return } var executionStart time.Time - if callStats != nil { + if callStatsOk { executionStart = time.Now() } float64Ret := p.service.Float64(r.Context(), arg_v) - if callStats != nil { + if callStatsOk { callStats.Execution = time.Since(executionStart) } rets = []any{float64Ret} @@ -463,11 +463,11 @@ func (p *ServiceGoTSRPCProxy) ServeHTTP(w http.ResponseWriter, r *http.Request) return } var executionStart time.Time - if callStats != nil { + if callStatsOk { executionStart = time.Now() } inlinedMixedStructRet := p.service.InlinedMixedStruct(r.Context(), arg_v) - if callStats != nil { + if callStatsOk { callStats.Execution = time.Since(executionStart) } rets = []any{inlinedMixedStructRet} @@ -491,11 +491,11 @@ func (p *ServiceGoTSRPCProxy) ServeHTTP(w http.ResponseWriter, r *http.Request) return } var executionStart time.Time - if callStats != nil { + if callStatsOk { executionStart = time.Now() } inlinedMultipleStructRet := p.service.InlinedMultipleStruct(r.Context(), arg_v) - if callStats != nil { + if callStatsOk { callStats.Execution = time.Since(executionStart) } rets = []any{inlinedMultipleStructRet} @@ -519,11 +519,11 @@ func (p *ServiceGoTSRPCProxy) ServeHTTP(w http.ResponseWriter, r *http.Request) return } var executionStart time.Time - if callStats != nil { + if callStatsOk { executionStart = time.Now() } inlinedPtrStructRet := p.service.InlinedPtrStruct(r.Context(), arg_v) - if callStats != nil { + if callStatsOk { callStats.Execution = time.Since(executionStart) } rets = []any{inlinedPtrStructRet} @@ -547,11 +547,11 @@ func (p *ServiceGoTSRPCProxy) ServeHTTP(w http.ResponseWriter, r *http.Request) return } var executionStart time.Time - if callStats != nil { + if callStatsOk { executionStart = time.Now() } inlinedStructRet := p.service.InlinedStruct(r.Context(), arg_v) - if callStats != nil { + if callStatsOk { callStats.Execution = time.Since(executionStart) } rets = []any{inlinedStructRet} @@ -575,11 +575,11 @@ func (p *ServiceGoTSRPCProxy) ServeHTTP(w http.ResponseWriter, r *http.Request) return } var executionStart time.Time - if callStats != nil { + if callStatsOk { executionStart = time.Now() } intRet := p.service.Int(r.Context(), arg_v) - if callStats != nil { + if callStatsOk { callStats.Execution = time.Since(executionStart) } rets = []any{intRet} @@ -603,11 +603,11 @@ func (p *ServiceGoTSRPCProxy) ServeHTTP(w http.ResponseWriter, r *http.Request) return } var executionStart time.Time - if callStats != nil { + if callStatsOk { executionStart = time.Now() } int16Ret := p.service.Int16(r.Context(), arg_v) - if callStats != nil { + if callStatsOk { callStats.Execution = time.Since(executionStart) } rets = []any{int16Ret} @@ -631,11 +631,11 @@ func (p *ServiceGoTSRPCProxy) ServeHTTP(w http.ResponseWriter, r *http.Request) return } var executionStart time.Time - if callStats != nil { + if callStatsOk { executionStart = time.Now() } int16PtrRet := p.service.Int16Ptr(r.Context(), arg_v) - if callStats != nil { + if callStatsOk { callStats.Execution = time.Since(executionStart) } rets = []any{int16PtrRet} @@ -659,11 +659,11 @@ func (p *ServiceGoTSRPCProxy) ServeHTTP(w http.ResponseWriter, r *http.Request) return } var executionStart time.Time - if callStats != nil { + if callStatsOk { executionStart = time.Now() } int16SliceRet := p.service.Int16Slice(r.Context(), arg_v) - if callStats != nil { + if callStatsOk { callStats.Execution = time.Since(executionStart) } rets = []any{int16SliceRet} @@ -687,11 +687,11 @@ func (p *ServiceGoTSRPCProxy) ServeHTTP(w http.ResponseWriter, r *http.Request) return } var executionStart time.Time - if callStats != nil { + if callStatsOk { executionStart = time.Now() } int32Ret := p.service.Int32(r.Context(), arg_v) - if callStats != nil { + if callStatsOk { callStats.Execution = time.Since(executionStart) } rets = []any{int32Ret} @@ -715,11 +715,11 @@ func (p *ServiceGoTSRPCProxy) ServeHTTP(w http.ResponseWriter, r *http.Request) return } var executionStart time.Time - if callStats != nil { + if callStatsOk { executionStart = time.Now() } int32PtrRet := p.service.Int32Ptr(r.Context(), arg_v) - if callStats != nil { + if callStatsOk { callStats.Execution = time.Since(executionStart) } rets = []any{int32PtrRet} @@ -743,11 +743,11 @@ func (p *ServiceGoTSRPCProxy) ServeHTTP(w http.ResponseWriter, r *http.Request) return } var executionStart time.Time - if callStats != nil { + if callStatsOk { executionStart = time.Now() } int32SliceRet := p.service.Int32Slice(r.Context(), arg_v) - if callStats != nil { + if callStatsOk { callStats.Execution = time.Since(executionStart) } rets = []any{int32SliceRet} @@ -771,11 +771,11 @@ func (p *ServiceGoTSRPCProxy) ServeHTTP(w http.ResponseWriter, r *http.Request) return } var executionStart time.Time - if callStats != nil { + if callStatsOk { executionStart = time.Now() } int64Ret := p.service.Int64(r.Context(), arg_v) - if callStats != nil { + if callStatsOk { callStats.Execution = time.Since(executionStart) } rets = []any{int64Ret} @@ -799,11 +799,11 @@ func (p *ServiceGoTSRPCProxy) ServeHTTP(w http.ResponseWriter, r *http.Request) return } var executionStart time.Time - if callStats != nil { + if callStatsOk { executionStart = time.Now() } int64PtrRet := p.service.Int64Ptr(r.Context(), arg_v) - if callStats != nil { + if callStatsOk { callStats.Execution = time.Since(executionStart) } rets = []any{int64PtrRet} @@ -827,11 +827,11 @@ func (p *ServiceGoTSRPCProxy) ServeHTTP(w http.ResponseWriter, r *http.Request) return } var executionStart time.Time - if callStats != nil { + if callStatsOk { executionStart = time.Now() } int64SliceRet := p.service.Int64Slice(r.Context(), arg_v) - if callStats != nil { + if callStatsOk { callStats.Execution = time.Since(executionStart) } rets = []any{int64SliceRet} @@ -855,11 +855,11 @@ func (p *ServiceGoTSRPCProxy) ServeHTTP(w http.ResponseWriter, r *http.Request) return } var executionStart time.Time - if callStats != nil { + if callStatsOk { executionStart = time.Now() } int8Ret := p.service.Int8(r.Context(), arg_v) - if callStats != nil { + if callStatsOk { callStats.Execution = time.Since(executionStart) } rets = []any{int8Ret} @@ -883,11 +883,11 @@ func (p *ServiceGoTSRPCProxy) ServeHTTP(w http.ResponseWriter, r *http.Request) return } var executionStart time.Time - if callStats != nil { + if callStatsOk { executionStart = time.Now() } int8PtrRet := p.service.Int8Ptr(r.Context(), arg_v) - if callStats != nil { + if callStatsOk { callStats.Execution = time.Since(executionStart) } rets = []any{int8PtrRet} @@ -911,11 +911,11 @@ func (p *ServiceGoTSRPCProxy) ServeHTTP(w http.ResponseWriter, r *http.Request) return } var executionStart time.Time - if callStats != nil { + if callStatsOk { executionStart = time.Now() } int8SliceRet := p.service.Int8Slice(r.Context(), arg_v) - if callStats != nil { + if callStatsOk { callStats.Execution = time.Since(executionStart) } rets = []any{int8SliceRet} @@ -939,11 +939,11 @@ func (p *ServiceGoTSRPCProxy) ServeHTTP(w http.ResponseWriter, r *http.Request) return } var executionStart time.Time - if callStats != nil { + if callStatsOk { executionStart = time.Now() } mapOfMapsRet := p.service.MapOfMaps(r.Context(), arg_v) - if callStats != nil { + if callStatsOk { callStats.Execution = time.Since(executionStart) } rets = []any{mapOfMapsRet} @@ -967,11 +967,11 @@ func (p *ServiceGoTSRPCProxy) ServeHTTP(w http.ResponseWriter, r *http.Request) return } var executionStart time.Time - if callStats != nil { + if callStatsOk { executionStart = time.Now() } mapOfSimpleSliceRet := p.service.MapOfSimpleSlice(r.Context(), arg_v) - if callStats != nil { + if callStatsOk { callStats.Execution = time.Since(executionStart) } rets = []any{mapOfSimpleSliceRet} @@ -997,11 +997,11 @@ func (p *ServiceGoTSRPCProxy) ServeHTTP(w http.ResponseWriter, r *http.Request) return } var executionStart time.Time - if callStats != nil { + if callStatsOk { executionStart = time.Now() } mixedArgsRet, mixedArgsRet_1, mixedArgsRet_2 := p.service.MixedArgs(r.Context(), arg_s, arg_items, arg_m) - if callStats != nil { + if callStatsOk { callStats.Execution = time.Since(executionStart) } rets = []any{mixedArgsRet, mixedArgsRet_1, mixedArgsRet_2} @@ -1027,11 +1027,11 @@ func (p *ServiceGoTSRPCProxy) ServeHTTP(w http.ResponseWriter, r *http.Request) return } var executionStart time.Time - if callStats != nil { + if callStatsOk { executionStart = time.Now() } multiArgsRet, multiArgsRet_1, multiArgsRet_2 := p.service.MultiArgs(r.Context(), arg_a, arg_b, arg_c) - if callStats != nil { + if callStatsOk { callStats.Execution = time.Since(executionStart) } rets = []any{multiArgsRet, multiArgsRet_1, multiArgsRet_2} @@ -1055,11 +1055,11 @@ func (p *ServiceGoTSRPCProxy) ServeHTTP(w http.ResponseWriter, r *http.Request) return } var executionStart time.Time - if callStats != nil { + if callStatsOk { executionStart = time.Now() } nestedStructRet := p.service.NestedStruct(r.Context(), arg_v) - if callStats != nil { + if callStatsOk { callStats.Execution = time.Since(executionStart) } rets = []any{nestedStructRet} @@ -1083,11 +1083,11 @@ func (p *ServiceGoTSRPCProxy) ServeHTTP(w http.ResponseWriter, r *http.Request) return } var executionStart time.Time - if callStats != nil { + if callStatsOk { executionStart = time.Now() } objectIDRet := p.service.ObjectID(r.Context(), arg_v) - if callStats != nil { + if callStatsOk { callStats.Execution = time.Since(executionStart) } rets = []any{objectIDRet} @@ -1111,11 +1111,11 @@ func (p *ServiceGoTSRPCProxy) ServeHTTP(w http.ResponseWriter, r *http.Request) return } var executionStart time.Time - if callStats != nil { + if callStatsOk { executionStart = time.Now() } simplePtrSliceRet := p.service.SimplePtrSlice(r.Context(), arg_v) - if callStats != nil { + if callStatsOk { callStats.Execution = time.Since(executionStart) } rets = []any{simplePtrSliceRet} @@ -1139,11 +1139,11 @@ func (p *ServiceGoTSRPCProxy) ServeHTTP(w http.ResponseWriter, r *http.Request) return } var executionStart time.Time - if callStats != nil { + if callStatsOk { executionStart = time.Now() } simpleSliceRet := p.service.SimpleSlice(r.Context(), arg_v) - if callStats != nil { + if callStatsOk { callStats.Execution = time.Since(executionStart) } rets = []any{simpleSliceRet} @@ -1167,11 +1167,11 @@ func (p *ServiceGoTSRPCProxy) ServeHTTP(w http.ResponseWriter, r *http.Request) return } var executionStart time.Time - if callStats != nil { + if callStatsOk { executionStart = time.Now() } simpleStructRet := p.service.SimpleStruct(r.Context(), arg_v) - if callStats != nil { + if callStatsOk { callStats.Execution = time.Since(executionStart) } rets = []any{simpleStructRet} @@ -1195,11 +1195,11 @@ func (p *ServiceGoTSRPCProxy) ServeHTTP(w http.ResponseWriter, r *http.Request) return } var executionStart time.Time - if callStats != nil { + if callStatsOk { executionStart = time.Now() } sliceOfMapsRet := p.service.SliceOfMaps(r.Context(), arg_v) - if callStats != nil { + if callStatsOk { callStats.Execution = time.Since(executionStart) } rets = []any{sliceOfMapsRet} @@ -1223,11 +1223,11 @@ func (p *ServiceGoTSRPCProxy) ServeHTTP(w http.ResponseWriter, r *http.Request) return } var executionStart time.Time - if callStats != nil { + if callStatsOk { executionStart = time.Now() } stringRet := p.service.String(r.Context(), arg_v) - if callStats != nil { + if callStatsOk { callStats.Execution = time.Since(executionStart) } rets = []any{stringRet} @@ -1251,11 +1251,11 @@ func (p *ServiceGoTSRPCProxy) ServeHTTP(w http.ResponseWriter, r *http.Request) return } var executionStart time.Time - if callStats != nil { + if callStatsOk { executionStart = time.Now() } stringFloat32MapRet := p.service.StringFloat32Map(r.Context(), arg_v) - if callStats != nil { + if callStatsOk { callStats.Execution = time.Since(executionStart) } rets = []any{stringFloat32MapRet} @@ -1279,11 +1279,11 @@ func (p *ServiceGoTSRPCProxy) ServeHTTP(w http.ResponseWriter, r *http.Request) return } var executionStart time.Time - if callStats != nil { + if callStatsOk { executionStart = time.Now() } stringInt16MapRet := p.service.StringInt16Map(r.Context(), arg_v) - if callStats != nil { + if callStatsOk { callStats.Execution = time.Since(executionStart) } rets = []any{stringInt16MapRet} @@ -1307,11 +1307,11 @@ func (p *ServiceGoTSRPCProxy) ServeHTTP(w http.ResponseWriter, r *http.Request) return } var executionStart time.Time - if callStats != nil { + if callStatsOk { executionStart = time.Now() } stringInt32MapRet := p.service.StringInt32Map(r.Context(), arg_v) - if callStats != nil { + if callStatsOk { callStats.Execution = time.Since(executionStart) } rets = []any{stringInt32MapRet} @@ -1335,11 +1335,11 @@ func (p *ServiceGoTSRPCProxy) ServeHTTP(w http.ResponseWriter, r *http.Request) return } var executionStart time.Time - if callStats != nil { + if callStatsOk { executionStart = time.Now() } stringInt64MapRet := p.service.StringInt64Map(r.Context(), arg_v) - if callStats != nil { + if callStatsOk { callStats.Execution = time.Since(executionStart) } rets = []any{stringInt64MapRet} @@ -1363,11 +1363,11 @@ func (p *ServiceGoTSRPCProxy) ServeHTTP(w http.ResponseWriter, r *http.Request) return } var executionStart time.Time - if callStats != nil { + if callStatsOk { executionStart = time.Now() } stringInt8MapRet := p.service.StringInt8Map(r.Context(), arg_v) - if callStats != nil { + if callStatsOk { callStats.Execution = time.Since(executionStart) } rets = []any{stringInt8MapRet} @@ -1391,11 +1391,11 @@ func (p *ServiceGoTSRPCProxy) ServeHTTP(w http.ResponseWriter, r *http.Request) return } var executionStart time.Time - if callStats != nil { + if callStatsOk { executionStart = time.Now() } stringPtrRet := p.service.StringPtr(r.Context(), arg_v) - if callStats != nil { + if callStatsOk { callStats.Execution = time.Since(executionStart) } rets = []any{stringPtrRet} @@ -1419,11 +1419,11 @@ func (p *ServiceGoTSRPCProxy) ServeHTTP(w http.ResponseWriter, r *http.Request) return } var executionStart time.Time - if callStats != nil { + if callStatsOk { executionStart = time.Now() } stringSimpleMapRet := p.service.StringSimpleMap(r.Context(), arg_v) - if callStats != nil { + if callStatsOk { callStats.Execution = time.Since(executionStart) } rets = []any{stringSimpleMapRet} @@ -1447,11 +1447,11 @@ func (p *ServiceGoTSRPCProxy) ServeHTTP(w http.ResponseWriter, r *http.Request) return } var executionStart time.Time - if callStats != nil { + if callStatsOk { executionStart = time.Now() } stringSimplePtrMapRet := p.service.StringSimplePtrMap(r.Context(), arg_v) - if callStats != nil { + if callStatsOk { callStats.Execution = time.Since(executionStart) } rets = []any{stringSimplePtrMapRet} @@ -1475,11 +1475,11 @@ func (p *ServiceGoTSRPCProxy) ServeHTTP(w http.ResponseWriter, r *http.Request) return } var executionStart time.Time - if callStats != nil { + if callStatsOk { executionStart = time.Now() } stringSliceRet := p.service.StringSlice(r.Context(), arg_v) - if callStats != nil { + if callStatsOk { callStats.Execution = time.Since(executionStart) } rets = []any{stringSliceRet} @@ -1503,11 +1503,11 @@ func (p *ServiceGoTSRPCProxy) ServeHTTP(w http.ResponseWriter, r *http.Request) return } var executionStart time.Time - if callStats != nil { + if callStatsOk { executionStart = time.Now() } stringSlice2DRet := p.service.StringSlice2D(r.Context(), arg_v) - if callStats != nil { + if callStatsOk { callStats.Execution = time.Since(executionStart) } rets = []any{stringSlice2DRet} @@ -1531,11 +1531,11 @@ func (p *ServiceGoTSRPCProxy) ServeHTTP(w http.ResponseWriter, r *http.Request) return } var executionStart time.Time - if callStats != nil { + if callStatsOk { executionStart = time.Now() } stringStringMapRet := p.service.StringStringMap(r.Context(), arg_v) - if callStats != nil { + if callStatsOk { callStats.Execution = time.Since(executionStart) } rets = []any{stringStringMapRet} @@ -1559,11 +1559,11 @@ func (p *ServiceGoTSRPCProxy) ServeHTTP(w http.ResponseWriter, r *http.Request) return } var executionStart time.Time - if callStats != nil { + if callStatsOk { executionStart = time.Now() } stringStringSliceMapRet := p.service.StringStringSliceMap(r.Context(), arg_v) - if callStats != nil { + if callStatsOk { callStats.Execution = time.Since(executionStart) } rets = []any{stringStringSliceMapRet} @@ -1587,11 +1587,11 @@ func (p *ServiceGoTSRPCProxy) ServeHTTP(w http.ResponseWriter, r *http.Request) return } var executionStart time.Time - if callStats != nil { + if callStatsOk { executionStart = time.Now() } stringUint16MapRet := p.service.StringUint16Map(r.Context(), arg_v) - if callStats != nil { + if callStatsOk { callStats.Execution = time.Since(executionStart) } rets = []any{stringUint16MapRet} @@ -1615,11 +1615,11 @@ func (p *ServiceGoTSRPCProxy) ServeHTTP(w http.ResponseWriter, r *http.Request) return } var executionStart time.Time - if callStats != nil { + if callStatsOk { executionStart = time.Now() } stringUint32MapRet := p.service.StringUint32Map(r.Context(), arg_v) - if callStats != nil { + if callStatsOk { callStats.Execution = time.Since(executionStart) } rets = []any{stringUint32MapRet} @@ -1643,11 +1643,11 @@ func (p *ServiceGoTSRPCProxy) ServeHTTP(w http.ResponseWriter, r *http.Request) return } var executionStart time.Time - if callStats != nil { + if callStatsOk { executionStart = time.Now() } stringUint64MapRet := p.service.StringUint64Map(r.Context(), arg_v) - if callStats != nil { + if callStatsOk { callStats.Execution = time.Since(executionStart) } rets = []any{stringUint64MapRet} @@ -1671,11 +1671,11 @@ func (p *ServiceGoTSRPCProxy) ServeHTTP(w http.ResponseWriter, r *http.Request) return } var executionStart time.Time - if callStats != nil { + if callStatsOk { executionStart = time.Now() } stringUint8MapRet := p.service.StringUint8Map(r.Context(), arg_v) - if callStats != nil { + if callStatsOk { callStats.Execution = time.Since(executionStart) } rets = []any{stringUint8MapRet} @@ -1699,11 +1699,11 @@ func (p *ServiceGoTSRPCProxy) ServeHTTP(w http.ResponseWriter, r *http.Request) return } var executionStart time.Time - if callStats != nil { + if callStatsOk { executionStart = time.Now() } stringUintMapRet := p.service.StringUintMap(r.Context(), arg_v) - if callStats != nil { + if callStatsOk { callStats.Execution = time.Since(executionStart) } rets = []any{stringUintMapRet} @@ -1727,11 +1727,11 @@ func (p *ServiceGoTSRPCProxy) ServeHTTP(w http.ResponseWriter, r *http.Request) return } var executionStart time.Time - if callStats != nil { + if callStatsOk { executionStart = time.Now() } structWithCollectionsRet := p.service.StructWithCollections(r.Context(), arg_v) - if callStats != nil { + if callStatsOk { callStats.Execution = time.Since(executionStart) } rets = []any{structWithCollectionsRet} @@ -1755,11 +1755,11 @@ func (p *ServiceGoTSRPCProxy) ServeHTTP(w http.ResponseWriter, r *http.Request) return } var executionStart time.Time - if callStats != nil { + if callStatsOk { executionStart = time.Now() } structWithPointersRet := p.service.StructWithPointers(r.Context(), arg_v) - if callStats != nil { + if callStatsOk { callStats.Execution = time.Since(executionStart) } rets = []any{structWithPointersRet} @@ -1783,11 +1783,11 @@ func (p *ServiceGoTSRPCProxy) ServeHTTP(w http.ResponseWriter, r *http.Request) return } var executionStart time.Time - if callStats != nil { + if callStatsOk { executionStart = time.Now() } uintRet := p.service.Uint(r.Context(), arg_v) - if callStats != nil { + if callStatsOk { callStats.Execution = time.Since(executionStart) } rets = []any{uintRet} @@ -1811,11 +1811,11 @@ func (p *ServiceGoTSRPCProxy) ServeHTTP(w http.ResponseWriter, r *http.Request) return } var executionStart time.Time - if callStats != nil { + if callStatsOk { executionStart = time.Now() } uint16Ret := p.service.Uint16(r.Context(), arg_v) - if callStats != nil { + if callStatsOk { callStats.Execution = time.Since(executionStart) } rets = []any{uint16Ret} @@ -1839,11 +1839,11 @@ func (p *ServiceGoTSRPCProxy) ServeHTTP(w http.ResponseWriter, r *http.Request) return } var executionStart time.Time - if callStats != nil { + if callStatsOk { executionStart = time.Now() } uint16PtrRet := p.service.Uint16Ptr(r.Context(), arg_v) - if callStats != nil { + if callStatsOk { callStats.Execution = time.Since(executionStart) } rets = []any{uint16PtrRet} @@ -1867,11 +1867,11 @@ func (p *ServiceGoTSRPCProxy) ServeHTTP(w http.ResponseWriter, r *http.Request) return } var executionStart time.Time - if callStats != nil { + if callStatsOk { executionStart = time.Now() } uint16SliceRet := p.service.Uint16Slice(r.Context(), arg_v) - if callStats != nil { + if callStatsOk { callStats.Execution = time.Since(executionStart) } rets = []any{uint16SliceRet} @@ -1895,11 +1895,11 @@ func (p *ServiceGoTSRPCProxy) ServeHTTP(w http.ResponseWriter, r *http.Request) return } var executionStart time.Time - if callStats != nil { + if callStatsOk { executionStart = time.Now() } uint32Ret := p.service.Uint32(r.Context(), arg_v) - if callStats != nil { + if callStatsOk { callStats.Execution = time.Since(executionStart) } rets = []any{uint32Ret} @@ -1923,11 +1923,11 @@ func (p *ServiceGoTSRPCProxy) ServeHTTP(w http.ResponseWriter, r *http.Request) return } var executionStart time.Time - if callStats != nil { + if callStatsOk { executionStart = time.Now() } uint32PtrRet := p.service.Uint32Ptr(r.Context(), arg_v) - if callStats != nil { + if callStatsOk { callStats.Execution = time.Since(executionStart) } rets = []any{uint32PtrRet} @@ -1951,11 +1951,11 @@ func (p *ServiceGoTSRPCProxy) ServeHTTP(w http.ResponseWriter, r *http.Request) return } var executionStart time.Time - if callStats != nil { + if callStatsOk { executionStart = time.Now() } uint32SliceRet := p.service.Uint32Slice(r.Context(), arg_v) - if callStats != nil { + if callStatsOk { callStats.Execution = time.Since(executionStart) } rets = []any{uint32SliceRet} @@ -1979,11 +1979,11 @@ func (p *ServiceGoTSRPCProxy) ServeHTTP(w http.ResponseWriter, r *http.Request) return } var executionStart time.Time - if callStats != nil { + if callStatsOk { executionStart = time.Now() } uint64Ret := p.service.Uint64(r.Context(), arg_v) - if callStats != nil { + if callStatsOk { callStats.Execution = time.Since(executionStart) } rets = []any{uint64Ret} @@ -2007,11 +2007,11 @@ func (p *ServiceGoTSRPCProxy) ServeHTTP(w http.ResponseWriter, r *http.Request) return } var executionStart time.Time - if callStats != nil { + if callStatsOk { executionStart = time.Now() } uint64PtrRet := p.service.Uint64Ptr(r.Context(), arg_v) - if callStats != nil { + if callStatsOk { callStats.Execution = time.Since(executionStart) } rets = []any{uint64PtrRet} @@ -2035,11 +2035,11 @@ func (p *ServiceGoTSRPCProxy) ServeHTTP(w http.ResponseWriter, r *http.Request) return } var executionStart time.Time - if callStats != nil { + if callStatsOk { executionStart = time.Now() } uint64SliceRet := p.service.Uint64Slice(r.Context(), arg_v) - if callStats != nil { + if callStatsOk { callStats.Execution = time.Since(executionStart) } rets = []any{uint64SliceRet} @@ -2063,11 +2063,11 @@ func (p *ServiceGoTSRPCProxy) ServeHTTP(w http.ResponseWriter, r *http.Request) return } var executionStart time.Time - if callStats != nil { + if callStatsOk { executionStart = time.Now() } uint8Ret := p.service.Uint8(r.Context(), arg_v) - if callStats != nil { + if callStatsOk { callStats.Execution = time.Since(executionStart) } rets = []any{uint8Ret} @@ -2091,11 +2091,11 @@ func (p *ServiceGoTSRPCProxy) ServeHTTP(w http.ResponseWriter, r *http.Request) return } var executionStart time.Time - if callStats != nil { + if callStatsOk { executionStart = time.Now() } uint8PtrRet := p.service.Uint8Ptr(r.Context(), arg_v) - if callStats != nil { + if callStatsOk { callStats.Execution = time.Since(executionStart) } rets = []any{uint8PtrRet} @@ -2119,11 +2119,11 @@ func (p *ServiceGoTSRPCProxy) ServeHTTP(w http.ResponseWriter, r *http.Request) return } var executionStart time.Time - if callStats != nil { + if callStatsOk { executionStart = time.Now() } uintPtrRet := p.service.UintPtr(r.Context(), arg_v) - if callStats != nil { + if callStatsOk { callStats.Execution = time.Since(executionStart) } rets = []any{uintPtrRet} @@ -2147,11 +2147,11 @@ func (p *ServiceGoTSRPCProxy) ServeHTTP(w http.ResponseWriter, r *http.Request) return } var executionStart time.Time - if callStats != nil { + if callStatsOk { executionStart = time.Now() } uintSliceRet := p.service.UintSlice(r.Context(), arg_v) - if callStats != nil { + if callStatsOk { callStats.Execution = time.Since(executionStart) } rets = []any{uintSliceRet} diff --git a/tests/union/server/gotsrpc_gen.go b/tests/union/server/gotsrpc_gen.go index 0f86f30..7c1abfe 100644 --- a/tests/union/server/gotsrpc_gen.go +++ b/tests/union/server/gotsrpc_gen.go @@ -49,8 +49,8 @@ func (p *ServiceGoTSRPCProxy) ServeHTTP(w http.ResponseWriter, r *http.Request) defer io.Copy(io.Discard, r.Body) // Drain Request Body funcName := gotsrpc.GetCalledFunc(r, p.EndPoint) - callStats, _ := gotsrpc.GetStatsForRequest(r) - if callStats != nil { + callStats, callStatsOk := gotsrpc.GetStatsForRequest(r) + if callStatsOk { callStats.Func = funcName callStats.Package = "github.com/foomo/gotsrpc/v2/tests/union/server" callStats.Service = "Service" @@ -62,12 +62,12 @@ func (p *ServiceGoTSRPCProxy) ServeHTTP(w http.ResponseWriter, r *http.Request) rets []any ) var executionStart time.Time - if callStats != nil { + if callStatsOk { executionStart = time.Now() } rw := gotsrpc.ResponseWriter{ResponseWriter: w} inlineStructE := p.service.InlineStruct(&rw, r) - if callStats != nil { + if callStatsOk { callStats.Execution = time.Since(executionStart) } if rw.Status() == http.StatusOK { @@ -85,12 +85,12 @@ func (p *ServiceGoTSRPCProxy) ServeHTTP(w http.ResponseWriter, r *http.Request) rets []any ) var executionStart time.Time - if callStats != nil { + if callStatsOk { executionStart = time.Now() } rw := gotsrpc.ResponseWriter{ResponseWriter: w} inlineStructPtrE := p.service.InlineStructPtr(&rw, r) - if callStats != nil { + if callStatsOk { callStats.Execution = time.Since(executionStart) } if rw.Status() == http.StatusOK { @@ -108,12 +108,12 @@ func (p *ServiceGoTSRPCProxy) ServeHTTP(w http.ResponseWriter, r *http.Request) rets []any ) var executionStart time.Time - if callStats != nil { + if callStatsOk { executionStart = time.Now() } rw := gotsrpc.ResponseWriter{ResponseWriter: w} unionStringE := p.service.UnionString(&rw, r) - if callStats != nil { + if callStatsOk { callStats.Execution = time.Since(executionStart) } if rw.Status() == http.StatusOK { @@ -131,12 +131,12 @@ func (p *ServiceGoTSRPCProxy) ServeHTTP(w http.ResponseWriter, r *http.Request) rets []any ) var executionStart time.Time - if callStats != nil { + if callStatsOk { executionStart = time.Now() } rw := gotsrpc.ResponseWriter{ResponseWriter: w} unionStructE := p.service.UnionStruct(&rw, r) - if callStats != nil { + if callStatsOk { callStats.Execution = time.Since(executionStart) } if rw.Status() == http.StatusOK {