Use source generator

.github/workflows/ci.yml

@@ -16,7 +16,7 @@ jobs:
     timeout-minutes: 10
     strategy:
       matrix:
-        os: [windows-latest]
+        os: [ubuntu-latest]
     steps:
       - uses: actions/checkout@v3
       - name: Setup .NET
@@ -27,6 +27,10 @@ jobs:
         run: dotnet build -c Release
       - name: Test
         run: dotnet test -c Release --no-build --verbosity normal
+      - name: Ensure Generated Code Committed
+        shell: bash  
+        run: |
+          git diff --ignore-space-at-eol --ignore-cr-at-eol --exit-code
 
   release:
     name: Create Release

Kafka.Protocol.Generator.Helpers/Definitions/ErrorCode.cs

@@ -5,6 +5,6 @@ public class ErrorCode
         public string Error { get; internal set; }
         public int Code { get; internal set; }
         public bool Retriable { get; internal set; }
-        public string Description { get; internal set; }
+        public string? Description { get; internal set; }
     }
 }

Kafka.Protocol.Generator.Helpers/Definitions/Messages/EnumerableMessageExtensions.cs

@@ -25,44 +25,47 @@ public static bool TryGetResponseMessageDefinitionFrom(
         }
 
         public static IEnumerable<Message> AddReferencesToFields(
-            this IEnumerable<Message> messageDefinitions)
+            this IEnumerable<Message> messageDefinitions) =>
+            messageDefinitions
+                .Select(messageDefinition => 
+                    messageDefinition.AddReferencesToFields());
+
+        public static Message AddReferencesToFields(
+            this Message messageDefinition)
         {
-            foreach (var messageDefinition in messageDefinitions)
+            foreach (var field in messageDefinition.Fields)
             {
-                foreach (var field in messageDefinition.Fields)
-                {
-                    field.Message = messageDefinition;
-                    AddReferenceToField(field);
-                }
+                field.Message = messageDefinition;
+                AddReferenceToField(field);
+            }
 
-                if (messageDefinition.CommonStructs != null)
+            if (messageDefinition.CommonStructs != null)
+            {
+                foreach (var commonStruct in messageDefinition.CommonStructs)
                 {
-                    foreach (var commonStruct in messageDefinition.CommonStructs)
+                    commonStruct.Message = messageDefinition;
+                    foreach (var field in commonStruct.Fields)
                     {
-                        commonStruct.Message = messageDefinition;
-                        foreach (var field in commonStruct.Fields)
-                        {
-                            AddReferenceToField(field);
-                        }
+                        AddReferenceToField(field);
                     }
                 }
+            }
 
-                void AddReferenceToField(Field field, Field? parent = null)
-                {
-                    field.Message = messageDefinition;
-                    field.Parent = parent;
-                    if (field.Fields == null)
-                    {
-                        return;
-                    }
+            return messageDefinition;
 
-                    foreach (var child in field.Fields)
-                    {
-                        AddReferenceToField(child, field);
-                    }
+            void AddReferenceToField(Field field, Field? parent = null)
+            {
+                field.Message = messageDefinition;
+                field.Parent = parent;
+                if (field.Fields == null)
+                {
+                    return;
                 }
 
-                yield return messageDefinition;
+                foreach (var child in field.Fields)
+                {
+                    AddReferenceToField(child, field);
+                }
             }
         }
     }

Kafka.Protocol.Generator.Helpers/Definitions/PrimitiveType.cs

@@ -3,6 +3,6 @@
     public class PrimitiveType
     {
         public string Type { get; internal set; }
-        public string Description { get; internal set; }
+        public string? Description { get; internal set; }
     }
 }