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';
 
/**
 * Account Customers Endpoint
 * Gets customers linked to an account
 */
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 accountId = searchParams.get('accountId');
 
    if (!accountId) {
      return NextResponse.json(
        { success: false, error: 'Account ID required' },
        { status: 400 }
      );
    }
 
    try {
      const buckParams = {
        "3": "retailmax.elink.customers",
        "9": `f132,0,${accountId}`
      };
 
      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('Account customers error:', error);
      return NextResponse.json(
        { success: false, error: 'Failed to fetch customers', source: 'elink' },
        { status: 503 }
      );
    }
 
  } catch (error) {
    console.error('Customers API error:', error);
    return NextResponse.json(
      { success: false, error: 'Failed to fetch customers' },
      { 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, customerId, accountId } = body;
 
    try {
      let xml = '<DATI><f8_s>retailmax.elink.customers.edit</f8_s>';
      
      if (action === 'link') {
        xml += `<f100>${customerId}</f100><f132>${accountId}</f132>`;
      } else if (action === 'unlink') {
        xml += `<f100>${customerId}</f100><f132>0</f132>`;
      }
      
      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(`Customer update failed: ${apiResponse.status} ${apiResponse.statusText}`);
      }
 
      const responseData = await apiResponse.json();
 
      return NextResponse.json({
        success: true,
        data: responseData,
        source: 'elink'
      });
 
    } catch (error) {
      console.error('Customer link/unlink error:', error);
      return NextResponse.json(
        { success: false, error: 'Failed to update customer link', source: 'elink' },
        { status: 503 }
      );
    }
 
  } catch (error) {
    console.error('Customers API error:', error);
    return NextResponse.json(
      { success: false, error: 'Failed to process request' },
      { status: 500 }
    );
  }
}