123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151 |
- // 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 (
- "container/list"
- "fmt"
- "os/exec"
- "strings"
-
- "code.gitea.io/git"
-
- "code.gitea.io/gitea/modules/log"
- )
-
- // env keys for git hooks need
- const (
- EnvRepoName = "GITEA_REPO_NAME"
- EnvRepoUsername = "GITEA_REPO_USER_NAME"
- EnvRepoUserSalt = "GITEA_REPO_USER_SALT"
- EnvRepoIsWiki = "GITEA_REPO_IS_WIKI"
- EnvPusherName = "GITEA_PUSHER_NAME"
- EnvPusherID = "GITEA_PUSHER_ID"
- )
-
- // CommitToPushCommit transforms a git.Commit to PushCommit type.
- func CommitToPushCommit(commit *git.Commit) *PushCommit {
- return &PushCommit{
- Sha1: commit.ID.String(),
- Message: commit.Message(),
- AuthorEmail: commit.Author.Email,
- AuthorName: commit.Author.Name,
- CommitterEmail: commit.Committer.Email,
- CommitterName: commit.Committer.Name,
- Timestamp: commit.Author.When,
- }
- }
-
- // ListToPushCommits transforms a list.List to PushCommits type.
- func ListToPushCommits(l *list.List) *PushCommits {
- var commits []*PushCommit
- var actEmail string
- for e := l.Front(); e != nil; e = e.Next() {
- commit := e.Value.(*git.Commit)
- if actEmail == "" {
- actEmail = commit.Committer.Email
- }
- commits = append(commits, CommitToPushCommit(commit))
- }
- return &PushCommits{l.Len(), commits, "", nil}
- }
-
- // PushUpdateOptions defines the push update options
- type PushUpdateOptions struct {
- PusherID int64
- PusherName string
- RepoUserName string
- RepoName string
- RefFullName string
- OldCommitID string
- NewCommitID string
- }
-
- // PushUpdate must be called for any push actions in order to
- // generates necessary push action history feeds.
- func PushUpdate(opts PushUpdateOptions) (err error) {
- isNewRef := opts.OldCommitID == git.EmptySHA
- isDelRef := opts.NewCommitID == git.EmptySHA
- if isNewRef && isDelRef {
- return fmt.Errorf("Old and new revisions are both %s", git.EmptySHA)
- }
-
- repoPath := RepoPath(opts.RepoUserName, opts.RepoName)
-
- gitUpdate := exec.Command("git", "update-server-info")
- gitUpdate.Dir = repoPath
- if err = gitUpdate.Run(); err != nil {
- return fmt.Errorf("Failed to call 'git update-server-info': %v", err)
- }
-
- if isDelRef {
- log.GitLogger.Info("Reference '%s' has been deleted from '%s/%s' by %s",
- opts.RefFullName, opts.RepoUserName, opts.RepoName, opts.PusherName)
- return nil
- }
-
- gitRepo, err := git.OpenRepository(repoPath)
- if err != nil {
- return fmt.Errorf("OpenRepository: %v", err)
- }
-
- owner, err := GetUserByName(opts.RepoUserName)
- if err != nil {
- return fmt.Errorf("GetUserByName: %v", err)
- }
-
- repo, err := GetRepositoryByName(owner.ID, opts.RepoName)
- if err != nil {
- return fmt.Errorf("GetRepositoryByName: %v", err)
- }
-
- // Push tags.
- if strings.HasPrefix(opts.RefFullName, git.TagPrefix) {
- if err := CommitRepoAction(CommitRepoActionOptions{
- PusherName: opts.PusherName,
- RepoOwnerID: owner.ID,
- RepoName: repo.Name,
- RefFullName: opts.RefFullName,
- OldCommitID: opts.OldCommitID,
- NewCommitID: opts.NewCommitID,
- Commits: &PushCommits{},
- }); err != nil {
- return fmt.Errorf("CommitRepoAction (tag): %v", err)
- }
- return nil
- }
-
- newCommit, err := gitRepo.GetCommit(opts.NewCommitID)
- if err != nil {
- return fmt.Errorf("gitRepo.GetCommit: %v", err)
- }
-
- // Push new branch.
- var l *list.List
- if isNewRef {
- l, err = newCommit.CommitsBeforeLimit(10)
- if err != nil {
- return fmt.Errorf("newCommit.CommitsBeforeLimit: %v", err)
- }
- } else {
- l, err = newCommit.CommitsBeforeUntil(opts.OldCommitID)
- if err != nil {
- return fmt.Errorf("newCommit.CommitsBeforeUntil: %v", err)
- }
- }
-
- if err := CommitRepoAction(CommitRepoActionOptions{
- PusherName: opts.PusherName,
- RepoOwnerID: owner.ID,
- RepoName: repo.Name,
- RefFullName: opts.RefFullName,
- OldCommitID: opts.OldCommitID,
- NewCommitID: opts.NewCommitID,
- Commits: ListToPushCommits(l),
- }); err != nil {
- return fmt.Errorf("CommitRepoAction (branch): %v", err)
- }
- return nil
- }
|