// Handle order events and trigger workflows
async function handleOrderWorkflow(change) {
  // Log the change
  await logDatabaseChange(change);
  
  // Only process new orders
  if (change.metadata.table_name === 'orders' && change.action === 'insert') {
    const order = change.record;
    
    // Update inventory for each item
    for (const item of order.items) {
      await updateInventory(item.product_id, -item.quantity);
    }
  }
}

// Update inventory levels and check thresholds
async function updateInventory(productId, quantityChange) {
  const { rows } = await db.query(
    'UPDATE inventory SET quantity = quantity + $1 WHERE product_id = $2 RETURNING quantity',
    [quantityChange, productId]
  );
  // Trigger alert if inventory is low
  if (rows[0].quantity <= 10) {
    await db.query(
      'INSERT INTO inventory_alerts (product_id, current_quantity) VALUES ($1, $2)',
      [productId, rows[0].quantity]
    );
  }
}