route.ts

Go to the documentation of this file.

import { NextRequest, NextResponse } from "next/server";
import { getRequestContext, validateStoreAccess, getStoreApiUrl } from "@/lib/server/sessionUtils";
import { FieldpineServerApi } from "@/lib/server/fieldpineApi";
 
/**
 * GET /api/v1/products/stock-alerts
 * Get products with low stock levels across locations
 * Uses OpenAPI Products endpoint (store-specific)
 */
export async function GET(request: NextRequest) {
  try {
    // Get session and store context
    const context = await getRequestContext(request);
    
    if (!context) {
      return NextResponse.json(
        { success: false, error: "Unauthorized" },
        { status: 401 }
      );
    }
 
    // Validate this is a retail store (not management portal)
    const validation = validateStoreAccess(context, 'store');
    if (!validation.valid) {
      return NextResponse.json(
        { success: false, error: validation.error },
        { status: 403 }
      );
    }
 
    const searchParams = request.nextUrl.searchParams;
    const limit = parseInt(searchParams.get("limit") || "20");
    const threshold = parseInt(searchParams.get("threshold") || "5");
 
    // Get store-specific API URL for OpenAPI
    const apiUrl = getStoreApiUrl(context, 'openapi');
    const api = new FieldpineServerApi(apiUrl);
 
    // Fetch products from store's OpenAPI endpoint
    const productsResponse = await api.apiCall('/Products', {
      method: 'GET',
      params: { limit: '1000' },
      cookie: context.session.apiKey
    });
 
    const products = productsResponse?.data?.Product || [];
 
    console.log(`[Stock Alerts API] Found ${products.length} products at ${context.store.name}`);
 
    // Filter products with low stock using OpenAPI StockLevel field
    const lowStockProducts = products
      .filter((p: any) => {
        const stockLevel = p.StockLevel || 0;
        return stockLevel <= threshold && stockLevel >= 0;
      })
      .sort((a: any, b: any) => (a.StockLevel || 0) - (b.StockLevel || 0))
      .slice(0, limit)
      .map((p: any) => ({
        pid: p.pid,
        description: p.Name || p.ProductName || 'Unknown Product',
        totalQty: p.StockLevel || 0,
        locations: [] // OpenAPI doesn't provide per-location breakdown
      }));
 
    console.log(`[Stock Alerts API] Low stock products found: ${lowStockProducts.length}`);
 
    if (lowStockProducts.length === 0) {
      return NextResponse.json({
        success: true,
        data: [],
        meta: { 
          total: 0, 
          threshold,
          store: context.store.name,
          storeType: context.store.type
        },
      });
    }
 
    return NextResponse.json({
      success: true,
      data: lowStockProducts,
      meta: {
        total: lowStockProducts.length,
        threshold,
        scannedProducts: products.length,
        store: context.store.name,
        storeType: context.store.type
      },
    });
  } catch (error: any) {
    console.error("[Stock Alerts API] Error:", error);
    return NextResponse.json(
      { success: false, error: error.message || "Failed to fetch stock alerts" },
      { status: 500 }
    );
  }
}