Order Events

@app.route('/api/orderEvent', methods=['POST'])
def handle_order_event():
    try:
        payload = request.get_json()
        message_id = payload['message_id']

        # Check if already processed
        if is_message_processed(message_id):
            return 'OK', 200

        # Process each order update
        for order in payload['data']:
            order_id = order['customer_identifier']
            status = order['status']

            # Update order status
            update_order_status(order_id, status)

            # Handle shipments
            if 'shipments' in order and order['shipments']:
                for shipment in order['shipments']:
                    tracking = shipment['tracking_number']
                    carrier = shipment['shipping_provider']

                    # Update shipment info
                    add_shipment_tracking(order_id, tracking, carrier)

                    # Send customer notification
                    send_shipping_notification(order_id, tracking)

            # Handle shorts
            if 'shorts' in order and order['shorts']:
                for short in order['shorts']:
                    sku = short['sku_customer_id']
                    qty = short['quantity']
                    reason = short['reason']

                    # Log short and notify customer
                    log_inventory_short(order_id, sku, qty, reason)
                    notify_customer_of_short(order_id, sku, qty)

        mark_message_processed(message_id)
        return 'OK', 200

    except Exception as e:
        logger.error(f"Order event webhook error: {e}")
        return 'Error', 500

app.post('/api/orderEvent', async (req, res) => {
  try {
    const payload = req.body;
    const messageId = payload.message_id;

    // Check if already processed
    if (await isMessageProcessed(messageId)) {
      return res.status(200).send('OK');
    }

    // Process each order update
    for (const order of payload.data) {
      const orderId = order.customer_identifier;
      const status = order.status;

      // Update order status
      await updateOrderStatus(orderId, status);

      // Handle shipments
      if (order.shipments?.length > 0) {
        for (const shipment of order.shipments) {
          await addShipmentTracking(
            orderId,
            shipment.tracking_number,
            shipment.shipping_provider
          );

          // Send customer notification
          await sendShippingNotification(orderId, shipment.tracking_number);
        }
      }

      // Handle shorts
      if (order.shorts?.length > 0) {
        for (const short of order.shorts) {
          await logInventoryShort(
            orderId,
            short.sku_customer_id,
            short.quantity,
            short.reason
          );

          await notifyCustomerOfShort(orderId, short.sku_customer_id);
        }
      }
    }

    await markMessageProcessed(messageId);
    res.status(200).send('OK');

  } catch (error) {
    console.error('Order event webhook error:', error);
    res.status(500).send('Error');
  }
});