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';
 
export async function GET(
  request: NextRequest,
  { params }: { params: Promise<{ id: string }> }
) {
  try {
    const customerId = parseInt(await params.then(p => p.id), 10);
    if (isNaN(customerId)) {
      return NextResponse.json(
        { success: false, error: 'Invalid customer ID' },
        { status: 400 }
      );
    }
 
    const auth = await getStoredAuth();
    if (!auth?.authenticated) {
      return NextResponse.json(
        { success: false, error: 'Not authenticated' },
        { status: 401 }
      );
    }
 
    const customer = await fieldpineServerApi.getCustomerById(customerId);
    
    if (!customer) {
      return NextResponse.json(
        { success: false, error: 'Customer not found' },
        { status: 404 }
      );
    }
 
    return NextResponse.json({
      success: true,
      data: customer,
    });
  } catch (error: any) {
    console.error('Error fetching customer:', error);
    return NextResponse.json(
      { success: false, error: error.message || 'Failed to fetch customer' },
      { status: 500 }
    );
  }
}
 
export async function PUT(
  request: NextRequest,
  { params }: { params: Promise<{ id: string }> }
) {
  try {
    const customerId = parseInt(await params.then(p => p.id), 10);
    if (isNaN(customerId)) {
      return NextResponse.json(
        { success: false, error: 'Invalid customer ID' },
        { status: 400 }
      );
    }
 
    const auth = await getStoredAuth();
    if (!auth?.authenticated) {
      return NextResponse.json(
        { success: false, error: 'Not authenticated' },
        { status: 401 }
      );
    }
 
    const body = await request.json();
    
    // Build DATI XML for customer update
    const datiFields: any = {
      f8_s: 'retailmax.elink.customers.edit',
      f11_B: 'E', // Edit operation
      f100_E: customerId.toString(),
    };
 
    // Map fields to Fieldpine field codes
    if (body.name !== undefined) datiFields.f101_s = body.name;
    if (body.company !== undefined) datiFields.f154_s = body.company;
    if (body.phone !== undefined) datiFields.f111_s = body.phone;
    if (body.phone2 !== undefined) datiFields.f112_s = body.phone2;
    if (body.mobile !== undefined) datiFields.f149_s = body.mobile;
    if (body.email !== undefined) datiFields.f150_s = body.email;
    if (body.division !== undefined) datiFields.f13_s = body.division;
 
    // Build XML
    const xmlLines = ['<DATI>'];
    for (const [key, value] of Object.entries(datiFields)) {
      xmlLines.push(`  <${key}>${escapeXml(value as string)}</${key}>`);
    }
    xmlLines.push('</DATI>');
    const xml = xmlLines.join('\n');
 
    console.log('Updating customer with XML:', xml);
 
    // Send DATI request to Fieldpine
    const response = await fieldpineServerApi.datiApiCall(xml);
 
    if (response.success) {
      return NextResponse.json({
        success: true,
        data: response.data,
        message: 'Customer updated successfully',
      });
    } else {
      return NextResponse.json(
        { success: false, error: response.error || 'Update failed' },
        { status: 500 }
      );
    }
  } catch (error: any) {
    console.error('Error updating customer:', error);
    return NextResponse.json(
      { success: false, error: error.message || 'Failed to update customer' },
      { status: 500 }
    );
  }
}
 
// Helper function to escape XML special characters
function escapeXml(str: string): string {
  if (!str) return '';
  return str
    .replace(/&/g, '&amp;')
    .replace(/</g, '&lt;')
    .replace(/>/g, '&gt;')
    .replace(/"/g, '&quot;')
    .replace(/'/g, '&apos;');
}