Add Service IResults. Add DI for FactoryBufferManager. Add random to requests

Author: NiceOneFox

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

@@ -6,8 +6,19 @@ namespace Bll.Domain.Entities;
 
 public class BufferManagerFactory : IBufferManagerFactory
 {
+    private readonly IServiceProvider serviceProvider;
+
+    public BufferManagerFactory(IServiceProvider serviceProvider)
+    {
+        this.serviceProvider = serviceProvider;
+    }
+
     public IBufferManager CreateBufferManager(SimulationType simulationType)
     {
-        return new StandardBufferManager();
+        return simulationType switch
+        {
+            0 => (IBufferManager)serviceProvider.GetService(typeof(StandardBufferManager)),
+            _ => throw new NotImplementedException()
+        };
     }
 }

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

@@ -5,9 +5,18 @@ namespace Bll.Domain.Entities;
 public class DeviceManager : IDeviceManager
 {
     private readonly ITimeProvider _time;
-    public DeviceManager(ITimeProvider time)
+
+    private readonly IResults _resultChannel;
+
+    private static readonly Random _random = new();
+
+    public double Lambda { get; set; }
+    public double TimeOfDeviceWillBeFree { get; set; }
+
+    public DeviceManager(ITimeProvider time, IResults resultChannel)
     {
         _time = time;
+        _resultChannel = resultChannel;
     }
 
     public void TakeRequest(Request request, Device device)
@@ -18,15 +27,19 @@ public void TakeRequest(Request request, Device device)
         }
         device.Request = request;
 
+        TimeOfDeviceWillBeFree = _time.Now +(-1.0 / Lambda) * Math.Log(_random.NextDouble());
         //TODO COUNT TIME OF WORKING ON THAT REQUEST
     }
 
-    public bool IsFree(Device device)
+    public bool FreeDevice(Device device)
     {
-        if (device.Request?.EndTime <= _time.Now)
+        if (TimeOfDeviceWillBeFree <= _time.Now)
         {
+            device.Request.EndTime = _time.Now;
+
             device.Request = null;
             device.IsWorking = false;
+
             // TODO COUNT THAT REQUEST WHICH IS END WORKING.
         }
         return true;

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

@@ -4,10 +4,12 @@ namespace Bll.Domain.Entities;
 
 public class InputParameters
 {
-    public int NumberOfSources { get; set; }
-    public int NumberOfDevices { get; set; }
-    public int BufferSize { get; set; }
-    public int AmountOfRequests { get; set; }
-    public double ModelingTime { get; set; }
-    public SimulationType SimulationType { get; set; }
+    public int NumberOfSources { get; set; } = 3;
+    public int NumberOfDevices { get; set; } = 2;
+    public int BufferSize { get; set; } = 2;
+    public int AmountOfRequests { get; set; } = 40;
+    public double ModelingTime { get; set; } = double.MaxValue;
+    public SimulationType SimulationType { get; set; } = SimulationType.Standard;
+
+    public double Lambda { get; set; } = 3;
 }

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

@@ -1,9 +1,10 @@
-namespace Bll.Domain.Entities;
+using Bll.Domain.Interfaces;
 
-public class Results
-{
-    public List<Request> Cancelled = new();
+namespace Bll.Domain.Entities;
 
-    public List<Request> Processed = new();
+public class Results : IResults
+{
+    public List<Request> Cancelled { get; set; } = new();
+    public List<Request> Processed { get; set; } = new();
     public double ModelingTime { get; set; }
 }

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

@@ -5,15 +5,22 @@ namespace Bll.Domain.Entities;
 public class SourceManager : ISourceManager
 {
     public ITimeProvider Time { get; set; }
+    public double TimeOfNextRequest { get; set; }
+    public double Lambda { get; set; }
+
+    private static Random _random = new();
     public SourceManager(ITimeProvider time)
     {
         Time = time;
     }
 
     public Request GetNewRequest(Source source)
     {
-        var generatedRequest = new Request(source.SourceId, source.SerialNumber, Time.Now, Time.Now + 0.11);
+        TimeOfNextRequest += -(1.0 / Lambda) * Math.Log(_random.NextDouble());
+
+        var generatedRequest = new Request(source.SourceId, source.SerialNumber, TimeOfNextRequest, -1);
         source.SerialNumber++;
+
         return generatedRequest;
     }
 }

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

@@ -4,17 +4,30 @@ namespace Bll.Domain.Entities;
 
 public class StandardBufferManager : IBufferManager
 {
+   private readonly IResults _resultChannel;
+
+   private readonly ITimeProvider _time;
+
     private readonly LinkedList<Request> _requests = new();
 
     public const int Capacity = 5;
 
+    public StandardBufferManager(IResults resultChannel, ITimeProvider time)
+    {
+        _resultChannel = resultChannel;
+        _time = time;
+    }
+
     public void Add(Request request)
     {
+        _time.Now = 0.6;
         if (_requests.Count >= Capacity)
         {
             var removedRequest = _requests.Last();
             _requests.RemoveLast();
-            // TODO ADD ALL DELETED REQUESTS TO SOME LOGS OR SOURCE. variable removedRequest
+
+            removedRequest.EndTime = _time.Now;
+            _resultChannel.Cancelled.Add(removedRequest);
         }
 
         _requests.AddFirst(request);

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

@@ -4,5 +4,5 @@ namespace Bll.Domain.Entities;
 
 public class TimeProvider : ITimeProvider
 {
-    public DateTime Now { get; } = DateTime.Now;
+    public double Now { get; set; }
 }

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

@@ -5,5 +5,5 @@ namespace Bll.Domain.Interfaces;
 public interface IDeviceManager
 {
     void TakeRequest(Request request, Device device);
-    bool IsFree(Device device);
+    bool FreeDevice(Device device);
 }

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

@@ -0,0 +1,10 @@
+using Bll.Domain.Entities;
+
+namespace Bll.Domain.Interfaces;
+
+public interface IResults
+{
+    public List<Request> Cancelled { get; set; }
+    public List<Request> Processed { get; set; }
+    double ModelingTime { get; set; }
+}

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

@@ -2,5 +2,5 @@
 
 public interface ITimeProvider
 {
-    double Now { get; }
+    double Now { get; set; }
 }