Thank you for your order, ${order.customer.name}!

Order ID: ${order.orderId}

Priority Level: ${order.priority}

Estimated Processing Time: ${order.estimatedProcessingTime} hours

Status: ${order.status}

Total: $${order.total.toFixed(2)}

\n \n

Items Ordered:

${itemsList}

\n \n

Shipping Information:

Method: ${order.shipping.method}

Address:
\n ${order.shipping.address.street}
\n ${order.shipping.address.city}, ${order.shipping.address.state} ${order.shipping.address.zipCode}
\n ${order.shipping.address.country}

\n \n ${order.shipping.isRushOrder ? '

⚡ Rush Order - Expedited processing requested

' : ''}\n ${order.shipping.requestedDeliveryDate ? `

Requested Delivery: ${new Date(order.shipping.requestedDeliveryDate).toLocaleDateString()}

` : ''}\n \n

Your order has been automatically sorted for optimal processing. We'll send you updates as it progresses through our fulfillment system.

Thank you for your business!

\n `\n });\n } catch (error) {\n console.error('Failed to send customer email:', error);\n }\n\n // Send business notification (priority-based)\n if (businessEmail) {\n const shouldNotify = order.priority === 'URGENT' || \n (order.priority === 'HIGH' && order.total >= 500) ||\n order.customer.type === 'VIP';\n\n if (shouldNotify) {\n try {\n await email({\n to: businessEmail,\n subject: `🚨 ${order.priority} Priority Order - ${order.orderId}`,\n html: `\n

\n ${getPriorityEmoji(order.priority)} ${order.priority} PRIORITY ORDER ALERT\n

\n \n

Event: ${event}

Order ID: ${order.orderId}

Customer: ${order.customer.name} (${order.customer.email})

Customer Type: ${order.customer.type}

Total: $${order.total.toFixed(2)}

Assigned Team: ${order.assignedTeam || 'Not assigned'}

Est. Processing Time: ${order.estimatedProcessingTime} hours

\n \n

Sorting Reasons:

${sortingReasons}

\n \n

Items (${order.items.length}):

${itemsList}

\n \n

Shipping Details:

Method: ${order.shipping.method}

