fix(application): harden download-to-setup handoff and processing recovery

.vscode/settings.json

@@ -51,7 +51,9 @@
     "**/.hg/**",
     "**/.svn/**"
   ],
-  "css.validate": false,
+  "css.customData": [".vscode/tailwind.css-data.json"],
+  "css.lint.unknownAtRules": "ignore",
+  "css.validate": true,
   "tailwindCSS.validate": true,
   "tailwindCSS.emmetCompletions": true,
   "typescript.preferences.autoImportSpecifierExcludeRegexes": [

.vscode/tailwind.css-data.json

@@ -0,0 +1,45 @@
+{
+  "version": 1.1,
+  "atDirectives": [
+    {
+      "name": "@apply",
+      "description": "Inline Tailwind utility classes into a CSS rule."
+    },
+    {
+      "name": "@config",
+      "description": "Load a legacy Tailwind JavaScript configuration file."
+    },
+    {
+      "name": "@custom-variant",
+      "description": "Define a custom Tailwind variant."
+    },
+    {
+      "name": "@plugin",
+      "description": "Load a legacy Tailwind JavaScript plugin."
+    },
+    {
+      "name": "@reference",
+      "description": "Import a Tailwind stylesheet for theme and utility references without emitting CSS."
+    },
+    {
+      "name": "@source",
+      "description": "Register source files for Tailwind class detection."
+    },
+    {
+      "name": "@tailwind",
+      "description": "Insert a Tailwind CSS layer."
+    },
+    {
+      "name": "@theme",
+      "description": "Define Tailwind theme variables."
+    },
+    {
+      "name": "@utility",
+      "description": "Define a custom Tailwind utility."
+    },
+    {
+      "name": "@variant",
+      "description": "Apply a Tailwind variant to CSS rules."
+    }
+  ]
+}

application/src/electron/handlers/handler.fs.ts

@@ -71,15 +71,27 @@ const extractArchive = (arg: {
         ],
       });
     }
