Data Layer: added saving diagnostic data to file.

Author: peetery

Data/DataAPI.cs

@@ -5,7 +5,26 @@ namespace Data
 {
     internal class DataLayer : DataAPI
     {
+        private static readonly SemaphoreSlim _fileSemaphore = new SemaphoreSlim(1, 1);
+
         public DataLayer() { }
+
+        public override async Task LogDiagnosticDataAsync(string data)
+        {
+            string filePath = "diagnostic_log.json";
+            await _fileSemaphore.WaitAsync();
+            try
+            {
+                using (StreamWriter writer = new StreamWriter(filePath, true))
+                {
+                    await writer.WriteLineAsync(data);
+                }
+            }
+            finally
+            {
+                _fileSemaphore.Release();
+            }
+        }
     }
 
     public abstract class DataAPI
@@ -24,5 +43,7 @@ public virtual Table getTableData(int width, int height)
         {
             return new Table(width, height);
         }
+
+        public abstract Task LogDiagnosticDataAsync(string data);
     }
 }

Logic/LogicAPI.cs

@@ -2,6 +2,7 @@
 using System;
 using System.Collections.ObjectModel;
 using System.Numerics;
+using System.Text.Json;
 using System.Threading;
 
 namespace Logic
@@ -30,11 +31,11 @@ public override void RunSimulation()
 
             foreach (BallLogic ball in balls)
             {
-                Task task = Task.Run(() =>
+                Task task = Task.Run(async () =>
                 {
                     barrier.SignalAndWait();
                     var timer = new System.Timers.Timer();
-                    timer.Elapsed += (_, elapsedArgs) =>
+                    timer.Elapsed += async (_, elapsedArgs) =>
                     {
                         if (token.IsCancellationRequested)
                         {
@@ -43,6 +44,8 @@ public override void RunSimulation()
                             return;
                         }
 
+                        List<string> logsToSave = new List<string>();
+
                         lock (balls)
                         {
                             ball.setPosition();
@@ -55,9 +58,24 @@ public override void RunSimulation()
                                 else if (ball.ballCollision(otherBall))
                                 {
                                     ball.handleBallColission(otherBall);
+                                    // Logowanie kolizji
+                                    var logData = new
+                                    {
+                                        Event = "Collision",
+                                        Ball1 = ball,
+                                        Ball2 = otherBall,
+                                        Timestamp = DateTime.UtcNow
+                                    };
+                                    string jsonData = JsonSerializer.Serialize(logData);
+                                    logsToSave.Add(jsonData);
                                 }
                             }
                         }
+
+                        foreach (var log in logsToSave)
+                        {
+                            await _dataAPI.LogDiagnosticDataAsync(log);
+                        }
                     };
                     timer.Interval = 8.8888; // 1/113Hz
                     timer.Enabled = true;