schema_validate.go 2.9 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117
  1. package preview
  2. import (
  3. "encoding/json"
  4. "fmt"
  5. "github.com/santhosh-tekuri/jsonschema/v5"
  6. _ "github.com/santhosh-tekuri/jsonschema/v5/httploader"
  7. )
  8. func validateWebChartValues(values map[string]interface{}) error {
  9. webValuesSchema, err := schemas.ReadFile("embed/web.values.schema.json")
  10. if err != nil {
  11. return fmt.Errorf("error reading web chart values schema: %w", err)
  12. }
  13. scm, err := jsonschema.CompileString("web.values.schema.json", string(webValuesSchema))
  14. if err != nil {
  15. return fmt.Errorf("error compiling web chart values schema: %w", err)
  16. }
  17. jsonBytes, err := json.Marshal(values)
  18. if err != nil {
  19. return fmt.Errorf("error marshalling values to JSON: %w", err)
  20. }
  21. var v interface{}
  22. if err := json.Unmarshal(jsonBytes, &v); err != nil {
  23. return fmt.Errorf("error unmarshalling values JSON to interface: %w", err)
  24. }
  25. return scm.Validate(v)
  26. }
  27. func validateWorkerChartValues(values map[string]interface{}) error {
  28. workerValuesSchema, err := schemas.ReadFile("embed/worker.values.schema.json")
  29. if err != nil {
  30. return fmt.Errorf("error reading worker chart values schema: %w", err)
  31. }
  32. scm, err := jsonschema.CompileString("worker.values.schema.json", string(workerValuesSchema))
  33. if err != nil {
  34. return fmt.Errorf("error compiling worker chart values schema: %w", err)
  35. }
  36. jsonBytes, err := json.Marshal(values)
  37. if err != nil {
  38. return fmt.Errorf("error marshalling values to JSON: %w", err)
  39. }
  40. var v interface{}
  41. if err := json.Unmarshal(jsonBytes, &v); err != nil {
  42. return fmt.Errorf("error unmarshalling values JSON to interface: %w", err)
  43. }
  44. return scm.Validate(v)
  45. }
  46. func validateJobChartValues(values map[string]interface{}) error {
  47. jobValuesSchema, err := schemas.ReadFile("embed/job.values.schema.json")
  48. if err != nil {
  49. return fmt.Errorf("error reading job chart values schema: %w", err)
  50. }
  51. scm, err := jsonschema.CompileString("job.values.schema.json", string(jobValuesSchema))
  52. if err != nil {
  53. return fmt.Errorf("error compiling job chart values schema: %w", err)
  54. }
  55. jsonBytes, err := json.Marshal(values)
  56. if err != nil {
  57. return fmt.Errorf("error marshalling values to JSON: %w", err)
  58. }
  59. var v interface{}
  60. if err := json.Unmarshal(jsonBytes, &v); err != nil {
  61. return fmt.Errorf("error unmarshalling values JSON to interface: %w", err)
  62. }
  63. return scm.Validate(v)
  64. }
  65. func validatePostgresChartValues(values map[string]interface{}) error {
  66. compiler := jsonschema.NewCompiler()
  67. scm, err := compiler.Compile("https://raw.githubusercontent.com/porter-dev/porter-charts/master/addons/postgresql/values.schema.json")
  68. if err != nil {
  69. return fmt.Errorf("error compiling postgres chart values schema: %w", err)
  70. }
  71. jsonBytes, err := json.Marshal(values)
  72. if err != nil {
  73. return fmt.Errorf("error marshalling values to JSON: %w", err)
  74. }
  75. var v interface{}
  76. if err := json.Unmarshal(jsonBytes, &v); err != nil {
  77. return fmt.Errorf("error unmarshalling values JSON to interface: %w", err)
  78. }
  79. return scm.Validate(v)
  80. }