diff options
Diffstat (limited to 'modules/notification')
-rw-r--r-- | modules/notification/indexer/indexer.go | 62 | ||||
-rw-r--r-- | modules/notification/notification.go | 2 |
2 files changed, 64 insertions, 0 deletions
diff --git a/modules/notification/indexer/indexer.go b/modules/notification/indexer/indexer.go new file mode 100644 index 0000000000..3fd3352188 --- /dev/null +++ b/modules/notification/indexer/indexer.go @@ -0,0 +1,62 @@ +// Copyright 2019 The Gitea Authors. All rights reserved. +// Use of this source code is governed by a MIT-style +// license that can be found in the LICENSE file. + +package indexer + +import ( + "code.gitea.io/gitea/models" + "code.gitea.io/gitea/modules/notification/base" +) + +type indexerNotifier struct { + base.NullNotifier +} + +var ( + _ base.Notifier = &indexerNotifier{} +) + +// NewNotifier create a new indexerNotifier notifier +func NewNotifier() base.Notifier { + return &indexerNotifier{} +} + +func (r *indexerNotifier) NotifyCreateIssueComment(doer *models.User, repo *models.Repository, + issue *models.Issue, comment *models.Comment) { + if comment.Type == models.CommentTypeComment { + models.UpdateIssueIndexer(issue.ID) + } +} + +func (r *indexerNotifier) NotifyNewIssue(issue *models.Issue) { + models.UpdateIssueIndexer(issue.ID) +} + +func (r *indexerNotifier) NotifyNewPullRequest(pr *models.PullRequest) { + models.UpdateIssueIndexer(pr.Issue.ID) +} + +func (r *indexerNotifier) NotifyUpdateComment(doer *models.User, c *models.Comment, oldContent string) { + if c.Type == models.CommentTypeComment { + models.UpdateIssueIndexer(c.IssueID) + } +} + +func (r *indexerNotifier) NotifyDeleteComment(doer *models.User, comment *models.Comment) { + if comment.Type == models.CommentTypeComment { + models.UpdateIssueIndexer(comment.IssueID) + } +} + +func (r *indexerNotifier) NotifyDeleteRepository(doer *models.User, repo *models.Repository) { + models.DeleteRepoFromIndexer(repo) +} + +func (r *indexerNotifier) NotifyIssueChangeContent(doer *models.User, issue *models.Issue, oldContent string) { + models.UpdateIssueIndexer(issue.ID) +} + +func (r *indexerNotifier) NotifyIssueChangeTitle(doer *models.User, issue *models.Issue, oldTitle string) { + models.UpdateIssueIndexer(issue.ID) +} diff --git a/modules/notification/notification.go b/modules/notification/notification.go index 6f482e8819..e38c36f7dd 100644 --- a/modules/notification/notification.go +++ b/modules/notification/notification.go @@ -8,6 +8,7 @@ import ( "code.gitea.io/git" "code.gitea.io/gitea/models" "code.gitea.io/gitea/modules/notification/base" + "code.gitea.io/gitea/modules/notification/indexer" "code.gitea.io/gitea/modules/notification/mail" "code.gitea.io/gitea/modules/notification/ui" ) @@ -25,6 +26,7 @@ func RegisterNotifier(notifier base.Notifier) { func init() { RegisterNotifier(ui.NewNotifier()) RegisterNotifier(mail.NewNotifier()) + RegisterNotifier(indexer.NewNotifier()) } // NotifyCreateIssueComment notifies issue comment related message to notifiers |