sevenhill/QSfera
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Handle events asynchronously (#6584)

Browse Source
This commit is contained in:
Andre Duffeck
2023-06-22 09:23:49 +02:00
committed by GitHub
parent 4f85efee84
commit 20252409ba
1 changed files with 39 additions and 36 deletions
Download Patch File Download Diff File Expand all files Collapse all files
services/search/pkg/search/events.go
+39 -36
View File
@@ -72,45 +72,48 @@ func HandleEvents(s Searcher, bus events.Consumer, logger log.Logger, cfg *confi
for i := 0; i < cfg.Events.NumConsumers; i++ { for i := 0; i < cfg.Events.NumConsumers; i++ {
go func(s Searcher, ch <-chan events.Event) { go func(s Searcher, ch <-chan events.Event) {
for e := range ch { for event := range ch {
logger.Debug().Interface("event", e).Msg("updating index") e := event
go func() {
logger.Debug().Interface("event", e).Msg("updating index")
var err error var err error
switch ev := e.Event.(type) { switch ev := e.Event.(type) {
case events.ItemTrashed: case events.ItemTrashed:
u := getUser(ev.SpaceOwner, ev.Executant) u := getUser(ev.SpaceOwner, ev.Executant)
s.TrashItem(ev.ID) s.TrashItem(ev.ID)
indexSpaceDebouncer.Debounce(getSpaceID(ev.Ref), u) indexSpaceDebouncer.Debounce(getSpaceID(ev.Ref), u)
case events.ItemMoved: case events.ItemMoved:
u := getUser(ev.SpaceOwner, ev.Executant) u := getUser(ev.SpaceOwner, ev.Executant)
s.MoveItem(ev.Ref, u) s.MoveItem(ev.Ref, u)
indexSpaceDebouncer.Debounce(getSpaceID(ev.Ref), getUser(ev.SpaceOwner, ev.Executant)) indexSpaceDebouncer.Debounce(getSpaceID(ev.Ref), getUser(ev.SpaceOwner, ev.Executant))
case events.ItemRestored: case events.ItemRestored:
u := getUser(ev.SpaceOwner, ev.Executant) u := getUser(ev.SpaceOwner, ev.Executant)
s.RestoreItem(ev.Ref, u) s.RestoreItem(ev.Ref, u)
indexSpaceDebouncer.Debounce(getSpaceID(ev.Ref), u) indexSpaceDebouncer.Debounce(getSpaceID(ev.Ref), u)
case events.ContainerCreated: case events.ContainerCreated:
indexSpaceDebouncer.Debounce(getSpaceID(ev.Ref), getUser(ev.SpaceOwner, ev.Executant)) indexSpaceDebouncer.Debounce(getSpaceID(ev.Ref), getUser(ev.SpaceOwner, ev.Executant))
case events.FileTouched: case events.FileTouched:
indexSpaceDebouncer.Debounce(getSpaceID(ev.Ref), getUser(ev.SpaceOwner, ev.Executant)) indexSpaceDebouncer.Debounce(getSpaceID(ev.Ref), getUser(ev.SpaceOwner, ev.Executant))
case events.FileVersionRestored: case events.FileVersionRestored:
indexSpaceDebouncer.Debounce(getSpaceID(ev.Ref), getUser(ev.SpaceOwner, ev.Executant)) indexSpaceDebouncer.Debounce(getSpaceID(ev.Ref), getUser(ev.SpaceOwner, ev.Executant))
case events.TagsAdded: case events.TagsAdded:
s.UpsertItem(ev.Ref, ev.Executant) s.UpsertItem(ev.Ref, ev.Executant)
case events.TagsRemoved: case events.TagsRemoved:
s.UpsertItem(ev.Ref, ev.Executant) s.UpsertItem(ev.Ref, ev.Executant)
case events.FileUploaded: case events.FileUploaded:
indexSpaceDebouncer.Debounce(getSpaceID(ev.Ref), getUser(ev.SpaceOwner, ev.Executant)) indexSpaceDebouncer.Debounce(getSpaceID(ev.Ref), getUser(ev.SpaceOwner, ev.Executant))
case events.UploadReady: case events.UploadReady:
indexSpaceDebouncer.Debounce(getSpaceID(ev.FileRef), getUser(ev.SpaceOwner, ev.ExecutingUser.Id)) indexSpaceDebouncer.Debounce(getSpaceID(ev.FileRef), getUser(ev.SpaceOwner, ev.ExecutingUser.Id))
case events.SpaceRenamed: case events.SpaceRenamed:
indexSpaceDebouncer.Debounce(ev.ID, getUser(ev.Executant)) indexSpaceDebouncer.Debounce(ev.ID, getUser(ev.Executant))
} }
if err != nil { if err != nil {
logger.Error().Err(err).Interface("event", e) logger.Error().Err(err).Interface("event", e)
} }
}()
} }
}( }(
s, s,