Catch all exceptions when reading session record

Fixes #1083

diff --git a/lib/src/main/java/org/asamk/signal/manager/storage/sessions/SessionStore.java b/lib/src/main/java/org/asamk/signal/manager/storage/sessions/SessionStore.java
index ec933742ea702abd77206f618154e5fee0906a6d..564df1d0b27883864c67b4f9432cd9217ffc77e2 100644 (file)
--- a/lib/src/main/java/org/asamk/signal/manager/storage/sessions/SessionStore.java
+++ b/lib/src/main/java/org/asamk/signal/manager/storage/sessions/SessionStore.java
@@ -3,7 +3,6 @@ package org.asamk.signal.manager.storage.sessions;
 import org.asamk.signal.manager.api.Pair;
 import org.asamk.signal.manager.storage.Database;
 import org.asamk.signal.manager.storage.Utils;
 import org.asamk.signal.manager.api.Pair;
 import org.asamk.signal.manager.storage.Database;
 import org.asamk.signal.manager.storage.Utils;

-import org.signal.libsignal.protocol.InvalidMessageException;

 import org.signal.libsignal.protocol.NoSessionException;
 import org.signal.libsignal.protocol.SignalProtocolAddress;
 import org.signal.libsignal.protocol.ecc.ECPublicKey;
 import org.signal.libsignal.protocol.NoSessionException;
 import org.signal.libsignal.protocol.SignalProtocolAddress;
 import org.signal.libsignal.protocol.ecc.ECPublicKey;


@@ -339,7 +338,7 @@ public class SessionStore implements SignalServiceSessionStore {
         try {
             final var record = resultSet.getBytes("record");
             return new SessionRecord(record);
         try {
             final var record = resultSet.getBytes("record");
             return new SessionRecord(record);

-        } catch (InvalidMessageException e) {
+        } catch (Exception e) {

             logger.warn("Failed to load session, resetting session: {}", e.getMessage());
             return null;
         }
             logger.warn("Failed to load session, resetting session: {}", e.getMessage());
             return null;
         }