Thiết kế Idempotent API (Xử lý trùng lặp thanh toán) với Idempotency Key và Redis

Client (Gửi Request kèm Idempotency-Key)
       │
       ▼
[ Backend Middleware ]
       │──> Kiểm tra Key trong Redis
       │
       ├─► [Đang xử lý]: Trả về HTTP 409 Conflict hoặc chờ
       ├─► [Đã hoàn thành]: Trả về đúng Response đã lưu trong Cache!
       └─► [Chưa từng có]: Đánh dấu "Processing" và tiếp tục chạy logic

import type { Request, Response, NextFunction } from 'express';
import Redis from 'ioredis';

const redis = new Redis();

export async function idempotencyMiddleware(req: Request, res: Response, next: NextFunction) {
  const idempotencyKey = req.header('Idempotency-Key');
  if (!idempotencyKey) return next();

  const cacheKey = `idempotency:${idempotencyKey}`;
  
  // 1. Thử thiết lập khóa với cờ NX (Chỉ set nếu chưa tồn tại)
  const acquired = await redis.set(cacheKey, JSON.stringify({ status: 'PROCESSING' }), 'EX', 120, 'NX');
  
  if (!acquired) {
    const cachedData = await redis.get(cacheKey);
    const parsed = JSON.parse(cachedData || '{}');
    
    if (parsed.status === 'PROCESSING') {
      return res.status(409).json({ message: 'Giao dịch đang được xử lý, vui lòng không gửi lại.' });
    }
    
    // Trả về kết quả trước đó mà không thực thi lại logic trừ tiền!
    return res.status(parsed.statusCode).json(parsed.body);
  }

  // 2. Bọc hàm res.json để lưu kết quả sau khi xử lý xong
  const originalJson = res.json.bind(res);
  res.json = (body: any) => {
    redis.set(cacheKey, JSON.stringify({ status: 'COMPLETED', statusCode: res.statusCode, body }), 'EX', 86400);
    return originalJson(body);
  };

  next();
}