Fix: Handle file:// URI

Author: Randall Flagg

src/LogExpert/Classes/Log/LogfileReader.cs

@@ -20,7 +20,17 @@ public class LogfileReader : IAutoLogLineColumnizerCallback
 
         private readonly GetLogLineFx _logLineFx;
 
-        private readonly string _fileName;
+        private string FileName
+        {
+            get; init
+            {
+                var uri = new Uri(value);
+                if (uri.IsFile)
+                {
+                    field = uri.LocalPath; // Convert the URI to a local file path
+                }
+            }
+        }
         private readonly int _MAX_BUFFERS = 10;
         private readonly int _MAX_LINES_PER_BUFFER = 100;
 
@@ -63,7 +73,7 @@ public LogfileReader(string fileName, EncodingOptions encodingOptions, bool mult
                 return;
             }
 
-            _fileName = fileName;
+            FileName = fileName;
             EncodingOptions = encodingOptions;
             IsMultiFile = multiFile;
             _MAX_BUFFERS = bufferCount;
@@ -117,7 +127,7 @@ public LogfileReader(string[] fileNames, EncodingOptions encodingOptions, int bu
             }
 
             _watchedILogFileInfo = fileInfo;
-            _fileName = fileInfo.FullName;
+            FileName = fileInfo.FullName;
 
             StartGCThread();
         }
