Method send

packages/core/src/common/request.ts:44–80

({endpoint, ...options}: SendOptions)

	}

	private async send<T>({endpoint, ...options}: SendOptions): Promise<T> {
		const url = this.buildUrl({endpoint});
		const headers = this.buildHeaders({headers: options.headers});

		let response: Response;
		try {
			response = await this.makeRequest({
				url,
				options: {...options, endpoint},
				headers,
			});
		} catch (error) {
			throw new APIConnectionError({
				cause: error instanceof Error ? error : undefined,
			});
		}

		if (!response.ok) {
			await this.handleErrorResponse({response});
		}

		const threadId = response.headers.get('lb-thread-id');

		if (options.body?.stream) {
			return handleResponseStream({
				response,
				rawResponse: options.body.rawResponse,
			}) as T;
		}

		return this.handleRunResponse({
			response,
			isChat: options.body?.chat,
			threadId,
			rawResponse: options.body?.rawResponse ?? false,
		});
	}

	private buildUrl({endpoint}: {endpoint: string}): string {
		return `${this.config.baseUrl}${endpoint}`;