From 9aec4fba38db10af2e1e87531c4d85563748fce7 Mon Sep 17 00:00:00 2001
From: Michael Li <alimy@gility.net>
Date: Sun, 24 Sep 2023 19:51:03 +0800
Subject: [PATCH] fixed not expire messages cache after follow user

---
 internal/servants/web/events.go     | 4 +++-
 internal/servants/web/followship.go | 1 +
 2 files changed, 4 insertions(+), 1 deletion(-)

diff --git a/internal/servants/web/events.go b/internal/servants/web/events.go
index 8a8c3f0d..1dc430cd 100644
--- a/internal/servants/web/events.go
+++ b/internal/servants/web/events.go
@@ -33,6 +33,7 @@ const (
 const (
 	_messageActionCreate uint8 = iota
 	_messageActionRead
+	_messageActionFollow
 )
 
 type cacheUnreadMsgEvent struct {
@@ -200,7 +201,8 @@ func (e *messageActionEvent) Action() (err error) {
 		case _messageActionRead:
 			// 清除未读消息数缓存，不需要处理错误
 			e.wc.DelUnreadMsgCountResp(userId)
-		case _messageActionCreate:
+		case _messageActionCreate,
+			_messageActionFollow:
 			fallthrough
 		default:
 			// TODO
diff --git a/internal/servants/web/followship.go b/internal/servants/web/followship.go
index d9786d2a..1baef23c 100644
--- a/internal/servants/web/followship.go
+++ b/internal/servants/web/followship.go
@@ -104,6 +104,7 @@ func (s *followshipSrv) FollowUser(r *web.FollowUserReq) mir.Error {
 	// 触发缓存更新事件
 	cache.OnCacheMyFollowIdsEvent(s.Ds, r.User.ID)
 	cache.OnExpireIndexTweetEvent(r.User.ID)
+	onMessageActionEvent(_messageActionFollow, r.User.ID)
 	return nil
 }