Skip to content

Commit faff30c

Browse files
committed
fix: delete duplicated run
1 parent 749cace commit faff30c

File tree

2 files changed

+17
-5
lines changed

2 files changed

+17
-5
lines changed

.gitignore

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,2 +1,3 @@
11
result
2-
demo*
2+
demo*
3+
kview

src/server/kv/runs.ts

Lines changed: 15 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -12,13 +12,20 @@ export async function save(project: string, data: Run) {
1212

1313
const run = await get(data.id);
1414

15-
await kv.delete([
15+
const { value: runDate } = await kv.get<number>([
1616
FLUENTCI_KV_PREFIX,
17-
"runs_by_date",
18-
project,
19-
dayjs(_.get(run, "date", data.date)).unix(),
17+
"run_date",
18+
data.id,
2019
]);
2120

21+
if (runDate) {
22+
await kv
23+
.atomic()
24+
.delete([FLUENTCI_KV_PREFIX, "runs_by_date", project, runDate])
25+
.delete([FLUENTCI_KV_PREFIX, "run_date", data.id])
26+
.commit();
27+
}
28+
2229
await kv
2330
.atomic()
2431
.set([FLUENTCI_KV_PREFIX, "runs", project, data.id], data)
@@ -33,6 +40,10 @@ export async function save(project: string, data: Run) {
3340
],
3441
data
3542
)
43+
.set(
44+
[FLUENTCI_KV_PREFIX, "run_date", data.id],
45+
dayjs(_.get(run, "date", data.date)).unix()
46+
)
3647
.set(
3748
[
3849
FLUENTCI_KV_PREFIX,

0 commit comments

Comments
 (0)