From a7c28dc4634f3a31e36e4992842471edcfa14699 Mon Sep 17 00:00:00 2001
From: ychao_1983 <ychao_1983@sina.com>
Date: Tue, 18 Jan 2022 10:16:15 +0800
Subject: [PATCH] fix-1365

---
 models/repo_watch.go                 | 5 ++++-
 services/socketwrap/clientManager.go | 1 +
 2 files changed, 5 insertions(+), 1 deletion(-)

diff --git a/models/repo_watch.go b/models/repo_watch.go
index 85a7834bb..31868fcae 100644
--- a/models/repo_watch.go
+++ b/models/repo_watch.go
@@ -305,7 +305,10 @@ func NotifyWatchersActions(acts []*Action) error {
 			return err
 		}
 	}
-	return sess.Commit()
+
+	err := sess.Commit()
+	producer(acts...)
+	return err
 }
 
 func watchIfAuto(e Engine, userID, repoID int64, isWrite bool) error {
diff --git a/services/socketwrap/clientManager.go b/services/socketwrap/clientManager.go
index c59936581..601c0f7a8 100644
--- a/services/socketwrap/clientManager.go
+++ b/services/socketwrap/clientManager.go
@@ -50,6 +50,7 @@ func (h *ClientsManager) Run() {
 			}
 		case message := <-models.ActionChan:
 			if isInOpTypes(opTypes, message.OpType) {
+				message.Comment = nil
 				LastActionsQueue.Push(message)
 				for _, client := range h.Clients.Keys() {
 					select {