route.ts

Go to the documentation of this file.

import { NextRequest, NextResponse } from 'next/server';
import { fieldpineServerApi } from '@/lib/server/fieldpineApi';
import { getStoredAuth } from '@/lib/server/auth';
 
/**
 * Customer Accounts Endpoint
 * Uses Fieldpine's elink/BUCK API for account management
 */
export async function GET(request: NextRequest) {
  try {
    // Verify authentication
    const authData = await getStoredAuth();
    if (!authData || !authData.authenticated) {
      return NextResponse.json(
        { success: false, error: 'Authentication required' },
        { status: 401 }
      );
    }
 
    const { searchParams } = new URL(request.url);
    const type = searchParams.get('type') || 'list'; // list, summary, search
    const search = searchParams.get('search');
 
    try {
      let buckParams: Record<string, string> = {};
 
      if (type === 'summary') {
        // Get account summary statistics
        buckParams = {
          "3": "retailmax.elink.account.summary",
          "10": "600"
        };
      } else if (type === 'search' && search) {
        // Search accounts by name
        buckParams = {
          "3": "retailmax.elink.account.detail",
          "9": `f101,c,${encodeURIComponent(search)}`
        };
      } else {
        // List all accounts
        buckParams = {
          "3": "retailmax.elink.account.detail",
          "9": "f100,4,0",
          "10": "1003,184,1100,1105,1107"
        };
      }
 
      const response = await fieldpineServerApi.buckApiCall(buckParams, authData.apiKey);
 
      if (response?.DATS && Array.isArray(response.DATS)) {
        return NextResponse.json({ 
          success: true, 
          data: response.DATS,
          source: 'elink'
        });
      } else {
        return NextResponse.json({ 
          success: true, 
          data: [],
          source: 'elink'
        });
      }
 
    } catch (error) {
      console.error('Accounts error:', error);
      return NextResponse.json(
        { success: false, error: 'Failed to fetch accounts', source: 'elink' },
        { status: 503 }
      );
    }
 
  } catch (error) {
    console.error('Accounts API error:', error);
    return NextResponse.json(
      { success: false, error: 'Failed to fetch accounts' },
      { status: 500 }
    );
  }
}
 
export async function POST(request: NextRequest) {
  try {
    // Verify authentication
    const authData = await getStoredAuth();
    if (!authData || !authData.authenticated) {
      return NextResponse.json(
        { success: false, error: 'Authentication required' },
        { status: 401 }
      );
    }
 
    const body = await request.json();
    const { action, data } = body;
 
    try {
      let xml = '';
 
      if (action === 'create' || action === 'update') {
        // Create or update account
        xml = '<DATI><f8_s>retailmax.elink.account.edit</f8_s>';
        
        if (data.id) xml += `<f100>${data.id}</f100>`;
        if (data.name) xml += `<f101>${data.name}</f101>`;
        if (data.creditLimit !== undefined) xml += `<f103>${data.creditLimit}</f103>`;
        if (data.floorLimit !== undefined) xml += `<f105>${data.floorLimit}</f105>`;
        if (data.email) xml += `<f1100>${data.email}</f1100>`;
        if (data.receiptFormat) xml += `<f1105>${data.receiptFormat}</f1105>`;
        if (data.externalId) xml += `<f184>${data.externalId}</f184>`;
        
        xml += '</DATI>';
 
        // POST DATI XML to BUCK endpoint
        const url = `${process.env.FIELDPINE_BASE_URL || "https://iig.cwanz.online"}/GNAP/j/buck`;
        const headers: Record<string, string> = {
          'Accept': 'application/json',
          'Content-Type': 'text/xml',
          'Cookie': `FieldpineApiKey=${authData.apiKey}`
        };
 
        const apiResponse = await fetch(url, {
          method: 'POST',
          headers,
          body: xml,
        });
 
        if (!apiResponse.ok) {
          throw new Error(`Account update failed: ${apiResponse.status} ${apiResponse.statusText}`);
        }
 
        const responseData = await apiResponse.json();
 
        return NextResponse.json({
          success: true,
          data: responseData,
          source: 'elink'
        });
      }
 
      return NextResponse.json(
        { success: false, error: 'Invalid action' },
        { status: 400 }
      );
 
    } catch (error) {
      console.error('Account update error:', error);
      return NextResponse.json(
        { success: false, error: 'Failed to update account', source: 'elink' },
        { status: 503 }
      );
    }
 
  } catch (error) {
    console.error('Accounts API error:', error);
    return NextResponse.json(
      { success: false, error: 'Failed to process request' },
      { status: 500 }
    );
  }
}