Mirrors/gitea
0
0
Fork 0
mirror of https://github.com/go-gitea/gitea.git synced 2026-06-30 03:17:23 +02:00
Code Issues Activity

update

Browse Source
This commit is contained in:
Lunny Xiao 2026-05-22 15:17:55 -07:00
parent a8856cdac9
commit 0433a0d352
No known key found for this signature in database
GPG Key ID: C3B7C91B632F738A
1 changed files with 15 additions and 15 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

30
services/projects/workflow_notifier.go
View File

@ -63,7 +63,7 @@ func (m *workflowNotifier) NewIssue(ctx context.Context, issue *issues_model.Iss
func (m *workflowNotifier) NewPullRequest(ctx context.Context, pr *issues_model.PullRequest, mentions []*user_model.User) {
if err := pr.LoadIssue(ctx); err != nil {
log.Error("NewIssue: LoadIssue: %v", err)
log.Error("NewPullRequest: LoadIssue: %v", err)
return
}
issue := pr.Issue
@ -81,7 +81,7 @@ func (m *workflowNotifier) IssueChangeStatus(ctx context.Context, doer *user_mod
return
}
if err := issue.LoadProjects(ctx); err != nil {
log.Error("NewIssue: LoadProject: %v", err)
log.Error("IssueChangeStatus: LoadProject: %v", err)
return
}
if len(issue.Projects) == 0 {
@ -131,7 +131,7 @@ func (*workflowNotifier) IssueChangeProjects(ctx context.Context, doer *user_mod
for _, removedProjectID := range removedProjectIDs {
workflows, err := project_model.FindWorkflowsByProjectID(ctx, removedProjectID)
if err != nil {
log.Error("IssueChangeStatus: FindWorkflowsByProjectID: %v", err)
log.Error("IssueChangeProjects: FindWorkflowsByProjectID: %v", err)
return
}
@ -145,13 +145,13 @@ func (*workflowNotifier) IssueChangeProjects(ctx context.Context, doer *user_mod
for _, newProject := range addedProjects {
if err := issue.LoadRepo(ctx); err != nil {
log.Error("IssueChangeStatus: LoadRepo: %v", err)
log.Error("IssueChangeProjects: LoadRepo: %v", err)
return
}
workflows, err := project_model.FindWorkflowsByProjectID(ctx, newProject.ID)
if err != nil {
log.Error("IssueChangeStatus: FindWorkflowsByProjectID: %v", err)
log.Error("IssueChangeProjects: FindWorkflowsByProjectID: %v", err)
return
}
@ -170,7 +170,7 @@ func (*workflowNotifier) IssueChangeProjectColumn(ctx context.Context, doer *use
return
}
if err := issue.LoadRepo(ctx); err != nil {
log.Error("IssueChangeStatus: LoadRepo: %v", err)
log.Error("IssueChangeProjectColumn: LoadRepo: %v", err)
return
}
@ -206,7 +206,7 @@ func (*workflowNotifier) IssueChangeProjectColumn(ctx context.Context, doer *use
workflows, err := project_model.FindWorkflowsByProjectID(ctx, oldColumn.ProjectID)
if err != nil {
log.Error("IssueChangeStatus: FindWorkflowsByProjectID: %v", err)
log.Error("IssueChangeProjectColumn: FindWorkflowsByProjectID: %v", err)
return
}
@ -220,18 +220,18 @@ func (*workflowNotifier) IssueChangeProjectColumn(ctx context.Context, doer *use
func (*workflowNotifier) MergePullRequest(ctx context.Context, doer *user_model.User, pr *issues_model.PullRequest) {
if err := pr.LoadIssue(ctx); err != nil {
log.Error("NewIssue: LoadIssue: %v", err)
log.Error("MergePullRequest: LoadIssue: %v", err)
return
}
issue := pr.Issue
if err := issue.LoadRepo(ctx); err != nil {
log.Error("IssueChangeStatus: LoadRepo: %v", err)
log.Error("MergePullRequest: LoadRepo: %v", err)
return
}
if err := issue.LoadProjects(ctx); err != nil {
log.Error("NewIssue: LoadProject: %v", err)
log.Error("MergePullRequest: LoadProjects: %v", err)
return
}
if len(issue.Projects) == 0 {
@ -241,7 +241,7 @@ func (*workflowNotifier) MergePullRequest(ctx context.Context, doer *user_model.
for _, project := range issue.Projects {
workflows, err := project_model.FindWorkflowsByProjectID(ctx, project.ID)
if err != nil {
log.Error("IssueChangeStatus: FindWorkflowsByProjectID: %v", err)
log.Error("MergePullRequest: FindWorkflowsByProjectID: %v", err)
return
}
@ -260,18 +260,18 @@ func (m *workflowNotifier) AutoMergePullRequest(ctx context.Context, doer *user_
func (*workflowNotifier) PullRequestReview(ctx context.Context, pr *issues_model.PullRequest, review *issues_model.Review, comment *issues_model.Comment, mentions []*user_model.User) {
if err := pr.LoadIssue(ctx); err != nil {
log.Error("NewIssue: LoadIssue: %v", err)
log.Error("PullRequestReview: LoadIssue: %v", err)
return
}
issue := pr.Issue
if err := issue.LoadRepo(ctx); err != nil {
log.Error("IssueChangeStatus: LoadRepo: %v", err)
log.Error("PullRequestReview: LoadRepo: %v", err)
return
}
if err := issue.LoadProjects(ctx); err != nil {
log.Error("NewIssue: LoadProjects: %v", err)
log.Error("PullRequestReview: LoadProjects: %v", err)
return
}
if len(issue.Projects) == 0 {
@ -281,7 +281,7 @@ func (*workflowNotifier) PullRequestReview(ctx context.Context, pr *issues_model
for _, project := range issue.Projects {
workflows, err := project_model.FindWorkflowsByProjectID(ctx, project.ID)
if err != nil {
log.Error("IssueChangeStatus: FindWorkflowsByProjectID: %v", err)
log.Error("PullRequestReview: FindWorkflowsByProjectID: %v", err)
return
}