(wip) TestSnapshotStore

src/core/Akka.Persistence.TestKit/Journal/IJournalBehaviorSetter.cs

@@ -0,0 +1,16 @@
+//-----------------------------------------------------------------------
+// <copyright file="IJournalBehaviorSetter.cs" company="Akka.NET Project">
+//     Copyright (C) 2009-2019 Lightbend Inc. <http://www.lightbend.com>
+//     Copyright (C) 2013-2019 .NET Foundation <https://github.com/akkadotnet/akka.net>
+// </copyright>
+//-----------------------------------------------------------------------
+
+namespace Akka.Persistence.TestKit
+{
+    using System.Threading.Tasks;
+
+    public interface IJournalBehaviorSetter
+    {
+        Task SetInterceptorAsync(IJournalInterceptor interceptor);
+    }
+}

src/core/Akka.Persistence.TestKit/IJournalBehaviorSetter.cs → src/core/Akka.Persistence.TestKit/Journal/JournalRecoveryBehaviorSetter.cs

@@ -1,5 +1,5 @@
 //-----------------------------------------------------------------------
-// <copyright file="IJournalBehaviorSetter.cs" company="Akka.NET Project">
+// <copyright file="JournalRecoveryBehaviorSetter.cs" company="Akka.NET Project">
 //     Copyright (C) 2009-2019 Lightbend Inc. <http://www.lightbend.com>
 //     Copyright (C) 2013-2019 .NET Foundation <https://github.com/akkadotnet/akka.net>
 // </copyright>
@@ -11,27 +11,6 @@ namespace Akka.Persistence.TestKit
     using System.Threading.Tasks;
     using Actor;
 
