X-Git-Url: https://git.nmode.ca/signal-cli/blobdiff_plain/00777a469c7ec152555a2e92eaf13b8dd0bf43f0..e74be0c345321888c1fbfa05616cb90cf3f07ffb:/src/main/java/org/asamk/signal/commands/DaemonCommand.java diff --git a/src/main/java/org/asamk/signal/commands/DaemonCommand.java b/src/main/java/org/asamk/signal/commands/DaemonCommand.java index 11805b44..c5ee2edc 100644 --- a/src/main/java/org/asamk/signal/commands/DaemonCommand.java +++ b/src/main/java/org/asamk/signal/commands/DaemonCommand.java @@ -6,6 +6,7 @@ import net.sourceforge.argparse4j.inf.Subparser; import org.asamk.signal.DbusReceiveMessageHandler; import org.asamk.signal.JsonDbusReceiveMessageHandler; +import org.asamk.signal.dbus.DbusSignalImpl; import org.asamk.signal.manager.Manager; import org.freedesktop.dbus.connections.impl.DBusConnection; import org.freedesktop.dbus.exceptions.DBusException; @@ -34,10 +35,6 @@ public class DaemonCommand implements LocalCommand { @Override public int handleCommand(final Namespace ns, final Manager m) { - if (!m.isRegistered()) { - System.err.println("User is not registered."); - return 1; - } DBusConnection conn = null; try { try { @@ -48,7 +45,7 @@ public class DaemonCommand implements LocalCommand { busType = DBusConnection.DBusBusType.SESSION; } conn = DBusConnection.getConnection(busType); - conn.exportObject(SIGNAL_OBJECTPATH, m); + conn.exportObject(SIGNAL_OBJECTPATH, new DbusSignalImpl(m)); conn.requestBusName(SIGNAL_BUSNAME); } catch (UnsatisfiedLinkError e) { System.err.println("Missing native library dependency for dbus service: " + e.getMessage()); @@ -59,7 +56,13 @@ public class DaemonCommand implements LocalCommand { } boolean ignoreAttachments = ns.getBoolean("ignore_attachments"); try { - m.receiveMessages(1, TimeUnit.HOURS, false, ignoreAttachments, ns.getBoolean("json") ? new JsonDbusReceiveMessageHandler(m, conn, SIGNAL_OBJECTPATH) : new DbusReceiveMessageHandler(m, conn, SIGNAL_OBJECTPATH)); + m.receiveMessages(1, + TimeUnit.HOURS, + false, + ignoreAttachments, + ns.getBoolean("json") + ? new JsonDbusReceiveMessageHandler(m, conn, SIGNAL_OBJECTPATH) + : new DbusReceiveMessageHandler(m, conn, SIGNAL_OBJECTPATH)); return 0; } catch (IOException e) { System.err.println("Error while receiving messages: " + e.getMessage());