route.ts

Go to the documentation of this file.

/**
 * FD1 Sales API Route
 * 
 * GET /api/v1/fd1/sales - List sales using FD1 protocol
 * POST /api/v1/fd1/sales - Create new sale
 * 
 * Query parameters (GET):
 * - date_from: Start date (YYYY-MM-DD)
 * - date_to: End date (YYYY-MM-DD)
 * - customer_id: Filter by customer
 * - location_id: Filter by location
 * - limit: Number of results (default 100)
 * - offset: Pagination offset (default 0)
 */
 
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 date_from = searchParams.get('date_from');
    const date_to = searchParams.get('date_to');
    const customer_id = searchParams.get('customer_id');
    const location_id = searchParams.get('location_id');
    const limit = parseInt(searchParams.get('limit') || '100', 10);
    const offset = parseInt(searchParams.get('offset') || '0', 10);
 
    // Build query filters
    const filters: Record<string, any> = {};
    if (date_from) filters.date_from = date_from;
    if (date_to) filters.date_to = date_to;
    if (customer_id) filters.customer_id = parseInt(customer_id, 10);
    if (location_id) filters.location_id = parseInt(location_id, 10);
 
    // Create FD1 client
    const fd1Client = createFD1Client({
      baseUrl: context.session.storeUrl!,
      apiKey: context.session.apiKey,
      protocol: 'fd3',
    });
 
    // Fetch sales
    const sales = await fd1Client.listSales(
      Object.keys(filters).length > 0 ? filters : undefined,
      undefined,
      limit,
      offset
    );
 
    return NextResponse.json({
      success: true,
      data: sales,
      count: sales.length,
      limit,
      offset,
    });
 
  } catch (error) {
    console.error('FD1 sales API error:', error);
    return NextResponse.json(
      {
        success: false,
        error: error instanceof Error ? error.message : 'Failed to fetch sales',
      },
      { status: 500 }
    );
  }
}
 
export async function POST(request: NextRequest) {
  try {
    const context = await getRequestContext(request);
    
    if (!context?.session?.storeUrl) {
      return NextResponse.json(
        { success: false, error: 'Not authenticated' },
        { status: 401 }
      );
    }
 
    const body = await request.json();
 
    // Validate request body
    if (!body.lines || !Array.isArray(body.lines) || body.lines.length === 0) {
      return NextResponse.json(
        { success: false, error: 'Sales must have at least one line item' },
        { status: 400 }
      );
    }
 
    // Validate line items
    for (const line of body.lines) {
      if (!line.product_id || !line.qty) {
        return NextResponse.json(
          { success: false, error: 'Each line must have product_id and qty' },
          { status: 400 }
        );
      }
    }
 
    // Create FD1 client
    const fd1Client = createFD1Client({
      baseUrl: context.session.storeUrl!,
      apiKey: context.session.apiKey,
      protocol: 'fd3',
    });
 
    // Create sale
    const sale = await fd1Client.createSale({
      lines: body.lines,
      customer_id: body.customer_id,
      location_id: body.location_id || context.session.storeId,
    });
 
    return NextResponse.json({
      success: true,
      data: sale,
    });
 
  } catch (error) {
    console.error('FD1 create sale API error:', error);
    return NextResponse.json(
      {
        success: false,
        error: error instanceof Error ? error.message : 'Failed to create sale',
      },
      { status: 500 }
    );
  }
}