Merge pull request #6 from TimetableDesigner/dev

Dev

.github/workflows/push_main.yml

@@ -4,8 +4,8 @@ on:
   push:
     branches:
       - "main"
-    #paths:
+    paths:
-      #- "TimetableDesigner.Backend.Events**"
+      - "TimetableDesigner.Backend.Events**"
 
 jobs:
   build:

TimetableDesigner.Backend.Events/EventQueue.cs

@@ -2,7 +2,16 @@
 
 namespace TimetableDesigner.Backend.Events;
 
-public abstract class EventQueue
+public abstract class EventQueue<TSelf> where TSelf : EventQueue<TSelf>
 {
-    public abstract void Setup(IServiceCollection services);
+    public void Setup<TBuilder>(IServiceCollection services, TBuilder configuration)
+        where TBuilder : EventQueueBuilder<TSelf> =>
+        Setup(services, configuration.GetConnectionParameters());
+
+    public void Setup(IServiceCollection services, string connectionString)
+        => Setup(services, connectionString.Split(';')
+                                                             .Select(x => x.Split('='))
+                                                             .ToDictionary(x => x.First(), x => x.Last()));
+
+    protected abstract void Setup(IServiceCollection services, IDictionary<string, string> connectionParameters);
 }

TimetableDesigner.Backend.Events/EventQueueBuilder.cs

@@ -0,0 +1,6 @@
+namespace TimetableDesigner.Backend.Events;
+
+public abstract class EventQueueBuilder<TQueue> where TQueue : EventQueue<TQueue>
+{
+    public abstract IDictionary<string, string> GetConnectionParameters();
+}

TimetableDesigner.Backend.Events/IEventQueuePublisher.cs

@@ -1,6 +1,10 @@
-namespace TimetableDesigner.Backend.Events;
+using System.Text.Json;
+using System.Text.Json.Nodes;
+
+namespace TimetableDesigner.Backend.Events;
 
 public interface IEventQueuePublisher
 {
-    public Task PublishAsync<T>(T data) where T : class;
+    public sealed Task PublishAsync<T>(T data) where T : class => PublishAsync(JsonSerializer.Serialize(data), data.GetType());
+    public Task PublishAsync(string data, Type dataType);
 }