123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561 |
- // Copyright 2022 The Gitea Authors. All rights reserved.
- // SPDX-License-Identifier: MIT
-
- package actions
-
- import (
- "context"
-
- "code.gitea.io/gitea/models/db"
- issues_model "code.gitea.io/gitea/models/issues"
- packages_model "code.gitea.io/gitea/models/packages"
- perm_model "code.gitea.io/gitea/models/perm"
- access_model "code.gitea.io/gitea/models/perm/access"
- repo_model "code.gitea.io/gitea/models/repo"
- user_model "code.gitea.io/gitea/models/user"
- "code.gitea.io/gitea/modules/git"
- "code.gitea.io/gitea/modules/log"
- "code.gitea.io/gitea/modules/notification/base"
- "code.gitea.io/gitea/modules/repository"
- "code.gitea.io/gitea/modules/setting"
- api "code.gitea.io/gitea/modules/structs"
- webhook_module "code.gitea.io/gitea/modules/webhook"
- "code.gitea.io/gitea/services/convert"
- )
-
- type actionsNotifier struct {
- base.NullNotifier
- }
-
- var _ base.Notifier = &actionsNotifier{}
-
- // NewNotifier create a new actionsNotifier notifier
- func NewNotifier() base.Notifier {
- return &actionsNotifier{}
- }
-
- // NotifyNewIssue notifies issue created event
- func (n *actionsNotifier) NotifyNewIssue(ctx context.Context, issue *issues_model.Issue, _ []*user_model.User) {
- ctx = withMethod(ctx, "NotifyNewIssue")
- if err := issue.LoadRepo(ctx); err != nil {
- log.Error("issue.LoadRepo: %v", err)
- return
- }
- if err := issue.LoadPoster(ctx); err != nil {
- log.Error("issue.LoadPoster: %v", err)
- return
- }
- mode, _ := access_model.AccessLevel(ctx, issue.Poster, issue.Repo)
-
- newNotifyInputFromIssue(issue, webhook_module.HookEventIssues).WithPayload(&api.IssuePayload{
- Action: api.HookIssueOpened,
- Index: issue.Index,
- Issue: convert.ToAPIIssue(ctx, issue),
- Repository: convert.ToRepo(ctx, issue.Repo, mode),
- Sender: convert.ToUser(ctx, issue.Poster, nil),
- }).Notify(withMethod(ctx, "NotifyNewIssue"))
- }
-
- // NotifyIssueChangeStatus notifies close or reopen issue to notifiers
- func (n *actionsNotifier) NotifyIssueChangeStatus(ctx context.Context, doer *user_model.User, commitID string, issue *issues_model.Issue, _ *issues_model.Comment, isClosed bool) {
- ctx = withMethod(ctx, "NotifyIssueChangeStatus")
- mode, _ := access_model.AccessLevel(ctx, issue.Poster, issue.Repo)
- if issue.IsPull {
- if err := issue.LoadPullRequest(ctx); err != nil {
- log.Error("LoadPullRequest: %v", err)
- return
- }
- // Merge pull request calls issue.changeStatus so we need to handle separately.
- apiPullRequest := &api.PullRequestPayload{
- Index: issue.Index,
- PullRequest: convert.ToAPIPullRequest(db.DefaultContext, issue.PullRequest, nil),
- Repository: convert.ToRepo(ctx, issue.Repo, mode),
- Sender: convert.ToUser(ctx, doer, nil),
- CommitID: commitID,
- }
- if isClosed {
- apiPullRequest.Action = api.HookIssueClosed
- } else {
- apiPullRequest.Action = api.HookIssueReOpened
- }
- newNotifyInputFromIssue(issue, webhook_module.HookEventPullRequest).
- WithDoer(doer).
- WithPayload(apiPullRequest).
- Notify(ctx)
- return
- }
- apiIssue := &api.IssuePayload{
- Index: issue.Index,
- Issue: convert.ToAPIIssue(ctx, issue),
- Repository: convert.ToRepo(ctx, issue.Repo, mode),
- Sender: convert.ToUser(ctx, doer, nil),
- }
- if isClosed {
- apiIssue.Action = api.HookIssueClosed
- } else {
- apiIssue.Action = api.HookIssueReOpened
- }
- newNotifyInputFromIssue(issue, webhook_module.HookEventIssues).
- WithDoer(doer).
- WithPayload(apiIssue).
- Notify(ctx)
- }
-
- func (n *actionsNotifier) NotifyIssueChangeLabels(ctx context.Context, doer *user_model.User, issue *issues_model.Issue,
- _, _ []*issues_model.Label,
- ) {
- ctx = withMethod(ctx, "NotifyIssueChangeLabels")
-
- var err error
- if err = issue.LoadRepo(ctx); err != nil {
- log.Error("LoadRepo: %v", err)
- return
- }
-
- if err = issue.LoadPoster(ctx); err != nil {
- log.Error("LoadPoster: %v", err)
- return
- }
-
- mode, _ := access_model.AccessLevel(ctx, issue.Poster, issue.Repo)
- if issue.IsPull {
- if err = issue.LoadPullRequest(ctx); err != nil {
- log.Error("loadPullRequest: %v", err)
- return
- }
- if err = issue.PullRequest.LoadIssue(ctx); err != nil {
- log.Error("LoadIssue: %v", err)
- return
- }
- newNotifyInputFromIssue(issue, webhook_module.HookEventPullRequestLabel).
- WithDoer(doer).
- WithPayload(&api.PullRequestPayload{
- Action: api.HookIssueLabelUpdated,
- Index: issue.Index,
- PullRequest: convert.ToAPIPullRequest(ctx, issue.PullRequest, nil),
- Repository: convert.ToRepo(ctx, issue.Repo, perm_model.AccessModeNone),
- Sender: convert.ToUser(ctx, doer, nil),
- }).
- Notify(ctx)
- return
- }
- newNotifyInputFromIssue(issue, webhook_module.HookEventIssueLabel).
- WithDoer(doer).
- WithPayload(&api.IssuePayload{
- Action: api.HookIssueLabelUpdated,
- Index: issue.Index,
- Issue: convert.ToAPIIssue(ctx, issue),
- Repository: convert.ToRepo(ctx, issue.Repo, mode),
- Sender: convert.ToUser(ctx, doer, nil),
- }).
- Notify(ctx)
- }
-
- // NotifyCreateIssueComment notifies comment on an issue to notifiers
- func (n *actionsNotifier) NotifyCreateIssueComment(ctx context.Context, doer *user_model.User, repo *repo_model.Repository,
- issue *issues_model.Issue, comment *issues_model.Comment, _ []*user_model.User,
- ) {
- ctx = withMethod(ctx, "NotifyCreateIssueComment")
-
- mode, _ := access_model.AccessLevel(ctx, doer, repo)
-
- if issue.IsPull {
- newNotifyInputFromIssue(issue, webhook_module.HookEventPullRequestComment).
- WithDoer(doer).
- WithPayload(&api.IssueCommentPayload{
- Action: api.HookIssueCommentCreated,
- Issue: convert.ToAPIIssue(ctx, issue),
- Comment: convert.ToComment(ctx, comment),
- Repository: convert.ToRepo(ctx, repo, mode),
- Sender: convert.ToUser(ctx, doer, nil),
- IsPull: true,
- }).
- Notify(ctx)
- return
- }
- newNotifyInputFromIssue(issue, webhook_module.HookEventIssueComment).
- WithDoer(doer).
- WithPayload(&api.IssueCommentPayload{
- Action: api.HookIssueCommentCreated,
- Issue: convert.ToAPIIssue(ctx, issue),
- Comment: convert.ToComment(ctx, comment),
- Repository: convert.ToRepo(ctx, repo, mode),
- Sender: convert.ToUser(ctx, doer, nil),
- IsPull: false,
- }).
- Notify(ctx)
- }
-
- func (n *actionsNotifier) NotifyNewPullRequest(ctx context.Context, pull *issues_model.PullRequest, _ []*user_model.User) {
- ctx = withMethod(ctx, "NotifyNewPullRequest")
-
- if err := pull.LoadIssue(ctx); err != nil {
- log.Error("pull.LoadIssue: %v", err)
- return
- }
- if err := pull.Issue.LoadRepo(ctx); err != nil {
- log.Error("pull.Issue.LoadRepo: %v", err)
- return
- }
- if err := pull.Issue.LoadPoster(ctx); err != nil {
- log.Error("pull.Issue.LoadPoster: %v", err)
- return
- }
-
- mode, _ := access_model.AccessLevel(ctx, pull.Issue.Poster, pull.Issue.Repo)
-
- newNotifyInputFromIssue(pull.Issue, webhook_module.HookEventPullRequest).
- WithPayload(&api.PullRequestPayload{
- Action: api.HookIssueOpened,
- Index: pull.Issue.Index,
- PullRequest: convert.ToAPIPullRequest(ctx, pull, nil),
- Repository: convert.ToRepo(ctx, pull.Issue.Repo, mode),
- Sender: convert.ToUser(ctx, pull.Issue.Poster, nil),
- }).
- WithPullRequest(pull).
- Notify(ctx)
- }
-
- func (n *actionsNotifier) NotifyCreateRepository(ctx context.Context, doer, u *user_model.User, repo *repo_model.Repository) {
- ctx = withMethod(ctx, "NotifyCreateRepository")
-
- newNotifyInput(repo, doer, webhook_module.HookEventRepository).WithPayload(&api.RepositoryPayload{
- Action: api.HookRepoCreated,
- Repository: convert.ToRepo(ctx, repo, perm_model.AccessModeOwner),
- Organization: convert.ToUser(ctx, u, nil),
- Sender: convert.ToUser(ctx, doer, nil),
- }).Notify(ctx)
- }
-
- func (n *actionsNotifier) NotifyForkRepository(ctx context.Context, doer *user_model.User, oldRepo, repo *repo_model.Repository) {
- ctx = withMethod(ctx, "NotifyForkRepository")
-
- oldMode, _ := access_model.AccessLevel(ctx, doer, oldRepo)
- mode, _ := access_model.AccessLevel(ctx, doer, repo)
-
- // forked webhook
- newNotifyInput(oldRepo, doer, webhook_module.HookEventFork).WithPayload(&api.ForkPayload{
- Forkee: convert.ToRepo(ctx, oldRepo, oldMode),
- Repo: convert.ToRepo(ctx, repo, mode),
- Sender: convert.ToUser(ctx, doer, nil),
- }).Notify(ctx)
-
- u := repo.MustOwner(ctx)
-
- // Add to hook queue for created repo after session commit.
- if u.IsOrganization() {
- newNotifyInput(repo, doer, webhook_module.HookEventRepository).
- WithRef(oldRepo.DefaultBranch).
- WithPayload(&api.RepositoryPayload{
- Action: api.HookRepoCreated,
- Repository: convert.ToRepo(ctx, repo, perm_model.AccessModeOwner),
- Organization: convert.ToUser(ctx, u, nil),
- Sender: convert.ToUser(ctx, doer, nil),
- }).Notify(ctx)
- }
- }
-
- func (n *actionsNotifier) NotifyPullRequestReview(ctx context.Context, pr *issues_model.PullRequest, review *issues_model.Review, _ *issues_model.Comment, _ []*user_model.User) {
- ctx = withMethod(ctx, "NotifyPullRequestReview")
-
- var reviewHookType webhook_module.HookEventType
-
- switch review.Type {
- case issues_model.ReviewTypeApprove:
- reviewHookType = webhook_module.HookEventPullRequestReviewApproved
- case issues_model.ReviewTypeComment:
- reviewHookType = webhook_module.HookEventPullRequestReviewComment
- case issues_model.ReviewTypeReject:
- reviewHookType = webhook_module.HookEventPullRequestReviewRejected
- default:
- // unsupported review webhook type here
- log.Error("Unsupported review webhook type")
- return
- }
-
- if err := pr.LoadIssue(ctx); err != nil {
- log.Error("pr.LoadIssue: %v", err)
- return
- }
-
- mode, err := access_model.AccessLevel(ctx, review.Issue.Poster, review.Issue.Repo)
- if err != nil {
- log.Error("models.AccessLevel: %v", err)
- return
- }
-
- newNotifyInput(review.Issue.Repo, review.Reviewer, reviewHookType).
- WithRef(review.CommitID).
- WithPayload(&api.PullRequestPayload{
- Action: api.HookIssueReviewed,
- Index: review.Issue.Index,
- PullRequest: convert.ToAPIPullRequest(db.DefaultContext, pr, nil),
- Repository: convert.ToRepo(ctx, review.Issue.Repo, mode),
- Sender: convert.ToUser(ctx, review.Reviewer, nil),
- Review: &api.ReviewPayload{
- Type: string(reviewHookType),
- Content: review.Content,
- },
- }).Notify(ctx)
- }
-
- func (*actionsNotifier) NotifyMergePullRequest(ctx context.Context, doer *user_model.User, pr *issues_model.PullRequest) {
- ctx = withMethod(ctx, "NotifyMergePullRequest")
-
- // Reload pull request information.
- if err := pr.LoadAttributes(ctx); err != nil {
- log.Error("LoadAttributes: %v", err)
- return
- }
-
- if err := pr.LoadIssue(ctx); err != nil {
- log.Error("LoadAttributes: %v", err)
- return
- }
-
- if err := pr.Issue.LoadRepo(db.DefaultContext); err != nil {
- log.Error("pr.Issue.LoadRepo: %v", err)
- return
- }
-
- mode, err := access_model.AccessLevel(ctx, doer, pr.Issue.Repo)
- if err != nil {
- log.Error("models.AccessLevel: %v", err)
- return
- }
-
- // Merge pull request calls issue.changeStatus so we need to handle separately.
- apiPullRequest := &api.PullRequestPayload{
- Index: pr.Issue.Index,
- PullRequest: convert.ToAPIPullRequest(db.DefaultContext, pr, nil),
- Repository: convert.ToRepo(ctx, pr.Issue.Repo, mode),
- Sender: convert.ToUser(ctx, doer, nil),
- Action: api.HookIssueClosed,
- }
-
- newNotifyInput(pr.Issue.Repo, doer, webhook_module.HookEventPullRequest).
- WithRef(pr.MergedCommitID).
- WithPayload(apiPullRequest).
- WithPullRequest(pr).
- Notify(ctx)
- }
-
- func (n *actionsNotifier) NotifyPushCommits(ctx context.Context, pusher *user_model.User, repo *repo_model.Repository, opts *repository.PushUpdateOptions, commits *repository.PushCommits) {
- ctx = withMethod(ctx, "NotifyPushCommits")
-
- apiPusher := convert.ToUser(ctx, pusher, nil)
- apiCommits, apiHeadCommit, err := commits.ToAPIPayloadCommits(ctx, repo.RepoPath(), repo.HTMLURL())
- if err != nil {
- log.Error("commits.ToAPIPayloadCommits failed: %v", err)
- return
- }
-
- newNotifyInput(repo, pusher, webhook_module.HookEventPush).
- WithRef(opts.RefFullName.String()).
- WithPayload(&api.PushPayload{
- Ref: opts.RefFullName.String(),
- Before: opts.OldCommitID,
- After: opts.NewCommitID,
- CompareURL: setting.AppURL + commits.CompareURL,
- Commits: apiCommits,
- HeadCommit: apiHeadCommit,
- Repo: convert.ToRepo(ctx, repo, perm_model.AccessModeOwner),
- Pusher: apiPusher,
- Sender: apiPusher,
- }).
- Notify(ctx)
- }
-
- func (n *actionsNotifier) NotifyCreateRef(ctx context.Context, pusher *user_model.User, repo *repo_model.Repository, refFullName git.RefName, refID string) {
- ctx = withMethod(ctx, "NotifyCreateRef")
-
- apiPusher := convert.ToUser(ctx, pusher, nil)
- apiRepo := convert.ToRepo(ctx, repo, perm_model.AccessModeNone)
-
- newNotifyInput(repo, pusher, webhook_module.HookEventCreate).
- WithRef(refFullName.ShortName()). // FIXME: should we use a full ref name
- WithPayload(&api.CreatePayload{
- Ref: refFullName.ShortName(),
- Sha: refID,
- RefType: refFullName.RefGroup(),
- Repo: apiRepo,
- Sender: apiPusher,
- }).
- Notify(ctx)
- }
-
- func (n *actionsNotifier) NotifyDeleteRef(ctx context.Context, pusher *user_model.User, repo *repo_model.Repository, refFullName git.RefName) {
- ctx = withMethod(ctx, "NotifyDeleteRef")
-
- apiPusher := convert.ToUser(ctx, pusher, nil)
- apiRepo := convert.ToRepo(ctx, repo, perm_model.AccessModeNone)
-
- newNotifyInput(repo, pusher, webhook_module.HookEventDelete).
- WithRef(refFullName.ShortName()). // FIXME: should we use a full ref name
- WithPayload(&api.DeletePayload{
- Ref: refFullName.ShortName(),
- RefType: refFullName.RefGroup(),
- PusherType: api.PusherTypeUser,
- Repo: apiRepo,
- Sender: apiPusher,
- }).
- Notify(ctx)
- }
-
- func (n *actionsNotifier) NotifySyncPushCommits(ctx context.Context, pusher *user_model.User, repo *repo_model.Repository, opts *repository.PushUpdateOptions, commits *repository.PushCommits) {
- ctx = withMethod(ctx, "NotifySyncPushCommits")
-
- apiPusher := convert.ToUser(ctx, pusher, nil)
- apiCommits, apiHeadCommit, err := commits.ToAPIPayloadCommits(db.DefaultContext, repo.RepoPath(), repo.HTMLURL())
- if err != nil {
- log.Error("commits.ToAPIPayloadCommits failed: %v", err)
- return
- }
-
- newNotifyInput(repo, pusher, webhook_module.HookEventPush).
- WithRef(opts.RefFullName.String()).
- WithPayload(&api.PushPayload{
- Ref: opts.RefFullName.String(),
- Before: opts.OldCommitID,
- After: opts.NewCommitID,
- CompareURL: setting.AppURL + commits.CompareURL,
- Commits: apiCommits,
- TotalCommits: commits.Len,
- HeadCommit: apiHeadCommit,
- Repo: convert.ToRepo(ctx, repo, perm_model.AccessModeOwner),
- Pusher: apiPusher,
- Sender: apiPusher,
- }).
- Notify(ctx)
- }
-
- func (n *actionsNotifier) NotifySyncCreateRef(ctx context.Context, pusher *user_model.User, repo *repo_model.Repository, refFullName git.RefName, refID string) {
- ctx = withMethod(ctx, "NotifySyncCreateRef")
- n.NotifyCreateRef(ctx, pusher, repo, refFullName, refID)
- }
-
- func (n *actionsNotifier) NotifySyncDeleteRef(ctx context.Context, pusher *user_model.User, repo *repo_model.Repository, refFullName git.RefName) {
- ctx = withMethod(ctx, "NotifySyncDeleteRef")
- n.NotifyDeleteRef(ctx, pusher, repo, refFullName)
- }
-
- func (n *actionsNotifier) NotifyNewRelease(ctx context.Context, rel *repo_model.Release) {
- ctx = withMethod(ctx, "NotifyNewRelease")
- notifyRelease(ctx, rel.Publisher, rel, api.HookReleasePublished)
- }
-
- func (n *actionsNotifier) NotifyUpdateRelease(ctx context.Context, doer *user_model.User, rel *repo_model.Release) {
- ctx = withMethod(ctx, "NotifyUpdateRelease")
- notifyRelease(ctx, doer, rel, api.HookReleaseUpdated)
- }
-
- func (n *actionsNotifier) NotifyDeleteRelease(ctx context.Context, doer *user_model.User, rel *repo_model.Release) {
- ctx = withMethod(ctx, "NotifyDeleteRelease")
- notifyRelease(ctx, doer, rel, api.HookReleaseDeleted)
- }
-
- func (n *actionsNotifier) NotifyPackageCreate(ctx context.Context, doer *user_model.User, pd *packages_model.PackageDescriptor) {
- ctx = withMethod(ctx, "NotifyPackageCreate")
- notifyPackage(ctx, doer, pd, api.HookPackageCreated)
- }
-
- func (n *actionsNotifier) NotifyPackageDelete(ctx context.Context, doer *user_model.User, pd *packages_model.PackageDescriptor) {
- ctx = withMethod(ctx, "NotifyPackageDelete")
- notifyPackage(ctx, doer, pd, api.HookPackageDeleted)
- }
-
- func (n *actionsNotifier) NotifyAutoMergePullRequest(ctx context.Context, doer *user_model.User, pr *issues_model.PullRequest) {
- ctx = withMethod(ctx, "NotifyAutoMergePullRequest")
- n.NotifyMergePullRequest(ctx, doer, pr)
- }
-
- func (n *actionsNotifier) NotifyPullRequestSynchronized(ctx context.Context, doer *user_model.User, pr *issues_model.PullRequest) {
- ctx = withMethod(ctx, "NotifyPullRequestSynchronized")
-
- if err := pr.LoadIssue(ctx); err != nil {
- log.Error("LoadAttributes: %v", err)
- return
- }
-
- if err := pr.Issue.LoadRepo(db.DefaultContext); err != nil {
- log.Error("pr.Issue.LoadRepo: %v", err)
- return
- }
-
- newNotifyInput(pr.Issue.Repo, doer, webhook_module.HookEventPullRequestSync).
- WithPayload(&api.PullRequestPayload{
- Action: api.HookIssueSynchronized,
- Index: pr.Issue.Index,
- PullRequest: convert.ToAPIPullRequest(ctx, pr, nil),
- Repository: convert.ToRepo(ctx, pr.Issue.Repo, perm_model.AccessModeNone),
- Sender: convert.ToUser(ctx, doer, nil),
- }).
- WithPullRequest(pr).
- Notify(ctx)
- }
-
- func (n *actionsNotifier) NotifyPullRequestChangeTargetBranch(ctx context.Context, doer *user_model.User, pr *issues_model.PullRequest, oldBranch string) {
- ctx = withMethod(ctx, "NotifyPullRequestChangeTargetBranch")
-
- if err := pr.LoadIssue(ctx); err != nil {
- log.Error("LoadAttributes: %v", err)
- return
- }
-
- if err := pr.Issue.LoadRepo(db.DefaultContext); err != nil {
- log.Error("pr.Issue.LoadRepo: %v", err)
- return
- }
-
- mode, _ := access_model.AccessLevel(ctx, pr.Issue.Poster, pr.Issue.Repo)
- newNotifyInput(pr.Issue.Repo, doer, webhook_module.HookEventPullRequest).
- WithPayload(&api.PullRequestPayload{
- Action: api.HookIssueEdited,
- Index: pr.Issue.Index,
- Changes: &api.ChangesPayload{
- Ref: &api.ChangesFromPayload{
- From: oldBranch,
- },
- },
- PullRequest: convert.ToAPIPullRequest(ctx, pr, nil),
- Repository: convert.ToRepo(ctx, pr.Issue.Repo, mode),
- Sender: convert.ToUser(ctx, doer, nil),
- }).
- WithPullRequest(pr).
- Notify(ctx)
- }
-
- func (n *actionsNotifier) NotifyNewWikiPage(ctx context.Context, doer *user_model.User, repo *repo_model.Repository, page, comment string) {
- ctx = withMethod(ctx, "NotifyNewWikiPage")
-
- newNotifyInput(repo, doer, webhook_module.HookEventWiki).WithPayload(&api.WikiPayload{
- Action: api.HookWikiCreated,
- Repository: convert.ToRepo(ctx, repo, perm_model.AccessModeOwner),
- Sender: convert.ToUser(ctx, doer, nil),
- Page: page,
- Comment: comment,
- }).Notify(ctx)
- }
-
- func (n *actionsNotifier) NotifyEditWikiPage(ctx context.Context, doer *user_model.User, repo *repo_model.Repository, page, comment string) {
- ctx = withMethod(ctx, "NotifyEditWikiPage")
-
- newNotifyInput(repo, doer, webhook_module.HookEventWiki).WithPayload(&api.WikiPayload{
- Action: api.HookWikiEdited,
- Repository: convert.ToRepo(ctx, repo, perm_model.AccessModeOwner),
- Sender: convert.ToUser(ctx, doer, nil),
- Page: page,
- Comment: comment,
- }).Notify(ctx)
- }
-
- func (n *actionsNotifier) NotifyDeleteWikiPage(ctx context.Context, doer *user_model.User, repo *repo_model.Repository, page string) {
- ctx = withMethod(ctx, "NotifyDeleteWikiPage")
-
- newNotifyInput(repo, doer, webhook_module.HookEventWiki).WithPayload(&api.WikiPayload{
- Action: api.HookWikiDeleted,
- Repository: convert.ToRepo(ctx, repo, perm_model.AccessModeOwner),
- Sender: convert.ToUser(ctx, doer, nil),
- Page: page,
- }).Notify(ctx)
- }
|