X-Git-Url: https://git.nmode.ca/signal-cli/blobdiff_plain/c9928043b2d23ae89de376eb1b567c7f66e461fe..5cccf521032954d7ad8e3f70e3cbef2ce1293e85:/lib/src/main/java/org/asamk/signal/manager/MultiAccountManagerImpl.java diff --git a/lib/src/main/java/org/asamk/signal/manager/MultiAccountManagerImpl.java b/lib/src/main/java/org/asamk/signal/manager/MultiAccountManagerImpl.java index 74c4c20a..4c67fd12 100644 --- a/lib/src/main/java/org/asamk/signal/manager/MultiAccountManagerImpl.java +++ b/lib/src/main/java/org/asamk/signal/manager/MultiAccountManagerImpl.java @@ -16,9 +16,8 @@ import java.util.Map; import java.util.Set; import java.util.concurrent.TimeoutException; import java.util.function.Consumer; -import java.util.stream.Collectors; -public class MultiAccountManagerImpl implements MultiAccountManager { +class MultiAccountManagerImpl implements MultiAccountManager { private final static Logger logger = LoggerFactory.getLogger(MultiAccountManagerImpl.class); @@ -26,19 +25,19 @@ public class MultiAccountManagerImpl implements MultiAccountManager { private final Set> onManagerRemovedHandlers = new HashSet<>(); private final Set managers = new HashSet<>(); private final Map provisioningManagers = new HashMap<>(); - private final File dataPath; + private final File settingsPath; private final ServiceEnvironment serviceEnvironment; private final String userAgent; public MultiAccountManagerImpl( final Collection managers, - final File dataPath, + final File settingsPath, final ServiceEnvironment serviceEnvironment, final String userAgent ) { this.managers.addAll(managers); managers.forEach(m -> m.addClosedListener(() -> this.removeManager(m))); - this.dataPath = dataPath; + this.settingsPath = settingsPath; this.serviceEnvironment = serviceEnvironment; this.userAgent = userAgent; } @@ -46,7 +45,14 @@ public class MultiAccountManagerImpl implements MultiAccountManager { @Override public List getAccountNumbers() { synchronized (managers) { - return managers.stream().map(Manager::getSelfNumber).collect(Collectors.toList()); + return managers.stream().map(Manager::getSelfNumber).toList(); + } + } + + @Override + public List getManagers() { + synchronized (managers) { + return new ArrayList<>(managers); } } @@ -112,14 +118,13 @@ public class MultiAccountManagerImpl implements MultiAccountManager { return provisioningManagers.remove(deviceLinkUri); } - @Override - public ProvisioningManager getNewProvisioningManager() { - return ProvisioningManager.init(dataPath, serviceEnvironment, userAgent, this::addManager); + private ProvisioningManager getNewProvisioningManager() { + return ProvisioningManager.init(settingsPath, serviceEnvironment, userAgent, this::addManager); } @Override public RegistrationManager getNewRegistrationManager(String account) throws IOException { - return RegistrationManager.init(account, dataPath, serviceEnvironment, userAgent, this::addManager); + return RegistrationManager.init(account, settingsPath, serviceEnvironment, userAgent, this::addManager); } @Override