Fix sending messages to groups

Fixes #1019

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 4bac3bd57ffdf22a396b81140e1fd3c6b78a5769..ec933742ea702abd77206f618154e5fee0906a6d 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
@@ -9,6 +9,7 @@ import org.signal.libsignal.protocol.SignalProtocolAddress;
 import org.signal.libsignal.protocol.ecc.ECPublicKey;
 import org.signal.libsignal.protocol.message.CiphertextMessage;
 import org.signal.libsignal.protocol.state.SessionRecord;
 import org.signal.libsignal.protocol.ecc.ECPublicKey;
 import org.signal.libsignal.protocol.message.CiphertextMessage;
 import org.signal.libsignal.protocol.state.SessionRecord;

+import org.signal.libsignal.protocol.util.Hex;

 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 import org.whispersystems.signalservice.api.SignalServiceSessionStore;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 import org.whispersystems.signalservice.api.SignalServiceSessionStore;


@@ -208,7 +209,8 @@ public class SessionStore implements SignalServiceSessionStore {
     public Set<SignalProtocolAddress> getAllAddressesWithActiveSessions(final List<String> addressNames) {
         final var serviceIdsCommaSeparated = addressNames.stream()
                 .map(ServiceId::parseOrThrow)
     public Set<SignalProtocolAddress> getAllAddressesWithActiveSessions(final List<String> addressNames) {
         final var serviceIdsCommaSeparated = addressNames.stream()
                 .map(ServiceId::parseOrThrow)

-                .map(ServiceId::toString)
+                .map(ServiceId::toByteArray)
+                .map(uuid -> "x'" + Hex.toStringCondensed(uuid) + "'")

                 .collect(Collectors.joining(","));
         final var sql = (
                 """
                 .collect(Collectors.joining(","));
         final var sql = (
                 """