diff --git a/internal/storage/search.go b/internal/storage/search.go index 1380798..fc46025 100644 --- a/internal/storage/search.go +++ b/internal/storage/search.go @@ -13,6 +13,7 @@ import ( "github.com/araddon/dateparse" "github.com/axllent/mailpit/internal/logger" "github.com/axllent/mailpit/internal/tools" + "github.com/axllent/mailpit/server/websockets" "github.com/leporo/sqlf" ) @@ -201,6 +202,18 @@ func DeleteSearch(search, timezone string) error { dbLastAction = time.Now() + // broadcast changes + if len(ids) > 200 { + websockets.Broadcast("prune", nil) + } else { + for _, id := range ids { + d := struct { + ID string + }{ID: id} + websockets.Broadcast("delete", d) + } + } + addDeletedSize(int64(deleteSize)) logMessagesDeleted(total)