Added UnitOfWork.Init

swisschain · Aug 12, 2020 · e6dcf4a · e6dcf4a
1 parent 0e71e79
commit e6dcf4a
Show file tree

Hide file tree

Showing 3 changed files with 26 additions and 26 deletions.
diff --git a/src/Swisschain.Extensions.Idempotency/IUnitOfWork.cs b/src/Swisschain.Extensions.Idempotency/IUnitOfWork.cs
@@ -11,7 +11,12 @@ public interface IUnitOfWork : IAsyncDisposable
         bool IsCommitted { get; }
         bool IsRolledBack { get; }
         Outbox Outbox { get; }
-
+
+        Task Init(IIdGeneratorRepository idGeneratorRepository,
+            IOutboxWriteRepository outboxWriteRepository,
+            string idempotencyId,
+            Outbox outbox);
+
         /// <summary>
         /// Closes the <see cref="Outbox"/> and commits unit of work transaction
         /// </summary>

diff --git a/src/Swisschain.Extensions.Idempotency/UnitOfWorkBase.cs b/src/Swisschain.Extensions.Idempotency/UnitOfWorkBase.cs
@@ -7,31 +7,35 @@ public abstract class UnitOfWorkBase : IUnitOfWork
     {
         private readonly IOutboxDispatcher _defaultOutboxDispatcher;
 
-        public UnitOfWorkBase(
-            IOutboxWriteRepository outboxWriteRepository,
-            IIdGeneratorRepository idGeneratorRepository,
-            string idempotencyId,
-            Outbox outbox,
-            IOutboxDispatcher defaultOutboxDispatcher)
+        public UnitOfWorkBase(IOutboxDispatcher defaultOutboxDispatcher)
         {
             _defaultOutboxDispatcher = defaultOutboxDispatcher;
-            OutboxWriteRepository = outboxWriteRepository;
-            IdGeneratorRepository = idGeneratorRepository;
-            IdempotencyId = idempotencyId;
-            Outbox = outbox;
         }
 
-        public IIdGeneratorRepository IdGeneratorRepository { get; }
-        public IOutboxWriteRepository OutboxWriteRepository { get; }
-        public string IdempotencyId { get; }
+        public IIdGeneratorRepository IdGeneratorRepository { get; private set; }
+        public IOutboxWriteRepository OutboxWriteRepository { get; private set; }
+        public string IdempotencyId { get; private set; }
         public bool IsCommitted { get; private set; }
         public bool IsRolledBack { get; private set; }
-        public Outbox Outbox { get; }
+        public Outbox Outbox { get; private set; }
 
         protected abstract Task CommitImpl();
         protected abstract Task RollbackImpl();
         protected abstract ValueTask DisposeAsync(bool disposing);
 
+        public Task Init(IIdGeneratorRepository idGeneratorRepository,
+            IOutboxWriteRepository outboxWriteRepository,
+            string idempotencyId,
+            Outbox outbox)
+        {
+            OutboxWriteRepository = outboxWriteRepository;
+            IdGeneratorRepository = idGeneratorRepository;
+            IdempotencyId = idempotencyId;
+            Outbox = outbox;
+
+            return Task.CompletedTask;
+        }
+
         public async Task Commit()
         {
             if (IsCommitted)

diff --git a/tests/Tests/ExampleUnitOfWork.cs b/tests/Tests/ExampleUnitOfWork.cs
@@ -5,17 +5,8 @@ namespace Tests
 {
     public class ExampleUnitOfWork : UnitOfWorkBase
     {
-        public ExampleUnitOfWork(IOutboxWriteRepository outboxWriteRepository,
-            IIdGeneratorRepository idGeneratorRepository,
-            string idempotencyId,
-            Outbox outbox,
-            IOutboxDispatcher defaultOutboxDispatcher) : 
-
-            base(outboxWriteRepository, 
-                idGeneratorRepository, 
-                idempotencyId,
-                outbox,
-                defaultOutboxDispatcher)
+        public ExampleUnitOfWork(IOutboxDispatcher defaultOutboxDispatcher) :
+            base(defaultOutboxDispatcher)
         {
         }