Add eventsource polyfill for Node.js and browser environments

.changeset/red-colts-burn.md

@@ -0,0 +1,7 @@
+---
+"@gradio/app": patch
+"@gradio/client": patch
+"gradio": patch
+---
+
+fix:Add eventsource polyfill for Node.js and browser environments

.changeset/ripe-shirts-grow.md

@@ -0,0 +1,7 @@
+---
+"@gradio/app": minor
+"@gradio/client": minor
+"gradio": minor
+---
+
+feat:Implement JS Client tests

client/js/package.json

@@ -13,7 +13,10 @@
 		"./package.json": "./package.json"
 	},
 	"dependencies": {
+		"@types/eventsource": "^1.1.15",
 		"bufferutil": "^4.0.7",
+		"eventsource": "^2.0.2",
+		"msw": "^2.2.1",
 		"semiver": "^1.1.0",
 		"typescript": "^5.0.0",
 		"ws": "^8.13.0"

client/js/src/client.ts

@@ -27,13 +27,24 @@ import {
 } from "./helpers/init_helpers";
 import { check_space_status } from "./helpers/spaces";
 import { open_stream } from "./utils/stream";
+import { API_INFO_ERROR_MSG, CONFIG_ERROR_MSG } from "./constants";
 
 export class NodeBlob extends Blob {
 	constructor(blobParts?: BlobPart[], options?: BlobPropertyBag) {
 		super(blobParts, options);
 	}
 }
 
+if (typeof window === "undefined") {
+	import("eventsource")
+		.then((EventSourceModule) => {
+			global.EventSource = EventSourceModule.default as any;
+		})
+		.catch((error) =>
+			console.error("Failed to load EventSource module:", error)
+		);
+}
+
 export class Client {
 	app_reference: string;
 	options: ClientOptions;
@@ -61,10 +72,12 @@ export class Client {
 	}
 
 	eventSource_factory(url: URL): EventSource | null {
-		if (typeof window !== undefined && typeof EventSource !== "undefined") {
+		if (typeof window !== "undefined" && "EventSource" in window) {
 			return new EventSource(url.toString());
+		} else if (typeof global !== "undefined" && global.EventSource) {
+			return new global.EventSource(url.toString());
 		}
-		return null; // todo: polyfill eventsource for node envs
+		return null;
 	}
 
 	view_api: () => Promise<ApiInfo<JsApiData>>;
@@ -95,7 +108,7 @@ export class Client {
 		event_data?: unknown
 	) => Promise<unknown>;
 	open_stream: () => void;
-	resolve_config: (endpoint: string) => Promise<Config | undefined>;
+	private resolve_config: (endpoint: string) => Promise<Config | undefined>;
 	constructor(app_reference: string, options: ClientOptions = {}) {
 		this.app_reference = app_reference;
 		this.options = options;
@@ -142,7 +155,7 @@ export class Client {
 				}
 			});
 		} catch (e) {
-			throw Error(`Could not resolve config: ${e}`);
+			throw Error(CONFIG_ERROR_MSG + (e as Error).message);
 		}
 
 		this.api_info = await this.view_api();
@@ -182,7 +195,7 @@ export class Client {
 			config = await this.resolve_config(`${http_protocol}//${host}`);
 
 			if (!config) {
-				throw new Error("Could not resolve app config");
+				throw new Error(CONFIG_ERROR_MSG);
 			}
 
 			return this.config_success(config);
@@ -224,7 +237,7 @@ export class Client {
 		try {
 			this.api_info = await this.view_api();
 		} catch (e) {
-			console.error(`Could not get API details: ${(e as Error).message}`);
+			console.error(API_INFO_ERROR_MSG + (e as Error).message);
 		}
 
 		return this.prepare_return_obj();
@@ -237,7 +250,7 @@ export class Client {
 			try {
 				this.config = await this._resolve_config();
 				if (!this.config) {
-					throw new Error("Could not resolve app config");
+					throw new Error(CONFIG_ERROR_MSG);
 				}
 
 				const _config = await this.config_success(this.config);
@@ -263,7 +276,7 @@ export class Client {
 		data: unknown[] | { binary: boolean; data: Record<string, any> }
 	): Promise<unknown> {
 		if (!this.config) {
-			throw new Error("Could not resolve app config");
+			throw new Error(CONFIG_ERROR_MSG);
 		}
 
 		const headers: {
@@ -363,4 +376,19 @@ export async function client(
 	return await Client.connect(app_reference, options);
 }
 
+/**
+ * @deprecated This method will be removed in v1.0. Use `Client.duplicate()` instead.
+ * Creates a duplicate of a space and returns a client instance for the duplicated space.
+ *
+ * @param {string} app_reference - The reference or URL to a Gradio space or app to duplicate.
+ * @param {DuplicateOptions} options - Configuration options for the client.
+ * @returns {Promise<Client>} A promise that resolves to a `Client` instance.
+ */
+export async function duplicate_space(
+	app_reference: string,
+	options: DuplicateOptions
+): Promise<Client> {
+	return await Client.duplicate(app_reference, options);
+}
+
 export type ClientInstance = Client;

client/js/src/constants.ts

@@ -9,12 +9,19 @@ export const UPLOAD_URL = "upload";
 export const LOGIN_URL = "login";
 export const CONFIG_URL = "config";
 export const API_INFO_URL = "info";
+export const RUNTIME_URL = "runtime";
+export const SLEEPTIME_URL = "sleeptime";
 export const RAW_API_INFO_URL = "info?serialize=False";
 export const SPACE_FETCHER_URL =
 	"https://gradio-space-api-fetcher-v2.hf.space/api";
 export const RESET_URL = "reset";
 export const SPACE_URL = "https://hf.space/{}";
 
 // messages
-export const QUEUE_FULL_MSG = "This application is too busy. Keep trying!";
-export const BROKEN_CONNECTION_MSG = "Connection errored out.";
+export const QUEUE_FULL_MSG =
+	"This application is currently busy. Please try again. ";
+export const BROKEN_CONNECTION_MSG = "Connection errored out. ";
+export const CONFIG_ERROR_MSG = "Could not resolve app config. ";
+export const SPACE_STATUS_ERROR_MSG = "Could not get space status. ";
+export const API_INFO_ERROR_MSG = "Could not get API info. ";
+export const SPACE_METADATA_ERROR_MSG = "Space metadata could not be loaded. ";

client/js/src/helpers/api_info.ts

@@ -29,16 +29,16 @@ export async function process_endpoint(
 				{ headers }
 			);
 
-			if (res.status !== 200)
-				throw new Error("Space metadata could not be loaded.");
 			const _host = (await res.json()).host;
 
 			return {
 				space_id: app_reference,
 				...determine_protocol(_host)
 			};
-		} catch (e: any) {
-			throw new Error("Space metadata could not be loaded." + e.message);
+		} catch (e) {
+			throw new Error(
+				"Space metadata could not be loaded. " + (e as Error).message
+			);
 		}
 	}
 

client/js/src/helpers/data.ts

@@ -5,7 +5,7 @@ import type {
 	Config,
 	EndpointInfo,
 	JsApiData,
-	ParamType
+	DataType
 } from "../types";
 
 export function update_object(
@@ -31,22 +31,22 @@ export function update_object(
 }
 
 export async function walk_and_store_blobs(
-	param: ParamType,
+	data: DataType,
 	type: string | undefined = undefined,
 	path: string[] = [],
 	root = false,
 	endpoint_info: EndpointInfo<ApiData | JsApiData> | undefined = undefined
 ): Promise<BlobRef[]> {
-	if (Array.isArray(param)) {
+	if (Array.isArray(data)) {
 		let blob_refs: BlobRef[] = [];
 
 		await Promise.all(
-			param.map(async (item) => {
+			data.map(async (item) => {
 				let new_path = path.slice();
 				new_path.push(item);
 
 				const array_refs = await walk_and_store_blobs(
-					param[item],
+					data[item],
 					root ? endpoint_info?.parameters[item]?.component || undefined : type,
 					new_path,
 					false,
@@ -58,44 +58,62 @@ export async function walk_and_store_blobs(
 		);
 
 		return blob_refs;
-	} else if (globalThis.Buffer && param instanceof globalThis.Buffer) {
+	} else if (
+		(globalThis.Buffer && data instanceof globalThis.Buffer) ||
+		data instanceof Blob
+	) {
 		const is_image = type === "Image";
 		return [
 			{
 				path: path,
-				blob: is_image ? false : new NodeBlob([param]),
+				blob: is_image ? false : new NodeBlob([data]),
 				type
 			}
 		];
-	} else if (typeof param === "object") {
+	} else if (typeof data === "object" && data !== null) {
 		let blob_refs: BlobRef[] = [];
-		for (let key in param) {
-			if (param.hasOwnProperty(key)) {
-				let new_path = path.slice();
-				new_path.push(key);
-				blob_refs = blob_refs.concat(
-					await walk_and_store_blobs(
-						// @ts-ignore
-						param[key],
-						undefined,
-						new_path,
-						false,
-						endpoint_info
-					)
-				);
-			}
+		for (const key of Object.keys(data) as (keyof typeof data)[]) {
+			const new_path = [...path, key];
+			const value = data[key];
+
+			blob_refs = blob_refs.concat(
+				await walk_and_store_blobs(
+					value,
+					undefined,
+					new_path,
+					false,
+					endpoint_info
+				)
+			);
+		}
+
+		if (
+			!blob_refs.length &&
+			!(
+				data instanceof Blob ||
+				data instanceof ArrayBuffer ||
+				data instanceof Uint8Array
+			)
+		) {
+			return [
+				{
+					path: path,
+					blob: new NodeBlob([JSON.stringify(data)]),
+					type: typeof data
+				}
+			];
 		}
 		return blob_refs;
 	}
+
 	return [];
 }
 
 export function skip_queue(id: number, config: Config): boolean {
-	return (
-		!(config?.dependencies?.[id]?.queue === null
-			? config.enable_queue
-			: config?.dependencies?.[id]?.queue) || false
-	);
+	if (config?.dependencies?.[id]?.queue !== null) {
+		return !config.dependencies[id].queue;
+	}
+	return !config.enable_queue;
 }
 
 // todo: add jsdoc for this function

client/js/src/helpers/init_helpers.ts

@@ -1,5 +1,5 @@
 import type { Config } from "../types";
-import { CONFIG_URL } from "../constants";
+import { CONFIG_ERROR_MSG, CONFIG_URL } from "../constants";
 import { Client } from "..";
 
 /**
@@ -38,7 +38,6 @@ export async function get_jwt(
 
 		return jwt || false;
 	} catch (e) {
-		console.error(e);
 		return false;
 	}
 }
@@ -89,10 +88,10 @@ export async function resolve_config(
 			config.root = endpoint;
 			return config;
 		}
-		throw new Error("Could not get config.");
+		throw new Error(CONFIG_ERROR_MSG);
 	}
 
-	throw new Error("No config or app endpoint found");
+	throw new Error(CONFIG_ERROR_MSG);
 }
 
 export function determine_protocol(endpoint: string): {

client/js/src/helpers/spaces.ts

@@ -1,3 +1,8 @@
+import {
+	RUNTIME_URL,
+	SLEEPTIME_URL,
+	SPACE_STATUS_ERROR_MSG
+} from "../constants";
 import type { SpaceStatusCallback } from "../types";
 
 export async function check_space_status(
@@ -22,7 +27,7 @@ export async function check_space_status(
 		status_callback({
 			status: "error",
 			load_status: "error",
-			message: "Could not get space status",
+			message: SPACE_STATUS_ERROR_MSG,
 			detail: "NOT_FOUND"
 		});
 		return;
@@ -121,7 +126,7 @@ export async function get_space_hardware(
 
 	try {
 		const res = await fetch(
-			`https://huggingface.co/api/spaces/${space_id}/runtime`,
+			`https://huggingface.co/api/spaces/${space_id}/${RUNTIME_URL}`,
 			{ headers }
 		);
 
@@ -154,7 +159,7 @@ export async function set_space_timeout(
 
 	try {
 		const res = await fetch(
-			`https://huggingface.co/api/spaces/${space_id}/sleeptime`,
+			`https://huggingface.co/api/spaces/${space_id}/${SLEEPTIME_URL}`,
 			{
 				method: "POST",
 				headers: { "Content-Type": "application/json", ...headers },

client/js/src/index.ts

@@ -14,4 +14,4 @@ export type {
 
 // todo: remove in @gradio/client v1.0
 export { client } from "./client";
-export { duplicate } from "./utils/duplicate";
+export { duplicate_space as duplicate } from "./client";