webmaster/signal-cli
1
0
Fork 0
mirror of https://github.com/AsamK/signal-cli synced 2025-08-30 02:50:39 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

Improve message cache behavior in case of io error

Browse source
This commit is contained in:
AsamK 2023-09-23 12:25:30 +02:00
parent 0bdc400a30
commit 67747253e8
1 changed files with 11 additions and 3 deletions
Download patch file Download diff file Expand all files Collapse all files

14
lib/src/main/java/org/asamk/signal/manager/storage/messageCache/MessageCache.java
View file

@ -51,13 +51,21 @@ public class MessageCache {
public CachedMessage cacheMessage(SignalServiceEnvelope envelope, RecipientId recipientId) { public CachedMessage cacheMessage(SignalServiceEnvelope envelope, RecipientId recipientId) {
final var now = System.currentTimeMillis(); final var now = System.currentTimeMillis();
File cacheFile;
try {
cacheFile = getMessageCacheFile(recipientId, now, envelope.getTimestamp());
} catch (IOException e) {
logger.warn("Failed to create recipient folder in disk cache: {}", e.getMessage());
throw new RuntimeException(e);
}
final var cachedMessage = new CachedMessage(cacheFile, envelope);
try { try {
var cacheFile = getMessageCacheFile(recipientId, now, envelope.getTimestamp());
MessageCacheUtils.storeEnvelope(envelope, cacheFile); MessageCacheUtils.storeEnvelope(envelope, cacheFile);
return new CachedMessage(cacheFile, envelope); return cachedMessage;
} catch (IOException e) { } catch (IOException e) {
logger.warn("Failed to store encrypted message in disk cache, ignoring: {}", e.getMessage()); logger.warn("Failed to store encrypted message in disk cache, ignoring: {}", e.getMessage());
return null; return cachedMessage;
} }
} }