Aggregate ID made optional

src/Swisschain.Extensions.Idempotency/DefaultOutboxRepository.cs

@@ -10,9 +10,14 @@ public Task<Outbox> Open(string requestId, Func<Task<long>> aggregateIdFactory)
             throw new InvalidOperationException("Outbox repository is not configured. To use outbox, you need to configure repository in service.AddOutbox(c => {...})");
         }
 
+        public Task<Outbox> Open(string requestId)
+        {
+            throw new InvalidOperationException("Outbox repository is not configured. To use outbox, you need to configure repository in service.AddOutbox(c => {...})");
+        }
+
         public Task Save(Outbox outbox, OutboxPersistingReason reason)
         {
             throw new InvalidOperationException("Outbox repository is not configured. To use outbox, you need to configure repository in service.AddOutbox(c => {...})");
         }
     }
-}
+}

src/Swisschain.Extensions.Idempotency/IOutboxManager.cs

@@ -6,6 +6,7 @@ namespace Swisschain.Extensions.Idempotency
     public interface IOutboxManager
     {
         Task<Outbox> Open(string requestId, Func<Task<long>> aggregateIdFactory);
+        Task<Outbox> Open(string requestId);
         Task Store(Outbox outbox);
         Task EnsureDispatched(Outbox outbox);
         Task EnsureDispatched(Outbox outbox, IOutboxDispatcher dispatcher);

src/Swisschain.Extensions.Idempotency/IOutboxRepository.cs

@@ -6,6 +6,7 @@ namespace Swisschain.Extensions.Idempotency
     public interface IOutboxRepository
     {
         Task<Outbox> Open(string requestId, Func<Task<long>> aggregateIdFactory);
+        Task<Outbox> Open(string requestId);
         Task Save(Outbox outbox, OutboxPersistingReason reason);
     }
 }

src/Swisschain.Extensions.Idempotency/Outbox.cs

@@ -63,12 +63,12 @@ public void Publish(object evt)
         public static Outbox Restore(string requestId,
             long aggregateId,
             bool isStored,
-            bool isShipped,
+            bool isDispatched,
             object response,
             IEnumerable<object> commands,
             IEnumerable<object> events)
         {
-            var instance = new Outbox(requestId, aggregateId, isStored, isShipped)
+            var instance = new Outbox(requestId, aggregateId, isStored, isDispatched)
             {
                 Response = response
             };

src/Swisschain.Extensions.Idempotency/OutboxManager.cs

@@ -15,9 +15,14 @@ public OutboxManager(IOutboxDispatcher dispatcher,
             _repository = repository;
         }
 
-        public async Task<Outbox> Open(string requestId, Func<Task<long>> aggregateIdFactory)
+        public Task<Outbox> Open(string requestId, Func<Task<long>> aggregateIdFactory)
         {
-            return await _repository.Open(requestId, aggregateIdFactory);
+            return _repository.Open(requestId, aggregateIdFactory);
+        }
+
+        public Task<Outbox> Open(string requestId)
+        {
+            return _repository.Open(requestId);
         }
 
         public async Task Store(Outbox outbox)

src/Swisschain.Extensions.Idempotency/OutboxServiceCollectionExtensions.cs

@@ -9,16 +9,15 @@ public static IServiceCollection AddOutbox(this IServiceCollection services, Act
         {
             services.AddTransient<IOutboxManager, OutboxManager>();
 
+            services.AddTransient<IOutboxDispatcher, DefaultOutboxDispatcher>();
+            services.AddTransient<IOutboxRepository, DefaultOutboxRepository>();
+
             if (config != null)
             {
                 var configBuilder = new OutboxConfigurationBuilder(services);
 
                 config.Invoke(configBuilder);
             }
-            else
-            {
-
-            }
 
             return services;
         }