Improve error messages when daemon is already running

[signal-cli] / 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 1e5bdca1d95449fdab4acc806cd5e82841ac431a..e224bf1c0a55ec4500fc1ecf581df5ade2aeca5e 100644 (file)
--- a/src/main/java/org/asamk/signal/commands/DaemonCommand.java
+++ b/src/main/java/org/asamk/signal/commands/DaemonCommand.java
@@ -36,8 +36,8 @@ import java.nio.channels.SocketChannel;
 import java.nio.charset.StandardCharsets;
 import java.util.List;
 import java.util.Objects;
 import java.nio.charset.StandardCharsets;
 import java.util.List;
 import java.util.Objects;

+import java.util.concurrent.atomic.AtomicInteger;

 import java.util.function.Consumer;
 import java.util.function.Consumer;

-import java.util.stream.Collectors;

 
 public class DaemonCommand implements MultiLocalCommand, LocalCommand {
 
 
 public class DaemonCommand implements MultiLocalCommand, LocalCommand {
 


@@ -155,7 +155,7 @@ public class DaemonCommand implements MultiLocalCommand, LocalCommand {
         final var receiveMode = ns.<ReceiveMode>get("receive-mode");
         final var ignoreAttachments = Boolean.TRUE.equals(ns.getBoolean("ignore-attachments"));
 
         final var receiveMode = ns.<ReceiveMode>get("receive-mode");
         final var ignoreAttachments = Boolean.TRUE.equals(ns.getBoolean("ignore-attachments"));
 

-        c.getAccountNumbers().stream().map(c::getManager).filter(Objects::nonNull).forEach(m -> {
+        c.getManagers().forEach(m -> {

             m.setIgnoreAttachments(ignoreAttachments);
             addDefaultReceiveHandler(m, noReceiveStdOut ? null : outputWriter, receiveMode != ReceiveMode.ON_START);
         });
             m.setIgnoreAttachments(ignoreAttachments);
             addDefaultReceiveHandler(m, noReceiveStdOut ? null : outputWriter, receiveMode != ReceiveMode.ON_START);
         });


@@ -235,8 +235,10 @@ public class DaemonCommand implements MultiLocalCommand, LocalCommand {
         });
     }
 
         });
     }
 

+    private static final AtomicInteger threadNumber = new AtomicInteger(0);
+

     private void runSocket(final ServerSocketChannel serverChannel, Consumer<SocketChannel> socketHandler) {
     private void runSocket(final ServerSocketChannel serverChannel, Consumer<SocketChannel> socketHandler) {

-        new Thread(() -> {
+        final var thread = new Thread(() -> {

             while (true) {
                 final SocketChannel channel;
                 final String clientString;
             while (true) {
                 final SocketChannel channel;
                 final String clientString;


@@ -251,16 +253,20 @@ public class DaemonCommand implements MultiLocalCommand, LocalCommand {
                     }
                     break;
                 }
                     }
                     break;
                 }

-                new Thread(() -> {
+                final var connectionThread = new Thread(() -> {

                     try (final var c = channel) {
                         socketHandler.accept(c);
                         logger.info("Connection closed: " + clientString);
                     } catch (IOException e) {
                         logger.warn("Failed to close channel", e);
                     }
                     try (final var c = channel) {
                         socketHandler.accept(c);
                         logger.info("Connection closed: " + clientString);
                     } catch (IOException e) {
                         logger.warn("Failed to close channel", e);
                     }

-                }).start();
+                });
+                connectionThread.setName("daemon-connection-" + threadNumber.getAndIncrement());
+                connectionThread.start();

             }
             }

-        }).start();
+        });
+        thread.setName("daemon-listener");
+        thread.start();

     }
 
     private SignalJsonRpcDispatcherHandler getSignalJsonRpcDispatcherHandler(
     }
 
     private SignalJsonRpcDispatcherHandler getSignalJsonRpcDispatcherHandler(


@@ -308,16 +314,13 @@ public class DaemonCommand implements MultiLocalCommand, LocalCommand {
                     }
                 } catch (DBusException ignored) {
                 }
                     }
                 } catch (DBusException ignored) {
                 }

