X-Git-Url: https://git.nmode.ca/signal-cli/blobdiff_plain/382d8d22d0ccad109106b140616638799cc646f6..fc8b6d0fcbedd6a4c9ae394a0640e79690e28337:/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 deleted file mode 100644 index 41edfd3f..00000000 --- a/src/main/java/org/asamk/signal/JsonReceiveMessageHandler.java +++ /dev/null @@ -1,38 +0,0 @@ -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.manager.api.MessageEnvelope; -import org.slf4j.Logger; -import org.slf4j.LoggerFactory; - -import java.util.HashMap; - -public class JsonReceiveMessageHandler implements Manager.ReceiveMessageHandler { - - private final static Logger logger = LoggerFactory.getLogger(JsonReceiveMessageHandler.class); - - private final Manager m; - private final JsonWriter jsonWriter; - - public JsonReceiveMessageHandler(Manager m, JsonWriter jsonWriter) { - this.m = m; - this.jsonWriter = jsonWriter; - } - - @Override - public void handleMessage(MessageEnvelope envelope, Throwable exception) { - final var object = new HashMap(); - object.put("account", m.getSelfNumber()); - if (exception != null) { - object.put("error", JsonError.from(exception)); - } - - if (envelope != null) { - object.put("envelope", JsonMessageEnvelope.from(envelope, exception, m)); - } - - jsonWriter.write(object); - } -}