refactor(deno-kv): Reorganize transaction begin and validation checks

Author: csulit

config/deno-kv.ts

@@ -120,6 +120,10 @@ export async function listenQueue(kv: Deno.Kv) {
             const client_1 = await dbPool.connect();
 
             try {
+              transaction = client_1.createTransaction("create-listing");
+
+              await transaction.begin();
+
               if (!msg.data?.dataLayer) {
                 throw new Error("DataLayer is missing or undefined");
               }
@@ -133,6 +137,27 @@ export async function listenQueue(kv: Deno.Kv) {
                 );
               }
 
+              if (!msg.data.dataLayer.agent_name) {
+                throw new Error("Agent name is missing or undefined");
+              }
+
+              if (!msg.data.dataLayer.product_owner) {
+                throw new Error("Product owner is missing or undefined");
+              }
+
+              if (!msg.data.dataLayer.product_owner_name) {
+                throw new Error("Product owner name is missing or undefined");
+              }
+
+              if (
+                !msg.data.dataLayer.location ||
+                typeof msg.data.dataLayer.location !== "object"
+              ) {
+                throw new Error(
+                  "Location is missing, undefined, or not an object"
+                );
+              }
+
               let propertyId;
               let warehouseTypeId;
               const listingUrl = msg.data.listingUrl;
@@ -147,9 +172,6 @@ export async function listenQueue(kv: Deno.Kv) {
               const isLand =
                 msg.data.dataLayer.attributes.subcategory === "Land";
 
-              transaction = client_1.createTransaction("create-listing");
-              await transaction.begin();
-
               const listingRecord = await transaction.queryObject(`
                 SELECT id, property_id
                 FROM Listing
@@ -203,27 +225,6 @@ export async function listenQueue(kv: Deno.Kv) {
                 return;
               }
 
-              if (!msg.data.dataLayer.agent_name) {
-                throw new Error("Agent name is missing or undefined");
-              }
-
-              if (!msg.data.dataLayer.product_owner) {
-                throw new Error("Product owner is missing or undefined");
-              }
-
-              if (!msg.data.dataLayer.product_owner_name) {
-                throw new Error("Product owner name is missing or undefined");
-              }
-
-              if (
-                !msg.data.dataLayer.location ||
-                typeof msg.data.dataLayer.location !== "object"
-              ) {
-                throw new Error(
-                  "Location is missing, undefined, or not an object"
-                );
-              }
-
               if (isCondominium) {
                 propertyId = 1;
               }