refactor(config): Clarify logs and adjust control flow in listenQueue

csulit · Oct 30, 2024 · 993c078 · 993c078
1 parent 3721df6
commit 993c078
Showing 1 changed file with 4 additions and 2 deletions.
diff --git a/config/deno-kv.ts b/config/deno-kv.ts
@@ -363,7 +363,7 @@ export async function listenQueue(kv: Deno.Kv) {
                 });
 
                 if (listingByUrl.rowCount && listingByUrl.rowCount > 0) {
-                  console.info("Listing already exists");
+                  console.info("Listing query by url already exists");
 
                   const updateListingResult = await transaction.queryObject({
                     args: [
@@ -439,7 +439,9 @@ export async function listenQueue(kv: Deno.Kv) {
                 });
 
                 if (listingByTitle.rowCount && listingByTitle.rowCount > 0) {
-                  continue;
+                  await transaction.commit()
+                  console.log("Listing query by title already exists")
+                  return;
                 }
 
                 let property;