refactor: reuse async iterators..

src/routes/files.ts

@@ -2,6 +2,7 @@ import { FastifyPluginCallback } from "fastify";
 import multipart from "@fastify/multipart";
 import { getFileDownload, getFileLink, uploadFiles } from "../telegram";
 import { readFile } from "fs/promises";
+import { asyncIteratorToArray } from "../utils/array";
 
 export const FilesAPI: FastifyPluginCallback = async (fastify, _, done) => {
   await fastify.register(multipart, {
@@ -18,7 +19,8 @@ export const FilesAPI: FastifyPluginCallback = async (fastify, _, done) => {
     // This is to avoid working with req.files(), which is an async iterator... and a pain to work with.
     // Files from saveRequestFiles() have a useless toBuffer method, so it needs to be replaced.
     console.log("Saving file to disk...");
-    const files = (await req.saveRequestFiles()).map((file) => ({ ...file, toBuffer: () => readFile(file.filepath) }));
+    const files = await asyncIteratorToArray(req.files());
+    // const files = (await req.saveRequestFiles()).map((file) => ({ ...file, toBuffer: () => readFile(file.filepath) }));
     console.log(`Start upload of ${files.length} files...`);
     const ret = await uploadFiles(files);
 

src/utils/array.ts

@@ -7,3 +7,11 @@ export function splitArrayIntoChunks<T>(arr: T[], chunkSize: number): T[][] {
 
   return result;
 }
+
+export async function asyncIteratorToArray<T>(gen: AsyncIterable<T>): Promise<T[]> {
+  const out: T[] = [];
+  for await (const x of gen) {
+    out.push(x);
+  }
+  return out;
+}