get_porter_app.go 1.2 KB

123456789101112131415161718192021222324252627282930313233343536373839404142
  1. package stacks
  2. import (
  3. "net/http"
  4. "github.com/porter-dev/porter/api/server/authz"
  5. "github.com/porter-dev/porter/api/server/handlers"
  6. "github.com/porter-dev/porter/api/server/shared"
  7. "github.com/porter-dev/porter/api/server/shared/apierrors"
  8. "github.com/porter-dev/porter/api/server/shared/config"
  9. "github.com/porter-dev/porter/api/server/shared/requestutils"
  10. "github.com/porter-dev/porter/api/types"
  11. "github.com/porter-dev/porter/internal/models"
  12. )
  13. type GetPorterAppHandler struct {
  14. handlers.PorterHandlerReadWriter
  15. authz.KubernetesAgentGetter
  16. }
  17. func NewGetPorterAppHandler(
  18. config *config.Config,
  19. writer shared.ResultWriter,
  20. ) *GetPorterAppHandler {
  21. return &GetPorterAppHandler{
  22. PorterHandlerReadWriter: handlers.NewDefaultPorterHandler(config, nil, writer),
  23. }
  24. }
  25. func (c *GetPorterAppHandler) ServeHTTP(w http.ResponseWriter, r *http.Request) {
  26. ctx := r.Context()
  27. cluster, _ := ctx.Value(types.ClusterScope).(*models.Cluster)
  28. name, _ := requestutils.GetURLParamString(r, types.URLParamReleaseName)
  29. app, err := c.Repo().PorterApp().ReadPorterApp(cluster.ID, name)
  30. if err != nil {
  31. c.HandleAPIError(w, r, apierrors.NewErrInternal(err))
  32. return
  33. }
  34. c.WriteResult(w, r, app.ToPorterAppType())
  35. }