\n ${order.shipping.isRushOrder ? '

⚡ RUSH ORDER

' : ''}\n ${order.shipping.requestedDeliveryDate ? `

Requested Delivery: ${new Date(order.shipping.requestedDeliveryDate).toLocaleDateString()}

` : ''}\n \n

Order Time: ${new Date(order.timestamp).toLocaleString()}

Sorted At: ${new Date(order.sortedAt).toLocaleString()}

\n \n

\n Action Required: This ${order.priority.toLowerCase()} priority order requires immediate attention from the ${order.assignedTeam} team.\n

\n `\n });\n } catch (error) {\n console.error('Failed to send business notification:', error);\n }\n }\n }\n}\n\nfunction getPriorityColor(priority: string): string {\n switch (priority) {\n case 'URGENT': return '#d32f2f';\n case 'HIGH': return '#f57c00';\n case 'MEDIUM': return '#388e3c';\n case 'LOW': return '#616161';\n default: return '#000000';\n }\n}\n\nfunction getPriorityEmoji(priority: string): string {\n switch (priority) {\n case 'URGENT': return '🚨';\n case 'HIGH': return '⚡';\n case 'MEDIUM': return '📦';\n case 'LOW': return '📋';\n default: return '📦';\n }\n}\n\nfunction getCustomerTypeColor(type: string): string {\n switch (type) {\n case 'VIP': return '#9c27b0';\n case 'Premium': return '#ff9800';\n case 'Standard': return '#2196f3';\n case 'New': return '#4caf50';\n default: return '#757575';\n }\n}\n\n// Main webhook endpoint for order sorting\nwebhook.post('/orders', async (c) => {\n try {\n const body = await c.req.text();\n const signature = c.req.header('x-webhook-signature') || c.req.header('x-signature');\n const webhookSecret = Deno.env.get('WEBHOOK_SECRET');\n\n // Verify webhook signature if secret is configured\n if (webhookSecret && signature) {\n if (!verifySignature(body, signature, webhookSecret)) {\n return c.json({ error: 'Invalid signature' }, 401);\n }\n }\n\n // Parse webhook payload\n let payload: WebhookPayload;\n try {\n payload = JSON.parse(body);\n } catch (error) {\n return c.json({ error: 'Invalid JSON payload' }, 400);\n }\n\n // Validate required fields\n if (!payload.event || !payload.data) {\n return c.json({ error: 'Missing required fields: event, data' }, 400);\n }\n\n const { event, data: order } = payload;\n\n // Validate order data\n if (!order.orderId || !order.customer?.email || !order.customer?.name || !order.items || order.items.length === 0) {\n return c.json({ error: 'Invalid order data - missing required fields' }, 400);\n }\n\n if (!order.shipping?.method || !order.shipping?.address) {\n return c.json({ error: 'Invalid shipping information' }, 400);\n }\n\n console.log(`Processing order sorting webhook: ${event} for order ${order.orderId}`);\n\n // Sort the order using our intelligent sorting system\n const sortedOrder = orderSorter.sortOrder(order);\n\n console.log(`Order ${order.orderId} sorted as ${sortedOrder.priority} priority, assigned to ${sortedOrder.assignedTeam}`);\n console.log(`Sorting reasons: ${sortedOrder.sortingReason.join(', ')}`);\n\n // Store sorted order in database\n await createSortedOrder(sortedOrder);\n\n // Send priority-based notifications\n await sendPriorityNotifications(sortedOrder, event);\n\n // Return detailed success response\n return c.json({\n success: true,\n message: `Order ${order.orderId} sorted and processed successfully`,\n orderDetails: {\n orderId: order.orderId,\n priority: sortedOrder.priority,\n assignedTeam: sortedOrder.assignedTeam,\n estimatedProcessingTime: sortedOrder.estimatedProcessingTime,\n sortingReasons: sortedOrder.sortingReason\n },\n event: event,\n processedAt: new Date().toISOString()\n });\n\n } catch (error) {\n console.error('Order sorting webhook error:', error);\n return c.json({ \n error: 'Internal server error',\n message: error.message \n }, 500);\n }\n});\n\n// Test endpoint for webhook validation\nwebhook.post('/test', async (c) => {\n try {\n const testOrder: Order = {\n orderId: `TEST-${Date.now()}`,\n customer: {\n email: 'test@example.com',\n name: 'Test Customer',\n type: 'Standard'\n },\n items: [\n {\n name: 'Test Product',\n quantity: 1,\n price: 99.99,\n category: 'physical'\n }\n ],\n total: 99.99,\n status: 'pending',\n timestamp: new Date().toISOString(),\n shipping: {\n method: 'standard',\n address: {\n street: '123 Test St',\n city: 'Test City',\n state: 'TS',\n zipCode: '12345',\n country: 'US'\n }\n }\n };\n\n const sortedOrder = orderSorter.sortOrder(testOrder);\n\n return c.json({\n message: 'Test order sorting successful',\n originalOrder: testOrder,\n sortedOrder: {\n priority: sortedOrder.priority,\n assignedTeam: sortedOrder.assignedTeam,\n estimatedProcessingTime: sortedOrder.estimatedProcessingTime,\n sortingReasons: sortedOrder.sortingReason\n }\n });\n } catch (error) {\n return c.json({ error: 'Test failed', message: error.message }, 500);\n }\n});\n\n// Health check endpoint\nwebhook.get('/health', (c) => {\n return c.json({ \n status: 'healthy', \n service: 'order-sorting-webhook',\n timestamp: new Date().toISOString() \n });\n});\n\nexport default webhook;","deleted","label",[171,172,153],"backend","routes","permalink","https://www.val.town/x/Victoria1234/creatawebhoodforabusiness/code/backend/routes/webhook.ts","extension","actionData","errors"]