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);
private final Set<Consumer<Manager>> onManagerRemovedHandlers = new HashSet<>();
private final Set<Manager> managers = new HashSet<>();
private final Map<URI, ProvisioningManager> provisioningManagers = new HashMap<>();
- private final File dataPath;
+ private final File settingsPath;
private final ServiceEnvironment serviceEnvironment;
private final String userAgent;
public MultiAccountManagerImpl(
final Collection<Manager> 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;
}
@Override
public List<String> getAccountNumbers() {
synchronized (managers) {
- return managers.stream().map(Manager::getSelfNumber).collect(Collectors.toList());
+ return managers.stream().map(Manager::getSelfNumber).toList();
+ }
+ }
+
+ @Override
+ public List<Manager> getManagers() {
+ synchronized (managers) {
+ return new ArrayList<>(managers);
}
}
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