aboutsummaryrefslogtreecommitdiff
path: root/models
diff options
context:
space:
mode:
authorskyblue <ssx205@gmail.com>2014-04-12 09:42:15 +0800
committerskyblue <ssx205@gmail.com>2014-04-12 09:42:15 +0800
commitf8e97b75fbe7201830413fabead33967fb690827 (patch)
tree5a1234fdbc527799913c4eaf691f97769dc2fe8b /models
parent5c1312f38e8968e068125a1b1dd59060f3f29bfe (diff)
parentd6dac160dfcac068b31bda9316ddc3d4919e3288 (diff)
Merge branch 'dev' of github.com:gogits/gogs into dev
Diffstat (limited to 'models')
-rw-r--r--models/git.go84
-rw-r--r--models/models.go2
-rw-r--r--models/repo.go12
-rw-r--r--models/user.go2
4 files changed, 93 insertions, 7 deletions
diff --git a/models/git.go b/models/git.go
index 68e13905..f20e663b 100644
--- a/models/git.go
+++ b/models/git.go
@@ -6,7 +6,9 @@ package models
import (
"bufio"
+ "bytes"
"container/list"
+ "errors"
"fmt"
"io"
"os"
@@ -409,3 +411,85 @@ func GetDiff(repoPath, commitid string) (*Diff, error) {
defer rd.Close()
return ParsePatch(rd)
}
+
+const prettyLogFormat = `--pretty=format:%H%n%an <%ae> %at%n%s`
+
+func parsePrettyFormatLog(logByts []byte) (*list.List, error) {
+ l := list.New()
+ buf := bytes.NewBuffer(logByts)
+ if buf.Len() == 0 {
+ return l, nil
+ }
+
+ idx := 0
+ var commit *git.Commit
+
+ for {
+ line, err := buf.ReadString('\n')
+ if err != nil && err != io.EOF {
+ return nil, err
+ }
+ line = strings.TrimSpace(line)
+ // fmt.Println(line)
+
+ var parseErr error
+ switch idx {
+ case 0: // SHA1.
+ commit = &git.Commit{}
+ commit.Oid, parseErr = git.NewOidFromString(line)
+ case 1: // Signature.
+ commit.Author, parseErr = git.NewSignatureFromCommitline([]byte(line + " "))
+ case 2: // Commit message.
+ commit.CommitMessage = line
+ l.PushBack(commit)
+ idx = -1
+ }
+
+ if parseErr != nil {
+ return nil, parseErr
+ }
+
+ idx++
+
+ if err == io.EOF {
+ break
+ }
+ }
+
+ return l, nil
+}
+
+// SearchCommits searches commits in given branch and keyword of repository.
+func SearchCommits(repoPath, branch, keyword string) (*list.List, error) {
+ stdout, stderr, err := com.ExecCmdDirBytes(repoPath, "git", "log", branch, "-100",
+ "-i", "--grep="+keyword, prettyLogFormat)
+ if err != nil {
+ return nil, err
+ } else if len(stderr) > 0 {
+ return nil, errors.New(string(stderr))
+ }
+ return parsePrettyFormatLog(stdout)
+}
+
+// GetCommitsByRange returns certain number of commits with given page of repository.
+func GetCommitsByRange(repoPath, branch string, page int) (*list.List, error) {
+ stdout, stderr, err := com.ExecCmdDirBytes(repoPath, "git", "log", branch,
+ "--skip="+base.ToStr((page-1)*50), "--max-count=50", prettyLogFormat)
+ if err != nil {
+ return nil, err
+ } else if len(stderr) > 0 {
+ return nil, errors.New(string(stderr))
+ }
+ return parsePrettyFormatLog(stdout)
+}
+
+// GetCommitsCount returns the commits count of given branch of repository.
+func GetCommitsCount(repoPath, branch string) (int, error) {
+ stdout, stderr, err := com.ExecCmdDir(repoPath, "git", "rev-list", "--count", branch)
+ if err != nil {
+ return 0, err
+ } else if len(stderr) > 0 {
+ return 0, errors.New(stderr)
+ }
+ return base.StrTo(strings.TrimSpace(stdout)).Int()
+}
diff --git a/models/models.go b/models/models.go
index ee96207d..b380d0e0 100644
--- a/models/models.go
+++ b/models/models.go
@@ -32,7 +32,7 @@ var (
func init() {
tables = append(tables, new(User), new(PublicKey), new(Repository), new(Watch),
- new(Action), new(Access), new(Issue), new(Comment), new(Oauth2))
+ new(Action), new(Access), new(Issue), new(Comment), new(Oauth2), new(Follow))
}
func LoadModelsConfig() {
diff --git a/models/repo.go b/models/repo.go
index 91dc7102..ce8665cc 100644
--- a/models/repo.go
+++ b/models/repo.go
@@ -192,12 +192,6 @@ func CreateRepository(user *User, repoName, desc, repoLang, license string, priv
return nil, err
}
- c := exec.Command("git", "update-server-info")
- c.Dir = repoPath
- if err = c.Run(); err != nil {
- log.Error("repo.CreateRepository(exec update-server-info): %v", err)
- }
-
if err = NewRepoAction(user, repo); err != nil {
log.Error("repo.CreateRepository(NewRepoAction): %v", err)
}
@@ -210,6 +204,12 @@ func CreateRepository(user *User, repoName, desc, repoLang, license string, priv
return nil, err
}
+ c := exec.Command("git", "update-server-info")
+ c.Dir = repoPath
+ if err = c.Run(); err != nil {
+ log.Error("repo.CreateRepository(exec update-server-info): %v", err)
+ }
+
return repo, nil
}
diff --git a/models/user.go b/models/user.go
index b2fddd0a..5274970f 100644
--- a/models/user.go
+++ b/models/user.go
@@ -294,6 +294,8 @@ func DeleteUser(user *User) error {
return err
}
+ // Delete oauth2.
+
// Delete all feeds.
if _, err = orm.Delete(&Action{UserId: user.Id}); err != nil {
return err