Fix assorted Frida download & install issues

This resolves a bug where the first download for an uncached version
would fail (race for data that wasn't buffered I think) and issues where
errors elsewhere (e.g. failed downloads) appeared as unhandled
rejections without proper tracking for pending downloads.

Author: pimterry

src/dynamic-dep-store.ts

@@ -1,8 +1,9 @@
 import * as path from 'path';
-import * as fs from './util/fs';
 import * as stream from 'stream';
+import { CustomError } from '@httptoolkit/util';
 
 import { HtkConfig } from './config';
+import * as fs from './util/fs';
 
 /**
  * This retrieves a stream for a dependency file, either from disk if it's already available
@@ -24,18 +25,30 @@ export async function getDependencyStream<K extends readonly string[]>(options:
     const tmpDownloadPath = depPath + `.tmp-${Math.random().toString(36).slice(2)}`;
     const downloadStream = await options.fetch(options.key);
     const diskStream = fs.createWriteStream(tmpDownloadPath);
+    const resultStream = new stream.PassThrough();
+
     downloadStream.pipe(diskStream);
+    downloadStream.pipe(resultStream);
 
     downloadStream.on('error', (e) => {
         console.warn(`Failed to download dependency to ${depPath}:`, e);
+
+        // Clean up the temp download file:
         diskStream.destroy();
         fs.deleteFile(tmpDownloadPath).catch(() => {});
+
+        // Pass the error on to the client:
+        resultStream.destroy(
+            new CustomError(`${options.key.join('-')} dependency fetch failed: ${e.message ?? e}`, {
+                cause: e
+            })
+        );
     });
 
     diskStream.on('finish', () => {
         fs.moveFile(tmpDownloadPath, depPath)
             .catch(console.warn);
     });
 
-    return downloadStream;
+    return resultStream;
 }

src/interceptors/frida/frida-android-integration.ts

@@ -116,7 +116,11 @@ export async function setupAndroidHost(config: HtkConfig, adbClient: AdbClient,
     const deviceArch = ANDROID_ABI_FRIDA_ARCH_MAP[firstKnownAbi];
     const serverStream = await getFridaServer(config, 'android', deviceArch);
 
-    await deviceClient.push(serverStream, ANDROID_FRIDA_BINARY_PATH, 0o555);
+    const transfer = await deviceClient.push(serverStream, ANDROID_FRIDA_BINARY_PATH, 0o555);
+    await new Promise<void>((resolve, reject) => {
+        transfer.on('end', resolve);
+        transfer.on('error', reject);
+    });
 }
 
 export async function launchAndroidHost(adbClient: AdbClient, hostId: string) {