X-Git-Url: https://git.nmode.ca/signal-cli/blobdiff_plain/9b102c49d06bd6dcd59f032ddd17663f47991118..cd29144e81701698092f3334bee0c99c0f77f202:/src/main/java/org/asamk/signal/commands/ReceiveCommand.java diff --git a/src/main/java/org/asamk/signal/commands/ReceiveCommand.java b/src/main/java/org/asamk/signal/commands/ReceiveCommand.java index 6b2e497e..fe062ffc 100644 --- a/src/main/java/org/asamk/signal/commands/ReceiveCommand.java +++ b/src/main/java/org/asamk/signal/commands/ReceiveCommand.java @@ -58,23 +58,22 @@ public class ReceiveCommand implements ExtendedDbusCommand, LocalCommand { final Namespace ns, final Signal signal, DBusConnection dbusconnection, final OutputWriter outputWriter ) throws CommandException { try { - if (outputWriter instanceof JsonWriter) { - final var jsonWriter = (JsonWriter) outputWriter; + if (outputWriter instanceof JsonWriter jsonWriter) { dbusconnection.addSigHandler(Signal.MessageReceived.class, signal, messageReceived -> { - var envelope = new JsonMessageEnvelope(messageReceived); + var envelope = JsonMessageEnvelope.from(messageReceived); final var object = Map.of("envelope", envelope); jsonWriter.write(object); }); dbusconnection.addSigHandler(Signal.ReceiptReceived.class, signal, receiptReceived -> { - var envelope = new JsonMessageEnvelope(receiptReceived); + var envelope = JsonMessageEnvelope.from(receiptReceived); final var object = Map.of("envelope", envelope); jsonWriter.write(object); }); dbusconnection.addSigHandler(Signal.SyncMessageReceived.class, signal, syncReceived -> { - var envelope = new JsonMessageEnvelope(syncReceived); + var envelope = JsonMessageEnvelope.from(syncReceived); final var object = Map.of("envelope", envelope); jsonWriter.write(object); });