Function shouldApplyRemoteRecord

packages/core/src/sync/simple-sync.ts:444–465

(
  record: Record<string, unknown>,
  timestampCol: string,
  localState: ExistingRecordState | undefined,
)

}

function shouldApplyRemoteRecord(
  record: Record<string, unknown>,
  timestampCol: string,
  localState: ExistingRecordState | undefined,
): boolean {
  if (!localState) return true;

  const remoteTs = record[timestampCol] as number;
  if (remoteTs > localState.timestamp) return true;
  if (remoteTs < localState.timestamp) return false;

  // Preserved book deletes are represented as regular rows with deleted_at set.
  // When timestamps tie, let the newer delete marker break the tie so devices
  // cannot stay split between live and deleted copies of the same book.
  if (!Object.prototype.hasOwnProperty.call(record, "deleted_at")) return false;

  const remoteDeletedAt = normalizeDeletedAt(record.deleted_at);
  const localDeletedAt = localState.deletedAt ?? null;
  if (remoteDeletedAt === undefined || remoteDeletedAt === localDeletedAt) return false;

  return (remoteDeletedAt ?? 0) > (localDeletedAt ?? 0);
}

async function rememberRemoteTombstone(
  db: Awaited<ReturnType<typeof getDB>>,