@@ -265,7 +275,7 @@ public void ReadFiles()
         /// <returns></returns>
         public int ShiftBuffers()
         {
-            _logger.Info("ShiftBuffers() begin for {0}{1}", _fileName, IsMultiFile ? " (MultiFile)" : "");
+            _logger.Info("ShiftBuffers() begin for {0}{1}", FileName, IsMultiFile ? " (MultiFile)" : "");
             AcquireBufferListWriterLock();
             int offset = 0;
             _isLineCountDirty = true;
@@ -579,7 +589,7 @@ await Task.Run(() =>
                 long oldSize = 0;
                 try
                 {
-                    OnLoadingStarted(new LoadFileEventArgs(_fileName, 0, false, 0, false));
+                    OnLoadingStarted(new LoadFileEventArgs(FileName, 0, false, 0, false));
                     ReadFiles();
                     if (!_isDeleted)
                     {
@@ -593,25 +603,57 @@ await Task.Run(() =>
                 }
             });
 
-            _watcher = new FileSystemWatcher
-            {
-                NotifyFilter = //NotifyFilters.Attributes
-                               //| NotifyFilters.CreationTime
-                               //| NotifyFilters.DirectoryName
-                               //|
-                                 NotifyFilters.FileName
-                                 //| NotifyFilters.LastAccess
-                                 | NotifyFilters.LastWrite
-                                 //| NotifyFilters.Security
-                                 | NotifyFilters.Size,
-
-                Path = Path.GetDirectoryName(_fileName) ?? throw new ArgumentException("Invalid file path"),
-                Filter = Path.GetFileName(_fileName), // Sets filter to the specific 
-                EnableRaisingEvents = true
+            try
+            {
+                _watcher = new FileSystemWatcher
+                {
+                    NotifyFilter = //NotifyFilters.Attributes
+                                   //| NotifyFilters.CreationTime
+                                   //| NotifyFilters.DirectoryName
+                                   //|
+                                     NotifyFilters.FileName
+                                     //| NotifyFilters.LastAccess
+                                     | NotifyFilters.LastWrite
+                                     //| NotifyFilters.Security
+                                     | NotifyFilters.Size,
+
+                    Path = Path.GetDirectoryName(FileName) ?? throw new ArgumentException("Invalid file path"),
+                    Filter = Path.GetFileName(FileName), // Sets filter to the specific 
+                    EnableRaisingEvents = true
+                };
+            }
+            catch (UnauthorizedAccessException ex)
+            {
+                Console.WriteLine($"Access denied: {ex.Message}");
+            }
+            catch (ArgumentException ex)
+            {
+                Console.WriteLine($"Invalid argument: {ex.Message}");
+            }
+            catch (Exception ex)
+            {
+                Console.WriteLine($"An error occurred: {ex.Message}");
+            }
+
+            _watcher.Error += (sender, e) =>
+            {
+                Console.WriteLine($"Error occurred: {e.GetException().Message}");
+                Task.Delay(5000).ContinueWith(_ =>
+                {
+                    try
+                    {
+                        Console.WriteLine("Attempting to restart the watcher...");
+                        _watcher.EnableRaisingEvents = true;
+                    }
+                    catch (Exception ex)
+                    {
+                        Console.WriteLine($"Failed to restart the watcher: {ex.Message}");
+                    }
+                });
             };
             _watcher.Changed += OnFileChanged;
             _watcher.Created += OnCreated;
-            _watcher.Deleted += OnFileDeleted; 
+            _watcher.Deleted += OnFileDeleted;
             _watcher.Renamed += OnFileRenamed;
             _watcher.Error += OnFileError;
 
@@ -651,7 +693,8 @@ private void OnFileChanged(object sender, FileSystemEventArgs e)
             {
                 MonitoredFileNotFound();
             }
-            catch (Exception ex) { 
+            catch (Exception ex)
+            {
                 throw new NotImplementedException();
             }
         }
@@ -708,11 +751,11 @@ public void DeleteAllContent()
         {
             if (_contentDeleted)
             {
-                _logger.Debug("Buffers for {0} already deleted.", Util.GetNameFromPath(_fileName));
+                _logger.Debug("Buffers for {0} already deleted.", Util.GetNameFromPath(FileName));
                 return;
             }
 
-            _logger.Info("Deleting all log buffers for {0}. Used mem: {1:N0}", Util.GetNameFromPath(_fileName), GC.GetTotalMemory(true)); //TODO [Z] uh GC collect calls creepy
+            _logger.Info("Deleting all log buffers for {0}. Used mem: {1:N0}", Util.GetNameFromPath(FileName), GC.GetTotalMemory(true)); //TODO [Z] uh GC collect calls creepy
             AcquireBufferListWriterLock();
             _lruCacheDictLock.AcquireWriterLock(Timeout.Infinite);
             _disposeLock.AcquireWriterLock(Timeout.Infinite);
@@ -779,7 +822,7 @@ internal void LogBufferInfoForLine(int lineNum)
             if (buffer == null)
             {
                 ReleaseBufferListReaderLock();
-                _logger.Error("Cannot find buffer for line {0}, file: {1}{2}", lineNum, _fileName, IsMultiFile ? " (MultiFile)" : "");
+                _logger.Error("Cannot find buffer for line {0}, file: {1}{2}", lineNum, FileName, IsMultiFile ? " (MultiFile)" : "");
                 return;
             }
 
@@ -804,7 +847,7 @@ internal void LogBufferDiagnostic()
             _lruCacheDictLock.ReleaseReaderLock();
 
             AcquireBufferListReaderLock();
-            _logger.Info("File: {0}\r\nBuffer count: {1}\r\nDisposed buffers: {2}", _fileName, _bufferList.Count, _bufferList.Count - cacheCount);
+            _logger.Info("File: {0}\r\nBuffer count: {1}\r\nDisposed buffers: {2}", FileName, _bufferList.Count, _bufferList.Count - cacheCount);
             int lineNum = 0;
             long disposeSum = 0;
             long maxDispose = 0;
@@ -860,7 +903,7 @@ private Task<ILogLine> GetLogLineInternal(int lineNum)
             if (logBuffer == null)
             {
                 ReleaseBufferListReaderLock();
-                _logger.Error("Cannot find buffer for line {0}, file: {1}{2}", lineNum, _fileName, IsMultiFile ? " (MultiFile)" : "");
+                _logger.Error("Cannot find buffer for line {0}, file: {1}{2}", lineNum, FileName, IsMultiFile ? " (MultiFile)" : "");
                 return null;
             }
 
@@ -1225,7 +1268,7 @@ private void GarbageCollectLruCache()
 #if DEBUG
                 if (diff > 0)
                 {
-                    _logger.Info("Removing {0} entries from LRU cache for {1}", diff, Util.GetNameFromPath(_fileName));
+                    _logger.Info("Removing {0} entries from LRU cache for {1}", diff, Util.GetNameFromPath(FileName));
                 }
 #endif
                 SortedList<long, int> useSorterList = [];
@@ -1573,7 +1616,7 @@ private void FileChanged()
             long newSize = _fileLength;
             //if (this.currFileSize != newSize)
             {
-                _logger.Info("file size changed. new size={0}, file: {1}", newSize, _fileName);
+                _logger.Info("file size changed. new size={0}, file: {1}", newSize, FileName);
                 FireChangeEvent();
             }
         }
@@ -1596,7 +1639,7 @@ private void FireChangeEvent()
                     {
                         // ReloadBufferList();  // removed because reloading is triggered by owning LogWindow
                         // Trigger "new file" handling (reload)
-                        OnLoadFile(new LoadFileEventArgs(_fileName, 0, true, _fileLength, true));
+                        OnLoadFile(new LoadFileEventArgs(FileName, 0, true, _fileLength, true));
 
                         if (_isDeleted)
                         {

src/LogExpert/LogExpert.csproj

@@ -19,6 +19,7 @@
     <ApplicationHighDpiMode>PerMonitorV2</ApplicationHighDpiMode>
     <ForceDesignerDPIUnaware>true</ForceDesignerDPIUnaware>
     <NoWarn>CS1591;</NoWarn>
+    <LangVersion>preview</LangVersion>
   </PropertyGroup>
   <PropertyGroup Condition="'$(Configuration)|$(Platform)'=='Debug|AnyCPU'">
     <Optimize>False</Optimize>