nmode's Git Repositories - signal-cli/blob - src/main/java/org/asamk/signal/dbus/DbusSignalControlImpl.java

   1 package org.asamk.signal.dbus;
   2
   3 import org.asamk.SignalControl;
   4 import org.asamk.signal.BaseConfig;
   5 import org.asamk.signal.DbusConfig;
   6 import org.asamk.signal.manager.Manager;
   7 import org.asamk.signal.manager.MultiAccountManager;
   8 import org.asamk.signal.manager.ProvisioningManager;
   9 import org.asamk.signal.manager.RegistrationManager;
  10 import org.asamk.signal.manager.UserAlreadyExists;
  11 import org.asamk.signal.manager.api.CaptchaRequiredException;
  12 import org.asamk.signal.manager.api.IncorrectPinException;
  13 import org.asamk.signal.manager.api.PinLockedException;
  14 import org.freedesktop.dbus.DBusPath;
  15
  16 import java.io.IOException;
  17 import java.net.URI;
  18 import java.net.URISyntaxException;
  19 import java.nio.channels.OverlappingFileLockException;
  20 import java.util.List;
  21 import java.util.concurrent.TimeoutException;
  22
  23 public class DbusSignalControlImpl implements org.asamk.SignalControl {
  24
  25     private final MultiAccountManager c;
  26
  27     private final String objectPath;
  28
  29     public DbusSignalControlImpl(final MultiAccountManager c, final String objectPath) {
  30         this.c = c;
  31         this.objectPath = objectPath;
  32     }
  33
  34     @Override
  35     public boolean isRemote() {
  36         return false;
  37     }
  38
  39     @Override
  40     public String getObjectPath() {
  41         return objectPath;
  42     }
  43
  44     @Override
  45     public void register(
  46             final String number, final boolean voiceVerification
  47     ) throws Error.Failure, Error.InvalidNumber {
  48         registerWithCaptcha(number, voiceVerification, null);
  49     }
  50
  51     @Override
  52     public void registerWithCaptcha(
  53             final String number, final boolean voiceVerification, final String captcha
  54     ) throws Error.Failure, Error.InvalidNumber {
  55         if (!Manager.isValidNumber(number, null)) {
  56             throw new SignalControl.Error.InvalidNumber(
  57                     "Invalid account (phone number), make sure you include the country code.");
  58         }
  59         try (final RegistrationManager registrationManager = c.getNewRegistrationManager(number)) {
  60             registrationManager.register(voiceVerification, captcha);
  61         } catch (CaptchaRequiredException e) {
  62             String message = captcha == null ? "Captcha required for verification." : "Invalid captcha given.";
  63             throw new SignalControl.Error.RequiresCaptcha(message);
  64         } catch (OverlappingFileLockException e) {
  65             throw new SignalControl.Error.Failure("Account is already in use");
  66         } catch (IOException e) {
  67             throw new SignalControl.Error.Failure(e.getClass().getSimpleName() + " " + e.getMessage());
  68         }
  69     }
  70
  71     @Override
  72     public void verify(final String number, final String verificationCode) throws Error.Failure, Error.InvalidNumber {
  73         verifyWithPin(number, verificationCode, null);
  74     }
  75
  76     @Override
  77     public void verifyWithPin(
  78             final String number, final String verificationCode, final String pin
  79     ) throws Error.Failure, Error.InvalidNumber {
  80         try (final RegistrationManager registrationManager = c.getNewRegistrationManager(number)) {
  81             registrationManager.verifyAccount(verificationCode, pin);
  82         } catch (OverlappingFileLockException e) {
  83             throw new SignalControl.Error.Failure("Account is already in use");
  84         } catch (IOException | PinLockedException | IncorrectPinException e) {
  85             throw new SignalControl.Error.Failure(e.getClass().getSimpleName() + " " + e.getMessage());
  86         }
  87     }
  88
  89     @Override
  90     public String link(final String newDeviceName) throws Error.Failure {
  91         try {
  92             final URI deviceLinkUri = c.getNewProvisioningDeviceLinkUri();
  93             new Thread(() -> {
  94                 final ProvisioningManager provisioningManager = c.getProvisioningManagerFor(deviceLinkUri);
  95                 try {
  96                     provisioningManager.finishDeviceLink(newDeviceName);
  97                 } catch (IOException | TimeoutException | UserAlreadyExists e) {
  98                     e.printStackTrace();
  99                 }
 100             }).start();
 101             return deviceLinkUri.toString();
 102         } catch (TimeoutException | IOException e) {
 103             throw new SignalControl.Error.Failure(e.getClass().getSimpleName() + " " + e.getMessage());
 104         }
 105     }
 106
 107     @Override
 108     public String startLink() throws Error.Failure {
 109         try {
 110             final URI deviceLinkUri = c.getNewProvisioningDeviceLinkUri();
 111             return deviceLinkUri.toString();
 112         } catch (TimeoutException | IOException e) {
 113             throw new SignalControl.Error.Failure(e.getClass().getSimpleName() + " " + e.getMessage());
 114         }
 115     }
 116
 117     @Override
 118     public String finishLink(String deviceLinkUri, final String newDeviceName) throws Error.Failure {
 119         try {
 120             final var provisioningManager = c.getProvisioningManagerFor(new URI(deviceLinkUri));
 121             return provisioningManager.finishDeviceLink(newDeviceName);
 122         } catch (TimeoutException | IOException | UserAlreadyExists | URISyntaxException e) {
 123             throw new SignalControl.Error.Failure(e.getClass().getSimpleName() + " " + e.getMessage());
 124         }
 125     }
 126
 127     @Override
 128     public String version() {
 129         return BaseConfig.PROJECT_VERSION;
 130     }
 131
 132     @Override
 133     public List<DBusPath> listAccounts() {
 134         return c.getAccountNumbers().stream().map(u -> new DBusPath(DbusConfig.getObjectPath(u))).toList();
 135     }
 136
 137     @Override
 138     public DBusPath getAccount(final String number) {
 139         return new DBusPath(DbusConfig.getObjectPath(number));
 140     }
 141 }