MCP WooCommerce Server

import { Tool } from '@modelcontextprotocol/sdk/types.js'; import { WooCommerceService } from '../services/woocommerce.js'; import { ValidationUtils } from '../utils/validation.js'; import { Logger } from '../utils/logger.js'; import { MCPToolParams, MCPToolResult } from '../types/mcp.js'; export class CustomerTools { constructor( private wooCommerce: WooCommerceService, private logger: Logger ) {} getToolDefinitions(): any[] { return this.getTools().map(tool => ({ name: tool.name, description: tool.description, inputSchema: tool.inputSchema })); } async callTool(name: string, args: any): Promise<any> { switch (name) { case 'wc_get_customers': return this.getCustomers(args); case 'wc_get_customer': return this.getCustomer(args); case 'wc_create_customer': return this.createCustomer(args); case 'wc_update_customer': return this.updateCustomer(args); case 'wc_delete_customer': return this.deleteCustomer(args); case 'wc_batch_customers': return this.batchCustomers(args); case 'wc_get_customer_orders': return this.getCustomerOrders(args); case 'wc_get_top_customers': return this.getTopCustomers(args); case 'wc_get_customer_purchase_history': return this.getCustomerPurchaseHistory(args); case 'wc_get_promotions_active': return this.getActivePromotions(args); default: throw new Error(`Unknown customer tool: ${name}`); } } getTools(): Tool[] { return [ { name: 'wc_get_customers', description: 'Retrieve a list of customers from WooCommerce store with filtering and pagination', inputSchema: { type: 'object', properties: { page: { type: 'integer', minimum: 1, description: 'Page number (default: 1)' }, per_page: { type: 'integer', minimum: 1, maximum: 100, description: 'Customers per page (default: 10)' }, search: { type: 'string', description: 'Search in customer name, email, or username' }, exclude: { type: 'array', items: { type: 'integer', minimum: 1 }, description: 'Customer IDs to exclude' }, include: { type: 'array', items: { type: 'integer', minimum: 1 }, description: 'Customer IDs to include' }, email: { type: 'string', format: 'email', description: 'Filter by email address' }, role: { type: 'string', enum: ['all', 'administrator', 'editor', 'author', 'contributor', 'subscriber', 'customer', 'shop_manager'], description: 'Filter by user role (default: customer)' }, order: { type: 'string', enum: ['asc', 'desc'], description: 'Sort order (default: asc)' }, orderby: { type: 'string', enum: ['id', 'include', 'name', 'registered_date'], description: 'Sort by field (default: name)' } }, required: [], additionalProperties: false } }, { name: 'wc_get_customer', description: 'Get detailed information about a specific customer by ID', inputSchema: { type: 'object', properties: { id: { type: 'integer', minimum: 1, description: 'Customer ID' } }, required: ['id'], additionalProperties: false } }, { name: 'wc_create_customer', description: 'Create a new customer in the WooCommerce store', inputSchema: { type: 'object', properties: { email: { type: 'string', format: 'email', description: 'Customer email address (required)' }, first_name: { type: 'string', maxLength: 100, description: 'First name' }, last_name: { type: 'string', maxLength: 100, description: 'Last name' }, username: { type: 'string', pattern: '^[a-zA-Z0-9_]+$', minLength: 3, maxLength: 60, description: 'Username (letters, numbers, underscore only)' }, password: { type: 'string', minLength: 6, maxLength: 100, description: 'Password (min 6 characters)' }, billing: { type: 'object', properties: { first_name: { type: 'string', maxLength: 100, description: 'Billing first name' }, last_name: { type: 'string', maxLength: 100, description: 'Billing last name' }, company: { type: 'string', maxLength: 100, description: 'Billing company' }, address_1: { type: 'string', maxLength: 100, description: 'Billing address line 1' }, address_2: { type: 'string', maxLength: 100, description: 'Billing address line 2' }, city: { type: 'string', maxLength: 100, description: 'Billing city' }, state: { type: 'string', maxLength: 100, description: 'Billing state/province' }, postcode: { type: 'string', maxLength: 20, description: 'Billing postal code' }, country: { type: 'string', minLength: 2, maxLength: 2, description: 'Billing country code (ISO 3166-1 alpha-2)' }, email: { type: 'string', format: 'email', description: 'Billing email address' }, phone: { type: 'string', maxLength: 20, description: 'Billing phone number' } }, description: 'Billing address information' }, shipping: { type: 'object', properties: { first_name: { type: 'string', maxLength: 100, description: 'Shipping first name' }, last_name: { type: 'string', maxLength: 100, description: 'Shipping last name' }, company: { type: 'string', maxLength: 100, description: 'Shipping company' }, address_1: { type: 'string', maxLength: 100, description: 'Shipping address line 1' }, address_2: { type: 'string', maxLength: 100, description: 'Shipping address line 2' }, city: { type: 'string', maxLength: 100, description: 'Shipping city' }, state: { type: 'string', maxLength: 100, description: 'Shipping state/province' }, postcode: { type: 'string', maxLength: 20, description: 'Shipping postal code' }, country: { type: 'string', minLength: 2, maxLength: 2, description: 'Shipping country code (ISO 3166-1 alpha-2)' } }, description: 'Shipping address information' } }, required: ['email'] } }, { name: 'wc_update_customer', description: 'Update an existing customer in the WooCommerce store', inputSchema: { type: 'object', properties: { id: { type: 'integer', minimum: 1, description: 'Customer ID' }, email: { type: 'string', format: 'email', description: 'Customer email address' }, first_name: { type: 'string', maxLength: 100, description: 'First name' }, last_name: { type: 'string', maxLength: 100, description: 'Last name' }, username: { type: 'string', pattern: '^[a-zA-Z0-9_]+$', minLength: 3, maxLength: 60, description: 'Username' }, password: { type: 'string', minLength: 6, maxLength: 100, description: 'New password' }, billing: { type: 'object', properties: { first_name: { type: 'string', maxLength: 100 }, last_name: { type: 'string', maxLength: 100 }, company: { type: 'string', maxLength: 100 }, address_1: { type: 'string', maxLength: 100 }, address_2: { type: 'string', maxLength: 100 }, city: { type: 'string', maxLength: 100 }, state: { type: 'string', maxLength: 100 }, postcode: { type: 'string', maxLength: 20 }, country: { type: 'string', minLength: 2, maxLength: 2 }, email: { type: 'string', format: 'email' }, phone: { type: 'string', maxLength: 20 } }, description: 'Billing address information' }, shipping: { type: 'object', properties: { first_name: { type: 'string', maxLength: 100 }, last_name: { type: 'string', maxLength: 100 }, company: { type: 'string', maxLength: 100 }, address_1: { type: 'string', maxLength: 100 }, address_2: { type: 'string', maxLength: 100 }, city: { type: 'string', maxLength: 100 }, state: { type: 'string', maxLength: 100 }, postcode: { type: 'string', maxLength: 20 }, country: { type: 'string', minLength: 2, maxLength: 2 } }, description: 'Shipping address information' } }, required: ['id'] } }, { name: 'wc_delete_customer', description: 'Delete a customer from the WooCommerce store', inputSchema: { type: 'object', properties: { id: { type: 'integer', minimum: 1, description: 'Customer ID' }, force: { type: 'boolean', description: 'Force delete (default: false, required for customers)' }, reassign: { type: 'integer', minimum: 1, description: 'Reassign customer orders to this user ID' } }, required: ['id'] } }, { name: 'wc_batch_customers', description: 'Perform batch operations on customers (create, update, delete multiple customers)', inputSchema: { type: 'object', properties: { create: { type: 'array', items: { type: 'object', properties: { email: { type: 'string', format: 'email' }, first_name: { type: 'string', maxLength: 100 }, last_name: { type: 'string', maxLength: 100 }, username: { type: 'string', pattern: '^[a-zA-Z0-9_]+$', minLength: 3, maxLength: 60 }, password: { type: 'string', minLength: 6, maxLength: 100 } }, required: ['email'] }, description: 'Customers to create' }, update: { type: 'array', items: { type: 'object', properties: { id: { type: 'integer', minimum: 1 }, email: { type: 'string', format: 'email' }, first_name: { type: 'string', maxLength: 100 }, last_name: { type: 'string', maxLength: 100 } }, required: ['id'] }, description: 'Customers to update' }, delete: { type: 'array', items: { type: 'integer', minimum: 1 }, description: 'Customer IDs to delete' } } } }, { name: 'wc_get_customer_orders', description: 'Get orders for a specific customer', inputSchema: { type: 'object', properties: { customer_id: { type: 'integer', minimum: 1, description: 'Customer ID' }, page: { type: 'integer', minimum: 1, description: 'Page number (default: 1)' }, per_page: { type: 'integer', minimum: 1, maximum: 100, description: 'Orders per page (default: 10)' }, status: { type: 'string', enum: ['pending', 'processing', 'on-hold', 'completed', 'cancelled', 'refunded', 'failed'], description: 'Filter by order status' } }, required: ['customer_id'] } }, { name: 'wc_get_top_customers', description: 'Get top customers by total purchase amount, order count, or lifetime value', inputSchema: { type: 'object', properties: { metric: { type: 'string', enum: ['total_spent', 'order_count', 'avg_order_value'], description: 'Ranking metric (default: total_spent)' }, limit: { type: 'integer', minimum: 1, maximum: 100, description: 'Number of top customers to return (default: 10)' }, period: { type: 'string', enum: ['week', 'month', 'quarter', 'year', 'all_time'], description: 'Time period for analysis (default: all_time)' }, min_orders: { type: 'integer', minimum: 1, description: 'Minimum number of orders required (default: 1)' } }, required: [], additionalProperties: false } }, { name: 'wc_get_customer_purchase_history', description: 'Get detailed purchase history for a specific customer including orders, products, and spending patterns', inputSchema: { type: 'object', properties: { customer_id: { type: 'integer', minimum: 1, description: 'Customer ID' }, email: { type: 'string', format: 'email', description: 'Customer email address (alternative to customer_id)' }, date_from: { type: 'string', format: 'date', description: 'Start date for purchase history (YYYY-MM-DD)' }, date_to: { type: 'string', format: 'date', description: 'End date for purchase history (YYYY-MM-DD)' }, include_products: { type: 'boolean', description: 'Include detailed product information (default: true)' }, status: { type: 'array', items: { type: 'string', enum: ['pending', 'processing', 'on-hold', 'completed', 'cancelled', 'refunded', 'failed'] }, description: 'Order statuses to include (default: completed, processing)' } }, required: [], additionalProperties: false } }, { name: 'wc_get_promotions_active', description: 'Get active promotions, discounts, and special offers currently available in the store', inputSchema: { type: 'object', properties: { type: { type: 'string', enum: ['coupon', 'sale', 'bundle', 'loyalty', 'seasonal'], description: 'Type of promotion to filter by (default: all)' }, status: { type: 'string', enum: ['active', 'scheduled', 'expired', 'all'], description: 'Promotion status filter (default: active)' }, category: { type: 'string', description: 'Product category for targeted promotions' }, min_discount: { type: 'number', minimum: 0, maximum: 100, description: 'Minimum discount percentage' } }, required: [], additionalProperties: false } } ]; } async handleTool(name: string, params: MCPToolParams): Promise<MCPToolResult> { try { this.logger.info(`Executing customer tool: ${name}`, { params }); switch (name) { case 'wc_get_customers': return await this.getCustomers(params); case 'wc_get_customer': return await this.getCustomer(params); case 'wc_create_customer': return await this.createCustomer(params); case 'wc_update_customer': return await this.updateCustomer(params); case 'wc_delete_customer': return await this.deleteCustomer(params); case 'wc_batch_customers': return await this.batchCustomers(params); case 'wc_get_customer_orders': return await this.getCustomerOrders(params); case 'wc_get_top_customers': return await this.getTopCustomers(params); case 'wc_get_customer_purchase_history': return await this.getCustomerPurchaseHistory(params); case 'wc_get_promotions_active': return await this.getActivePromotions(params); default: throw new Error(`Unknown customer tool: ${name}`); } } catch (error) { this.logger.error(`Customer tool error: ${name}`, { error: error instanceof Error ? error.message : error, params }); return { content: [{ type: 'text', text: `Error executing ${name}: ${error instanceof Error ? error.message : 'Unknown error'}` }], isError: true }; } } private async getCustomers(params: MCPToolParams): Promise<MCPToolResult> { const validation = ValidationUtils.validateListParams(params); if (validation.error) { throw new Error(`Validation error: ${validation.error}`); } const customers = await this.wooCommerce.getCustomers(validation.value); return { content: [{ type: 'text', text: JSON.stringify({ success: true, data: customers, count: customers.length, message: `Retrieved ${customers.length} customers` }, null, 2) }] }; } private async getCustomer(params: MCPToolParams): Promise<MCPToolResult> { const { id } = params; if (!id || typeof id !== 'number') { throw new Error('Customer ID is required and must be a number'); } const customer = await this.wooCommerce.getCustomer(id); return { content: [{ type: 'text', text: JSON.stringify({ success: true, data: customer, message: `Retrieved customer: ${customer.first_name} ${customer.last_name} (${customer.email})` }, null, 2) }] }; } private async createCustomer(params: MCPToolParams): Promise<MCPToolResult> { const validation = ValidationUtils.validateCustomer(params); if (validation.error) { throw new Error(`Validation error: ${validation.error}`); } const sanitizedData = ValidationUtils.sanitizeInput(validation.value); const customer = await this.wooCommerce.createCustomer(sanitizedData); return { content: [{ type: 'text', text: JSON.stringify({ success: true, data: customer, message: `Customer created successfully: ${customer.first_name} ${customer.last_name} (${customer.email}) - ID: ${customer.id}` }, null, 2) }] }; } private async updateCustomer(params: MCPToolParams): Promise<MCPToolResult> { const { id, ...updateData } = params; if (!id || typeof id !== 'number') { throw new Error('Customer ID is required and must be a number'); } if (Object.keys(updateData).length === 0) { throw new Error('At least one field must be provided for update'); } const validation = ValidationUtils.validateCustomer(updateData); if (validation.error) { throw new Error(`Validation error: ${validation.error}`); } const sanitizedData = ValidationUtils.sanitizeInput(validation.value); const customer = await this.wooCommerce.updateCustomer(id, sanitizedData); return { content: [{ type: 'text', text: JSON.stringify({ success: true, data: customer, message: `Customer updated successfully: ${customer.first_name} ${customer.last_name} (${customer.email})` }, null, 2) }] }; } private async deleteCustomer(params: MCPToolParams): Promise<MCPToolResult> { const { id, force = true, reassign } = params; if (!id || typeof id !== 'number') { throw new Error('Customer ID is required and must be a number'); } // For customers, force=true is typically required as they cannot be trashed const customer = await this.wooCommerce.deleteCustomer(id, force, reassign); return { content: [{ type: 'text', text: JSON.stringify({ success: true, data: customer, message: `Customer deleted successfully: ${customer.first_name} ${customer.last_name} (${customer.email})${reassign ? ` - Orders reassigned to user ID: ${reassign}` : ''}` }, null, 2) }] }; } private async batchCustomers(params: MCPToolParams): Promise<MCPToolResult> { const { create = [], update = [], delete: deleteIds = [] } = params; if (create.length === 0 && update.length === 0 && deleteIds.length === 0) { throw new Error('At least one batch operation must be specified'); } // Validate create data for (const customer of create) { const validation = ValidationUtils.validateCustomer(customer); if (validation.error) { throw new Error(`Validation error in create batch: ${validation.error}`); } } // Validate update data for (const customer of update) { if (!customer.id || typeof customer.id !== 'number') { throw new Error('Customer ID is required for batch update'); } const { id, ...updateData } = customer; const validation = ValidationUtils.validateCustomer(updateData); if (validation.error) { throw new Error(`Validation error in update batch: ${validation.error}`); } } const sanitizedData = { create: ValidationUtils.sanitizeInput(create), update: ValidationUtils.sanitizeInput(update), delete: deleteIds }; const result = await this.wooCommerce.batchCustomers(sanitizedData); return { content: [{ type: 'text', text: JSON.stringify({ success: true, data: result, message: `Batch operation completed: ${create.length} created, ${update.length} updated, ${deleteIds.length} deleted` }, null, 2) }] }; } private async getCustomerOrders(params: MCPToolParams): Promise<MCPToolResult> { const { customer_id, ...filterParams } = params; if (!customer_id || typeof customer_id !== 'number') { throw new Error('Customer ID is required and must be a number'); } const validation = ValidationUtils.validateListParams({ ...filterParams, customer: customer_id }); if (validation.error) { throw new Error(`Validation error: ${validation.error}`); } const orders = await this.wooCommerce.getOrders(validation.value); return { content: [{ type: 'text', text: JSON.stringify({ success: true, data: orders, count: orders.length, message: `Retrieved ${orders.length} orders for customer ID: ${customer_id}` }, null, 2) }] }; } private async getTopCustomers(params: MCPToolParams): Promise<MCPToolResult> { const { metric = 'total_spent', limit = 10, period = 'all_time', min_orders = 1 } = params; this.logger.info('🏆 Getting top customers', { metric, limit, period, min_orders }); // Only real WooCommerce API - no fallback try { // Get real customers from WooCommerce (max 50 per page) const realCustomers = await this.wooCommerce.getCustomers({ per_page: 50 }); // Get real orders to calculate customer metrics (max 50 per page) const realOrders = await this.wooCommerce.getOrders({ per_page: 50, status: 'completed' }); // Calculate real customer metrics const realTopCustomers = this.calculateRealCustomerMetrics(realCustomers, realOrders, metric, limit, min_orders); return { content: [{ type: 'text', text: JSON.stringify({ success: true, period: period, metric: metric, top_customers: realTopCustomers, source: 'woocommerce_api', message: `Top ${realTopCustomers.length} customers by ${metric} from WooCommerce store` }, null, 2) }] }; } catch (error) { this.logger.error('Failed to fetch customer data from WooCommerce', { error: error instanceof Error ? error.message : error }); throw new Error(`WooCommerce API error: ${error instanceof Error ? error.message : 'Unknown error'}`); } } private async getCustomerPurchaseHistory(params: MCPToolParams): Promise<MCPToolResult> { const { customer_id, email, date_from, date_to, include_products = true, status = ['completed', 'processing'] } = params; if (!customer_id && !email) { throw new Error('Either customer_id or email must be provided'); } this.logger.info('📋 Getting customer purchase history', { customer_id, email, date_from, date_to, include_products, status }); // Only real WooCommerce API - no fallback try { // Get customer data first let targetCustomer: any = null; if (customer_id) { targetCustomer = await this.wooCommerce.getCustomer(customer_id); } else if (email) { const customers = await this.wooCommerce.getCustomers({ search: email, per_page: 50 }); targetCustomer = customers.find((c: any) => c.email.toLowerCase() === email.toLowerCase()); } if (!targetCustomer) { return { content: [{ type: 'text', text: JSON.stringify({ success: false, message: `Customer ${email || `ID ${customer_id}`} not found in WooCommerce store`, source: 'woocommerce_api' }, null, 2) }] }; } // Get customer orders const customerOrders = await this.wooCommerce.getOrders({ customer: targetCustomer.id, per_page: 50, status: status.join(',') }); // Filter by date range if provided let filteredOrders = customerOrders; if (date_from || date_to) { filteredOrders = customerOrders.filter((order: any) => { const orderDate = new Date(order.date_created); if (date_from && orderDate < new Date(date_from)) return false; if (date_to && orderDate > new Date(date_to)) return false; return true; }); } const purchaseHistory = { customer_info: { customer_id: targetCustomer.id, email: targetCustomer.email, first_name: targetCustomer.first_name, last_name: targetCustomer.last_name, registration_date: targetCustomer.date_created, total_orders: filteredOrders.length, total_spent: filteredOrders.reduce((sum: number, order: any) => sum + parseFloat(order.total || 0), 0) }, orders: include_products ? filteredOrders : filteredOrders.map((order: any) => ({ ...order, line_items: undefined // Remove product details if not requested })), summary: { filtered_orders_count: filteredOrders.length, filtered_total_spent: filteredOrders.reduce((sum: number, order: any) => sum + parseFloat(order.total || 0), 0), date_range: { from: date_from, to: date_to }, status_filter: status } }; return { content: [{ type: 'text', text: JSON.stringify({ success: true, customer_id: targetCustomer.id, email: targetCustomer.email, date_range: { from: date_from, to: date_to }, purchase_history: purchaseHistory, source: 'woocommerce_api', message: `Purchase history retrieved for ${targetCustomer.email} (from WooCommerce store)` }, null, 2) }] }; } catch (error) { this.logger.error('Failed to fetch customer purchase history', { error: error instanceof Error ? error.message : error }); throw new Error(`WooCommerce API error: ${error instanceof Error ? error.message : 'Unknown error'}`); } } private async getActivePromotions(params: MCPToolParams): Promise<MCPToolResult> { const { type = 'all', status = 'active', category, min_discount = 0 } = params; this.logger.info('🎯 Getting active promotions', { type, status, category, min_discount }); // Only real WooCommerce API - no fallback try { // Get real coupons and sales from WooCommerce const realCoupons = await this.wooCommerce.getCoupons({ per_page: 50 }); const realPromotions = realCoupons .filter((coupon: any) => coupon.status === 'publish') .map((coupon: any) => ({ id: coupon.id, name: coupon.code, type: 'coupon', status: 'active', category: 'general', discount_type: coupon.discount_type, discount_value: parseFloat(coupon.amount || 0), description: coupon.description || `${coupon.amount}${coupon.discount_type === 'percent' ? '%' : ' MXN'} discount`, code: coupon.code, valid_from: coupon.date_created, valid_until: coupon.date_expires, min_amount: parseFloat(coupon.minimum_amount || 0), usage_limit: coupon.usage_limit, used_count: coupon.usage_count || 0, currency: 'MXN' })) .filter((promo: any) => type === 'all' || promo.type === type) .filter((promo: any) => promo.discount_value >= min_discount); return { content: [{ type: 'text', text: JSON.stringify({ success: true, filter: { type, status, category, min_discount }, promotions: realPromotions, source: 'woocommerce_api', message: `Found ${realPromotions.length} ${status} promotions from WooCommerce store` }, null, 2) }] }; } catch (error) { this.logger.error('Failed to fetch promotions data from WooCommerce', { error: error instanceof Error ? error.message : error }); throw new Error(`WooCommerce API error: ${error instanceof Error ? error.message : 'Unknown error'}`); } } private calculateRealCustomerMetrics(customers: any[], orders: any[], metric: string, limit: number, minOrders: number): any[] { // Calculate real customer metrics from WooCommerce data const customerMetrics = new Map(); const emailToCustomer = new Map(); // Process each registered customer customers.forEach(customer => { const customerData = { id: customer.id, email: customer.email, first_name: customer.first_name, last_name: customer.last_name, total_spent: 0, orders_count: 0, average_order_value: 0, last_order_date: null, registration_date: customer.date_created, is_registered: true }; customerMetrics.set(customer.id, customerData); emailToCustomer.set(customer.email.toLowerCase(), customerData); }); // Process orders to calculate metrics (registered + guest customers) let ordersProcessed = 0; let ordersMatched = 0; let guestOrdersCreated = 0; orders.forEach((order: any) => { ordersProcessed++; const customerId = order.customer_id; const billingEmail = order.billing?.email?.toLowerCase(); let targetMetrics = null; // 1. Try registered customer first if (customerId && customerId !== 0 && customerMetrics.has(customerId)) { targetMetrics = customerMetrics.get(customerId); ordersMatched++; } // 2. Try guest customer by email else if (billingEmail && emailToCustomer.has(billingEmail)) { targetMetrics = emailToCustomer.get(billingEmail); ordersMatched++; } // 3. Create new guest customer else if (billingEmail) { const guestCustomerId = `guest_${billingEmail}`; targetMetrics = { id: guestCustomerId, email: billingEmail, first_name: order.billing?.first_name || 'Guest', last_name: order.billing?.last_name || 'Customer', total_spent: 0, orders_count: 0, average_order_value: 0, last_order_date: null, registration_date: order.date_created, is_registered: false }; customerMetrics.set(guestCustomerId, targetMetrics); emailToCustomer.set(billingEmail, targetMetrics); guestOrdersCreated++; } // Update metrics if we found/created a customer if (targetMetrics) { targetMetrics.total_spent += parseFloat(order.total || 0); targetMetrics.orders_count += 1; if (!targetMetrics.last_order_date || order.date_created > targetMetrics.last_order_date) { targetMetrics.last_order_date = order.date_created; } } }); // Log processing summary for monitoring this.logger.info('Customer metrics calculated', { ordersProcessed, ordersMatched, guestCustomersCreated: guestOrdersCreated }); // Calculate average order value and filter by min orders const qualifiedCustomers = Array.from(customerMetrics.values()) .filter(customer => customer.orders_count >= minOrders) .map(customer => { customer.average_order_value = customer.orders_count > 0 ? (customer.total_spent / customer.orders_count) : 0; return customer; }); // Sort by specified metric qualifiedCustomers.sort((a, b) => { switch (metric) { case 'total_spent': return b.total_spent - a.total_spent; case 'orders_count': return b.orders_count - a.orders_count; case 'average_order_value': return b.average_order_value - a.average_order_value; default: return b.total_spent - a.total_spent; } }); return qualifiedCustomers.slice(0, limit); } }