delete.go 2.0 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081
  1. package project_role
  2. import (
  3. "errors"
  4. "fmt"
  5. "net/http"
  6. "github.com/porter-dev/porter/api/server/handlers"
  7. "github.com/porter-dev/porter/api/server/shared"
  8. "github.com/porter-dev/porter/api/server/shared/apierrors"
  9. "github.com/porter-dev/porter/api/server/shared/config"
  10. "github.com/porter-dev/porter/api/server/shared/requestutils"
  11. "github.com/porter-dev/porter/api/types"
  12. "github.com/porter-dev/porter/internal/models"
  13. "gorm.io/gorm"
  14. )
  15. type DeleteProjectRoleHandler struct {
  16. handlers.PorterHandlerReadWriter
  17. }
  18. func NewDeleteProjectRoleHandler(
  19. config *config.Config,
  20. decoderValidator shared.RequestDecoderValidator,
  21. writer shared.ResultWriter,
  22. ) *DeleteProjectRoleHandler {
  23. return &DeleteProjectRoleHandler{
  24. PorterHandlerReadWriter: handlers.NewDefaultPorterHandler(config, decoderValidator, writer),
  25. }
  26. }
  27. func (c *DeleteProjectRoleHandler) ServeHTTP(w http.ResponseWriter, r *http.Request) {
  28. project, _ := r.Context().Value(types.ProjectScope).(*models.Project)
  29. roleUID, reqErr := requestutils.GetURLParamString(r, types.URLParamProjectRoleID)
  30. if reqErr != nil {
  31. c.HandleAPIError(w, r, reqErr)
  32. return
  33. }
  34. role, err := c.Repo().ProjectRole().ReadProjectRole(project.ID, roleUID)
  35. if err != nil {
  36. if errors.Is(err, gorm.ErrRecordNotFound) {
  37. c.HandleAPIError(w, r, apierrors.NewErrNotFound(fmt.Errorf("no such project role exists")))
  38. return
  39. }
  40. c.HandleAPIError(w, r, apierrors.NewErrInternal(err))
  41. return
  42. }
  43. if len(role.Users) > 0 {
  44. c.HandleAPIError(w, r, apierrors.NewErrPassThroughToClient(
  45. fmt.Errorf("role has one or more users assigned"), http.StatusPreconditionFailed,
  46. ))
  47. return
  48. }
  49. policy, err := c.Repo().Policy().ReadPolicy(project.ID, role.PolicyUID)
  50. if err != nil {
  51. c.HandleAPIError(w, r, apierrors.NewErrInternal(err))
  52. return
  53. }
  54. _, err = c.Repo().Policy().DeletePolicy(policy)
  55. if err != nil {
  56. c.HandleAPIError(w, r, apierrors.NewErrInternal(err))
  57. return
  58. }
  59. _, err = c.Repo().ProjectRole().DeleteProjectRole(role)
  60. if err != nil {
  61. c.HandleAPIError(w, r, apierrors.NewErrInternal(err))
  62. return
  63. }
  64. }