get_policy.go 1.3 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647
  1. package project
  2. import (
  3. "net/http"
  4. "github.com/porter-dev/porter/api/server/authz/policy"
  5. "github.com/porter-dev/porter/api/server/shared/apierrors"
  6. "github.com/porter-dev/porter/api/server/shared/config"
  7. "github.com/porter-dev/porter/api/server/handlers"
  8. "github.com/porter-dev/porter/api/server/shared"
  9. "github.com/porter-dev/porter/api/types"
  10. "github.com/porter-dev/porter/internal/models"
  11. )
  12. type ProjectGetPolicyHandler struct {
  13. handlers.PorterHandlerWriter
  14. }
  15. func NewProjectGetPolicyHandler(
  16. config *config.Config,
  17. writer shared.ResultWriter,
  18. ) *ProjectGetPolicyHandler {
  19. return &ProjectGetPolicyHandler{
  20. PorterHandlerWriter: handlers.NewDefaultPorterHandler(config, nil, writer),
  21. }
  22. }
  23. func (p *ProjectGetPolicyHandler) ServeHTTP(w http.ResponseWriter, r *http.Request) {
  24. user, _ := r.Context().Value(types.UserScope).(*models.User)
  25. proj, _ := r.Context().Value(types.ProjectScope).(*models.Project)
  26. policyDocLoader := policy.NewBasicPolicyDocumentLoader(p.Config().Repo.Project(), p.Config().Repo.Policy())
  27. policyDocs, err := policyDocLoader.LoadPolicyDocuments(&policy.PolicyLoaderOpts{
  28. UserID: user.ID,
  29. ProjectID: proj.ID,
  30. })
  31. if err != nil {
  32. p.HandleAPIError(w, r, apierrors.NewErrInternal(err))
  33. }
  34. var res types.GetProjectPolicyResponse = policyDocs
  35. p.WriteResult(w, r, res)
  36. }