Refactor notification for indexer (#5111)

* notification for indexer

* use NullNotifier as parent struct

1 files changed, 62 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)
+}