Race conditions

[HttpPost("/api/orders/{orderId:long}/coupon")]public async Task<IActionResult> ApplyCoupon(long orderId, [FromBody] CouponRequest req, CancellationToken ct){    // ❌ ĐỌC. Từ đây tới lúc GHI ở dòng 20 là cửa sổ, và mọi request khác tới trong    //    khoảng đó cũng đọc được đúng giá trị này.    var coupon = await _db.Coupons        .FirstOrDefaultAsync(c => c.Code == req.Code, ct);     if (coupon is null) return NotFound();     // ❌ KIỂM. Đúng về logic, và vô dụng về đồng thời: hai mươi request cùng lúc    //    đều thấy UsesLeft = 1 và đều đi qua dòng này.    if (coupon.UsesLeft <= 0)        return BadRequest(new { error = "Coupon exhausted" });     coupon.UsesLeft--;    _db.OrderDiscounts.Add(new OrderDiscount(orderId, req.Code, coupon.Percent));     // ❌ GHI, ở một round-trip KHÁC. Transaction của SaveChanges không cứu được:    //    mặc định là Read Committed, và Read Committed cho phép đúng cửa sổ này.    await _db.SaveChangesAsync(ct);     return Ok(new { applied = true, discount = $"{coupon.Percent}%" });}

@app.post("/api/accounts/<int:account_id>/withdraw")def withdraw(account_id):    amount = Decimal(request.json["amount"])     with db.session.begin():        # ❌ ĐỌC. Mặc định của Postgres là Read Committed, và Read Committed cho        #    phép một transaction khác đọc cùng giá trị này.        acct = db.session.get(Account, account_id)         # ❌ KIỂM. Hai request đồng thời đều thấy balance = 100 và đều đi qua.        if acct.balance < amount:            return {"error": "insufficient funds"}, 400         # ❌ GHI. Gán từ một giá trị đã ĐỌC trước đó: nó ghi đè kết quả của        #    transaction kia thay vì trừ tiếp lên nó.        acct.balance = acct.balance - amount        db.session.add(Ledger(account_id=account_id, amount=-amount))     return {"balance": str(acct.balance)}

public class CouponConcurrencyTests : IClassFixture<PostgresFixture>{    private readonly PostgresFixture _fx;     public CouponConcurrencyTests(PostgresFixture fx) => _fx = fx;     /// <summary>    /// Test PHẢI song song thật. Một test gọi endpoint hai lần liên tiếp pass trên    /// code lỗi — cửa sổ không bao giờ mở, vì lần gọi đầu đã ghi xong trước khi lần    /// thứ hai bắt đầu đọc.    ///    /// Barrier là thứ làm test này có nghĩa: nó giữ cả 20 task ở vạch xuất phát cho    /// tới khi task cuối cùng đã sẵn sàng, rồi thả tất cả trong cùng một nhịp. Đây là    /// bản mô phỏng của single-packet attack ở tầng test.    /// </summary>    [Theory]    [InlineData(20)]    [InlineData(50)]    public async Task Single_use_coupon_applies_exactly_once(int concurrency)    {        await _fx.SeedCouponAsync("SAVE50", maxUses: 1);        var orders = await _fx.SeedOrdersAsync(count: concurrency);         using var barrier = new Barrier(concurrency);        var results = new CouponResult[concurrency];         await Task.WhenAll(Enumerable.Range(0, concurrency).Select(i => Task.Run(async () =>        {            // Mỗi task có scope DI riêng → connection riêng → transaction riêng.            // Dùng chung một DbContext thì test đo sai thứ: nó đo hành vi của            // change tracker, không đo hành vi đồng thời của DB.            await using var scope = _fx.Services.CreateAsyncScope();            var svc = scope.ServiceProvider.GetRequiredService<CouponService>();             barrier.SignalAndWait();          // ← tất cả xuất phát cùng lúc            results[i] = await svc.ApplyAsync(orders[i].Id, "SAVE50", default);        })));         // Khẳng định 1: đúng MỘT request thành công.        Assert.Equal(1, results.Count(r => r == CouponResult.Applied));         // Khẳng định 2 — QUAN TRỌNG NHẤT: đếm TÁC DỤNG, không đếm bộ đếm.        //        // uses_left = 0 là ĐÚNG trong cả hai trường hợp (đã vá và chưa vá), nên một        // test chỉ kiểm uses_left sẽ xanh trên code lỗi. Con số nói ra sự thật là số        // dòng discount thật sự đã được ghi.        Assert.Equal(1, await _fx.CountDiscountsAsync("SAVE50"));    }     /// <summary>    /// Mã cho phép 5 lượt: 50 request đồng thời phải cho ra ĐÚNG 5. Test này bắt được    /// một lỗi mà test max_uses=1 ở trên bỏ qua — bản vá đúng cho 1 nhưng sai dấu    /// so sánh (>= thay vì >) vẫn pass ở trên và đỏ ở đây.    /// </summary>    [Fact]    public async Task Multi_use_coupon_never_exceeds_its_limit()    {        await _fx.SeedCouponAsync("SAVE10", maxUses: 5);        var orders = await _fx.SeedOrdersAsync(count: 50);         using var barrier = new Barrier(50);        await Task.WhenAll(orders.Select((o, i) => Task.Run(async () =>        {            await using var scope = _fx.Services.CreateAsyncScope();            var svc = scope.ServiceProvider.GetRequiredService<CouponService>();            barrier.SignalAndWait();            await svc.ApplyAsync(o.Id, "SAVE10", default);        })));         Assert.Equal(5, await _fx.CountDiscountsAsync("SAVE10"));        Assert.Equal(0, await _fx.GetUsesLeftAsync("SAVE10"));    }     /// <summary>    /// Ràng buộc UNIQUE sống trong migration, không trong code — nên một migration    /// khác xoá nó đi mà không test nào đỏ. Test này là thứ làm nó đỏ.    /// </summary>    [Fact]    public async Task Unique_constraint_exists()    {        var found = await _fx.QueryScalarAsync<long>("""            SELECT count(*) FROM pg_indexes             WHERE schemaname = 'core' AND tablename = 'order_discount'               AND indexdef ILIKE '%UNIQUE%coupon_code%'            """);         Assert.True(found > 0, "ràng buộc UNIQUE trên order_discount đã biến mất");    }}