forked from mirror/logrus
Fix entity data bleed when using WithContext and WithTime
Creates a copy of the data map when using WithContext to create a child entity. Without this, the data map of the parent entitiy, which is exposed in the entity struct, is shared between a parent and all children instances. This can create bugs of shared or overwritten data when a parent entity is used to make children in differing contexts, and behaves differently than `WithField` and its diritivites which does make a copy of the data. Additionally implements the same logic for WithTime, for API consistency in behavior.
This commit is contained in:
parent
67a7fdcf74
commit
bcc146f96b
12
entry.go
12
entry.go
|
@ -103,7 +103,11 @@ func (entry *Entry) WithError(err error) *Entry {
|
||||||
|
|
||||||
// Add a context to the Entry.
|
// Add a context to the Entry.
|
||||||
func (entry *Entry) WithContext(ctx context.Context) *Entry {
|
func (entry *Entry) WithContext(ctx context.Context) *Entry {
|
||||||
return &Entry{Logger: entry.Logger, Data: entry.Data, Time: entry.Time, err: entry.err, Context: ctx}
|
dataCopy := make(Fields, len(entry.Data))
|
||||||
|
for k, v := range entry.Data {
|
||||||
|
dataCopy[k] = v
|
||||||
|
}
|
||||||
|
return &Entry{Logger: entry.Logger, Data: dataCopy, Time: entry.Time, err: entry.err, Context: ctx}
|
||||||
}
|
}
|
||||||
|
|
||||||
// Add a single field to the Entry.
|
// Add a single field to the Entry.
|
||||||
|
@ -144,7 +148,11 @@ func (entry *Entry) WithFields(fields Fields) *Entry {
|
||||||
|
|
||||||
// Overrides the time of the Entry.
|
// Overrides the time of the Entry.
|
||||||
func (entry *Entry) WithTime(t time.Time) *Entry {
|
func (entry *Entry) WithTime(t time.Time) *Entry {
|
||||||
return &Entry{Logger: entry.Logger, Data: entry.Data, Time: t, err: entry.err, Context: entry.Context}
|
dataCopy := make(Fields, len(entry.Data))
|
||||||
|
for k, v := range entry.Data {
|
||||||
|
dataCopy[k] = v
|
||||||
|
}
|
||||||
|
return &Entry{Logger: entry.Logger, Data: dataCopy, Time: t, err: entry.err, Context: entry.Context}
|
||||||
}
|
}
|
||||||
|
|
||||||
// getPackageName reduces a fully qualified function name to the package name
|
// getPackageName reduces a fully qualified function name to the package name
|
||||||
|
|
|
@ -47,6 +47,34 @@ func TestEntryWithContext(t *testing.T) {
|
||||||
assert.Equal(ctx, entry.WithContext(ctx).Context)
|
assert.Equal(ctx, entry.WithContext(ctx).Context)
|
||||||
}
|
}
|
||||||
|
|
||||||
|
func TestEntryWithContextCopiesData(t *testing.T) {
|
||||||
|
assert := assert.New(t)
|
||||||
|
ctx1 := context.WithValue(context.Background(), "foo", "bar")
|
||||||
|
ctx2 := context.WithValue(context.Background(), "bar", "baz")
|
||||||
|
assert.NotEqual(ctx1, ctx2)
|
||||||
|
|
||||||
|
logger := New()
|
||||||
|
logger.Out = &bytes.Buffer{}
|
||||||
|
parentEntry := NewEntry(logger).WithField("parentKey", "parentValue")
|
||||||
|
childEntry1 := parentEntry.WithContext(ctx1)
|
||||||
|
assert.Equal(ctx1, childEntry1.Context)
|
||||||
|
childEntry2 := parentEntry.WithContext(ctx2)
|
||||||
|
assert.Equal(ctx2, childEntry2.Context)
|
||||||
|
assert.NotEqual(ctx1, ctx2)
|
||||||
|
assert.Equal("parentValue", childEntry1.Data["parentKey"])
|
||||||
|
assert.Equal("parentValue", childEntry2.Data["parentKey"])
|
||||||
|
|
||||||
|
childEntry1.Data["ChildKeyValue1"] = "ChildDataValue1"
|
||||||
|
|
||||||
|
val, exists := childEntry1.Data["ChildKeyValue1"]
|
||||||
|
assert.True(exists)
|
||||||
|
assert.Equal("ChildDataValue1", val)
|
||||||
|
|
||||||
|
val, exists = childEntry2.Data["ChildKeyValue1"]
|
||||||
|
assert.False(exists)
|
||||||
|
assert.Empty(val)
|
||||||
|
}
|
||||||
|
|
||||||
func TestEntryPanicln(t *testing.T) {
|
func TestEntryPanicln(t *testing.T) {
|
||||||
errBoom := fmt.Errorf("boom time")
|
errBoom := fmt.Errorf("boom time")
|
||||||
|
|
||||||
|
|
Loading…
Reference in New Issue