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.nio.channels.OverlappingFileLockException;
  19 import java.util.List;
  20 import java.util.concurrent.TimeoutException;
  21 import java.util.stream.Collectors;
  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 ProvisioningManager provisioningManager = c.getNewProvisioningManager();
  93             final URI deviceLinkUri = provisioningManager.getDeviceLinkUri();
  94             new Thread(() -> {
  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 version() {
 109         return BaseConfig.PROJECT_VERSION;
 110     }
 111
 112     @Override
 113     public List<DBusPath> listAccounts() {
 114         return c.getAccountNumbers()
 115                 .stream()
 116                 .map(u -> new DBusPath(DbusConfig.getObjectPath(u)))
 117                 .collect(Collectors.toList());
 118     }
 119 }