Merge pull request #57 from tbdrake/enable-nullable-in-ping-pong

Enable <Nullable> in PingPonger.csproj and address warnings

Author: nojaf

PingPonger/PingPonger.csproj

@@ -3,6 +3,7 @@
   <PropertyGroup>
     <OutputType>Exe</OutputType>
     <TargetFramework>net9.0</TargetFramework>
+    <Nullable>enable</Nullable>
   </PropertyGroup>
   <ItemGroup>
     <PackageReference Include="Serilog.Sinks.ColoredConsole" Version="3.0.1"/>

PingPonger/Program.cs

@@ -21,11 +21,11 @@ internal class Options
 
         [Option('i', "ip", Required = false,
                 HelpText = "IP to send to")]
-        public string IP { get; set; }
+        public string? IP { get; set; }
 
         [Option('l', "url", Required = false,
         HelpText = "URL to send to")]
-        public string Url { get; set; }
+        public string? Url { get; set; }
 
         [Option('p', "port", Required = false,
                 HelpText = "the Port to send to")]
@@ -60,7 +60,7 @@ public static int Main(string[] args)
 
                 logConfig.WriteTo.ColoredConsole();
 
-                if (options.Url.Length > 0)
+                if (options.Url?.Length > 0)
                 {
                     if (options.UDP)
                     {
@@ -71,10 +71,9 @@ public static int Main(string[] args)
                         logConfig.WriteTo.TCPSink(options.Url, options.Port, null, null, new LogstashJsonFormatter());
                     }
                 }
-                else if (options.IP.Length > 0)
+                else if (options.IP?.Length > 0)
                 {
-                    IPAddress ipAddress;
-                    if (!IPAddress.TryParse(options.IP, out ipAddress))
+                    if (!IPAddress.TryParse(options.IP, out var ipAddress))
                     {
                         Console.WriteLine("Could not parse " + options.IP + " as an IP address");
                         return 1;

Serilog.Sinks.Network/Sinks/TCP/TCPSocketWriter.cs

@@ -206,7 +206,7 @@ private async Task Run(Func<Task<Stream?>> tryOpenStream)
             }
         }
 
-        private async Task FlushQueue(string entry)
+        private async Task FlushQueue(string? entry)
         {
             while (_eventQueue.Count > 0)
             {
@@ -285,7 +285,7 @@ public class ExponentialBackoffTcpReconnectionPolicy
     {
         private const int Ceiling = 10 * 60; // 10 minutes in seconds
 
-        public static async Task<Stream> ConnectAsync(Func<Uri, Task<Stream>> connect, Uri host,
+        public static async Task<Stream?> ConnectAsync(Func<Uri, Task<Stream>> connect, Uri host,
             CancellationToken cancellationToken)
         {
             int delay = 1; // in seconds