Don't use Akka deserialization when using LegacySerialization is on. (#…

…135) Co-authored-by: Jack Wild <jackyoulend@outlook.com>
akkadotnet · May 12, 2020 · 3bd8c63 · 3bd8c63
1 parent 86cf35f
commit 3bd8c63
Show file tree

Hide file tree

Showing 2 changed files with 23 additions and 0 deletions.
diff --git a/src/Akka.Persistence.MongoDb/Journal/MongoDbJournal.cs b/src/Akka.Persistence.MongoDb/Journal/MongoDbJournal.cs
@@ -331,6 +331,19 @@ private JournalEntry ToJournalEntry(IPersistentRepresentation message)
 
         private Persistent ToPersistenceRepresentation(JournalEntry entry, IActorRef sender)
         {
+            if (_settings.LegacySerialization)
+            {
+                var manifest = string.IsNullOrEmpty(entry.Manifest) ? entry.Payload.GetType().TypeQualifiedName() : entry.Manifest;
+
+                return new Persistent(
+                    entry.Payload,
+                    entry.SequenceNr,
+                    entry.PersistenceId,
+                    manifest,
+                    entry.IsDeleted,
+                    sender);
+            }
+
             var legacy = entry.SerializerId.HasValue || !string.IsNullOrEmpty(entry.Manifest);
             if (!legacy)
             {

diff --git a/src/Akka.Persistence.MongoDb/Snapshot/MongoDbSnapshotStore.cs b/src/Akka.Persistence.MongoDb/Snapshot/MongoDbSnapshotStore.cs
@@ -165,6 +165,16 @@ private SnapshotEntry ToSnapshotEntry(SnapshotMetadata metadata, object snapshot
 
         private SelectedSnapshot ToSelectedSnapshot(SnapshotEntry entry)
         {
+            if (_settings.LegacySerialization)
+            {
+                return new SelectedSnapshot(
+                    new SnapshotMetadata(
+                        entry.PersistenceId,
+                        entry.SequenceNr,
+                        new DateTime(entry.Timestamp)),
+                        entry.Snapshot);
+            }
+
             var legacy = entry.SerializerId.HasValue || !string.IsNullOrEmpty(entry.Manifest);
 
             if (!legacy)