Use file scoped namespaces

.editorconfig

@@ -12,6 +12,7 @@ indent_size = 4
 
 [*.cs]
 indent_size = 4
+csharp_style_namespace_declarations = file_scoped:warning
 
 [*.json]
 indent_size = 2

examples/ConsumeAndMultiOutputPublisherWithRabbitMQ/Model/InputMessage.cs

@@ -1,8 +1,7 @@
-namespace ConsumeAndMultiOutputPublisherWithRabbitMQ.Model
+namespace ConsumeAndMultiOutputPublisherWithRabbitMQ.Model;
+
+public record InputMessage
 {
-    public record InputMessage
-    {
-        public string FancyText { get; set; } = "FooBar";
-        public int FancyNumber { get; set; } = 42;
-    }
+    public string FancyText { get; set; } = "FooBar";
+    public int FancyNumber { get; set; } = 42;
 }

examples/ConsumeAndMultiOutputPublisherWithRabbitMQ/Model/OutputMessage.cs

@@ -1,8 +1,7 @@
-namespace ConsumeAndMultiOutputPublisherWithRabbitMQ.Model
+namespace ConsumeAndMultiOutputPublisherWithRabbitMQ.Model;
+
+public record OutputMessage
 {
-    public record OutputMessage
-    {
-        public string NotSoFancyText { get; set; }
-        public int NotSoFancyNumber { get; set; }
-    }
+    public string NotSoFancyText { get; set; }
+    public int NotSoFancyNumber { get; set; }
 }

examples/ConsumeAndMultiOutputPublisherWithRabbitMQ/MultiOutputService.cs

@@ -8,48 +8,47 @@
 using Motor.Extensions.Hosting.Abstractions;
 using Motor.Extensions.Hosting.CloudEvents;
 
-namespace ConsumeAndMultiOutputPublisherWithRabbitMQ
+namespace ConsumeAndMultiOutputPublisherWithRabbitMQ;
+
+public class MultiOutputService : IMultiOutputService<InputMessage, OutputMessage>
 {
-    public class MultiOutputService : IMultiOutputService<InputMessage, OutputMessage>
+    // Handle incoming messages
+    public async IAsyncEnumerable<MotorCloudEvent<OutputMessage>> ConvertMessageAsync(
+        MotorCloudEvent<InputMessage> inputEvent, [EnumeratorCancellation] CancellationToken token = default)
     {
-        // Handle incoming messages
-        public async IAsyncEnumerable<MotorCloudEvent<OutputMessage>> ConvertMessageAsync(
-            MotorCloudEvent<InputMessage> inputEvent, [EnumeratorCancellation] CancellationToken token = default)
-        {
-            // Get the input message from the cloud event
-            var input = inputEvent.TypedData;
+        // Get the input message from the cloud event
+        var input = inputEvent.TypedData;
 
-            // Do your magic here .....
-            var output = MagicFuncAsync(input);
+        // Do your magic here .....
+        var output = MagicFuncAsync(input);
 
-            // Create a new cloud event from your output message which is automatically published and return a new task.
-            await foreach (var outputMessage in output.WithCancellation(token))
-            {
-                yield return inputEvent.CreateNew(outputMessage);
-            }
+        // Create a new cloud event from your output message which is automatically published and return a new task.
+        await foreach (var outputMessage in output.WithCancellation(token))
+        {
+            yield return inputEvent.CreateNew(outputMessage);
         }
+    }
 
-        private static async IAsyncEnumerable<OutputMessage> MagicFuncAsync(InputMessage input)
+    private static async IAsyncEnumerable<OutputMessage> MagicFuncAsync(InputMessage input)
+    {
+        if (string.IsNullOrEmpty(input.FancyText))
         {
-            if (string.IsNullOrEmpty(input.FancyText))
-            {
-                // Reject message in RabbitMQ queue (Any ArgumentException can be used to reject to messages.).
-                throw new ArgumentNullException("FancyText is empty");
-            }
+            // Reject message in RabbitMQ queue (Any ArgumentException can be used to reject to messages.).
+            throw new ArgumentNullException("FancyText is empty");
+        }
 
-            // Magic async function.
-            await Task.Delay(10).ConfigureAwait(false);
+        // Magic async function.
+        await Task.Delay(10).ConfigureAwait(false);
 
-            yield return new()
-            {
-                NotSoFancyText = input.FancyText.Reverse().ToString(),
-                NotSoFancyNumber = input.FancyNumber * -1,
-            };
-            yield return new()
-            {
-                NotSoFancyText = input.FancyText,
-                NotSoFancyNumber = input.FancyNumber * -2,
-            };
-        }
+        yield return new()
+        {
+            NotSoFancyText = input.FancyText.Reverse().ToString(),
+            NotSoFancyNumber = input.FancyNumber * -1,
+        };
+        yield return new()
+        {
+            NotSoFancyText = input.FancyText,
+            NotSoFancyNumber = input.FancyNumber * -2,
+        };
     }
 }

