Spaces:
Running
Running
File size: 2,714 Bytes
14d08f0 6815f3d 14d08f0 615d308 14d08f0 6d03b1a 14d08f0 6d03b1a 14d08f0 | 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 | // src/api.js
const configuredApiUrl = (import.meta.env.VITE_API_URL || '').trim();
const isLocalhost = typeof window !== 'undefined' && ['localhost', '127.0.0.1'].includes(window.location.hostname);
const defaultApiUrl = isLocalhost ? 'http://localhost:4000/api' : '/api';
const API_URL = (configuredApiUrl || defaultApiUrl).replace(/\/$/, '');
const getHeaders = (options = {}) => {
const headers = {
...options.headers,
};
// Add auth token if exists
const token = localStorage.getItem('token');
if (token) {
headers['Authorization'] = `Bearer ${token}`;
}
// Only add Content-Type if we're not sending FormData
if (!(options.body instanceof FormData)) {
headers['Content-Type'] = 'application/json';
}
return headers;
};
export const fetchApi = async (endpoint, options = {}) => {
try {
const url = `${API_URL}${endpoint.startsWith('/') ? endpoint : `/${endpoint}`}`;
// Default fetch options
const fetchOptions = {
...options,
headers: getHeaders(options),
};
// Stringify body if it's an object (and not FormData)
if (options.body && typeof options.body === 'object' && !(options.body instanceof FormData)) {
fetchOptions.body = JSON.stringify(options.body);
}
const response = await fetch(url, fetchOptions);
let data;
const contentType = response.headers.get("content-type");
if (contentType && contentType.indexOf("application/json") !== -1) {
data = await response.json();
} else {
data = await response.text();
}
if (!response.ok) {
const errorMessage = data?.error || data?.message || data || 'An error occurred';
throw new Error(errorMessage);
}
return data;
} catch (error) {
console.error(`API Error (${endpoint}):`, error);
throw error;
}
};
export const streamApi = async (endpoint, options = {}, onToken) => {
const url = `${API_URL}${endpoint.startsWith('/') ? endpoint : `/${endpoint}`}`;
const fetchOptions = {
...options,
headers: getHeaders(options),
};
if (options.body && typeof options.body === 'object' && !(options.body instanceof FormData)) {
fetchOptions.body = JSON.stringify(options.body);
}
const response = await fetch(url, fetchOptions);
if (!response.ok) {
const data = await response.json().catch(() => ({}));
throw new Error(data.error || 'Stream error');
}
const reader = response.body.getReader();
const decoder = new TextDecoder();
let done = false;
while (!done) {
const { value, done: doneReading } = await reader.read();
done = doneReading;
const chunkValue = decoder.decode(value);
if (chunkValue) {
onToken(chunkValue);
}
}
};
|