测试批量 SendAll ServiceStack

Question

我在单元测试中收到有关 SendAll 的错误

这很好用...

 using (var service = HostContext.ResolveService<DeviceService>(authenticatedRequest))
                    {
                        service.Put(new AddConfig { ConfigName = key.KeyName, ConfigValue = key.Value, DeviceId = 0 });
                    }}

ServiceStack.WebServiceException: '此服务不存在操作 'AddConfig[]''

  //DeviceConfig
        /// <summary>
        /// To insert new Config
        /// </summary>
        /// <returns> New row Id or -1 on error</returns>
        public long Any(AddConfig request)
        {
            try
            {
                //convert request to model
                var perm = request.ConvertTo<DeviceConfig>();
                //log user
                perm.AuditUserId = UserAuth.Id;
                //insert data
                var insert = Db.Insert(perm, selectIdentity:true);
                //log inserted data
                LogInfo(typeof(DeviceConfig), perm, LogAction.Insert);
                return insert;
            }
            //on error log error and data
            catch (Exception e)
            {
                Log.Error(e);
            }
            return -1;
        }

   [Route("/Config", "PUT")]
    public class AddConfig : IReturn<long>
    {
        public int DeviceId { get; set; }
        public string ConfigName { get; set; }
        public string ConfigValue { get; set; }
    }

public const string TestingUrl = "http://localhost:5123/";

    public void DeviceX400Test(string deviceTemaplateFile)
    {
        //Resolve auto-wired service
        WireUpService<DeviceService>();

        var requests = new[]
        {
            new AddConfig { ConfigName = "Foo" },
            new AddConfig { ConfigName = "Bar" },
            new AddConfig { ConfigName = "Baz" },
        };
        var client = new JsonServiceClient(TestingUrl);
        var deviceConfigs = client.SendAll(requests);
    }

从我的 .netcore appsettings.Json 文件构建的用于单元测试的我的服务库

 public abstract class ServiceTestBase: IDisposable
    {
        //private readonly ServiceStackHost appHost;
        public BasicRequest authenticatedRequest;
        public const string TestingUrl = "http://localhost:5123/";
        public SeflHostedAppHost apphost;
        public ServiceTestBase()
        {
            var licenseKeyText = "********************************";
            Licensing.RegisterLicense(licenseKeyText);

            apphost = (SeflHostedAppHost) new SeflHostedAppHost()
                .Init()
                .Start(TestingUrl);
            //regsiter a test user
            apphost.Container.Register<IAuthSession>(c => new AuthUserSession { FirstName = "test", IsAuthenticated = true }); 
        }

        public void WireUpService<T>() where T : class
        {
            //var service = apphost.Container.Resolve<T>();  //Resolve auto-wired service
            apphost.Container.AddTransient<T>();

            authenticatedRequest = new BasicRequest
            {
                Items = {
                    [Keywords.Session] = new AuthUserSession { FirstName = "test" , UserAuthId="1", IsAuthenticated = true}
                }
            };
        }

        public virtual void Dispose()
        {
            apphost.Dispose();
        }
    }

    //Create your ServiceStack AppHost with only the dependencies your tests need
    /// <summary>
    /// This class may need updates to match what is in the mvc.service apphost.cs
    /// </summary>
    public class SeflHostedAppHost : AppSelfHostBase
    {
        public IConfigurationRoot Configuration { get; set; }

        public SeflHostedAppHost() : base("Customer REST Example", typeof(StartupService).Assembly) { }

        public override void Configure(Container container)
        {
            var file = Path.GetFullPath(@"../../../../cbw.services");
            var builder = new ConfigurationBuilder().SetBasePath(file).AddJsonFile("appsettings.json").AddJsonFile("appsettings.LocalSQLServer.json", optional: true);
            Configuration = builder.Build();
            var sqlString = Configuration["ConnectionString"];

            RegisterServiceStack();
            //container.Register<ServiceStack.Data.IDbConnectionFactory>(new OrmLiteConnectionFactory(sqlString,SqlServerDialect.Provider));
            container.Register<IDbConnectionFactory>(new OrmLiteConnectionFactory(":memory:", SqliteDialect.Provider));
            container.RegisterAutoWired<DatabaseInitService>();
            var service = container.Resolve<DatabaseInitService>();

            container.Register<IAuthRepository>(c =>
                new MyOrmLiteAuthRepository(c.Resolve<IDbConnectionFactory>())
                {
                    UseDistinctRoleTables = true,
                });
            container.Resolve<IAuthRepository>().InitSchema();
            var authRepo = (OrmLiteAuthRepository)container.Resolve<IAuthRepository>();

            service.ResetDatabase();
            SessionService.ResetUsers(authRepo);
            service.InitializeTablesAndData();

            //Logging
            LogManager.LogFactory = new SerilogFactory(new LoggerConfiguration()
                .ReadFrom.Configuration(Configuration)
                .Destructure.UsingAttributes()
                .CreateLogger());
            Serilog.Debugging.SelfLog.Enable(msg => Debug.WriteLine(msg));
            Serilog.Debugging.SelfLog.Enable(Console.Error);

            ILog log = LogManager.GetLogger(MethodBase.GetCurrentMethod().DeclaringType);
            //ILog Log = LogManager.GetLogger(typeof(StartupService));

            log.InfoFormat("Applicaiton Starting {Date}", DateTime.Now);
        }

        public void RegisterServiceStack()
        {
            var licenseKeyText = "****************************";
            Licensing.RegisterLicense(licenseKeyText);
        }

    }

