Skip to content

Commit

Permalink
Merge pull request #7047 from Particular/backport-7042-to-7-8
Browse files Browse the repository at this point in the history
FileShareDataBusImplementation throws a FileNotFoundException when sending databus messages from Windows to Linux
  • Loading branch information
abparticular authored May 31, 2024
2 parents e2a99a3 + 59fe14c commit 96b60e8
Showing 1 changed file with 27 additions and 1 deletion.
28 changes: 27 additions & 1 deletion src/NServiceBus.Core/DataBus/FileShareDataBusImplementation.cs
Original file line number Diff line number Diff line change
Expand Up @@ -8,6 +8,32 @@ namespace NServiceBus

class FileShareDataBusImplementation : IDataBus
{
// to account for mixed platforms ie windows -> linux or linux -> windows
internal class PathNormalizer
{
// Example keys
// string key1 = "foldername/filename";
// string key2 = "foldername\\filename";

// Normalize the keys
// string normalizedKey1 = NormalizePath(key1);
// string normalizedKey2 = NormalizePath(key2);

// Output the normalized keys
// Console.WriteLine(normalizedKey1); // Output will be "foldername\filename" on Windows, "foldername/filename" on Unix-based systems
// Console.WriteLine(normalizedKey2); // Output will be "foldername\filename" on Windows, "foldername/filename" on Unix-based systems
internal static string NormalizePath(string key)
{
// Determine the directory separator for the current platform
char separator = Path.DirectorySeparatorChar;
// Replace any forward slashes (common in URIs) and backward slashes with the platform-specific separator
string normalizedPath = key.Replace('/', separator).Replace('\\', separator);

return normalizedPath;
}
}


public FileShareDataBusImplementation(string basePath)
{
this.basePath = basePath;
Expand All @@ -17,7 +43,7 @@ public FileShareDataBusImplementation(string basePath)

public Task<Stream> Get(string key)
{
var filePath = Path.Combine(basePath, key);
var filePath = Path.Combine(basePath, PathNormalizer.NormalizePath(key));

logger.DebugFormat("Opening stream from '{0}'.", filePath);

Expand Down

0 comments on commit 96b60e8

Please sign in to comment.