게스트 기록 가져오기의 저장 완료 오판정

INSERT OR IGNORE INTO guest_import_batches (user_key, import_id, imported_at)
VALUES (?, ?, CURRENT_TIMESTAMP)

statements.push(d1.prepare(GUEST_IMPORT_MARKER_SQL).bind(input.userKey, input.importId));
const results = await d1.batch(statements);
return { imported: Number(results.at(-1)?.meta?.changes ?? 0) > 0 };

await requestStudyMutation(
  "guest-import",
  /* 가져올 기록 */
  signal,
);
window.localStorage.removeItem(GUEST_LEARNING_STORAGE_KEY);

WHERE NOT EXISTS (
  SELECT 1 FROM exam_session_items item
  JOIN exam_sessions session ON session.id = item.session_id
  WHERE item.question_id IN (SELECT value FROM json_each(?)) AND session.user_key = ?
    AND session.status != 'submitted'
)
  AND NOT EXISTS (
    SELECT 1 FROM guest_import_batches WHERE user_key = ? AND import_id = ?
  )

INSERT OR IGNORE INTO guest_import_batches (user_key, import_id, imported_at)
SELECT ?, ?, CURRENT_TIMESTAMP WHERE ${GUEST_IMPORT_COMPLETENESS_SQL}
  AND EXISTS (
    SELECT 1 FROM guest_import_receipts
    WHERE user_key = ? AND import_id = ? AND payload_digest = ?
  )

const results = await d1.batch(statements);
const imported = Number(results.at(-1)?.meta?.changes ?? 0) > 0;
const receipt = !imported ? await readGuestImportReceipt(d1, input.userKey, input.importId) : null;
const duplicate = Boolean(receipt?.payloadDigest && receipt.payloadDigest === input.payloadDigest);
return {
  imported,
  duplicate,
  conflict: !imported && (Boolean(receipt && !duplicate) || await hasConflictingExistingAttempt()),
  attempts: imported || duplicate ? input.attempts.length : 0,
};

return result.ok === true && result.imported === true && result.verified === true
  && result.bookmarks === submitted.bookmarks.length
  && result.attempts === submitted.attempts.length
  && result.theoryProgress === 0;

if (guestImportCompletedForSnapshot(submitted, response)) {
  // Manual retry runs this saved operation after the original caller
  // has returned, so receipt reconciliation belongs in the operation.
  if (!reconcileGuestImportSnapshot(submitted, userKeyHash)) {
    return { ...response, verified: false };
  }
  if (retry) await onImported.current();
}
return response;