fix(config): Handle error by setting is_process flag in Deno KV listener

csulit · Oct 29, 2024 · 9e094eb · 9e094eb
1 parent c3f691f
commit 9e094eb
Show file tree

Hide file tree

Showing 2 changed files with 9 additions and 1 deletion.
diff --git a/config/deno-kv.ts b/config/deno-kv.ts
@@ -518,6 +518,14 @@ export async function listenQueue(kv: Deno.Kv) {
                       console.info("1 record updated in lamudi_raw_data");
                     }
                   } catch (error) {
+                    await client2.queryObject({
+                      args: [rawProperty.id],
+                      text: `
+                      UPDATE lamudi_raw_data
+                      SET is_process = TRUE
+                      WHERE id = $1
+                    `,
+                    });
                     throw error;
                   }
                 }

diff --git a/server.ts b/server.ts
@@ -104,7 +104,7 @@ app.get("/api/properties", async (c: Context) => {
   if (query.search) {
     addWhereCondition(
       `to_tsvector('english', l.title || ' ' || l.description) @@ plainto_tsquery($${paramCounter})`,
-      query.search
+      query.search,
     );
   }