route.ts

Go to the documentation of this file.

/**
 * FD1 Products API Route
 * 
 * GET /api/v1/fd1/products - List products using FD1 protocol
 * 
 * Query parameters:
 * - search: Search term for product name/sku
 * - department: Filter by department
 * - sku: Filter by SKU
 * - limit: Number of results (default 100)
 * - offset: Pagination offset (default 0)
 * - fields: Comma-separated list of fields to return
 */
 
import { NextRequest, NextResponse } from 'next/server';
import { getRequestContext } from '@/lib/server/sessionUtils';
import { createFD1Client } from '@/lib/client/fd1Client';
 
export async function GET(request: NextRequest) {
  try {
    const context = await getRequestContext(request);
    
    if (!context?.session?.storeUrl) {
      return NextResponse.json(
        { success: false, error: 'Not authenticated' },
        { status: 401 }
      );
    }
 
    // Parse query parameters
    const searchParams = request.nextUrl.searchParams;
    const search = searchParams.get('search');
    const department = searchParams.get('department');
    const sku = searchParams.get('sku');
    const limit = parseInt(searchParams.get('limit') || '100', 10);
    const offset = parseInt(searchParams.get('offset') || '0', 10);
    const fieldsParam = searchParams.get('fields');
 
    // Build query filters
    const filters: Record<string, any> = {};
    if (search) filters.search = search;
    if (department) filters.department = department;
    if (sku) filters.sku = sku;
 
    // Build field selection
    let fields: Record<string, any> = {
      internal_id_n: 'pid',
      internal_guid: 'physkey',
      description: true,
      sku: true,
      barcode: true,
      price: true,
      cost: true,
      stock_level: true,
      department_id: true,
    };
 
    if (fieldsParam) {
      // Parse custom fields
      fields = {};
      fieldsParam.split(',').forEach(field => {
        fields[field.trim()] = true;
      });
    }
 
    // Create FD1 client
    const fd1Client = createFD1Client({
      baseUrl: context.session.storeUrl!,
      apiKey: context.session.apiKey,
      protocol: 'fd3',
    });
 
    // Fetch products
    const products = await fd1Client.listProducts(
      Object.keys(filters).length > 0 ? filters : undefined,
      fields,
      limit,
      offset
    );
 
    return NextResponse.json({
      success: true,
      data: products,
      count: products.length,
      limit,
      offset,
    });
 
  } catch (error) {
    console.error('FD1 products API error:', error);
    return NextResponse.json(
      {
        success: false,
        error: error instanceof Error ? error.message : 'Failed to fetch products',
      },
      { status: 500 }
    );
  }
}