packages/moxxmpp/lib/src/connection.dart

@@ -226,7 +226,7 @@ class XmppConnection {
   /// Registers a list of [XmppManagerBase] sub-classes as managers on this connection.
   Future<void> registerManagers(List<XmppManagerBase> managers) async {
     for (final manager in managers) {
-      _log.finest('Registering ${manager.id}');
+      _log.finest('Registering ${manager.getId()}');
       manager.register(
         XmppManagerAttributes(
           sendStanza: sendStanza,
@@ -242,7 +242,8 @@ class XmppConnection {
         ),
       );
 
-      _xmppManagers[manager.id] = manager;
+      final id = manager.getId();
+      _xmppManagers[id] = manager;
 
       _incomingStanzaHandlers.addAll(manager.getIncomingStanzaHandlers());
       _incomingPreStanzaHandlers.addAll(manager.getIncomingPreStanzaHandlers());
@@ -259,7 +260,7 @@ class XmppConnection {
     // Run the post register callbacks
     for (final manager in _xmppManagers.values) {
       if (!manager.initialized) {
-        _log.finest('Running post-registration callback for ${manager.name}');
+        _log.finest('Running post-registration callback for ${manager.getName()}');
         await manager.postRegisterCallback();
       }
     }

packages/moxxmpp/lib/src/managers/base.dart

@@ -10,8 +10,6 @@ import 'package:moxxmpp/src/xeps/xep_0030/types.dart';
 import 'package:moxxmpp/src/xeps/xep_0030/xep_0030.dart';
 
 abstract class XmppManagerBase {
-  XmppManagerBase(this.id);
-
   late final XmppManagerAttributes _managerAttributes;
   late final Logger _log;
 
@@ -21,7 +19,7 @@ abstract class XmppManagerBase {
   /// Registers the callbacks from XmppConnection with the manager
   void register(XmppManagerAttributes attributes) {
     _managerAttributes = attributes;
-    _log = Logger(name);
+    _log = Logger(getName());
   }
   
   /// Returns the attributes that are registered with the manager.
@@ -62,11 +60,11 @@ abstract class XmppManagerBase {
   List<Identity> getDiscoIdentities() => [];
   
   /// Return the Id (akin to xmlns) of this manager.
-  final String id;
+  String getId();
+
+  /// Return a name that will be used for logging.
+  String getName();
 
-  /// The name of the manager.
-  String get name => toString();
-  
   /// Return the logger for this manager.
   Logger get logger => _log;
   

packages/moxxmpp/lib/src/message.dart

@@ -76,7 +76,11 @@ class MessageDetails {
 }
 
 class MessageManager extends XmppManagerBase {
-  MessageManager() : super(messageManager);
+  @override
+  String getId() => messageManager;
+
+  @override
+  String getName() => 'MessageManager';
 
   @override
   List<StanzaHandler> getIncomingStanzaHandlers() => [

packages/moxxmpp/lib/src/ping.dart

@@ -4,7 +4,11 @@ import 'package:moxxmpp/src/managers/namespaces.dart';
 import 'package:moxxmpp/src/xeps/xep_0198/xep_0198.dart';
 
 class PingManager extends XmppManagerBase {
-  PingManager() : super(pingManager);
+  @override
+  String getId() => pingManager;
+
+  @override
+  String getName() => 'PingManager';
 
   @override
   Future<bool> isSupported() async => true;

packages/moxxmpp/lib/src/presence.dart

@@ -17,10 +17,16 @@ typedef PresencePreSendCallback = Future<List<XMLNode>> Function();
 /// A mandatory manager that handles initial presence sending, sending of subscription
 /// request management requests and triggers events for incoming presence stanzas.
 class PresenceManager extends XmppManagerBase {
-  PresenceManager() : super(presenceManager);
+  PresenceManager() : super();
 
   /// The list of pre-send callbacks.
   final List<PresencePreSendCallback> _presenceCallbacks = List.empty(growable: true);
+  
+  @override
+  String getId() => presenceManager;
+
+  @override
+  String getName() => 'PresenceManager';
 
   @override
   List<StanzaHandler> getIncomingStanzaHandlers() => [

packages/moxxmpp/lib/src/roster/roster.dart

@@ -93,7 +93,7 @@ class RosterFeatureNegotiator extends XmppFeatureNegotiatorBase {
 
 /// This manager requires a RosterFeatureNegotiator to be registered.
 class RosterManager extends XmppManagerBase {
-  RosterManager(this._stateManager) : super(rosterManager);
+  RosterManager(this._stateManager) : super();
 
   /// The class managing the entire roster state.
   final BaseRosterStateManager _stateManager;
@@ -104,6 +104,12 @@ class RosterManager extends XmppManagerBase {
     _stateManager.register(attributes.sendEvent); 
   }
   
+  @override
+  String getId() => rosterManager;
+
+  @override
+  String getName() => 'RosterManager';
+
   @override
   List<StanzaHandler> getIncomingStanzaHandlers() => [
     StanzaHandler(

packages/moxxmpp/lib/src/util/wait.dart

@@ -1,67 +0,0 @@
-import 'dart:async';
-import 'package:meta/meta.dart';
-import 'package:synchronized/synchronized.dart';
-
-/// This class allows for multiple asynchronous code places to wait on the
-/// same computation of type [V], indentified by a key of type [K].
-class WaitForTracker<K, V> {
-  /// The mapping of key -> Completer for the pending tasks.
-  final Map<K, List<Completer<V>>> _tracker = {};
-
-  /// The lock for accessing _tracker.
-  final Lock _lock = Lock();
-
-  /// Wait for a task with key [key]. If there was no such task already
-  /// present, returns null. If one or more tasks were already present, returns
-  /// a future that will resolve to the result of the first task.
-  Future<Future<V>?> waitFor(K key) async {
-    final result = await _lock.synchronized(() {
-      if (_tracker.containsKey(key)) {
-        // The task already exists. Just append outselves
-        final completer = Completer<V>();
-        _tracker[key]!.add(completer);
-        return completer;
-      }
-
-      // The task does not exist yet
-      _tracker[key] = List<Completer<V>>.empty(growable: true);
-      return null;
-    });
-
-    return result?.future;
-  }
-
-  /// Resolve a task with key [key] to [value].
-  Future<void> resolve(K key, V value) async {
-    await _lock.synchronized(() {
-      if (!_tracker.containsKey(key)) return;
-
-      for (final completer in _tracker[key]!) {
-        completer.complete(value);
-      }
-
-      _tracker.remove(key);
-    });
-  }
-
-  Future<void> resolveAll(V value) async {
-    await _lock.synchronized(() {
-      for (final key in _tracker.keys) {
-        for (final completer in _tracker[key]!) {
-          completer.complete(value);
-        }
-      }
-    });
-  }
-  
-  /// Remove all tasks from the tracker.
-  Future<void> clear() async {
-    await _lock.synchronized(_tracker.clear);
-  }
-
-  @visibleForTesting
-  bool hasTasksRunning() => _tracker.isNotEmpty;
-
-  @visibleForTesting
-  List<Completer<V>> getRunningTasks(K key) => _tracker[key]!;
-}

packages/moxxmpp/lib/src/xeps/staging/file_upload_notification.dart

@@ -11,7 +11,13 @@ import 'package:moxxmpp/src/xeps/xep_0446.dart';
 const fileUploadNotificationXmlns = 'proto:urn:xmpp:fun:0';
 
 class FileUploadNotificationManager extends XmppManagerBase {
-  FileUploadNotificationManager() : super(fileUploadNotificationManager);
+  FileUploadNotificationManager() : super();
+
+  @override
+  String getId() => fileUploadNotificationManager;
+
+  @override
+  String getName() => 'FileUploadNotificationManager';
 
   @override
   List<StanzaHandler> getIncomingStanzaHandlers() => [

packages/moxxmpp/lib/src/xeps/xep_0030/cache.dart

@@ -1,23 +0,0 @@
-import 'package:meta/meta.dart';
-
-@internal
-@immutable
-class DiscoCacheKey {
-  const DiscoCacheKey(this.jid, this.node);
-  
-  /// The JID we're requesting disco data from.
-  final String jid;
-
-  /// Optionally the node we are requesting from.
-  final String? node;
-
-  @override
-  bool operator ==(Object other) {
-    return other is DiscoCacheKey &&
-           jid == other.jid &&
-           node == other.node;
-  }
-  
-  @override
-  int get hashCode => jid.hashCode ^ node.hashCode;
-}

packages/moxxmpp/lib/src/xeps/xep_0030/xep_0030.dart

@@ -1,6 +1,5 @@
 import 'dart:async';
 import 'package:meta/meta.dart';
-import 'package:moxxmpp/src/connection.dart';
 import 'package:moxxmpp/src/events.dart';
 import 'package:moxxmpp/src/jid.dart';
 import 'package:moxxmpp/src/managers/base.dart';
@@ -11,8 +10,6 @@ import 'package:moxxmpp/src/namespaces.dart';
 import 'package:moxxmpp/src/stanza.dart';
 import 'package:moxxmpp/src/stringxml.dart';
 import 'package:moxxmpp/src/types/result.dart';
-import 'package:moxxmpp/src/util/wait.dart';
-import 'package:moxxmpp/src/xeps/xep_0030/cache.dart';
 import 'package:moxxmpp/src/xeps/xep_0030/errors.dart';
 import 'package:moxxmpp/src/xeps/xep_0030/helpers.dart';
 import 'package:moxxmpp/src/xeps/xep_0030/types.dart';
@@ -25,6 +22,21 @@ typedef DiscoInfoRequestCallback = Future<DiscoInfo> Function();
 /// Callback that is called when a disco#items requests is received on a given node.
 typedef DiscoItemsRequestCallback = Future<List<DiscoItem>> Function();
 
+@immutable
+class DiscoCacheKey {
+  const DiscoCacheKey(this.jid, this.node);
+  final String jid;
+  final String? node;
+
+  @override
+  bool operator ==(Object other) {
+    return other is DiscoCacheKey && jid == other.jid && node == other.node;
+  }
+  
+  @override
+  int get hashCode => jid.hashCode ^ node.hashCode;
+}
+
 /// This manager implements XEP-0030 by providing a way of performing disco#info and
 /// disco#items requests and answering those requests.
 /// A caching mechanism is also provided.
@@ -33,7 +45,7 @@ class DiscoManager extends XmppManagerBase {
   /// to a disco#info response.
   DiscoManager(List<Identity> identities)
     : _identities = List<Identity>.from(identities),
-      super(discoManager);
+      super();
 
   /// Our features
   final List<String> _features = List.empty(growable: true);
@@ -50,11 +62,8 @@ class DiscoManager extends XmppManagerBase {
   /// Map full JID to Disco Info
   final Map<DiscoCacheKey, DiscoInfo> _discoInfoCache = {};
 
-  /// The tracker for tracking disco#info queries that are in flight.
-  final WaitForTracker<DiscoCacheKey, Result<DiscoError, DiscoInfo>> _discoInfoTracker = WaitForTracker();
-
-  /// The tracker for tracking disco#info queries that are in flight.
-  final WaitForTracker<DiscoCacheKey, Result<DiscoError, List<DiscoItem>>> _discoItemsTracker = WaitForTracker();
+  /// Mapping the full JID to a list of running requests
+  final Map<DiscoCacheKey, List<Completer<Result<DiscoError, DiscoInfo>>>> _runningInfoQueries = {};
 
   /// Cache lock
   final Lock _cacheLock = Lock();
@@ -70,9 +79,12 @@ class DiscoManager extends XmppManagerBase {
 
   /// The list of disco features that are registered.
   List<String> get features => _features;
+  
+  @visibleForTesting
+  bool hasInfoQueriesRunning() => _runningInfoQueries.isNotEmpty;
 
   @visibleForTesting
-  WaitForTracker<DiscoCacheKey, Result<DiscoError, DiscoInfo>> get infoTracker => _discoInfoTracker;
+  List<Completer<Result<DiscoError, DiscoInfo>>> getRunningInfoQueries(DiscoCacheKey key) => _runningInfoQueries[key]!;
   
   @override
   List<StanzaHandler> getIncomingStanzaHandlers() => [
@@ -90,6 +102,12 @@ class DiscoManager extends XmppManagerBase {
     ),
   ];
 
+  @override
+  String getId() => discoManager;
+
+  @override
+  String getName() => 'DiscoManager';
+
   @override
   List<String> getDiscoFeatures() => [ discoInfoXmlns, discoItemsXmlns ];
 
@@ -100,21 +118,7 @@ class DiscoManager extends XmppManagerBase {
   Future<void> onXmppEvent(XmppEvent event) async {
     if (event is PresenceReceivedEvent) {
       await _onPresence(event.jid, event.presence);
-    } else if (event is ConnectionStateChangedEvent) {
-      // TODO(Unknown): This handling is stupid. We should have an event that is
-      //                triggered when we cannot guarantee that everything is as
-      //                it was before.
-      if (event.state != XmppConnectionState.connected) return;
-      if (event.resumed) return;
-
-      // Cancel all waiting requests
-      await _discoInfoTracker.resolveAll(
-        Result<DiscoError, DiscoInfo>(UnknownDiscoError()),
-      );
-      await _discoItemsTracker.resolveAll(
-        Result<DiscoError, List<DiscoItem>>(UnknownDiscoError()),
-      );
-      
+    } else if (event is StreamResumeFailedEvent) {
       await _cacheLock.synchronized(() async {
         // Clear the cache
         _discoInfoCache.clear();
@@ -255,37 +259,46 @@ class DiscoManager extends XmppManagerBase {
   }
 
   Future<void> _exitDiscoInfoCriticalSection(DiscoCacheKey key, Result<DiscoError, DiscoInfo> result) async {
-    await _cacheLock.synchronized(() async {
+    return _cacheLock.synchronized(() async {
+      // Complete all futures
+      for (final completer in _runningInfoQueries[key]!) {
+        completer.complete(result);
+      }
+
       // Add to cache if it is a result
       if (result.isType<DiscoInfo>()) {
         _discoInfoCache[key] = result.get<DiscoInfo>();
       }
+      
+      // Remove from the request cache
+      _runningInfoQueries.remove(key);
     });
-
-    await _discoInfoTracker.resolve(key, result);
   }
   
   /// Sends a disco info query to the (full) jid [entity], optionally with node=[node].
   Future<Result<DiscoError, DiscoInfo>> discoInfoQuery(String entity, { String? node, bool shouldEncrypt = true }) async {
     final cacheKey = DiscoCacheKey(entity, node);
     DiscoInfo? info;
-    final ffuture = await _cacheLock.synchronized<Future<Future<Result<DiscoError, DiscoInfo>>?>?>(() async {
+    Completer<Result<DiscoError, DiscoInfo>>? completer;
+    await _cacheLock.synchronized(() async {
       // Check if we already know what the JID supports
       if (_discoInfoCache.containsKey(cacheKey)) {
         info = _discoInfoCache[cacheKey];
-        return null;
       } else {
-        return _discoInfoTracker.waitFor(cacheKey);
+        // Is a request running?
+        if (_runningInfoQueries.containsKey(cacheKey)) {
+          completer = Completer();
+          _runningInfoQueries[cacheKey]!.add(completer!);
+        } else {
+          _runningInfoQueries[cacheKey] = List.from(<Completer<DiscoInfo?>>[]);
+        }
       }
     });
 
     if (info != null) {
       return Result<DiscoError, DiscoInfo>(info);
-    } else {
-      final future = await ffuture;
-      if (future != null) {
-        return future;
-      }
+    } else if (completer != null) {
+      return completer!.future;
     }
 
     final stanza = await getAttributes().sendStanza(
@@ -318,12 +331,6 @@ class DiscoManager extends XmppManagerBase {
 
   /// Sends a disco items query to the (full) jid [entity], optionally with node=[node].
   Future<Result<DiscoError, List<DiscoItem>>> discoItemsQuery(String entity, { String? node, bool shouldEncrypt = true }) async {
-    final key = DiscoCacheKey(entity, node);
-    final future = await _discoItemsTracker.waitFor(key);
-    if (future != null) {
-      return future;
-    }
-
     final stanza = await getAttributes()
       .sendStanza(
         buildDiscoItemsQueryStanza(entity, node: node),
@@ -331,18 +338,12 @@ class DiscoManager extends XmppManagerBase {
       ) as Stanza;
 
     final query = stanza.firstTag('query');
-    if (query == null) {
-      final result = Result<DiscoError, List<DiscoItem>>(InvalidResponseDiscoError());
-      await _discoItemsTracker.resolve(key, result);
-      return result;
-    }
+    if (query == null) return Result(InvalidResponseDiscoError());
 
     if (stanza.type == 'error') {
       //final error = stanza.firstTag('error');
       //print("Disco Items error: " + error.toXml());
-      final result = Result<DiscoError, List<DiscoItem>>(ErrorResponseDiscoError());
-      await _discoItemsTracker.resolve(key, result);
-      return result;
+      return Result(ErrorResponseDiscoError());
     }
 
     final items = query.findTags('item').map((node) => DiscoItem(
@@ -351,9 +352,7 @@ class DiscoManager extends XmppManagerBase {
       name: node.attributes['name'] as String?,
     ),).toList();
 
-    final result = Result<DiscoError, List<DiscoItem>>(items);
-    await _discoItemsTracker.resolve(key, result);
-    return result;
+    return Result(items);
   }
 
   /// Queries information about a jid based on its node and capability hash.

packages/moxxmpp/lib/src/xeps/xep_0054.dart

@@ -28,9 +28,15 @@ class VCard {
 }
 
 class VCardManager extends XmppManagerBase {
-  VCardManager() : super(vcardManager);
-  final Map<String, String> _lastHash = {};
+  VCardManager() : _lastHash = {}, super();
+  final Map<String, String> _lastHash;
   
+  @override
+  String getId() => vcardManager;
+
+  @override
+  String getName() => 'vCardManager';
+
   @override
   List<StanzaHandler> getIncomingStanzaHandlers() => [
     StanzaHandler(

packages/moxxmpp/lib/src/xeps/xep_0060/xep_0060.dart

@@ -69,7 +69,11 @@ class PubSubItem {
 }
 
 class PubSubManager extends XmppManagerBase {
-  PubSubManager() : super(pubsubManager);
+  @override
+  String getId() => pubsubManager;
+
+  @override
+  String getName() => 'PubsubManager';
 
   @override
   List<StanzaHandler> getIncomingStanzaHandlers() => [

packages/moxxmpp/lib/src/xeps/xep_0066.dart

@@ -8,6 +8,7 @@ import 'package:moxxmpp/src/stringxml.dart';
 
 /// A data class representing the jabber:x:oob tag.
 class OOBData {
+
   const OOBData({ this.url, this.desc });
   final String? url;
   final String? desc;
@@ -31,7 +32,11 @@ XMLNode constructOOBNode(OOBData data) {
 }
 
 class OOBManager extends XmppManagerBase {
-  OOBManager() : super(oobManager);
+  @override
+  String getName() => 'OOBName';
+
+  @override
+  String getId() => oobManager;
 
   @override
   List<String> getDiscoFeatures() => [ oobDataXmlns ];

packages/moxxmpp/lib/src/xeps/xep_0084.dart

@@ -28,24 +28,24 @@ class UserAvatarMetadata {
     this.height,
     this.mime,
   );
-
   /// The amount of bytes in the file
   final int length;
-
   /// The identifier of the avatar
   final String id;
-
   /// Image proportions
   final int width;
   final int height;
-
   /// The MIME type of the avatar
   final String mime;
 }
 
 /// NOTE: This class requires a PubSubManager
 class UserAvatarManager extends XmppManagerBase {
-  UserAvatarManager() : super(userAvatarManager);
+  @override
+  String getId() => userAvatarManager;
+
+  @override
+  String getName() => 'UserAvatarManager';
 
   PubSubManager _getPubSubManager() => getAttributes().getManagerById(pubsubManager)! as PubSubManager;
   

packages/moxxmpp/lib/src/xeps/xep_0085.dart

@@ -39,11 +39,15 @@ ChatState chatStateFromString(String raw) {
 String chatStateToString(ChatState state) => state.toString().split('.').last;
 
 class ChatStateManager extends XmppManagerBase {
-  ChatStateManager() : super(chatStateManager);
-
   @override
   List<String> getDiscoFeatures() => [ chatStateXmlns ];
 
+  @override
+  String getName() => 'ChatStateManager';
+
+  @override
+  String getId() => chatStateManager;
+
   @override
   List<StanzaHandler> getIncomingStanzaHandlers() => [
     StanzaHandler(

packages/moxxmpp/lib/src/xeps/xep_0115.dart

@@ -71,7 +71,7 @@ Future<String> calculateCapabilityHash(DiscoInfo info, HashAlgorithm algorithm)
 /// the DiscoManager.
 /// NOTE: This manager requires that the DiscoManager is also registered.
 class EntityCapabilitiesManager extends XmppManagerBase {
-  EntityCapabilitiesManager(this._capabilityHashBase) : super(entityCapabilitiesManager);
+  EntityCapabilitiesManager(this._capabilityHashBase) : super();
 
   /// The string that is both the node under which we advertise the disco info
   /// and the base for the actual node on which we respond to disco#info requests.
@@ -80,11 +80,19 @@ class EntityCapabilitiesManager extends XmppManagerBase {
   /// The cached capability hash.
   String? _capabilityHash;
 
+  @override
+  String getName() => 'EntityCapabilitiesManager';
+  
+  @override
+  String getId() => entityCapabilitiesManager;
+
   @override
   Future<bool> isSupported() async => true;
 
   @override
-  List<String> getDiscoFeatures() => [ capsXmlns ];
+  List<String> getDiscoFeatures() => [
+    capsXmlns,
+  ];
 
   /// Computes, if required, the capability hash of the data provided by
   /// the DiscoManager.

packages/moxxmpp/lib/src/xeps/xep_0184.dart

@@ -24,11 +24,15 @@ XMLNode makeMessageDeliveryResponse(String id) {
 }
 
 class MessageDeliveryReceiptManager extends XmppManagerBase {
-  MessageDeliveryReceiptManager() : super(messageDeliveryReceiptManager);
-
   @override
   List<String> getDiscoFeatures() => [ deliveryXmlns ];
 
+  @override
+  String getName() => 'MessageDeliveryReceiptManager';
+
+  @override
+  String getId() => messageDeliveryReceiptManager;
+
   @override
   List<StanzaHandler> getIncomingStanzaHandlers() => [
     StanzaHandler(

packages/moxxmpp/lib/src/xeps/xep_0191.dart

@@ -9,10 +9,16 @@ import 'package:moxxmpp/src/stringxml.dart';
 import 'package:moxxmpp/src/xeps/xep_0030/xep_0030.dart';
 
 class BlockingManager extends XmppManagerBase {
-  BlockingManager() : super(blockingManager);
+  BlockingManager() : _supported = false, _gotSupported = false, super();
 
-  bool _supported = false;
-  bool _gotSupported = false;
+  bool _supported;
+  bool _gotSupported;
+
+  @override
+  String getId() => blockingManager;
+
+  @override
+  String getName() => 'BlockingManager';
 
   @override
   List<StanzaHandler> getIncomingStanzaHandlers() => [

packages/moxxmpp/lib/src/xeps/xep_0198/xep_0198.dart

@@ -21,41 +21,40 @@ const xmlUintMax = 4294967296; // 2**32
 typedef StanzaAckedCallback = bool Function(Stanza stanza);
 
 class StreamManagementManager extends XmppManagerBase {
+
   StreamManagementManager({
     this.ackTimeout = const Duration(seconds: 30),
-  }) : super(smManager);
-
+  })
+  : _state = StreamManagementState(0, 0),
+    _unackedStanzas = {},
+    _stateLock = Lock(),
+    _streamManagementEnabled = false,
+    _lastAckTimestamp = -1,
+    _pendingAcks = 0,
+    _streamResumed = false,
+    _ackLock = Lock();
   /// The queue of stanzas that are not (yet) acked
-  final Map<int, Stanza> _unackedStanzas = {};
-
+  final Map<int, Stanza> _unackedStanzas;
   /// Commitable state of the StreamManagementManager
-  StreamManagementState _state = StreamManagementState(0, 0);
-
+  StreamManagementState _state;
   /// Mutex lock for _state
-  final Lock _stateLock = Lock();
-
+  final Lock _stateLock;
   /// If the have enabled SM on the stream yet
-  bool _streamManagementEnabled = false;
-
+  bool _streamManagementEnabled;
   /// If the current stream has been resumed;
-  bool _streamResumed = false;
-
+  bool _streamResumed;
   /// The time in which the response to an ack is still valid. Counts as a timeout
   /// otherwise
   @internal
   final Duration ackTimeout;
-
   /// The time at which the last ack has been sent
-  int _lastAckTimestamp = -1;
-
+  int _lastAckTimestamp;
   /// The timer to see if we timed the connection out
   Timer? _ackTimer;
-
   /// Counts how many acks we're waiting for
-  int _pendingAcks = 0;
-
+  int _pendingAcks;
   /// Lock for both [_lastAckTimestamp] and [_pendingAcks].
-  final Lock _ackLock = Lock();
+  final Lock _ackLock;
 
   /// Functions for testing
   @visibleForTesting
@@ -121,6 +120,12 @@ class StreamManagementManager extends XmppManagerBase {
   StreamManagementState get state => _state;
 
   bool get streamResumed => _streamResumed;
+  
+  @override
+  String getId() => smManager;
+
+  @override
+  String getName() => 'StreamManagementManager';
 
   @override
   List<NonzaHandler> getNonzaHandlers() => [

packages/moxxmpp/lib/src/xeps/xep_0203.dart

@@ -14,7 +14,11 @@ class DelayedDelivery {
 }
 
 class DelayedDeliveryManager extends XmppManagerBase {
-  DelayedDeliveryManager() : super(delayedDeliveryManager);
+  @override
+  String getId() => delayedDeliveryManager;
+
+  @override
+  String getName() => 'DelayedDeliveryManager';
 
   @override
   Future<bool> isSupported() async => true;

packages/moxxmpp/lib/src/xeps/xep_0280.dart

@@ -14,7 +14,7 @@ import 'package:moxxmpp/src/xeps/xep_0297.dart';
 
 /// This manager class implements support for XEP-0280.
 class CarbonsManager extends XmppManagerBase {
-  CarbonsManager() : super(carbonsManager);
+  CarbonsManager() : super();
 
   /// Indicates that message carbons are enabled.
   bool _isEnabled = false;
@@ -25,6 +25,12 @@ class CarbonsManager extends XmppManagerBase {
   /// Indicates that we know that [CarbonsManager._supported] is accurate.
   bool _gotSupported = false;
   
+  @override
+  String getId() => carbonsManager;
+
+  @override
+  String getName() => 'CarbonsManager';
+
   @override
   List<StanzaHandler> getIncomingPreStanzaHandlers() => [
     StanzaHandler(

packages/moxxmpp/lib/src/xeps/xep_0300.dart

@@ -61,7 +61,11 @@ HashFunction hashFunctionFromName(String name) {
 }
 
 class CryptographicHashManager extends XmppManagerBase {
-  CryptographicHashManager() : super(cryptographicHashManager);
+  @override
+  String getId() => cryptographicHashManager;
+
+  @override
+  String getName() => 'CryptographicHashManager';
 
   @override
   Future<bool> isSupported() async => true;
@@ -77,7 +81,7 @@ class CryptographicHashManager extends XmppManagerBase {
   ];
 
   static Future<List<int>> hashFromData(List<int> data, HashFunction function) async {
-    // TODO(PapaTutuWawa): Implement the others as well
+    // TODO(PapaTutuWawa): Implemen the others as well
     HashAlgorithm algo;
     switch (function) {
       case HashFunction.sha256:

packages/moxxmpp/lib/src/xeps/xep_0308.dart

@@ -17,7 +17,11 @@ XMLNode makeLastMessageCorrectionEdit(String id) {
 }
 
 class LastMessageCorrectionManager extends XmppManagerBase {
-  LastMessageCorrectionManager() : super(lastMessageCorrectionManager);
+  @override
+  String getName() => 'LastMessageCorrectionManager';
+
+  @override
+  String getId() => lastMessageCorrectionManager;
 
   @override
   List<String> getDiscoFeatures() => [ lmcXmlns ];

packages/moxxmpp/lib/src/xeps/xep_0333.dart

@@ -25,7 +25,11 @@ XMLNode makeChatMarker(String tag, String id) {
 }
 
 class ChatMarkerManager extends XmppManagerBase {
-  ChatMarkerManager() : super(chatMarkerManager);
+  @override
+  String getName() => 'ChatMarkerManager';
+
+  @override
+  String getId() => chatMarkerManager;
 
   @override
   List<String> getDiscoFeatures() => [ chatMarkersXmlns ];

packages/moxxmpp/lib/src/xeps/xep_0352.dart

@@ -26,10 +26,10 @@ class CSIInactiveNonza extends XMLNode {
 
 /// A Stub negotiator that is just for "intercepting" the stream feature.
 class CSINegotiator extends XmppFeatureNegotiatorBase {
-  CSINegotiator() : super(11, false, csiXmlns, csiNegotiator);
+  CSINegotiator() : _supported = false, super(11, false, csiXmlns, csiNegotiator);
 
   /// True if CSI is supported. False otherwise.
-  bool _supported = false;
+  bool _supported;
   bool get isSupported => _supported;
   
   @override
@@ -50,9 +50,15 @@ class CSINegotiator extends XmppFeatureNegotiatorBase {
 
 /// The manager requires a CSINegotiator to be registered as a feature negotiator.
 class CSIManager extends XmppManagerBase {
-  CSIManager() : super(csiManager);
 
-  bool _isActive = true;
+  CSIManager() : _isActive = true, super();
+  bool _isActive; 
+
+  @override
+  String getId() => csiManager;
+
+  @override
+  String getName() => 'CSIManager';
 
   @override
   Future<bool> isSupported() async {

packages/moxxmpp/lib/src/xeps/xep_0359.dart

@@ -13,6 +13,7 @@ import 'package:moxxmpp/src/xeps/xep_0030/xep_0030.dart';
 /// NOTE: [StableStanzaId.stanzaId] must not be confused with the actual id attribute of
 ///       the message stanza.
 class StableStanzaId {
+
   const StableStanzaId({ this.originId, this.stanzaId, this.stanzaIdBy });
   final String? originId;
   final String? stanzaId;
@@ -28,7 +29,11 @@ XMLNode makeOriginIdElement(String id) {
 }
 
 class StableIdManager extends XmppManagerBase {
-  StableIdManager() : super(stableIdManager);
+  @override
+  String getName() => 'StableIdManager';
+
+  @override
+  String getId() => stableIdManager;
 
   @override
   List<String> getDiscoFeatures() => [ stableIdXmlns ];

packages/moxxmpp/lib/src/xeps/xep_0363/xep_0363.dart

@@ -41,19 +41,17 @@ Map<String, String> prepareHeaders(Map<String, String> headers) {
 }
 
 class HttpFileUploadManager extends XmppManagerBase {
-  HttpFileUploadManager() : super(httpFileUploadManager);
-
-  /// The entity that we will request file uploads from, if discovered.
+  HttpFileUploadManager() : _gotSupported = false, _supported = false, super();
   JID? _entityJid;
-
-  /// The maximum file upload file size, if advertised and discovered.
   int? _maxUploadSize;
+  bool _gotSupported;
+  bool _supported;
 
-  /// Flag, if we every tried to discover the upload entity.
-  bool _gotSupported = false;
+  @override
+  String getId() => httpFileUploadManager;
 
-  /// Flag, if we can use HTTP File Upload
-  bool _supported = false;
+  @override
+  String getName() => 'HttpFileUploadManager';
 
   /// Returns whether the entity provided an identity that tells us that we can ask it
   /// for an HTTP upload slot.

packages/moxxmpp/lib/src/xeps/xep_0380.dart

@@ -53,12 +53,20 @@ XMLNode buildEmeElement(ExplicitEncryptionType type) {
 }
 
 class EmeManager extends XmppManagerBase {
-  EmeManager() : super(emeManager);
+
+  EmeManager() : super();
+
+  @override
+  String getId() => emeManager;
+
+  @override
+  String getName() => 'EmeManager';
+
   @override
   Future<bool> isSupported() async => true;
 
   @override
-  List<String> getDiscoFeatures() => [ emeXmlns ];
+  List<String> getDiscoFeatures() => [emeXmlns];
   
   @override
   List<StanzaHandler> getIncomingStanzaHandlers() => [

packages/moxxmpp/lib/src/xeps/xep_0384/xep_0384.dart

@@ -42,9 +42,12 @@ const _doNotEncryptList = [
   DoNotEncrypt('stanza-id', stableIdXmlns),
 ];
 
-@mustCallSuper
 abstract class BaseOmemoManager extends XmppManagerBase {
-  BaseOmemoManager() : super(omemoManager);
+  @override
+  String getId() => omemoManager;
+
+  @override
+  String getName() => 'OmemoManager';
 
   // TODO(Unknown): Technically, this is not always true
   @override

packages/moxxmpp/lib/src/xeps/xep_0385.dart

@@ -8,6 +8,7 @@ import 'package:moxxmpp/src/stringxml.dart';
 import 'package:moxxmpp/src/xeps/staging/extensible_file_thumbnails.dart';
 
 class StatelessMediaSharingData {
+
   const StatelessMediaSharingData({ required this.mediaType, required this.size, required this.description, required this.hashes, required this.url, required this.thumbnails });
   final String mediaType;
   final int size;
@@ -62,7 +63,11 @@ StatelessMediaSharingData parseSIMSElement(XMLNode node) {
 }
 
 class SIMSManager extends XmppManagerBase {
-  SIMSManager() : super(simsManager);
+  @override
+  String getName() => 'SIMSManager';
+
+  @override
+  String getId() => simsManager;
 
   @override
   List<String> getDiscoFeatures() => [ simsXmlns ];

packages/moxxmpp/lib/src/xeps/xep_0424.dart

@@ -12,7 +12,11 @@ class MessageRetractionData {
 }
 
 class MessageRetractionManager extends XmppManagerBase {
-  MessageRetractionManager() : super(messageRetractionManager);
+  @override
+  String getName() => 'MessageRetractionManager';
+
+  @override
+  String getId() => messageRetractionManager;
 
   @override
   List<String> getDiscoFeatures() => [ messageRetractionXmlns ];

packages/moxxmpp/lib/src/xeps/xep_0444.dart

@@ -29,11 +29,15 @@ class MessageReactions {
 }
 
 class MessageReactionsManager extends XmppManagerBase {
-  MessageReactionsManager() : super(messageReactionsManager);
-
   @override
   List<String> getDiscoFeatures() => [ messageReactionsXmlns ];
 
+  @override
+  String getName() => 'MessageReactionsManager';
+
+  @override
+  String getId() => messageReactionsManager;
+
   @override
   List<StanzaHandler> getIncomingStanzaHandlers() => [
     StanzaHandler(

packages/moxxmpp/lib/src/xeps/xep_0447.dart

@@ -105,7 +105,11 @@ class StatelessFileSharingData {
 }
 
 class SFSManager extends XmppManagerBase {
-  SFSManager() : super(sfsManager);
+  @override
+  String getName() => 'SFSManager';
+
+  @override
+  String getId() => sfsManager;
 
   @override
   List<StanzaHandler> getIncomingStanzaHandlers() => [

packages/moxxmpp/lib/src/xeps/xep_0449.dart

@@ -225,7 +225,11 @@ class StickerPack {
 }
 
 class StickersManager extends XmppManagerBase {
-  StickersManager() : super(stickersManager);
+  @override
+  String getId() => stickersManager;
+
+  @override
+  String getName() => 'StickersManager';
 
   @override
   Future<bool> isSupported() async => true;

packages/moxxmpp/lib/src/xeps/xep_0461.dart

@@ -66,7 +66,11 @@ class QuoteData {
 /// A manager implementing support for parsing XEP-0461 metadata. The
 /// MessageRepliesManager itself does not modify the body of the message.
 class MessageRepliesManager extends XmppManagerBase {
-  MessageRepliesManager() : super(messageRepliesManager);
+  @override
+  String getName() => 'MessageRepliesManager';
+
+  @override
+  String getId() => messageRepliesManager;
 
   @override
   List<String> getDiscoFeatures() => [

packages/moxxmpp/test/wait_test.dart

@@ -1,40 +0,0 @@
-import 'package:test/test.dart';
-import 'package:moxxmpp/src/util/wait.dart';
-
-void main() {
-  test('Test adding and resolving', () async {
-    // ID -> Milliseconds since epoch
-    final tracker = WaitForTracker<int, int>();
-
-    int r2 = 0;
-    int r3 = 0;
-    
-    // Queue some jobs
-    final r1 = await tracker.waitFor(0);
-    expect(r1, null);
-    
-    tracker
-      .waitFor(0)
-      .then((result) async {
-        expect(result != null, true);
-        r2 = await result!;
-      });
-    tracker
-      .waitFor(0)
-      .then((result) async {
-        expect(result != null, true);
-        r3 = await result!;
-      });
-
-    final c = await tracker.waitFor(1);
-    expect(c, null);
-
-    // Resolve jobs
-    await tracker.resolve(0, 42);
-    await tracker.resolve(1, 25);
-    await tracker.resolve(2, -1);
-
-    expect(r2, 42);
-    expect(r3, 42);
-  });
-}

packages/moxxmpp/test/xeps/xep_0030_test.dart

@@ -1,13 +1,9 @@
 import 'package:moxxmpp/moxxmpp.dart';
-import 'package:moxxmpp/src/xeps/xep_0030/cache.dart';
 import 'package:test/test.dart';
 
-import '../helpers/logging.dart';
 import '../helpers/xmpp.dart';
 
 void main() {
-  initLogger();
-
   test('Test having multiple disco requests for the same JID', () async {
     final fakeSocket = StubTCPSocket(
       play: [
@@ -106,7 +102,7 @@ void main() {
 
     await Future.delayed(const Duration(seconds: 1));
     expect(
-      disco.infoTracker.getRunningTasks(DiscoCacheKey(jid.toString(), null)).length,
+      disco.getRunningInfoQueries(DiscoCacheKey(jid.toString(), null)).length,
       1,
     );
     fakeSocket.injectRawXml("<iq type='result' id='${fakeSocket.lastId!}' from='romeo@montague.lit/orchard' to='polynomdivision@test.server/MU29eEZn' xmlns='jabber:client'><query xmlns='http://jabber.org/protocol/disco#info' /></iq>");
@@ -115,6 +111,6 @@ void main() {
     
     expect(fakeSocket.getState(), 6);
     expect(await result1, await result2);
-    expect(disco.infoTracker.hasTasksRunning(), false);
+    expect(disco.hasInfoQueriesRunning(), false);
   });
 }