return setting.AppSubUrl + "/" + repo.Owner.Name + "/" + repo.Name, nil
}
+func (repo *Repository) HasAccess(u *User) bool {
+ has, _ := HasAccess(u, repo, ACCESS_MODE_READ)
+ return has
+}
+
func (repo *Repository) IsOwnedBy(u *User) bool {
return repo.OwnerId == u.Id
}
if _, err = sess.Insert(repo); err != nil {
return nil, err
+ } else if _, err = sess.Exec("UPDATE `user` SET num_repos = num_repos + 1 WHERE id = ?", u.Id); err != nil {
+ return nil, err
}
- var t *Team // Owner team.
-
// TODO fix code for mirrors?
// Give access to all members in owner team.
if err = repo.recalculateAccesses(sess); err != nil {
return nil, err
}
- }
-
- if _, err = sess.Exec("UPDATE `user` SET num_repos = num_repos + 1 WHERE id = ?", u.Id); err != nil {
- return nil, err
- }
-
- // Update owner team info and count.
- if u.IsOrganization() {
- t.RepoIds += "$" + com.ToStr(repo.Id) + "|"
- t.NumRepos++
- if _, err = sess.Id(t.Id).AllCols().Update(t); err != nil {
- return nil, err
- }
- }
- if u.IsOrganization() {
+ // Update owner team info and count.
t, err := u.getOwnerTeam(sess)
if err != nil {
return nil, fmt.Errorf("get owner team: %v", err)
return nil, fmt.Errorf("watch repository: %v", err)
}
}
+
+ t.RepoIds += "$" + com.ToStr(repo.Id) + "|"
+ t.NumRepos++
+ if _, err = sess.Id(t.Id).AllCols().Update(t); err != nil {
+ return nil, err
+ }
} else {
if err = watchRepo(sess, u.Id, repo.Id, true); err != nil {
return nil, fmt.Errorf("watch repository 2: %v", err)
}
sess := x.NewSession()
- defer sess.Close()
+ defer sessionRelease(sess)
if err = sess.Begin(); err != nil {
return err
}
- if _, err = sess.Delete(&Repository{Id: repoId}); err != nil {
- sess.Rollback()
- return err
- }
-
- // Delete all access.
- if _, err := sess.Delete(&Access{RepoID: repo.Id}); err != nil {
- sess.Rollback()
- return err
- }
if org.IsOrganization() {
idStr := "$" + com.ToStr(repoId) + "|"
for _, t := range org.Teams {
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()
+ if _, err = sess.Delete(&Repository{Id: repoId}); err != nil {
return err
- }
- if _, err = sess.Delete(&Watch{RepoId: repoId}); err != nil {
- sess.Rollback()
+ } else if _, err := sess.Delete(&Access{RepoID: repo.Id}); err != nil {
return err
- }
- if _, err = sess.Delete(&Mirror{RepoId: repoId}); err != nil {
- sess.Rollback()
+ } else if _, err := sess.Delete(&Action{RepoId: repo.Id}); err != nil {
return err
- }
- if _, err = sess.Delete(&IssueUser{RepoId: repoId}); err != nil {
- sess.Rollback()
+ } else if _, err = sess.Delete(&Watch{RepoId: repoId}); err != nil {
return err
- }
- if _, err = sess.Delete(&Milestone{RepoId: repoId}); err != nil {
- sess.Rollback()
+ } else if _, err = sess.Delete(&Mirror{RepoId: repoId}); err != nil {
return err
- }
- if _, err = sess.Delete(&Release{RepoId: repoId}); err != nil {
- sess.Rollback()
+ } else if _, err = sess.Delete(&IssueUser{RepoId: repoId}); err != nil {
+ return err
+ } else if _, err = sess.Delete(&Milestone{RepoId: repoId}); err != nil {
+ return err
+ } else if _, err = sess.Delete(&Release{RepoId: repoId}); err != nil {
return err
}
if err = x.Iterate(&Issue{RepoId: repoId}, func(idx int, bean interface{}) error {
issue := bean.(*Issue)
if _, err = sess.Delete(&Comment{IssueId: issue.Id}); err != nil {
- sess.Rollback()
return err
}
return nil
}); err != nil {
- sess.Rollback()
return err
}
if _, err = sess.Delete(&Issue{RepoId: repoId}); err != nil {
- sess.Rollback()
return err
}
if repo.IsFork {
if _, err = sess.Exec("UPDATE `repository` SET num_forks = num_forks - 1 WHERE id = ?", repo.ForkId); err != nil {
- sess.Rollback()
return err
}
}
if _, err = sess.Exec("UPDATE `user` SET num_repos = num_repos - 1 WHERE id = ?", uid); err != nil {
- sess.Rollback()
return err
}
log.Error(4, "Fail to add notice: %v", err)
}
}
+
return sess.Commit()
}
if err = repo.recalculateAccesses(sess); err != nil {
return nil, err
- }
-
- var t *Team // Owner team.
-
- if _, err = sess.Exec("UPDATE `user` SET num_repos = num_repos + 1 WHERE id = ?", u.Id); err != nil {
+ } else if _, err = sess.Exec("UPDATE `user` SET num_repos = num_repos + 1 WHERE id = ?", u.Id); err != nil {
return nil, err
}
- // Update owner team info and count.
- if u.IsOrganization() {
- t.RepoIds += "$" + com.ToStr(repo.Id) + "|"
- t.NumRepos++
- if _, err = sess.Id(t.Id).AllCols().Update(t); err != nil {
- return nil, err
- }
- }
-
if u.IsOrganization() {
+ // Update owner team info and count.
t, err := u.getOwnerTeam(sess)
if err != nil {
return nil, fmt.Errorf("get owner team: %v", err)
- } else {
- if err = t.getMembers(sess); err != nil {
- return nil, fmt.Errorf("get team members: %v", err)
- } else {
- for _, u := range t.Members {
- if err = watchRepo(sess, u.Id, repo.Id, true); err != nil {
- return nil, fmt.Errorf("watch repository: %v", err)
- }
- }
+ } else if err = t.getMembers(sess); err != nil {
+ return nil, fmt.Errorf("get team members: %v", err)
+ }
+
+ for _, u := range t.Members {
+ if err = watchRepo(sess, u.Id, repo.Id, true); err != nil {
+ return nil, fmt.Errorf("watch repository: %v", err)
}
}
+
+ t.RepoIds += "$" + com.ToStr(repo.Id) + "|"
+ t.NumRepos++
+ if _, err = sess.Id(t.Id).AllCols().Update(t); err != nil {
+ return nil, err
+ }
} else {
if err = watchRepo(sess, u.Id, repo.Id, true); err != nil {
return nil, fmt.Errorf("watch repository 2: %v", err)