123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789 |
- // Copyright 2014 The Gogs Authors. All rights reserved.
- // Copyright 2019 The Gitea Authors. All rights reserved.
- // SPDX-License-Identifier: MIT
-
- package activities
-
- import (
- "context"
- "fmt"
- "net/url"
- "path"
- "strconv"
- "strings"
- "time"
-
- "code.gitea.io/gitea/models/db"
- issues_model "code.gitea.io/gitea/models/issues"
- "code.gitea.io/gitea/models/organization"
- access_model "code.gitea.io/gitea/models/perm/access"
- repo_model "code.gitea.io/gitea/models/repo"
- "code.gitea.io/gitea/models/unit"
- user_model "code.gitea.io/gitea/models/user"
- "code.gitea.io/gitea/modules/base"
- "code.gitea.io/gitea/modules/git"
- "code.gitea.io/gitea/modules/log"
- "code.gitea.io/gitea/modules/optional"
- "code.gitea.io/gitea/modules/setting"
- "code.gitea.io/gitea/modules/structs"
- "code.gitea.io/gitea/modules/timeutil"
-
- "xorm.io/builder"
- "xorm.io/xorm/schemas"
- )
-
- // ActionType represents the type of an action.
- type ActionType int
-
- // Possible action types.
- const (
- ActionCreateRepo ActionType = iota + 1 // 1
- ActionRenameRepo // 2
- ActionStarRepo // 3
- ActionWatchRepo // 4
- ActionCommitRepo // 5
- ActionCreateIssue // 6
- ActionCreatePullRequest // 7
- ActionTransferRepo // 8
- ActionPushTag // 9
- ActionCommentIssue // 10
- ActionMergePullRequest // 11
- ActionCloseIssue // 12
- ActionReopenIssue // 13
- ActionClosePullRequest // 14
- ActionReopenPullRequest // 15
- ActionDeleteTag // 16
- ActionDeleteBranch // 17
- ActionMirrorSyncPush // 18
- ActionMirrorSyncCreate // 19
- ActionMirrorSyncDelete // 20
- ActionApprovePullRequest // 21
- ActionRejectPullRequest // 22
- ActionCommentPull // 23
- ActionPublishRelease // 24
- ActionPullReviewDismissed // 25
- ActionPullRequestReadyForReview // 26
- ActionAutoMergePullRequest // 27
- )
-
- func (at ActionType) String() string {
- switch at {
- case ActionCreateRepo:
- return "create_repo"
- case ActionRenameRepo:
- return "rename_repo"
- case ActionStarRepo:
- return "star_repo"
- case ActionWatchRepo:
- return "watch_repo"
- case ActionCommitRepo:
- return "commit_repo"
- case ActionCreateIssue:
- return "create_issue"
- case ActionCreatePullRequest:
- return "create_pull_request"
- case ActionTransferRepo:
- return "transfer_repo"
- case ActionPushTag:
- return "push_tag"
- case ActionCommentIssue:
- return "comment_issue"
- case ActionMergePullRequest:
- return "merge_pull_request"
- case ActionCloseIssue:
- return "close_issue"
- case ActionReopenIssue:
- return "reopen_issue"
- case ActionClosePullRequest:
- return "close_pull_request"
- case ActionReopenPullRequest:
- return "reopen_pull_request"
- case ActionDeleteTag:
- return "delete_tag"
- case ActionDeleteBranch:
- return "delete_branch"
- case ActionMirrorSyncPush:
- return "mirror_sync_push"
- case ActionMirrorSyncCreate:
- return "mirror_sync_create"
- case ActionMirrorSyncDelete:
- return "mirror_sync_delete"
- case ActionApprovePullRequest:
- return "approve_pull_request"
- case ActionRejectPullRequest:
- return "reject_pull_request"
- case ActionCommentPull:
- return "comment_pull"
- case ActionPublishRelease:
- return "publish_release"
- case ActionPullReviewDismissed:
- return "pull_review_dismissed"
- case ActionPullRequestReadyForReview:
- return "pull_request_ready_for_review"
- case ActionAutoMergePullRequest:
- return "auto_merge_pull_request"
- default:
- return "action-" + strconv.Itoa(int(at))
- }
- }
-
- func (at ActionType) InActions(actions ...string) bool {
- for _, action := range actions {
- if action == at.String() {
- return true
- }
- }
- return false
- }
-
- // Action represents user operation type and other information to
- // repository. It implemented interface base.Actioner so that can be
- // used in template render.
- type Action struct {
- ID int64 `xorm:"pk autoincr"`
- UserID int64 `xorm:"INDEX"` // Receiver user id.
- OpType ActionType
- ActUserID int64 // Action user id.
- ActUser *user_model.User `xorm:"-"`
- RepoID int64
- Repo *repo_model.Repository `xorm:"-"`
- CommentID int64 `xorm:"INDEX"`
- Comment *issues_model.Comment `xorm:"-"`
- Issue *issues_model.Issue `xorm:"-"` // get the issue id from content
- IsDeleted bool `xorm:"NOT NULL DEFAULT false"`
- RefName string
- IsPrivate bool `xorm:"NOT NULL DEFAULT false"`
- IsPrivateView bool `xorm:"-"`
- Content string `xorm:"TEXT"`
- CreatedUnix timeutil.TimeStamp `xorm:"created"`
- }
-
- func init() {
- db.RegisterModel(new(Action))
- }
-
- // TableIndices implements xorm's TableIndices interface
- func (a *Action) TableIndices() []*schemas.Index {
- repoIndex := schemas.NewIndex("r_u_d", schemas.IndexType)
- repoIndex.AddColumn("repo_id", "user_id", "is_deleted")
-
- actUserIndex := schemas.NewIndex("au_r_c_u_d", schemas.IndexType)
- actUserIndex.AddColumn("act_user_id", "repo_id", "created_unix", "user_id", "is_deleted")
-
- cudIndex := schemas.NewIndex("c_u_d", schemas.IndexType)
- cudIndex.AddColumn("created_unix", "user_id", "is_deleted")
-
- indices := []*schemas.Index{actUserIndex, repoIndex, cudIndex}
-
- return indices
- }
-
- // GetOpType gets the ActionType of this action.
- func (a *Action) GetOpType() ActionType {
- return a.OpType
- }
-
- // LoadActUser loads a.ActUser
- func (a *Action) LoadActUser(ctx context.Context) {
- if a.ActUser != nil {
- return
- }
- var err error
- a.ActUser, err = user_model.GetUserByID(ctx, a.ActUserID)
- if err == nil {
- return
- } else if user_model.IsErrUserNotExist(err) {
- a.ActUser = user_model.NewGhostUser()
- } else {
- log.Error("GetUserByID(%d): %v", a.ActUserID, err)
- }
- }
-
- func (a *Action) loadRepo(ctx context.Context) {
- if a.Repo != nil {
- return
- }
- var err error
- a.Repo, err = repo_model.GetRepositoryByID(ctx, a.RepoID)
- if err != nil {
- log.Error("repo_model.GetRepositoryByID(%d): %v", a.RepoID, err)
- }
- }
-
- // GetActFullName gets the action's user full name.
- func (a *Action) GetActFullName(ctx context.Context) string {
- a.LoadActUser(ctx)
- return a.ActUser.FullName
- }
-
- // GetActUserName gets the action's user name.
- func (a *Action) GetActUserName(ctx context.Context) string {
- a.LoadActUser(ctx)
- return a.ActUser.Name
- }
-
- // ShortActUserName gets the action's user name trimmed to max 20
- // chars.
- func (a *Action) ShortActUserName(ctx context.Context) string {
- return base.EllipsisString(a.GetActUserName(ctx), 20)
- }
-
- // GetActDisplayName gets the action's display name based on DEFAULT_SHOW_FULL_NAME, or falls back to the username if it is blank.
- func (a *Action) GetActDisplayName(ctx context.Context) string {
- if setting.UI.DefaultShowFullName {
- trimmedFullName := strings.TrimSpace(a.GetActFullName(ctx))
- if len(trimmedFullName) > 0 {
- return trimmedFullName
- }
- }
- return a.ShortActUserName(ctx)
- }
-
- // GetActDisplayNameTitle gets the action's display name used for the title (tooltip) based on DEFAULT_SHOW_FULL_NAME
- func (a *Action) GetActDisplayNameTitle(ctx context.Context) string {
- if setting.UI.DefaultShowFullName {
- return a.ShortActUserName(ctx)
- }
- return a.GetActFullName(ctx)
- }
-
- // GetRepoUserName returns the name of the action repository owner.
- func (a *Action) GetRepoUserName(ctx context.Context) string {
- a.loadRepo(ctx)
- return a.Repo.OwnerName
- }
-
- // ShortRepoUserName returns the name of the action repository owner
- // trimmed to max 20 chars.
- func (a *Action) ShortRepoUserName(ctx context.Context) string {
- return base.EllipsisString(a.GetRepoUserName(ctx), 20)
- }
-
- // GetRepoName returns the name of the action repository.
- func (a *Action) GetRepoName(ctx context.Context) string {
- a.loadRepo(ctx)
- return a.Repo.Name
- }
-
- // ShortRepoName returns the name of the action repository
- // trimmed to max 33 chars.
- func (a *Action) ShortRepoName(ctx context.Context) string {
- return base.EllipsisString(a.GetRepoName(ctx), 33)
- }
-
- // GetRepoPath returns the virtual path to the action repository.
- func (a *Action) GetRepoPath(ctx context.Context) string {
- return path.Join(a.GetRepoUserName(ctx), a.GetRepoName(ctx))
- }
-
- // ShortRepoPath returns the virtual path to the action repository
- // trimmed to max 20 + 1 + 33 chars.
- func (a *Action) ShortRepoPath(ctx context.Context) string {
- return path.Join(a.ShortRepoUserName(ctx), a.ShortRepoName(ctx))
- }
-
- // GetRepoLink returns relative link to action repository.
- func (a *Action) GetRepoLink(ctx context.Context) string {
- // path.Join will skip empty strings
- return path.Join(setting.AppSubURL, "/", url.PathEscape(a.GetRepoUserName(ctx)), url.PathEscape(a.GetRepoName(ctx)))
- }
-
- // GetRepoAbsoluteLink returns the absolute link to action repository.
- func (a *Action) GetRepoAbsoluteLink(ctx context.Context) string {
- return setting.AppURL + url.PathEscape(a.GetRepoUserName(ctx)) + "/" + url.PathEscape(a.GetRepoName(ctx))
- }
-
- func (a *Action) loadComment(ctx context.Context) (err error) {
- if a.CommentID == 0 || a.Comment != nil {
- return nil
- }
- a.Comment, err = issues_model.GetCommentByID(ctx, a.CommentID)
- return err
- }
-
- // GetCommentHTMLURL returns link to action comment.
- func (a *Action) GetCommentHTMLURL(ctx context.Context) string {
- if a == nil {
- return "#"
- }
- _ = a.loadComment(ctx)
- if a.Comment != nil {
- return a.Comment.HTMLURL(ctx)
- }
-
- if err := a.LoadIssue(ctx); err != nil || a.Issue == nil {
- return "#"
- }
- if err := a.Issue.LoadRepo(ctx); err != nil {
- return "#"
- }
-
- return a.Issue.HTMLURL()
- }
-
- // GetCommentLink returns link to action comment.
- func (a *Action) GetCommentLink(ctx context.Context) string {
- if a == nil {
- return "#"
- }
- _ = a.loadComment(ctx)
- if a.Comment != nil {
- return a.Comment.Link(ctx)
- }
-
- if err := a.LoadIssue(ctx); err != nil || a.Issue == nil {
- return "#"
- }
- if err := a.Issue.LoadRepo(ctx); err != nil {
- return "#"
- }
-
- return a.Issue.Link()
- }
-
- // GetBranch returns the action's repository branch.
- func (a *Action) GetBranch() string {
- return strings.TrimPrefix(a.RefName, git.BranchPrefix)
- }
-
- // GetRefLink returns the action's ref link.
- func (a *Action) GetRefLink(ctx context.Context) string {
- return git.RefURL(a.GetRepoLink(ctx), a.RefName)
- }
-
- // GetTag returns the action's repository tag.
- func (a *Action) GetTag() string {
- return strings.TrimPrefix(a.RefName, git.TagPrefix)
- }
-
- // GetContent returns the action's content.
- func (a *Action) GetContent() string {
- return a.Content
- }
-
- // GetCreate returns the action creation time.
- func (a *Action) GetCreate() time.Time {
- return a.CreatedUnix.AsTime()
- }
-
- func (a *Action) IsIssueEvent() bool {
- return a.OpType.InActions("comment_issue", "approve_pull_request", "reject_pull_request", "comment_pull", "merge_pull_request")
- }
-
- // GetIssueInfos returns a list of associated information with the action.
- func (a *Action) GetIssueInfos() []string {
- // make sure it always returns 3 elements, because there are some access to the a[1] and a[2] without checking the length
- ret := strings.SplitN(a.Content, "|", 3)
- for len(ret) < 3 {
- ret = append(ret, "")
- }
- return ret
- }
-
- func (a *Action) getIssueIndex() int64 {
- infos := a.GetIssueInfos()
- if len(infos) == 0 {
- return 0
- }
- index, _ := strconv.ParseInt(infos[0], 10, 64)
- return index
- }
-
- func (a *Action) LoadIssue(ctx context.Context) error {
- if a.Issue != nil {
- return nil
- }
- if index := a.getIssueIndex(); index > 0 {
- issue, err := issues_model.GetIssueByIndex(ctx, a.RepoID, index)
- if err != nil {
- return err
- }
- a.Issue = issue
- a.Issue.Repo = a.Repo
- }
- return nil
- }
-
- // GetIssueTitle returns the title of first issue associated with the action.
- func (a *Action) GetIssueTitle(ctx context.Context) string {
- if err := a.LoadIssue(ctx); err != nil {
- log.Error("LoadIssue: %v", err)
- return "<500 when get issue>"
- }
- if a.Issue == nil {
- return "<Issue not found>"
- }
- return a.Issue.Title
- }
-
- // GetIssueContent returns the content of first issue associated with this action.
- func (a *Action) GetIssueContent(ctx context.Context) string {
- if err := a.LoadIssue(ctx); err != nil {
- log.Error("LoadIssue: %v", err)
- return "<500 when get issue>"
- }
- if a.Issue == nil {
- return "<Content not found>"
- }
- return a.Issue.Content
- }
-
- // GetFeedsOptions options for retrieving feeds
- type GetFeedsOptions struct {
- db.ListOptions
- RequestedUser *user_model.User // the user we want activity for
- RequestedTeam *organization.Team // the team we want activity for
- RequestedRepo *repo_model.Repository // the repo we want activity for
- Actor *user_model.User // the user viewing the activity
- IncludePrivate bool // include private actions
- OnlyPerformedBy bool // only actions performed by requested user
- IncludeDeleted bool // include deleted actions
- Date string // the day we want activity for: YYYY-MM-DD
- }
-
- // GetFeeds returns actions according to the provided options
- func GetFeeds(ctx context.Context, opts GetFeedsOptions) (ActionList, int64, error) {
- if opts.RequestedUser == nil && opts.RequestedTeam == nil && opts.RequestedRepo == nil {
- return nil, 0, fmt.Errorf("need at least one of these filters: RequestedUser, RequestedTeam, RequestedRepo")
- }
-
- cond, err := activityQueryCondition(ctx, opts)
- if err != nil {
- return nil, 0, err
- }
-
- sess := db.GetEngine(ctx).Where(cond).
- Select("`action`.*"). // this line will avoid select other joined table's columns
- Join("INNER", "repository", "`repository`.id = `action`.repo_id")
-
- opts.SetDefaultValues()
- sess = db.SetSessionPagination(sess, &opts)
-
- actions := make(ActionList, 0, opts.PageSize)
- count, err := sess.Desc("`action`.created_unix").FindAndCount(&actions)
- if err != nil {
- return nil, 0, fmt.Errorf("FindAndCount: %w", err)
- }
-
- if err := actions.LoadAttributes(ctx); err != nil {
- return nil, 0, fmt.Errorf("LoadAttributes: %w", err)
- }
-
- if opts.Actor != nil && opts.RequestedUser != nil {
- isPrivateForActor := !opts.Actor.IsAdmin && opts.Actor.ID != opts.RequestedUser.ID
-
- // cache user repo read permissions
- canReadRepo := make(map[int64]optional.Option[bool], 0)
-
- for _, action := range actions {
- action.IsPrivateView = isPrivateForActor && action.IsPrivate
-
- if action.IsPrivateView && action.Repo.Owner.IsOrganization() {
- if !canReadRepo[action.Repo.ID].Has() {
- perm, err := access_model.GetUserRepoPermission(ctx, action.Repo, opts.Actor)
- if err != nil {
- return nil, 0, fmt.Errorf("GetUserRepoPermission: %w", err)
- }
- canRead := perm.CanRead(unit.TypeCode)
- action.IsPrivateView = !canRead
- canReadRepo[action.Repo.ID] = optional.Option[bool]{canRead}
- }
-
- action.IsPrivateView = !canReadRepo[action.Repo.ID].Value()
- }
- }
- } else {
- for _, action := range actions {
- action.IsPrivateView = action.IsPrivate
- }
- }
-
- return actions, count, nil
- }
-
- // ActivityReadable return whether doer can read activities of user
- func ActivityReadable(user, doer *user_model.User) bool {
- if doer != nil && (doer.IsAdmin || user.ID == doer.ID) {
- return true
- }
- if user.ActivityVisibility.ShowNone() {
- return false
- }
- return true
- }
-
- func activityQueryCondition(ctx context.Context, opts GetFeedsOptions) (builder.Cond, error) {
- cond := builder.NewCond()
-
- if opts.RequestedTeam != nil && opts.RequestedUser == nil {
- org, err := user_model.GetUserByID(ctx, opts.RequestedTeam.OrgID)
- if err != nil {
- return nil, err
- }
- opts.RequestedUser = org
- }
-
- // check activity visibility for actor ( similar to activityReadable() )
- if opts.Actor == nil {
- cond = cond.And(builder.In("act_user_id",
- builder.Select("`user`.id").Where(
- builder.Eq{"visibility": structs.VisibleTypePublic},
- ).Where(
- builder.Neq{"activity_visibility": structs.ActivityVisibilityNone},
- ).From("`user`"),
- ))
- } else if !opts.Actor.IsAdmin {
- uidCond := builder.Select("`user`.id").From("`user`").Where(
- builder.Neq{"activity_visibility": structs.ActivityVisibilityNone},
- ).Where(
- builder.In("visibility", structs.VisibleTypePublic, structs.VisibleTypeLimited),
- ).Or(builder.Eq{"id": opts.Actor.ID})
-
- if opts.RequestedUser != nil {
- if opts.RequestedUser.IsOrganization() {
- // An organization can always see the activities whose `act_user_id` is the same as its id.
- uidCond = uidCond.Or(builder.Eq{"id": opts.RequestedUser.ID})
- } else {
- // A user can always see the activities of the organizations to which the user belongs.
- uidCond = uidCond.Or(
- builder.Eq{"type": user_model.UserTypeOrganization}.
- And(builder.In("`user`.id", builder.Select("org_id").
- Where(builder.Eq{"uid": opts.RequestedUser.ID}).
- From("team_user"))),
- )
- }
- }
-
- cond = cond.And(builder.In("act_user_id", uidCond))
- }
-
- includePrivateRepos := opts.RequestedUser != nil && opts.RequestedUser.ActivityVisibility.ShowAll()
- // check readable repositories by doer/actor
- if !includePrivateRepos && (opts.Actor == nil || !opts.Actor.IsAdmin) {
- cond = cond.And(builder.In("repo_id", repo_model.AccessibleRepoIDsQuery(opts.Actor)))
- }
-
- if opts.RequestedRepo != nil {
- cond = cond.And(builder.Eq{"repo_id": opts.RequestedRepo.ID})
- }
-
- if opts.RequestedTeam != nil {
- env := organization.OrgFromUser(opts.RequestedUser).AccessibleTeamReposEnv(ctx, opts.RequestedTeam)
- teamRepoIDs, err := env.RepoIDs(1, opts.RequestedUser.NumRepos)
- if err != nil {
- return nil, fmt.Errorf("GetTeamRepositories: %w", err)
- }
- cond = cond.And(builder.In("repo_id", teamRepoIDs))
- }
-
- if opts.RequestedUser != nil {
- cond = cond.And(builder.Eq{"user_id": opts.RequestedUser.ID})
-
- if opts.OnlyPerformedBy {
- cond = cond.And(builder.Eq{"act_user_id": opts.RequestedUser.ID})
- }
- }
-
- if !opts.IncludePrivate {
- cond = cond.And(builder.Eq{"`action`.is_private": false})
- }
- if !opts.IncludeDeleted {
- cond = cond.And(builder.Eq{"is_deleted": false})
- }
-
- if opts.Date != "" {
- dateLow, err := time.ParseInLocation("2006-01-02", opts.Date, setting.DefaultUILocation)
- if err != nil {
- log.Warn("Unable to parse %s, filter not applied: %v", opts.Date, err)
- } else {
- dateHigh := dateLow.Add(86399000000000) // 23h59m59s
-
- cond = cond.And(builder.Gte{"`action`.created_unix": dateLow.Unix()})
- cond = cond.And(builder.Lte{"`action`.created_unix": dateHigh.Unix()})
- }
- }
-
- return cond, nil
- }
-
- // DeleteOldActions deletes all old actions from database.
- func DeleteOldActions(ctx context.Context, olderThan time.Duration) (err error) {
- if olderThan <= 0 {
- return nil
- }
-
- _, err = db.GetEngine(ctx).Where("created_unix < ?", time.Now().Add(-olderThan).Unix()).Delete(&Action{})
- return err
- }
-
- // NotifyWatchers creates batch of actions for every watcher.
- func NotifyWatchers(ctx context.Context, actions ...*Action) error {
- var watchers []*repo_model.Watch
- var repo *repo_model.Repository
- var err error
- var permCode []bool
- var permIssue []bool
- var permPR []bool
-
- e := db.GetEngine(ctx)
-
- for _, act := range actions {
- repoChanged := repo == nil || repo.ID != act.RepoID
-
- if repoChanged {
- // Add feeds for user self and all watchers.
- watchers, err = repo_model.GetWatchers(ctx, act.RepoID)
- if err != nil {
- return fmt.Errorf("get watchers: %w", err)
- }
- }
-
- // Add feed for actioner.
- act.UserID = act.ActUserID
- if _, err = e.Insert(act); err != nil {
- return fmt.Errorf("insert new actioner: %w", err)
- }
-
- if repoChanged {
- act.loadRepo(ctx)
- repo = act.Repo
-
- // check repo owner exist.
- if err := act.Repo.LoadOwner(ctx); err != nil {
- return fmt.Errorf("can't get repo owner: %w", err)
- }
- } else if act.Repo == nil {
- act.Repo = repo
- }
-
- // Add feed for organization
- if act.Repo.Owner.IsOrganization() && act.ActUserID != act.Repo.Owner.ID {
- act.ID = 0
- act.UserID = act.Repo.Owner.ID
- if err = db.Insert(ctx, act); err != nil {
- return fmt.Errorf("insert new actioner: %w", err)
- }
- }
-
- if repoChanged {
- permCode = make([]bool, len(watchers))
- permIssue = make([]bool, len(watchers))
- permPR = make([]bool, len(watchers))
- for i, watcher := range watchers {
- user, err := user_model.GetUserByID(ctx, watcher.UserID)
- if err != nil {
- permCode[i] = false
- permIssue[i] = false
- permPR[i] = false
- continue
- }
- perm, err := access_model.GetUserRepoPermission(ctx, repo, user)
- if err != nil {
- permCode[i] = false
- permIssue[i] = false
- permPR[i] = false
- continue
- }
- permCode[i] = perm.CanRead(unit.TypeCode)
- permIssue[i] = perm.CanRead(unit.TypeIssues)
- permPR[i] = perm.CanRead(unit.TypePullRequests)
- }
- }
-
- for i, watcher := range watchers {
- if act.ActUserID == watcher.UserID {
- continue
- }
- act.ID = 0
- act.UserID = watcher.UserID
- act.Repo.Units = nil
-
- switch act.OpType {
- case ActionCommitRepo, ActionPushTag, ActionDeleteTag, ActionPublishRelease, ActionDeleteBranch:
- if !permCode[i] {
- continue
- }
- case ActionCreateIssue, ActionCommentIssue, ActionCloseIssue, ActionReopenIssue:
- if !permIssue[i] {
- continue
- }
- case ActionCreatePullRequest, ActionCommentPull, ActionMergePullRequest, ActionClosePullRequest, ActionReopenPullRequest, ActionAutoMergePullRequest:
- if !permPR[i] {
- continue
- }
- }
-
- if err = db.Insert(ctx, act); err != nil {
- return fmt.Errorf("insert new action: %w", err)
- }
- }
- }
- return nil
- }
-
- // NotifyWatchersActions creates batch of actions for every watcher.
- func NotifyWatchersActions(ctx context.Context, acts []*Action) error {
- ctx, committer, err := db.TxContext(ctx)
- if err != nil {
- return err
- }
- defer committer.Close()
- for _, act := range acts {
- if err := NotifyWatchers(ctx, act); err != nil {
- return err
- }
- }
- return committer.Commit()
- }
-
- // DeleteIssueActions delete all actions related with issueID
- func DeleteIssueActions(ctx context.Context, repoID, issueID, issueIndex int64) error {
- // delete actions assigned to this issue
- e := db.GetEngine(ctx)
-
- // MariaDB has a performance bug: https://jira.mariadb.org/browse/MDEV-16289
- // so here it uses "DELETE ... WHERE IN" with pre-queried IDs.
- var lastCommentID int64
- commentIDs := make([]int64, 0, db.DefaultMaxInSize)
- for {
- commentIDs = commentIDs[:0]
- err := e.Select("`id`").Table(&issues_model.Comment{}).
- Where(builder.Eq{"issue_id": issueID}).And("`id` > ?", lastCommentID).
- OrderBy("`id`").Limit(db.DefaultMaxInSize).
- Find(&commentIDs)
- if err != nil {
- return err
- } else if len(commentIDs) == 0 {
- break
- } else if _, err = db.GetEngine(ctx).In("comment_id", commentIDs).Delete(&Action{}); err != nil {
- return err
- }
- lastCommentID = commentIDs[len(commentIDs)-1]
- }
-
- _, err := e.Where("repo_id = ?", repoID).
- In("op_type", ActionCreateIssue, ActionCreatePullRequest).
- Where("content LIKE ?", strconv.FormatInt(issueIndex, 10)+"|%"). // "IssueIndex|content..."
- Delete(&Action{})
- return err
- }
-
- // CountActionCreatedUnixString count actions where created_unix is an empty string
- func CountActionCreatedUnixString(ctx context.Context) (int64, error) {
- if setting.Database.Type.IsSQLite3() {
- return db.GetEngine(ctx).Where(`created_unix = ""`).Count(new(Action))
- }
- return 0, nil
- }
-
- // FixActionCreatedUnixString set created_unix to zero if it is an empty string
- func FixActionCreatedUnixString(ctx context.Context) (int64, error) {
- if setting.Database.Type.IsSQLite3() {
- res, err := db.GetEngine(ctx).Exec(`UPDATE action SET created_unix = 0 WHERE created_unix = ""`)
- if err != nil {
- return 0, err
- }
- return res.RowsAffected()
- }
- return 0, nil
- }
|