mirror of
https://github.com/ClusterCockpit/cc-backend
synced 2024-09-20 11:27:26 +02:00
24a4244f19
- '$ROOT/$FILE' for better localization in the code - add text where none was given - fix unnecessary sprintf nesting in influxv2 and prometheus metricrepo logging
67 lines
1.4 KiB
Go
67 lines
1.4 KiB
Go
// Copyright (C) 2022 NHR@FAU, University Erlangen-Nuremberg.
|
|
// All rights reserved.
|
|
// Use of this source code is governed by a MIT-style
|
|
// license that can be found in the LICENSE file.
|
|
package schema
|
|
|
|
import (
|
|
"embed"
|
|
"encoding/json"
|
|
"fmt"
|
|
"io"
|
|
"path/filepath"
|
|
"strings"
|
|
|
|
"github.com/ClusterCockpit/cc-backend/pkg/log"
|
|
"github.com/santhosh-tekuri/jsonschema/v5"
|
|
)
|
|
|
|
type Kind int
|
|
|
|
const (
|
|
Meta Kind = iota + 1
|
|
Data
|
|
Config
|
|
ClusterCfg
|
|
)
|
|
|
|
//go:embed schemas/*
|
|
var schemaFiles embed.FS
|
|
|
|
func Validate(k Kind, r io.Reader) (err error) {
|
|
jsonschema.Loaders["embedfs"] = func(s string) (io.ReadCloser, error) {
|
|
f := filepath.Join("schemas", strings.Split(s, "//")[1])
|
|
return schemaFiles.Open(f)
|
|
}
|
|
var s *jsonschema.Schema
|
|
|
|
switch k {
|
|
case Meta:
|
|
s, err = jsonschema.Compile("embedfs://job-meta.schema.json")
|
|
case Data:
|
|
s, err = jsonschema.Compile("embedfs://job-data.schema.json")
|
|
case ClusterCfg:
|
|
s, err = jsonschema.Compile("embedfs://cluster.schema.json")
|
|
case Config:
|
|
s, err = jsonschema.Compile("embedfs://config.schema.json")
|
|
default:
|
|
return fmt.Errorf("SCHEMA/VALIDATE > unkown schema kind: %v", k)
|
|
}
|
|
|
|
if err != nil {
|
|
return err
|
|
}
|
|
|
|
var v interface{}
|
|
if err := json.NewDecoder(r).Decode(&v); err != nil {
|
|
log.Errorf("SCHEMA/VALIDATE > Failed to decode %v", err)
|
|
return err
|
|
}
|
|
|
|
if err = s.Validate(v); err != nil {
|
|
return fmt.Errorf("SCHEMA/VALIDATE > %#v", err)
|
|
}
|
|
|
|
return nil
|
|
}
|