Close Manager if checkAccountState fails

[signal-cli] / src / main / java / org / asamk / signal / JsonReceiveMessageHandler.java

diff --git a/src/main/java/org/asamk/signal/JsonReceiveMessageHandler.java b/src/main/java/org/asamk/signal/JsonReceiveMessageHandler.java
index 96f4acb52d21738ee962c303882555da9fccf60c..1135e89a879eba581f707be295ebd9db4e271ea0 100644 (file)
--- a/src/main/java/org/asamk/signal/JsonReceiveMessageHandler.java
+++ b/src/main/java/org/asamk/signal/JsonReceiveMessageHandler.java
@@ -3,10 +3,9 @@ package org.asamk.signal;
 import org.asamk.signal.json.JsonError;
 import org.asamk.signal.json.JsonMessageEnvelope;
 import org.asamk.signal.manager.Manager;
 import org.asamk.signal.json.JsonError;
 import org.asamk.signal.json.JsonMessageEnvelope;
 import org.asamk.signal.manager.Manager;

+import org.asamk.signal.manager.api.MessageEnvelope;

 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;

-import org.whispersystems.signalservice.api.messages.SignalServiceContent;
-import org.whispersystems.signalservice.api.messages.SignalServiceEnvelope;

 
 import java.util.HashMap;
 
 
 import java.util.HashMap;
 


@@ -23,14 +22,14 @@ public class JsonReceiveMessageHandler implements Manager.ReceiveMessageHandler
     }
 
     @Override
     }
 
     @Override

-    public void handleMessage(SignalServiceEnvelope envelope, SignalServiceContent content, Throwable exception) {
+    public void handleMessage(MessageEnvelope envelope, Throwable exception) {

         final var object = new HashMap<String, Object>();
         if (exception != null) {
             object.put("error", JsonError.from(exception));
         }
 
         if (envelope != null) {
         final var object = new HashMap<String, Object>();
         if (exception != null) {
             object.put("error", JsonError.from(exception));
         }
 
         if (envelope != null) {

-            object.put("envelope", JsonMessageEnvelope.from(envelope, content, exception, m));
+            object.put("envelope", JsonMessageEnvelope.from(envelope, exception, m));

         }
 
         jsonWriter.write(object);
         }
 
         jsonWriter.write(object);