fix: Mark snapshot envelopes with snapshot source

akka · Oct 19, 2023 · fd11c0c · fd11c0c
1 parent ac25135
commit fd11c0c
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 2 deletions.
diff --git a/core/src/main/scala/akka/persistence/r2dbc/query/scaladsl/R2dbcReadJournal.scala b/core/src/main/scala/akka/persistence/r2dbc/query/scaladsl/R2dbcReadJournal.scala
@@ -162,7 +162,8 @@ final class R2dbcReadJournal(system: ExtendedActorSystem, config: Config, cfgPat
       row.entityType,
       row.slice,
       filtered = false,
-      source = "",
+      // FIXME move constant to Akka/EnvelopeOrigin
+      source = "SN",
       tags = row.tags)
   }
 

diff --git a/...st/scala/akka/persistence/r2dbc/query/EventsByPersistenceIdStartingFromSnapshotSpec.scala b/...st/scala/akka/persistence/r2dbc/query/EventsByPersistenceIdStartingFromSnapshotSpec.scala
@@ -124,7 +124,9 @@ class EventsByPersistenceIdStartingFromSnapshotSpec
           .runWith(sinkProbe)
           .request(21)
 
-        result.expectNext().event shouldBe expectedSnapshotEvent(17)
+        val evt17 = result.expectNext()
+        evt17.event shouldBe expectedSnapshotEvent(17)
+        evt17.source should ===("SN")
         for (i <- 18 to 20) {
           result.expectNext().event shouldBe s"e-$i"
         }