update_role.go 2.0 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778
  1. //go:build ee
  2. // +build ee
  3. package invite
  4. import (
  5. "errors"
  6. "fmt"
  7. "net/http"
  8. "strings"
  9. "github.com/porter-dev/porter/api/server/handlers"
  10. "github.com/porter-dev/porter/api/server/shared"
  11. "github.com/porter-dev/porter/api/server/shared/apierrors"
  12. "github.com/porter-dev/porter/api/server/shared/config"
  13. "github.com/porter-dev/porter/api/types"
  14. "github.com/porter-dev/porter/internal/models"
  15. "gorm.io/gorm"
  16. )
  17. type InviteUpdateRoleHandler struct {
  18. handlers.PorterHandlerReader
  19. }
  20. func NewInviteUpdateRoleHandler(
  21. config *config.Config,
  22. decoderValidator shared.RequestDecoderValidator,
  23. ) http.Handler {
  24. return &InviteUpdateRoleHandler{
  25. PorterHandlerReader: handlers.NewDefaultPorterHandler(config, decoderValidator, nil),
  26. }
  27. }
  28. func (c *InviteUpdateRoleHandler) ServeHTTP(w http.ResponseWriter, r *http.Request) {
  29. invite, _ := r.Context().Value(types.InviteScope).(*models.Invite)
  30. project, _ := r.Context().Value(types.ProjectScope).(*models.Project)
  31. request := &types.UpdateInviteRoleRequest{}
  32. if ok := c.DecodeAndValidate(w, r, request); !ok {
  33. return
  34. }
  35. if request.Kind == "" && len(request.RoleUIDs) == 0 {
  36. c.HandleAPIError(w, r, apierrors.NewErrPassThroughToClient(
  37. fmt.Errorf("roles cannot be empty"), http.StatusBadRequest,
  38. ))
  39. return
  40. }
  41. changed := false
  42. if len(request.RoleUIDs) > 0 {
  43. // check for valid project roles
  44. for _, roleUID := range request.RoleUIDs {
  45. _, err := c.Repo().ProjectRole().ReadProjectRole(project.ID, roleUID)
  46. if err != nil && errors.Is(err, gorm.ErrRecordNotFound) {
  47. c.HandleAPIError(w, r, apierrors.NewErrNotFound(fmt.Errorf("role not found in project: %s", roleUID)))
  48. return
  49. }
  50. }
  51. invite.Roles = []byte(strings.Join(request.RoleUIDs, ","))
  52. changed = true
  53. } else if request.Kind != "" { // legacy invite
  54. invite.Kind = request.Kind
  55. changed = true
  56. }
  57. if changed {
  58. if _, err := c.Repo().Invite().UpdateInvite(invite); err != nil {
  59. c.HandleAPIError(w, r, apierrors.NewErrInternal(err))
  60. }
  61. }
  62. }