fix: update db filter input type

packages/slonik/src/__test__/helpers/utils.ts

@@ -1,24 +1,45 @@
+import { ApiConfig } from "@dzangolab/fastify-config";
+
 import type { FilterInput, SortInput } from "../../types";
-import type { ApiConfig } from "@dzangolab/fastify-config";
 
-const getFilterDataset = () => {
+const getFilterDataset = (): FilterInput[] => {
   return [
-    { key: "name", operator: "ct", value: "Test" },
-    { key: "name", operator: "ew", value: "t1" },
-    { key: "name", operator: "sw", value: "Test" },
-    { key: "name", operator: "eq", value: "Test" },
-    { key: "id", operator: "gt", value: 10 },
-    { key: "id", operator: "gte", value: 10 },
-    { key: "id", operator: "lt", value: 10 },
-    { key: "id", operator: "lte", value: 10 },
-    { key: "name", operator: "in", value: "Test1, Test2" },
-    { key: "id", operator: "bt", value: "10, 20" },
-    { key: "id", not: true, operator: "bt", value: "10, 20" },
-    { key: "name", operator: "eq", value: "null" },
-    { key: "name", not: true, operator: "eq", value: "NULL" },
-    { key: "countryCode", operator: "eq", value: "FR" },
-    { key: "country_code", operator: "eq", value: "FR" },
-  ] as FilterInput[];
+    { key: "name", operator: "sw", value: "s" },
+    {
+      AND: [
+        { key: "name", operator: "sw", value: "s" },
+        { key: "latitude", operator: "gt", value: "40" },
+      ],
+    },
+    {
+      OR: [
+        { key: "name", operator: "sw", value: "Test" },
+        { key: "name", operator: "ew", value: "t1" },
+      ],
+    },
+    {
+      AND: [
+        { key: "id", operator: "gt", value: "10" },
+        {
+          OR: [
+            { key: "name", operator: "sw", value: "Test" },
+            { key: "name", operator: "ew", value: "t1" },
+          ],
+        },
+      ],
+    },
+    {
+      OR: [
+        { key: "id", operator: "gt", value: "10" },
+        {
+          AND: [
+            { key: "name", operator: "sw", value: "Test" },
+            { key: "name", operator: "ew", value: "t1" },
+          ],
+        },
+      ],
+    },
+  ];
 };
 
 const getLimitAndOffsetDataset = async (count: number, config: ApiConfig) => {
@@ -84,7 +105,7 @@ const getLimitAndOffsetDataset = async (count: number, config: ApiConfig) => {
   ];
 };
 
-const getSortDataset = () => {
+const getSortDataset = (): SortInput[][] => {
   return [
     [{ key: "name", direction: "ASC" }],
     [{ key: "id", direction: "DESC" }],
@@ -94,7 +115,7 @@ const getSortDataset = () => {
       { key: "id", direction: "DESC" },
       { key: "name", direction: "ASC" },
     ],
-  ] as SortInput[][];
+  ];
 };
 
 export { getFilterDataset, getLimitAndOffsetDataset, getSortDataset };

packages/slonik/src/dbFilters.ts

@@ -1,13 +1,12 @@
 import humps from "humps";
 import { sql } from "slonik";
 
-import { FilterInput } from "./types";
-
+import type { BaseFilterInput, FilterInput } from "./types";
 import type { IdentifierSqlToken, FragmentSqlToken } from "slonik";
 
 const applyFilter = (
-  filter: FilterInput,
-  tableIdentifier: IdentifierSqlToken
+  tableIdentifier: IdentifierSqlToken,
+  filter: BaseFilterInput
 ) => {
   const key = humps.decamelize(filter.key);
   const operator = filter.operator || "eq";
@@ -87,16 +86,16 @@ const applyFiltersToQuery = (
     tableIdentifier: IdentifierSqlToken,
     not = false
   ) => {
-    if (filters.AND) {
+    if ("AND" in filters) {
       for (const filterData of filters.AND) {
         applyFilters(filterData, tableIdentifier);
       }
-    } else if (filters.OR) {
+    } else if ("OR" in filters) {
       for (const filterData of filters.OR) {
         applyFilters(filterData, tableIdentifier, true);
       }
     } else {
-      const query = applyFilter(filters, tableIdentifier);
+      const query = applyFilter(tableIdentifier, filters as BaseFilterInput);
 
       if (not) {
         orFilter.push(query);
@@ -114,7 +113,9 @@ const applyFiltersToQuery = (
         sql.fragment`(${sql.join(andFilter, sql.fragment` AND `)})`,
         sql.fragment`(${sql.join(orFilter, sql.fragment` OR `)})`,
       ],
-      sql.fragment`${filters.AND ? sql.fragment` AND ` : sql.fragment` OR `}`
+      sql.fragment`${
+        "AND" in filters ? sql.fragment` AND ` : sql.fragment` OR `
+      }`
     );
   } else if (andFilter.length > 0) {
     queryFilter = sql.join(andFilter, sql.fragment` AND `);

packages/slonik/src/index.ts

@@ -52,6 +52,7 @@ export { default as formatDate } from "./formatDate";
 export { default as migrationPlugin } from "./migrationPlugin";
 
 export type {
+  BaseFilterInput,
   Database,
   FilterInput,
   PaginatedList,

packages/slonik/src/types/database.ts

@@ -18,20 +18,33 @@ type operator =
   | "in"
   | "bt";
 
-type FilterInput = {
-  AND: FilterInput[];
-  OR: FilterInput[];
+type BaseFilterInput = {
   key: string;
   operator: operator;
-  not: boolean;
+  not?: boolean;
   value: string;
 };
 
+type FilterInput =
+  | BaseFilterInput
+  | {
+      AND: FilterInput[];
+    }
+  | {
+      OR: FilterInput[];
+    };
+
 type SortDirection = "ASC" | "DESC";
 
 type SortInput = {
   key: string;
   direction: SortDirection;
 };
 
-export type { Database, FilterInput, SortDirection, SortInput };
+export type {
+  BaseFilterInput,
+  Database,
+  FilterInput,
+  SortDirection,
+  SortInput,
+};

packages/slonik/src/types/index.ts

@@ -5,6 +5,7 @@ export type {
   FilterInput,
   SortDirection,
   SortInput,
+  BaseFilterInput,
 } from "./database";
 
 export type { PaginatedList, Service } from "./service";