Port akkadotnet/akka.net#7313: Made DateTime.UtcNow the default tim…

…estamp for `SnapshotMetdata`
Arkatufus · Sep 11, 2024 · 916d18b · 916d18b
1 parent 5ad7a15
commit 916d18b
Showing 1 changed file with 7 additions and 1 deletion.
diff --git a/src/Akka.Persistence.Azure/Snapshot/AzureBlobSnapshotStore.cs b/src/Akka.Persistence.Azure/Snapshot/AzureBlobSnapshotStore.cs
@@ -260,7 +260,13 @@ protected override async Task DeleteAsync(SnapshotMetadata metadata)
             cts.CancelAfter(_settings.RequestTimeout);
             using (cts)
             {
-                await blobClient.DeleteIfExistsAsync(cancellationToken: cts.Token);
+                var response = await blobClient.DownloadAsync(cts.Token);
+                if (response.HasValue)
+                {
+                    var timestamp = new DateTime(long.Parse(response.Value.Details.Metadata[TimeStampMetaDataKey])); 
+                    if(timestamp <= metadata.Timestamp)
+                        await blobClient.DeleteAsync(cancellationToken: cts.Token);
+                }
             }
         }