1 package org
.asamk
.signal
.dbus
;
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
.api
.CaptchaRequiredException
;
11 import org
.asamk
.signal
.manager
.api
.IncorrectPinException
;
12 import org
.asamk
.signal
.manager
.api
.NonNormalizedPhoneNumberException
;
13 import org
.asamk
.signal
.manager
.api
.PinLockedException
;
14 import org
.asamk
.signal
.manager
.api
.RateLimitException
;
15 import org
.asamk
.signal
.manager
.api
.UserAlreadyExistsException
;
16 import org
.freedesktop
.dbus
.DBusPath
;
18 import java
.io
.IOException
;
20 import java
.net
.URISyntaxException
;
21 import java
.nio
.channels
.OverlappingFileLockException
;
22 import java
.util
.List
;
23 import java
.util
.concurrent
.TimeoutException
;
25 public class DbusSignalControlImpl
implements org
.asamk
.SignalControl
{
27 private final MultiAccountManager c
;
29 private final String objectPath
;
31 public DbusSignalControlImpl(final MultiAccountManager c
, final String objectPath
) {
33 this.objectPath
= objectPath
;
37 public boolean isRemote() {
42 public String
getObjectPath() {
48 final String number
, final boolean voiceVerification
49 ) throws Error
.Failure
, Error
.InvalidNumber
{
50 registerWithCaptcha(number
, voiceVerification
, null);
54 public void registerWithCaptcha(
55 final String number
, final boolean voiceVerification
, final String captcha
56 ) throws Error
.Failure
, Error
.InvalidNumber
{
57 if (!Manager
.isValidNumber(number
, null)) {
58 throw new SignalControl
.Error
.InvalidNumber(
59 "Invalid account (phone number), make sure you include the country code.");
61 try (final RegistrationManager registrationManager
= c
.getNewRegistrationManager(number
)) {
62 registrationManager
.register(voiceVerification
, captcha
);
63 } catch (RateLimitException e
) {
64 String message
= "Rate limit reached";
65 throw new SignalControl
.Error
.Failure(message
);
66 } catch (CaptchaRequiredException e
) {
67 String message
= captcha
== null ?
"Captcha required for verification." : "Invalid captcha given.";
68 throw new SignalControl
.Error
.RequiresCaptcha(message
);
69 } catch (NonNormalizedPhoneNumberException e
) {
70 throw new Error
.InvalidNumber(e
.getMessage());
71 } catch (OverlappingFileLockException e
) {
72 throw new SignalControl
.Error
.Failure("Account is already in use");
73 } catch (IOException e
) {
74 throw new SignalControl
.Error
.Failure(e
.getClass().getSimpleName() + " " + e
.getMessage());
79 public void verify(final String number
, final String verificationCode
) throws Error
.Failure
, Error
.InvalidNumber
{
80 verifyWithPin(number
, verificationCode
, null);
84 public void verifyWithPin(
85 final String number
, final String verificationCode
, final String pin
86 ) throws Error
.Failure
, Error
.InvalidNumber
{
87 try (final RegistrationManager registrationManager
= c
.getNewRegistrationManager(number
)) {
88 registrationManager
.verifyAccount(verificationCode
, pin
);
89 } catch (OverlappingFileLockException e
) {
90 throw new SignalControl
.Error
.Failure("Account is already in use");
91 } catch (IOException e
) {
92 throw new SignalControl
.Error
.Failure(e
.getClass().getSimpleName() + " " + e
.getMessage());
93 } catch (PinLockedException e
) {
94 throw new Error
.Failure(
95 "Verification failed! This number is locked with a pin. Hours remaining until reset: "
96 + (e
.getTimeRemaining() / 1000 / 60 / 60));
97 } catch (IncorrectPinException e
) {
98 throw new Error
.Failure("Verification failed! Invalid pin, tries remaining: " + e
.getTriesRemaining());
103 public String
link(final String newDeviceName
) throws Error
.Failure
{
105 final URI deviceLinkUri
= c
.getNewProvisioningDeviceLinkUri();
106 final var thread
= new Thread(() -> {
107 final ProvisioningManager provisioningManager
= c
.getProvisioningManagerFor(deviceLinkUri
);
109 provisioningManager
.finishDeviceLink(newDeviceName
);
110 } catch (IOException
| TimeoutException
| UserAlreadyExistsException e
) {
114 thread
.setName("dbus-link");
116 return deviceLinkUri
.toString();
117 } catch (TimeoutException
| IOException e
) {
118 throw new SignalControl
.Error
.Failure(e
.getClass().getSimpleName() + " " + e
.getMessage());
123 public String
startLink() throws Error
.Failure
{
125 final URI deviceLinkUri
= c
.getNewProvisioningDeviceLinkUri();
126 return deviceLinkUri
.toString();
127 } catch (TimeoutException
| IOException e
) {
128 throw new SignalControl
.Error
.Failure(e
.getClass().getSimpleName() + " " + e
.getMessage());
133 public String
finishLink(String deviceLinkUri
, final String newDeviceName
) throws Error
.Failure
{
135 final var provisioningManager
= c
.getProvisioningManagerFor(new URI(deviceLinkUri
));
136 return provisioningManager
.finishDeviceLink(newDeviceName
);
137 } catch (TimeoutException
| IOException
| UserAlreadyExistsException
| URISyntaxException e
) {
138 throw new SignalControl
.Error
.Failure(e
.getClass().getSimpleName() + " " + e
.getMessage());
143 public String
version() {
144 return BaseConfig
.PROJECT_VERSION
;
148 public List
<DBusPath
> listAccounts() {
149 return c
.getAccountNumbers().stream().map(u
-> new DBusPath(DbusConfig
.getObjectPath(u
))).toList();
153 public DBusPath
getAccount(final String number
) {
154 return new DBusPath(DbusConfig
.getObjectPath(number
));