aboutsummaryrefslogtreecommitdiffstats
path: root/src/libutil/regexp.c
Commit message (Collapse)AuthorAgeFilesLines
* [Rework] Replace fastutf with simdutfVsevolod Stakhov2024-11-291-1/+1
| | | | | | Simdutf is faster and has way better support of the architectures (especially when it comes to non-x86 stuff). Hence, it is a good idea to use it instead of the non-supported fastutf8 stuff.
* [Minor] Deny zero length in regexp search functionsVsevolod Stakhov2024-03-221-11/+5
|
* [Rework] Further types conversion (no functional changes)Vsevolod Stakhov2024-03-181-58/+58
|
* [Rework] Remove some of the GLib types in lieu of standard onesVsevolod Stakhov2024-03-181-7/+7
| | | | This types have constant conflicts with the system ones especially on OSX.
* [Minor] Improve error messageVsevolod Stakhov2023-09-131-18/+23
|
* [Rework] Use clang-format to unify formatting in all sourcesVsevolod Stakhov2023-07-261-326/+316
| | | | No meaningful changes.
* [Minor] Add safe-guard for a number of regular expressions to be cachedVsevolod Stakhov2023-03-171-21/+9
|
* [Fix] Plug memory leak in regexp destruction with pcre2Vsevolod Stakhov2022-09-181-10/+18
|
* [Minor] Restrict `m` patterns in regexpsVsevolod Stakhov2022-07-301-1/+1
| | | | Issue: #4221
* [Fix] Fix processing captures from pcre2Vsevolod Stakhov2021-12-141-19/+63
|
* [Minor] Fix match_limit in pcre2 codeVsevolod Stakhov2021-08-251-0/+4
|
* [Minor] Save 8 bytes in rspamd_regexp_tVsevolod Stakhov2021-08-241-29/+0
|
* [Minor] Fix match limit feature in regexpsVsevolod Stakhov2021-08-241-0/+25
|
* [Minor] Fix another extreme caseVsevolod Stakhov2021-07-171-2/+4
|
* [Minor] Fix regexp parsing bugVsevolod Stakhov2021-07-171-2/+2
|
* [Minor] Fix regexps parsingVsevolod Stakhov2021-07-151-6/+9
|
* [Rework] Add composites manager conceptVsevolod Stakhov2021-07-151-1/+1
|
* [Rework] Slightly improve old regexp APIVsevolod Stakhov2021-07-151-22/+27
|
* [Minor] Add null safety to rspamd_regexp_newVsevolod Stakhov2020-08-151-0/+6
|
* [Project] Add `L` flag for regexps to save start of the match in HyperscanVsevolod Stakhov2020-07-281-0/+4
|
* [Fix] Slashing fix: fix captures matching APIVsevolod Stakhov2020-05-141-2/+2
|
* [Minor] Eliminate g_utf8_validateVsevolod Stakhov2020-02-101-4/+5
|
* [Fix] Fix regexp type check for pcre2Vsevolod Stakhov2020-01-271-0/+5
|
* fix NULL pointer use when JIT compiling a regular expression.Dirk Jagdmann2019-12-251-1/+2
|
* [Minor] Improve error loggingVsevolod Stakhov2019-11-021-2/+2
|
* [Minor] Sigh, try to be compatible with old crappy shitVsevolod Stakhov2019-10-091-2/+2
|
* [Fix] Set sanity limits for pcre2Vsevolod Stakhov2019-10-091-1/+9
|
* [Minor] Further static leaks removalVsevolod Stakhov2019-09-271-0/+1
|
* [Rework] Rework initialisation to reduce static leaks countVsevolod Stakhov2019-09-271-21/+25
|
* [Minor] Allow 0 length in rspamd_regexp_matchVsevolod Stakhov2019-08-151-0/+4
|
* [Minor] Fix pcre2 jit checksVsevolod Stakhov2019-05-301-9/+16
|
* [Minor] Store the fact that we have utf8 only regexps in corpusVsevolod Stakhov2018-11-281-0/+2
|
* [Fix] Some fixes for raw partsVsevolod Stakhov2018-11-271-1/+5
|
* [Minor] Do not parse raw regexp for explicitly utf expressionsVsevolod Stakhov2018-10-301-1/+3
|
* [Minor] Fix compilationVsevolod Stakhov2018-05-051-1/+1
|
* [Feature] Use common jit cache for all regexpsVsevolod Stakhov2018-05-051-43/+36
|
* [Minor] Try to allow disabling JIT in PCREVsevolod Stakhov2018-05-041-32/+40
|
* [Minor] Further g_slice cleanupVsevolod Stakhov2017-10-281-3/+3
|
* [Minor] Do not blame so loudly if pcre_study fails...Vsevolod Stakhov2016-12-181-6/+10
|
* [Feature] Add method to create regexp from a glob patternVsevolod Stakhov2016-12-181-0/+116
|
* [Fix] Fix various warnings and issuesVsevolod Stakhov2016-11-221-1/+1
|
* [Fix] Plug memory leak in regexp desctructorVsevolod Stakhov2016-10-131-0/+2
|
* [Fix] Fix UTF8 mode in PCRE2Vsevolod Stakhov2016-04-231-2/+0
|
* [Fix] Fix JIT usage for PCRE2Vsevolod Stakhov2016-04-231-1/+0
|
* [Fix] Fix JIT compilation for PCRE2 expressionsVsevolod Stakhov2016-04-231-12/+8
|
* [Minor] Revert disabling of fast pathVsevolod Stakhov2016-03-111-1/+1
|
* [Minor] Disable pcre jit fastVsevolod Stakhov2016-03-111-1/+1
|
* Fix non-UTF regexps for pcre2Vsevolod Stakhov2016-02-251-1/+1
|
* Temporary disable JIT when using valgrindVsevolod Stakhov2016-02-241-3/+9
|
* Fix pcre jit fast path (one more time)Vsevolod Stakhov2016-02-231-9/+24
|
generated by cgit v1.2.3 (git 2.39.1) at 2025-07-31 21:03:34 +0000
Notifier { return &webhookNotifier{} } func (m *webhookNotifier) NotifyIssueClearLabels(doer *models.User, issue *models.Issue) { if err := issue.LoadPoster(); err != nil { log.Error("loadPoster: %v", err) return } if err := issue.LoadRepo(); err != nil { log.Error("LoadRepo: %v", err) return } mode, _ := models.AccessLevel(issue.Poster, issue.Repo) var err error if issue.IsPull { if err = issue.LoadPullRequest(); err != nil { log.Error("LoadPullRequest: %v", err) return } err = webhook_module.PrepareWebhooks(issue.Repo, models.HookEventPullRequestLabel, &api.PullRequestPayload{ Action: api.HookIssueLabelCleared, Index: issue.Index, PullRequest: convert.ToAPIPullRequest(issue.PullRequest), Repository: issue.Repo.APIFormat(mode), Sender: doer.APIFormat(), }) } else { err = webhook_module.PrepareWebhooks(issue.Repo, models.HookEventIssueLabel, &api.IssuePayload{ Action: api.HookIssueLabelCleared, Index: issue.Index, Issue: convert.ToAPIIssue(issue), Repository: issue.Repo.APIFormat(mode), Sender: doer.APIFormat(), }) } if err != nil { log.Error("PrepareWebhooks [is_pull: %v]: %v", issue.IsPull, err) } } func (m *webhookNotifier) NotifyForkRepository(doer *models.User, oldRepo, repo *models.Repository) { oldMode, _ := models.AccessLevel(doer, oldRepo) mode, _ := models.AccessLevel(doer, repo) // forked webhook if err := webhook_module.PrepareWebhooks(oldRepo, models.HookEventFork, &api.ForkPayload{ Forkee: oldRepo.APIFormat(oldMode), Repo: repo.APIFormat(mode), Sender: doer.APIFormat(), }); err != nil { log.Error("PrepareWebhooks [repo_id: %d]: %v", oldRepo.ID, err) } u := repo.MustOwner() // Add to hook queue for created repo after session commit. if u.IsOrganization() { if err := webhook_module.PrepareWebhooks(repo, models.HookEventRepository, &api.RepositoryPayload{ Action: api.HookRepoCreated, Repository: repo.APIFormat(models.AccessModeOwner), Organization: u.APIFormat(), Sender: doer.APIFormat(), }); err != nil { log.Error("PrepareWebhooks [repo_id: %d]: %v", repo.ID, err) } } } func (m *webhookNotifier) NotifyCreateRepository(doer *models.User, u *models.User, repo *models.Repository) { // Add to hook queue for created repo after session commit. if err := webhook_module.PrepareWebhooks(repo, models.HookEventRepository, &api.RepositoryPayload{ Action: api.HookRepoCreated, Repository: repo.APIFormat(models.AccessModeOwner), Organization: u.APIFormat(), Sender: doer.APIFormat(), }); err != nil { log.Error("PrepareWebhooks [repo_id: %d]: %v", repo.ID, err) } } func (m *webhookNotifier) NotifyDeleteRepository(doer *models.User, repo *models.Repository) { u := repo.MustOwner() if err := webhook_module.PrepareWebhooks(repo, models.HookEventRepository, &api.RepositoryPayload{ Action: api.HookRepoDeleted, Repository: repo.APIFormat(models.AccessModeOwner), Organization: u.APIFormat(), Sender: doer.APIFormat(), }); err != nil { log.Error("PrepareWebhooks [repo_id: %d]: %v", repo.ID, err) } } func (m *webhookNotifier) NotifyIssueChangeAssignee(doer *models.User, issue *models.Issue, assignee *models.User, removed bool, comment *models.Comment) { if issue.IsPull { mode, _ := models.AccessLevelUnit(doer, issue.Repo, models.UnitTypePullRequests) if err := issue.LoadPullRequest(); err != nil { log.Error("LoadPullRequest failed: %v", err) return } issue.PullRequest.Issue = issue apiPullRequest := &api.PullRequestPayload{ Index: issue.Index, PullRequest: convert.ToAPIPullRequest(issue.PullRequest), Repository: issue.Repo.APIFormat(mode), Sender: doer.APIFormat(), } if removed { apiPullRequest.Action = api.HookIssueUnassigned } else { apiPullRequest.Action = api.HookIssueAssigned } // Assignee comment triggers a webhook if err := webhook_module.PrepareWebhooks(issue.Repo, models.HookEventPullRequestAssign, apiPullRequest); err != nil { log.Error("PrepareWebhooks [is_pull: %v, remove_assignee: %v]: %v", issue.IsPull, removed, err) return } } else { mode, _ := models.AccessLevelUnit(doer, issue.Repo, models.UnitTypeIssues) apiIssue := &api.IssuePayload{ Index: issue.Index, Issue: convert.ToAPIIssue(issue), Repository: issue.Repo.APIFormat(mode), Sender: doer.APIFormat(), } if removed { apiIssue.Action = api.HookIssueUnassigned } else { apiIssue.Action = api.HookIssueAssigned } // Assignee comment triggers a webhook if err := webhook_module.PrepareWebhooks(issue.Repo, models.HookEventIssueAssign, apiIssue); err != nil { log.Error("PrepareWebhooks [is_pull: %v, remove_assignee: %v]: %v", issue.IsPull, removed, err) return } } } func (m *webhookNotifier) NotifyIssueChangeTitle(doer *models.User, issue *models.Issue, oldTitle string) { mode, _ := models.AccessLevel(issue.Poster, issue.Repo) var err error if issue.IsPull { if err = issue.LoadPullRequest(); err != nil { log.Error("LoadPullRequest failed: %v", err) return } issue.PullRequest.Issue = issue err = webhook_module.PrepareWebhooks(issue.Repo, models.HookEventPullRequest, &api.PullRequestPayload{ Action: api.HookIssueEdited, Index: issue.Index, Changes: &api.ChangesPayload{ Title: &api.ChangesFromPayload{ From: oldTitle, }, }, PullRequest: convert.ToAPIPullRequest(issue.PullRequest), Repository: issue.Repo.APIFormat(mode), Sender: doer.APIFormat(), }) } else { err = webhook_module.PrepareWebhooks(issue.Repo, models.HookEventIssues, &api.IssuePayload{ Action: api.HookIssueEdited, Index: issue.Index, Changes: &api.ChangesPayload{ Title: &api.ChangesFromPayload{ From: oldTitle, }, }, Issue: convert.ToAPIIssue(issue), Repository: issue.Repo.APIFormat(mode), Sender: issue.Poster.APIFormat(), }) } if err != nil { log.Error("PrepareWebhooks [is_pull: %v]: %v", issue.IsPull, err) } } func (m *webhookNotifier) NotifyIssueChangeStatus(doer *models.User, issue *models.Issue, actionComment *models.Comment, isClosed bool) { mode, _ := models.AccessLevel(issue.Poster, issue.Repo) var err error if issue.IsPull { if err = issue.LoadPullRequest(); 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(issue.PullRequest), Repository: issue.Repo.APIFormat(mode), Sender: doer.APIFormat(), } if isClosed { apiPullRequest.Action = api.HookIssueClosed } else { apiPullRequest.Action = api.HookIssueReOpened } err = webhook_module.PrepareWebhooks(issue.Repo, models.HookEventPullRequest, apiPullRequest) } else { apiIssue := &api.IssuePayload{ Index: issue.Index, Issue: convert.ToAPIIssue(issue), Repository: issue.Repo.APIFormat(mode), Sender: doer.APIFormat(), } if isClosed { apiIssue.Action = api.HookIssueClosed } else { apiIssue.Action = api.HookIssueReOpened } err = webhook_module.PrepareWebhooks(issue.Repo, models.HookEventIssues, apiIssue) } if err != nil { log.Error("PrepareWebhooks [is_pull: %v, is_closed: %v]: %v", issue.IsPull, isClosed, err) } } func (m *webhookNotifier) NotifyNewIssue(issue *models.Issue, mentions []*models.User) { if err := issue.LoadRepo(); err != nil { log.Error("issue.LoadRepo: %v", err) return } if err := issue.LoadPoster(); err != nil { log.Error("issue.LoadPoster: %v", err) return } mode, _ := models.AccessLevel(issue.Poster, issue.Repo) if err := webhook_module.PrepareWebhooks(issue.Repo, models.HookEventIssues, &api.IssuePayload{ Action: api.HookIssueOpened, Index: issue.Index, Issue: convert.ToAPIIssue(issue), Repository: issue.Repo.APIFormat(mode), Sender: issue.Poster.APIFormat(), }); err != nil { log.Error("PrepareWebhooks: %v", err) } } func (m *webhookNotifier) NotifyNewPullRequest(pull *models.PullRequest, mentions []*models.User) { if err := pull.LoadIssue(); err != nil { log.Error("pull.LoadIssue: %v", err) return } if err := pull.Issue.LoadRepo(); err != nil { log.Error("pull.Issue.LoadRepo: %v", err) return } if err := pull.Issue.LoadPoster(); err != nil { log.Error("pull.Issue.LoadPoster: %v", err) return } mode, _ := models.AccessLevel(pull.Issue.Poster, pull.Issue.Repo) if err := webhook_module.PrepareWebhooks(pull.Issue.Repo, models.HookEventPullRequest, &api.PullRequestPayload{ Action: api.HookIssueOpened, Index: pull.Issue.Index, PullRequest: convert.ToAPIPullRequest(pull), Repository: pull.Issue.Repo.APIFormat(mode), Sender: pull.Issue.Poster.APIFormat(), }); err != nil { log.Error("PrepareWebhooks: %v", err) } } func (m *webhookNotifier) NotifyIssueChangeContent(doer *models.User, issue *models.Issue, oldContent string) { mode, _ := models.AccessLevel(issue.Poster, issue.Repo) var err error if issue.IsPull { issue.PullRequest.Issue = issue err = webhook_module.PrepareWebhooks(issue.Repo, models.HookEventPullRequest, &api.PullRequestPayload{ Action: api.HookIssueEdited, Index: issue.Index, Changes: &api.ChangesPayload{ Body: &api.ChangesFromPayload{ From: oldContent, }, }, PullRequest: convert.ToAPIPullRequest(issue.PullRequest), Repository: issue.Repo.APIFormat(mode), Sender: doer.APIFormat(), }) } else { err = webhook_module.PrepareWebhooks(issue.Repo, models.HookEventIssues, &api.IssuePayload{ Action: api.HookIssueEdited, Index: issue.Index, Changes: &api.ChangesPayload{ Body: &api.ChangesFromPayload{ From: oldContent, }, }, Issue: convert.ToAPIIssue(issue), Repository: issue.Repo.APIFormat(mode), Sender: doer.APIFormat(), }) } if err != nil { log.Error("PrepareWebhooks [is_pull: %v]: %v", issue.IsPull, err) } } func (m *webhookNotifier) NotifyUpdateComment(doer *models.User, c *models.Comment, oldContent string) { var err error if err = c.LoadPoster(); err != nil { log.Error("LoadPoster: %v", err) return } if err = c.LoadIssue(); err != nil { log.Error("LoadIssue: %v", err) return } if err = c.Issue.LoadAttributes(); err != nil { log.Error("LoadAttributes: %v", err) return } mode, _ := models.AccessLevel(doer, c.Issue.Repo) if c.Issue.IsPull { err = webhook_module.PrepareWebhooks(c.Issue.Repo, models.HookEventPullRequestComment, &api.IssueCommentPayload{ Action: api.HookIssueCommentEdited, Issue: convert.ToAPIIssue(c.Issue), Comment: c.APIFormat(), Changes: &api.ChangesPayload{ Body: &api.ChangesFromPayload{ From: oldContent, }, }, Repository: c.Issue.Repo.APIFormat(mode), Sender: doer.APIFormat(), IsPull: true, }) } else { err = webhook_module.PrepareWebhooks(c.Issue.Repo, models.HookEventIssueComment, &api.IssueCommentPayload{ Action: api.HookIssueCommentEdited, Issue: convert.ToAPIIssue(c.Issue), Comment: c.APIFormat(), Changes: &api.ChangesPayload{ Body: &api.ChangesFromPayload{ From: oldContent, }, }, Repository: c.Issue.Repo.APIFormat(mode), Sender: doer.APIFormat(), IsPull: false, }) } if err != nil { log.Error("PrepareWebhooks [comment_id: %d]: %v", c.ID, err) } } func (m *webhookNotifier) NotifyCreateIssueComment(doer *models.User, repo *models.Repository, issue *models.Issue, comment *models.Comment, mentions []*models.User) { mode, _ := models.AccessLevel(doer, repo) var err error if issue.IsPull { err = webhook_module.PrepareWebhooks(issue.Repo, models.HookEventPullRequestComment, &api.IssueCommentPayload{ Action: api.HookIssueCommentCreated, Issue: convert.ToAPIIssue(issue), Comment: comment.APIFormat(), Repository: repo.APIFormat(mode), Sender: doer.APIFormat(), IsPull: true, }) } else { err = webhook_module.PrepareWebhooks(issue.Repo, models.HookEventIssueComment, &api.IssueCommentPayload{ Action: api.HookIssueCommentCreated, Issue: convert.ToAPIIssue(issue), Comment: comment.APIFormat(), Repository: repo.APIFormat(mode), Sender: doer.APIFormat(), IsPull: false, }) } if err != nil { log.Error("PrepareWebhooks [comment_id: %d]: %v", comment.ID, err) } } func (m *webhookNotifier) NotifyDeleteComment(doer *models.User, comment *models.Comment) { var err error if err = comment.LoadPoster(); err != nil { log.Error("LoadPoster: %v", err) return } if err = comment.LoadIssue(); err != nil { log.Error("LoadIssue: %v", err) return } if err = comment.Issue.LoadAttributes(); err != nil { log.Error("LoadAttributes: %v", err) return } mode, _ := models.AccessLevel(doer, comment.Issue.Repo) if comment.Issue.IsPull { err = webhook_module.PrepareWebhooks(comment.Issue.Repo, models.HookEventPullRequestComment, &api.IssueCommentPayload{ Action: api.HookIssueCommentDeleted, Issue: convert.ToAPIIssue(comment.Issue), Comment: comment.APIFormat(), Repository: comment.Issue.Repo.APIFormat(mode), Sender: doer.APIFormat(), IsPull: true, }) } else { err = webhook_module.PrepareWebhooks(comment.Issue.Repo, models.HookEventIssueComment, &api.IssueCommentPayload{ Action: api.HookIssueCommentDeleted, Issue: convert.ToAPIIssue(comment.Issue), Comment: comment.APIFormat(), Repository: comment.Issue.Repo.APIFormat(mode), Sender: doer.APIFormat(), IsPull: false, }) } if err != nil { log.Error("PrepareWebhooks [comment_id: %d]: %v", comment.ID, err) } } func (m *webhookNotifier) NotifyIssueChangeLabels(doer *models.User, issue *models.Issue, addedLabels []*models.Label, removedLabels []*models.Label) { var err error if err = issue.LoadRepo(); err != nil { log.Error("LoadRepo: %v", err) return } if err = issue.LoadPoster(); err != nil { log.Error("LoadPoster: %v", err) return } mode, _ := models.AccessLevel(issue.Poster, issue.Repo) if issue.IsPull { if err = issue.LoadPullRequest(); err != nil { log.Error("loadPullRequest: %v", err) return } if err = issue.PullRequest.LoadIssue(); err != nil { log.Error("LoadIssue: %v", err) return } err = webhook_module.PrepareWebhooks(issue.Repo, models.HookEventPullRequestLabel, &api.PullRequestPayload{ Action: api.HookIssueLabelUpdated, Index: issue.Index, PullRequest: convert.ToAPIPullRequest(issue.PullRequest), Repository: issue.Repo.APIFormat(models.AccessModeNone), Sender: doer.APIFormat(), }) } else { err = webhook_module.PrepareWebhooks(issue.Repo, models.HookEventIssueLabel, &api.IssuePayload{ Action: api.HookIssueLabelUpdated, Index: issue.Index, Issue: convert.ToAPIIssue(issue), Repository: issue.Repo.APIFormat(mode), Sender: doer.APIFormat(), }) } if err != nil { log.Error("PrepareWebhooks [is_pull: %v]: %v", issue.IsPull, err) } } func (m *webhookNotifier) NotifyIssueChangeMilestone(doer *models.User, issue *models.Issue, oldMilestoneID int64) { var hookAction api.HookIssueAction var err error if issue.MilestoneID > 0 { hookAction = api.HookIssueMilestoned } else { hookAction = api.HookIssueDemilestoned } if err = issue.LoadAttributes(); err != nil { log.Error("issue.LoadAttributes failed: %v", err) return } mode, _ := models.AccessLevel(doer, issue.Repo) if issue.IsPull { err = issue.PullRequest.LoadIssue() if err != nil { log.Error("LoadIssue: %v", err) return } err = webhook_module.PrepareWebhooks(issue.Repo, models.HookEventPullRequestMilestone, &api.PullRequestPayload{ Action: hookAction, Index: issue.Index, PullRequest: convert.ToAPIPullRequest(issue.PullRequest), Repository: issue.Repo.APIFormat(mode), Sender: doer.APIFormat(), }) } else { err = webhook_module.PrepareWebhooks(issue.Repo, models.HookEventIssueMilestone, &api.IssuePayload{ Action: hookAction, Index: issue.Index, Issue: convert.ToAPIIssue(issue), Repository: issue.Repo.APIFormat(mode), Sender: doer.APIFormat(), }) } if err != nil { log.Error("PrepareWebhooks [is_pull: %v]: %v", issue.IsPull, err) } } func (m *webhookNotifier) NotifyPushCommits(pusher *models.User, repo *models.Repository, refName, oldCommitID, newCommitID string, commits *repository.PushCommits) { apiPusher := pusher.APIFormat() apiCommits, err := commits.ToAPIPayloadCommits(repo.RepoPath(), repo.HTMLURL()) if err != nil { log.Error("commits.ToAPIPayloadCommits failed: %v", err) return } if err := webhook_module.PrepareWebhooks(repo, models.HookEventPush, &api.PushPayload{ Ref: refName, Before: oldCommitID, After: newCommitID, CompareURL: setting.AppURL + commits.CompareURL, Commits: apiCommits, Repo: repo.APIFormat(models.AccessModeOwner), Pusher: apiPusher, Sender: apiPusher, }); err != nil { log.Error("PrepareWebhooks: %v", err) } } func (*webhookNotifier) NotifyMergePullRequest(pr *models.PullRequest, doer *models.User) { // Reload pull request information. if err := pr.LoadAttributes(); err != nil { log.Error("LoadAttributes: %v", err) return } if err := pr.LoadIssue(); err != nil { log.Error("LoadAttributes: %v", err) return } if err := pr.Issue.LoadRepo(); err != nil { log.Error("pr.Issue.LoadRepo: %v", err) return } mode, err := models.AccessLevel(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(pr), Repository: pr.Issue.Repo.APIFormat(mode), Sender: doer.APIFormat(), Action: api.HookIssueClosed, } err = webhook_module.PrepareWebhooks(pr.Issue.Repo, models.HookEventPullRequest, apiPullRequest) if err != nil { log.Error("PrepareWebhooks: %v", err) } } func (m *webhookNotifier) NotifyPullRequestChangeTargetBranch(doer *models.User, pr *models.PullRequest, oldBranch string) { issue := pr.Issue if !issue.IsPull { return } var err error if err = issue.LoadPullRequest(); err != nil { log.Error("LoadPullRequest failed: %v", err) return } issue.PullRequest.Issue = issue mode, _ := models.AccessLevel(issue.Poster, issue.Repo) err = webhook_module.PrepareWebhooks(issue.Repo, models.HookEventPullRequest, &api.PullRequestPayload{ Action: api.HookIssueEdited, Index: issue.Index, Changes: &api.ChangesPayload{ Ref: &api.ChangesFromPayload{ From: oldBranch, }, }, PullRequest: convert.ToAPIPullRequest(issue.PullRequest), Repository: issue.Repo.APIFormat(mode), Sender: doer.APIFormat(), }) if err != nil { log.Error("PrepareWebhooks [is_pull: %v]: %v", issue.IsPull, err) } } func (m *webhookNotifier) NotifyPullRequestReview(pr *models.PullRequest, review *models.Review, comment *models.Comment, mentions []*models.User) { var reviewHookType models.HookEventType switch review.Type { case models.ReviewTypeApprove: reviewHookType = models.HookEventPullRequestReviewApproved case models.ReviewTypeComment: reviewHookType = models.HookEventPullRequestComment case models.ReviewTypeReject: reviewHookType = models.HookEventPullRequestReviewRejected default: // unsupported review webhook type here log.Error("Unsupported review webhook type") return } if err := pr.LoadIssue(); err != nil { log.Error("pr.LoadIssue: %v", err) return } mode, err := models.AccessLevel(review.Issue.Poster, review.Issue.Repo) if err != nil { log.Error("models.AccessLevel: %v", err) return } if err := webhook_module.PrepareWebhooks(review.Issue.Repo, reviewHookType, &api.PullRequestPayload{ Action: api.HookIssueReviewed, Index: review.Issue.Index, PullRequest: convert.ToAPIPullRequest(pr), Repository: review.Issue.Repo.APIFormat(mode), Sender: review.Reviewer.APIFormat(), Review: &api.ReviewPayload{ Type: string(reviewHookType), Content: review.Content, }, }); err != nil { log.Error("PrepareWebhooks: %v", err) } } func (m *webhookNotifier) NotifyCreateRef(pusher *models.User, repo *models.Repository, refType, refFullName string) { apiPusher := pusher.APIFormat() apiRepo := repo.APIFormat(models.AccessModeNone) refName := git.RefEndName(refFullName) gitRepo, err := git.OpenRepository(repo.RepoPath()) if err != nil { log.Error("OpenRepository[%s]: %v", repo.RepoPath(), err) return } shaSum, err := gitRepo.GetRefCommitID(refFullName) if err != nil { gitRepo.Close() log.Error("GetRefCommitID[%s]: %v", refFullName, err) return } gitRepo.Close() if err = webhook_module.PrepareWebhooks(repo, models.HookEventCreate, &api.CreatePayload{ Ref: refName, Sha: shaSum, RefType: refType, Repo: apiRepo, Sender: apiPusher, }); err != nil { log.Error("PrepareWebhooks: %v", err) } } func (m *webhookNotifier) NotifyPullRequestSynchronized(doer *models.User, pr *models.PullRequest) { if err := pr.LoadIssue(); err != nil { log.Error("pr.LoadIssue: %v", err) return } if err := pr.Issue.LoadAttributes(); err != nil { log.Error("LoadAttributes: %v", err) return } if err := webhook_module.PrepareWebhooks(pr.Issue.Repo, models.HookEventPullRequestSync, &api.PullRequestPayload{ Action: api.HookIssueSynchronized, Index: pr.Issue.Index, PullRequest: convert.ToAPIPullRequest(pr), Repository: pr.Issue.Repo.APIFormat(models.AccessModeNone), Sender: doer.APIFormat(), }); err != nil { log.Error("PrepareWebhooks [pull_id: %v]: %v", pr.ID, err) } } func (m *webhookNotifier) NotifyDeleteRef(pusher *models.User, repo *models.Repository, refType, refFullName string) { apiPusher := pusher.APIFormat() apiRepo := repo.APIFormat(models.AccessModeNone) refName := git.RefEndName(refFullName) if err := webhook_module.PrepareWebhooks(repo, models.HookEventDelete, &api.DeletePayload{ Ref: refName, RefType: refType, PusherType: api.PusherTypeUser, Repo: apiRepo, Sender: apiPusher, }); err != nil { log.Error("PrepareWebhooks.(delete %s): %v", refType, err) } } func sendReleaseHook(doer *models.User, rel *models.Release, action api.HookReleaseAction) { if err := rel.LoadAttributes(); err != nil { log.Error("LoadAttributes: %v", err) return } mode, _ := models.AccessLevel(rel.Publisher, rel.Repo) if err := webhook_module.PrepareWebhooks(rel.Repo, models.HookEventRelease, &api.ReleasePayload{ Action: action, Release: rel.APIFormat(), Repository: rel.Repo.APIFormat(mode), Sender: rel.Publisher.APIFormat(), }); err != nil { log.Error("PrepareWebhooks: %v", err) } } func (m *webhookNotifier) NotifyNewRelease(rel *models.Release) { sendReleaseHook(rel.Publisher, rel, api.HookReleasePublished) } func (m *webhookNotifier) NotifyUpdateRelease(doer *models.User, rel *models.Release) { sendReleaseHook(doer, rel, api.HookReleaseUpdated) } func (m *webhookNotifier) NotifyDeleteRelease(doer *models.User, rel *models.Release) { sendReleaseHook(doer, rel, api.HookReleaseDeleted) } func (m *webhookNotifier) NotifySyncPushCommits(pusher *models.User, repo *models.Repository, refName, oldCommitID, newCommitID string, commits *repository.PushCommits) { apiPusher := pusher.APIFormat() apiCommits, err := commits.ToAPIPayloadCommits(repo.RepoPath(), repo.HTMLURL()) if err != nil { log.Error("commits.ToAPIPayloadCommits failed: %v", err) return } if err := webhook_module.PrepareWebhooks(repo, models.HookEventPush, &api.PushPayload{ Ref: refName, Before: oldCommitID, After: newCommitID, CompareURL: setting.AppURL + commits.CompareURL, Commits: apiCommits, Repo: repo.APIFormat(models.AccessModeOwner), Pusher: apiPusher, Sender: apiPusher, }); err != nil { log.Error("PrepareWebhooks: %v", err) } } func (m *webhookNotifier) NotifySyncCreateRef(pusher *models.User, repo *models.Repository, refType, refFullName string) { m.NotifyCreateRef(pusher, repo, refType, refFullName) } func (m *webhookNotifier) NotifySyncDeleteRef(pusher *models.User, repo *models.Repository, refType, refFullName string) { m.NotifyDeleteRef(pusher, repo, refType, refFullName) }
generated by cgit v1.2.3 (git 2.39.1) at 2025-07-31 21:03:32 +0000