using System;
|
using System.IO;
|
using System.Threading;
|
using Aging.Infrastructure.Core;
|
using Aging.ResourceContracts;
|
using Xunit;
|
|
namespace Aging.MvpTests
|
{
|
public class FacadeLeaseLifecycleTests : IDisposable
|
{
|
private readonly string _dbPath;
|
private readonly DbLeaseStore _store;
|
public FacadeLeaseLifecycleTests()
|
{
|
_dbPath = Path.Combine(Path.GetTempPath(), "arb_" + Guid.NewGuid().ToString("N") + ".db");
|
_store = new DbLeaseStore(_dbPath, "local-main");
|
}
|
public void Dispose() { try { File.Delete(_dbPath); File.Delete(_dbPath + "-wal"); File.Delete(_dbPath + "-shm"); } catch { } }
|
|
private LeaseGrant Grab(string key, int ttl)
|
=> _store.Acquire(new AcquireRequest
|
{
|
OwnerId = "f", OwnerType = OwnerTypeV3.Production,
|
ResourceKeys = new[] { key }, TtlSeconds = ttl
|
}).Grants[0];
|
|
[Fact]
|
public void Heartbeat_Renew_Extends_Expiry()
|
{
|
var g = Grab("can/x", 2);
|
long before = g.ExpiresUtcMs;
|
Thread.Sleep(1200);
|
Assert.True(_store.Renew(g, 2));
|
Assert.True(_store.ProbeConflict("can/x").ExpiresUtcMs > before);
|
}
|
|
[Fact]
|
public void Expired_Sweep_StaleRenew_False_And_RecoveryBlocked()
|
{
|
var g = Grab("can/y", 1);
|
Thread.Sleep(1500);
|
Assert.Equal(1, _store.SweepExpired());
|
Assert.False(_store.Renew(g, 5));
|
Assert.Null(_store.ProbeConflict("can/y"));
|
Assert.Equal(LeasePhase.RecoveryRequired, _store.PhaseOf("can/y"));
|
}
|
}
|
}
|
