Build

Author: artemiusgreat

Core/Core.Tests/SiloBuilder.cs

@@ -1,7 +1,6 @@
 using Core.Models;
 using Core.Services;
 using Microsoft.Extensions.Configuration;
-using Microsoft.Extensions.DependencyInjection;
 using Orleans.Hosting;
 using Orleans.Providers;
 using Orleans.Serialization;

Gateways/Simulation/Tests/PositionsGrainTests.cs

@@ -1,3 +1,4 @@
+using Core.Conventions;
 using Core.Enums;
 using Core.Grains;
 using Core.Models;
@@ -52,8 +53,10 @@ public void StoreException()
     [Fact]
     public async Task Store()
     {
+      var descriptor = Descriptor;
       var stamp = DateTime.Now.Ticks;
-      var grain = _cluster.GrainFactory.GetGrain<IPositionsGrain>(Descriptor);
+      var grain = _cluster.GrainFactory.GetGrain<IPositionsGrain>(descriptor);
+      var actionsGrain = _cluster.GrainFactory.GetGrain<ITransactionsGrain>(descriptor);
       var order = new Order
       {
         Amount = 1,
@@ -76,6 +79,15 @@ public async Task Store()
         }
       };
 
+      var observer = new Mock<ITradeObserver>();
+      var observerReference = _cluster.Client.CreateObjectReference<ITradeObserver>(observer.Object);
+
+      observer
+        .Setup(o => o.StreamOrder(It.IsAny<Order>()))
+        .Verifiable();
+
+      await actionsGrain.Setup(observerReference);
+
       // Open
 
       var openPosition = await grain.Send(order);