app.get('/return', async (req, res) => {
  const { tid, orderId, amount, authResultCode } = req.query;

  // 1. 결제 성공 여부 확인
  if (authResultCode !== '0000') {
    return res.send('결제 실패');
  }

  // 2. 승인금액검증
  const isValid = await verifyAmount(tid, amount);
  if (!isValid) {
    console.error('❌ 금액 불일치 - 위변조 의심');
    return res.send('결제 검증 실패');
  }

  // 3. 중복 처리 방지
  if (await isProcessed(orderId)) {
    return res.send('결제 완료');
  }

  // 4. 주문 처리
  await processOrder(orderId, tid, amount);
  res.send('결제 완료');
});

app.post('/webhook/nicepay', async (req, res) => {
  const webhookData = req.body;

  // 즉시 OK 응답 (필수)
  res.status(200).type('text/html').send('OK');

  // 백그라운드 처리
  setImmediate(async () => {
    // 1. Signature 검증
    if (!verifySignature(webhookData)) {
      return;
    }

    // 2. 중복 처리 방지
    if (await isProcessed(webhookData.orderId)) {
      return;
    }

    // 3. 주문 처리
    await processOrder(
      webhookData.orderId,
      webhookData.tid,
      webhookData.amount
    );
  });
});

// Redis를 활용한 중복 체크
async function isProcessed(orderId) {
  const key = `order:processed:${orderId}`;
  const exists = await redis.exists(key);

  if (!exists) {
    // 1시간 동안 처리 완료 상태 유지
    await redis.setex(key, 3600, '1');
    return false;
  }

  return true;
}