m = new Manager(username, settingsPath);
ts = m;
- if (m.userExists()) {
- try {
- m.init();
- } catch (Exception e) {
- System.err.println("Error loading state file \"" + m.getFileName() + "\": " + e.getMessage());
- return 2;
- }
+ try {
+ m.init();
+ } catch (Exception e) {
+ System.err.println("Error loading state file: " + e.getMessage());
+ return 2;
}
}
System.err.println("register is not yet implemented via dbus");
return 1;
}
- if (!m.userHasKeys()) {
- m.createNewIdentity();
- }
try {
m.register(ns.getBoolean("voice"));
} catch (IOException e) {
return 1;
}
- // When linking, username is null and we always have to create keys
- m.createNewIdentity();
-
String deviceName = ns.getString("name");
if (deviceName == null) {
deviceName = "cli";
System.err.println("Aborting sending.");
}
-
private static void handleDBusExecutionException(DBusExecutionException e) {
System.err.println("Cannot connect to dbus: " + e.getMessage());
System.err.println("Aborting.");
}
private static class ReceiveMessageHandler implements Manager.ReceiveMessageHandler {
+
final Manager m;
public ReceiveMessageHandler(Manager m) {
}
private static class DbusReceiveMessageHandler extends ReceiveMessageHandler {
+
final DBusConnection conn;
public DbusReceiveMessageHandler(Manager m, DBusConnection conn) {
}
private static class JsonReceiveMessageHandler implements Manager.ReceiveMessageHandler {
+
final Manager m;
final ObjectMapper jsonProcessor;
}
private static class JsonDbusReceiveMessageHandler extends JsonReceiveMessageHandler {
+
final DBusConnection conn;
public JsonDbusReceiveMessageHandler(Manager m, DBusConnection conn) {
this.conn = conn;
}
- @Override
- public void handleMessage(SignalServiceEnvelope envelope, SignalServiceContent content, Throwable exception) {
- super.handleMessage(envelope, content, exception);
-
- sendReceivedMessageToDbus(envelope, content, conn, m);
- }
-
private static void sendReceivedMessageToDbus(SignalServiceEnvelope envelope, SignalServiceContent content, DBusConnection conn, Manager m) {
if (envelope.isReceipt()) {
try {
}
}
}
+
+ @Override
+ public void handleMessage(SignalServiceEnvelope envelope, SignalServiceContent content, Throwable exception) {
+ super.handleMessage(envelope, content, exception);
+
+ sendReceivedMessageToDbus(envelope, content, conn, m);
+ }
}
}