feat: support recursive auto-upload

.gitignore

@@ -40,4 +40,5 @@ Thumbs.db
 
 # Next.js
 .next
-*.local
+*.local
+.vercel

libs/client/package.json

@@ -1,7 +1,7 @@
 {
   "name": "@fal-ai/serverless-client",
   "description": "The fal serverless JS/TS client",
-  "version": "0.9.1",
+  "version": "0.9.2",
   "license": "MIT",
   "repository": {
     "type": "git",

libs/client/src/storage.ts

@@ -59,7 +59,7 @@
  * @returns the file extension or `bin` if the content type is not recognized.
  */
 function getExtensionFromContentType(contentType: string): string {
   const [_, fileType] = contentType.split('/');
   return fileType.split(/[-;]/)[0] ?? 'bin';
 }
 
@@ -121,6 +121,9 @@
       if (isPlainObject(value)) {
         return [key, await storageImpl.transformInput(value)];
       }
+      if (Array.isArray(value)) {
+        return [key, await Promise.all(value.map(storageImpl.transformInput))];
+      }
       return [key, value] as KeyValuePair;
     });
     const results = await Promise.all(promises);

libs/client/src/streaming.ts

@@ -30,7 +30,7 @@
 
 type FalStreamEventType = 'message' | 'error' | 'done';
 
 type EventHandler = (event: any) => void;
 
 /**
  * The class representing a streaming response. With t
@@ -72,7 +72,7 @@
         reject(error);
       });
     });
-    this.start();
+    this.start().catch(this.handleError);
   }
 
   private start = async () => {
@@ -145,8 +145,7 @@
         this.emit(
           'error',
           new ApiError({
-            message:
-              'Event stream timed out after 15 seconds with no messages.',
+            message: `Event stream timed out after ${(timeout / 1000).toFixed(0)} seconds with no messages.`,
             status: 408,
           })
         );
@@ -163,7 +162,7 @@
     return;
   };
 
   private handleError = (error: any) => {
     const apiError =
       error instanceof ApiError
         ? error
@@ -182,7 +181,7 @@
     this.listeners.get(type)?.push(listener);
   };
 
   private emit = (type: FalStreamEventType, event: any) => {
     const listeners = this.listeners.get(type) || [];
     for (const listener of listeners) {
       listener(event);
@@ -228,7 +227,7 @@
  * @param options the request options, including the input payload.
  * @returns the `FalStream` instance.
  */
 export async function stream<Input = Record<string, any>, Output = any>(
   appId: string,
   options: StreamOptions<Input>
 ): Promise<FalStream<Input, Output>> {