Add comments to commit pages

models/activities/notification.go

@@ -9,6 +9,7 @@ import (
 	"net/url"
 	"strconv"
 
+	conversations_model "code.gitea.io/gitea/models/conversations"
 	"code.gitea.io/gitea/models/db"
 	issues_model "code.gitea.io/gitea/models/issues"
 	"code.gitea.io/gitea/models/organization"
@@ -159,6 +160,16 @@ func GetIssueNotification(ctx context.Context, userID, issueID int64) (*Notifica
 	return notification, err
 }
 
+// GetConversationNotification return the notification about an conversation
+func GetConversationNotification(ctx context.Context, userID, conversationID int64) (*Notification, error) {
+	notification := new(Notification)
+	_, err := db.GetEngine(ctx).
+		Where("user_id = ?", userID).
+		And("conversation_id = ?", conversationID).
+		Get(notification)
+	return notification, err
+}
+
 // LoadAttributes load Repo Issue User and Comment if not loaded
 func (n *Notification) LoadAttributes(ctx context.Context) (err error) {
 	if err = n.loadRepo(ctx); err != nil {
@@ -322,6 +333,32 @@ func setIssueNotificationStatusReadIfUnread(ctx context.Context, userID, issueID
 	return err
 }
 
+// SetConversationReadBy sets conversation to be read by given user.
+func SetConversationReadBy(ctx context.Context, conversationID, userID int64) error {
+	if err := conversations_model.UpdateConversationUserByRead(ctx, userID, conversationID); err != nil {
+		return err
+	}
+
+	return setConversationNotificationStatusReadIfUnread(ctx, userID, conversationID)
+}
+
+func setConversationNotificationStatusReadIfUnread(ctx context.Context, userID, conversationID int64) error {
+	notification, err := GetConversationNotification(ctx, userID, conversationID)
+	// ignore if not exists
+	if err != nil {
+		return nil
+	}
+
+	if notification.Status != NotificationStatusUnread {
+		return nil
+	}
+
+	notification.Status = NotificationStatusRead
+
+	_, err = db.GetEngine(ctx).ID(notification.ID).Cols("status").Update(notification)
+	return err
+}
+
 // SetRepoReadBy sets repo to be visited by given user.
 func SetRepoReadBy(ctx context.Context, userID, repoID int64) error {
 	_, err := db.GetEngine(ctx).Where(builder.Eq{