feat(client): realtime state machine impl

apps/demo-nextjs-app-router/app/realtime/page.tsx

@@ -2,8 +2,8 @@
 
 /* eslint-disable @next/next/no-img-element */
 import * as fal from '@fal-ai/serverless-client';
-import { DrawingCanvas } from '../../components/drawing';
 import { useState } from 'react';
+import { DrawingCanvas } from '../../components/drawing';
 
 fal.config({
   proxyUrl: '/api/fal/proxy',
@@ -14,8 +14,9 @@ const PROMPT = 'a moon in a starry night sky';
 export default function RealtimePage() {
   const [image, setImage] = useState<string | null>(null);
 
-  const { send } = fal.realtime.connect('110602490-shared-lcm-test', {
+  const { send } = fal.realtime.connect('110602490-lcm-sd15-i2i', {
     connectionKey: 'realtime-demo',
+    throttleInterval: 128,
     onResult(result) {
       if (result.images && result.images[0]) {
         setImage(result.images[0].url);

libs/client/package.json

@@ -1,7 +1,7 @@
 {
   "name": "@fal-ai/serverless-client",
   "description": "The fal serverless JS/TS client",
-  "version": "0.6.1",
+  "version": "0.7.0",
   "license": "MIT",
   "repository": {
     "type": "git",
@@ -14,5 +14,8 @@
     "client",
     "ai",
     "ml"
-  ]
+  ],
+  "dependencies": {
+    "robot3": "^0.4.1"
+  }
 }

libs/client/src/config.ts

@@ -1,7 +1,7 @@
 import {
+  withMiddleware,
   withProxy,
   type RequestMiddleware,
-  withMiddleware,
 } from './middleware';
 import type { ResponseHandler } from './response';
 import { defaultResponseHandler } from './response';
@@ -13,7 +13,7 @@
   host?: string;
   proxyUrl?: string;
   requestMiddleware?: RequestMiddleware;
   responseHandler?: ResponseHandler<any>;
 };
 
 export type RequiredConfig = Required<Config>;

libs/client/src/function.ts

@@ -1,6 +1,6 @@
 import { getConfig } from './config';
-import { storageImpl } from './storage';
 import { dispatchRequest } from './request';
+import { storageImpl } from './storage';
 import { EnqueueResult, QueueStatus } from './types';
 import { isUUIDv4, isValidUrl } from './utils';