fix: Wrong VersionVector when migrated from non-replicated

* it should be replicaId and not persistenceId
akka · Jan 24, 2025 · 7a0b908 · 7a0b908
1 parent b0741d8
commit 7a0b908
Show file tree

Hide file tree

Showing 2 changed files with 7 additions and 5 deletions.
diff --git a/...on-grpc-tests/src/test/scala/akka/projection/grpc/internal/EventProducerServiceSpec.scala b/...on-grpc-tests/src/test/scala/akka/projection/grpc/internal/EventProducerServiceSpec.scala
@@ -258,13 +258,15 @@ class EventProducerServiceSpec
       .withReplicatedEventMetadataTransformation(
         env =>
           if (env.eventMetadata.isDefined) None
-          else
+          else {
+            // migrated from non-replicated, fill in metadata
             Some(
               ReplicatedEventMetadata(
                 originReplica = ReplicaId.empty,
                 originSequenceNr = env.sequenceNr,
-                version = VersionVector(env.persistenceId, env.sequenceNr),
-                concurrent = false))))
+                version = VersionVector(ReplicaId.empty.id, env.sequenceNr),
+                concurrent = false))
+          }))
 
   private val eventProducerService =
     new EventProducerServiceImpl(

diff --git a/...ction-grpc/src/main/scala/akka/projection/grpc/replication/internal/ReplicationImpl.scala b/...ction-grpc/src/main/scala/akka/projection/grpc/replication/internal/ReplicationImpl.scala
@@ -110,7 +110,7 @@ private[akka] object ReplicationImpl {
             ReplicatedEventMetadata(
               originReplica = settings.selfReplicaId,
               originSequenceNr = env.sequenceNr,
-              version = VersionVector(env.persistenceId, env.sequenceNr),
+              version = VersionVector(settings.selfReplicaId.id, env.sequenceNr),
               concurrent = false))
         })
 
@@ -367,7 +367,7 @@ private[akka] object ReplicationImpl {
             ReplicatedEventMetadata(
               originReplica = settings.selfReplicaId,
               originSequenceNr = env.sequenceNr,
-              version = VersionVector(env.persistenceId, env.sequenceNr),
+              version = VersionVector(settings.selfReplicaId.id, env.sequenceNr),
               concurrent = false))
         })