-
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.
* feat: config query grammar * chore: add peg to resource selector search * chore: fix grammar errors and add comprehensive tests * chore: remove test focus * chore: remove duplicate ParseFilteringQueryV2 and fix remaining tests * chore: remove extra logging * chore: fix lint * chore: fix relative time test --------- Co-authored-by: Yash Mehrotra <[email protected]>
- Loading branch information
1 parent
f02849f
commit 4be7147
Showing
18 changed files
with
3,416 additions
and
52 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
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,172 @@ | ||
| //go:generate go run github.com/mna/[email protected] -o grammer.go grammer.peg | ||
| package grammar | ||
|
|
||
| import ( | ||
| "fmt" | ||
| "strings" | ||
|
|
||
| "github.com/flanksource/commons/logger" | ||
| "github.com/flanksource/duty/types" | ||
| ) | ||
|
|
||
| type Source struct { | ||
| Name string `json:"name,omitempty"` | ||
| Path []string `json:"path,omitempty"` | ||
| } | ||
|
|
||
| type NumberUnit struct { | ||
| Number interface{} `json:"number,omitempty"` //int64/float64 | ||
| Units string `json:"units,omitempty"` | ||
| } | ||
|
|
||
| func makeSource(name interface{}, path interface{}) (string, error) { | ||
| ps := path.([]interface{}) | ||
|
|
||
| paths := make([]string, 0) | ||
| for _, p := range ps { | ||
| pa := p.([]interface{}) | ||
| px := pa[1:] | ||
| for _, pi := range px { | ||
| paths = append(paths, pi.(string)) | ||
| } | ||
| } | ||
| return strings.Join(append([]string{name.(string)}, paths...), "."), nil | ||
| } | ||
|
|
||
| func makeFQFromQuery(a interface{}) (interface{}, error) { | ||
| return a.(*types.QueryField), nil | ||
| } | ||
|
|
||
| //nolint:unused | ||
| func makeCatchAll(f interface{}) (*types.QueryField, error) { | ||
| logger.Warnf("ctach all %v (%T)", f, f) | ||
|
|
||
| switch v := f.(type) { | ||
| case string: | ||
| return &types.QueryField{Op: "rest", Value: v}, nil | ||
| case []byte: | ||
| return &types.QueryField{Op: "rest", Value: string(v)}, nil | ||
| case []interface{}: | ||
|
|
||
| rest := "" | ||
| for _, i := range v { | ||
| rest += fmt.Sprintf("%s", i) | ||
| } | ||
| return &types.QueryField{Op: "rest", Value: rest}, nil | ||
| } | ||
| return &types.QueryField{Op: "rest", Value: f}, nil | ||
| } | ||
|
|
||
| func makeFQFromField(f interface{}) (*types.QueryField, error) { | ||
| return f.(*types.QueryField), nil | ||
| } | ||
|
|
||
| //nolint:unused | ||
| func makeQuery(a, b interface{}) (*types.QueryField, error) { | ||
| q := &types.QueryField{ | ||
| Op: "or", | ||
| } | ||
|
|
||
| switch v := a.(type) { | ||
| case *types.QueryField: | ||
| q.Fields = append(q.Fields, v) | ||
| default: | ||
| logger.Warnf("Unknown type for query.a: %v = %T", a, a) | ||
| } | ||
|
|
||
| switch v := b.(type) { | ||
| case *types.QueryField: | ||
| q.Fields = append(q.Fields, v) | ||
| case []interface{}: | ||
| for _, i := range v { | ||
| switch v2 := i.(type) { | ||
| case *types.QueryField: | ||
| q.Fields = append(q.Fields, v2) | ||
|
|
||
| default: | ||
| logger.Warnf("Unknown array item: %v (%T)", i, i) | ||
| } | ||
| } | ||
| default: | ||
| logger.Warnf("Unknown type for query.b: %v = %T", b, b) | ||
| } | ||
|
|
||
| return q, nil | ||
| } | ||
|
|
||
| func makeAndQuery(a any, b any) (*types.QueryField, error) { | ||
|
|
||
| q := &types.QueryField{Op: "and"} | ||
|
|
||
| switch v := a.(type) { | ||
| case *types.QueryField: | ||
| q.Fields = append(q.Fields, v) | ||
|
|
||
| default: | ||
| logger.Warnf("Unknown type for a: %v = %T", a, a) | ||
| } | ||
|
|
||
| switch v := b.(type) { | ||
| case *types.QueryField: | ||
| q.Fields = append(q.Fields, v) | ||
| case []interface{}: | ||
| for _, i := range v { | ||
| switch v2 := i.(type) { | ||
| case *types.QueryField: | ||
| q.Fields = append(q.Fields, v2) | ||
| default: | ||
| logger.Warnf("Unknown array item: %v (%T)", i, i) | ||
| } | ||
| } | ||
| default: | ||
| logger.Warnf("Unknown type for b: %v = %T", b, b) | ||
| } | ||
|
|
||
| return q, nil | ||
| } | ||
|
|
||
| func makeValue(val interface{}) (interface{}, error) { | ||
| return val, nil | ||
| } | ||
|
|
||
| func makeMeasure(num interface{}, units interface{}) (*NumberUnit, error) { | ||
| retVal := &NumberUnit{Number: num, Units: units.(string)} | ||
|
|
||
| return retVal, nil | ||
| } | ||
|
|
||
| func stringFromChars(chars interface{}) string { | ||
| str := "" | ||
| r := chars.([]interface{}) | ||
| for _, i := range r { | ||
| j := i.([]uint8) | ||
| str += string(j[0]) | ||
| } | ||
| return str | ||
| } | ||
|
|
||
| func FlatFields(qf *types.QueryField) []string { | ||
| var fields []string | ||
| if qf.Field != "" { | ||
| fields = append(fields, qf.Field) | ||
| } | ||
| for _, f := range qf.Fields { | ||
| fields = append(fields, FlatFields(f)...) | ||
| } | ||
| return fields | ||
| } | ||
|
|
||
| func ParsePEG(peg string) (*types.QueryField, error) { | ||
| stats := Stats{} | ||
|
|
||
| v, err := Parse("", []byte(peg), Statistics(&stats, "no match")) | ||
| if err != nil { | ||
| return nil, fmt.Errorf("error parsing peg: %w", err) | ||
| } | ||
|
|
||
| rv, ok := v.(*types.QueryField) | ||
| if !ok { | ||
| return nil, fmt.Errorf("return type not types.QueryField") | ||
| } | ||
| return rv, nil | ||
| } |
Oops, something went wrong.