72 lines
2.4 KiB
Go
72 lines
2.4 KiB
Go
package consumers_test
|
|
|
|
import (
|
|
"errors"
|
|
"fmt"
|
|
"strings"
|
|
"testing"
|
|
|
|
configkit "gitea.maximumdirect.net/eric/ConfigKit"
|
|
"gitea.maximumdirect.net/eric/ConfigKit/examples/consumers"
|
|
)
|
|
|
|
func Example_nativeFilesystem() {
|
|
result, err := consumers.LoadBundled()
|
|
if err != nil {
|
|
fmt.Println(err)
|
|
return
|
|
}
|
|
fmt.Println(result.Config.Name, result.Config.Enabled)
|
|
// Output: embedded false
|
|
}
|
|
|
|
func Example_layeredCatalog() {
|
|
result, err := consumers.LoadCatalog(fixture("layered-main", "config.yml"))
|
|
if err != nil {
|
|
fmt.Println(err)
|
|
return
|
|
}
|
|
welcome, err := consumers.ReadWelcome(result)
|
|
fmt.Println(result.Config.Mode, result.Config.Enabled, result.Config.Workers,
|
|
result.Config.Labels["origin"], result.Config.Labels["tenant"], strings.TrimSpace(welcome), err)
|
|
// Output: production false 0 bundle example Welcome from the bundle. <nil>
|
|
}
|
|
|
|
func TestCatalogRetainsPresenceAndSourceContext(t *testing.T) {
|
|
result, err := consumers.LoadCatalog(fixture("layered-main", "config.yml"))
|
|
if err != nil {
|
|
t.Fatal(err)
|
|
}
|
|
for _, key := range []string{"enabled", "workers"} {
|
|
info, found := result.Metadata().Lookup(configkit.Keys(key))
|
|
if !found || !info.Explicit || info.Origin.Layer != configkit.LayerBase {
|
|
t.Fatalf("%s presence = %#v, %v", key, info, found)
|
|
}
|
|
}
|
|
info, found := result.Metadata().Lookup(configkit.Keys("templates", "welcome"))
|
|
if !found || info.Origin.Layer != configkit.LayerUnderlay || len(info.Origin.Locations) != 1 {
|
|
t.Fatalf("welcome origin = %#v, %v", info, found)
|
|
}
|
|
context, found := result.SourceContext(info.Origin.Locations[0].SourceID)
|
|
if !found || context.BaseDir != "defaults" {
|
|
t.Fatalf("welcome context = %#v, %v", context, found)
|
|
}
|
|
welcome, err := consumers.ReadWelcome(result)
|
|
if err != nil || strings.TrimSpace(welcome) != "Welcome from the bundle." {
|
|
t.Fatalf("welcome = %q, %v", welcome, err)
|
|
}
|
|
if result.Config.Labels["tenant"] != "example" || result.Config.Labels["origin"] != "bundle" {
|
|
t.Fatalf("recursive underlay labels = %#v", result.Config.Labels)
|
|
}
|
|
}
|
|
|
|
func TestCatalogValidationRejectsInvalidMode(t *testing.T) {
|
|
_, err := consumers.LoadCatalog(fixture("layered-main", "invalid.yml"))
|
|
var loadError *configkit.LoadError
|
|
if !errors.As(err, &loadError) || len(loadError.Diagnostics()) == 0 ||
|
|
loadError.Diagnostics()[0].Code != configkit.CodeValidateError ||
|
|
loadError.Diagnostics()[0].Path.String() != "/mode" {
|
|
t.Fatalf("invalid mode error = %v", err)
|
|
}
|
|
}
|