dashboard_acl.go 2.3 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182
  1. package api
  2. import (
  3. "time"
  4. "github.com/grafana/grafana/pkg/api/dtos"
  5. "github.com/grafana/grafana/pkg/bus"
  6. "github.com/grafana/grafana/pkg/metrics"
  7. "github.com/grafana/grafana/pkg/middleware"
  8. m "github.com/grafana/grafana/pkg/models"
  9. "github.com/grafana/grafana/pkg/services/guardian"
  10. )
  11. func GetDashboardAclList(c *middleware.Context) Response {
  12. dashId := c.ParamsInt64(":dashboardId")
  13. guardian := guardian.NewDashboardGuardian(dashId, c.OrgId, c.SignedInUser)
  14. if canView, err := guardian.CanView(); err != nil || !canView {
  15. return dashboardGuardianResponse(err)
  16. }
  17. query := m.GetDashboardAclInfoListQuery{DashboardId: dashId}
  18. if err := bus.Dispatch(&query); err != nil {
  19. return ApiError(500, "Failed to get Dashboard ACL", err)
  20. }
  21. list := query.Result
  22. return Json(200, list)
  23. }
  24. func UpdateDashboardAcl(c *middleware.Context, apiCmd dtos.UpdateDashboardAclCommand) Response {
  25. dashId := c.ParamsInt64(":dashboardId")
  26. guardian := guardian.NewDashboardGuardian(dashId, c.OrgId, c.SignedInUser)
  27. if canSave, err := guardian.CanSave(); err != nil || !canSave {
  28. return dashboardGuardianResponse(err)
  29. }
  30. cmd := m.UpdateDashboardAclCommand{}
  31. cmd.DashboardId = dashId
  32. for _, item := range apiCmd.Items {
  33. cmd.Items = append(cmd.Items, &m.DashboardAcl{
  34. OrgId: c.OrgId,
  35. DashboardId: dashId,
  36. UserId: item.UserId,
  37. UserGroupId: item.UserGroupId,
  38. Role: item.Role,
  39. Permission: item.Permission,
  40. Created: time.Now(),
  41. Updated: time.Now(),
  42. })
  43. }
  44. if err := bus.Dispatch(&cmd); err != nil {
  45. if err == m.ErrDashboardAclInfoMissing || err == m.ErrDashboardPermissionDashboardEmpty {
  46. return ApiError(409, err.Error(), err)
  47. }
  48. return ApiError(500, "Failed to create permission", err)
  49. }
  50. metrics.M_Api_Dashboard_Acl_Update.Inc(1)
  51. return ApiSuccess("Dashboard acl updated")
  52. }
  53. func DeleteDashboardAcl(c *middleware.Context) Response {
  54. dashId := c.ParamsInt64(":dashboardId")
  55. aclId := c.ParamsInt64(":aclId")
  56. guardian := guardian.NewDashboardGuardian(dashId, c.OrgId, c.SignedInUser)
  57. if canSave, err := guardian.CanSave(); err != nil || !canSave {
  58. return dashboardGuardianResponse(err)
  59. }
  60. cmd := m.RemoveDashboardAclCommand{OrgId: c.OrgId, AclId: aclId}
  61. if err := bus.Dispatch(&cmd); err != nil {
  62. return ApiError(500, "Failed to delete permission for user", err)
  63. }
  64. return Json(200, "")
  65. }