Implement $nin

Author: erikdubbelboer

filter/converter.go

@@ -140,11 +140,16 @@ func (c *Converter) convertFilter(filter map[string]any, paramIndex int) (string
 						return "", nil, fmt.Errorf("$or as scalar operator not supported")
 					case "$and":
 						return "", nil, fmt.Errorf("$and as scalar operator not supported")
-					case "$in":
+					case "$in", "$nin":
 						if !isScalarSlice(v[operator]) {
 							return "", nil, fmt.Errorf("invalid value for $in operator (must array of primatives): %v", v[operator])
 						}
-						inner = append(inner, fmt.Sprintf("(%s = ANY($%d))", c.columnName(key), paramIndex))
+						op := ""
+						if operator == "$nin" {
+							op = "NOT "
+						}
+						// `column != ANY(...)` does not work, so we need to do `NOT column = ANY(...)` instead.
+						inner = append(inner, fmt.Sprintf("(%s%s = ANY($%d))", op, c.columnName(key), paramIndex))
 						paramIndex++
 						if c.arrayDriver != nil {
 							v[operator] = c.arrayDriver(v[operator])

filter/converter_test.go

@@ -74,31 +74,39 @@ func TestConverter_Convert(t *testing.T) {
 			nil,
 		},
 		{
-			"in-array operator simple",
+			"simple $in",
 			nil,
 			`{"status": {"$in": ["NEW", "OPEN"]}}`,
 			`("status" = ANY($1))`,
 			[]any{[]any{"NEW", "OPEN"}},
 			nil,
 		},
 		{
-			"in-array operator invalid value",
+			"simple $nin",
+			nil,
+			`{"status": {"$nin": ["NEW", "OPEN"]}}`,
+			`(NOT "status" = ANY($1))`,
+			[]any{[]any{"NEW", "OPEN"}},
+			nil,
+		},
+		{
+			"$in invalid value",
 			nil,
 			`{"status": {"$in": [{"hacker": 1}, "OPEN"]}}`,
 			``,
 			nil,
 			fmt.Errorf("invalid value for $in operator (must array of primatives): [map[hacker:1] OPEN]"),
 		},
 		{
-			"in-array operator scalar value",
+			"$in scalar value",
 			nil,
 			`{"status": {"$in": "text"}}`,
 			``,
 			nil,
 			fmt.Errorf("invalid value for $in operator (must array of primatives): text"),
 		},
 		{
-			"in-array operator with null value",
+			"$in with null value",
 			nil,
 			`{"status": {"$in": ["guest", null]}}`,
 			`("status" = ANY($1))`,

integration/postgres_test.go

@@ -297,6 +297,12 @@ func TestIntegration_BasicOperators(t *testing.T) {
 			[]int{},
 			nil,
 		},
+		{
+			"$nin",
+			`{"level": {"$nin": [20, 30, 40]}}`,
+			[]int{1, 5, 6, 7, 8, 9, 10},
+			nil,
+		},
 	}
 
 	for _, tt := range tests {