Fixed Custom SQL UpdateOne

Wrongly filter was passed to the update SQL
event-driven-io · Oct 2, 2024 · 7ca0e8d · 7ca0e8d
1 parent e33a031
commit 7ca0e8d
Show file tree

Hide file tree

Showing 4 changed files with 7 additions and 7 deletions.
diff --git a/src/package-lock.json b/src/package-lock.json
diff --git a/src/package.json b/src/package.json
@@ -1,6 +1,6 @@
 {
   "name": "@event-driven-io/pongo-core",
-  "version": "0.15.2",
+  "version": "0.15.3",
   "description": "Pongo - Mongo with strong consistency on top of Postgres",
   "type": "module",
   "engines": {

diff --git a/src/packages/pongo/package.json b/src/packages/pongo/package.json
@@ -1,6 +1,6 @@
 {
   "name": "@event-driven-io/pongo",
-  "version": "0.15.2",
+  "version": "0.15.3",
   "description": "Pongo - Mongo with strong consistency on top of Postgres",
   "type": "module",
   "scripts": {

diff --git a/src/packages/pongo/src/postgres/sqlBuilder/index.ts b/src/packages/pongo/src/postgres/sqlBuilder/index.ts
@@ -88,7 +88,7 @@ export const postgresSQLBuilder = (
       expectedVersion != null ? [collectionName, expectedVersion] : [];
 
     const filterQuery = isSQL(filter) ? filter : constructFilterQuery(filter);
-    const updateQuery = isSQL(update) ? filter : buildUpdateQuery(update);
+    const updateQuery = isSQL(update) ? update : buildUpdateQuery(update);
 
     return sql(
       `WITH existing AS (
@@ -176,7 +176,7 @@ export const postgresSQLBuilder = (
     update: PongoUpdate<T> | SQL,
   ): SQL => {
     const filterQuery = isSQL(filter) ? filter : constructFilterQuery(filter);
-    const updateQuery = isSQL(update) ? filter : buildUpdateQuery(update);
+    const updateQuery = isSQL(update) ? update : buildUpdateQuery(update);
 
     return sql(
       `UPDATE %I