examples/ConsumeAndPublishWithKafka/Model/InputMessage.cs

@@ -1,8 +1,7 @@
-namespace ConsumeAndPublishWithKafka.Model
+namespace ConsumeAndPublishWithKafka.Model;
+
+public record InputMessage
 {
-    public record InputMessage
-    {
-        public string FancyText { get; set; } = "FooBar";
-        public int FancyNumber { get; set; } = 42;
-    }
+    public string FancyText { get; set; } = "FooBar";
+    public int FancyNumber { get; set; } = 42;
 }

examples/ConsumeAndPublishWithKafka/Model/OutputMessage.cs

@@ -1,8 +1,7 @@
-namespace ConsumeAndPublishWithKafka.Model
+namespace ConsumeAndPublishWithKafka.Model;
+
+public record OutputMessage
 {
-    public record OutputMessage
-    {
-        public string NotSoFancyText { get; set; }
-        public int NotSoFancyNumber { get; set; }
-    }
+    public string NotSoFancyText { get; set; }
+    public int NotSoFancyNumber { get; set; }
 }

examples/ConsumeAndPublishWithKafka/SingleOutputService.cs

@@ -6,40 +6,39 @@
 using Motor.Extensions.Hosting.Abstractions;
 using Motor.Extensions.Hosting.CloudEvents;
 
-namespace ConsumeAndPublishWithKafka
+namespace ConsumeAndPublishWithKafka;
+
+public class SingleOutputService : ISingleOutputService<InputMessage, OutputMessage>
 {
-    public class SingleOutputService : ISingleOutputService<InputMessage, OutputMessage>
+    // Handle incoming messages
+    public Task<MotorCloudEvent<OutputMessage>> ConvertMessageAsync(
+        MotorCloudEvent<InputMessage> inputEvent,
+        CancellationToken token = default)
     {
-        // Handle incoming messages
-        public Task<MotorCloudEvent<OutputMessage>> ConvertMessageAsync(
-            MotorCloudEvent<InputMessage> inputEvent,
-            CancellationToken token = default)
-        {
-            // Get the input message from the cloud event
-            var input = inputEvent.TypedData;
+        // Get the input message from the cloud event
+        var input = inputEvent.TypedData;
 
-            // Do your magic here .....
-            var output = MagicFunc(input);
+        // Do your magic here .....
+        var output = MagicFunc(input);
 
-            // Create a new cloud event from your output message which is automatically published and return a new task.
-            var outputEvent = inputEvent.CreateNew(output);
-            return Task.FromResult(outputEvent);
-        }
+        // Create a new cloud event from your output message which is automatically published and return a new task.
+        var outputEvent = inputEvent.CreateNew(output);
+        return Task.FromResult(outputEvent);
+    }
 
-        private static OutputMessage MagicFunc(InputMessage input)
+    private static OutputMessage MagicFunc(InputMessage input)
+    {
+        if (string.IsNullOrEmpty(input.FancyText))
         {
-            if (string.IsNullOrEmpty(input.FancyText))
-            {
-                // Reject message in RabbitMQ queue (Any ArgumentException can be used to reject to messages.).
-                throw new ArgumentNullException("FancyText is empty");
-            }
-
-            var output = new OutputMessage
-            {
-                NotSoFancyText = input.FancyText.Reverse().ToString(),
-                NotSoFancyNumber = input.FancyNumber * -1,
-            };
-            return output;
+            // Reject message in RabbitMQ queue (Any ArgumentException can be used to reject to messages.).
+            throw new ArgumentNullException("FancyText is empty");
         }
+
+        var output = new OutputMessage
+        {
+            NotSoFancyText = input.FancyText.Reverse().ToString(),
+            NotSoFancyNumber = input.FancyNumber * -1,
+        };
+        return output;
     }
 }

