Disable projections in Api tests

src/Admin/NCafe.Admin.Api/Program.cs

@@ -11,7 +11,7 @@
 
 // Add services to the container.
 builder.Services.AddEventStoreRepository(builder.Configuration)
-                .AddEventStoreProjectionService<Product>()
+                .AddEventStoreProjectionService<Product>(builder.Configuration)
                 .AddInMemoryReadModelRepository<Product>()
                 .AddHostedService<ProductProjectionService>();
 

src/Admin/NCafe.Admin.Api/appsettings.json

@@ -8,5 +8,8 @@
   "AllowedHosts": "*",
   "ConnectionStrings": {
     "EventStore": "esdb://localhost:2113?tls=false"
+  },
+  "EventStore": {
+    "EnableProjections": "true"
   }
 }

src/Admin/NCafe.Admin.Domain.Tests/Commands/CreateProductTests.cs

@@ -59,6 +59,6 @@ public async Task GivenValidProductInformation_ShouldCreateAndStoreProduct()
 
         // Assert
         A.CallTo(() => _repository.Save(A<Product>.That.Matches(p => p.Name == command.Name && p.Price == command.Price)))
-            .MustHaveHappenedOnceExactly(); ;
+            .MustHaveHappenedOnceExactly();
     }
 }

src/Barista/NCafe.Barista.Api/Program.cs

@@ -21,7 +21,7 @@
 
 // Add services to the container.
 builder.Services.AddEventStoreRepository(builder.Configuration)
-                .AddEventStoreProjectionService<BaristaOrder>()
+                .AddEventStoreProjectionService<BaristaOrder>(builder.Configuration)
                 .AddInMemoryReadModelRepository<BaristaOrder>()
                 .AddHostedService<BaristaOrderProjectionService>();
 

src/Barista/NCafe.Barista.Api/appsettings.json

@@ -10,6 +10,9 @@
     "EventStore": "esdb://localhost:2113?tls=false",
     "RabbitMq": "host=localhost;username=myuser;password=mypassword"
   },
+  "EventStore": {
+    "EnableProjections": "true"
+  },
   "RabbitMq": {
     "queuePrefix": "barista-service"
   }

src/Cashier/NCafe.Cashier.Api.Tests/CashierWebApplicationFactory.cs

@@ -4,6 +4,7 @@
 using Microsoft.Extensions.DependencyInjection;
 using NCafe.Cashier.Domain.ReadModels;
 using NCafe.Core.MessageBus;
+using NCafe.Core.Projections;
 using NCafe.Core.ReadModels;
 using NCafe.Core.Repositories;
 
@@ -15,6 +16,7 @@ public class CashierWebApplicationFactory<TProgram>
     private readonly IRepository _repository;
     private readonly IReadModelRepository<Product> _productRepository;
     private readonly IBusPublisher _busPublisher;
+    private readonly IProjectionService<Product> _productProjectionService;
 
     public IRepository FakeRepository => _repository;
     public IReadModelRepository<Product> FakeProductRepository => _productRepository;
@@ -25,10 +27,12 @@ public CashierWebApplicationFactory()
         _repository = A.Fake<IRepository>();
         _productRepository = A.Fake<IReadModelRepository<Product>>();
         _busPublisher = A.Fake<IBusPublisher>();
+        _productProjectionService = A.Fake<IProjectionService<Product>>();
     }
 
     protected override void ConfigureWebHost(IWebHostBuilder builder)
     {
+        Environment.SetEnvironmentVariable("EventStore__EnableProjections", "false");
         Environment.SetEnvironmentVariable("RabbitMq__InitializeExchange", "false");
 
         builder.ConfigureServices(services =>
@@ -45,9 +49,14 @@ protected override void ConfigureWebHost(IWebHostBuilder builder)
                 d => d.ServiceType == typeof(IBusPublisher));
             services.Remove(busPublisherDescriptor!);
 
+            var productProjectionServiceDescriptor = services.SingleOrDefault(
+                d => d.ServiceType == typeof(IProjectionService<Product>));
+            services.Remove(productProjectionServiceDescriptor!);
+
             services.AddSingleton(_repository);
             services.AddSingleton(_productRepository);
             services.AddSingleton(_busPublisher);
+            services.AddSingleton(_productProjectionService);
         });
 
         builder.UseEnvironment("Tests");

src/Cashier/NCafe.Cashier.Api.Tests/PlaceOrderTests.cs

@@ -1,5 +1,6 @@
 using FakeItEasy;
 using NCafe.Cashier.Domain.Entities;
+using NCafe.Cashier.Domain.Messages;
 using Shouldly;
 using System.Net;
 using System.Net.Http.Json;
@@ -28,5 +29,8 @@ public async Task PlaceOrder_ShouldReturnAcceptedStatus()
 
         // Assert
         response.StatusCode.ShouldBe(HttpStatusCode.Accepted);
+
+        A.CallTo(() => _factory.FakeBusPublisher.Publish(A<OrderPlacedMessage>.That.Matches(p => p.Id == orderId)))
+            .MustHaveHappenedOnceExactly();
     }
 }

src/Cashier/NCafe.Cashier.Api/Program.cs

@@ -13,7 +13,7 @@
 
 // Add services to the container.
 builder.Services.AddEventStoreRepository(builder.Configuration)
-                .AddEventStoreProjectionService<Product>()
+                .AddEventStoreProjectionService<Product>(builder.Configuration)
                 .AddInMemoryReadModelRepository<Product>()
                 .AddHostedService<ProductProjectionService>();
 

src/Cashier/NCafe.Cashier.Api/appsettings.json

@@ -10,6 +10,9 @@
     "EventStore": "esdb://localhost:2113?tls=false",
     "RabbitMq": "amqp://myuser:mypassword@localhost:5672"
   },
+  "EventStore": {
+    "EnableProjections": "true"
+  },
   "RabbitMq": {
     "ExchangeName": "cashier",
     "InitializeExchange": "true"

src/Common/NCafe.Infrastructure/DependencyRegistration.cs

@@ -30,10 +30,15 @@ public static IServiceCollection AddEventStoreRepository(this IServiceCollection
         return services;
     }
 
-    public static IServiceCollection AddEventStoreProjectionService<TModel>(this IServiceCollection services)
+    public static IServiceCollection AddEventStoreProjectionService<TModel>(this IServiceCollection services, IConfiguration configuration)
         where TModel : ReadModel
     {
-        return services.AddSingleton<IProjectionService<TModel>, EventStoreProjectionService<TModel>>();
+        if (configuration.GetValue("EventStore:EnableProjections", false))
+        {
+            services.AddSingleton<IProjectionService<TModel>, EventStoreProjectionService<TModel>>();
+        }
+
+        return services;
     }
 
     public static IServiceCollection AddRabbitMqPublisher(this IServiceCollection services, IConfiguration configuration)