Add option for explicit nested AND sub-queries

Signed-off-by: Peter Broadhurst <[email protected]>

Author: peterbroadhurst

pkg/ffapi/restfilter_json.go

@@ -67,7 +67,8 @@ type FilterJSONKeyValues struct {
 }
 
 type FilterJSON struct {
-	Or []*FilterJSON `ffstruct:"FilterJSON" json:"or,omitempty"`
+	Or  []*FilterJSON `ffstruct:"FilterJSON" json:"or,omitempty"`
+	And []*FilterJSON `ffstruct:"FilterJSON" json:"and,omitempty"`
 	FilterJSONOps
 }
 
@@ -435,6 +436,13 @@ func (jf *FilterJSON) BuildAndFilter(ctx context.Context, fb FilterBuilder, opti
 			andFilter = andFilter.Condition(fb.In(field, rv.resolveMany(field, e.Values)))
 		}
 	}
+	for _, child := range jf.And {
+		subFilter, err := child.BuildSubFilter(ctx, fb, options...)
+		if err != nil {
+			return nil, err
+		}
+		andFilter.Condition(subFilter)
+	}
 	if len(jf.Or) > 0 {
 		childFilter := fb.Or()
 		for _, child := range jf.Or {

pkg/ffapi/restfilter_json_test.go

@@ -139,6 +139,52 @@ func TestBuildQuerySingleNestedOr(t *testing.T) {
 	assert.Equal(t, "tag == 'a'", fi.String())
 }
 
+func TestBuildQueryAndWithNestedOr(t *testing.T) {
+
+	var qf QueryJSON
+	err := json.Unmarshal([]byte(`{
+	  "and": [
+	  	{
+			"or": [
+				{
+					"equal": [
+						{
+							"field": "tag",
+							"value": "a"
+						}
+					]		
+				},
+				{
+					"equal": [
+						{
+							"field": "tag",
+							"value": "b"
+						}
+					]		
+				}			
+			]
+		},
+	  	{
+			"equal": [
+				{
+					"field": "cid",
+					"value": "12345"
+				}
+			]		
+		}		
+	  ]
+	}`), &qf)
+	assert.NoError(t, err)
+
+	filter, err := qf.BuildFilter(context.Background(), TestQueryFactory)
+	assert.NoError(t, err)
+
+	fi, err := filter.Finalize()
+	assert.NoError(t, err)
+
+	assert.Equal(t, "( ( tag == 'a' ) || ( tag == 'b' ) ) && ( cid == '12345' )", fi.String())
+}
+
 func TestBuildQuerySkipFieldValidation(t *testing.T) {
 
 	var jf *FilterJSON
@@ -706,3 +752,28 @@ func TestBuildQueryJSONContainsShortNames(t *testing.T) {
 
 	assert.Equal(t, "( sequence <= 12345 ) && ( sequence >> 12345 )", fi.String())
 }
+
+func TestBuildQueryAndFail(t *testing.T) {
+
+	var qf QueryJSON
+	err := json.Unmarshal([]byte(`{
+	  "and": [
+	  	{
+			"or": [
+				{
+					"equal": [
+						{
+							"field": "color",
+							"value": "b"
+						}
+					]		
+				}			
+			]
+		}	
+	  ]
+	}`), &qf)
+	assert.NoError(t, err)
+
+	_, err = qf.BuildFilter(context.Background(), TestQueryFactory)
+	assert.Regexp(t, "FF00142.*color", err)
+}

pkg/i18n/en_base_field_descriptions.go

@@ -44,6 +44,7 @@ var (
 	FilterJSONSort               = ffm("FilterJSON.sort", "Array of fields to sort by. A '-' prefix on a field requests that field is sorted in descending order")
 	FilterJSONCount              = ffm("FilterJSON.count", "If true, the total number of entries that could be returned from the database will be calculated and returned as a 'total' (has a performance cost)")
 	FilterJSONOr                 = ffm("FilterJSON.or", "Array of sub-queries where any sub-query can match to return results (OR combined). Note that within each sub-query all filters must match (AND combined)")
+	FilterJSONAnd                = ffm("FilterJSON.and", "Array of sub-queries where any sub-query can match to return results (AND combined). Allows complex construction, such as an AND of two nested OR sub-queries.")
 	FilterJSONFields             = ffm("FilterJSON.fields", "Fields to return in the response")
 
 	EventStreamBatchSize         = ffm("eventstream.batchSize", "Maximum number of events to deliver in each batch")