examples/ConsumeAndPublishWithRabbitMQ/Model/InputMessage.cs

@@ -1,8 +1,7 @@
-namespace ConsumeAndPublishWithRabbitMQ.Model
+namespace ConsumeAndPublishWithRabbitMQ.Model;
+
+public record InputMessage
 {
-    public record InputMessage
-    {
-        public string FancyText { get; set; } = "FooBar";
-        public int FancyNumber { get; set; } = 42;
-    }
+    public string FancyText { get; set; } = "FooBar";
+    public int FancyNumber { get; set; } = 42;
 }

examples/ConsumeAndPublishWithRabbitMQ/Model/OutputMessage.cs

@@ -1,8 +1,7 @@
-namespace ConsumeAndPublishWithRabbitMQ.Model
+namespace ConsumeAndPublishWithRabbitMQ.Model;
+
+public record OutputMessage
 {
-    public record OutputMessage
-    {
-        public string NotSoFancyText { get; set; }
-        public int NotSoFancyNumber { get; set; }
-    }
+    public string NotSoFancyText { get; set; }
+    public int NotSoFancyNumber { get; set; }
 }

examples/ConsumeAndPublishWithRabbitMQ/SingleOutputService.cs

@@ -6,40 +6,39 @@
 using Motor.Extensions.Hosting.Abstractions;
 using Motor.Extensions.Hosting.CloudEvents;
 
-namespace ConsumeAndPublishWithRabbitMQ
+namespace ConsumeAndPublishWithRabbitMQ;
+
+public class SingleOutputService : ISingleOutputService<InputMessage, OutputMessage>
 {
-    public class SingleOutputService : ISingleOutputService<InputMessage, OutputMessage>
+    // Handle incoming messages
+    public Task<MotorCloudEvent<OutputMessage>> ConvertMessageAsync(
+        MotorCloudEvent<InputMessage> inputEvent,
+        CancellationToken token = default)
     {
-        // Handle incoming messages
-        public Task<MotorCloudEvent<OutputMessage>> ConvertMessageAsync(
-            MotorCloudEvent<InputMessage> inputEvent,
-            CancellationToken token = default)
-        {
-            // Get the input message from the cloud event
-            var input = inputEvent.TypedData;
+        // Get the input message from the cloud event
+        var input = inputEvent.TypedData;
 
-            // Do your magic here .....
-            var output = MagicFunc(input);
+        // Do your magic here .....
+        var output = MagicFunc(input);
 
-            // Create a new cloud event from your output message which is automatically published and return a new task.
-            var outputEvent = inputEvent.CreateNew(output);
-            return Task.FromResult(outputEvent);
-        }
+        // Create a new cloud event from your output message which is automatically published and return a new task.
+        var outputEvent = inputEvent.CreateNew(output);
+        return Task.FromResult(outputEvent);
+    }
 
-        private static OutputMessage MagicFunc(InputMessage input)
+    private static OutputMessage MagicFunc(InputMessage input)
+    {
+        if (string.IsNullOrEmpty(input.FancyText))
         {
-            if (string.IsNullOrEmpty(input.FancyText))
-            {
-                // Reject message in RabbitMQ queue (Any ArgumentException can be used to reject to messages.).
-                throw new ArgumentNullException("FancyText is empty");
-            }
-
-            var output = new OutputMessage
-            {
-                NotSoFancyText = input.FancyText.Reverse().ToString(),
-                NotSoFancyNumber = input.FancyNumber * -1,
-            };
-            return output;
+            // Reject message in RabbitMQ queue (Any ArgumentException can be used to reject to messages.).
+            throw new ArgumentNullException("FancyText is empty");
         }
+
+        var output = new OutputMessage
+        {
+            NotSoFancyText = input.FancyText.Reverse().ToString(),
+            NotSoFancyNumber = input.FancyNumber * -1,
+        };
+        return output;
     }
 }

