-
Notifications
You must be signed in to change notification settings - Fork 1
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
* initial cut of a registry * go mod tidy * fixup generate with memory loader, add tests Signed-off-by: Sarah Funkhouser <[email protected]> --------- Signed-off-by: Matt Anderson <[email protected]> Signed-off-by: Sarah Funkhouser <[email protected]> Co-authored-by: Sarah Funkhouser <[email protected]>
- Loading branch information
1 parent
b0a8d12
commit 1edf628
Showing
10 changed files
with
1,771 additions
and
2 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,2 @@ | ||
| // Package registry provides a basic jsonschema registry for creating / viewing jsonschema definitions | ||
| package registry |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,279 @@ | ||
| package registry | ||
|
|
||
| import ( | ||
| "encoding/base64" | ||
| "fmt" | ||
| "net" | ||
| "net/http" | ||
| "net/url" | ||
| "regexp" | ||
| "time" | ||
| ) | ||
|
|
||
| // FormatFunc validates the customized format in json schema | ||
| type FormatFunc func(v interface{}) error | ||
|
|
||
| var ( | ||
| formatsFuncs = map[string]FormatFunc{ | ||
| "urlname": urlName, | ||
| "httpmethod": httpMethod, | ||
| "httpmethod-array": httpMethodArray, | ||
| "httpcode": httpCode, | ||
| "httpcode-array": httpCodeArray, | ||
| "timerfc3339": timerfc3339, | ||
| "duration": duration, | ||
| "ipcidr": ipcidr, | ||
| "ipcidr-array": ipcidrArray, | ||
| "hostport": hostport, | ||
| "regexp": _regexp, | ||
| "base64": _base64, | ||
| "url": _url, | ||
| } | ||
|
|
||
| urlCharsRegexp = regexp.MustCompile(`^[\p{L}0-9\-_\.~]{1,253}$`) | ||
| ) | ||
|
|
||
| func getFormatFunc(format string) (FormatFunc, bool) { | ||
| switch format { | ||
| case "date-time", "email", "hostname", "ipv4", "ipv6", "uri": | ||
| return standardFormat, true | ||
|
|
||
| case "": | ||
| // NOTICE: Empty format does nothing like standard format. | ||
| return standardFormat, true | ||
| } | ||
|
|
||
| if fn, exists := formatsFuncs[format]; exists { | ||
| return fn, true | ||
| } | ||
|
|
||
| return nil, false | ||
| } | ||
|
|
||
| func standardFormat(v interface{}) error { | ||
| // errors will be reported by standard json schema validation | ||
| return nil | ||
| } | ||
|
|
||
| var ErrInvalidName = fmt.Errorf("invalid name format") | ||
|
|
||
| func urlName(v interface{}) error { | ||
| url, ok := v.(string) | ||
| if !ok { | ||
| return fmt.Errorf("%w: %v", ErrInvalidName, v) | ||
| } | ||
|
|
||
| if urlCharsRegexp.MatchString(url) { | ||
| return nil | ||
| } | ||
|
|
||
| return fmt.Errorf("%w: %s", ErrInvalidName, url) | ||
| } | ||
|
|
||
| var ErrInvalidHTTPMethod = fmt.Errorf("invalid http method") | ||
|
|
||
| func httpMethod(v interface{}) error { | ||
| method, ok := v.(string) | ||
| if !ok { | ||
| return fmt.Errorf("%w", ErrInvalidHTTPMethod) | ||
| } | ||
|
|
||
| switch method { | ||
| case http.MethodGet, | ||
| http.MethodHead, | ||
| http.MethodPost, | ||
| http.MethodPut, | ||
| http.MethodPatch, | ||
| http.MethodDelete, | ||
| http.MethodConnect, | ||
| http.MethodOptions, | ||
| http.MethodTrace: | ||
| return nil | ||
| default: | ||
| return fmt.Errorf("%w", ErrInvalidHTTPMethod) | ||
| } | ||
| } | ||
|
|
||
| func httpMethodArray(v interface{}) error { | ||
| methods, ok := v.([]string) | ||
| if !ok { | ||
| return fmt.Errorf("%w", ErrInvalidHTTPMethod) | ||
| } | ||
|
|
||
| for _, method := range methods { | ||
| err := httpMethod(method) | ||
| if err != nil { | ||
| return err | ||
| } | ||
| } | ||
|
|
||
| return nil | ||
| } | ||
|
|
||
| var ErrInvalidHTTPCode = fmt.Errorf("invalid http code") | ||
|
|
||
| func httpCode(v interface{}) error { | ||
| code, ok := v.(int) | ||
| if !ok { | ||
| return fmt.Errorf("%w", ErrInvalidHTTPCode) | ||
| } | ||
|
|
||
| // Reference: https://tools.ietf.org/html/rfc7231#section-6 | ||
| if code < 100 || code >= 600 { | ||
| return fmt.Errorf("%w", ErrInvalidHTTPCode) | ||
| } | ||
|
|
||
| return nil | ||
| } | ||
|
|
||
| func httpCodeArray(v interface{}) error { | ||
| codeArray, ok := v.([]int) | ||
| if !ok { | ||
| return fmt.Errorf("%w", ErrInvalidHTTPCode) | ||
| } | ||
|
|
||
| for _, method := range codeArray { | ||
| if err := httpCode(method); err != nil { | ||
| return err | ||
| } | ||
| } | ||
|
|
||
| return nil | ||
| } | ||
|
|
||
| // ErrInvalidRFC3339Time is returned when the time is not in RFC3339 format | ||
| var ErrInvalidRFC3339Time = fmt.Errorf("invalid RFC3339 time") | ||
|
|
||
| func timerfc3339(v interface{}) error { | ||
| s, ok := v.(string) | ||
| if !ok { | ||
| return ErrInvalidRFC3339Time | ||
| } | ||
|
|
||
| if _, err := time.Parse(time.RFC3339, s); err != nil { | ||
| return fmt.Errorf("%w: %v", ErrInvalidRFC3339Time, err) | ||
| } | ||
|
|
||
| return nil | ||
| } | ||
|
|
||
| // ErrInvalidDuration is returned when the duration is not in valid format | ||
| var ErrInvalidDuration = fmt.Errorf("invalid duration") | ||
|
|
||
| func duration(v interface{}) error { | ||
| s, ok := v.(string) | ||
| if !ok { | ||
| return ErrInvalidDuration | ||
| } | ||
|
|
||
| if _, err := time.ParseDuration(s); err != nil { | ||
| return fmt.Errorf("%w: %v", ErrInvalidDuration, err) | ||
| } | ||
|
|
||
| return nil | ||
| } | ||
|
|
||
| // ErrInvalidIPCIDR is returned when the ip or cidr is not in valid format | ||
| var ErrInvalidIPCIDR = fmt.Errorf("invalid ip or cidr") | ||
|
|
||
| func ipcidr(v interface{}) error { | ||
| s, ok := v.(string) | ||
| if !ok { | ||
| return ErrInvalidIPCIDR | ||
| } | ||
|
|
||
| ip := net.ParseIP(s) | ||
| if ip != nil { | ||
| return nil | ||
| } | ||
|
|
||
| if _, _, err := net.ParseCIDR(s); err != nil { | ||
| return fmt.Errorf("%w: %w", ErrInvalidIPCIDR, err) | ||
| } | ||
|
|
||
| return nil | ||
| } | ||
|
|
||
| func ipcidrArray(v interface{}) error { | ||
| cidrs, ok := v.([]string) | ||
| if !ok { | ||
| return ErrInvalidIPCIDR | ||
| } | ||
|
|
||
| for _, ic := range cidrs { | ||
| if err := ipcidr(ic); err != nil { | ||
| return err | ||
| } | ||
| } | ||
|
|
||
| return nil | ||
| } | ||
|
|
||
| var ErrInvalidHostport = fmt.Errorf("invalid hostport") | ||
|
|
||
| func hostport(v interface{}) error { | ||
| s, ok := v.(string) | ||
| if !ok { | ||
| return ErrInvalidHostport | ||
| } | ||
|
|
||
| if _, _, err := net.SplitHostPort(s); err != nil { | ||
| return fmt.Errorf("%w: %v", ErrInvalidHostport, err) | ||
| } | ||
|
|
||
| return nil | ||
| } | ||
|
|
||
| var ErrInvalidRegexp = fmt.Errorf("invalid regular expression") | ||
|
|
||
| func _regexp(v interface{}) error { | ||
| s, ok := v.(string) | ||
| if !ok { | ||
| return ErrInvalidRegexp | ||
| } | ||
|
|
||
| if _, err := regexp.Compile(s); err != nil { | ||
| return fmt.Errorf("%w: %v", ErrInvalidRegexp, err) | ||
| } | ||
|
|
||
| return nil | ||
| } | ||
|
|
||
| var ErrInvalidBase64 = fmt.Errorf("invalid base64") | ||
|
|
||
| func _base64(v interface{}) error { | ||
| s, ok := v.(string) | ||
| if !ok { | ||
| return ErrInvalidBase64 | ||
| } | ||
|
|
||
| if _, err := base64.StdEncoding.DecodeString(s); err != nil { | ||
| return fmt.Errorf("%w: %v", ErrInvalidBase64, err) | ||
| } | ||
|
|
||
| return nil | ||
| } | ||
|
|
||
| var ErrInvalidURL = fmt.Errorf("invalid url") | ||
|
|
||
| func _url(v interface{}) error { | ||
| s, ok := v.(string) | ||
| if !ok { | ||
| return ErrInvalidURL | ||
| } | ||
|
|
||
| url, err := url.Parse(s) | ||
| if err != nil { | ||
| return fmt.Errorf("%w: %v", ErrInvalidURL, err) | ||
| } | ||
|
|
||
| if url.Host == "" { | ||
| return fmt.Errorf("%w: host is empty", ErrInvalidURL) | ||
| } | ||
|
|
||
| if url.Scheme == "" { | ||
| return fmt.Errorf("%w: scheme is empty", ErrInvalidURL) | ||
| } | ||
|
|
||
| return nil | ||
| } |
Oops, something went wrong.