get_history.go 1.5 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152
  1. package release
  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 GetReleaseHistoryHandler struct {
  14. handlers.PorterHandlerReadWriter
  15. authz.KubernetesAgentGetter
  16. }
  17. func NewGetReleaseHistoryHandler(
  18. config *config.Config,
  19. decoderValidator shared.RequestDecoderValidator,
  20. writer shared.ResultWriter,
  21. ) *GetReleaseHistoryHandler {
  22. return &GetReleaseHistoryHandler{
  23. PorterHandlerReadWriter: handlers.NewDefaultPorterHandler(config, decoderValidator, writer),
  24. KubernetesAgentGetter: authz.NewOutOfClusterAgentGetter(config),
  25. }
  26. }
  27. func (c *GetReleaseHistoryHandler) ServeHTTP(w http.ResponseWriter, r *http.Request) {
  28. cluster, _ := r.Context().Value(types.ClusterScope).(*models.Cluster)
  29. helmAgent, err := c.GetHelmAgent(r, cluster, "")
  30. if err != nil {
  31. c.HandleAPIError(w, r, apierrors.NewErrInternal(err))
  32. return
  33. }
  34. // get the name of the application
  35. name, _ := requestutils.GetURLParamString(r, types.URLParamReleaseName)
  36. history, err := helmAgent.GetReleaseHistory(name)
  37. if err != nil {
  38. c.HandleAPIError(w, r, apierrors.NewErrInternal(err))
  39. return
  40. }
  41. c.WriteResult(w, r, history)
  42. }