我的 Xunit 测试

 public class DeviceTemplateTest : ServiceTestBase
    {

        //Post Data
        //Device Sends State.XML

        [Theory]
        [InlineData("C:\DeviceTemplate.txt")]
        public void DeviceX400Test(string deviceTemaplateFile)
        {
            //Resolve auto-wired service
            WireUpService<DeviceService>();

            var parser = new FileIniDataParser();
            IniData data = parser.ReadFile(deviceTemaplateFile);

            List<AddConfig> batch = new List<AddConfig>();
            //Iterate through all the sections
            foreach (SectionData section in data.Sections)
            {
                Console.WriteLine("[" + section.SectionName + "]");

                //Iterate through all the keys in the current section
                //printing the values
                foreach (KeyData key in section.Keys)
                {
                    batch.Add(new AddConfig { ConfigName = key.KeyName, ConfigValue = key.Value, DeviceId = 0 });
                    //    using (var service = HostContext.ResolveService<DeviceService>(authenticatedRequest))
                    //{
                    //    service.Any(new AddConfig { ConfigName = key.KeyName, ConfigValue = key.Value, DeviceId = 0 });
                    //}
                }
            }

            var client = new JsonServiceClient(TestingUrl);
            var deviceConfigs = client.SendAll(batch.ToArray());
        }

    }

Answer 1

首先，您应该 never return value types in Services，您的请求 DTO 说 returns 一个 DeviceConfig 响应类型 DTO：

public class AddConfig : IReturn<DeviceConfig> { ... }

您的服务应该返回哪个。

我不清楚这是如何工作或编译的：

using (var service = HostContext.ResolveService<DeviceService>(authenticatedRequest))
{
    service.SendAll(new AddConfig { 
         ConfigName = key.KeyName, ConfigValue = key.Value, DeviceId = 0 
    });
}

因为它直接调用 DeviceService 服务 class 上的方法，而 Service class 上没有 SendAll() 方法（或者在您的示例中)，您使用的是 Service Gateway 吗？

如果没有看到完整的源代码并能够重现问题，我无法从这里判断出问题是什么，但听起来 AddConfig 未被识别为服务，它是否出现在/metadata 页？如果不是，你有它继承 Service 的 class 吗？

否则，如果您可以 post 在 GitHub 上进行最少的重现，我就能确定问题所在。

测试批量 SendAll ServiceStack

Testing Batch SendAll ServiceStack

servicestack