-    public interface IJournalBehaviorSetter
-    {
-        Task SetInterceptorAsync(IJournalInterceptor interceptor);
-    }
-
-    internal class JournalWriteBehaviorSetter : IJournalBehaviorSetter
-    {
-        internal JournalWriteBehaviorSetter(IActorRef journal)
-        {
-            this._journal = journal;
-        }
-
-        private readonly IActorRef _journal;
-
-        public Task SetInterceptorAsync(IJournalInterceptor interceptor)
-            => _journal.Ask<TestJournal.Ack>(
-                new TestJournal.UseWriteInterceptor(interceptor),
-                TimeSpan.FromSeconds(3)
-            );
-    }
-
     internal class JournalRecoveryBehaviorSetter : IJournalBehaviorSetter
     {
         internal JournalRecoveryBehaviorSetter(IActorRef journal)

src/core/Akka.Persistence.TestKit/Journal/JournalWriteBehaviorSetter.cs

@@ -0,0 +1,29 @@
+//-----------------------------------------------------------------------
+// <copyright file="JournalWriteBehaviorSetter.cs" company="Akka.NET Project">
+//     Copyright (C) 2009-2019 Lightbend Inc. <http://www.lightbend.com>
+//     Copyright (C) 2013-2019 .NET Foundation <https://github.com/akkadotnet/akka.net>
+// </copyright>
+//-----------------------------------------------------------------------
+
+namespace Akka.Persistence.TestKit
+{
+    using System;
+    using System.Threading.Tasks;
+    using Actor;
+
+    internal class JournalWriteBehaviorSetter : IJournalBehaviorSetter
+    {
+        internal JournalWriteBehaviorSetter(IActorRef journal)
+        {
+            this._journal = journal;
+        }
+
+        private readonly IActorRef _journal;
+
+        public Task SetInterceptorAsync(IJournalInterceptor interceptor)
+            => _journal.Ask<TestJournal.Ack>(
+                new TestJournal.UseWriteInterceptor(interceptor),
+                TimeSpan.FromSeconds(3)
+            );
+    }
+}

src/core/Akka.Persistence.TestKit/SnapshotStore/ISnapshotStoreBehaviorSetter.cs

@@ -0,0 +1,16 @@
+// -----------------------------------------------------------------------
+//  <copyright file="ISnapshotStoreBehaviorSetter.cs" company="Akka.NET Project">
+//      Copyright (C) 2009-2019 Lightbend Inc. <http://www.lightbend.com>
+//      Copyright (C) 2013-2019 .NET Foundation <https://github.com/akkadotnet/akka.net>
+//  </copyright>
+// -----------------------------------------------------------------------
+
+namespace Akka.Persistence.TestKit
+{
+    using System.Threading.Tasks;
+
+    public interface ISnapshotStoreBehaviorSetter
+    {
+        Task SetInterceptorAsync(ISnapshotStoreInterceptor interceptor);
+    }
+}

src/core/Akka.Persistence.TestKit/SnapshotStore/ISnapshotStoreInterceptor.cs

@@ -0,0 +1,16 @@
+//-----------------------------------------------------------------------
+// <copyright file="ISnapshotStoreInterceptor.cs" company="Akka.NET Project">
+//     Copyright (C) 2009-2019 Lightbend Inc. <http://www.lightbend.com>
+//     Copyright (C) 2013-2019 .NET Foundation <https://github.com/akkadotnet/akka.net>
+// </copyright>
+//-----------------------------------------------------------------------
+
+namespace Akka.Persistence.TestKit
+{
+    using System.Threading.Tasks;
+
+    public interface ISnapshotStoreInterceptor
+    {
+        Task Intercept(string persistenceId, SnapshotSelectionCriteria criteria);
+    }
+}

src/core/Akka.Persistence.TestKit/SnapshotStore/ITestSnapshotStore.cs

@@ -0,0 +1,16 @@
+//-----------------------------------------------------------------------
+// <copyright file="ITestSnapshotStore.cs" company="Akka.NET Project">
+//     Copyright (C) 2009-2019 Lightbend Inc. <http://www.lightbend.com>
+//     Copyright (C) 2013-2019 .NET Foundation <https://github.com/akkadotnet/akka.net>
+// </copyright>
+//-----------------------------------------------------------------------
+
+namespace Akka.Persistence.TestKit
+{
+    public interface ITestSnapshotStore
+    {
+        SnapshotStoreSaveBehavior OnSave { get; }
+        SnapshotStoreLoadBehavior OnLoad { get; }
+        SnapshotStoreDeleteBehavior OnDelete { get; }
+    }
+}

src/core/Akka.Persistence.TestKit/SnapshotStore/SnapshotStoreDeleteBehavior.cs

@@ -0,0 +1,17 @@
+// -----------------------------------------------------------------------
+//  <copyright file="SnapshotStoreDeleteBehavior.cs" company="Akka.NET Project">
+//      Copyright (C) 2009-2019 Lightbend Inc. <http://www.lightbend.com>
+//      Copyright (C) 2013-2019 .NET Foundation <https://github.com/akkadotnet/akka.net>
+//  </copyright>
+// -----------------------------------------------------------------------
+
+namespace Akka.Persistence.TestKit
+{
+    public class SnapshotStoreDeleteBehavior : SnapshotStoreSaveBehavior
+    {
+        public SnapshotStoreDeleteBehavior(ISnapshotStoreBehaviorSetter setter) : base(setter)
+        {
+
+        }
+    }
+}

src/core/Akka.Persistence.TestKit/SnapshotStore/SnapshotStoreDeleteBehaviorSetter.cs

@@ -0,0 +1,29 @@
+// -----------------------------------------------------------------------
+//  <copyright file="SnapshotStoreDeleteBehaviorSetter.cs" company="Akka.NET Project">
+//      Copyright (C) 2009-2019 Lightbend Inc. <http://www.lightbend.com>
+//      Copyright (C) 2013-2019 .NET Foundation <https://github.com/akkadotnet/akka.net>
+//  </copyright>
+// -----------------------------------------------------------------------
+
+namespace Akka.Persistence.TestKit
+{
+    using System;
+    using System.Threading.Tasks;
+    using Actor;
+
+    internal class SnapshotStoreDeleteBehaviorSetter : ISnapshotStoreBehaviorSetter
+    {
+        internal SnapshotStoreDeleteBehaviorSetter(IActorRef snapshots)
+        {
+            this._snapshots = snapshots;
+        }
+
+        private readonly IActorRef _snapshots;
+
+        public Task SetInterceptorAsync(ISnapshotStoreInterceptor interceptor)
+            => _snapshots.Ask<TestSnapshotStore.Ack>(
+                new TestSnapshotStore.UseDeleteInterceptor(interceptor),
+                TimeSpan.FromSeconds(3)
+            );
+    }
+}

src/core/Akka.Persistence.TestKit/SnapshotStore/SnapshotStoreInterceptors.cs

@@ -0,0 +1,22 @@
+//-----------------------------------------------------------------------
+// <copyright file="SnapshotStoreInterceptors.cs" company="Akka.NET Project">
+//     Copyright (C) 2009-2019 Lightbend Inc. <http://www.lightbend.com>
+//     Copyright (C) 2013-2019 .NET Foundation <https://github.com/akkadotnet/akka.net>
+// </copyright>
+//-----------------------------------------------------------------------
+
+namespace Akka.Persistence.TestKit
+{
+    using System.Threading.Tasks;
+
+    internal static class SnapshotStoreInterceptors
+    {
+        internal class Failure : ISnapshotStoreInterceptor
+        {
+            public Task Intercept(string persistenceId, SnapshotSelectionCriteria criteria)
+            {
+                throw new TestSnapshotStoreFailureException();
+            }
+        }
+    }
+}

src/core/Akka.Persistence.TestKit/SnapshotStore/SnapshotStoreLoadBehavior.cs

@@ -0,0 +1,17 @@
+// -----------------------------------------------------------------------
+//  <copyright file="SnapshotStoreLoadBehavior.cs" company="Akka.NET Project">
+//      Copyright (C) 2009-2019 Lightbend Inc. <http://www.lightbend.com>
+//      Copyright (C) 2013-2019 .NET Foundation <https://github.com/akkadotnet/akka.net>
+//  </copyright>
+// -----------------------------------------------------------------------
+
+namespace Akka.Persistence.TestKit
+{
+    public class SnapshotStoreLoadBehavior : SnapshotStoreSaveBehavior
+    {
+        public SnapshotStoreLoadBehavior(ISnapshotStoreBehaviorSetter setter) : base(setter)
+        {
+
+        }
+    }
+}

src/core/Akka.Persistence.TestKit/SnapshotStore/SnapshotStoreLoadBehaviorSetter.cs

@@ -0,0 +1,29 @@
+// -----------------------------------------------------------------------
+//  <copyright file="SnapshotStoreLoadBehaviorSetter.cs" company="Akka.NET Project">
+//      Copyright (C) 2009-2019 Lightbend Inc. <http://www.lightbend.com>
+//      Copyright (C) 2013-2019 .NET Foundation <https://github.com/akkadotnet/akka.net>
+//  </copyright>
+// -----------------------------------------------------------------------
+
+namespace Akka.Persistence.TestKit
+{
+    using System;
+    using System.Threading.Tasks;
+    using Actor;
+
+    internal class SnapshotStoreLoadBehaviorSetter : ISnapshotStoreBehaviorSetter
+    {
+        internal SnapshotStoreLoadBehaviorSetter(IActorRef snapshots)
+        {
+            this._snapshots = snapshots;
+        }
+
+        private readonly IActorRef _snapshots;
+
+        public Task SetInterceptorAsync(ISnapshotStoreInterceptor interceptor)
+            => _snapshots.Ask<TestSnapshotStore.Ack>(
+                new TestSnapshotStore.UseLoadInterceptor(interceptor),
+                TimeSpan.FromSeconds(3)
+            );
+    }
+}

src/core/Akka.Persistence.TestKit/SnapshotStore/SnapshotStoreSaveBehavior.cs

@@ -0,0 +1,19 @@
+//-----------------------------------------------------------------------
+// <copyright file="SnapshotStoreSaveBehavior.cs" company="Akka.NET Project">
+//     Copyright (C) 2009-2019 Lightbend Inc. <http://www.lightbend.com>
+//     Copyright (C) 2013-2019 .NET Foundation <https://github.com/akkadotnet/akka.net>
+// </copyright>
+//-----------------------------------------------------------------------
+
+namespace Akka.Persistence.TestKit
+{
+    public class SnapshotStoreSaveBehavior
+    {
+        public SnapshotStoreSaveBehavior(ISnapshotStoreBehaviorSetter setter)
+        {
+            Setter = setter;
+        }
+
+        protected readonly ISnapshotStoreBehaviorSetter Setter;
+    }
+}

src/core/Akka.Persistence.TestKit/SnapshotStore/SnapshotStoreSaveBehaviorSetter.cs

@@ -0,0 +1,29 @@
+// -----------------------------------------------------------------------
+//  <copyright file="SnapshotStoreSaveBehaviorSetter.cs" company="Akka.NET Project">
+//      Copyright (C) 2009-2019 Lightbend Inc. <http://www.lightbend.com>
+//      Copyright (C) 2013-2019 .NET Foundation <https://github.com/akkadotnet/akka.net>
+//  </copyright>
+// -----------------------------------------------------------------------
+
+namespace Akka.Persistence.TestKit
+{
+    using System;
+    using System.Threading.Tasks;
+    using Actor;
+
+    internal class SnapshotStoreSaveBehaviorSetter : ISnapshotStoreBehaviorSetter
+    {
+        internal SnapshotStoreSaveBehaviorSetter(IActorRef snapshots)
+        {
+            this._snapshots = snapshots;
+        }
+
+        private readonly IActorRef _snapshots;
+
+        public Task SetInterceptorAsync(ISnapshotStoreInterceptor interceptor)
+            => _snapshots.Ask<TestSnapshotStore.Ack>(
+                new TestSnapshotStore.UseSaveInterceptor(interceptor),
+                TimeSpan.FromSeconds(3)
+            );
+    }
+}