Jannik/PaperClipAI
1
0 Fork 0
mirror of https://github.com/paperclipai/paperclip.git synced 2026-11-08 12:33:05 +01:00
Code Issues Packages Projects Releases Wiki Activity

fix(runtime): narrow missing pre-copy stamps before publication checks

Browse Source 
Co-Authored-By: Paperclip <noreply@paperclip.ing>
This commit is contained in:
DottaandPaperclip committed 2026-11-04 22:19:11 -06:00
1 parent d7c41047b2
commit 016e069cb2
1 file changed
+2 -2
Download Patch File Download Diff File Expand all files Collapse all files
server/src/services/native-runtime/native-harness-backup-storage.ts
+2 -2
View File
@@ -30,7 +30,7 @@ type OfflineOwner = { kind: "offline_migration"; companyId: string; issueId: str
writersStopped: true; terminalFailureOnly?: true };
type InactiveSource = { root: string; manifestSha256: string; scopeDigest: string;
normalizedSessionId: string; runnerInstanceId: string; providerLeaseId: string };
const fail = (reason: string): never => { throw new Error(`native_harness_storage_${reason}`); };
function fail(reason: string): never { throw new Error(`native_harness_storage_${reason}`); }
const aad = (binding: Binding) => Buffer.from(JSON.stringify([SCHEMA, binding.companyId, binding.scopeDigest, binding.id]));
const scope = (binding: Pick<Binding, "companyId" | "scopeDigest">) => and(
eq(nativeHarnessBackups.companyId, binding.companyId), eq(nativeHarnessBackups.scopeDigest, binding.scopeDigest));
@@ -159,7 +159,7 @@ async function fence(tx: Parameters<Parameters<Db["transaction"]>[0]>[0], owner:
eq(environmentLeases.issueId, owner.issueId), eq(environmentLeases.providerLeaseId, inactiveSource.providerLeaseId),
sql`${environmentLeases.metadata}->'nativeHarnessBackup'->>'manifestSha256' = ${inactiveSource.manifestSha256}`)).limit(1);
const stamp = readNativeHarnessBackupStamp(lease?.stamp, inactiveSource.providerLeaseId);
if (!binding || stamp?.sessionScopeSha256 !== inactiveSource.scopeDigest
if (!binding || !stamp || stamp.sessionScopeSha256 !== inactiveSource.scopeDigest
|| stamp.normalizedSessionId !== inactiveSource.normalizedSessionId || stamp.runnerInstanceId !== inactiveSource.runnerInstanceId) {
fail("prestage_source_changed");
}