examples/ConsumeNATS/Model/NatsMessage.cs

@@ -1,11 +1,10 @@
 using System;
 using System.Text.Json.Serialization;
 
-namespace ConsumeNATS.Model
+namespace ConsumeNATS.Model;
+
+public class NatsMessage
 {
-    public class NatsMessage
-    {
-        [JsonPropertyName("SomeProperty")] public string SomeProperty { get; set; }
-        [JsonPropertyName("Time")] public DateTime Time { get; set; }
-    }
+    [JsonPropertyName("SomeProperty")] public string SomeProperty { get; set; }
+    [JsonPropertyName("Time")] public DateTime Time { get; set; }
 }

examples/ConsumeNATS/NoOutputService.cs

@@ -4,14 +4,13 @@
 using Motor.Extensions.Hosting.Abstractions;
 using Motor.Extensions.Hosting.CloudEvents;
 
-namespace ConsumeNATS
+namespace ConsumeNATS;
+
+public class NoOutputService : INoOutputService<NatsMessage>
 {
-    public class NoOutputService : INoOutputService<NatsMessage>
+    public Task<ProcessedMessageStatus> HandleMessageAsync(MotorCloudEvent<NatsMessage> dataCloudEvent, CancellationToken token = new())
     {
-        public Task<ProcessedMessageStatus> HandleMessageAsync(MotorCloudEvent<NatsMessage> dataCloudEvent, CancellationToken token = new())
-        {
-            System.Console.WriteLine(dataCloudEvent.TypedData.SomeProperty);
-            return Task.FromResult(ProcessedMessageStatus.Success);
-        }
+        System.Console.WriteLine(dataCloudEvent.TypedData.SomeProperty);
+        return Task.FromResult(ProcessedMessageStatus.Success);
     }
 }

examples/ConsumeSQS/Model/InputMessage.cs

@@ -1,8 +1,7 @@
-namespace ConsumeSQS.Model
+namespace ConsumeSQS.Model;
+
+public record InputMessage
 {
-    public record InputMessage
-    {
-        public string FancyText { get; set; } = "FooBar";
-        public int FancyNumber { get; set; } = 42;
-    }
+    public string FancyText { get; set; } = "FooBar";
+    public int FancyNumber { get; set; } = 42;
 }

examples/ConsumeSQS/NoOutputService.cs

@@ -5,16 +5,15 @@
 using Motor.Extensions.Hosting.Abstractions;
 using Motor.Extensions.Hosting.CloudEvents;
 
-namespace ConsumeSQS
+namespace ConsumeSQS;
+
+public class NoOutputService : INoOutputService<InputMessage>
 {
-    public class NoOutputService : INoOutputService<InputMessage>
-    {
 
-        public Task<ProcessedMessageStatus> HandleMessageAsync(MotorCloudEvent<InputMessage> dataCloudEvent, CancellationToken token = default)
-        {
-            var msg = dataCloudEvent?.TypedData;
-            Console.WriteLine(msg);
-            return Task.FromResult(ProcessedMessageStatus.Success);
-        }
+    public Task<ProcessedMessageStatus> HandleMessageAsync(MotorCloudEvent<InputMessage> dataCloudEvent, CancellationToken token = default)
+    {
+        var msg = dataCloudEvent?.TypedData;
+        Console.WriteLine(msg);
+        return Task.FromResult(ProcessedMessageStatus.Success);
     }
 }