GitAuto: [FEATURE] Add Saga capability

Src/CrispyWaffle/Commands/CommandsConsumer.cs

@@ -1,4 +1,5 @@
 using System.Threading.Tasks;
+using CrispyWaffle.Sagas;
 using CrispyWaffle.Composition;
 using CrispyWaffle.Log;
 

Src/CrispyWaffle/Events/EventsConsumer.cs

@@ -1,53 +1,54 @@
-using System.Threading.Tasks;
-using CrispyWaffle.Composition;
-using CrispyWaffle.Log;
-
-namespace CrispyWaffle.Events
-{
-    /// <summary>
-    /// Manage events raising
-    /// </summary>
-    public static class EventsConsumer
-    {
-        /// <summary>
-        /// Raises the specified event.
-        /// </summary>
-        /// <typeparam name="TEvent">The type of the event.</typeparam>
-        /// <param name="event">The event.</param>
-        public static void Raise<TEvent>(TEvent @event)
-            where TEvent : IEvent
-        {
-            var handlers = ServiceLocator.ResolveAll<IEventHandler<TEvent>>();
-
-            foreach (var handler in handlers)
-            {
-                LogConsumer.Trace(
-                    $"Calling {handler.GetType().FullName} for event {@event.GetType().FullName}"
-                );
-
-                handler.Handle(@event);
-            }
-        }
-
-        /// <summary>
-        /// Raises the specified event asynchronously.
-        /// </summary>
-        /// <typeparam name="TEvent">The type of the event.</typeparam>
-        /// <param name="event">The event.</param>
-        public static async Task RaiseAsync<TEvent>(TEvent @event)
-            where TEvent : IEvent
-        {
-            await Task.Run(() =>
-            {
-                var handlers = ServiceLocator.ResolveAll<IEventHandlerAsync<TEvent>>();
-                foreach (var handler in handlers)
-                {
-                    LogConsumer.Trace(
-                        $"Calling {handler.GetType().FullName} for event {@event.GetType().FullName}"
-                    );
-                    handler.HandleAsync(@event);
-                }
-            });
-        }
-    }
-}
+using System.Threading.Tasks;
+using CrispyWaffle.Sagas;
+using CrispyWaffle.Composition;
+using CrispyWaffle.Log;
+
+namespace CrispyWaffle.Events
+{
+    /// <summary>
+    /// Manage events raising
+    /// </summary>
+    public static class EventsConsumer
+    {
+        /// <summary>
+        /// Raises the specified event.
+        /// </summary>
+        /// <typeparam name="TEvent">The type of the event.</typeparam>
+        /// <param name="event">The event.</param>
+        public static void Raise<TEvent>(TEvent @event)
+            where TEvent : IEvent
+        {
+            var handlers = ServiceLocator.ResolveAll<IEventHandler<TEvent>>();
+
+            foreach (var handler in handlers)
+            {
+                LogConsumer.Trace(
+                    $"Calling {handler.GetType().FullName} for event {@event.GetType().FullName}"
+                );
+
+                handler.Handle(@event);
+            }
+        }
+
+        /// <summary>
+        /// Raises the specified event asynchronously.
+        /// </summary>
+        /// <typeparam name="TEvent">The type of the event.</typeparam>
+        /// <param name="event">The event.</param>
+        public static async Task RaiseAsync<TEvent>(TEvent @event)
+            where TEvent : IEvent
+        {
+            await Task.Run(() =>
+            {
+                var handlers = ServiceLocator.ResolveAll<IEventHandlerAsync<TEvent>>();
+                foreach (var handler in handlers)
+                {
+                    LogConsumer.Trace(
+                        $"Calling {handler.GetType().FullName} for event {@event.GetType().FullName}"
+                    );
+                    handler.HandleAsync(@event);
+                }
+            });
+        }
+    }
+}

Src/CrispyWaffle/Sagas/GenericSagaHandler.cs

@@ -0,0 +1,23 @@
+namespace CrispyWaffle.Sagas;
+
+public abstract class GenericSagaHandler : ISagaHandler
+{
+    public abstract void Handle<T>(T message);
+
+    public abstract void HandleTimeout<T>(T message);
+
+    protected void StartSaga<T>(T message)
+    {
+        // Logic to start a saga
+    }
+
+    protected void UpdateSagaState<T>(T message)
+    {
+        // Logic to update saga state
+    }
+
+    protected void CompleteSaga()
+    {
+        // Logic to complete a saga
+    }
+}

Src/CrispyWaffle/Sagas/ISaga.cs

@@ -0,0 +1,6 @@
+namespace CrispyWaffle.Sagas;
+
+public interface ISaga
+{
+    Guid SagaId { get; }
+}

Src/CrispyWaffle/Sagas/ISagaData.cs

@@ -0,0 +1,6 @@
+namespace CrispyWaffle.Sagas;
+
+public interface ISagaData
+{
+    Guid SagaId { get; set; }
+}

Src/CrispyWaffle/Sagas/ISagaHandler.cs

@@ -0,0 +1,7 @@
+namespace CrispyWaffle.Sagas;
+
+public interface ISagaHandler
+{
+    void Handle<T>(T message);
+    void HandleTimeout<T>(T message);
+}

Src/CrispyWaffle/Sagas/SagaData.cs

@@ -0,0 +1,15 @@
+namespace CrispyWaffle.Sagas;
+
+public class SagaData : ISagaData
+{
+    public Guid SagaId { get; set; }
+    public string State { get; set; }
+    public DateTime CreatedAt { get; set; }
+    // Additional properties as needed
+
+    public SagaData()
+    {
+        SagaId = Guid.NewGuid();
+        CreatedAt = DateTime.UtcNow;
+    }
+}

Src/CrispyWaffle/Sagas/SagaRepository.cs

@@ -0,0 +1,22 @@
+namespace CrispyWaffle.Sagas;
+
+public class SagaRepository
+{
+    private readonly Dictionary<Guid, SagaData> _storage = new Dictionary<Guid, SagaData>();
+
+    public void Save(SagaData sagaData)
+    {
+        _storage[sagaData.SagaId] = sagaData;
+    }
+
+    public SagaData Load(Guid sagaId)
+    {
+        _storage.TryGetValue(sagaId, out var sagaData);
+        return sagaData;
+    }
+
+    public void Delete(Guid sagaId)
+    {
+        _storage.Remove(sagaId);
+    }
+}