fix(client): global reference when accessing fetch

libs/client/package.json

@@ -1,7 +1,7 @@
 {
   "name": "@fal-ai/serverless-client",
   "description": "The fal serverless JS/TS client",
-  "version": "0.14.1-alpha.0",
+  "version": "0.14.1-alpha.3",
   "license": "MIT",
   "repository": {
     "type": "git",

libs/client/src/config.ts

@@ -8,6 +8,17 @@
 
 export type CredentialsResolver = () => string | undefined;
 
+type FetchType = typeof fetch;
+
+export function resolveDefaultFetch(): FetchType {
+  if (typeof fetch === 'undefined') {
+    throw new Error(
+      'Your environment does not support fetch. Please provide your own fetch implementation.'
+    );
+  }
+  return fetch;
+}
+
 export type Config = {
   /**
    * The credentials to use for the fal serverless client. When using the
@@ -41,12 +52,12 @@
    * The response handler to use for the client requests. By default it uses
    * a built-in response handler that returns the JSON response.
    */
   responseHandler?: ResponseHandler<any>;
   /**
    * The fetch implementation to use for the client requests. By default it uses
    * the global `fetch` function.
    */
-  fetch?: typeof fetch;
+  fetch?: FetchType;
 };
 
 export type RequiredConfig = Required<Config>;
@@ -94,7 +105,11 @@
  * @param config the new configuration.
  */
 export function config(config: Config) {
-  configuration = { ...DEFAULT_CONFIG, ...config } as RequiredConfig;
+  configuration = {
+    ...DEFAULT_CONFIG,
+    ...config,
+    fetch: config.fetch ?? resolveDefaultFetch(),
+  } as RequiredConfig;
   if (config.proxyUrl) {
     configuration = {
       ...configuration,
@@ -125,7 +140,10 @@
 export function getConfig(): RequiredConfig {
   if (!configuration) {
     console.info('Using default configuration for the fal client');
-    return { ...DEFAULT_CONFIG } as RequiredConfig;
+    return {
+      ...DEFAULT_CONFIG,
+      fetch: resolveDefaultFetch(),
+    } as RequiredConfig;
   }
   return configuration;
 }

libs/client/src/request.ts

@@ -7,7 +7,7 @@
   navigator?.userAgent === 'Cloudflare-Workers';
 
 type RequestOptions = {
   responseHandler?: ResponseHandler<any>;
 };
 
 export async function dispatchRequest<Input, Output>(
@@ -20,7 +20,7 @@
     credentials: credentialsValue,
     requestMiddleware,
     responseHandler,
-    fetch = global.fetch,
+    fetch,
   } = getConfig();
   const userAgent = isBrowser() ? {} : { 'User-Agent': getUserAgent() };
   const credentials =

libs/client/src/storage.ts

@@ -46,7 +46,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';
 }
 
@@ -76,7 +76,7 @@
 
 export const storageImpl: StorageSupport = {
   upload: async (file: Blob) => {
-    const { fetch = global.fetch } = getConfig();
+    const { fetch } = getConfig();
     const { upload_url: uploadUrl, file_url: url } = await initiateUpload(file);
     const response = await fetch(uploadUrl, {
       method: 'PUT',
@@ -97,7 +97,7 @@
     } else if (input instanceof Blob) {
       return await storageImpl.upload(input);
     } else if (isPlainObject(input)) {
       const inputObject = input as Record<string, any>;
       const promises = Object.entries(inputObject).map(
         async ([key, value]): Promise<KeyValuePair> => {
           return [key, await storageImpl.transformInput(value)];

libs/client/src/streaming.ts

@@ -67,7 +67,7 @@
 
 type FalStreamEventType = 'data' | 'error' | 'done';
 
 type EventHandler<T = any> = (event: T) => void;
 
 /**
  * The class representing a streaming response. With t
@@ -129,7 +129,7 @@
         // if we are in the browser, we need to get a temporary token
         // to authenticate the request
         const token = await getTemporaryAuthToken(endpointId);
-        const { fetch = global.fetch } = getConfig();
+        const { fetch } = getConfig();
         const parsedUrl = new URL(this.url);
         parsedUrl.searchParams.set('fal_jwt_token', token);
         const response = await fetch(parsedUrl.toString(), {
@@ -212,7 +212,7 @@
           this.emit('data', parsedData);
 
           // also emit 'message'for backwards compatibility
           this.emit('message' as any, parsedData);
         } catch (e) {
           this.emit('error', e);
         }
@@ -248,7 +248,7 @@
     return;
   };
 
   private handleError = (error: any) => {
     const apiError =
       error instanceof ApiError
         ? error
@@ -267,7 +267,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);