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';
 
/**
 * GET /api/v1/elink/sales/[id]
 * Fetch detailed sale information including line items, payments, and location
 */
export async function GET(
  request: NextRequest,
  { params }: { params: Promise<{ id: string }> }
) {
  try {
    const context = await getRequestContext(request);
    if (!context?.session) {
      return NextResponse.json(
        { success: false, error: 'Not authenticated' },
        { status: 401 }
      );
    }
 
    const { id: saleId } = await params;
    console.log(`[Sale Fetch] Fetching sale details for ID: ${saleId}`);
 
    // Use BUCK API to fetch full sale details
    // retailmax.elink.sale.fetch with 100=1 returns full details including LINE, PAYM, LOCN
    const buckParams: Record<string, string> = {
      '3': 'retailmax.elink.sale.fetch',
      '100': '1', // Include all sub-records
      '9': `f100,0,${saleId}` // Filter by sale ID
    };
 
    const result = await fieldpineServerApi.buckApiCall(buckParams, context.session.apiKey);
 
    if (!result) {
      return NextResponse.json(
        { success: false, error: 'Sale not found' },
        { status: 404 }
      );
    }
 
    console.log(`[Sale Fetch] Successfully fetched sale ${saleId}`);
    
    return NextResponse.json({
      success: true,
      data: result
    });
 
  } catch (error) {
    console.error('[Sale Fetch] Error:', error);
    return NextResponse.json(
      { 
        success: false, 
        error: error instanceof Error ? error.message : 'Failed to fetch sale details'
      },
      { status: 500 }
    );
  }
}
 
/**
 * DELETE /api/v1/elink/sales/[id]
 * Void/delete a sale by setting phase to 10002
 */
export async function DELETE(
  request: NextRequest,
  { params }: { params: Promise<{ id: string }> }
) {
  try {
    const context = await getRequestContext(request);
    if (!context?.session) {
      return NextResponse.json(
        { success: false, error: 'Not authenticated' },
        { status: 401 }
      );
    }
 
    const { id: saleId } = await params;
    console.log(`[Sale Delete] Voiding sale ID: ${saleId}`);
 
    // First, parse the delete command (dry run)
    const parseUrl = `${context.session.storeUrl}/OpenApi2/Sales/Edit/Parse?saleid=${saleId}&ref=${Date.now()}`;
    const parseResponse = await fetch(parseUrl, {
      method: 'POST',
      headers: {
        'Authorization': `Bearer ${context.session.apiKey}`,
        'Content-Type': 'text/plain'
      },
      body: 'delete sale\n'
    });
 
    if (!parseResponse.ok) {
      throw new Error(`Parse failed: ${parseResponse.status} ${parseResponse.statusText}`);
    }
 
    const parseResult = await parseResponse.json();
    console.log('[Sale Delete] Parse result:', parseResult);
 
    // If parse was successful, execute the actual delete
    const editUrl = `${context.session.storeUrl}/OpenApi2/Sales/Edit?saleid=${saleId}&ref=${Date.now()}`;
    const editResponse = await fetch(editUrl, {
      method: 'POST',
      headers: {
        'Authorization': `Bearer ${context.session.apiKey}`,
        'Content-Type': 'text/plain'
      },
      body: 'delete sale\n'
    });
 
    if (!editResponse.ok) {
      throw new Error(`Delete failed: ${editResponse.status} ${editResponse.statusText}`);
    }
 
    const editResult = await editResponse.json();
    console.log('[Sale Delete] Edit result:', editResult);
 
    if (editResult.data?.Status?.includes('Changes applied')) {
      return NextResponse.json({
        success: true,
        message: 'Sale voided successfully',
        data: editResult.data
      });
    } else {
      return NextResponse.json(
        { 
          success: false, 
          error: 'Failed to void sale',
          details: editResult
        },
        { status: 500 }
      );
    }
 
  } catch (error) {
    console.error('[Sale Delete] Error:', error);
    return NextResponse.json(
      { 
        success: false, 
        error: error instanceof Error ? error.message : 'Failed to void sale'
      },
      { status: 500 }
    );
  }
}
 
/**
 * PUT /api/v1/elink/sales/[id]
 * Update sale details (placeholder for future implementation)
 */
export async function PUT(
  request: NextRequest,
  { params }: { params: Promise<{ id: string }> }
) {
  return NextResponse.json(
    { success: false, error: 'Sale updates not yet implemented' },
    { status: 501 }
  );
}