How to Integrate Bolt.new with Magento

1// lib/magento.ts
2const BASE_URL = `${process.env.MAGENTO_BASE_URL}/rest/V1`;
3
4interface MagentoRequestOptions {
5  method?: 'GET' | 'POST' | 'PUT' | 'DELETE';
6  body?: unknown;
7  params?: Record<string, string>;
8}
9
10export async function magentoApi<T>(
11  path: string,
12  options: MagentoRequestOptions = {}
13): Promise<T> {
14  const url = new URL(`${BASE_URL}${path}`);
15  if (options.params) {
16    Object.entries(options.params).forEach(([key, value]) => {
17      url.searchParams.set(key, value);
18    });
19  }
20
21  const response = await fetch(url.toString(), {
22    method: options.method ?? 'GET',
23    headers: {
24      Authorization: `Bearer ${process.env.MAGENTO_ACCESS_TOKEN}`,
25      'Content-Type': 'application/json',
26      Accept: 'application/json',
27    },
28    body: options.body ? JSON.stringify(options.body) : undefined,
29  });
30
31  if (!response.ok) {
32    const errorBody = await response.text();
33    throw new Error(`Magento API ${response.status}: ${errorBody}`);
34  }
35
36  return response.json() as Promise<T>;
37}

1// app/api/products/route.ts
2import { NextRequest, NextResponse } from 'next/server';
3import { magentoApi } from '@/lib/magento';
4
5interface MagentoProduct {
6  id: number;
7  sku: string;
8  name: string;
9  price: number;
10  status: number;
11  visibility: number;
12  media_gallery_entries?: Array<{ file: string; types: string[]; position: number }>;
13  custom_attributes?: Array<{ attribute_code: string; value: string }>;
14}
15
16interface MagentoProductsResponse {
17  items: MagentoProduct[];
18  total_count: number;
19}
20
21export async function GET(request: NextRequest) {
22  const page = request.nextUrl.searchParams.get('page') ?? '1';
23
24  try {
25    const data = await magentoApi<MagentoProductsResponse>('/products', {
26      params: {
27        'searchCriteria[filterGroups][0][filters][0][field]': 'status',
28        'searchCriteria[filterGroups][0][filters][0][value]': '1',
29        'searchCriteria[filterGroups][0][filters][0][conditionType]': 'eq',
30        'searchCriteria[filterGroups][1][filters][0][field]': 'visibility',
31        'searchCriteria[filterGroups][1][filters][0][value]': '2,3,4',
32        'searchCriteria[filterGroups][1][filters][0][conditionType]': 'in',
33        'searchCriteria[pageSize]': '24',
34        'searchCriteria[currentPage]': page,
35        'searchCriteria[sortOrders][0][field]': 'created_at',
36        'searchCriteria[sortOrders][0][direction]': 'DESC',
37      },
38    });
39
40    const baseUrl = process.env.MAGENTO_BASE_URL;
41    const products = data.items.map((p) => {
42      const mainImage = p.media_gallery_entries?.find((img) => img.types.includes('image'));
43      const specialPrice = p.custom_attributes?.find((a) => a.attribute_code === 'special_price')?.value;
44      return {
45        id: p.id,
46        sku: p.sku,
47        name: p.name,
48        price: p.price,
49        salePrice: specialPrice ? parseFloat(specialPrice) : null,
50        image: mainImage ? `${baseUrl}/pub/media/catalog/product${mainImage.file}` : null,
51      };
52    });
53
54    return NextResponse.json({ products, total: data.total_count });
55  } catch (error) {
56    return NextResponse.json({ error: 'Failed to fetch products' }, { status: 500 });
57  }
58}

1// app/api/cart/route.ts
2import { NextRequest, NextResponse } from 'next/server';
3import { magentoApi } from '@/lib/magento';
4
5interface CartItem {
6  sku: string;
7  qty: number;
8  quote_id: string;
9}
10
11export async function GET(request: NextRequest) {
12  const quoteId = request.nextUrl.searchParams.get('quoteId');
13  if (!quoteId) return NextResponse.json({ error: 'quoteId required' }, { status: 400 });
14
15  const cart = await magentoApi(`/guest-carts/${quoteId}`);
16  return NextResponse.json(cart);
17}
18
19export async function POST(request: NextRequest) {
20  const body = await request.json();
21
22  if (body.action === 'create') {
23    const quoteId = await magentoApi<string>('/guest-carts', { method: 'POST' });
24    return NextResponse.json({ quoteId });
25  }
26
27  if (body.action === 'add') {
28    const { quoteId, sku, qty } = body;
29    const item = await magentoApi(`/guest-carts/${quoteId}/items`, {
30      method: 'POST',
31      body: { cartItem: { sku, qty, quote_id: quoteId } as CartItem },
32    });
33    return NextResponse.json(item);
34  }
35
36  return NextResponse.json({ error: 'Invalid action' }, { status: 400 });
37}

1// app/api/orders/recent/route.ts
2import { NextResponse } from 'next/server';
3import { magentoApi } from '@/lib/magento';
4
5interface MagentoOrder {
6  entity_id: number;
7  increment_id: string;
8  customer_email: string;
9  grand_total: number;
10  status: string;
11  created_at: string;
12}
13
14interface MagentoOrdersResponse {
15  items: MagentoOrder[];
16  total_count: number;
17}
18
19export async function GET() {
20  const yesterday = new Date();
21  yesterday.setDate(yesterday.getDate() - 1);
22  const fromDate = yesterday.toISOString().split('T')[0]; // YYYY-MM-DD
23
24  try {
25    const data = await magentoApi<MagentoOrdersResponse>('/orders', {
26      params: {
27        'searchCriteria[filterGroups][0][filters][0][field]': 'created_at',
28        'searchCriteria[filterGroups][0][filters][0][value]': fromDate,
29        'searchCriteria[filterGroups][0][filters][0][conditionType]': 'gteq',
30        'searchCriteria[sortOrders][0][field]': 'created_at',
31        'searchCriteria[sortOrders][0][direction]': 'DESC',
32        'searchCriteria[pageSize]': '20',
33        'fields': 'items[entity_id,increment_id,customer_email,grand_total,status,created_at],total_count',
34      },
35    });
36
37    return NextResponse.json({ orders: data.items, total: data.total_count });
38  } catch (error) {
39    return NextResponse.json({ error: 'Failed to fetch orders' }, { status: 500 });
40  }
41}