refactor(config): Reorder update queries for better transaction flow

csulit · Oct 29, 2024 · 14cb41e · 14cb41e
1 parent 776881c
commit 14cb41e
Showing 1 changed file with 15 additions and 17 deletions.
diff --git a/config/deno-kv.ts b/config/deno-kv.ts
@@ -365,26 +365,11 @@ export async function listenQueue(kv: Deno.Kv) {
                 if (listing.rowCount && listing.rowCount > 0) {
                   console.info("Listing already exists");
 
-                  const updateResult = await transaction.queryObject({
-                    args: [rawProperty.id],
-                    text: `
-                      UPDATE lamudi_raw_data
-                      SET is_process = TRUE
-                      WHERE id = $1
-                    `,
-                  });
-
-                  if (updateResult.rowCount === 1) {
-                    console.info("1 record updated in lamudi_raw_data");
-                  }
-
-
-
                   const updateListingResult = await transaction.queryObject({
                     args: [
                       rawProperty.price,
                       rawProperty.price_formatted,
-                      listing.rows[0].id
+                      listing.rows[0].id,
                     ],
                     text: `
                       UPDATE Listing 
@@ -405,7 +390,7 @@ export async function listenQueue(kv: Deno.Kv) {
                       rawProperty.agent_name,
                       rawProperty.product_owner_name,
                       rawProperty.project_name,
-                      listing.rows[0].property_id
+                      listing.rows[0].property_id,
                     ],
                     text: `
                       UPDATE Property p
@@ -424,6 +409,19 @@ export async function listenQueue(kv: Deno.Kv) {
                     );
                   }
 
+                  const updateResult = await transaction.queryObject({
+                    args: [rawProperty.id],
+                    text: `
+                      UPDATE lamudi_raw_data
+                      SET is_process = TRUE
+                      WHERE id = $1
+                    `,
+                  });
+
+                  if (updateResult.rowCount === 1) {
+                    console.info("1 record updated in lamudi_raw_data");
+                  }
+
                   continue;
                 }