Implement custom events (#113)

* Implement custom events

* Add a test

Author: KubaZ2

Directory.Build.props

@@ -4,7 +4,7 @@
     <TargetFramework>net8.0</TargetFramework>
     <ImplicitUsings>enable</ImplicitUsings>
     <Nullable>enable</Nullable>
-    <LangVersion>latest</LangVersion>
+    <LangVersion>preview</LangVersion>
     <AllowUnsafeBlocks>true</AllowUnsafeBlocks>
     <IsAotCompatible>true</IsAotCompatible>
     <NoWarn>1591</NoWarn>

Documentation/Directory.Build.props

@@ -3,7 +3,7 @@
   <PropertyGroup>
     <TargetFramework>net8.0</TargetFramework>
     <ImplicitUsings>enable</ImplicitUsings>
-    <LangVersion>latest</LangVersion>
+    <LangVersion>preview</LangVersion>
     <Nullable>enable</Nullable>
     <AssemblyName>MyBot</AssemblyName>
     <RootNamespace>MyBot</RootNamespace>

NetCord.slnx

@@ -71,9 +71,10 @@
     <File Path="SourceGenerators/Directory.Build.targets" />
     <Project Path="SourceGenerators/MethodsForPropertiesGenerator/MethodsForPropertiesGenerator.csproj" />
     <Project Path="SourceGenerators/RestClientMethodAliasesGenerator/RestClientMethodAliasesGenerator.csproj" />
-    <Project Path="SourceGenerators/ShardedGatewayClientEventsGenerator/ShardedGatewayClientEventsGenerator.csproj" Id="cb9012b4-aed0-4ab9-b182-aa167bdb9b96" />
+    <Project Path="SourceGenerators/ShardedGatewayClientEventsGenerator/ShardedGatewayClientEventsGenerator.csproj" />
     <Project Path="SourceGenerators/Shared/Shared.csproj" />
     <Project Path="SourceGenerators/UserAgentHeaderGenerator/UserAgentHeaderGenerator.csproj" />
+    <Project Path="SourceGenerators/WebSocketClientEventsGenerator/WebSocketClientEventsGenerator.csproj" />
   </Folder>
   <Folder Name="/Tests/">
     <File Path="Tests/Directory.Build.props" />

NetCord/Gateway/GatewayClient.cs

@@ -11,12 +11,12 @@
 
 namespace NetCord.Gateway.Voice;
 
-public class VoiceClient : WebSocketClient
+public partial class VoiceClient : WebSocketClient
 {
-    public event Func<VoiceReceiveEventArgs, ValueTask>? VoiceReceive;
-    public event Func<ValueTask>? Ready;
-    public event Func<UserConnectEventArgs, ValueTask>? UserConnect;
-    public event Func<UserDisconnectEventArgs, ValueTask>? UserDisconnect;
+    public partial event Func<VoiceReceiveEventArgs, ValueTask>? VoiceReceive;
+    public partial event Func<ValueTask>? Ready;
+    public partial event Func<UserConnectEventArgs, ValueTask>? UserConnect;
+    public partial event Func<UserDisconnectEventArgs, ValueTask>? UserDisconnect;
 
     public ulong UserId { get; }
 
@@ -192,7 +192,7 @@ void GetIpAndPort(out string ip, out ushort port)
                     var sessionDescription = payload.Data.GetValueOrDefault().ToObject(Serialization.Default.JsonSessionDescription);
                     _encryption!.SetKey(sessionDescription.SecretKey);
                     InvokeLog(LogMessage.Info("Ready"));
-                    var readyTask = InvokeEventAsync(Ready);
+                    var readyTask = InvokeEventAsync(_ready);
 
                     state.IndicateReady(connectionState);
 
@@ -237,13 +237,13 @@ void GetIpAndPort(out string ip, out ushort port)
             case VoiceOpcode.ClientConnect:
                 {
                     var json = payload.Data.GetValueOrDefault().ToObject(Serialization.Default.JsonClientConnect);
-                    await InvokeEventAsync(UserConnect, new UserConnectEventArgs(json.UserIds)).ConfigureAwait(false);
+                    await InvokeEventAsync(_userConnect, new UserConnectEventArgs(json.UserIds)).ConfigureAwait(false);
                 }
                 break;
             case VoiceOpcode.ClientDisconnect:
                 {
                     var json = payload.Data.GetValueOrDefault().ToObject(Serialization.Default.JsonClientDisconnect);
-                    await InvokeEventAsync(UserDisconnect, new(json.UserId), args =>
+                    await InvokeEventAsync(_userDisconnect, new(json.UserId), args =>
                     {
                         var userId = args.UserId;
                         var cache = Cache;
@@ -259,12 +259,12 @@ void GetIpAndPort(out string ip, out ushort port)
         }
     }
 
-    internal ValueTask InvokeVoiceReceiveAsync(VoiceReceiveEventArgs data) => InvokeEventAsync(VoiceReceive, data);
+    internal ValueTask InvokeVoiceReceiveAsync(VoiceReceiveEventArgs data) => InvokeEventAsync(_voiceReceive, data);
 
     private async void HandleDatagramReceive(UdpReceiveResult obj)
     {
-        var @event = VoiceReceive;
-        if (@event is not null)
+        var handlers = _voiceReceive;
+        if (!handlers.IsEmpty)
         {
             try
             {