Merge pull request #1188 from smallstep/herman/fix-stack-trace-error-logging-panos

Merge log.Error tests
This commit is contained in:
Herman Slatman 2022-11-17 23:28:48 +01:00 committed by GitHub
commit 36da484604
No known key found for this signature in database
GPG key ID: 4AEE18F83AFDEB23
2 changed files with 52 additions and 80 deletions

View file

@ -7,8 +7,6 @@ import (
"os" "os"
"github.com/pkg/errors" "github.com/pkg/errors"
"github.com/smallstep/certificates/logging"
) )
// StackTracedError is the set of errors implementing the StackTrace function. // StackTracedError is the set of errors implementing the StackTrace function.
@ -21,16 +19,20 @@ type StackTracedError interface {
StackTrace() errors.StackTrace StackTrace() errors.StackTrace
} }
type fieldCarrier interface {
WithFields(map[string]any)
}
// Error adds to the response writer the given error if it implements // Error adds to the response writer the given error if it implements
// logging.ResponseLogger. If it does not implement it, then writes the error // logging.ResponseLogger. If it does not implement it, then writes the error
// using the log package. // using the log package.
func Error(rw http.ResponseWriter, err error) { func Error(rw http.ResponseWriter, err error) {
rl, ok := rw.(logging.ResponseLogger) fc, ok := rw.(fieldCarrier)
if !ok { if !ok {
return return
} }
rl.WithFields(map[string]interface{}{ fc.WithFields(map[string]any{
"error": err, "error": err,
}) })
@ -40,7 +42,7 @@ func Error(rw http.ResponseWriter, err error) {
var st StackTracedError var st StackTracedError
if errors.As(err, &st) { if errors.As(err, &st) {
rl.WithFields(map[string]interface{}{ fc.WithFields(map[string]any{
"stack-trace": fmt.Sprintf("%+v", st.StackTrace()), "stack-trace": fmt.Sprintf("%+v", st.StackTrace()),
}) })
} }
@ -48,9 +50,9 @@ func Error(rw http.ResponseWriter, err error) {
// EnabledResponse log the response object if it implements the EnableLogger // EnabledResponse log the response object if it implements the EnableLogger
// interface. // interface.
func EnabledResponse(rw http.ResponseWriter, v interface{}) { func EnabledResponse(rw http.ResponseWriter, v any) {
type enableLogger interface { type enableLogger interface {
ToLog() (interface{}, error) ToLog() (any, error)
} }
if el, ok := v.(enableLogger); ok { if el, ok := v.(enableLogger); ok {
@ -61,8 +63,8 @@ func EnabledResponse(rw http.ResponseWriter, v interface{}) {
return return
} }
if rl, ok := rw.(logging.ResponseLogger); ok { if rl, ok := rw.(fieldCarrier); ok {
rl.WithFields(map[string]interface{}{ rl.WithFields(map[string]any{
"response": out, "response": out,
}) })
} }

View file

@ -1,102 +1,72 @@
package log package log
import ( import (
"errors"
"net/http"
"net/http/httptest" "net/http/httptest"
"strconv"
"testing" "testing"
"unsafe" "unsafe"
pkgerrors "github.com/pkg/errors" pkgerrors "github.com/pkg/errors"
"github.com/stretchr/testify/assert"
"github.com/smallstep/certificates/logging" "github.com/smallstep/certificates/logging"
) )
func TestError(t *testing.T) { func TestError(t *testing.T) {
cases := []struct {
t.Setenv("STEPDEBUG", "1") // force to end of `Error` function instead of early return error
theError := errors.New("the error") stepDebug bool
expectStackTrace bool
type args struct {
rw http.ResponseWriter
err error
}
tests := []struct {
name string
args args
withFields bool
want string
}{ }{
{"normalLogger", args{httptest.NewRecorder(), theError}, false, "the error"}, 0: {nil, false, false},
{"responseLogger", args{logging.NewResponseLogger(httptest.NewRecorder()), theError}, true, "the error"}, 1: {nil, true, false},
2: {assert.AnError, false, false},
3: {assert.AnError, true, false},
4: {new(stackTracedError), false, false},
5: {new(stackTracedError), true, true},
} }
for _, tt := range tests { for caseIndex := range cases {
t.Run(tt.name, func(t *testing.T) { kase := cases[caseIndex]
Error(tt.args.rw, tt.args.err)
if tt.withFields { t.Run(strconv.Itoa(caseIndex), func(t *testing.T) {
if rl, ok := tt.args.rw.(logging.ResponseLogger); ok { if kase.stepDebug {
fields := rl.Fields() t.Setenv("STEPDEBUG", "1")
if fields["error"].(error).Error() != tt.want {
t.Errorf(`ResponseLogger["error"] = %s, wants %s`, fields["error"], tt.want)
}
} else { } else {
t.Error("ResponseWriter does not implement logging.ResponseLogger") t.Setenv("STEPDEBUG", "0")
} }
rw := logging.NewResponseLogger(httptest.NewRecorder())
Error(rw, kase.error)
fields := rw.Fields()
// expect the error field to be set and to be the same error that was fed to Error
if kase.error == nil {
assert.Nil(t, fields["error"])
} else {
assert.Same(t, kase.error, fields["error"])
}
if _, hasStackTrace := fields["stack-trace"]; kase.expectStackTrace && !hasStackTrace {
t.Error("stack-trace was not set")
} else if !kase.expectStackTrace && hasStackTrace {
t.Error("stack-trace was set")
} }
}) })
} }
} }
type mockStackTracedError struct{} type stackTracedError struct{}
func (t *mockStackTracedError) Error() string { func (stackTracedError) Error() string {
return "a stacktraced error" return "a stacktraced error"
} }
func (t *mockStackTracedError) StackTrace() pkgerrors.StackTrace { func (stackTracedError) StackTrace() pkgerrors.StackTrace {
f := struct{}{} f := struct{}{}
return pkgerrors.StackTrace{ // fake stacktrace return pkgerrors.StackTrace{ // fake stacktrace
pkgerrors.Frame(unsafe.Pointer(&f)), pkgerrors.Frame(unsafe.Pointer(&f)),
pkgerrors.Frame(unsafe.Pointer(&f)), pkgerrors.Frame(unsafe.Pointer(&f)),
} }
} }
func TestError_StackTracedError(t *testing.T) {
t.Setenv("STEPDEBUG", "1")
aStackTracedError := mockStackTracedError{}
type args struct {
rw http.ResponseWriter
err error
}
tests := []struct {
name string
args args
withFields bool
want string
}{
{"responseLoggerWithStackTracedError", args{logging.NewResponseLogger(httptest.NewRecorder()), &aStackTracedError}, true, "a stacktraced error"},
}
for _, tt := range tests {
t.Run(tt.name, func(t *testing.T) {
Error(tt.args.rw, tt.args.err)
if tt.withFields {
if rl, ok := tt.args.rw.(logging.ResponseLogger); ok {
fields := rl.Fields()
if fields["error"].(error).Error() != tt.want {
t.Errorf(`ResponseLogger["error"] = %s, wants %s`, fields["error"], tt.want)
}
// `stack-trace` expected to be set; not interested in actual output
if _, ok := fields["stack-trace"]; !ok {
t.Errorf(`ResponseLogger["stack-trace"] not set`)
}
} else {
t.Error("ResponseWriter does not implement logging.ResponseLogger")
}
}
})
}
}