aboutsummaryrefslogtreecommitdiff
path: root/models/repo.go
diff options
context:
space:
mode:
Diffstat (limited to 'models/repo.go')
-rw-r--r--models/repo.go526
1 files changed, 361 insertions, 165 deletions
diff --git a/models/repo.go b/models/repo.go
index 70f9341d..47036966 100644
--- a/models/repo.go
+++ b/models/repo.go
@@ -7,10 +7,14 @@ package models
import (
"errors"
"fmt"
+ "html"
+ "html/template"
"io/ioutil"
"os"
+ "os/exec"
"path"
"path/filepath"
+ "regexp"
"sort"
"strings"
"time"
@@ -19,10 +23,7 @@ import (
"github.com/Unknwon/cae/zip"
"github.com/Unknwon/com"
- "github.com/gogits/git"
-
- "github.com/gogits/gogs/modules/base"
- "github.com/gogits/gogs/modules/bin"
+ "github.com/gogits/gogs/modules/git"
"github.com/gogits/gogs/modules/log"
"github.com/gogits/gogs/modules/process"
"github.com/gogits/gogs/modules/setting"
@@ -39,34 +40,31 @@ var (
ErrRepoNameIllegal = errors.New("Repository name contains illegal characters")
ErrRepoFileNotLoaded = errors.New("Repository file not loaded")
ErrMirrorNotExist = errors.New("Mirror does not exist")
+ ErrInvalidReference = errors.New("Invalid reference specified")
)
var (
- LanguageIgns, Licenses []string
+ Gitignores, Licenses []string
)
-// getAssetList returns corresponding asset list in 'conf'.
-func getAssetList(prefix string) []string {
- assets := make([]string, 0, 15)
- for _, name := range bin.AssetNames() {
- if strings.HasPrefix(name, prefix) {
- assets = append(assets, strings.TrimPrefix(name, prefix+"/"))
- }
- }
- return assets
-}
+var (
+ DescriptionPattern = regexp.MustCompile(`https?://\S+`)
+)
func LoadRepoConfig() {
// Load .gitignore and license files.
types := []string{"gitignore", "license"}
typeFiles := make([][]string, 2)
for i, t := range types {
- files := getAssetList(path.Join("conf", t))
+ files, err := com.StatDir(path.Join("conf", t))
+ if err != nil {
+ log.Fatal(4, "Fail to get %s files: %v", t, err)
+ }
customPath := path.Join(setting.CustomPath, "conf", t)
if com.IsDir(customPath) {
customFiles, err := com.StatDir(customPath)
if err != nil {
- log.Fatal("Fail to get custom %s files: %v", t, err)
+ log.Fatal(4, "Fail to get custom %s files: %v", t, err)
}
for _, f := range customFiles {
@@ -78,36 +76,47 @@ func LoadRepoConfig() {
typeFiles[i] = files
}
- LanguageIgns = typeFiles[0]
+ Gitignores = typeFiles[0]
Licenses = typeFiles[1]
- sort.Strings(LanguageIgns)
+ sort.Strings(Gitignores)
sort.Strings(Licenses)
}
func NewRepoContext() {
zip.Verbose = false
+ // Check Git installation.
+ if _, err := exec.LookPath("git"); err != nil {
+ log.Fatal(4, "Fail to test 'git' command: %v (forgotten install?)", err)
+ }
+
+ // Check Git version.
+ ver, err := git.GetVersion()
+ if err != nil {
+ log.Fatal(4, "Fail to get Git version: %v", err)
+ }
+ if ver.Major < 2 && ver.Minor < 8 {
+ log.Fatal(4, "Gogs requires Git version greater or equal to 1.8.0")
+ }
+
// Check if server has basic git setting.
stdout, stderr, err := process.Exec("NewRepoContext(get setting)", "git", "config", "--get", "user.name")
- if strings.Contains(stderr, "fatal:") {
- log.Fatal("repo.NewRepoContext(fail to get git user.name): %s", stderr)
+ if err != nil {
+ log.Fatal(4, "Fail to get git user.name: %s", stderr)
} else if err != nil || len(strings.TrimSpace(stdout)) == 0 {
if _, stderr, err = process.Exec("NewRepoContext(set email)", "git", "config", "--global", "user.email", "gogitservice@gmail.com"); err != nil {
- log.Fatal("repo.NewRepoContext(fail to set git user.email): %s", stderr)
+ log.Fatal(4, "Fail to set git user.email: %s", stderr)
} else if _, stderr, err = process.Exec("NewRepoContext(set name)", "git", "config", "--global", "user.name", "Gogs"); err != nil {
- log.Fatal("repo.NewRepoContext(fail to set git user.name): %s", stderr)
+ log.Fatal(4, "Fail to set git user.name: %s", stderr)
}
}
- barePath := path.Join(setting.RepoRootPath, "git-bare.zip")
- if !com.IsExist(barePath) {
- data, err := bin.Asset("conf/content/git-bare.zip")
- if err != nil {
- log.Fatal("Fail to get asset 'git-bare.zip': %v", err)
- } else if err := ioutil.WriteFile(barePath, data, os.ModePerm); err != nil {
- log.Fatal("Fail to write asset 'git-bare.zip': %v", err)
- }
+ // Set git some configurations.
+ if _, stderr, err = process.Exec("NewRepoContext(git config --global core.quotepath false)",
+ "git", "config", "--global", "core.quotepath", "false"); err != nil {
+ log.Fatal(4, "Fail to execute 'git config --global core.quotepath false': %s", stderr)
}
+
}
// Repository represents a git repository.
@@ -126,12 +135,17 @@ type Repository struct {
NumIssues int
NumClosedIssues int
NumOpenIssues int `xorm:"-"`
+ NumPulls int
+ NumClosedPulls int
+ NumOpenPulls int `xorm:"-"`
NumMilestones int `xorm:"NOT NULL DEFAULT 0"`
NumClosedMilestones int `xorm:"NOT NULL DEFAULT 0"`
NumOpenMilestones int `xorm:"-"`
NumTags int `xorm:"-"`
IsPrivate bool
IsMirror bool
+ *Mirror `xorm:"-"`
+ IsFork bool `xorm:"NOT NULL DEFAULT false"`
IsBare bool
IsGoget bool
DefaultBranch string
@@ -144,6 +158,21 @@ func (repo *Repository) GetOwner() (err error) {
return err
}
+func (repo *Repository) GetMirror() (err error) {
+ repo.Mirror, err = GetMirror(repo.Id)
+ return err
+}
+
+// DescriptionHtml does special handles to description and return HTML string.
+func (repo *Repository) DescriptionHtml() template.HTML {
+ sanitize := func(s string) string {
+ // TODO(nuss-justin): Improve sanitization. Strip all tags?
+ ss := html.EscapeString(s)
+ return fmt.Sprintf(`<a href="%s" target="_blank">%s</a>`, ss, ss)
+ }
+ return template.HTML(DescriptionPattern.ReplaceAllStringFunc(repo.Description, sanitize))
+}
+
// IsRepositoryExist returns true if the repository with given name under user has already existed.
func IsRepositoryExist(u *User, repoName string) (bool, error) {
repo := Repository{OwnerId: u.Id}
@@ -188,10 +217,26 @@ type Mirror struct {
NextUpdate time.Time
}
+func GetMirror(repoId int64) (*Mirror, error) {
+ m := &Mirror{RepoId: repoId}
+ has, err := x.Get(m)
+ if err != nil {
+ return nil, err
+ } else if !has {
+ return nil, ErrMirrorNotExist
+ }
+ return m, nil
+}
+
+func UpdateMirror(m *Mirror) error {
+ _, err := x.Id(m.Id).Update(m)
+ return err
+}
+
// MirrorRepository creates a mirror repository from source.
func MirrorRepository(repoId int64, userName, repoName, repoPath, url string) error {
- // TODO: need timeout.
- _, stderr, err := process.Exec(fmt.Sprintf("MirrorRepository: %s/%s", userName, repoName),
+ _, stderr, err := process.ExecTimeout(10*time.Minute,
+ fmt.Sprintf("MirrorRepository: %s/%s", userName, repoName),
"git", "clone", "--mirror", url, repoPath)
if err != nil {
return errors.New("git clone --mirror: " + stderr)
@@ -205,24 +250,7 @@ func MirrorRepository(repoId int64, userName, repoName, repoPath, url string) er
}); err != nil {
return err
}
-
- return git.UnpackRefs(repoPath)
-}
-
-func GetMirror(repoId int64) (*Mirror, error) {
- m := &Mirror{RepoId: repoId}
- has, err := x.Get(m)
- if err != nil {
- return nil, err
- } else if !has {
- return nil, ErrMirrorNotExist
- }
- return m, nil
-}
-
-func UpdateMirror(m *Mirror) error {
- _, err := x.Id(m.Id).Update(m)
- return err
+ return nil
}
// MirrorUpdate checks and updates mirror repositories.
@@ -233,20 +261,17 @@ func MirrorUpdate() {
return nil
}
- // TODO: need timeout.
repoPath := filepath.Join(setting.RepoRootPath, m.RepoName+".git")
- if _, stderr, err := process.ExecDir(
+ if _, stderr, err := process.ExecDir(10*time.Minute,
repoPath, fmt.Sprintf("MirrorUpdate: %s", repoPath),
"git", "remote", "update"); err != nil {
return errors.New("git remote update: " + stderr)
- } else if err = git.UnpackRefs(repoPath); err != nil {
- return errors.New("UnpackRefs: " + err.Error())
}
m.NextUpdate = time.Now().Add(time.Duration(m.Interval) * time.Hour)
return UpdateMirror(m)
}); err != nil {
- log.Error("repo.MirrorUpdate: %v", err)
+ log.Error(4, "repo.MirrorUpdate: %v", err)
}
}
@@ -263,6 +288,16 @@ func MigrateRepository(u *User, name, desc string, private, mirror bool, url str
repoPath := RepoPath(u.Name, name)
+ if u.IsOrganization() {
+ t, err := u.GetOwnerTeam()
+ if err != nil {
+ return nil, err
+ }
+ repo.NumWatches = t.NumMembers
+ } else {
+ repo.NumWatches = 1
+ }
+
repo.IsBare = false
if mirror {
if err = MirrorRepository(repo.Id, u.Name, repo.Name, repoPath, url); err != nil {
@@ -272,28 +307,25 @@ func MigrateRepository(u *User, name, desc string, private, mirror bool, url str
return repo, UpdateRepository(repo)
}
- // TODO: need timeout.
// Clone from local repository.
- _, stderr, err := process.Exec(
+ _, stderr, err := process.ExecTimeout(10*time.Minute,
fmt.Sprintf("MigrateRepository(git clone): %s", repoPath),
"git", "clone", repoPath, tmpDir)
if err != nil {
return repo, errors.New("git clone: " + stderr)
}
- // TODO: need timeout.
- // Pull data from source.
- if _, stderr, err = process.ExecDir(
+ // Add remote and fetch data.
+ if _, stderr, err = process.ExecDir(3*time.Minute,
tmpDir, fmt.Sprintf("MigrateRepository(git pull): %s", repoPath),
- "git", "pull", url); err != nil {
- return repo, errors.New("git pull: " + stderr)
+ "git", "remote", "add", "-f", "--tags", "upstream", url); err != nil {
+ return repo, errors.New("git remote: " + stderr)
}
- // TODO: need timeout.
// Push data to local repository.
- if _, stderr, err = process.ExecDir(
+ if _, stderr, err = process.ExecDir(3*time.Minute,
tmpDir, fmt.Sprintf("MigrateRepository(git push): %s", repoPath),
- "git", "push", "origin", "master"); err != nil {
+ "git", "push", "--tags", "origin", "refs/remotes/upstream/*:refs/heads/*"); err != nil {
return repo, errors.New("git push: " + stderr)
}
@@ -302,7 +334,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(filepath.Join(setting.RepoRootPath, "git-bare.zip"))
+ z, err := zip.Open(path.Join(setting.ConfRootPath, "content/git-bare.zip"))
if err != nil {
return err
}
@@ -314,20 +346,20 @@ func extractGitBareZip(repoPath string) error {
// initRepoCommit temporarily changes with work directory.
func initRepoCommit(tmpPath string, sig *git.Signature) (err error) {
var stderr string
- if _, stderr, err = process.ExecDir(
+ if _, stderr, err = process.ExecDir(-1,
tmpPath, fmt.Sprintf("initRepoCommit(git add): %s", tmpPath),
"git", "add", "--all"); err != nil {
return errors.New("git add: " + stderr)
}
- if _, stderr, err = process.ExecDir(
+ if _, stderr, err = process.ExecDir(-1,
tmpPath, fmt.Sprintf("initRepoCommit(git commit): %s", tmpPath),
"git", "commit", fmt.Sprintf("--author='%s <%s>'", sig.Name, sig.Email),
"-m", "Init commit"); err != nil {
return errors.New("git commit: " + stderr)
}
- if _, stderr, err = process.ExecDir(
+ if _, stderr, err = process.ExecDir(-1,
tmpPath, fmt.Sprintf("initRepoCommit(git push): %s", tmpPath),
"git", "push", "origin", "master"); err != nil {
return errors.New("git push: " + stderr)
@@ -346,28 +378,18 @@ func createHookUpdate(hookPath, content string) error {
return err
}
-// SetRepoEnvs sets environment variables for command update.
-func SetRepoEnvs(userId int64, userName, repoName, repoUserName string) {
- os.Setenv("userId", base.ToStr(userId))
- os.Setenv("userName", userName)
- os.Setenv("repoName", repoName)
- os.Setenv("repoUserName", repoUserName)
-}
-
// InitRepository initializes README and .gitignore if needed.
-func initRepository(f string, user *User, repo *Repository, initReadme bool, repoLang, license string) error {
- repoPath := RepoPath(user.Name, repo.Name)
+func initRepository(f string, u *User, repo *Repository, initReadme bool, repoLang, license string) error {
+ repoPath := RepoPath(u.Name, repo.Name)
// Create bare new repository.
if err := extractGitBareZip(repoPath); err != nil {
return err
}
- rp := strings.NewReplacer("\\", "/", " ", "\\ ")
// hook/post-update
if err := createHookUpdate(filepath.Join(repoPath, "hooks", "update"),
- fmt.Sprintf(TPL_UPDATE_HOOK, setting.ScriptType,
- rp.Replace(appPath))); err != nil {
+ fmt.Sprintf(TPL_UPDATE_HOOK, setting.ScriptType, "\""+appPath+"\"")); err != nil {
return err
}
@@ -384,7 +406,7 @@ func initRepository(f string, user *User, repo *Repository, initReadme bool, rep
}
// Clone to temprory path and do the init commit.
- tmpDir := filepath.Join(os.TempDir(), base.ToStr(time.Now().Nanosecond()))
+ tmpDir := filepath.Join(os.TempDir(), com.ToStr(time.Now().Nanosecond()))
os.MkdirAll(tmpDir, os.ModePerm)
_, stderr, err := process.Exec(
@@ -405,12 +427,11 @@ func initRepository(f string, user *User, repo *Repository, initReadme bool, rep
}
// .gitignore
- if repoLang != "" {
- filePath := "conf/gitignore/" + repoLang
+ filePath := "conf/gitignore/" + repoLang
+ if com.IsFile(filePath) {
targetPath := path.Join(tmpDir, fileName["gitign"])
- data, err := bin.Asset(filePath)
- if err == nil {
- if err = ioutil.WriteFile(targetPath, data, os.ModePerm); err != nil {
+ if com.IsFile(filePath) {
+ if err = com.Copy(filePath, targetPath); err != nil {
return err
}
} else {
@@ -422,15 +443,16 @@ func initRepository(f string, user *User, repo *Repository, initReadme bool, rep
}
}
}
+ } else {
+ delete(fileName, "gitign")
}
// LICENSE
- if license != "" {
- filePath := "conf/license/" + license
+ filePath = "conf/license/" + license
+ if com.IsFile(filePath) {
targetPath := path.Join(tmpDir, fileName["license"])
- data, err := bin.Asset(filePath)
- if err == nil {
- if err = ioutil.WriteFile(targetPath, data, os.ModePerm); err != nil {
+ if com.IsFile(filePath) {
+ if err = com.Copy(filePath, targetPath); err != nil {
return err
}
} else {
@@ -442,16 +464,18 @@ func initRepository(f string, user *User, repo *Repository, initReadme bool, rep
}
}
}
+ } else {
+ delete(fileName, "license")
}
if len(fileName) == 0 {
- return nil
+ repo.IsBare = true
+ repo.DefaultBranch = "master"
+ return UpdateRepository(repo)
}
- SetRepoEnvs(user.Id, user.Name, repo.Name, user.Name)
-
// Apply changes and commit.
- return initRepoCommit(tmpDir, user.NewGitSig())
+ return initRepoCommit(tmpDir, u.NewGitSig())
}
// CreateRepository creates a repository for given user or organization.
@@ -480,10 +504,6 @@ func CreateRepository(u *User, name, desc, lang, license string, private, mirror
LowerName: strings.ToLower(name),
Description: desc,
IsPrivate: private,
- IsBare: lang == "" && license == "" && !initReadme,
- }
- if !repo.IsBare {
- repo.DefaultBranch = "master"
}
if _, err = sess.Insert(repo); err != nil {
@@ -499,7 +519,7 @@ func CreateRepository(u *User, name, desc, lang, license string, private, mirror
}
access := &Access{
UserName: u.LowerName,
- RepoName: strings.ToLower(path.Join(u.Name, repo.Name)),
+ RepoName: path.Join(u.LowerName, repo.LowerName),
Mode: mode,
}
// Give access to all members in owner team.
@@ -509,12 +529,12 @@ func CreateRepository(u *User, name, desc, lang, license string, private, mirror
sess.Rollback()
return nil, err
}
- us, err := GetTeamMembers(u.Id, t.Id)
- if err != nil {
+ if err = t.GetMembers(); err != nil {
sess.Rollback()
return nil, err
}
- for _, u := range us {
+ for _, u := range t.Members {
+ access.Id = 0
access.UserName = u.LowerName
if _, err = sess.Insert(access); err != nil {
sess.Rollback()
@@ -528,15 +548,15 @@ func CreateRepository(u *User, name, desc, lang, license string, private, mirror
}
}
- rawSql := "UPDATE `user` SET num_repos = num_repos + 1 WHERE id = ?"
- if _, err = sess.Exec(rawSql, u.Id); err != nil {
+ if _, err = sess.Exec(
+ "UPDATE `user` SET num_repos = num_repos + 1 WHERE id = ?", u.Id); err != nil {
sess.Rollback()
return nil, err
}
// Update owner team info and count.
if u.IsOrganization() {
- t.RepoIds += "$" + base.ToStr(repo.Id) + "|"
+ t.RepoIds += "$" + com.ToStr(repo.Id) + "|"
t.NumRepos++
if _, err = sess.Id(t.Id).AllCols().Update(t); err != nil {
sess.Rollback()
@@ -549,26 +569,31 @@ func CreateRepository(u *User, name, desc, lang, license string, private, mirror
}
if u.IsOrganization() {
- ous, err := GetOrgUsersByOrgId(u.Id)
+ t, err := u.GetOwnerTeam()
if err != nil {
- log.Error("repo.CreateRepository(GetOrgUsersByOrgId): %v", err)
+ log.Error(4, "GetOwnerTeam: %v", err)
} else {
- for _, ou := range ous {
- if err = WatchRepo(ou.Uid, repo.Id, true); err != nil {
- log.Error("repo.CreateRepository(WatchRepo): %v", err)
+ if err = t.GetMembers(); err != nil {
+ log.Error(4, "GetMembers: %v", err)
+ } else {
+ for _, u := range t.Members {
+ if err = WatchRepo(u.Id, repo.Id, true); err != nil {
+ log.Error(4, "WatchRepo2: %v", err)
+ }
}
}
}
- }
- if err = WatchRepo(u.Id, repo.Id, true); err != nil {
- log.Error("repo.CreateRepository(WatchRepo2): %v", err)
+ } else {
+ if err = WatchRepo(u.Id, repo.Id, true); err != nil {
+ log.Error(4, "WatchRepo3: %v", err)
+ }
}
if err = NewRepoAction(u, repo); err != nil {
- log.Error("repo.CreateRepository(NewRepoAction): %v", err)
+ log.Error(4, "NewRepoAction: %v", err)
}
- // No need for init for mirror.
+ // No need for init mirror.
if mirror {
return repo, nil
}
@@ -576,14 +601,14 @@ func CreateRepository(u *User, name, desc, lang, license string, private, mirror
repoPath := RepoPath(u.Name, repo.Name)
if err = initRepository(repoPath, u, repo, initReadme, lang, license); err != nil {
if err2 := os.RemoveAll(repoPath); err2 != nil {
- log.Error("repo.CreateRepository(initRepository): %v", err)
- return nil, errors.New(fmt.Sprintf(
- "delete repo directory %s/%s failed(2): %v", u.Name, repo.Name, err2))
+ log.Error(4, "initRepository: %v", err)
+ return nil, fmt.Errorf(
+ "delete repo directory %s/%s failed(2): %v", u.Name, repo.Name, err2)
}
- return nil, err
+ return nil, fmt.Errorf("initRepository: %v", err)
}
- _, stderr, err := process.ExecDir(
+ _, stderr, err := process.ExecDir(-1,
repoPath, fmt.Sprintf("CreateRepository(git update-server-info): %s", repoPath),
"git", "update-server-info")
if err != nil {
@@ -593,6 +618,12 @@ func CreateRepository(u *User, name, desc, lang, license string, private, mirror
return repo, nil
}
+// CountRepositories returns number of repositories.
+func CountRepositories() int64 {
+ count, _ := x.Count(new(Repository))
+ return count
+}
+
// GetRepositoriesWithUsers returns given number of repository objects with offset.
// It also auto-gets corresponding users.
func GetRepositoriesWithUsers(num, offset int) ([]*Repository, error) {
@@ -626,26 +657,23 @@ func TransferOwnership(u *User, newOwner string, repo *Repository) (err error) {
return err
}
- // Update accesses.
- accesses := make([]Access, 0, 10)
- if err = x.Find(&accesses, &Access{RepoName: u.LowerName + "/" + repo.LowerName}); err != nil {
- return err
- }
-
sess := x.NewSession()
defer sess.Close()
if err = sess.Begin(); err != nil {
return err
}
- for i := range accesses {
- accesses[i].RepoName = newUser.LowerName + "/" + repo.LowerName
- if accesses[i].UserName == u.LowerName {
- accesses[i].UserName = newUser.LowerName
- }
- if err = UpdateAccessWithSession(sess, &accesses[i]); err != nil {
- return err
- }
+ if _, err = sess.Where("repo_name = ?", u.LowerName+"/"+repo.LowerName).
+ And("user_name = ?", u.LowerName).Update(&Access{UserName: newUser.LowerName}); err != nil {
+ sess.Rollback()
+ return err
+ }
+
+ if _, err = sess.Where("repo_name = ?", u.LowerName+"/"+repo.LowerName).Update(&Access{
+ RepoName: newUser.LowerName + "/" + repo.LowerName,
+ }); err != nil {
+ sess.Rollback()
+ return err
}
// Update repository.
@@ -656,28 +684,59 @@ func TransferOwnership(u *User, newOwner string, repo *Repository) (err error) {
}
// Update user repository number.
- rawSql := "UPDATE `user` SET num_repos = num_repos + 1 WHERE id = ?"
- if _, err = sess.Exec(rawSql, newUser.Id); err != nil {
+ if _, err = sess.Exec("UPDATE `user` SET num_repos = num_repos + 1 WHERE id = ?", newUser.Id); err != nil {
sess.Rollback()
return err
}
- rawSql = "UPDATE `user` SET num_repos = num_repos - 1 WHERE id = ?"
- if _, err = sess.Exec(rawSql, u.Id); err != nil {
+
+ if _, err = sess.Exec("UPDATE `user` SET num_repos = num_repos - 1 WHERE id = ?", u.Id); err != nil {
sess.Rollback()
return err
}
- // Add watch of new owner to repository.
- if !IsWatching(newUser.Id, repo.Id) {
- if err = WatchRepo(newUser.Id, repo.Id, true); err != nil {
+ // New owner is organization.
+ if newUser.IsOrganization() {
+ mode := WRITABLE
+ if repo.IsMirror {
+ mode = READABLE
+ }
+ access := &Access{
+ RepoName: path.Join(newUser.LowerName, repo.LowerName),
+ Mode: mode,
+ }
+
+ // Give access to all members in owner team.
+ t, err := newUser.GetOwnerTeam()
+ if err != nil {
sess.Rollback()
return err
}
- }
+ if err = t.GetMembers(); err != nil {
+ sess.Rollback()
+ return err
+ }
+ for _, u := range t.Members {
+ access.Id = 0
+ access.UserName = u.LowerName
+ if _, err = sess.Insert(access); err != nil {
+ sess.Rollback()
+ return err
+ }
+ }
- if err = TransferRepoAction(u, newUser, repo); err != nil {
- sess.Rollback()
- return err
+ if _, err = sess.Exec(
+ "UPDATE `user` SET num_repos = num_repos + 1 WHERE id = ?", u.Id); err != nil {
+ sess.Rollback()
+ return err
+ }
+
+ // Update owner team info and count.
+ t.RepoIds += "$" + com.ToStr(repo.Id) + "|"
+ t.NumRepos++
+ if _, err = sess.Id(t.Id).AllCols().Update(t); err != nil {
+ sess.Rollback()
+ return err
+ }
}
// Change repository directory name.
@@ -686,11 +745,33 @@ func TransferOwnership(u *User, newOwner string, repo *Repository) (err error) {
return err
}
- return sess.Commit()
+ if err = sess.Commit(); err != nil {
+ return err
+ }
+
+ // Add watch of new owner to repository.
+ if !newUser.IsOrganization() {
+ if err = WatchRepo(newUser.Id, repo.Id, true); err != nil {
+ log.Error(4, "WatchRepo", err)
+ }
+ }
+ if err = WatchRepo(u.Id, repo.Id, false); err != nil {
+ log.Error(4, "WatchRepo2", err)
+ }
+
+ if err = TransferRepoAction(u, newUser, repo); err != nil {
+ return err
+ }
+
+ return nil
}
// ChangeRepositoryName changes all corresponding setting from old repository name to new one.
func ChangeRepositoryName(userName, oldRepoName, newRepoName string) (err error) {
+ if !IsLegalName(newRepoName) {
+ return ErrRepoNameIllegal
+ }
+
// Update accesses.
accesses := make([]Access, 0, 10)
if err = x.Find(&accesses, &Access{RepoName: strings.ToLower(userName + "/" + oldRepoName)}); err != nil {
@@ -733,8 +814,8 @@ func UpdateRepository(repo *Repository) error {
}
// DeleteRepository deletes a repository for a user or orgnaztion.
-func DeleteRepository(userId, repoId int64, userName string) error {
- repo := &Repository{Id: repoId, OwnerId: userId}
+func DeleteRepository(uid, repoId int64, userName string) error {
+ repo := &Repository{Id: repoId, OwnerId: uid}
has, err := x.Get(repo)
if err != nil {
return err
@@ -742,6 +823,17 @@ func DeleteRepository(userId, repoId int64, userName string) error {
return ErrRepoNotExist
}
+ // In case is a organization.
+ org, err := GetUserById(uid)
+ if err != nil {
+ return err
+ }
+ if org.IsOrganization() {
+ if err = org.GetTeams(); err != nil {
+ return err
+ }
+ }
+
sess := x.NewSession()
defer sess.Close()
if err = sess.Begin(); err != nil {
@@ -752,10 +844,27 @@ func DeleteRepository(userId, repoId int64, userName string) error {
sess.Rollback()
return err
}
+
+ // Delete all access.
if _, err := sess.Delete(&Access{RepoName: strings.ToLower(path.Join(userName, repo.Name))}); err != nil {
sess.Rollback()
return err
}
+ if org.IsOrganization() {
+ idStr := "$" + com.ToStr(repoId) + "|"
+ for _, t := range org.Teams {
+ if !strings.Contains(t.RepoIds, idStr) {
+ continue
+ }
+ t.NumRepos--
+ t.RepoIds = strings.Replace(t.RepoIds, idStr, "", 1)
+ if _, err = sess.Id(t.Id).AllCols().Update(t); err != nil {
+ sess.Rollback()
+ return err
+ }
+ }
+ }
+
if _, err := sess.Delete(&Action{RepoId: repo.Id}); err != nil {
sess.Rollback()
return err
@@ -799,8 +908,7 @@ func DeleteRepository(userId, repoId int64, userName string) error {
return err
}
- rawSql := "UPDATE `user` SET num_repos = num_repos - 1 WHERE id = ?"
- if _, err = sess.Exec(rawSql, userId); err != nil {
+ if _, err = sess.Exec("UPDATE `user` SET num_repos = num_repos - 1 WHERE id = ?", uid); err != nil {
sess.Rollback()
return err
}
@@ -811,6 +919,26 @@ func DeleteRepository(userId, repoId int64, userName string) error {
return sess.Commit()
}
+// GetRepositoryByRef returns a Repository specified by a GFM reference.
+// See https://help.github.com/articles/writing-on-github#references for more information on the syntax.
+func GetRepositoryByRef(ref string) (*Repository, error) {
+ n := strings.IndexByte(ref, byte('/'))
+
+ if n < 2 {
+ return nil, ErrInvalidReference
+ }
+
+ userName, repoName := ref[:n], ref[n+1:]
+
+ user, err := GetUserByName(userName)
+
+ if err != nil {
+ return nil, err
+ }
+
+ return GetRepositoryByName(user.Id, repoName)
+}
+
// GetRepositoryByName returns the repository by given name under user if exists.
func GetRepositoryByName(userId int64, repoName string) (*Repository, error) {
repo := &Repository{
@@ -922,6 +1050,37 @@ func GetCollaborators(repoName string) (us []*User, err error) {
return us, nil
}
+type SearchOption struct {
+ Keyword string
+ Uid int64
+ Limit int
+}
+
+// SearchRepositoryByName returns given number of repositories whose name contains keyword.
+func SearchRepositoryByName(opt SearchOption) (repos []*Repository, err error) {
+ // Prevent SQL inject.
+ opt.Keyword = strings.TrimSpace(opt.Keyword)
+ if len(opt.Keyword) == 0 {
+ return repos, nil
+ }
+
+ opt.Keyword = strings.Split(opt.Keyword, " ")[0]
+ if len(opt.Keyword) == 0 {
+ return repos, nil
+ }
+ opt.Keyword = strings.ToLower(opt.Keyword)
+
+ repos = make([]*Repository, 0, opt.Limit)
+
+ // Append conditions.
+ sess := x.Limit(opt.Limit)
+ if opt.Uid > 0 {
+ sess.Where("owner_id=?", opt.Uid)
+ }
+ sess.And("lower_name like '%" + opt.Keyword + "%'").Find(&repos)
+ return repos, err
+}
+
// Watch is connection request for receiving repository notifycation.
type Watch struct {
Id int64
@@ -930,24 +1089,33 @@ type Watch struct {
}
// Watch or unwatch repository.
-func WatchRepo(uid, rid int64, watch bool) (err error) {
+func WatchRepo(uid, repoId int64, watch bool) (err error) {
if watch {
- if _, err = x.Insert(&Watch{RepoId: rid, UserId: uid}); err != nil {
+ if IsWatching(uid, repoId) {
+ return nil
+ }
+ if _, err = x.Insert(&Watch{RepoId: repoId, UserId: uid}); err != nil {
return err
}
-
- rawSql := "UPDATE `repository` SET num_watches = num_watches + 1 WHERE id = ?"
- _, err = x.Exec(rawSql, rid)
+ _, err = x.Exec("UPDATE `repository` SET num_watches = num_watches + 1 WHERE id = ?", repoId)
} else {
- if _, err = x.Delete(&Watch{0, uid, rid}); err != nil {
+ if !IsWatching(uid, repoId) {
+ return nil
+ }
+ if _, err = x.Delete(&Watch{0, uid, repoId}); err != nil {
return err
}
- rawSql := "UPDATE `repository` SET num_watches = num_watches - 1 WHERE id = ?"
- _, err = x.Exec(rawSql, rid)
+ _, err = x.Exec("UPDATE `repository` SET num_watches = num_watches - 1 WHERE id = ?", repoId)
}
return err
}
+// IsWatching checks if user has watched given repository.
+func IsWatching(uid, rid int64) bool {
+ has, _ := x.Get(&Watch{0, uid, rid})
+ return has
+}
+
// GetWatchers returns all watchers of given repository.
func GetWatchers(rid int64) ([]*Watch, error) {
watches := make([]*Watch, 0, 10)
@@ -983,9 +1151,37 @@ func NotifyWatchers(act *Action) error {
return nil
}
-// IsWatching checks if user has watched given repository.
-func IsWatching(uid, rid int64) bool {
- has, _ := x.Get(&Watch{0, uid, rid})
+type Star struct {
+ Id int64
+ Uid int64 `xorm:"UNIQUE(s)"`
+ RepoId int64 `xorm:"UNIQUE(s)"`
+}
+
+// Star or unstar repository.
+func StarRepo(uid, repoId int64, star bool) (err error) {
+ if star {
+ if IsStaring(uid, repoId) {
+ return nil
+ }
+ if _, err = x.Insert(&Star{Uid: uid, RepoId: repoId}); err != nil {
+ return err
+ }
+ _, err = x.Exec("UPDATE `repository` SET num_stars = num_stars + 1 WHERE id = ?", repoId)
+ } else {
+ if !IsStaring(uid, repoId) {
+ return nil
+ }
+ if _, err = x.Delete(&Star{0, uid, repoId}); err != nil {
+ return err
+ }
+ _, err = x.Exec("UPDATE `repository` SET num_stars = num_stars - 1 WHERE id = ?", repoId)
+ }
+ return err
+}
+
+// IsStaring checks if user has starred given repository.
+func IsStaring(uid, repoId int64) bool {
+ has, _ := x.Get(&Star{0, uid, repoId})
return has
}
Powered by cgit, Themed by Ted Yin.