diff options
author | Unknown <joe2010xtmf@163.com> | 2014-06-28 15:43:28 -0400 |
---|---|---|
committer | Unknown <joe2010xtmf@163.com> | 2014-06-28 15:43:28 -0400 |
commit | 99713e1180ad149faf6442bba311fec6e501aa00 (patch) | |
tree | 3bdcbf737babf55b47d0e4a6d69970b297920e48 /models | |
parent | 5dbfe3c26c3dd227e287d52134e978084d5081e3 (diff) | |
parent | 1c46d68abaf08890e10386b3af674233b4dda2d3 (diff) | |
download | gitea-99713e1180ad149faf6442bba311fec6e501aa00.tar.gz gitea-99713e1180ad149faf6442bba311fec6e501aa00.zip |
Merge branch 'dev' of github.com:gogits/gogs into dev
Diffstat (limited to 'models')
-rw-r--r-- | models/models.go | 3 | ||||
-rw-r--r-- | models/repo.go | 2 | ||||
-rw-r--r-- | models/update.go | 82 |
3 files changed, 75 insertions, 12 deletions
diff --git a/models/models.go b/models/models.go index 4e65c00bcb..070784f137 100644 --- a/models/models.go +++ b/models/models.go @@ -35,7 +35,8 @@ func init() { tables = append(tables, new(User), new(PublicKey), new(Repository), new(Watch), new(Action), new(Access), new(Issue), new(Comment), new(Oauth2), new(Follow), new(Mirror), new(Release), new(LoginSource), new(Webhook), new(IssueUser), - new(Milestone), new(Label), new(HookTask), new(Team), new(OrgUser), new(TeamUser)) + new(Milestone), new(Label), new(HookTask), new(Team), new(OrgUser), new(TeamUser), + new(UpdateTask)) } func LoadModelsConfig() { diff --git a/models/repo.go b/models/repo.go index 3d38ed6689..8eec131fee 100644 --- a/models/repo.go +++ b/models/repo.go @@ -302,7 +302,7 @@ func MigrateRepository(u *User, name, desc string, private, mirror bool, url str // extractGitBareZip extracts git-bare.zip to repository path. func extractGitBareZip(repoPath string) error { - z, err := zip.Open(path.Join(setting.RepoRootPath, "git-bare.zip")) + z, err := zip.Open(filepath.Join(setting.RepoRootPath, "git-bare.zip")) if err != nil { return err } diff --git a/models/update.go b/models/update.go index 3328f2213f..cf7f5d2a79 100644 --- a/models/update.go +++ b/models/update.go @@ -16,7 +16,39 @@ import ( "github.com/gogits/gogs/modules/log" ) +type UpdateTask struct { + Id int64 + Uuid string `xorm:"index"` + RefName string + OldCommitId string + NewCommitId string +} + +func AddUpdateTask(task *UpdateTask) error { + _, err := x.Insert(task) + return err +} + +func GetUpdateTasksByUuid(uuid string) ([]*UpdateTask, error) { + task := &UpdateTask{ + Uuid: uuid, + } + tasks := make([]*UpdateTask, 0) + err := x.Find(&tasks, task) + if err != nil { + return nil, err + } + return tasks, nil +} + +func DelUpdateTasksByUuid(uuid string) error { + _, err := x.Delete(&UpdateTask{Uuid: uuid}) + return err +} + func Update(refName, oldCommitId, newCommitId, userName, repoUserName, repoName string, userId int64) error { + //fmt.Println(refName, oldCommitId, newCommitId) + //fmt.Println(userName, repoUserName, repoName) isNew := strings.HasPrefix(oldCommitId, "0000000") if isNew && strings.HasPrefix(newCommitId, "0000000") { @@ -40,6 +72,44 @@ func Update(refName, oldCommitId, newCommitId, userName, repoUserName, repoName return fmt.Errorf("runUpdate.Open repoId: %v", err) } + ru, err := GetUserByName(repoUserName) + if err != nil { + return fmt.Errorf("runUpdate.GetUserByName: %v", err) + } + + repos, err := GetRepositoryByName(ru.Id, repoName) + if err != nil { + return fmt.Errorf("runUpdate.GetRepositoryByName userId: %v", err) + } + + // if tags push + if strings.HasPrefix(refName, "refs/tags/") { + tagName := git.RefEndName(refName) + tag, err := repo.GetTag(tagName) + if err != nil { + log.GitLogger.Fatal("runUpdate.GetTag: %v", err) + } + + var actEmail string + if tag.Tagger != nil { + actEmail = tag.Tagger.Email + } else { + cmt, err := tag.Commit() + if err != nil { + log.GitLogger.Fatal("runUpdate.GetTag Commit: %v", err) + } + actEmail = cmt.Committer.Email + } + + commit := &base.PushCommits{} + + if err = CommitRepoAction(userId, ru.Id, userName, actEmail, + repos.Id, repoUserName, repoName, refName, commit); err != nil { + log.GitLogger.Fatal("runUpdate.models.CommitRepoAction: %s/%s:%v", repoUserName, repoName, err) + } + return err + } + newCommit, err := repo.GetCommit(newCommitId) if err != nil { return fmt.Errorf("runUpdate GetCommit of newCommitId: %v", err) @@ -63,21 +133,13 @@ func Update(refName, oldCommitId, newCommitId, userName, repoUserName, repoName return fmt.Errorf("runUpdate.Commit repoId: %v", err) } - ru, err := GetUserByName(repoUserName) - if err != nil { - return fmt.Errorf("runUpdate.GetUserByName: %v", err) - } - - repos, err := GetRepositoryByName(ru.Id, repoName) - if err != nil { - return fmt.Errorf("runUpdate.GetRepositoryByName userId: %v", err) - } - + // if commits push commits := make([]*base.PushCommit, 0) var maxCommits = 3 var actEmail string for e := l.Front(); e != nil; e = e.Next() { commit := e.Value.(*git.Commit) + if actEmail == "" { actEmail = commit.Committer.Email } |