get_chart.go 2.6 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990
  1. package helmrepo
  2. import (
  3. "net/http"
  4. "strings"
  5. "github.com/porter-dev/porter/api/server/handlers"
  6. "github.com/porter-dev/porter/api/server/handlers/release"
  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. "github.com/porter-dev/porter/internal/telemetry"
  14. "github.com/porter-dev/porter/internal/templater/parser"
  15. )
  16. type ChartGetHandler struct {
  17. handlers.PorterHandlerReadWriter
  18. }
  19. func NewChartGetHandler(
  20. config *config.Config,
  21. decoderValidator shared.RequestDecoderValidator,
  22. writer shared.ResultWriter,
  23. ) *ChartGetHandler {
  24. return &ChartGetHandler{
  25. PorterHandlerReadWriter: handlers.NewDefaultPorterHandler(config, decoderValidator, writer),
  26. }
  27. }
  28. func (t *ChartGetHandler) ServeHTTP(w http.ResponseWriter, r *http.Request) {
  29. ctx, span := telemetry.NewSpan(r.Context(), "serve-get-chart")
  30. defer span.End()
  31. proj, _ := ctx.Value(types.ProjectScope).(*models.Project)
  32. helmRepo, _ := ctx.Value(types.HelmRepoScope).(*models.HelmRepo)
  33. name, _ := requestutils.GetURLParamString(r, types.URLParamTemplateName)
  34. version, _ := requestutils.GetURLParamString(r, types.URLParamTemplateVersion)
  35. // if version passed as latest, pass empty string to loader to get latest
  36. if version == "latest" {
  37. version = ""
  38. }
  39. telemetry.WithAttributes(span,
  40. telemetry.AttributeKV{Key: "helm-repo-url", Value: helmRepo.RepoURL},
  41. telemetry.AttributeKV{Key: "template-name", Value: name},
  42. telemetry.AttributeKV{Key: "template-version", Value: version},
  43. )
  44. chart, err := release.LoadChart(ctx, t.Config(), &release.LoadAddonChartOpts{
  45. ProjectID: proj.ID,
  46. RepoURL: helmRepo.RepoURL,
  47. TemplateName: name,
  48. TemplateVersion: version,
  49. })
  50. if err != nil {
  51. err := telemetry.Error(ctx, span, nil, "error loading chart from helm")
  52. t.HandleAPIError(w, r, apierrors.NewErrPassThroughToClient(err, http.StatusInternalServerError))
  53. return
  54. }
  55. parserDef := &parser.ClientConfigDefault{
  56. HelmChart: chart,
  57. }
  58. res := &types.GetTemplateResponse{
  59. RepoURL: helmRepo.RepoURL,
  60. }
  61. res.Metadata = chart.Metadata
  62. res.Values = chart.Values
  63. for _, file := range chart.Files {
  64. if strings.Contains(file.Name, "form.yaml") {
  65. formYAML, err := parser.FormYAMLFromBytes(parserDef, file.Data, "declared", "")
  66. if err != nil {
  67. break
  68. }
  69. res.Form = formYAML
  70. } else if strings.Contains(file.Name, "README.md") {
  71. res.Markdown = string(file.Data)
  72. }
  73. }
  74. t.WriteResult(w, r, res)
  75. }