Add SnapshotStore SaveSnapshot spec from TCK (#271)

akkadotnet · Sep 11, 2024 · 61593d8 · 61593d8
1 parent 848c8a5
commit 61593d8
Showing 1 changed file with 41 additions and 0 deletions.
diff --git a/src/Akka.Persistence.PostgreSql.Tests/PostgreSqlSnapshotStoreSaveSnapshotSpec.cs b/src/Akka.Persistence.PostgreSql.Tests/PostgreSqlSnapshotStoreSaveSnapshotSpec.cs
@@ -0,0 +1,41 @@
+using Akka.Configuration;
+using Akka.Persistence.TCK.Snapshot;
+using Xunit;
+using Xunit.Abstractions;
+
+namespace Akka.Persistence.PostgreSql.Tests;
+
+[Collection("PostgreSqlSpec")]
+public class PostgreSqlSnapshotStoreSaveSnapshotSpec: SnapshotStoreSaveSnapshotSpec
+{
+    private static Config Initialize(PostgresFixture fixture)
+    {
+        //need to make sure db is created before the tests start
+        DbUtils.Initialize(fixture);
+
+        var config = @$"
+                akka.persistence {{
+                    publish-plugin-commands = on
+                    snapshot-store {{
+                        plugin = ""akka.persistence.snapshot-store.postgresql""
+                        postgresql {{
+                            class = ""Akka.Persistence.PostgreSql.Snapshot.PostgreSqlSnapshotStore, Akka.Persistence.PostgreSql""
+                            plugin-dispatcher = ""akka.actor.default-dispatcher""
+                            table-name = snapshot_store
+                            schema-name = public
+                            auto-initialize = on
+                            connection-string = ""{DbUtils.ConnectionString}""
+                            stored-as = bytea
+                        }}
+                    }}
+                }}
+                akka.test.single-expect-default = 10s";
+
+        return ConfigurationFactory.ParseString(config);
+    }
+
+    public PostgreSqlSnapshotStoreSaveSnapshotSpec(ITestOutputHelper output, PostgresFixture fixture)
+        : base(Initialize(fixture), nameof(PostgreSqlSnapshotStoreSaveSnapshotSpec), output: output)
+    {
+    }
+}