fix: delete duplicated run

fluentci-io · May 30, 2024 · faff30c · faff30c
1 parent 749cace
commit faff30c
Show file tree

Hide file tree

Showing 2 changed files with 17 additions and 5 deletions.
diff --git a/.gitignore b/.gitignore
@@ -1,2 +1,3 @@
 result
-demo*
+demo*
+kview
diff --git a/src/server/kv/runs.ts b/src/server/kv/runs.ts
@@ -12,13 +12,20 @@ export async function save(project: string, data: Run) {
 
   const run = await get(data.id);
 
-  await kv.delete([
+  const { value: runDate } = await kv.get<number>([
     FLUENTCI_KV_PREFIX,
-    "runs_by_date",
-    project,
-    dayjs(_.get(run, "date", data.date)).unix(),
+    "run_date",
+    data.id,
   ]);
 
+  if (runDate) {
+    await kv
+      .atomic()
+      .delete([FLUENTCI_KV_PREFIX, "runs_by_date", project, runDate])
+      .delete([FLUENTCI_KV_PREFIX, "run_date", data.id])
+      .commit();
+  }
+
   await kv
     .atomic()
     .set([FLUENTCI_KV_PREFIX, "runs", project, data.id], data)
@@ -33,6 +40,10 @@ export async function save(project: string, data: Run) {
       ],
       data
     )
+    .set(
+      [FLUENTCI_KV_PREFIX, "run_date", data.id],
+      dayjs(_.get(run, "date", data.date)).unix()
+    )
     .set(
       [
         FLUENTCI_KV_PREFIX,