dkforest

commit 0bbff11e7106f33e5d23f89cac88eadda3363c65
parent 1cca9382e5cee9560331edc3f5578dd5f4afae7d
Author: n0tr1v <n0tr1v@protonmail.com>
Date:   Mon, 22 May 2023 21:46:59 -0700

force refresh on HB/un-HB/purge

Diffstat:
M
pkg/database/tableUsers.go
 | 
2
++
M
pkg/web/handlers/api/v1/slashInterceptor.go
 | 
1
+

2 files changed, 3 insertions(+), 0 deletions(-)
diff --git a/pkg/database/tableUsers.go b/pkg/database/tableUsers.go
@@ -272,6 +272,7 @@ func (u *User) HellBan(db *DkfDB) {
 	if err := db.db.Model(&ChatMessage{}).Where("user_id = ?", u.ID).Update("is_hellbanned", true).Error; err != nil {
 		logrus.Error(err)
 	}
+	MsgPubSub.Pub("refresh", ChatMessageType{Typ: ForceRefresh})
 }
 
 func (u *User) UnHellBan(db *DkfDB) {
@@ -280,6 +281,7 @@ func (u *User) UnHellBan(db *DkfDB) {
 	if err := db.db.Model(&ChatMessage{}).Where("user_id = ?", u.ID).Update("is_hellbanned", false).Error; err != nil {
 		logrus.Error(err)
 	}
+	MsgPubSub.Pub("refresh", ChatMessageType{Typ: ForceRefresh})
 }
 
 // GetUserBySessionKey ...
diff --git a/pkg/web/handlers/api/v1/slashInterceptor.go b/pkg/web/handlers/api/v1/slashInterceptor.go
@@ -1569,6 +1569,7 @@ func handlePurge(c *Command) (handled bool) {
 		}
 		c.db.NewAudit(*c.authUser, fmt.Sprintf("purge %s #%d", user.Username, user.ID))
 		_ = c.db.DeleteUserChatMessages(user.ID)
+		database.MsgPubSub.Pub("refresh", database.ChatMessageType{Typ: database.ForceRefresh})
 		c.err = ErrRedirect
 		return true
 	}