mirror of
https://github.com/gogrlx/nats-server.git
synced 2026-04-02 11:48:43 -07:00
120 lines
2.5 KiB
Go
120 lines
2.5 KiB
Go
// +build ignore
|
|
|
|
package main
|
|
|
|
import (
|
|
"encoding/json"
|
|
"fmt"
|
|
"io/ioutil"
|
|
"log"
|
|
"os"
|
|
"os/exec"
|
|
"sort"
|
|
"text/template"
|
|
|
|
"github.com/nats-io/nats-server/v2/server"
|
|
)
|
|
|
|
var templ = `
|
|
// Generated code, do not edit. See errors.json and run go generate to update
|
|
|
|
package server
|
|
|
|
const (
|
|
{{- range $i, $error := . }}
|
|
{{- if .Comment }}
|
|
// {{ .Constant }} {{ .Comment }} ({{ .Description | print }})
|
|
{{- else }}
|
|
// {{ .Constant }} {{ .Description | print }}
|
|
{{- end }}
|
|
{{ .Constant }} ErrorIdentifier = {{ .ErrCode }}
|
|
{{ end }}
|
|
)
|
|
|
|
var (
|
|
ApiErrors = map[ErrorIdentifier]*ApiError{
|
|
{{- range $i, $error := . }}
|
|
{{ .Constant }}: {Code: {{ .Code }},ErrCode: {{ .ErrCode }},Description: {{ .Description | printf "%q" }}},{{- end }}
|
|
}
|
|
|
|
{{- range $i, $error := . }}
|
|
{{- if .Deprecates }}
|
|
// {{ .Deprecates }} Deprecated by {{ .Constant }} ApiError, use IsNatsError() for comparisons
|
|
{{ .Deprecates }} = ApiErrors[{{ .Constant }}]
|
|
{{- end }}
|
|
{{- end }}
|
|
)
|
|
`
|
|
|
|
func panicIfErr(err error) {
|
|
if err == nil {
|
|
return
|
|
}
|
|
panic(err)
|
|
}
|
|
|
|
func goFmt(file string) error {
|
|
c := exec.Command("go", "fmt", file)
|
|
out, err := c.CombinedOutput()
|
|
if err != nil {
|
|
log.Printf("go fmt failed: %s", string(out))
|
|
}
|
|
|
|
return err
|
|
}
|
|
|
|
func checkDupes(errs []server.ErrorsData) error {
|
|
codes := []uint16{}
|
|
highest := uint16(0)
|
|
for _, err := range errs {
|
|
codes = append(codes, err.ErrCode)
|
|
if highest < err.ErrCode {
|
|
highest = err.ErrCode
|
|
}
|
|
}
|
|
|
|
codeKeys := make(map[uint16]bool)
|
|
constKeys := make(map[string]bool)
|
|
|
|
for _, entry := range errs {
|
|
if _, found := codeKeys[entry.ErrCode]; found {
|
|
return fmt.Errorf("duplicate error code %+v, highest code is %d", entry, highest)
|
|
}
|
|
|
|
if _, found := constKeys[entry.Constant]; found {
|
|
return fmt.Errorf("duplicate error constant %+v", entry)
|
|
}
|
|
|
|
codeKeys[entry.ErrCode] = true
|
|
constKeys[entry.Constant] = true
|
|
}
|
|
|
|
return nil
|
|
}
|
|
|
|
func main() {
|
|
ej, err := os.ReadFile("server/errors.json")
|
|
panicIfErr(err)
|
|
|
|
errs := []server.ErrorsData{}
|
|
panicIfErr(json.Unmarshal(ej, &errs))
|
|
panicIfErr(checkDupes(errs))
|
|
|
|
sort.Slice(errs, func(i, j int) bool {
|
|
return errs[i].Constant < errs[j].Constant
|
|
})
|
|
|
|
t := template.New("errors").Funcs(template.FuncMap{"inc": func(i int) int { return i + 1 }})
|
|
p, err := t.Parse(templ)
|
|
panicIfErr(err)
|
|
|
|
tf, err := ioutil.TempFile("", "")
|
|
panicIfErr(err)
|
|
defer tf.Close()
|
|
|
|
panicIfErr(p.Execute(tf, errs))
|
|
|
|
panicIfErr(os.Rename(tf.Name(), "server/jetstream_errors_generated.go"))
|
|
panicIfErr(goFmt("server/jetstream_errors_generated.go"))
|
|
}
|