From ad3513879254346a663d9abf4fcbd0a4679f29e5 Mon Sep 17 00:00:00 2001 From: AmirSa12 Date: Sat, 2 May 2026 18:39:03 +0330 Subject: [PATCH] fix: overwrite legacy timestamp --- packages/app/server/routes/publish.post.ts | 13 +++++++++++-- 1 file changed, 11 insertions(+), 2 deletions(-) diff --git a/packages/app/server/routes/publish.post.ts b/packages/app/server/routes/publish.post.ts index b4785b78..7131b807 100644 --- a/packages/app/server/routes/publish.post.ts +++ b/packages/app/server/routes/publish.post.ts @@ -195,7 +195,16 @@ export default eventHandler(async (event) => { templatesHtmlMap[template] = new URL(`/template/${uuid}`, origin).href; } - if (!currentCursor || currentCursor.timestamp < runId) { + const LEGACY_MS_TIMESTAMP_CUTOFF = 1e12; + const isStaleCursor = (cursor: { timestamp?: number } | null) => { + if (!cursor) return true; + const ts = Number(cursor.timestamp); + if (!Number.isFinite(ts)) return true; + if (ts >= LEGACY_MS_TIMESTAMP_CUTOFF) return true; + return ts < runId; + }; + + if (isStaleCursor(currentCursor)) { await cursorBucket.setItem(cursorKey, { sha: workflowData.sha, timestamp: runId, @@ -208,7 +217,7 @@ export default eventHandler(async (event) => { ) { const branchCursorKey = `${baseKey}:${workflowData.headBranch}`; const branchCursor = await cursorBucket.getItem(branchCursorKey); - if (!branchCursor || branchCursor.timestamp < runId) { + if (isStaleCursor(branchCursor)) { await cursorBucket.setItem(branchCursorKey, { sha: workflowData.sha, timestamp: runId,