Update libsignal-service

[signal-cli] / lib / src / main / java / org / asamk / signal / manager / util / MessageCacheUtils.java

diff --git a/lib/src/main/java/org/asamk/signal/manager/util/MessageCacheUtils.java b/lib/src/main/java/org/asamk/signal/manager/util/MessageCacheUtils.java
index a7682682bce3333983f0d0d576851d163db6a03f..b1568bdc21494261652964af48372c8d3e495604 100644 (file)
--- a/lib/src/main/java/org/asamk/signal/manager/util/MessageCacheUtils.java
+++ b/lib/src/main/java/org/asamk/signal/manager/util/MessageCacheUtils.java
@@ -6,7 +6,7 @@ import org.whispersystems.signalservice.api.messages.SignalServiceEnvelope;
 import org.whispersystems.signalservice.api.push.ServiceId;
 import org.whispersystems.signalservice.api.push.SignalServiceAddress;
 import org.whispersystems.signalservice.api.util.UuidUtil;
-import org.whispersystems.signalservice.internal.push.SignalServiceProtos;
+import org.whispersystems.signalservice.internal.push.Envelope;
 
 import java.io.DataInputStream;
 import java.io.DataOutputStream;
@@ -34,7 +34,7 @@ public class MessageCacheUtils {
             }
             if (version >= 9) {
                 final var serverReceivedTimestamp = in.readLong();
-                final var envelope = SignalServiceProtos.Envelope.parseFrom(in.readAllBytes());
+                final var envelope = Envelope.ADAPTER.decode(in.readAllBytes());
                 return new SignalServiceEnvelope(envelope, serverReceivedTimestamp);
             } else {
                 var type = in.readInt();
@@ -114,7 +114,7 @@ public class MessageCacheUtils {
             try (var out = new DataOutputStream(f)) {
                 out.writeInt(CURRENT_VERSION); // version
                 out.writeLong(envelope.getServerDeliveredTimestamp());
-                envelope.getProto().writeTo(out);
+                envelope.getProto().encode(out);
             }
         }
     }