具有通用存盤庫的.net6中MediatR的單元測驗回傳空存盤庫

我正在使用 MediatR 進行命令查詢隔離。我想測驗命令方法，我的命令方法接受一個clientappsetting模型作為輸入。在這里你可以看到我的整個處理程式和命令代碼：

   AddClientAppSettingCommandHandler : IRequestHandler<AddClientAppSettingCommand, AddClientAppSettingResponse>
    {
        private readonly ICurrentUserService _userService;
        private readonly IRepository<ClientAppSettings> _repository;

        public AddClientAppSettingCommandHandler(ICurrentUserService userService,
            IRepositoryAccessor repositoryAccessor)
        {
            _userService = userService;
            _repository = repositoryAccessor.GetRepository<ClientAppSettings>(_userService.CustomerIsin,
                reThrowException: true, type: DatabaseType.Raven);
        }

        public async Task<AddClientAppSettingResponse> Handle(AddClientAppSettingCommand request,
            CancellationToken cancellationToken)
        {
            var entity = new ClientAppSettings(_userService.CustomerIsin)
            {
                LightTheme = request.Setting.LightTheme,
                Order = request.Setting.Order,
                Notch = request.Setting.Notch,
                PageSize = request.Setting.PageSize,
                ApplyCommissionInPortfolio = request.Setting.ApplyCommissionInPortfolio,
                UseClosingPriceInPortfolioTotalValue = request.Setting.UseClosingPriceInPortfolioTotalValue,
                ShowNotifications = request.Setting.ShowNotifications,
                NoSleep = request.Setting.NoSleep,
                NoBalance = request.Setting.NoBalance,
                DataTracker = request.Setting.DataTracker,
                UserStatusBarToUp = request.Setting.UserStatusBarToUp,
                PortfolioBasedOnLastPositivePeriod = request.Setting.PortfolioBasedOnLastPositivePeriod,
            };
            var cRepository = CacheableRepository<ClientAppSettings>.From(_repository);
            var result = await cRepository.AddOrUpdateAsync(entity);

            if (!result.IsSucceeded)
                throw new EasyException(EasyException.DATABASE_EXCEPTION, result.Error);
            return AddClientAppSettingResponse.Map(entity);
        }

如您所見，我的處理程式有兩個依賴項 ICurrentUserService , IRepositoryAccessor

我的問題是IRepositoryAccessor 當我運行測驗時存盤庫物件為 null 。

這是我的存盤庫介面和 imp ；

public interface IRepositoryAccessor
{
    IRepository<TEntity> GetRepository<TEntity>(
        string shard = "public",
        DatabaseType type = DatabaseType.Raven,
        Type inheritedRepository = null,
        bool manualDisposing = false,
        bool reThrowException=false) where TEntity : BaseEntity;

    void CloseSession();

}

小鬼：

 public sealed class RepositoryAccessor : IRepositoryAccessor, IDisposable
    {
        private static readonly Dictionary<Type, object> FlyweightSqlGenerator = new();
        private readonly List<IDisposable> _sessions = new();

        private readonly ITracer _tracer;
        private readonly IConfiguration _configuration;
        public RepositoryAccessor(IConfiguration configuration, ITracer tracer = null)
        {
            _configuration = configuration;
            _tracer = tracer;
        }

        public void CloseSession()
        {
            for (int i = 0; i < _sessions.Count; i  )
            {
                _sessions[i].Dispose();
            }
            _sessions.Clear();
        }

        public void Dispose() => CloseSession();


        public IRepository<TEntity> GetRepository<TEntity>(
            string shard = "public",
            DatabaseType type = DatabaseType.Raven,
            Type inheritedRepository = null,
            bool manualDisposing = false,
            bool reThrowException = false) where TEntity : BaseEntity
        {
            if (type == DatabaseType.Raven)
            {
                return GetRavenRepository<TEntity>(inheritedRepository, shard, manualDisposing, reThrowException);
            }
            else if (type == DatabaseType.Redis)
            {
                return new RedisRepository<TEntity>();
            }
            return GetSQLRepository<TEntity>(inheritedRepository, manualDisposing, reThrowException);
        }
}

這是我的測驗：

[Fact]
public async void Test1()
{
    //Arange
    var mediator = new Mock<IMediator>();
    var userservice = new Mock<ICurrentUserService>();
    var repo = new Mock<IRepositoryAccessor>();



    AddClientAppSettingCommand command = new AddClientAppSettingCommand(new domain.Entities.ClientAppSettings());
    AddClientAppSettingCommandHandler handler = new AddClientAppSettingCommandHandler(userservice.Object,repo.Object);

    //Act
    var x = await handler.Handle(command, new System.Threading.CancellationToken());

  
}

當我以除錯模式運行測驗時，我的存盤庫為 null ：

uj5u.com熱心網友回復：

如您所見，我應該將IAccessorand定義IRepository為模擬并為 IAccessor 設定 Irepository：

var repoacc = new Mock<IRepositoryAccessor>();
            var repo = new Mock<domain.Interfaces.IRepository<ClientAppSettings>>();

            repoacc.Setup(i => i.GetRepository<ClientAppSettings>(It.IsAny<string>(), DatabaseType.Raven, null, false, true)).Returns(repo.Object);

標籤：

上一篇：如何正確對ServiceBusSendAsync方法進行單元測驗？

下一篇：GoTestCoverage-GoToolNotRecognizeerr!=nil回傳