refactor: Use transaction object for DB queries in listenQueue

csulit · Oct 30, 2024 · 0284b7f · 0284b7f
1 parent dbd53f6
commit 0284b7f
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/config/deno-kv.ts b/config/deno-kv.ts
@@ -222,7 +222,7 @@ export async function listenQueue(kv: Deno.Kv) {
                   const newRegionId = lastRegionId.rows[0].id +
                     Math.floor(100000 + Math.random() * 900000);
 
-                  region = await client2.queryObject({
+                  region = await transaction.queryObject({
                     args: [
                       newRegionId,
                       rawProperty.region,
@@ -257,7 +257,7 @@ export async function listenQueue(kv: Deno.Kv) {
                   const newCityId = lastCityId.rows[0].id +
                     Math.floor(100000 + Math.random() * 900000);
 
-                  city = await client2.queryObject({
+                  city = await transaction.queryObject({
                     args: [
                       newCityId,
                       rawProperty.city,
@@ -289,7 +289,7 @@ export async function listenQueue(kv: Deno.Kv) {
                   const newAreaId = lastAreaId.rows[0].id +
                     Math.floor(100000 + Math.random() * 900000);
 
-                  area = await client2.queryObject({
+                  area = await transaction.queryObject({
                     args: [
                       newAreaId,
                       rawProperty.listing_area,