Add ResultManager. Modify Factory

Author: NiceOneFox

backend/ServiceSimulation/Bll.Domain/Bll.Domain.csproj

@@ -6,4 +6,9 @@
     <Nullable>enable</Nullable>
   </PropertyGroup>
 
+  <ItemGroup>
+    <PackageReference Include="Castle.Core" Version="4.4.1" />
+    <PackageReference Include="Microsoft.Extensions.DependencyInjection.Abstractions" Version="6.0.0" />
+  </ItemGroup>
+
 </Project>

backend/ServiceSimulation/Bll.Domain/Entities/BufferManagerFactory.cs

@@ -1,23 +1,33 @@
 using Api.enums;
 using Bll.Domain.Factories;
 using Bll.Domain.Interfaces;
+using Castle.DynamicProxy;
+using Microsoft.Extensions.DependencyInjection;
 
 namespace Bll.Domain.Entities;
 
 public class BufferManagerFactory : IBufferManagerFactory
 {
-    private readonly IServiceProvider serviceProvider;
+    private readonly IServiceProvider _serviceProvider;
 
     public BufferManagerFactory(IServiceProvider serviceProvider)
     {
-        this.serviceProvider = serviceProvider;
+        _serviceProvider = serviceProvider;
     }
 
-    public IBufferManager CreateBufferManager(SimulationType simulationType)
+    public IBufferManager CreateBufferManager(SimulationType simulationType) // TODO PASS MORE PARAMETERS. SIZE BUFFER
     {
+       // var a = ActivatorUtilities.CreateInstance<IBufferManager>(_serviceProvider, 
+       //     new StandardBufferManager(_serviceProvider.GetRequiredService<IResults>(),
+        //        _serviceProvider.GetRequiredService<ITimeProvider>(), 5));
+        
         return simulationType switch
         {
-            0 => (IBufferManager)serviceProvider.GetService(typeof(StandardBufferManager)),
+            0 => new StandardBufferManager(_serviceProvider.GetRequiredService<IResults>(), _serviceProvider.GetRequiredService<ITimeProvider>(), 5),
+            //0 => (IBufferManager)_serviceProvider.GetRequiredService(typeof(StandardBufferManager)),
+            //0 => Activator.CreateInstance<IBufferManager>(nameof(StandardBufferManager), 5),// (IBufferManager)_serviceProvider.GetService(typeof(StandardBufferManager)),
+            // 0 => ActivatorUtilities.CreateInstance<IBufferManager>(_serviceProvider,
+            //    new StandardBufferManager(_serviceProvider.GetRequiredService<IResults>(), _serviceProvider.GetRequiredService<ITimeProvider>())),
             _ => throw new NotImplementedException()
         };
     }

backend/ServiceSimulation/Bll.Domain/Entities/ResultManager.cs

@@ -0,0 +1,21 @@
+using Bll.Domain.Interfaces;
+
+namespace Bll.Domain.Entities;
+
+public class ResultManager : IResultManager
+{
+    public double AverageProbabilityOfMaintenance(int amountOfServedRequests, int totalAmountOfRequests)
+    {
+        return amountOfServedRequests / (double)totalAmountOfRequests;
+    }
+
+    public double BandwidthOfSystem(int amountOfServedRequests, double modelingTime)
+    {
+        return amountOfServedRequests / modelingTime;
+    }
+
+    public double ProbabilityOfFailure(int amountOfDeclinedRequests, int totalAmountOfRequests)
+    {
+        return amountOfDeclinedRequests / (double)totalAmountOfRequests;
+    }
+}

backend/ServiceSimulation/Bll.Domain/Entities/StandardBufferManager.cs

@@ -4,18 +4,19 @@ namespace Bll.Domain.Entities;
 
 public class StandardBufferManager : IBufferManager
 {
-   private readonly IResults _resultChannel;
+    private readonly IResults _resultChannel;
 
-   private readonly ITimeProvider _time;
+    private readonly ITimeProvider _time;
 
     private readonly LinkedList<Request> _requests = new();
 
-    public const int Capacity = 5;
+    public int Capacity = 4;
 
-    public StandardBufferManager(IResults resultChannel, ITimeProvider time)
+    public StandardBufferManager(IResults resultChannel, ITimeProvider time, int capacity)
     {
         _resultChannel = resultChannel;
         _time = time;
+        Capacity = capacity;
     }
 
     public void Add(Request request)

backend/ServiceSimulation/Bll.Domain/Interfaces/IResultManager.cs

@@ -0,0 +1,19 @@
+namespace Bll.Domain.Interfaces;
+
+public interface IResultManager
+{
+    /// <summary>
+    /// P = N served / N total
+    /// </summary>
+    double AverageProbabilityOfMaintenance(int amountOfServedRequests, int totalAmountOfRequests);
+
+    /// <summary>
+    /// A = N served / T modeling
+    /// </summary>
+    double BandwidthOfSystem(int amountOfServedRequests, double modelingTime);
+
+    /// <summary>
+    /// P failire of request = N declined / N total
+    /// </summary>
+    double ProbabilityOfFailure(int amountOfDeclinedRequests, int totalAmountOfRequests);
+}

backend/ServiceSimulation/Bll.Domain/Services/SimulationService.cs

@@ -22,8 +22,8 @@ public SimulationService(ISourceManager sourceManager, IDeviceManager deviceMana
 
     public void StartSimulation(InputParameters parameters)
     {
-        List<Source> sources = new List<Source>(parameters.NumberOfSources);
-        List<Device> devices = new List<Device>(parameters.NumberOfDevices);
+        var sources = new List<Source>(parameters.NumberOfSources);
+        var devices = new List<Device>(parameters.NumberOfDevices);
 
         for (int i = 0; i < parameters.NumberOfSources; i++)
         {
@@ -50,7 +50,7 @@ public void StartSimulation(InputParameters parameters)
         }
 
         var bufferManager = _bufferManagerFactory.CreateBufferManager(parameters.SimulationType);
-
+        
         foreach (var source in sources) // Generate first requests that generated by sources.
         {
             _sourceManager.GetNewRequest(source);
@@ -60,7 +60,8 @@ public void StartSimulation(InputParameters parameters)
         {
             if (_results.AmountOfGeneratedRequests >= parameters.AmountOfRequests &&
                 bufferManager.IsFree() &&
-                IsAllDevicesFree(devices))
+                IsAllDevicesFree(devices) &&
+                _results.AmountOfServedRequest == parameters.AmountOfRequests) // TODO CHECK FOR REQUESTS ON SOURCES. WHEN TO END SYSTEM MODELING
             {
                 break;
             }
@@ -131,7 +132,15 @@ private void FindNextSpecialEvent(List<Device> devices, List<Source> sources, IB
 
     }
 
-    public bool IsAllDevicesFree(List<Device> devices) =>
-        devices.Any(d => d.IsWorking);
-
+    public bool IsAllDevicesFree(List<Device> devices)
+    {
+        foreach (var device in devices)
+        {
+            if (device.IsWorking)
+            {
+                return false;
+            }
+        }
+        return true;
+    }
 }

backend/ServiceSimulation/WebApplication2/Api.csproj

@@ -13,6 +13,7 @@
   <ItemGroup>
     <Folder Include="Controllers\" />
     <Folder Include="Models\" />
+    <Folder Include="Entities\" />
   </ItemGroup>
 
   <ItemGroup>

backend/ServiceSimulation/WebApplication2/Program.cs

@@ -14,15 +14,18 @@
 
 builder.Services.AddScoped<ITimeProvider, TimeProvider>();
 builder.Services.AddScoped<IResults, Bll.Domain.Entities.Results>();
+builder.Services.AddScoped<IResultManager, ResultManager>();
 //builder.Services.AddTransient<IBufferManager, StandardBufferManager>();
 builder.Services.AddTransient<IBufferManagerFactory, BufferManagerFactory>();
 builder.Services.AddTransient<IDeviceManager, DeviceManager>();
 builder.Services.AddTransient<ISourceManager, SourceManager>();
 
 
-builder.Services.AddScoped<StandardBufferManager>()
-    .AddScoped<IBufferManager, StandardBufferManager>(s => s.GetService<StandardBufferManager>());
+//builder.Services.AddScoped<StandardBufferManager>()
+//    .AddScoped<IBufferManager, StandardBufferManager>(s => s.GetRequiredService<StandardBufferManager>());
 
+//builder.Services.AddScoped<IBufferManager>(s =>
+//    ActivatorUtilities.CreateInstance<StandardBufferManager>(s));
 #endregion
 
 var app = builder.Build();