get_upgrade_notes.go 2.0 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182
  1. package template
  2. import (
  3. "net/http"
  4. "strings"
  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/helm/loader"
  12. "github.com/porter-dev/porter/internal/helm/upgrade"
  13. )
  14. type TemplateGetUpgradeNotesHandler struct {
  15. handlers.PorterHandlerReadWriter
  16. }
  17. func NewTemplateGetUpgradeNotesHandler(
  18. config *config.Config,
  19. decoderValidator shared.RequestDecoderValidator,
  20. writer shared.ResultWriter,
  21. ) *TemplateGetUpgradeNotesHandler {
  22. return &TemplateGetUpgradeNotesHandler{
  23. PorterHandlerReadWriter: handlers.NewDefaultPorterHandler(config, decoderValidator, writer),
  24. }
  25. }
  26. func (t *TemplateGetUpgradeNotesHandler) ServeHTTP(w http.ResponseWriter, r *http.Request) {
  27. request := &types.GetTemplateUpgradeNotesRequest{}
  28. ok := t.DecodeAndValidate(w, r, request)
  29. if !ok {
  30. return
  31. }
  32. name, _ := requestutils.GetURLParamString(r, types.URLParamTemplateName)
  33. version, _ := requestutils.GetURLParamString(r, types.URLParamTemplateVersion)
  34. // if version passed as latest, pass empty string to loader to get latest
  35. if version == "latest" {
  36. version = ""
  37. }
  38. prevVersion := request.PrevVersion
  39. if prevVersion == "" {
  40. prevVersion = "v0.0.0"
  41. }
  42. chart, err := loader.LoadChartPublic(request.RepoURL, name, version)
  43. if err != nil {
  44. t.HandleAPIError(w, r, apierrors.NewErrInternal(err))
  45. return
  46. }
  47. res := &upgrade.UpgradeFile{}
  48. for _, file := range chart.Files {
  49. if strings.Contains(file.Name, "upgrade.yaml") {
  50. upgradeFile, err := upgrade.ParseUpgradeFileFromBytes(file.Data)
  51. if err != nil {
  52. break
  53. }
  54. upgradeFile, err = upgradeFile.GetUpgradeFileBetweenVersions(prevVersion, version)
  55. if err != nil {
  56. break
  57. }
  58. res = upgradeFile
  59. }
  60. }
  61. t.WriteResult(w, r, res)
  62. }