+22

appview/db/notifications.go

Reviewed

··· 331 331 return nil 332 332 } 333 333 334 334 + func MarkNotificationsReadForIssue(e Execer, userDID, repoDid string, issueNum int) error { 335 335 + query := ` 336 336 + update notifications set read = 1 337 337 + where recipient_did = ? 338 338 + and read = 0 339 339 + and issue_id = (select id from issues where repo_did = ? and issue_id = ?) 340 340 + ` 341 341 + _, err := e.Exec(query, userDID, repoDid, issueNum) 342 342 + return err 343 343 + } 344 344 + 345 345 + func MarkNotificationsReadForPull(e Execer, userDID, repoDid string, pullNum int) error { 346 346 + query := ` 347 347 + update notifications set read = 1 348 348 + where recipient_did = ? 349 349 + and read = 0 350 350 + and pull_id = (select p.id from pulls p where p.pull_id = ? and p.repo_did = ?) 351 351 + ` 352 352 + _, err := e.Exec(query, userDID, pullNum, repoDid) 353 353 + return err 354 354 + } 355 355 + 334 356 func MarkNotificationUnread(e Execer, notificationID int64, userDID string) error { 335 357 idFilter := orm.FilterEq("id", notificationID) 336 358 recipientFilter := orm.FilterEq("recipient_did", userDID)

+11

appview/issues/issues.go

Reviewed

··· 99 99 return 100 100 } 101 101 102 102 + if user != nil { 103 103 + repoDid := f.RepoDid 104 104 + userDid := user.Did 105 105 + issueId := issue.IssueId 106 106 + go func() { 107 107 + if err := db.MarkNotificationsReadForIssue(rp.db, userDid, repoDid, issueId); err != nil { 108 108 + l.Error("failed to mark issue notifications as read", "err", err) 109 109 + } 110 110 + }() 111 111 + } 112 112 + 102 113 entities := []syntax.ATURI{issue.AtUri()} 103 114 for _, c := range issue.Comments { 104 115 entities = append(entities, c.FeedCommentAtUri())

+11

appview/pulls/single.go

Reviewed

··· 102 102 } 103 103 l = l.With("pull_id", pull.PullId, "pull_owner", pull.OwnerDid) 104 104 105 105 + if user != nil { 106 106 + repoDid := f.RepoDid 107 107 + userDid := user.Did 108 108 + pullId := pull.PullId 109 109 + go func() { 110 110 + if err := db.MarkNotificationsReadForPull(s.db, userDid, repoDid, pullId); err != nil { 111 111 + l.Error("failed to mark pull notifications as read", "err", err) 112 112 + } 113 113 + }() 114 114 + } 115 115 + 105 116 backlinks, err := db.GetBacklinks(s.db, pull.AtUri()) 106 117 if err != nil { 107 118 l.Error("failed to get pull backlinks", "err", err)