mirror of
https://github.com/grafana/grafana.git
synced 2024-11-28 03:34:15 -06:00
131 lines
2.6 KiB
Go
131 lines
2.6 KiB
Go
package guardian
|
|
|
|
import (
|
|
"github.com/grafana/grafana/pkg/bus"
|
|
"github.com/grafana/grafana/pkg/log"
|
|
m "github.com/grafana/grafana/pkg/models"
|
|
"github.com/grafana/grafana/pkg/setting"
|
|
)
|
|
|
|
type DashboardGuardian struct {
|
|
user *m.SignedInUser
|
|
dashId int64
|
|
orgId int64
|
|
acl []*m.DashboardAclInfoDTO
|
|
groups []*m.Team
|
|
log log.Logger
|
|
}
|
|
|
|
func NewDashboardGuardian(dashId int64, orgId int64, user *m.SignedInUser) *DashboardGuardian {
|
|
return &DashboardGuardian{
|
|
user: user,
|
|
dashId: dashId,
|
|
orgId: orgId,
|
|
log: log.New("guardians.dashboard"),
|
|
}
|
|
}
|
|
|
|
func (g *DashboardGuardian) CanSave() (bool, error) {
|
|
return g.HasPermission(m.PERMISSION_EDIT)
|
|
}
|
|
|
|
func (g *DashboardGuardian) CanEdit() (bool, error) {
|
|
if setting.ViewersCanEdit {
|
|
return g.HasPermission(m.PERMISSION_VIEW)
|
|
}
|
|
|
|
return g.HasPermission(m.PERMISSION_EDIT)
|
|
}
|
|
|
|
func (g *DashboardGuardian) CanView() (bool, error) {
|
|
return g.HasPermission(m.PERMISSION_VIEW)
|
|
}
|
|
|
|
func (g *DashboardGuardian) CanAdmin() (bool, error) {
|
|
return g.HasPermission(m.PERMISSION_ADMIN)
|
|
}
|
|
|
|
func (g *DashboardGuardian) HasPermission(permission m.PermissionType) (bool, error) {
|
|
if g.user.OrgRole == m.ROLE_ADMIN {
|
|
return true, nil
|
|
}
|
|
|
|
acl, err := g.GetAcl()
|
|
if err != nil {
|
|
return false, err
|
|
}
|
|
|
|
orgRole := g.user.OrgRole
|
|
teamAclItems := []*m.DashboardAclInfoDTO{}
|
|
|
|
for _, p := range acl {
|
|
// user match
|
|
if !g.user.IsAnonymous {
|
|
if p.UserId == g.user.UserId && p.Permission >= permission {
|
|
return true, nil
|
|
}
|
|
}
|
|
|
|
// role match
|
|
if p.Role != nil {
|
|
if *p.Role == orgRole && p.Permission >= permission {
|
|
return true, nil
|
|
}
|
|
}
|
|
|
|
// remember this rule for later
|
|
if p.TeamId > 0 {
|
|
teamAclItems = append(teamAclItems, p)
|
|
}
|
|
}
|
|
|
|
// do we have group rules?
|
|
if len(teamAclItems) == 0 {
|
|
return false, nil
|
|
}
|
|
|
|
// load groups
|
|
teams, err := g.getTeams()
|
|
if err != nil {
|
|
return false, err
|
|
}
|
|
|
|
// evalute group rules
|
|
for _, p := range acl {
|
|
for _, ug := range teams {
|
|
if ug.Id == p.TeamId && p.Permission >= permission {
|
|
return true, nil
|
|
}
|
|
}
|
|
}
|
|
|
|
return false, nil
|
|
}
|
|
|
|
// Returns dashboard acl
|
|
func (g *DashboardGuardian) GetAcl() ([]*m.DashboardAclInfoDTO, error) {
|
|
if g.acl != nil {
|
|
return g.acl, nil
|
|
}
|
|
|
|
query := m.GetDashboardAclInfoListQuery{DashboardId: g.dashId, OrgId: g.orgId}
|
|
if err := bus.Dispatch(&query); err != nil {
|
|
return nil, err
|
|
}
|
|
|
|
g.acl = query.Result
|
|
return g.acl, nil
|
|
}
|
|
|
|
func (g *DashboardGuardian) getTeams() ([]*m.Team, error) {
|
|
if g.groups != nil {
|
|
return g.groups, nil
|
|
}
|
|
|
|
query := m.GetTeamsByUserQuery{UserId: g.user.UserId}
|
|
err := bus.Dispatch(&query)
|
|
|
|
g.groups = query.Result
|
|
return query.Result, err
|
|
}
|