foomo/keel
1
0
Fork 0
mirror of https://github.com/foomo/keel.git synced 2025-10-16 12:35:34 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

feat: handle error

Browse Source
This commit is contained in:
franklin 2023-08-14 08:47:25 +02:00
parent dd8b12577e
commit c5040533e7
1 changed files with 8 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
integration/gotsrpc/net/middleware/telemetry.go
View File

@ -158,21 +158,26 @@ func TelemetryWithOptions(opts TelemetryOptions) middleware.Middleware {
}
observer.Observe(duration.Seconds())
}
sanitizePayload := func(r *http.Request) string {
if r.Method != http.MethodPost {
return ""
}
bodyBytes, _ := io.ReadAll(r.Body)
body, err := io.ReadAll(r.Body)
if err != nil {
return ""
}
if err := r.Body.Close(); err != nil {
return ""
}
r.Body = io.NopCloser(bytes.NewBuffer(bodyBytes))
b, err := bson.MarshalExtJSON(bodyBytes, false, false)
r.Body = io.NopCloser(bytes.NewBuffer(body))
b, err := bson.MarshalExtJSON(body, false, false)
if err != nil {
return ""
}
return string(b)
}
return func(l *zap.Logger, name string, next http.Handler) http.Handler {
return http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
ctx, span := telemetry.Start(r.Context(), "GOTSRPC")