mirror of
https://github.com/kairos-io/kairos-sdk.git
synced 2025-04-27 19:15:23 +00:00
c90740d747
* Move schema validation to sdk to be used by different repos Signed-off-by: Mauro Morales <mauro.morales@spectrocloud.com> * remove unused Signed-off-by: Mauro Morales <mauro.morales@spectrocloud.com> * fix recommendations Signed-off-by: Mauro Morales <mauro.morales@spectrocloud.com> --------- Signed-off-by: Mauro Morales <mauro.morales@spectrocloud.com>
107 lines
2.7 KiB
Go
107 lines
2.7 KiB
Go
package schema_test
|
|
|
|
import (
|
|
"os"
|
|
"path/filepath"
|
|
"strings"
|
|
|
|
. "github.com/kairos-io/kairos-sdk/schema"
|
|
|
|
. "github.com/onsi/ginkgo/v2"
|
|
. "github.com/onsi/gomega"
|
|
)
|
|
|
|
var _ = Describe("Validate", func() {
|
|
Context("JSONSchema", func() {
|
|
It("returns a schema with a url to the given version", func() {
|
|
out, err := JSONSchema("0.0.0")
|
|
Expect(err).ToNot(HaveOccurred())
|
|
Expect(strings.Contains(out, `$schema": "https://kairos.io/0.0.0/cloud-config.json"`)).To(BeTrue())
|
|
})
|
|
})
|
|
|
|
Context("Validate", func() {
|
|
var yaml string
|
|
|
|
Context("With a really long config string", func() {
|
|
BeforeEach(func() {
|
|
yaml = `#cloud-config
|
|
users:
|
|
- name: kairos
|
|
passwd: kairos
|
|
vpn:
|
|
network_token: "dssdnfjkldashfkjhasdkhfkasjdhfkjhasdjkfhaksjdhfkjashjdkfhioreqwhfuihqweruifhuewrbfhuewrfuyequfhuiehuifheqrihfuiqrehfuirqheiufhreqiuhfuiqheiufhqeuihfuiqrehfiuhqreuifrhiuqehfiuhqeirhfiuewhrfhqwehfriuewhfuihewiuhfruewhrifhwiuehrfiuhweiurfhwueihrfuiwehufhweuihrfuiwerhfuihewruifhewuihfiouwehrfiouhwei"
|
|
`
|
|
})
|
|
It("validates", func() {
|
|
Expect(Validate(yaml)).ToNot(HaveOccurred())
|
|
})
|
|
})
|
|
|
|
Context("with a valid config", func() {
|
|
BeforeEach(func() {
|
|
yaml = `#cloud-config
|
|
users:
|
|
- name: kairos
|
|
passwd: kairos`
|
|
})
|
|
|
|
It("is successful reading it from file", func() {
|
|
f, err := os.MkdirTemp("", "tests")
|
|
Expect(err).ToNot(HaveOccurred())
|
|
defer os.RemoveAll(f)
|
|
|
|
path := filepath.Join(f, "config.yaml")
|
|
err = os.WriteFile(path, []byte(yaml), 0655)
|
|
Expect(err).ToNot(HaveOccurred())
|
|
err = Validate(path)
|
|
Expect(err).ToNot(HaveOccurred())
|
|
})
|
|
It("is successful reading it from a string", func() {
|
|
Expect(Validate(yaml)).ToNot(HaveOccurred())
|
|
})
|
|
})
|
|
|
|
Context("without a header", func() {
|
|
BeforeEach(func() {
|
|
yaml = `users:
|
|
- name: kairos
|
|
passwd: kairos`
|
|
})
|
|
|
|
It("is fails", func() {
|
|
f, err := os.MkdirTemp("", "tests")
|
|
Expect(err).ToNot(HaveOccurred())
|
|
defer os.RemoveAll(f)
|
|
|
|
path := filepath.Join(f, "config.yaml")
|
|
err = os.WriteFile(path, []byte(yaml), 0655)
|
|
Expect(err).ToNot(HaveOccurred())
|
|
err = Validate(path)
|
|
Expect(err).To(MatchError("missing #cloud-config header"))
|
|
})
|
|
})
|
|
|
|
Context("with an invalid rule", func() {
|
|
BeforeEach(func() {
|
|
yaml = `#cloud-config
|
|
users:
|
|
- name: 007
|
|
passwd: kairos`
|
|
})
|
|
|
|
It("is fails", func() {
|
|
f, err := os.MkdirTemp("", "tests")
|
|
Expect(err).ToNot(HaveOccurred())
|
|
defer os.RemoveAll(f)
|
|
|
|
path := filepath.Join(f, "config.yaml")
|
|
err = os.WriteFile(path, []byte(yaml), 0655)
|
|
Expect(err).ToNot(HaveOccurred())
|
|
err = Validate(path)
|
|
Expect(err.Error()).To(MatchRegexp("expected string, but got number"))
|
|
})
|
|
})
|
|
})
|
|
})
|