access.go 3.4 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154
  1. // Copyright 2014 The Gogs Authors. All rights reserved.
  2. // Use of this source code is governed by a MIT-style
  3. // license that can be found in the LICENSE file.
  4. package models
  5. //import (
  6. // "github.com/go-xorm/xorm"
  7. //)
  8. type AccessMode int
  9. const (
  10. NoAccess AccessMode = iota
  11. ReadAccess
  12. WriteAccess
  13. AdminAccess
  14. OwnerAccess
  15. )
  16. func maxAccessMode(modes ...AccessMode) AccessMode {
  17. max := NoAccess
  18. for _, mode := range modes {
  19. if mode > max {
  20. max = mode
  21. }
  22. }
  23. return max
  24. }
  25. // Access represents the highest access level of a user to the repository. The only access type
  26. // that is not in this table is the real owner of a repository. In case of an organization
  27. // repository, the members of the owners team are in this table.
  28. type Access struct {
  29. ID int64 `xorm:"pk autoincr"`
  30. UserID int64 `xorm:"UNIQUE(s)"`
  31. RepoID int64 `xorm:"UNIQUE(s)"`
  32. Mode AccessMode
  33. }
  34. // HasAccess returns true if someone has the request access level. User can be nil!
  35. func HasAccess(u *User, r *Repository, testMode AccessMode) (bool, error) {
  36. mode, err := AccessLevel(u, r)
  37. return testMode <= mode, err
  38. }
  39. // Return the Access a user has to a repository. Will return NoneAccess if the
  40. // user does not have access. User can be nil!
  41. func AccessLevel(u *User, r *Repository) (AccessMode, error) {
  42. mode := NoAccess
  43. if !r.IsPrivate {
  44. mode = ReadAccess
  45. }
  46. if u != nil {
  47. if u.Id == r.OwnerId {
  48. return OwnerAccess, nil
  49. }
  50. a := &Access{UserID: u.Id, RepoID: r.Id}
  51. if has, err := x.Get(a); !has || err != nil {
  52. return mode, err
  53. }
  54. return a.Mode, nil
  55. }
  56. return mode, nil
  57. }
  58. // GetAccessibleRepositories finds all repositories where a user has access to,
  59. // besides his own.
  60. func (u *User) GetAccessibleRepositories() (map[*Repository]AccessMode, error) {
  61. accesses := make([]*Access, 0, 10)
  62. if err := x.Find(&accesses, &Access{UserID: u.Id}); err != nil {
  63. return nil, err
  64. }
  65. repos := make(map[*Repository]AccessMode, len(accesses))
  66. for _, access := range accesses {
  67. repo, err := GetRepositoryById(access.RepoID)
  68. if err != nil {
  69. return nil, err
  70. }
  71. err = repo.GetOwner()
  72. if err != nil {
  73. return nil, err
  74. }
  75. repos[repo] = access.Mode
  76. }
  77. return repos, nil
  78. }
  79. // Recalculate all accesses for repository
  80. func (r *Repository) RecalcAccessSess() error {
  81. accessMap := make(map[int64]AccessMode, 20)
  82. // Give all collaborators write access
  83. collaborators, err := r.GetCollaborators()
  84. if err != nil {
  85. return err
  86. }
  87. for _, c := range collaborators {
  88. accessMap[c.Id] = WriteAccess
  89. }
  90. if err := r.GetOwner(); err != nil {
  91. return err
  92. }
  93. if r.Owner.IsOrganization() {
  94. if err = r.Owner.GetTeams(); err != nil {
  95. return err
  96. }
  97. for _, team := range r.Owner.Teams {
  98. if !(team.IsOwnerTeam() || team.HasRepository(r)) {
  99. continue
  100. }
  101. if err = team.GetMembers(); err != nil {
  102. return err
  103. }
  104. for _, u := range team.Members {
  105. accessMap[u.Id] = maxAccessMode(accessMap[u.Id], team.Authorize)
  106. }
  107. }
  108. }
  109. minMode := ReadAccess
  110. if !r.IsPrivate {
  111. minMode = WriteAccess
  112. }
  113. newAccesses := make([]Access, 0, len(accessMap))
  114. for userID, mode := range accessMap {
  115. if userID == r.OwnerId || mode <= minMode {
  116. continue
  117. }
  118. newAccesses = append(newAccesses, Access{UserID: userID, RepoID: r.Id, Mode: mode})
  119. }
  120. // Delete old accesses for repository
  121. if _, err = x.Delete(&Access{RepoID: r.Id}); err != nil {
  122. return err
  123. }
  124. // And insert the new ones
  125. if _, err = x.Insert(newAccesses); err != nil {
  126. return err
  127. }
  128. return nil
  129. }