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';
 
/**
 * Contact Logs API Endpoint
 * Fetches and creates contact log entries for customers
 */
export async function GET(request: NextRequest) {
  try {
    // Verify authentication
    const authData = await getStoredAuth();
    if (!authData || !authData.authenticated) {
      return NextResponse.json(
        { error: 'Authentication required' },
        { status: 401 }
      );
    }
 
    // Parse query parameters
    const { searchParams } = new URL(request.url);
    
    const customerId = searchParams.get('customerId');
    const accountId = searchParams.get('accountId');
    const limit = searchParams.get('limit') || '10';
 
    if (!customerId && !accountId) {
      return NextResponse.json(
        { error: 'customerId or accountId required' },
        { status: 400 }
      );
    }
 
    // Build BUCK API parameters
    let buckParams: Record<string, string> = {
      "3": "retailmax.elink.contactlog.list",
      "111": "101", // Filter type
      "99": Math.random().toString()
    };
 
    if (customerId) {
      buckParams["113"] = customerId;
    }
 
    try {
      const response = await fieldpineServerApi.buckApiCall(buckParams, authData.apiKey);
      
      const logs = response?.DATS || [];
      
      return NextResponse.json({ 
        success: true, 
        data: logs
      });
      
    } catch (error) {
      console.error('Contact logs API error:', error);
      return NextResponse.json(
        { error: 'Failed to fetch contact logs' },
        { status: 503 }
      );
    }
 
  } catch (error) {
    console.error('Contact logs API error:', error);
    return NextResponse.json(
      { error: 'Failed to fetch contact logs' },
      { status: 500 }
    );
  }
}
 
export async function POST(request: NextRequest) {
  try {
    // Verify authentication
    const authData = await getStoredAuth();
    if (!authData || !authData.authenticated) {
      return NextResponse.json(
        { error: 'Authentication required' },
        { status: 401 }
      );
    }
 
    const body = await request.json();
    const { customerId, accountId, message, reminder } = body;
 
    if (!customerId && !accountId) {
      return NextResponse.json(
        { error: 'customerId or accountId required' },
        { status: 400 }
      );
    }
 
    if (!message) {
      return NextResponse.json(
        { error: 'message required' },
        { status: 400 }
      );
    }
 
    // Build XML for DATI endpoint
    let xml = "<DATI>";
    xml += "<f8_s>retailmax.elink.contactlog.edit</f8_s>";
    xml += "<f111_s>customer</f111_s>";
    
    if (customerId) {
      xml += `<f113_E>${customerId}</f113_E>`;
    }
    
    xml += `<f120_s>${escapeXml(message)}</f120_s>`;
    
    if (reminder) {
      xml += `<f130_s>${escapeXml(reminder)}</f130_s>`;
    }
    
    xml += "</DATI>";
 
    try {
      const response = await fetch(`${process.env.FIELDPINE_BASE_URL}/DATI`, {
        method: 'POST',
        headers: {
          'Content-Type': 'application/xml',
          'Cookie': authData.apiKey || ''
        },
        body: xml
      });
 
      if (!response.ok) {
        throw new Error('Failed to save contact log');
      }
 
      const result = await response.json();
      
      return NextResponse.json({ 
        success: true, 
        data: result
      });
      
    } catch (error) {
      console.error('Save contact log error:', error);
      return NextResponse.json(
        { error: 'Failed to save contact log' },
        { status: 503 }
      );
    }
 
  } catch (error) {
    console.error('Contact logs POST error:', error);
    return NextResponse.json(
      { error: 'Failed to save contact log' },
      { status: 500 }
    );
  }
}
 
function escapeXml(unsafe: string): string {
  return unsafe.replace(/[<>&'"]/g, (c) => {
    switch (c) {
      case '<': return '&lt;';
      case '>': return '&gt;';
      case '&': return '&amp;';
      case "'": return '&apos;';
      case '"': return '&quot;';
      default: return c;
    }
  });
}