Commit48fc384

committed

protected user map on request with mutex

1 parent942437f commit48fc384Copy full SHA for 48fc384

File tree

-0

lines changed

-0

lines changed

Lines changed: 7 additions & 0 deletions

Original file line number	Diff line number	Diff line change
`@@ -4,6 +4,7 @@ import (`
`4`	`4`	`"context"`
`5`	`5`	`"fmt"`
`6`	`6`	`"net/http"`
	`7`	`+"sync"`
`7`	`8`	`"time"`
`8`	`9`
`9`	`10`	`"cdr.dev/slog"`
`@@ -71,6 +72,7 @@ type SlogRequestLogger struct {`
`71`	`72`	`writtenbool`
`72`	`73`	`messagestring`
`73`	`74`	`start time.Time`
	`75`	`+mu sync.RWMutex`
`74`	`76`	`actorsmap[rbac.SubjectType]rbac.Subject`
`75`	`77`	`}`
`76`	`78`
`@@ -91,10 +93,15 @@ func (c *SlogRequestLogger) WithFields(fields ...slog.Field) {`
`91`	`93`	`}`
`92`	`94`
`93`	`95`	`func (c*SlogRequestLogger)WithAuthContext(actor rbac.Subject) {`
	`96`	`+c.mu.Lock()`
	`97`	`+deferc.mu.Unlock()`
`94`	`98`	`c.actors[actor.Type]=actor`
`95`	`99`	`}`
`96`	`100`
`97`	`101`	`func (c*SlogRequestLogger)addAuthContextFields() {`
	`102`	`+c.mu.RLock()`
	`103`	`+deferc.mu.RUnlock()`
	`104`	`+`
`98`	`105`	`usr,ok:=c.actors[rbac.SubjectTypeUser]`
`99`	`106`	`ifok {`
`100`	`107`	`c.log=c.log.With(`

Comments

(0)