Log persistence connection

kbilsted · Feb 7, 2024 · f4b3bb4 · f4b3bb4
1 parent cbebca1
commit f4b3bb4
Show file tree

Hide file tree

Showing 4 changed files with 11 additions and 1 deletion.
diff --git a/src/Product/GreenFeetWorkFlow.AdoPersistence/AdoDb.cs b/src/Product/GreenFeetWorkFlow.AdoPersistence/AdoDb.cs
@@ -1,6 +1,7 @@
 using GreenFeetWorkflow;
 using Microsoft.Data.SqlClient;
 using System.Data;
+using System.Text.RegularExpressions;
 
 namespace GreenFeetWorkFlow.AdoMsSql;
 
@@ -47,6 +48,8 @@ public object CreateTransaction()
         return transaction;
     }
 
+    public string GetConnectionInfoForLogging() => "SqlServer persister: " + Regex.Replace(connectionString, "Password=[^;]*", "");
+
     public T InTransaction<T>(Func<T> code, object? outsideTransaction = null)
     {
         try

diff --git a/src/Product/GreenFeetWorkFlow/DemoImplementations/DemoInMemoryPersister.cs b/src/Product/GreenFeetWorkFlow/DemoImplementations/DemoInMemoryPersister.cs
@@ -116,6 +116,8 @@ public void SetTransaction(object transaction)
     {
     }
 
+    public string GetConnectionInfoForLogging() => "InMemory Demo Persister";
+
     public T InTransaction<T>(Func<T> code, object? transaction = null)
     {
         return code();

diff --git a/src/Product/GreenFeetWorkFlow/Interfaces.cs b/src/Product/GreenFeetWorkFlow/Interfaces.cs
@@ -32,6 +32,8 @@ public interface IWorkflowIocContainer
 /// </summary>
 public interface IStepPersister : IDisposable
 {
+    string GetConnectionInfoForLogging();
+
     T InTransaction<T>(Func<T> code, object? transaction = null);
     object CreateTransaction();
     /// <summary> You can either set the transaction explicitly or create one using <see cref="CreateTransaction"/> </summary>

diff --git a/src/Product/GreenFeetWorkFlow/WorkflowEngine.cs b/src/Product/GreenFeetWorkFlow/WorkflowEngine.cs
@@ -43,7 +43,10 @@ static string MakeEngineName()
     void Init(WorkflowConfiguration configuration, string? engineName, CancellationToken? token)
     {
         if (logger.InfoLoggingEnabled)
-            logger.LogInfo($"{nameof(WorkflowEngine)}: starting engine {engineName}", null, null);
+        {
+            logger.LogInfo($"{nameof(WorkflowEngine)}: starting engine: {engineName}", null, null);
+            logger.LogInfo($"{nameof(WorkflowEngine)}: starting persister connection: {iocContainer.GetInstance<IStepPersister>().GetConnectionInfoForLogging()}", null, null);
+        }
 
         Configuration = configuration;
         configuration.LoggerConfiguration = logger.Configuration;