summaryrefslogtreecommitdiffstats
path: root/models
diff options
context:
space:
mode:
authorUnknown <joe2010xtmf@163.com>2014-06-28 15:43:28 -0400
committerUnknown <joe2010xtmf@163.com>2014-06-28 15:43:28 -0400
commit99713e1180ad149faf6442bba311fec6e501aa00 (patch)
tree3bdcbf737babf55b47d0e4a6d69970b297920e48 /models
parent5dbfe3c26c3dd227e287d52134e978084d5081e3 (diff)
parent1c46d68abaf08890e10386b3af674233b4dda2d3 (diff)
downloadgitea-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.go3
-rw-r--r--models/repo.go2
-rw-r--r--models/update.go82
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
}