123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300 |
- // Copyright 2019 The Gitea Authors. All rights reserved.
- // SPDX-License-Identifier: MIT
-
- package issue
-
- import (
- "context"
- "fmt"
-
- activities_model "code.gitea.io/gitea/models/activities"
- "code.gitea.io/gitea/models/db"
- issues_model "code.gitea.io/gitea/models/issues"
- access_model "code.gitea.io/gitea/models/perm/access"
- project_model "code.gitea.io/gitea/models/project"
- repo_model "code.gitea.io/gitea/models/repo"
- system_model "code.gitea.io/gitea/models/system"
- user_model "code.gitea.io/gitea/models/user"
- "code.gitea.io/gitea/modules/git"
- "code.gitea.io/gitea/modules/notification"
- "code.gitea.io/gitea/modules/storage"
- )
-
- // NewIssue creates new issue with labels for repository.
- func NewIssue(ctx context.Context, repo *repo_model.Repository, issue *issues_model.Issue, labelIDs []int64, uuids []string, assigneeIDs []int64) error {
- if err := issues_model.NewIssue(repo, issue, labelIDs, uuids); err != nil {
- return err
- }
-
- for _, assigneeID := range assigneeIDs {
- if err := AddAssigneeIfNotAssigned(ctx, issue, issue.Poster, assigneeID); err != nil {
- return err
- }
- }
-
- mentions, err := issues_model.FindAndUpdateIssueMentions(ctx, issue, issue.Poster, issue.Content)
- if err != nil {
- return err
- }
-
- notification.NotifyNewIssue(ctx, issue, mentions)
- if len(issue.Labels) > 0 {
- notification.NotifyIssueChangeLabels(ctx, issue.Poster, issue, issue.Labels, nil)
- }
- if issue.Milestone != nil {
- notification.NotifyIssueChangeMilestone(ctx, issue.Poster, issue, 0)
- }
-
- return nil
- }
-
- // ChangeTitle changes the title of this issue, as the given user.
- func ChangeTitle(ctx context.Context, issue *issues_model.Issue, doer *user_model.User, title string) (err error) {
- oldTitle := issue.Title
- issue.Title = title
-
- if err = issues_model.ChangeIssueTitle(ctx, issue, doer, oldTitle); err != nil {
- return
- }
-
- notification.NotifyIssueChangeTitle(ctx, doer, issue, oldTitle)
-
- return nil
- }
-
- // ChangeIssueRef changes the branch of this issue, as the given user.
- func ChangeIssueRef(ctx context.Context, issue *issues_model.Issue, doer *user_model.User, ref string) error {
- oldRef := issue.Ref
- issue.Ref = ref
-
- if err := issues_model.ChangeIssueRef(issue, doer, oldRef); err != nil {
- return err
- }
-
- notification.NotifyIssueChangeRef(ctx, doer, issue, oldRef)
-
- return nil
- }
-
- // UpdateAssignees is a helper function to add or delete one or multiple issue assignee(s)
- // Deleting is done the GitHub way (quote from their api documentation):
- // https://developer.github.com/v3/issues/#edit-an-issue
- // "assignees" (array): Logins for Users to assign to this issue.
- // Pass one or more user logins to replace the set of assignees on this Issue.
- // Send an empty array ([]) to clear all assignees from the Issue.
- func UpdateAssignees(ctx context.Context, issue *issues_model.Issue, oneAssignee string, multipleAssignees []string, doer *user_model.User) (err error) {
- var allNewAssignees []*user_model.User
-
- // Keep the old assignee thingy for compatibility reasons
- if oneAssignee != "" {
- // Prevent double adding assignees
- var isDouble bool
- for _, assignee := range multipleAssignees {
- if assignee == oneAssignee {
- isDouble = true
- break
- }
- }
-
- if !isDouble {
- multipleAssignees = append(multipleAssignees, oneAssignee)
- }
- }
-
- // Loop through all assignees to add them
- for _, assigneeName := range multipleAssignees {
- assignee, err := user_model.GetUserByName(ctx, assigneeName)
- if err != nil {
- return err
- }
-
- allNewAssignees = append(allNewAssignees, assignee)
- }
-
- // Delete all old assignees not passed
- if err = DeleteNotPassedAssignee(ctx, issue, doer, allNewAssignees); err != nil {
- return err
- }
-
- // Add all new assignees
- // Update the assignee. The function will check if the user exists, is already
- // assigned (which he shouldn't as we deleted all assignees before) and
- // has access to the repo.
- for _, assignee := range allNewAssignees {
- // Extra method to prevent double adding (which would result in removing)
- err = AddAssigneeIfNotAssigned(ctx, issue, doer, assignee.ID)
- if err != nil {
- return err
- }
- }
-
- return err
- }
-
- // DeleteIssue deletes an issue
- func DeleteIssue(ctx context.Context, doer *user_model.User, gitRepo *git.Repository, issue *issues_model.Issue) error {
- // load issue before deleting it
- if err := issue.LoadAttributes(ctx); err != nil {
- return err
- }
- if err := issue.LoadPullRequest(ctx); err != nil {
- return err
- }
-
- // delete entries in database
- if err := deleteIssue(ctx, issue); err != nil {
- return err
- }
-
- // delete pull request related git data
- if issue.IsPull && gitRepo != nil {
- if err := gitRepo.RemoveReference(fmt.Sprintf("%s%d/head", git.PullPrefix, issue.PullRequest.Index)); err != nil {
- return err
- }
- }
-
- // If the Issue is pinned, we should unpin it before deletion to avoid problems with other pinned Issues
- if issue.IsPinned() {
- if err := issue.Unpin(ctx, doer); err != nil {
- return err
- }
- }
-
- notification.NotifyDeleteIssue(ctx, doer, issue)
-
- return nil
- }
-
- // AddAssigneeIfNotAssigned adds an assignee only if he isn't already assigned to the issue.
- // Also checks for access of assigned user
- func AddAssigneeIfNotAssigned(ctx context.Context, issue *issues_model.Issue, doer *user_model.User, assigneeID int64) (err error) {
- assignee, err := user_model.GetUserByID(ctx, assigneeID)
- if err != nil {
- return err
- }
-
- // Check if the user is already assigned
- isAssigned, err := issues_model.IsUserAssignedToIssue(ctx, issue, assignee)
- if err != nil {
- return err
- }
- if isAssigned {
- // nothing to to
- return nil
- }
-
- valid, err := access_model.CanBeAssigned(ctx, assignee, issue.Repo, issue.IsPull)
- if err != nil {
- return err
- }
- if !valid {
- return repo_model.ErrUserDoesNotHaveAccessToRepo{UserID: assigneeID, RepoName: issue.Repo.Name}
- }
-
- _, _, err = ToggleAssignee(ctx, issue, doer, assigneeID)
- if err != nil {
- return err
- }
-
- return nil
- }
-
- // GetRefEndNamesAndURLs retrieves the ref end names (e.g. refs/heads/branch-name -> branch-name)
- // and their respective URLs.
- func GetRefEndNamesAndURLs(issues []*issues_model.Issue, repoLink string) (map[int64]string, map[int64]string) {
- issueRefEndNames := make(map[int64]string, len(issues))
- issueRefURLs := make(map[int64]string, len(issues))
- for _, issue := range issues {
- if issue.Ref != "" {
- issueRefEndNames[issue.ID] = git.RefName(issue.Ref).ShortName()
- issueRefURLs[issue.ID] = git.RefURL(repoLink, issue.Ref)
- }
- }
- return issueRefEndNames, issueRefURLs
- }
-
- // deleteIssue deletes the issue
- func deleteIssue(ctx context.Context, issue *issues_model.Issue) error {
- ctx, committer, err := db.TxContext(ctx)
- if err != nil {
- return err
- }
- defer committer.Close()
-
- e := db.GetEngine(ctx)
- if _, err := e.ID(issue.ID).NoAutoCondition().Delete(issue); err != nil {
- return err
- }
-
- // update the total issue numbers
- if err := repo_model.UpdateRepoIssueNumbers(ctx, issue.RepoID, issue.IsPull, false); err != nil {
- return err
- }
- // if the issue is closed, update the closed issue numbers
- if issue.IsClosed {
- if err := repo_model.UpdateRepoIssueNumbers(ctx, issue.RepoID, issue.IsPull, true); err != nil {
- return err
- }
- }
-
- if err := issues_model.UpdateMilestoneCounters(ctx, issue.MilestoneID); err != nil {
- return fmt.Errorf("error updating counters for milestone id %d: %w",
- issue.MilestoneID, err)
- }
-
- if err := activities_model.DeleteIssueActions(ctx, issue.RepoID, issue.ID); err != nil {
- return err
- }
-
- // find attachments related to this issue and remove them
- if err := issue.LoadAttributes(ctx); err != nil {
- return err
- }
-
- for i := range issue.Attachments {
- system_model.RemoveStorageWithNotice(ctx, storage.Attachments, "Delete issue attachment", issue.Attachments[i].RelativePath())
- }
-
- // delete all database data still assigned to this issue
- if err := issues_model.DeleteInIssue(ctx, issue.ID,
- &issues_model.ContentHistory{},
- &issues_model.Comment{},
- &issues_model.IssueLabel{},
- &issues_model.IssueDependency{},
- &issues_model.IssueAssignees{},
- &issues_model.IssueUser{},
- &activities_model.Notification{},
- &issues_model.Reaction{},
- &issues_model.IssueWatch{},
- &issues_model.Stopwatch{},
- &issues_model.TrackedTime{},
- &project_model.ProjectIssue{},
- &repo_model.Attachment{},
- &issues_model.PullRequest{},
- ); err != nil {
- return err
- }
-
- // References to this issue in other issues
- if _, err := db.DeleteByBean(ctx, &issues_model.Comment{
- RefIssueID: issue.ID,
- }); err != nil {
- return err
- }
-
- // Delete dependencies for issues in other repositories
- if _, err := db.DeleteByBean(ctx, &issues_model.IssueDependency{
- DependencyID: issue.ID,
- }); err != nil {
- return err
- }
-
- // delete from dependent issues
- if _, err := db.DeleteByBean(ctx, &issues_model.Comment{
- DependentIssueID: issue.ID,
- }); err != nil {
- return err
- }
-
- return committer.Commit()
- }
|