file-share-databus sample improvements back port (#7561)

Author: cquirosj

samples/databus/file-share-databus/Core_8/Receiver/Program.cs

@@ -1,4 +1,5 @@
 using NServiceBus;
+using Shared;
 using System;
 using System.Threading.Tasks;
 
@@ -9,7 +10,8 @@ static async Task Main()
         Console.Title = "Receiver";
         var endpointConfiguration = new EndpointConfiguration("Samples.DataBus.Receiver");
         var dataBus = endpointConfiguration.UseDataBus<FileShareDataBus, SystemJsonDataBusSerializer>();
-        dataBus.BasePath(@"..\..\..\..\storage");
+        var storagePath = new SolutionDirectoryFinder().GetDirectory("storage");
+        dataBus.BasePath(storagePath);
         endpointConfiguration.UsePersistence<LearningPersistence>();
         endpointConfiguration.UseSerialization<XmlSerializer>();
         endpointConfiguration.UseTransport(new LearningTransport());

samples/databus/file-share-databus/Core_8/Sender/Program.cs

@@ -1,9 +1,12 @@
 using NServiceBus;
+using Shared;
 using System;
 using System.Threading.Tasks;
 
 class Program
 {
+    static string storagePath = new SolutionDirectoryFinder().GetDirectory("storage");
+    
     static async Task Main()
     {
         Console.Title = "Sender";
@@ -12,7 +15,7 @@ static async Task Main()
         #region ConfigureDataBus
 
         var dataBus = endpointConfiguration.UseDataBus<FileShareDataBus, SystemJsonDataBusSerializer>();
-        dataBus.BasePath(@"..\..\..\..\storage");
+        dataBus.BasePath(storagePath);
 
         #endregion
 
@@ -59,7 +62,7 @@ static async Task SendMessageLargePayload(IEndpointInstance endpointInstance)
 
         #endregion
 
-        Console.WriteLine(@"Message sent, the payload is stored in: ..\..\..\storage");
+        Console.WriteLine($"Message sent, the payload is stored in: {storagePath}");
     }
 
     static async Task SendMessageTooLargePayload(IEndpointInstance endpointInstance)

samples/databus/file-share-databus/Core_8/Shared/SolutionDirectoryFinder.cs

@@ -0,0 +1,41 @@
+using System;
+using System.IO;
+using System.Linq;
+
+namespace Shared
+{
+    public class SolutionDirectoryFinder
+    {
+        public string Root { get; }
+
+        public SolutionDirectoryFinder(string root) => Root = root;
+
+        public SolutionDirectoryFinder()
+        {
+            var directory = AppContext.BaseDirectory;
+
+            while (true)
+            {
+                if (Directory.EnumerateFiles(directory).Any(file => file.EndsWith(".sln")))
+                {
+                    Root = directory;
+                    return;
+                }
+
+                var parent = Directory.GetParent(directory) ?? throw new Exception(
+                    "Couldn't find the solution directory for the ClaimCheck storage. " +
+                    "If the endpoint is outside the solution folder structure, " +
+                    "make sure to specify a storage directory using an absolute path.");
+
+                directory = parent.FullName;
+            }
+        }
+
+        public string GetDirectory(string relativePath)
+        {
+            var fullPath = Path.GetFullPath(Path.Combine(Root, relativePath));
+            Directory.CreateDirectory(fullPath);
+            return fullPath;
+        }
+    }
+}