93 lines
2.9 KiB
TypeScript
93 lines
2.9 KiB
TypeScript
import { createDirectus, rest, authentication, readItems } from '@directus/sdk';
|
|
import { config } from './config';
|
|
|
|
const { url, adminEmail, password, token, proxyPath } = config.directus;
|
|
|
|
const client = createDirectus(url)
|
|
.with(rest())
|
|
.with(authentication());
|
|
|
|
export async function ensureAuthenticated() {
|
|
if (token) {
|
|
client.setToken(token);
|
|
return;
|
|
}
|
|
if (adminEmail && password) {
|
|
try {
|
|
await client.login(adminEmail, password);
|
|
} catch (e) {
|
|
console.error("Failed to authenticate with Directus:", e);
|
|
}
|
|
}
|
|
}
|
|
|
|
/**
|
|
* Maps the new translation-based schema back to the application's Product interface
|
|
*/
|
|
function mapDirectusProduct(item: any, locale: string): any {
|
|
const langCode = locale === 'en' ? 'en-US' : 'de-DE';
|
|
const translation = item.translations?.find((t: any) => t.languages_code === langCode) || item.translations?.[0] || {};
|
|
|
|
return {
|
|
id: item.id,
|
|
sku: item.sku,
|
|
title: translation.name || '',
|
|
description: translation.description || '',
|
|
content: translation.content || '',
|
|
technicalData: {
|
|
technicalItems: translation.technical_items || [],
|
|
voltageTables: translation.voltage_tables || []
|
|
},
|
|
locale: locale,
|
|
// Use proxy URL for assets to avoid CORS and handle internal/external issues
|
|
data_sheet_url: item.data_sheet ? `${proxyPath}/assets/${item.data_sheet}` : null,
|
|
categories: (item.categories_link || []).map((c: any) => c.categories_id?.translations?.[0]?.name).filter(Boolean)
|
|
};
|
|
}
|
|
|
|
export async function getProducts(locale: string = 'de') {
|
|
await ensureAuthenticated();
|
|
try {
|
|
const items = await client.request(readItems('products', {
|
|
fields: [
|
|
'*',
|
|
'translations.*',
|
|
'categories_link.categories_id.translations.name'
|
|
]
|
|
}));
|
|
return items.map(item => mapDirectusProduct(item, locale));
|
|
} catch (error) {
|
|
console.error('Error fetching products:', error);
|
|
return [];
|
|
}
|
|
}
|
|
|
|
export async function getProductBySlug(slug: string, locale: string = 'de') {
|
|
await ensureAuthenticated();
|
|
const langCode = locale === 'en' ? 'en-US' : 'de-DE';
|
|
try {
|
|
const items = await client.request(readItems('products', {
|
|
filter: {
|
|
translations: {
|
|
slug: { _eq: slug },
|
|
languages_code: { _eq: langCode }
|
|
}
|
|
},
|
|
fields: [
|
|
'*',
|
|
'translations.*',
|
|
'categories_link.categories_id.translations.name'
|
|
],
|
|
limit: 1
|
|
}));
|
|
|
|
if (!items || items.length === 0) return null;
|
|
return mapDirectusProduct(items[0], locale);
|
|
} catch (error) {
|
|
console.error(`Error fetching product ${slug}:`, error);
|
|
return null;
|
|
}
|
|
}
|
|
|
|
export default client;
|