import org.asamk.signal.manager.api.RateLimitException;
import org.asamk.signal.manager.api.UserAlreadyExistsException;
import org.freedesktop.dbus.DBusPath;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
import java.io.IOException;
import java.net.URI;
public class DbusSignalControlImpl implements org.asamk.SignalControl {
+ private static final Logger logger = LoggerFactory.getLogger(DbusSignalControlImpl.class);
private final MultiAccountManager c;
private final String objectPath;
@Override
public String link(final String newDeviceName) throws Error.Failure {
+ final URI deviceLinkUri;
try {
- final URI deviceLinkUri = c.getNewProvisioningDeviceLinkUri();
- final var thread = new Thread(() -> {
- final ProvisioningManager provisioningManager = c.getProvisioningManagerFor(deviceLinkUri);
- try {
- provisioningManager.finishDeviceLink(newDeviceName);
- } catch (IOException | TimeoutException | UserAlreadyExistsException e) {
- e.printStackTrace();
- }
- });
- thread.setName("dbus-link");
- thread.start();
- return deviceLinkUri.toString();
+ deviceLinkUri = c.getNewProvisioningDeviceLinkUri();
} catch (TimeoutException | IOException e) {
throw new SignalControl.Error.Failure(e.getClass().getSimpleName() + " " + e.getMessage());
}
+ Thread.ofPlatform().name("dbus-link").start(() -> {
+ final ProvisioningManager provisioningManager = c.getProvisioningManagerFor(deviceLinkUri);
+ try {
+ provisioningManager.finishDeviceLink(newDeviceName);
+ } catch (IOException | TimeoutException | UserAlreadyExistsException e) {
+ logger.warn("Failed to finish linking", e);
+ }
+ });
+ return deviceLinkUri.toString();
}
@Override