route.ts

Go to the documentation of this file.

import { NextRequest, NextResponse } from 'next/server';
import { fieldpineServerApi } from '@/lib/server/fieldpineApi';
import { getRequestContext } from '@/lib/server/sessionUtils';
 
/**
 * eLink/BUCK Sales Endpoint
 * Uses Fieldpine's BUCK API via eLink protocol for sales data
 * Documentation: https://docs.fieldpine.com/pos/elink.htm
 */
export async function GET(request: NextRequest) {
  try {
    // Get request context with authentication
    const context = await getRequestContext(request);
    if (!context?.session) {
      return NextResponse.json(
        { error: 'Authentication required' },
        { status: 401 }
      );
    }
 
    // Rate limiting
    const clientId = request.headers.get('x-forwarded-for') || 
                    request.headers.get('x-real-ip') || 
                    context.session.userId || 
                    'unknown';
    if (!fieldpineServerApi.checkClientRateLimit(clientId)) {
      return NextResponse.json(
        { error: 'Rate limit exceeded' },
        { status: 429 }
      );
    }
 
    // Parse query parameters
    const { searchParams } = new URL(request.url);
    const params: Record<string, string> = {};
    
    const limit = searchParams.get('limit') || searchParams.get('$top');
    if (limit) params.limit = limit;
    
    const startDate = searchParams.get('startDate');
    if (startDate) params.startDate = startDate;
    
    const endDate = searchParams.get('endDate');
    if (endDate) params.endDate = endDate;
    
    const storeId = searchParams.get('storeId');
    if (storeId) params.storeId = storeId;
 
    // Call Fieldpine BUCK API via eLink protocol
    try {
      // Use sale.list for retrieving sales/invoices
      const buckParams: Record<string, string> = {
        "3": "retailmax.elink.sale.list",
        "8": limit || '100', // Limit results
      };
      
      console.log('[ELINK Sales] BUCK params:', buckParams);
      console.log('[ELINK Sales] API Key available:', !!context.session.apiKey);
      
      // Add date filters if provided (using proper date filter format)
      // f110 = CompletedDt field
      // Filter operator: 4 = greater than or equal, 1 = less than or equal
      if (params.startDate) {
        buckParams["9"] = `f110,4,${params.startDate}`;
      }
      if (params.endDate) {
        const key = params.startDate ? "9.1" : "9";
        buckParams[key] = `f110,1,${params.endDate}`;
      }
      
      // Add store filter if provided
      if (params.storeId) {
        buckParams["7"] = params.storeId;
      }
      
      console.log('[ELINK Sales] Final BUCK params:', buckParams);
      
      const sales = await fieldpineServerApi.buckApiCall(buckParams, context.session.apiKey);
      
      console.log('[ELINK Sales] Raw response:', JSON.stringify(sales).substring(0, 200));
      
      // Extract DATS array from BUCK response
      const salesData = sales?.DATS || [];
      
      console.log(`[ELINK Sales] Loaded ${salesData.length} sales`);
      
      // Handle no sales found
      if (!salesData || salesData.length === 0) {
        console.log('[ELINK Sales] No sales records found');
        return NextResponse.json({ 
          success: true, 
          data: [],
          count: 0,
          message: 'No sales records found for the specified criteria',
          source: 'elink'
        });
      }
      
      return NextResponse.json({ 
        success: true, 
        data: salesData,
        count: salesData.length,
        source: 'elink'
      });
      
    } catch (error) {
      console.error('[ELINK Sales] Error details:', error);
      return NextResponse.json(
        { 
          success: false,
          error: 'eLink endpoint unavailable', 
          details: error instanceof Error ? error.message : String(error),
          source: 'elink' 
        },
        { status: 503 }
      );
    }
 
  } catch (error) {
    console.error('eLink sales error:', error);
    return NextResponse.json(
      { error: 'Failed to fetch sales' },
      { status: 500 }
    );
  }
}