File size: 2,701 Bytes
5da4770 |
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 |
import { createClient } from '@/lib/supabase/client';
import { IApiClient } from '../repositories/interfaces';
import { isFlagEnabled } from '@/lib/feature-flags';
const API_URL = process.env.NEXT_PUBLIC_BACKEND_URL || '';
export class SupabaseApiClient implements IApiClient {
private async getAuthHeaders(): Promise<Record<string, string>> {
const agentPlaygroundEnabled = await isFlagEnabled('custom_agents');
if (!agentPlaygroundEnabled) {
throw new Error('Custom agents is not enabled');
}
const supabase = createClient();
const { data: { session } } = await supabase.auth.getSession();
if (!session) {
throw new Error('You must be logged in');
}
return {
'Content-Type': 'application/json',
'Authorization': `Bearer ${session.access_token}`,
};
}
async get<T>(url: string): Promise<T> {
const headers = await this.getAuthHeaders();
const response = await fetch(`${API_URL}${url}`, {
method: 'GET',
headers,
});
if (!response.ok) {
const errorData = await response.json().catch(() => ({ message: 'Unknown error' }));
throw new Error(errorData.message || `HTTP ${response.status}: ${response.statusText}`);
}
return response.json();
}
async post<T>(url: string, data?: any): Promise<T> {
const headers = await this.getAuthHeaders();
const response = await fetch(`${API_URL}${url}`, {
method: 'POST',
headers,
body: data ? JSON.stringify(data) : undefined,
});
if (!response.ok) {
const errorData = await response.json().catch(() => ({ message: 'Unknown error' }));
throw new Error(errorData.message || `HTTP ${response.status}: ${response.statusText}`);
}
return response.json();
}
async put<T>(url: string, data?: any): Promise<T> {
const headers = await this.getAuthHeaders();
const response = await fetch(`${API_URL}${url}`, {
method: 'PUT',
headers,
body: data ? JSON.stringify(data) : undefined,
});
if (!response.ok) {
const errorData = await response.json().catch(() => ({ message: 'Unknown error' }));
throw new Error(errorData.message || `HTTP ${response.status}: ${response.statusText}`);
}
return response.json();
}
async delete(url: string): Promise<void> {
const headers = await this.getAuthHeaders();
const response = await fetch(`${API_URL}${url}`, {
method: 'DELETE',
headers,
});
if (!response.ok) {
const errorData = await response.json().catch(() => ({ message: 'Unknown error' }));
throw new Error(errorData.message || `HTTP ${response.status}: ${response.statusText}`);
}
}
} |