diff --git a/EonaCat.LogStack/EonaCat.LogStack.csproj b/EonaCat.LogStack/EonaCat.LogStack.csproj
index d57307e..36440f3 100644
--- a/EonaCat.LogStack/EonaCat.LogStack.csproj
+++ b/EonaCat.LogStack/EonaCat.LogStack.csproj
@@ -14,7 +14,7 @@ It features a rich fluent API for routing log events to dozens of destinations f
EonaCat (Jeroen Saey)
EonaCat;Logger;EonaCatLogStack;Log;Writer;Flows;LogStack;Memory;Speed;Jeroen;Saey
- 0.1.6
+ 0.1.7
README.md
True
LICENSE
@@ -25,7 +25,7 @@ It features a rich fluent API for routing log events to dozens of destinations f
- 0.1.6+{chash:10}.{c:ymd}
+ 0.1.7+{chash:10}.{c:ymd}
true
true
v[0-9]*
@@ -36,7 +36,7 @@ It features a rich fluent API for routing log events to dozens of destinations f
- 0.1.6
+ 0.1.7
EonaCat.LogStack
EonaCat.LogStack
https://git.saey.me/EonaCat/EonaCat.LogStack
diff --git a/EonaCat.LogStack/EonaCatLoggerCore/Flows/EncryptedFileFlow.cs b/EonaCat.LogStack/EonaCatLoggerCore/Flows/EncryptedFileFlow.cs
index 6f69362..c6468b2 100644
--- a/EonaCat.LogStack/EonaCatLoggerCore/Flows/EncryptedFileFlow.cs
+++ b/EonaCat.LogStack/EonaCatLoggerCore/Flows/EncryptedFileFlow.cs
@@ -48,6 +48,7 @@ namespace EonaCat.LogStack.Flows
private readonly Thread _flushThread;
private readonly Thread _retentionThread;
private readonly Stopwatch _uptime = Stopwatch.StartNew();
+ public static event EventHandler OnException;
private struct QueueEntry
{
@@ -84,8 +85,6 @@ namespace EonaCat.LogStack.Flows
private long _totalBytesWritten;
private long _currentMemoryBytes;
- public bool IgnoreConsoleErrors { get; set; }
-
private volatile SamplingPolicy _samplingPolicy;
private volatile Action _onDrop;
private volatile Action _onRotate;
@@ -623,7 +622,7 @@ namespace EonaCat.LogStack.Flows
}
catch (Exception e)
{
- Console.WriteLine($"Exception during decryption => {e.Message}");
+ OnException?.Invoke(null, "[EncryptedFileFlow] Exception during decryption: " + e.Message);
}
return false;
}
@@ -793,7 +792,7 @@ namespace EonaCat.LogStack.Flows
}
catch (Exception ex)
{
- WriteToConsoleError("[EncryptedFileFlow] Writer error: " + ex.Message);
+ OnException?.Invoke(null, "[EncryptedFileFlow] Writer error: " + ex.Message);
}
finally
{
@@ -878,7 +877,7 @@ namespace EonaCat.LogStack.Flows
_lastError = ex;
Interlocked.Increment(ref _totalErrors);
Interlocked.Exchange(ref _lastErrorTimestamp, DateTime.UtcNow.Ticks);
- WriteToConsoleError("[EncryptedFileFlow] Write error: " + ex.Message);
+ OnException?.Invoke(null, "[EncryptedFileFlow] Write error: " + ex.Message);
}
}
}
@@ -1083,16 +1082,6 @@ namespace EonaCat.LogStack.Flows
}
}
- private void WriteToConsoleError(string text)
- {
- if (IgnoreConsoleErrors)
- {
- return;
- }
-
- Console.Error.WriteLine(text);
- }
-
private string Format(LogEvent log)
{
var sb = new StringBuilder(256);
@@ -1292,7 +1281,7 @@ namespace EonaCat.LogStack.Flows
}
catch (Exception ex)
{
- WriteToConsoleError("[EncryptedFileFlow] Retention error: " + ex.Message);
+ OnException?.Invoke(null, "[EncryptedFileFlow] Retention error: " + ex.Message);
}
}
}
@@ -1336,7 +1325,7 @@ namespace EonaCat.LogStack.Flows
}
catch (Exception ex)
{
- WriteToConsoleError("[EncryptedFileFlow] Retention error: " + ex.Message);
+ OnException?.Invoke(null, "[EncryptedFileFlow] Retention error: " + ex.Message);
}
}
diff --git a/EonaCat.LogStack/EonaCatLoggerCore/Flows/FileFlow.cs b/EonaCat.LogStack/EonaCatLoggerCore/Flows/FileFlow.cs
index 078826e..23b1cda 100644
--- a/EonaCat.LogStack/EonaCatLoggerCore/Flows/FileFlow.cs
+++ b/EonaCat.LogStack/EonaCatLoggerCore/Flows/FileFlow.cs
@@ -26,11 +26,11 @@ namespace EonaCat.LogStack.Flows
public sealed class FileFlow : FlowBase
{
public event EventHandler OnDirectoryException;
+ public event EventHandler OnException;
private const int FileBufferSize = 131072; // 128 KB
private const int WriterBufferSize = 131072; // 128 KB
private readonly int _batchSize;
private const int QueueCapacity = 8192;
- public bool IgnoreConsoleErrors { get; set; }
private static readonly Dictionary LevelStrings =
new Dictionary
@@ -208,7 +208,6 @@ namespace EonaCat.LogStack.Flows
}
catch (Exception ex)
{
- WriteToConsoleError($"[FileFlow] Critical error in directory resolution: {ex.Message}");
_directory = Path.GetTempPath();
OnDirectoryException?.Invoke(this, $"FileFlow: Critical failure in directory resolution: {ex.Message}. Falling back to temp: '{_directory}'");
}
@@ -849,7 +848,6 @@ namespace EonaCat.LogStack.Flows
}
private void WriterThreadBody()
{
- WriteToConsoleError("[FileFlow] Writer thread started");
try
{
while (!_queue.IsCompleted)
@@ -886,7 +884,7 @@ namespace EonaCat.LogStack.Flows
}
catch (Exception ex)
{
- WriteToConsoleError("[FileFlow] Writer thread error: " + ex.Message);
+ OnException?.Invoke(this, $"[FileFlow] Writer thread encountered an error: {ex.Message}");
}
finally
{
@@ -907,26 +905,6 @@ namespace EonaCat.LogStack.Flows
}
}
}
-
- private void WriteToConsoleError(string text)
- {
- if (IgnoreConsoleErrors)
- {
- return;
- }
-
- try
- {
- // Write to both stdout and stderr to ensure visibility
- Console.WriteLine(text);
- Console.Error.WriteLine(text);
- }
- catch
- {
- // Logging must never bring down the application.
- }
- }
-
private void WriteLogEvent(LogEvent log)
{
long size =0;
@@ -1034,11 +1012,6 @@ namespace EonaCat.LogStack.Flows
of.Writer.WriteLine(line);
of.Size += line.Length + Environment.NewLine.Length;
}
- else
- {
- // File handle disappeared between EnsureFileOpen and write attempt
- WriteToConsoleError("[FileFlow] File handle for '" + path + "' missing after EnsureFileOpen");
- }
}
}
}
@@ -1058,7 +1031,7 @@ namespace EonaCat.LogStack.Flows
diagnosis = " | " + Helpers.DirectoryPermissionHelper.GetAccessIssueDiagnosis(dir);
}
}
- WriteToConsoleError("[FileFlow] Write error for '" + path + "': " + ex.Message + diagnosis);
+ OnException?.Invoke(this, "[FileFlow] Write error for '" + path + "': " + ex.Message + diagnosis);
}
catch { /* Do nothing */ }
}
@@ -1083,7 +1056,7 @@ namespace EonaCat.LogStack.Flows
{
try
{
- WriteToConsoleError("[FileFlow] WriteLogEvent error: " + ex.Message);
+ OnException?.Invoke(this, "[FileFlow] WriteLogEvent error: " + ex.Message);
}
catch { /* Do nothing */ }
}
@@ -1592,7 +1565,7 @@ namespace EonaCat.LogStack.Flows
}
catch (Exception ex)
{
- WriteToConsoleError("[FileFlow] CSV header write error for '" + path + "': " + ex.Message);
+ OnException?.Invoke(this, "[FileFlow] CSV header write error for '" + path + "': " + ex.Message);
}
}
@@ -1616,7 +1589,7 @@ namespace EonaCat.LogStack.Flows
}
catch (Exception ex)
{
- WriteToConsoleError("[FileFlow] XML header write error for '" + path + "': " + ex.Message);
+ OnException?.Invoke(this, "[FileFlow] XML header write error for '" + path + "': " + ex.Message);
}
}
@@ -1646,7 +1619,7 @@ namespace EonaCat.LogStack.Flows
diagnosis = " Diagnosis: " + Helpers.DirectoryPermissionHelper.GetAccessIssueDiagnosis(dir);
}
}
- WriteToConsoleError("[FileFlow] Failed to open '" + path + "': " + ex.Message + diagnosis);
+ OnException?.Invoke(this, "[FileFlow] Failed to open '" + path + "': " + ex.Message + diagnosis);
return false;
}
}
@@ -1655,7 +1628,7 @@ namespace EonaCat.LogStack.Flows
// Outermost safety net – never let this method take down the process
try
{
- WriteToConsoleError("[FileFlow] EnsureFileOpen unhandled error: " + ex.Message);
+ OnException?.Invoke(this, "[FileFlow] EnsureFileOpen unhandled error: " + ex.Message);
}
catch { /* ignore */ }
return false;
@@ -1763,7 +1736,7 @@ namespace EonaCat.LogStack.Flows
}
catch (Exception ex)
{
- WriteToConsoleError("[FileFlow] Archive error '" + filePath + "': " + ex.Message);
+ OnException?.Invoke(this, "[FileFlow] Archive error '" + filePath + "': " + ex.Message);
return null;
}
}
@@ -1807,7 +1780,7 @@ namespace EonaCat.LogStack.Flows
try { CompressFile(path); }
catch (Exception ex)
{
- WriteToConsoleError("[FileFlow] Compress error '" + path + "': " + ex.Message);
+ OnException?.Invoke(this, "[FileFlow] Compress error '" + path + "': " + ex.Message);
}
}
}
@@ -1873,13 +1846,12 @@ namespace EonaCat.LogStack.Flows
}
catch (Exception ex)
{
- WriteToConsoleError("[FileFlow] Compressed retention error: " + ex.Message);
+ OnException?.Invoke(this, "[FileFlow] Compressed retention error: " + ex.Message);
}
}
private void PeriodicFlushLoop()
{
- WriteToConsoleError("[FileFlow] Periodic flush loop started");
try
{
while (!_isDisposing && !_cts.Token.IsCancellationRequested)
@@ -1918,13 +1890,13 @@ namespace EonaCat.LogStack.Flows
catch (ThreadInterruptedException) { break; }
catch (Exception ex)
{
- WriteToConsoleError("[FileFlow] Flush error: " + ex.Message);
+ OnException?.Invoke(this, "[FileFlow] Flush error: " + ex.Message);
}
}
}
catch (Exception ex)
{
- WriteToConsoleError("[FileFlow] PeriodicFlushLoop error: " + ex.Message);
+ OnException?.Invoke(this, "[FileFlow] PeriodicFlushLoop error: " + ex.Message);
}
}
@@ -1958,7 +1930,7 @@ namespace EonaCat.LogStack.Flows
}
catch (Exception ex)
{
- WriteToConsoleError("[FileFlow] RetentionLoop error: " + ex.Message);
+ OnException?.Invoke(this, "[FileFlow] RetentionLoop error: " + ex.Message);
}
}
@@ -2011,7 +1983,7 @@ namespace EonaCat.LogStack.Flows
}
catch (Exception ex)
{
- WriteToConsoleError("[FileFlow] Retention error: " + ex.Message);
+ OnException?.Invoke(this, "[FileFlow] Retention error: " + ex.Message);
}
}
@@ -2058,50 +2030,30 @@ namespace EonaCat.LogStack.Flows
workingDirectory = Path.Combine(AppDomain.CurrentDomain.BaseDirectory, workingDirectory.Substring(2));
}
- // Attempt 1: Use the requested directory
- WriteToConsoleError($"[FileFlow] Attempting to use log directory: {workingDirectory}");
if (Helpers.DirectoryPermissionHelper.EnsureDirectoryHierarchy(workingDirectory))
{
- WriteToConsoleError($"[FileFlow] Successfully using log directory: {workingDirectory}");
return workingDirectory;
}
- WriteToConsoleError($"[FileFlow] Failed to use log directory: {workingDirectory}. Diagnosis: {Helpers.DirectoryPermissionHelper.GetAccessIssueDiagnosis(workingDirectory)}");
-
- // Attempt 2: Try to fix permissions on the requested directory
- WriteToConsoleError($"[FileFlow] Attempting to fix permissions on: {workingDirectory}");
if (TryFixDirectoryPermissions(workingDirectory) && Helpers.DirectoryPermissionHelper.EnsureDirectoryHierarchy(workingDirectory))
{
- WriteToConsoleError($"[FileFlow] Successfully fixed permissions and using log directory: {workingDirectory}");
return workingDirectory;
}
- WriteToConsoleError($"[FileFlow] Failed to fix permissions on: {workingDirectory}");
+ string appDataDirectory = Path.Combine(Environment.GetFolderPath(Environment.SpecialFolder.ApplicationData), "EonaCat.LogStack");
- // Attempt 3: Fall back to AppData directory
- string appDataDirectory = Path.Combine(
- Environment.GetFolderPath(Environment.SpecialFolder.ApplicationData),
- "EonaCat.LogStack");
-
- WriteToConsoleError($"[FileFlow] Attempting to use AppData log directory: {appDataDirectory}");
if (Helpers.DirectoryPermissionHelper.EnsureDirectoryHierarchy(appDataDirectory))
{
- WriteToConsoleError($"[FileFlow] Successfully using AppData log directory: {appDataDirectory}");
OnDirectoryException?.Invoke(this, $"FileFlow: Could not use requested directory '{requestedDirectory}', fell back to '{appDataDirectory}'");
return appDataDirectory;
}
- WriteToConsoleError($"[FileFlow] Failed to use AppData log directory: {appDataDirectory}. Diagnosis: {Helpers.DirectoryPermissionHelper.GetAccessIssueDiagnosis(appDataDirectory)}");
-
- // Attempt 4: Fall back to TEMP directory
string tempDirectory = Path.GetTempPath();
- WriteToConsoleError($"[FileFlow] Attempting to use TEMP log directory: {tempDirectory}");
try
{
if (Helpers.DirectoryPermissionHelper.CanWrite(tempDirectory))
{
- WriteToConsoleError($"[FileFlow] Successfully using TEMP log directory: {tempDirectory}");
OnDirectoryException?.Invoke(this, $"FileFlow: Could not use requested directory '{requestedDirectory}' or AppData, fell back to TEMP directory '{tempDirectory}'");
return tempDirectory;
}
@@ -2111,8 +2063,6 @@ namespace EonaCat.LogStack.Flows
// Temp directory check failed
}
- WriteToConsoleError($"[FileFlow] Failed to use TEMP log directory: {tempDirectory}. This is a critical error - logging may not work.");
-
// Final fallback: return the temp path anyway, even if it might not work
OnDirectoryException?.Invoke(this, $"FileFlow: Critical - could not find any writable directory. Attempting to use TEMP: '{tempDirectory}'");
return tempDirectory;
@@ -2144,7 +2094,6 @@ namespace EonaCat.LogStack.Flows
// Attempt to set everyone permissions (handles all platforms)
if (Helpers.DirectoryPermissionHelper.TrySetEveryonePermissions(dirPath))
{
- WriteToConsoleError($"[FileFlow] Set permissions on: {dirPath}");
return true;
}
@@ -2157,13 +2106,12 @@ namespace EonaCat.LogStack.Flows
if ((dirInfo.Attributes & FileAttributes.ReadOnly) != 0)
{
dirInfo.Attributes &= ~FileAttributes.ReadOnly;
- WriteToConsoleError($"[FileFlow] Cleared read-only attribute on: {dirPath}");
}
return true;
}
catch (Exception ex)
{
- WriteToConsoleError($"[FileFlow] Failed to fix permissions: {ex.Message}");
+ OnException?.Invoke(this, $"[FileFlow] Failed to fix permissions: {ex.Message}");
return false;
}
}
diff --git a/EonaCat.LogStack/EonaCatLoggerCore/Flows/StatusFlow.cs b/EonaCat.LogStack/EonaCatLoggerCore/Flows/StatusFlow.cs
index c4394fb..c636760 100644
--- a/EonaCat.LogStack/EonaCatLoggerCore/Flows/StatusFlow.cs
+++ b/EonaCat.LogStack/EonaCatLoggerCore/Flows/StatusFlow.cs
@@ -43,6 +43,7 @@ namespace ServiceMonitoring
private readonly string _statusDirectory;
private readonly CancellationTokenSource _cts;
private readonly Action _statusChangeTrigger;
+ public event EventHandler OnException;
///
/// Log fileSize (default: 10 MB)
@@ -300,7 +301,7 @@ namespace ServiceMonitoring
}
catch (Exception ex)
{
- Console.WriteLine($"StatusFlow: Error writing to file: {ex.Message}");
+ OnException?.Invoke(null, $"StatusFlow: Error writing to file: {ex.Message}");
}
}
@@ -326,7 +327,7 @@ namespace ServiceMonitoring
}
catch (Exception ex)
{
- Console.WriteLine($"StatusFlow: Error handling log file rollover: {ex.Message}");
+ OnException?.Invoke(null, $"StatusFlow: Error handling log file rollover: {ex.Message}");
}
}