access.go 3.5 KB

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