mirror/wakapi
1
0
Fork 0
mirror of https://github.com/muety/wakapi.git synced 2023-08-10 21:12:56 +03:00
Code Issues Projects Releases Wiki Activity

fix: clear summary cache on new project label (resolve #369)

Browse Source
This commit is contained in:
Ferdinand Mütsch 2022-05-07 09:37:10 +02:00
parent 74a5226e73
commit a76db3e95f
1 changed files with 1 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
services/summary.go
View File

@ -2,7 +2,6 @@ package services
import ( import (
"errors" "errors"
"fmt"
"github.com/duke-git/lancet/v2/datetime" "github.com/duke-git/lancet/v2/datetime"
"github.com/emvi/logbuch" "github.com/emvi/logbuch"
"github.com/leandro-lugaresi/hub" "github.com/leandro-lugaresi/hub"
@ -41,12 +40,7 @@ func NewSummaryService(summaryRepo repositories.ISummaryRepository, durationServ
sub1 := srv.eventBus.Subscribe(0, config.TopicProjectLabel) sub1 := srv.eventBus.Subscribe(0, config.TopicProjectLabel)
go func(sub *hub.Subscription) { go func(sub *hub.Subscription) {
for m := range sub.Receiver { for m := range sub.Receiver {
userId := m.Fields[config.FieldUserId].(string) srv.invalidateUserCache(m.Fields[config.FieldUserId].(string))
for key := range srv.cache.Items() {
if strings.HasSuffix(key, fmt.Sprintf("__%s__--aliased", userId)) {
srv.cache.Delete(key)
}
}
} }
}(&sub1) }(&sub1)