Use DownloadManager

client_manager.ts

@@ -36,6 +36,8 @@ import {
 import { StorageDenoKV } from "mtkruto/storage/1_storage_deno_kv.ts";
 import { transportProviderTcp } from "mtkruto/transport/3_transport_provider_tcp.ts";
 
+import { DownloadManager } from "./download_manager.ts";
+
 export interface ClientStats {
   connected: boolean;
   me: User;
@@ -87,6 +89,16 @@ export class ClientManager {
     };
   }
 
+  #downloadManagers = new Map<Client, DownloadManager>();
+  async download(id: string, fileId: string) {
+    const client = await this.getClient(id);
+    let downloadManager = this.#downloadManagers.get(client);
+    if (!downloadManager) {
+      downloadManager = new DownloadManager(client);
+    }
+    return downloadManager.download(fileId);
+  }
+
   async getClient(id: string) {
     {
       const client = this.#clients.get(id);

download_manager.ts

@@ -1,5 +1,6 @@
 import * as path from "std/path/mod.ts";
 import { exists, existsSync } from "std/fs/mod.ts";
+
 import { Client } from "mtkruto/mod.ts";
 import { Queue } from "mtkruto/1_utilities.ts";
 

main.ts

@@ -175,7 +175,9 @@ async function handleMethod(
           if (chunk == null) {
             controller.close();
           } else {
-            controller.enqueue(chunk.value);
+            if (chunk.value) {
+              controller.enqueue(chunk.value);
+            }
             if (chunk.done) {
               controller.close();
             }

worker.ts

@@ -161,10 +161,15 @@ async function serve(
   if (!(ALLOWED_METHODS.includes(method))) {
     return "DROP";
   }
-  const client = await clientManager.getClient(id);
-  // deno-lint-ignore ban-ts-comment
-  // @ts-ignore
-  const result = transform(await client[method](...args));
+  let result;
+  if (method == "download") {
+    result = await clientManager.download(id, args[0]);
+  } else {
+    const client = await clientManager.getClient(id);
+    // deno-lint-ignore ban-ts-comment
+    // @ts-ignore
+    result = transform(await client[method](...args));
+  }
   if (result !== undefined) {
     if (
       typeof result === "object" && result != null &&