using event dispatcher to handle events

Author: 01Dri

src/Disc.NET/Gateway/GatewayConnection.cs

@@ -1,11 +1,10 @@
-using Disc.NET.Handlers;
+using Disc.NET.Dispatcher;
 using Disc.NET.Shared.Configurations;
 using Disc.NET.Shared.Enums;
 using Disc.NET.Shared.Extensions;
 using Disc.NET.Shared.Serializer;
 using Microsoft.Extensions.Logging;
 using System.Net.WebSockets;
-using System.Reflection.Metadata;
 using System.Text.Json;
 using System.Threading.Channels;
 
@@ -31,14 +30,17 @@ internal class GatewayConnection
         private readonly ClientWebSocket _ws = new();
         private readonly Channel<JsonDocument> _channel = Channel.CreateUnbounded<JsonDocument>();
         private readonly ILogger<GatewayConnection> _logger;
-
+        private readonly EventDispatcher _eventDispatcher;
+        private readonly AppConfiguration _appConfiguration;
         /// <summary>
         /// Initializes a new instance of the <see cref="GatewayConnection"/> class.
         /// </summary>
         /// <param name="logger">Logger instance used for structured logging and diagnostics.</param>
-        public GatewayConnection(ILogger<GatewayConnection> logger)
+        public GatewayConnection(AppConfiguration appConfiguration,ILogger<GatewayConnection> logger)
         {
+            _appConfiguration = appConfiguration;
             _logger = logger;
+            _eventDispatcher = new EventDispatcher(_appConfiguration);
         }
 
         /// <summary>
@@ -55,7 +57,7 @@ public GatewayConnection(ILogger<GatewayConnection> logger)
         /// <item>Starts concurrent loops for reading WebSocket messages and handling them asynchronously.</item>
         /// </list>
         /// </remarks>
-        public async Task ConnectAsync(AppConfiguration configuration)
+        public async Task ConnectAsync()
         {
             _logger.LogInformation("Connecting to Discord Gateway...");
 
@@ -76,7 +78,7 @@ public async Task ConnectAsync(AppConfiguration configuration)
 
             // Identify and authenticate
             _logger.LogDebug("Sending Identify payload...");
-            await SendIdentifyPayloadAsync(configuration.Token, configuration).ConfigureAwait(false);
+            await SendIdentifyPayloadAsync(_appConfiguration).ConfigureAwait(false);
             _logger.LogDebug("Identify payload sent.");
 
             // Producer: Reads WebSocket messages and writes them to a channel
@@ -138,8 +140,7 @@ public async Task ConnectAsync(AppConfiguration configuration)
                 _logger.LogDebug("Dispatching event: {Event}", eventName);
                 _logger.LogDebug("Event context: {Event}", DiscNetSerializer.GetInstance().Serialize(eventContextData));
 
-                await HandlerFactory.CreateHandlerChain(configuration).HandleAsync(eventType, eventContextData, configuration)
-                   .ConfigureAwait(false);
+                await _eventDispatcher.DispatchAsync(new EventHandlerPayload(eventType, eventContextData));
             }
         }
 
@@ -215,14 +216,14 @@ await _ws.SendAsync(
         /// <remarks>
         /// The Identify payload includes OS, device, and browser properties as required by the Discord API.
         /// </remarks>
-        private async Task SendIdentifyPayloadAsync(string token, AppConfiguration configuration)
+        private async Task SendIdentifyPayloadAsync(AppConfiguration configuration)
         {
             var identify = JsonSerializer.Serialize(new
             {
                 op = GatewayOpCode.Identify,
                 d = new
                 {
-                    token = $"Bot {token}",
+                    token = $"Bot {configuration.Token}",
                     intents = configuration.Intents.GetIntIntents(),
                     properties = new
                     {