test: SshnpdChannel

packages/noports_core/lib/src/common/mixins/async_initialization.dart

@@ -10,7 +10,7 @@ mixin class AsyncInitialization {
   // * Public members
 
   /// Used to check if initialization has started
-  bool get initalizeStarted => _initializeStarted;
+  bool get initializeStarted => _initializeStarted;
 
   /// Used to check if initialization has completed
   Future<void> get initialized => _initializedCompleter.future;

packages/noports_core/lib/src/sshnp/util/sshnpd_channel/sshnpd_channel.dart

@@ -57,11 +57,12 @@ abstract class SshnpdChannel with AsyncInitialization, AtClientBindings {
     subscribe(
       regex: regex,
       shouldDecrypt: true,
-    ).listen(_handleSshnpdResponses);
+    ).listen(handleSshnpdResponses);
   }
 
   /// Main reponse handler for the daemon's notifications.
-  Future<void> _handleSshnpdResponses(AtNotification notification) async {
+  @visibleForTesting
+  Future<void> handleSshnpdResponses(AtNotification notification) async {
     String notificationKey = notification.key
         .replaceAll('${notification.to}:', '')
         .replaceAll('.$namespace@${notification.from}', '')
@@ -183,7 +184,7 @@ abstract class SshnpdChannel with AsyncInitialization, AtClientBindings {
         'device_info\\.$sshnpDeviceNameRegex\\.${DefaultArgs.namespace}';
 
     var atKeys =
-        await _getAtKeysRemote(regex: scanRegex, sharedBy: params.sshnpdAtSign);
+        await getAtKeysRemote(regex: scanRegex, sharedBy: params.sshnpdAtSign);
 
     SshnpDeviceList deviceList = SshnpDeviceList();
 
@@ -234,7 +235,8 @@ abstract class SshnpdChannel with AsyncInitialization, AtClientBindings {
   }
 
   /// A custom implementation of AtClient.getAtKeys which bypasses the cache
-  Future<List<AtKey>> _getAtKeysRemote(
+  @visibleForTesting
+  Future<List<AtKey>> getAtKeysRemote(
       {String? regex,
       String? sharedBy,
       String? sharedWith,

packages/noports_core/test/sshnp/sshnp_mocks.dart

@@ -11,6 +11,12 @@ abstract class FunctionCaller<T> {
 
 class FunctionStub<T> extends Mock implements FunctionCaller<T> {}
 
+abstract class NotifyCaller {
+  Future<void> call(AtKey key, String value);
+}
+
+class NotifyStub extends Mock implements NotifyCaller {}
+
 abstract class SubscribeCaller {
   Stream<AtNotification> call({String? regex, bool shouldDecrypt});
 }

packages/noports_core/test/sshnp/util/sshnpd_channel/sshnpd_channel_mocks.dart

@@ -0,0 +1,57 @@
+import 'package:at_client/at_client.dart';
+import 'package:mocktail/mocktail.dart';
+import 'package:noports_core/sshnp_foundation.dart';
+
+abstract class HandleSshnpdPayloadCaller {
+  Future<SshnpdAck> call(AtNotification notification);
+}
+
+class HandleSshnpdPayloadStub extends Mock
+    implements HandleSshnpdPayloadCaller {}
+
+class StubbedSshnpdChannel extends SshnpdChannel {
+  final Future<void> Function(AtKey, String)? _notify;
+  final Stream<AtNotification> Function({String? regex, bool shouldDecrypt})?
+      _subscribe;
+  final Future<SshnpdAck> Function(AtNotification notification)?
+      _handleSshnpdPayload;
+
+  StubbedSshnpdChannel({
+    required super.atClient,
+    required super.params,
+    required super.sessionId,
+    required super.namespace,
+    Future<void> Function(AtKey, String)? notify,
+    Stream<AtNotification> Function({String? regex, bool shouldDecrypt})?
+        subscribe,
+    Future<SshnpdAck> Function(AtNotification notification)?
+        handleSshnpdPayload,
+  })  : _notify = notify,
+        _subscribe = subscribe,
+        _handleSshnpdPayload = handleSshnpdPayload;
+
+  @override
+  Future<SshnpdAck> handleSshnpdPayload(AtNotification notification) async {
+    return await _handleSshnpdPayload?.call(notification) ??
+        SshnpdAck.notAcknowledged;
+  }
+
+  @override
+  Future<void> notify(
+    AtKey atKey,
+    String value,
+  ) async {
+    return _notify?.call(atKey, value);
+  }
+
+  @override
+  Stream<AtNotification> subscribe({
+    String? regex,
+    bool shouldDecrypt = false,
+  }) {
+    return _subscribe?.call(regex: regex, shouldDecrypt: shouldDecrypt) ??
+        Stream.empty();
+  }
+}
+
+class MockRemoteSecondary extends Mock implements RemoteSecondary {}