+    // Throttle progress IPC: per-file move callbacks can fire thousands of
+    // times for large games. Always let stage changes and completion through.
+    let lastProgressSent = 0;
+    let lastStage: string | undefined;
     yield* fsTryPromise(arg.outputDir, () =>
-      extraction(archivePath, arg.outputDir, (progress) => {
-        if (arg.downloadId) {
-          sendIPCMessage('processing:progress', {
-            id: arg.downloadId,
-            phase: 'Extracting archive',
-            progress,
-          });
-        }
+      extraction(archivePath, arg.outputDir, (progress, stage) => {
+        if (!arg.downloadId) return;
+        const now = Date.now();
+        if (
+          stage === lastStage &&
+          progress !== 1 &&
+          now - lastProgressSent < 100
+        )
+          return;
+        lastProgressSent = now;
+        lastStage = stage;
+        sendIPCMessage('processing:progress', {
+          id: arg.downloadId,
+          phase: stage === 'moving' ? 'Moving files' : 'Extracting archive',
+          progress,
+        });
       })
     ).pipe(
       Effect.tapError((error) =>

application/src/electron/handlers/handler.torrent.ts

@@ -88,6 +88,7 @@ interface WebTorrentControls {
   pause: () => void;
   resume: () => void;
   destroy: () => void;
+  waitUntilFilesReady: () => Effect.Effect<void, TorrentError>;
 }
 
 const downloads = new Map<string, TorrentDownload>();
@@ -306,7 +307,7 @@ class TorrentDownload {
           );
 
           yield* Deferred.await(completed);
-          yield* Effect.sleep('1 second');
+          yield* this.wtBlock.waitUntilFilesReady();
 
           if (this.status === 'cancelled' || this.status === 'failed') {
             return false;

application/src/electron/lib/steam-installation.ts

@@ -513,6 +513,7 @@ export const SteamRepositoryLive = (
           const configExisted = config.existed;
           let shortcutsCommitted = false;
           let configCommitted = false;
+          let shortcutsBackupWritten = false;
           const restore = (
             filePath: string,
             fileExisted: boolean,
@@ -553,6 +554,13 @@ export const SteamRepositoryLive = (
                   yield* writeFileAtomic(configPath, options.configSource);
                   configCommitted = true;
                 }
+                if (existed && !shortcutsBackupWritten) {
+                  yield* writeFileAtomic(
+                    `${shortcutsPath}.ogi-backup`,
+                    original
+                  );
+                  shortcutsBackupWritten = true;
+                }
                 const written = yield* Effect.either(
                   write(shortcutsPath, updatedRoot)
                 );

application/src/electron/lib/torrent-files.ts

@@ -0,0 +1,53 @@
+import { open, stat } from 'node:fs/promises';
+
+export interface TorrentFileExpectation {
+  path: string;
+  length: number;
+}
+
+interface TorrentFileReadinessOptions {
+  timeoutMs?: number;
+  intervalMs?: number;
+  probe?: (file: TorrentFileExpectation) => Promise<void>;
+}
+
+async function probeTorrentFile(file: TorrentFileExpectation): Promise<void> {
+  const fileStat = await stat(file.path);
+  if (fileStat.size !== file.length) {
+    throw new Error(
+      `Torrent file has size ${fileStat.size}, expected ${file.length}: ${file.path}`
+    );
+  }
+
+  const handle = await open(file.path, 'r');
+  await handle.close();
+}
+
+/** Wait until WebTorrent's completed files can be safely reopened by setup/seeding. */
+export async function waitForTorrentFiles(
+  files: readonly TorrentFileExpectation[],
+  options: TorrentFileReadinessOptions = {}
+): Promise<void> {
+  const timeoutMs = options.timeoutMs ?? 10_000;
+  const intervalMs = options.intervalMs ?? 100;
+  const probe = options.probe ?? probeTorrentFile;
+  const deadline = Date.now() + timeoutMs;
+  let lastError: unknown;
+
+  do {
+    try {
+      await Promise.all(files.map(probe));
+      return;
+    } catch (error) {
+      lastError = error;
+      if (Date.now() >= deadline) break;
+      await new Promise<void>((resolveDelay) =>
+        setTimeout(resolveDelay, intervalMs)
+      );
+    }
+  } while (Date.now() <= deadline);
+
+  throw lastError instanceof Error
+    ? lastError
+    : new Error('Torrent files did not become ready');
+}

application/src/electron/manager/manager.webtorrent.ts

@@ -1,7 +1,9 @@
+import { resolve as resolvePath } from 'node:path';
 import { TorrentError } from '@ogi-sdk/errors';
 import { createLogger, LOGGER_PREFIXES } from '@ogi-sdk/logger';
 import { Effect } from 'effect';
 import webtorrent from 'webtorrent';
+import { waitForTorrentFiles } from '@/electron/lib/torrent-files.js';
 
 const logger = createLogger(LOGGER_PREFIXES.electron);
 
@@ -12,6 +14,7 @@ type TorrentControls = {
   pause: () => void;
   resume: () => void;
   destroy: () => void;
+  waitUntilFilesReady: () => Effect.Effect<void, TorrentError>;
 };
 
 export function torrent(torrentId: string | Buffer, path: string) {
@@ -82,6 +85,21 @@ export function torrent(torrentId: string | Buffer, path: string) {
                   stopProgressReporting();
                   activeTorrent.destroy();
                 },
+                waitUntilFilesReady: () =>
+                  Effect.tryPromise({
+                    try: () =>
+                      waitForTorrentFiles(
+                        activeTorrent.files.map((file) => ({
+                          path: resolvePath(path, file.path),
+                          length: file.length,
+                        }))
+                      ),
+                    catch: (cause) =>
+                      new TorrentError({
+                        message: `Torrent files did not become ready: ${String(cause)}`,
+                        cause,
+                      }),
+                  }),
               })
             );
           });

application/src/electron/tsconfig.json

@@ -2,7 +2,7 @@
   "compileOnSave": true,
   "compilerOptions": {
     "outDir": "../../build",
-    "baseUrl": ".",
+    "rootDir": "..",
     "typeRoots": ["node_modules/@types"],
     "target": "ES2022",
     "allowJs": true,

application/src/frontend/components/built/UpdateAppModal.svelte

@@ -225,9 +225,16 @@ async function handleDownloadClick(
     updateVersion: updateVersion,
   } as SearchResultWithAddon & { isUpdate: boolean; updateVersion: string };
 
-  const started = await runFrontendEffect(
-    startDownloadEffect(updateResult, appID, event).pipe(
+  startDownloadEffect(updateResult, appID, event)
+    .pipe(
       Effect.as(true),
+      Effect.tap(() => {
+        createNotification({
+          id: Math.random().toString(36).substring(7),
+          message: `Starting update download for ${gameName}`,
+          type: 'info',
+        });
+      }),
       Effect.catchAll((error) =>
         Effect.sync(() => {
           logger.sync.error('Failed to start update download:', error);
@@ -240,15 +247,8 @@ async function handleDownloadClick(
         })
       )
     )
-  );
-  if (!started) return;
+    .pipe(Effect.runFork);
   onClose();
-
-  createNotification({
-    id: Math.random().toString(36).substring(7),
-    message: `Starting update download for ${gameName}`,
-    type: 'info',
-  });
 }
 
 function toggleAddonCollapse(addonId: string) {