get_porter_app.go 1.2 KB

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