forgejo/models/access.go

158 lines
3.7 KiB
Go
Raw Normal View History

2014-02-17 23:38:50 +00:00
// Copyright 2014 The Gogs Authors. All rights reserved.
// Use of this source code is governed by a MIT-style
// license that can be found in the LICENSE file.
2014-02-17 15:57:23 +00:00
package models
type AccessMode int
2014-06-25 04:44:48 +00:00
2014-02-17 15:57:23 +00:00
const (
ACCESS_MODE_NONE AccessMode = iota
ACCESS_MODE_READ
ACCESS_MODE_WRITE
ACCESS_MODE_ADMIN
ACCESS_MODE_OWNER
2014-02-17 15:57:23 +00:00
)
// Access represents the highest access level of a user to the repository. The only access type
// that is not in this table is the real owner of a repository. In case of an organization
// repository, the members of the owners team are in this table.
type Access struct {
ID int64 `xorm:"pk autoincr"`
UserID int64 `xorm:"UNIQUE(s)"`
RepoID int64 `xorm:"UNIQUE(s)"`
Mode AccessMode
2014-02-17 15:57:23 +00:00
}
// Return the Access a user has to a repository. Will return NoneAccess if the
// user does not have access. User can be nil!
func AccessLevel(u *User, r *Repository) (AccessMode, error) {
mode := ACCESS_MODE_NONE
if !r.IsPrivate {
mode = ACCESS_MODE_READ
2015-02-12 02:58:37 +00:00
}
2014-05-01 15:32:12 +00:00
if u != nil {
if u.Id == r.OwnerId {
return ACCESS_MODE_OWNER, nil
}
2014-04-04 22:55:17 +00:00
a := &Access{UserID: u.Id, RepoID: r.Id}
if has, err := x.Get(a); !has || err != nil {
return mode, err
}
return a.Mode, nil
2014-04-12 01:47:39 +00:00
}
return mode, nil
2014-02-17 15:57:23 +00:00
}
2015-01-23 07:54:16 +00:00
2015-02-13 05:58:46 +00:00
// HasAccess returns true if someone has the request access level. User can be nil!
func HasAccess(u *User, r *Repository, testMode AccessMode) (bool, error) {
mode, err := AccessLevel(u, r)
return testMode <= mode, err
}
2015-01-23 07:54:16 +00:00
// GetAccessibleRepositories finds all repositories where a user has access to,
// besides his own.
func (u *User) GetAccessibleRepositories() (map[*Repository]AccessMode, error) {
2015-01-23 07:54:16 +00:00
accesses := make([]*Access, 0, 10)
if err := x.Find(&accesses, &Access{UserID: u.Id}); err != nil {
2015-01-23 07:54:16 +00:00
return nil, err
}
repos := make(map[*Repository]AccessMode, len(accesses))
2015-01-23 07:54:16 +00:00
for _, access := range accesses {
repo, err := GetRepositoryById(access.RepoID)
2015-01-23 07:54:16 +00:00
if err != nil {
return nil, err
}
2015-02-12 02:58:37 +00:00
if err = repo.GetOwner(); err != nil {
return nil, err
2015-02-12 02:58:37 +00:00
} else if repo.OwnerId == u.Id {
continue
}
2015-01-23 07:54:16 +00:00
repos[repo] = access.Mode
}
return repos, nil
}
2015-02-13 05:58:46 +00:00
func maxAccessMode(modes ...AccessMode) AccessMode {
max := ACCESS_MODE_NONE
for _, mode := range modes {
if mode > max {
max = mode
}
}
return max
}
func (repo *Repository) recalculateAccesses(e Engine) error {
accessMap := make(map[int64]AccessMode, 20)
// Give all collaborators write access
2015-02-13 05:58:46 +00:00
collaborators, err := repo.getCollaborators(e)
if err != nil {
return err
}
for _, c := range collaborators {
accessMap[c.Id] = ACCESS_MODE_WRITE
}
2015-02-13 05:58:46 +00:00
if err := repo.getOwner(e); err != nil {
return err
}
2015-02-13 05:58:46 +00:00
if repo.Owner.IsOrganization() {
if err = repo.Owner.getTeams(e); err != nil {
return err
}
2015-02-13 05:58:46 +00:00
for _, team := range repo.Owner.Teams {
if !(team.IsOwnerTeam() || team.HasRepository(repo)) {
continue
}
2015-02-13 05:58:46 +00:00
if err = team.getMembers(e); err != nil {
return err
}
for _, u := range team.Members {
accessMap[u.Id] = maxAccessMode(accessMap[u.Id], team.Authorize)
}
}
}
minMode := ACCESS_MODE_READ
2015-02-13 05:58:46 +00:00
if !repo.IsPrivate {
minMode = ACCESS_MODE_WRITE
}
newAccesses := make([]Access, 0, len(accessMap))
for userID, mode := range accessMap {
2015-02-13 05:58:46 +00:00
if userID == repo.OwnerId || mode <= minMode {
continue
}
2015-02-13 05:58:46 +00:00
newAccesses = append(newAccesses, Access{
UserID: userID,
RepoID: repo.Id,
Mode: mode})
}
// Delete old accesses for repository
2015-02-13 05:58:46 +00:00
if _, err = e.Delete(&Access{RepoID: repo.Id}); err != nil {
return err
}
// And insert the new ones
2015-02-13 05:58:46 +00:00
if _, err = e.Insert(newAccesses); err != nil {
return err
}
return nil
2015-02-13 05:58:46 +00:00
}
2015-02-13 05:58:46 +00:00
// RecalculateAccesses recalculates all accesses for repository.
func (r *Repository) RecalculateAccesses() error {
return r.recalculateAccesses(x)
}