Function syncFiles

packages/core/src/sync/sync-files.ts:314–579

(
  backend: ISyncBackend,
  onProgress?: (progress: SyncProgress) => void,
  options: SyncFilesOptions = {},
)

 * Sync book files and covers between local and remote.
 */
export async function syncFiles(
  backend: ISyncBackend,
  onProgress?: (progress: SyncProgress) => void,
  options: SyncFilesOptions = {},
): Promise<{
  filesUploaded: number;
  filesDownloaded: number;
  filesUploadFailed: number;
  filesDownloadFailed: number;
}> {
  const syncFilesStart = Date.now();
  console.log("[Sync] 📁 Starting file sync...");

  const adapter = getSyncAdapter();
  const db = await getDB();
  const { setBookSyncStatus } = await import("../db/database");
  const {
    forceUploadAll = false,
    forceDownloadAll = false,
    downloadRemoteBooks = false,
    disableUploads = false,
    disableRemoteDeletes = false,
  } = options;
  let filesUploaded = 0;
  let filesDownloaded = 0;
  let filesUploadFailed = 0;
  let filesDownloadFailed = 0;

  const books = await db.select<BookRow>(
    "SELECT id, file_path, file_hash, cover_url, title FROM books WHERE deleted_at IS NULL",
    [],
  );

  const appDataDir = await adapter.getAppDataDir();
  const currentBookIds = new Set(books.map((b) => b.id));

  // --- Compute per-book info ---
  const bookInfos: BookInfo[] = books.map((book) => {
    const fileExt = book.file_path ? getExt(book.file_path) || "epub" : "";
    const coverExt = book.cover_url ? getExt(book.cover_url) || "jpg" : "";
    const localFilePath = book.file_path
      ? isAbsoluteOrProtocolPath(book.file_path)
        ? book.file_path
        : adapter.joinPath(appDataDir, book.file_path)
      : "";
    const localCoverPath = book.cover_url
      ? isAbsoluteOrProtocolPath(book.cover_url)
        ? book.cover_url
        : adapter.joinPath(appDataDir, book.cover_url)
      : "";
    return {
      book,
      fileExt,
      coverExt,
      localFilePath,
      localCoverPath,
      remoteDir: buildBookRemoteDir(book),
      expectedFolderName: buildBookFolderName(book),