Function fetchSource

frontend/src/api/sources.ts:38–71

(sourceId: string)

}

export async function fetchSource(sourceId: string): Promise<DataSource> {
  try {
    // Validate sourceId to prevent path traversal attacks
    if (!sourceId || sourceId.trim() === '') {
      throw new ApiError('Source ID cannot be empty', 400);
    }
    if (sourceId.includes('/') || sourceId.includes('..')) {
      throw new ApiError('Invalid source ID format', 400);
    }

    const response = await fetch(`${API_BASE}/sources/${encodeURIComponent(sourceId)}`);

    if (!response.ok) {
      const errorMessage = await parseJsonResponse<{ error: string }>(response)
        .then((data) => data.error)
        .catch(() => response.statusText);

      throw new ApiError(
        response.status === 404 ? `Source not found: ${sourceId}` : `Failed to fetch source: ${errorMessage}`,
        response.status,
        response.statusText
      );
    }

    return response.json();
  } catch (err) {
    // Ensure all errors are ApiError instances
    if (err instanceof ApiError) {
      throw err;
    }
    // Network errors, timeout, etc.
    throw new ApiError(err instanceof Error ? err.message : 'Network error', 0);
  }
}