|
|
@ -145,25 +145,6 @@ func (repo *Repository) refreshCollaboratorAccesses(e Engine, accessMap map[int6 |
|
|
|
for _, c := range collaborators { |
|
|
|
for _, c := range collaborators { |
|
|
|
accessMap[c.Id] = ACCESS_MODE_WRITE |
|
|
|
accessMap[c.Id] = ACCESS_MODE_WRITE |
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
// Adds team members access.
|
|
|
|
|
|
|
|
if repo.Owner.IsOrganization() { |
|
|
|
|
|
|
|
if err = repo.Owner.GetTeams(); err != nil { |
|
|
|
|
|
|
|
return fmt.Errorf("GetTeams: %v", err) |
|
|
|
|
|
|
|
} |
|
|
|
|
|
|
|
for _, t := range repo.Owner.Teams { |
|
|
|
|
|
|
|
if err = t.GetMembers(); err != nil { |
|
|
|
|
|
|
|
return fmt.Errorf("GetMembers: %v", err) |
|
|
|
|
|
|
|
} |
|
|
|
|
|
|
|
for _, m := range t.Members { |
|
|
|
|
|
|
|
if t.IsOwnerTeam() { |
|
|
|
|
|
|
|
accessMap[m.Id] = ACCESS_MODE_OWNER |
|
|
|
|
|
|
|
} else { |
|
|
|
|
|
|
|
accessMap[m.Id] = maxAccessMode(accessMap[m.Id], t.Authorize) |
|
|
|
|
|
|
|
} |
|
|
|
|
|
|
|
} |
|
|
|
|
|
|
|
} |
|
|
|
|
|
|
|
} |
|
|
|
|
|
|
|
return nil |
|
|
|
return nil |
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
@ -175,34 +156,36 @@ func (repo *Repository) recalculateTeamAccesses(e Engine, ignTeamID int64) (err |
|
|
|
|
|
|
|
|
|
|
|
if err = repo.getOwner(e); err != nil { |
|
|
|
if err = repo.getOwner(e); err != nil { |
|
|
|
return err |
|
|
|
return err |
|
|
|
|
|
|
|
} else if !repo.Owner.IsOrganization() { |
|
|
|
|
|
|
|
return fmt.Errorf("owner is not an organization: %d", repo.OwnerID) |
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
if err = repo.refreshCollaboratorAccesses(e, accessMap); err != nil { |
|
|
|
if err = repo.refreshCollaboratorAccesses(e, accessMap); err != nil { |
|
|
|
return fmt.Errorf("refreshCollaboratorAccesses: %v", err) |
|
|
|
return fmt.Errorf("refreshCollaboratorAccesses: %v", err) |
|
|
|
} |
|
|
|
} |
|
|
|
if repo.Owner.IsOrganization() { |
|
|
|
|
|
|
|
if err = repo.Owner.getTeams(e); err != nil { |
|
|
|
|
|
|
|
return err |
|
|
|
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
for _, t := range repo.Owner.Teams { |
|
|
|
if err = repo.Owner.getTeams(e); err != nil { |
|
|
|
if t.ID == ignTeamID { |
|
|
|
return err |
|
|
|
continue |
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
// Owner team gets owner access, and skip for teams that do not
|
|
|
|
for _, t := range repo.Owner.Teams { |
|
|
|
// have relations with repository.
|
|
|
|
if t.ID == ignTeamID { |
|
|
|
if t.IsOwnerTeam() { |
|
|
|
continue |
|
|
|
t.Authorize = ACCESS_MODE_OWNER |
|
|
|
} |
|
|
|
} else if !t.hasRepository(e, repo.ID) { |
|
|
|
|
|
|
|
continue |
|
|
|
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
if err = t.getMembers(e); err != nil { |
|
|
|
// Owner team gets owner access, and skip for teams that do not
|
|
|
|
return fmt.Errorf("getMembers '%d': %v", t.ID, err) |
|
|
|
// have relations with repository.
|
|
|
|
} |
|
|
|
if t.IsOwnerTeam() { |
|
|
|
for _, m := range t.Members { |
|
|
|
t.Authorize = ACCESS_MODE_OWNER |
|
|
|
accessMap[m.Id] = maxAccessMode(accessMap[m.Id], t.Authorize) |
|
|
|
} else if !t.hasRepository(e, repo.ID) { |
|
|
|
} |
|
|
|
continue |
|
|
|
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
if err = t.getMembers(e); err != nil { |
|
|
|
|
|
|
|
return fmt.Errorf("getMembers '%d': %v", t.ID, err) |
|
|
|
|
|
|
|
} |
|
|
|
|
|
|
|
for _, m := range t.Members { |
|
|
|
|
|
|
|
accessMap[m.Id] = maxAccessMode(accessMap[m.Id], t.Authorize) |
|
|
|
} |
|
|
|
} |
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
@ -210,6 +193,10 @@ func (repo *Repository) recalculateTeamAccesses(e Engine, ignTeamID int64) (err |
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
func (repo *Repository) recalculateAccesses(e Engine) error { |
|
|
|
func (repo *Repository) recalculateAccesses(e Engine) error { |
|
|
|
|
|
|
|
if repo.Owner.IsOrganization() { |
|
|
|
|
|
|
|
return repo.recalculateTeamAccesses(e, 0) |
|
|
|
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
accessMap := make(map[int64]AccessMode, 20) |
|
|
|
accessMap := make(map[int64]AccessMode, 20) |
|
|
|
if err := repo.refreshCollaboratorAccesses(e, accessMap); err != nil { |
|
|
|
if err := repo.refreshCollaboratorAccesses(e, accessMap); err != nil { |
|
|
|
return fmt.Errorf("refreshCollaboratorAccesses: %v", err) |
|
|
|
return fmt.Errorf("refreshCollaboratorAccesses: %v", err) |
|
|
|