From 33a4ec076abe1b698bdfc6ce7fded42f077d61a4 Mon Sep 17 00:00:00 2001
From: Chris Philips <the.avid.engineer@outlook.com>
Date: Fri, 15 Jul 2022 12:56:34 -0700
Subject: [PATCH] feat: more logs

log when transaction starts, commits, aborts
---
 src/EntityDb.MongoDb/Sessions/MongoSession.cs | 26 ++++++++++++++++++-
 1 file changed, 25 insertions(+), 1 deletion(-)

diff --git a/src/EntityDb.MongoDb/Sessions/MongoSession.cs b/src/EntityDb.MongoDb/Sessions/MongoSession.cs
index 0ee371e7..1b41a09a 100644
--- a/src/EntityDb.MongoDb/Sessions/MongoSession.cs
+++ b/src/EntityDb.MongoDb/Sessions/MongoSession.cs
@@ -169,12 +169,20 @@ public IMongoSession WithTransactionSessionOptions(MongoDbTransactionSessionOpti
     public void StartTransaction()
     {
         AssertNotReadOnly();
-
+        
         ClientSessionHandle.StartTransaction(new TransactionOptions
         (
             writeConcern: WriteConcern,
             maxCommitTime: Options.WriteTimeout
         ));
+
+        Logger
+            .LogInformation
+            (
+                "Started MongoDb Transaction on `{DatabaseNamespace}`\n\nServer SessionId: {ServerSessionId}",
+                MongoDatabase.DatabaseNamespace,
+                ClientSessionHandle.ServerSession.Id.ToString()
+            );
     }
 
     [ExcludeFromCodeCoverage(Justification =
@@ -184,6 +192,14 @@ public async Task CommitTransaction(CancellationToken cancellationToken)
         AssertNotReadOnly();
 
         await ClientSessionHandle.CommitTransactionAsync(cancellationToken);
+
+        Logger
+            .LogInformation
+            (
+                "Committed MongoDb Transaction on `{DatabaseNamespace}`\n\nServer SessionId: {ServerSessionId}",
+                MongoDatabase.DatabaseNamespace,
+                ClientSessionHandle.ServerSession.Id.ToString()
+            );
     }
 
     public async Task AbortTransaction()
@@ -191,6 +207,14 @@ public async Task AbortTransaction()
         AssertNotReadOnly();
 
         await ClientSessionHandle.AbortTransactionAsync();
+
+        Logger
+            .LogInformation
+            (
+                "Aborted MongoDb Transaction on `{DatabaseNamespace}`\n\nServer SessionId: {ServerSessionId}",
+                MongoDatabase.DatabaseNamespace,
+                ClientSessionHandle.ServerSession.Id.ToString()
+            );
     }
 
     public override ValueTask DisposeAsync()