123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746 |
- // Copyright 2014 The Gogs Authors. All rights reserved.
- // Use of this source code is governed by a MIT-style
- // license that can be found in the LICENSE file.
-
- package models
-
- import (
- "encoding/json"
- "fmt"
- "path"
- "regexp"
- "strconv"
- "strings"
- "time"
- "unicode"
-
- "code.gitea.io/git"
- "code.gitea.io/gitea/modules/base"
- "code.gitea.io/gitea/modules/log"
- "code.gitea.io/gitea/modules/setting"
- "code.gitea.io/gitea/modules/util"
- api "code.gitea.io/sdk/gitea"
-
- "github.com/Unknwon/com"
- "github.com/go-xorm/builder"
- )
-
- // 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
- )
-
- var (
- // Same as Github. See
- // https://help.github.com/articles/closing-issues-via-commit-messages
- issueCloseKeywords = []string{"close", "closes", "closed", "fix", "fixes", "fixed", "resolve", "resolves", "resolved"}
- issueReopenKeywords = []string{"reopen", "reopens", "reopened"}
-
- issueCloseKeywordsPat, issueReopenKeywordsPat *regexp.Regexp
- issueReferenceKeywordsPat *regexp.Regexp
- )
-
- const issueRefRegexpStr = `(?:\S+/\S=)?#\d+`
-
- func assembleKeywordsPattern(words []string) string {
- return fmt.Sprintf(`(?i)(?:%s) %s`, strings.Join(words, "|"), issueRefRegexpStr)
- }
-
- func init() {
- issueCloseKeywordsPat = regexp.MustCompile(assembleKeywordsPattern(issueCloseKeywords))
- issueReopenKeywordsPat = regexp.MustCompile(assembleKeywordsPattern(issueReopenKeywords))
- issueReferenceKeywordsPat = regexp.MustCompile(issueRefRegexpStr)
- }
-
- // 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 `xorm:"INDEX"` // Action user id.
- ActUser *User `xorm:"-"`
- RepoID int64 `xorm:"INDEX"`
- Repo *Repository `xorm:"-"`
- CommentID int64 `xorm:"INDEX"`
- Comment *Comment `xorm:"-"`
- IsDeleted bool `xorm:"INDEX NOT NULL DEFAULT false"`
- RefName string
- IsPrivate bool `xorm:"INDEX NOT NULL DEFAULT false"`
- Content string `xorm:"TEXT"`
- CreatedUnix util.TimeStamp `xorm:"INDEX created"`
- }
-
- // GetOpType gets the ActionType of this action.
- func (a *Action) GetOpType() ActionType {
- return a.OpType
- }
-
- func (a *Action) loadActUser() {
- if a.ActUser != nil {
- return
- }
- var err error
- a.ActUser, err = GetUserByID(a.ActUserID)
- if err == nil {
- return
- } else if IsErrUserNotExist(err) {
- a.ActUser = NewGhostUser()
- } else {
- log.Error(4, "GetUserByID(%d): %v", a.ActUserID, err)
- }
- }
-
- func (a *Action) loadRepo() {
- if a.Repo != nil {
- return
- }
- var err error
- a.Repo, err = GetRepositoryByID(a.RepoID)
- if err != nil {
- log.Error(4, "GetRepositoryByID(%d): %v", a.RepoID, err)
- }
- }
-
- // GetActUserName gets the action's user name.
- func (a *Action) GetActUserName() string {
- a.loadActUser()
- return a.ActUser.Name
- }
-
- // ShortActUserName gets the action's user name trimmed to max 20
- // chars.
- func (a *Action) ShortActUserName() string {
- return base.EllipsisString(a.GetActUserName(), 20)
- }
-
- // GetActAvatar the action's user's avatar link
- func (a *Action) GetActAvatar() string {
- a.loadActUser()
- return a.ActUser.RelAvatarLink()
- }
-
- // GetRepoUserName returns the name of the action repository owner.
- func (a *Action) GetRepoUserName() string {
- a.loadRepo()
- return a.Repo.MustOwner().Name
- }
-
- // ShortRepoUserName returns the name of the action repository owner
- // trimmed to max 20 chars.
- func (a *Action) ShortRepoUserName() string {
- return base.EllipsisString(a.GetRepoUserName(), 20)
- }
-
- // GetRepoName returns the name of the action repository.
- func (a *Action) GetRepoName() string {
- a.loadRepo()
- return a.Repo.Name
- }
-
- // ShortRepoName returns the name of the action repository
- // trimmed to max 33 chars.
- func (a *Action) ShortRepoName() string {
- return base.EllipsisString(a.GetRepoName(), 33)
- }
-
- // GetRepoPath returns the virtual path to the action repository.
- func (a *Action) GetRepoPath() string {
- return path.Join(a.GetRepoUserName(), a.GetRepoName())
- }
-
- // ShortRepoPath returns the virtual path to the action repository
- // trimmed to max 20 + 1 + 33 chars.
- func (a *Action) ShortRepoPath() string {
- return path.Join(a.ShortRepoUserName(), a.ShortRepoName())
- }
-
- // GetRepoLink returns relative link to action repository.
- func (a *Action) GetRepoLink() string {
- if len(setting.AppSubURL) > 0 {
- return path.Join(setting.AppSubURL, a.GetRepoPath())
- }
- return "/" + a.GetRepoPath()
- }
-
- // GetCommentLink returns link to action comment.
- func (a *Action) GetCommentLink() string {
- if a == nil {
- return "#"
- }
- if a.Comment == nil && a.CommentID != 0 {
- a.Comment, _ = GetCommentByID(a.CommentID)
- }
- if a.Comment != nil {
- return a.Comment.HTMLURL()
- }
- if len(a.GetIssueInfos()) == 0 {
- return "#"
- }
- //Return link to issue
- issueIDString := a.GetIssueInfos()[0]
- issueID, err := strconv.ParseInt(issueIDString, 10, 64)
- if err != nil {
- return "#"
- }
-
- issue, err := GetIssueByID(issueID)
- if err != nil {
- return "#"
- }
-
- return issue.HTMLURL()
- }
-
- // GetBranch returns the action's repository branch.
- func (a *Action) GetBranch() string {
- return a.RefName
- }
-
- // 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()
- }
-
- // GetIssueInfos returns a list of issues associated with
- // the action.
- func (a *Action) GetIssueInfos() []string {
- return strings.SplitN(a.Content, "|", 2)
- }
-
- // GetIssueTitle returns the title of first issue associated
- // with the action.
- func (a *Action) GetIssueTitle() string {
- index := com.StrTo(a.GetIssueInfos()[0]).MustInt64()
- issue, err := GetIssueByIndex(a.RepoID, index)
- if err != nil {
- log.Error(4, "GetIssueByIndex: %v", err)
- return "500 when get issue"
- }
- return issue.Title
- }
-
- // GetIssueContent returns the content of first issue associated with
- // this action.
- func (a *Action) GetIssueContent() string {
- index := com.StrTo(a.GetIssueInfos()[0]).MustInt64()
- issue, err := GetIssueByIndex(a.RepoID, index)
- if err != nil {
- log.Error(4, "GetIssueByIndex: %v", err)
- return "500 when get issue"
- }
- return issue.Content
- }
-
- func newRepoAction(e Engine, u *User, repo *Repository) (err error) {
- if err = notifyWatchers(e, &Action{
- ActUserID: u.ID,
- ActUser: u,
- OpType: ActionCreateRepo,
- RepoID: repo.ID,
- Repo: repo,
- IsPrivate: repo.IsPrivate,
- }); err != nil {
- return fmt.Errorf("notify watchers '%d/%d': %v", u.ID, repo.ID, err)
- }
-
- log.Trace("action.newRepoAction: %s/%s", u.Name, repo.Name)
- return err
- }
-
- // NewRepoAction adds new action for creating repository.
- func NewRepoAction(u *User, repo *Repository) (err error) {
- return newRepoAction(x, u, repo)
- }
-
- func renameRepoAction(e Engine, actUser *User, oldRepoName string, repo *Repository) (err error) {
- if err = notifyWatchers(e, &Action{
- ActUserID: actUser.ID,
- ActUser: actUser,
- OpType: ActionRenameRepo,
- RepoID: repo.ID,
- Repo: repo,
- IsPrivate: repo.IsPrivate,
- Content: oldRepoName,
- }); err != nil {
- return fmt.Errorf("notify watchers: %v", err)
- }
-
- log.Trace("action.renameRepoAction: %s/%s", actUser.Name, repo.Name)
- return nil
- }
-
- // RenameRepoAction adds new action for renaming a repository.
- func RenameRepoAction(actUser *User, oldRepoName string, repo *Repository) error {
- return renameRepoAction(x, actUser, oldRepoName, repo)
- }
-
- func issueIndexTrimRight(c rune) bool {
- return !unicode.IsDigit(c)
- }
-
- // PushCommit represents a commit in a push operation.
- type PushCommit struct {
- Sha1 string
- Message string
- AuthorEmail string
- AuthorName string
- CommitterEmail string
- CommitterName string
- Timestamp time.Time
- }
-
- // PushCommits represents list of commits in a push operation.
- type PushCommits struct {
- Len int
- Commits []*PushCommit
- CompareURL string
-
- avatars map[string]string
- }
-
- // NewPushCommits creates a new PushCommits object.
- func NewPushCommits() *PushCommits {
- return &PushCommits{
- avatars: make(map[string]string),
- }
- }
-
- // ToAPIPayloadCommits converts a PushCommits object to
- // api.PayloadCommit format.
- func (pc *PushCommits) ToAPIPayloadCommits(repoLink string) []*api.PayloadCommit {
- commits := make([]*api.PayloadCommit, len(pc.Commits))
- for i, commit := range pc.Commits {
- authorUsername := ""
- author, err := GetUserByEmail(commit.AuthorEmail)
- if err == nil {
- authorUsername = author.Name
- }
- committerUsername := ""
- committer, err := GetUserByEmail(commit.CommitterEmail)
- if err == nil {
- // TODO: check errors other than email not found.
- committerUsername = committer.Name
- }
- commits[i] = &api.PayloadCommit{
- ID: commit.Sha1,
- Message: commit.Message,
- URL: fmt.Sprintf("%s/commit/%s", repoLink, commit.Sha1),
- Author: &api.PayloadUser{
- Name: commit.AuthorName,
- Email: commit.AuthorEmail,
- UserName: authorUsername,
- },
- Committer: &api.PayloadUser{
- Name: commit.CommitterName,
- Email: commit.CommitterEmail,
- UserName: committerUsername,
- },
- Timestamp: commit.Timestamp,
- }
- }
- return commits
- }
-
- // AvatarLink tries to match user in database with e-mail
- // in order to show custom avatar, and falls back to general avatar link.
- func (pc *PushCommits) AvatarLink(email string) string {
- _, ok := pc.avatars[email]
- if !ok {
- u, err := GetUserByEmail(email)
- if err != nil {
- pc.avatars[email] = base.AvatarLink(email)
- if !IsErrUserNotExist(err) {
- log.Error(4, "GetUserByEmail: %v", err)
- }
- } else {
- pc.avatars[email] = u.RelAvatarLink()
- }
- }
-
- return pc.avatars[email]
- }
-
- // getIssueFromRef returns the issue referenced by a ref. Returns a nil *Issue
- // if the provided ref is misformatted or references a non-existent issue.
- func getIssueFromRef(repo *Repository, ref string) (*Issue, error) {
- ref = ref[strings.IndexByte(ref, ' ')+1:]
- ref = strings.TrimRightFunc(ref, issueIndexTrimRight)
-
- var refRepo *Repository
- poundIndex := strings.IndexByte(ref, '#')
- if poundIndex < 0 {
- return nil, nil
- } else if poundIndex == 0 {
- refRepo = repo
- } else {
- slashIndex := strings.IndexByte(ref, '/')
- if slashIndex < 0 || slashIndex >= poundIndex {
- return nil, nil
- }
- ownerName := ref[:slashIndex]
- repoName := ref[slashIndex+1 : poundIndex]
- var err error
- refRepo, err = GetRepositoryByOwnerAndName(ownerName, repoName)
- if err != nil {
- if IsErrRepoNotExist(err) {
- return nil, nil
- }
- return nil, err
- }
- }
- issueIndex, err := strconv.ParseInt(ref[poundIndex+1:], 10, 64)
- if err != nil {
- return nil, nil
- }
-
- issue, err := GetIssueByIndex(refRepo.ID, int64(issueIndex))
- if err != nil {
- if IsErrIssueNotExist(err) {
- return nil, nil
- }
- return nil, err
- }
- return issue, nil
- }
-
- // UpdateIssuesCommit checks if issues are manipulated by commit message.
- func UpdateIssuesCommit(doer *User, repo *Repository, commits []*PushCommit) error {
- // Commits are appended in the reverse order.
- for i := len(commits) - 1; i >= 0; i-- {
- c := commits[i]
-
- refMarked := make(map[int64]bool)
- for _, ref := range issueReferenceKeywordsPat.FindAllString(c.Message, -1) {
- issue, err := getIssueFromRef(repo, ref)
- if err != nil {
- return err
- }
-
- if issue == nil || refMarked[issue.ID] {
- continue
- }
- refMarked[issue.ID] = true
-
- message := fmt.Sprintf(`<a href="%s/commit/%s">%s</a>`, repo.Link(), c.Sha1, c.Message)
- if err = CreateRefComment(doer, repo, issue, message, c.Sha1); err != nil {
- return err
- }
- }
-
- refMarked = make(map[int64]bool)
- // FIXME: can merge this one and next one to a common function.
- for _, ref := range issueCloseKeywordsPat.FindAllString(c.Message, -1) {
- issue, err := getIssueFromRef(repo, ref)
- if err != nil {
- return err
- }
-
- if issue == nil || refMarked[issue.ID] {
- continue
- }
- refMarked[issue.ID] = true
-
- if issue.RepoID != repo.ID || issue.IsClosed {
- continue
- }
-
- if err = issue.ChangeStatus(doer, repo, true); err != nil {
- return err
- }
- }
-
- // It is conflict to have close and reopen at same time, so refsMarked doesn't need to reinit here.
- for _, ref := range issueReopenKeywordsPat.FindAllString(c.Message, -1) {
- issue, err := getIssueFromRef(repo, ref)
- if err != nil {
- return err
- }
-
- if issue == nil || refMarked[issue.ID] {
- continue
- }
- refMarked[issue.ID] = true
-
- if issue.RepoID != repo.ID || !issue.IsClosed {
- continue
- }
-
- if err = issue.ChangeStatus(doer, repo, false); err != nil {
- return err
- }
- }
- }
- return nil
- }
-
- // CommitRepoActionOptions represent options of a new commit action.
- type CommitRepoActionOptions struct {
- PusherName string
- RepoOwnerID int64
- RepoName string
- RefFullName string
- OldCommitID string
- NewCommitID string
- Commits *PushCommits
- }
-
- // CommitRepoAction adds new commit action to the repository, and prepare
- // corresponding webhooks.
- func CommitRepoAction(opts CommitRepoActionOptions) error {
- pusher, err := GetUserByName(opts.PusherName)
- if err != nil {
- return fmt.Errorf("GetUserByName [%s]: %v", opts.PusherName, err)
- }
-
- repo, err := GetRepositoryByName(opts.RepoOwnerID, opts.RepoName)
- if err != nil {
- return fmt.Errorf("GetRepositoryByName [owner_id: %d, name: %s]: %v", opts.RepoOwnerID, opts.RepoName, err)
- }
-
- // Change repository bare status and update last updated time.
- repo.IsBare = repo.IsBare && opts.Commits.Len <= 0
- if err = UpdateRepository(repo, false); err != nil {
- return fmt.Errorf("UpdateRepository: %v", err)
- }
-
- isNewBranch := false
- opType := ActionCommitRepo
- // Check it's tag push or branch.
- if strings.HasPrefix(opts.RefFullName, git.TagPrefix) {
- opType = ActionPushTag
- if opts.NewCommitID == git.EmptySHA {
- opType = ActionDeleteTag
- }
- opts.Commits = &PushCommits{}
- } else if opts.NewCommitID == git.EmptySHA {
- opType = ActionDeleteBranch
- opts.Commits = &PushCommits{}
- } else {
- // if not the first commit, set the compare URL.
- if opts.OldCommitID == git.EmptySHA {
- isNewBranch = true
- } else {
- opts.Commits.CompareURL = repo.ComposeCompareURL(opts.OldCommitID, opts.NewCommitID)
- }
-
- if err = UpdateIssuesCommit(pusher, repo, opts.Commits.Commits); err != nil {
- log.Error(4, "updateIssuesCommit: %v", err)
- }
- }
-
- if len(opts.Commits.Commits) > setting.UI.FeedMaxCommitNum {
- opts.Commits.Commits = opts.Commits.Commits[:setting.UI.FeedMaxCommitNum]
- }
-
- data, err := json.Marshal(opts.Commits)
- if err != nil {
- return fmt.Errorf("Marshal: %v", err)
- }
-
- refName := git.RefEndName(opts.RefFullName)
- if err = NotifyWatchers(&Action{
- ActUserID: pusher.ID,
- ActUser: pusher,
- OpType: opType,
- Content: string(data),
- RepoID: repo.ID,
- Repo: repo,
- RefName: refName,
- IsPrivate: repo.IsPrivate,
- }); err != nil {
- return fmt.Errorf("NotifyWatchers: %v", err)
- }
-
- defer func() {
- go HookQueue.Add(repo.ID)
- }()
-
- apiPusher := pusher.APIFormat()
- apiRepo := repo.APIFormat(AccessModeNone)
-
- var shaSum string
- var isHookEventPush = false
- switch opType {
- case ActionCommitRepo: // Push
- isHookEventPush = true
-
- if isNewBranch {
- gitRepo, err := git.OpenRepository(repo.RepoPath())
- if err != nil {
- log.Error(4, "OpenRepository[%s]: %v", repo.RepoPath(), err)
- }
-
- shaSum, err = gitRepo.GetBranchCommitID(refName)
- if err != nil {
- log.Error(4, "GetBranchCommitID[%s]: %v", opts.RefFullName, err)
- }
- if err = PrepareWebhooks(repo, HookEventCreate, &api.CreatePayload{
- Ref: refName,
- Sha: shaSum,
- RefType: "branch",
- Repo: apiRepo,
- Sender: apiPusher,
- }); err != nil {
- return fmt.Errorf("PrepareWebhooks: %v", err)
- }
- }
-
- case ActionDeleteBranch: // Delete Branch
- isHookEventPush = true
-
- case ActionPushTag: // Create
- isHookEventPush = true
-
- gitRepo, err := git.OpenRepository(repo.RepoPath())
- if err != nil {
- log.Error(4, "OpenRepository[%s]: %v", repo.RepoPath(), err)
- }
- shaSum, err = gitRepo.GetTagCommitID(refName)
- if err != nil {
- log.Error(4, "GetTagCommitID[%s]: %v", opts.RefFullName, err)
- }
- if err = PrepareWebhooks(repo, HookEventCreate, &api.CreatePayload{
- Ref: refName,
- Sha: shaSum,
- RefType: "tag",
- Repo: apiRepo,
- Sender: apiPusher,
- }); err != nil {
- return fmt.Errorf("PrepareWebhooks: %v", err)
- }
- case ActionDeleteTag: // Delete Tag
- isHookEventPush = true
- }
-
- if isHookEventPush {
- if err = PrepareWebhooks(repo, HookEventPush, &api.PushPayload{
- Ref: opts.RefFullName,
- Before: opts.OldCommitID,
- After: opts.NewCommitID,
- CompareURL: setting.AppURL + opts.Commits.CompareURL,
- Commits: opts.Commits.ToAPIPayloadCommits(repo.HTMLURL()),
- Repo: apiRepo,
- Pusher: apiPusher,
- Sender: apiPusher,
- }); err != nil {
- return fmt.Errorf("PrepareWebhooks: %v", err)
- }
- }
-
- return nil
- }
-
- func transferRepoAction(e Engine, doer, oldOwner *User, repo *Repository) (err error) {
- if err = notifyWatchers(e, &Action{
- ActUserID: doer.ID,
- ActUser: doer,
- OpType: ActionTransferRepo,
- RepoID: repo.ID,
- Repo: repo,
- IsPrivate: repo.IsPrivate,
- Content: path.Join(oldOwner.Name, repo.Name),
- }); err != nil {
- return fmt.Errorf("notifyWatchers: %v", err)
- }
-
- // Remove watch for organization.
- if oldOwner.IsOrganization() {
- if err = watchRepo(e, oldOwner.ID, repo.ID, false); err != nil {
- return fmt.Errorf("watchRepo [false]: %v", err)
- }
- }
-
- return nil
- }
-
- // TransferRepoAction adds new action for transferring repository,
- // the Owner field of repository is assumed to be new owner.
- func TransferRepoAction(doer, oldOwner *User, repo *Repository) error {
- return transferRepoAction(x, doer, oldOwner, repo)
- }
-
- func mergePullRequestAction(e Engine, doer *User, repo *Repository, issue *Issue) error {
- return notifyWatchers(e, &Action{
- ActUserID: doer.ID,
- ActUser: doer,
- OpType: ActionMergePullRequest,
- Content: fmt.Sprintf("%d|%s", issue.Index, issue.Title),
- RepoID: repo.ID,
- Repo: repo,
- IsPrivate: repo.IsPrivate,
- })
- }
-
- // MergePullRequestAction adds new action for merging pull request.
- func MergePullRequestAction(actUser *User, repo *Repository, pull *Issue) error {
- return mergePullRequestAction(x, actUser, repo, pull)
- }
-
- // GetFeedsOptions options for retrieving feeds
- type GetFeedsOptions struct {
- RequestedUser *User
- RequestingUserID int64
- IncludePrivate bool // include private actions
- OnlyPerformedBy bool // only actions performed by requested user
- IncludeDeleted bool // include deleted actions
- }
-
- // GetFeeds returns actions according to the provided options
- func GetFeeds(opts GetFeedsOptions) ([]*Action, error) {
- cond := builder.NewCond()
-
- var repoIDs []int64
- if opts.RequestedUser.IsOrganization() {
- env, err := opts.RequestedUser.AccessibleReposEnv(opts.RequestingUserID)
- if err != nil {
- return nil, fmt.Errorf("AccessibleReposEnv: %v", err)
- }
- if repoIDs, err = env.RepoIDs(1, opts.RequestedUser.NumRepos); err != nil {
- return nil, fmt.Errorf("GetUserRepositories: %v", err)
- }
-
- cond = cond.And(builder.In("repo_id", repoIDs))
- }
-
- 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{"is_private": false})
- }
-
- if !opts.IncludeDeleted {
- cond = cond.And(builder.Eq{"is_deleted": false})
- }
-
- actions := make([]*Action, 0, 20)
- return actions, x.Limit(20).Desc("id").Where(cond).Find(&actions)
- }
|