Replace cached envelopes when moving

Fixes #1730

diff --git a/lib/src/main/java/org/asamk/signal/manager/storage/messageCache/MessageCache.java b/lib/src/main/java/org/asamk/signal/manager/storage/messageCache/MessageCache.java
index 51882a442835f1e7527235b4b273064810384220..e4fd8c01dbfbcfa4bec5d32cd160b8811d4fc95f 100644 (file)
--- a/lib/src/main/java/org/asamk/signal/manager/storage/messageCache/MessageCache.java
+++ b/lib/src/main/java/org/asamk/signal/manager/storage/messageCache/MessageCache.java
@@ -10,6 +10,7 @@ import org.whispersystems.signalservice.api.messages.SignalServiceEnvelope;
 import java.io.File;
 import java.io.IOException;
 import java.nio.file.Files;
 import java.io.File;
 import java.io.IOException;
 import java.nio.file.Files;

+import java.nio.file.StandardCopyOption;

 import java.util.Arrays;
 import java.util.Collections;
 import java.util.Objects;
 import java.util.Arrays;
 import java.util.Collections;
 import java.util.Objects;


@@ -75,7 +76,7 @@ public class MessageCache {
             return cachedMessage;
         }
         logger.debug("Moving cached message {} to {}", cachedMessage.getFile().toPath(), cacheFile.toPath());
             return cachedMessage;
         }
         logger.debug("Moving cached message {} to {}", cachedMessage.getFile().toPath(), cacheFile.toPath());

-        Files.move(cachedMessage.getFile().toPath(), cacheFile.toPath());
+        Files.move(cachedMessage.getFile().toPath(), cacheFile.toPath(), StandardCopyOption.REPLACE_EXISTING);

         return new CachedMessage(cacheFile);
     }
 
         return new CachedMessage(cacheFile);
     }