feat: support in operator in query

service/handler_test.go

@@ -816,6 +816,54 @@ allow {
 		require.Equal(t, expectedQuery, filterQuery)
 	})
 
+	t.Run("sends filter query with $in", func(t *testing.T) {
+		policy := `package policies
+allow {
+	input.request.method == "GET"
+
+	employee := data.resources[_]
+	employee.membership in "member_test"
+}
+
+allow {
+	input.request.method == "GET"
+	input.request.path == "/api"
+	employee := data.resources[_]
+	employee.salary > 0
+}
+`
+
+		mockBodySting := "I am a body"
+
+		body := strings.NewReader(mockBodySting)
+
+		partialEvaluators, err := core.SetupEvaluators(ctx, nil, &oasWithFilter, mockOPAModule, envs)
+		require.NoError(t, err, "Unexpected error")
+
+		ctx := createContext(t,
+			context.Background(),
+			env,
+			nil,
+			mockRondConfigWithQueryGen,
+			&core.OPAModuleConfig{Name: "mypolicy.rego", Content: policy},
+			partialEvaluators,
+		)
+
+		r, err := http.NewRequestWithContext(ctx, "GET", "http://www.example.com:8080/api", body)
+		require.NoError(t, err, "Unexpected error")
+		r.Header.Set("miauserproperties", `{"name":"gianni"}`)
+		r.Header.Set("examplekey", "value")
+		r.Header.Set("Content-Type", "text/plain")
+		w := httptest.NewRecorder()
+
+		rbacHandler(w, r)
+
+		require.Equal(t, http.StatusOK, w.Result().StatusCode, "Unexpected status code.")
+		filterQuery := r.Header.Get("rowfilterquery")
+		expectedQuery := `{"$or":[{"$and":[{"membership":{"$in":["manager_test"]}}]},{"$and":[{"salary":{"$gt":0}}]}]}`
+		require.Equal(t, expectedQuery, filterQuery)
+	})
+
 	t.Run("sends empty filter query", func(t *testing.T) {
 		policy := `package policies
 allow {