주문/배송 자동 처리 파이프라인

// AI 프롬프트: "WooCommerce 주문 웹훅 수신 서버 만들어줘"
const express = require('express');
const crypto = require('crypto');
const app = express();

app.use(express.json());

// 웹훅 서명 검증
function verifyWebhook(req) {
  const signature = req.headers['x-wc-webhook-signature'];
  const hash = crypto.createHmac('sha256', process.env.WEBHOOK_SECRET)
    .update(JSON.stringify(req.body))
    .digest('base64');
  return signature === hash;
}

// 주문 접수 웹훅
app.post('/webhooks/order-created', async (req, res) => {
  if (!verifyWebhook(req)) {
    return res.status(401).json({ error: '서명 불일치' });
  }

  const order = req.body;
  console.log(`새 주문 접수: #${order.id} - ${order.billing.first_name}`);

  try {
    // 1. 결제 상태 확인
    if (order.status !== 'processing') {
      console.log('결제 미완료, 대기 중...');
      return res.json({ status: 'pending' });
    }

    // 2. 재고 확인 및 차감
    await checkAndDeductStock(order.line_items);

    // 3. 배송 요청
    const trackingNumber = await requestShipping(order);

    // 4. 고객 알림 발송
    await sendCustomerNotification(order, trackingNumber);

    // 5. 주문 상태 업데이트
    await updateOrderStatus(order.id, 'shipped', trackingNumber);

    res.json({ status: 'processed', tracking: trackingNumber });
  } catch (error) {
    console.error('주문 처리 실패:', error);
    await notifyAdmin(order.id, error);
    res.status(500).json({ error: error.message });
  }
});