-                connection.unExportObject(path);

             });
 
             });
 

-            final var initThreads = c.getAccountNumbers()
+            final var initThreads = c.getManagers()

                     .stream()
                     .stream()

-                    .map(c::getManager)
-                    .filter(Objects::nonNull)

                     .map(m -> exportMultiAccountManager(connection, m, noReceiveOnStart))
                     .filter(Objects::nonNull)
                     .map(m -> exportMultiAccountManager(connection, m, noReceiveOnStart))
                     .filter(Objects::nonNull)

-                    .collect(Collectors.toList());
+                    .toList();

 
             for (var t : initThreads) {
                 try {
 
             for (var t : initThreads) {
                 try {


@@ -337,41 +340,39 @@ public class DaemonCommand implements MultiLocalCommand, LocalCommand {
         } else {
             busType = DBusConnection.DBusBusType.SESSION;
         }
         } else {
             busType = DBusConnection.DBusBusType.SESSION;
         }

+        DBusConnection conn;

         try {
         try {

-            var conn = DBusConnection.getConnection(busType);
+            conn = DBusConnection.getConnection(busType);

             dbusRunner.run(conn, DbusConfig.getObjectPath());
             dbusRunner.run(conn, DbusConfig.getObjectPath());

+        } catch (DBusException e) {
+            throw new UnexpectedErrorException("Dbus command failed: " + e.getMessage(), e);
+        }

 
 

+        try {

             conn.requestBusName(DbusConfig.getBusname());
             conn.requestBusName(DbusConfig.getBusname());

-
-            logger.info("DBus daemon running on {} bus: {}", busType, DbusConfig.getBusname());

         } catch (DBusException e) {
         } catch (DBusException e) {

-            logger.error("Dbus command failed", e);
-            throw new UnexpectedErrorException("Dbus command failed", e);
+            throw new UnexpectedErrorException("Dbus command failed, maybe signal-cli dbus daemon is already running: "
+                    + e.getMessage(), e);

         }
         }

+
+        logger.info("DBus daemon running on {} bus: {}", busType, DbusConfig.getBusname());

     }
 
     private Thread exportMultiAccountManager(
             final DBusConnection conn, final Manager m, final boolean noReceiveOnStart
     ) {
     }
 
     private Thread exportMultiAccountManager(
             final DBusConnection conn, final Manager m, final boolean noReceiveOnStart
     ) {

-        try {
-            final var objectPath = DbusConfig.getObjectPath(m.getSelfNumber());
-            return exportDbusObject(conn, objectPath, m, noReceiveOnStart);
-        } catch (DBusException e) {
-            logger.error("Failed to export object", e);
-            return null;
-        }
+        final var objectPath = DbusConfig.getObjectPath(m.getSelfNumber());
+        return exportDbusObject(conn, objectPath, m, noReceiveOnStart);

     }
 
     private Thread exportDbusObject(
             final DBusConnection conn, final String objectPath, final Manager m, final boolean noReceiveOnStart
     }
 
     private Thread exportDbusObject(
             final DBusConnection conn, final String objectPath, final Manager m, final boolean noReceiveOnStart

-    ) throws DBusException {
+    ) {

         final var signal = new DbusSignalImpl(m, conn, objectPath, noReceiveOnStart);
         final var signal = new DbusSignalImpl(m, conn, objectPath, noReceiveOnStart);

-        conn.exportObject(signal);

         final var initThread = new Thread(signal::initObjects);
         final var initThread = new Thread(signal::initObjects);

+        initThread.setName("dbus-init");

         initThread.start();
 
         initThread.start();
 

-        logger.debug("Exported dbus object: " + objectPath);
-

         return initThread;
     }
 
         return initThread;
     }