RPC Records list filtering

db/sql/00_msar.sql

@@ -3305,6 +3305,52 @@ SELECT val;
 $$ LANGUAGE SQL RETURNS NULL ON NULL INPUT;
 
 
+DROP TABLE IF EXISTS msar.expr_templates;
+CREATE TABLE msar.expr_templates (expr_key text PRIMARY KEY, expr_template text);
+INSERT INTO msar.expr_templates VALUES
+  -- basic composition operators
+  ('and', '(%s) AND (%s)'),
+  ('or', '(%s) OR (%s)'),
+  -- general comparison operators
+  ('equal', '(%s) = (%s)'),
+  ('lesser', '(%s) < (%s)'),
+  ('greater', '(%s) > (%s)'),
+  ('lesser_or_equal', '(%s) <= (%s)'),
+  ('greater_or_equal', '(%s) >= (%s)'),
+  ('null', '(%s) IS NULL'),
+  ('not_null', '(%s) IS NOT NULL'),
+  -- string specific filters
+  ('contains_case_insensitive', 'strpos(lower(%s), lower(%s))::boolean'),
+  ('starts_with_case_insensitive', 'starts_with(lower(%s), lower(%s))'),
+  ('contains', 'strpos((%s), (%s))::boolean'),
+  ('starts_with', 'starts_with((%s), (%s))'),
+  -- json(b) filters and expressions
+  ('json_array_length', 'jsonb_array_length((%s)::jsonb)'),
+  ('json_array_contains', '(%s)::jsonb @> (%s)::jsonb'),
+  -- URI part getters
+  ('uri_scheme', 'mathesar_types.uri_scheme(%s)'),
+  ('uri_authority', 'mathesar_types.uri_authority(%s)'),
+  -- Email part getters
+  ('email_domain', 'mathesar_types.email_domain_name(%s)')
+;
+
+CREATE OR REPLACE FUNCTION msar.build_expr(rel_id oid, tree jsonb) RETURNS text AS $$
+SELECT CASE tree ->> 'type'
+  WHEN 'literal' THEN format('%L', tree ->> 'value')
+  WHEN 'attnum' THEN format('%I', msar.get_column_name(rel_id, (tree ->> 'value')::smallint))
+  ELSE
+    format(max(expr_template), VARIADIC array_agg(msar.build_expr(rel_id, inner_tree)))
+END
+FROM jsonb_array_elements(tree -> 'args') inner_tree, msar.expr_templates
+WHERE tree ->> 'type' = expr_key
+$$ LANGUAGE SQL RETURNS NULL ON NULL INPUT;
+
+
+CREATE OR REPLACE FUNCTION msar.build_where_clause(rel_id oid, tree jsonb) RETURNS text AS $$
+SELECT 'WHERE ' || msar.build_expr(rel_id, tree);
+$$ LANGUAGE SQL RETURNS NULL ON NULL INPUT;
+
+
 CREATE OR REPLACE FUNCTION
 msar.sanitize_direction(direction text) RETURNS text AS $$/*
 */
@@ -3428,13 +3474,14 @@ BEGIN
   EXECUTE format(
     $q$
     WITH count_cte AS (
-      SELECT count(1) AS count FROM %2$I.%3$I
+      SELECT count(1) AS count FROM %2$I.%3$I %7$s
     ), results_cte AS (
-      SELECT %1$s FROM %2$I.%3$I %6$s LIMIT %4$L OFFSET %5$L
+      SELECT %1$s FROM %2$I.%3$I %7$s %6$s LIMIT %4$L OFFSET %5$L
     )
     SELECT jsonb_build_object(
       'results', jsonb_agg(row_to_json(results_cte.*)),
-      'count', max(count_cte.count)
+      'count', max(count_cte.count),
+      'query', $iq$SELECT %1$s FROM %2$I.%3$I %7$s %6$s LIMIT %4$L OFFSET %5$L$iq$
     )
     FROM results_cte, count_cte
     $q$,
@@ -3443,7 +3490,8 @@ BEGIN
     msar.get_relation_name(tab_id),
     limit_,
     offset_,
-    msar.build_order_by_expr(tab_id, order_)
+    msar.build_order_by_expr(tab_id, order_),
+    msar.build_where_clause(tab_id, filter_)
   ) INTO records;
   RETURN records;
 END;