app/src/services/apiClient.ts - main - GreyCat/openhuman

app/src/services/apiClient.ts
188 строк5 KB
YellowSnnowmann
feat(agent_meetings): wire mascotId through full stack + fix tests (#3363)
05 июн 2026, 17:15
05 июн 2026, 17:15b3be665
import type { ApiError } from '../types/api';
import { IS_DEV } from '../utils/config';
import { getBackendUrl } from './backendUrl';
import { getClientVersionHeaders } from './clientVersionHeaders';

type HttpMethod = 'GET' | 'POST' | 'PUT' | 'PATCH' | 'DELETE';

interface RequestOptions {
  method?: HttpMethod;
  body?: unknown;
  headers?: Record<string, string>;
  requireAuth?: boolean;
  timeout?: number;
}

/**
 * Lazy auth token accessor so `apiClient` never imports `store/index` at module level.
 * Entry (`main.tsx`) and Vitest setup call `setStoreForApiClient` after the store module loads,
 * avoiding a cycle: `store` → `apiClient` → … → `socketService` → `store`.
 *
 * The binding name avoids clashing with transpiled private method names (e.g. `_getToken`).
 */
let authTokenGetterRef: (() => string | null) | null = null;

export function setStoreForApiClient(getToken: () => string | null) {
  authTokenGetterRef = getToken;
}

/**
 * API Client for making requests to the backend
 * Handles authentication, error handling, and response typing
 */
class ApiClient {
  private resolveAuthToken(): string | null {
    return authTokenGetterRef ? authTokenGetterRef() : null;
  }

  /**
   * Build headers for the request
   */
  private async buildHeaders(options: RequestOptions): Promise<Record<string, string>> {
    const versionHeaders = await getClientVersionHeaders();
    const headers: Record<string, string> = {
      'Content-Type': 'application/json',
      // Only skip ngrok interstitials in dev (local tunnels). Never send in production.
      ...(IS_DEV ? { 'ngrok-skip-browser-warning': '1' } : {}),
      ...options.headers,
      ...versionHeaders,
    };

    // Add authorization header if auth is required
    if (options.requireAuth !== false) {
      const token = this.resolveAuthToken();
      if (token) {
        headers.Authorization = `Bearer ${token}`;
      }
    }

    return headers;
  }

  private sanitizeRequestLogHeaders(headers: HeadersInit): Record<string, string> {
    const safeHeaders = { ...(headers as Record<string, string>) };
    delete safeHeaders.Authorization;
    delete safeHeaders.authorization;
    return safeHeaders;
  }

  /**
   * Make an API request
   */
  private async request<T>(endpoint: string, options: RequestOptions = {}): Promise<T> {
    const { method = 'GET', body, requireAuth = true, timeout = 120_000 } = options;

    const baseUrl = await getBackendUrl();
    const url = `${baseUrl}${endpoint}`;
    const headers = await this.buildHeaders({ ...options, requireAuth });

    if (IS_DEV) {
      console.log('request', { url, headers: this.sanitizeRequestLogHeaders(headers), method });
    }

    const controller = new AbortController();
    const timeoutId = setTimeout(() => controller.abort(), timeout);

    const config: RequestInit = { method, headers, signal: controller.signal };

    if (body && method !== 'GET') {
      config.body = JSON.stringify(body);
    }

    try {
      const response = await fetch(url, config);

      // Handle non-JSON responses
      const contentType = response.headers.get('content-type');
      if (!contentType || !contentType.includes('application/json')) {
        if (!response.ok) {
          throw new Error(`HTTP error! status: ${response.status}`);
        }
        return {} as T;
      }

      const data = await response.json();

      // Handle error responses
      if (!response.ok) {
        const error: ApiError = data.error
          ? { success: false, error: data.error, message: data.message }
          : { success: false, error: `HTTP ${response.status}: ${response.statusText}` };
        throw error;
      }

      return data as T;
    } catch (error) {
      // Re-throw API errors as-is
      if (error && typeof error === 'object' && 'error' in error) {
        throw error;
      }

      // Handle abort/timeout specifically
      if (
        (error instanceof DOMException && error.name === 'AbortError') ||
        (error instanceof Error && error.name === 'AbortError')
      ) {
        throw { success: false, error: `Request timed out after ${timeout / 1000}s` } as ApiError;
      }

      // Wrap network/other errors
      throw {
        success: false,
        error: error instanceof Error ? error.message : 'Unknown error occurred',
      } as ApiError;
    } finally {
      clearTimeout(timeoutId);
    }
  }

  /**
   * GET request
   */
  async get<T>(endpoint: string, options?: Omit<RequestOptions, 'method' | 'body'>): Promise<T> {
    return this.request<T>(endpoint, { ...options, method: 'GET' });
  }

  /**
   * POST request
   */
  async post<T>(
    endpoint: string,
    body?: unknown,
    options?: Omit<RequestOptions, 'method' | 'body'>
  ): Promise<T> {
    return this.request<T>(endpoint, { ...options, method: 'POST', body });
  }

  /**
   * PUT request
   */
  async put<T>(
    endpoint: string,
    body?: unknown,
    options?: Omit<RequestOptions, 'method' | 'body'>
  ): Promise<T> {
    return this.request<T>(endpoint, { ...options, method: 'PUT', body });
  }

  /**
   * PATCH request
   */
  async patch<T>(
    endpoint: string,
    body?: unknown,
    options?: Omit<RequestOptions, 'method' | 'body'>
  ): Promise<T> {
    return this.request<T>(endpoint, { ...options, method: 'PATCH', body });
  }

  /**
   * DELETE request
   */
  async delete<T>(endpoint: string, options?: Omit<RequestOptions, 'method' | 'body'>): Promise<T> {
    return this.request<T>(endpoint, { ...options, method: 'DELETE' });
  }
}

// Export singleton instance
export const apiClient = new ApiClient();