feat: add new method to fetch enrollment requests

packages/at_client/lib/src/client/at_client_impl.dart

@@ -673,6 +673,21 @@ class AtClientImpl implements AtClient, AtSignChangeListener {
     return AtChopsImpl(atChopsKeys);
   }
 
+  @override
+  Future<Map<String, dynamic>> fetchEnrollmentRequests(
+      {String? appName, String? deviceName}) async {
+    EnrollVerbBuilder enrollBuilder = EnrollVerbBuilder()
+      ..operation = EnrollOperationEnum.list
+      ..appName = appName
+      ..deviceName = deviceName;
+
+    var response = await getRemoteSecondary()
+        ?.executeCommand(enrollBuilder.buildCommand(), auth: true);
+    response = response?.replaceFirst('data:', '');
+    Map<String, dynamic> enrollRequests = jsonDecode(response!);
+    return enrollRequests;
+  }
+
   @override
   Future<AtStreamResponse> stream(String sharedWith, String filePath,
       {String? namespace}) async {

packages/at_client/lib/src/client/at_client_spec.dart

@@ -572,4 +572,8 @@ abstract class AtClient {
   String? getCurrentAtSign();
 
   EncryptionService? get encryptionService;
+
+  /// Fetches all enrollment requests from the corresponding atServer
+  Future<Map<String, dynamic>> fetchEnrollmentRequests(
+      {String? appName, String? deviceName});
 }

packages/at_client/lib/src/client/remote_secondary.dart

@@ -33,10 +33,10 @@ class RemoteSecondary implements Secondary {
     logger = AtSignLogger('RemoteSecondary ($_atSign)');
     _preference = preference;
     privateKey ??= preference.privateKey;
-    SecureSocketConfig secureSocketConfig = SecureSocketConfig();
-    secureSocketConfig.decryptPackets = preference.decryptPackets;
-    secureSocketConfig.pathToCerts = preference.pathToCerts;
-    secureSocketConfig.tlsKeysSavePath = preference.tlsKeysSavePath;
+    SecureSocketConfig secureSocketConfig = SecureSocketConfig()
+      ..decryptPackets = preference.decryptPackets
+      ..pathToCerts = preference.pathToCerts
+      ..tlsKeysSavePath = preference.tlsKeysSavePath;
     atLookUp = AtLookupImpl(atSign, preference.rootDomain, preference.rootPort,
         privateKey: privateKey,
         cramSecret: preference.cramSecret,
@@ -107,14 +107,8 @@ class RemoteSecondary implements Secondary {
     // ignore: prefer_typing_uninitialized_variables
     var verbResult;
     try {
-      logger.finer(logger.getLogMessageWithClientParticulars(
-          _preference.atClientParticulars,
-          'Command sent to server: ${builder.buildCommand()}'));
       verbResult = await executeVerb(builder);
       verbResult = verbResult.replaceFirst('data:', '');
-      logger.finer(logger.getLogMessageWithClientParticulars(
-          _preference.atClientParticulars,
-          'Response from server: $verbResult'));
     } on AtException catch (e) {
       throw e
         ..stack(AtChainedException(Intent.fetchData,

packages/at_client/test/at_client_impl_test.dart

@@ -1,3 +1,5 @@
+import 'dart:convert';
+
 import 'package:at_client/at_client.dart';
 import 'package:at_client/src/compaction/at_commit_log_compaction.dart';
 import 'package:at_client/src/service/notification_service_impl.dart';
@@ -20,6 +22,8 @@ class MockAtCompactionJob extends Mock implements AtCompactionJob {
   }
 }
 
+class MockRemoteSecondary extends Mock implements RemoteSecondary {}
+
 void main() {
   group('A group of at client impl create tests', () {
     final String atSign = '@alice';
@@ -251,7 +255,7 @@ void main() {
     });
   });
 
-  group('A group of tests related to setting enrollmentId', () {
+  group('A group of tests related to apkam/enrollments', () {
     test(
         'A test to verify enrollmentId is set in atClient after calling setCurrentAtSign',
         () async {
@@ -261,5 +265,39 @@ void main() {
               enrollmentId: testEnrollmentId);
       expect(atClientManager.atClient.enrollmentId, testEnrollmentId);
     });
+
+    MockRemoteSecondary mockRemoteSecondary = MockRemoteSecondary();
+
+    test('verify behaviour of fetchEnrollmentRequests()', () async {
+      String currentAtsign = '@apkam';
+      String enrollKey1 =
+          '0acdeb4d-1a2e-43e4-93bd-378f1d366ea7.new.enrollments.__manage$currentAtsign';
+      String enrollValue1 =
+          '{"appName":"buzz","deviceName":"pixel","namespace":{"buzz":"rw"}}';
+      String enrollKey2 =
+          '9beefa26-3384-4f10-81a6-0deaa4332669.new.enrollments.__manage$currentAtsign';
+      String enrollValue2 =
+          '{"appName":"buzz","deviceName":"pixel","namespace":{"buzz":"rw"}}';
+      String enrollKey3 =
+          'a6bbef17-c7bf-46f4-a172-1ed7b3b443bc.new.enrollments.__manage$currentAtsign';
+      String enrollValue3 =
+          '{"appName":"buzz","deviceName":"pixel","namespace":{"buzz":"rw"}}';
+      when(() =>
+          mockRemoteSecondary.executeCommand('enroll:list\n',
+              auth: true)).thenAnswer((_) => Future.value('data:{"$enrollKey1":'
+          '$enrollValue1,"$enrollKey2":$enrollValue2,"$enrollKey3":$enrollValue3}'));
+
+      AtClient? client = await AtClientImpl.create(
+          currentAtsign, 'buzz', AtClientPreference(),
+          remoteSecondary: mockRemoteSecondary);
+      AtClientImpl? clientImpl = client as AtClientImpl;
+
+      Map<String, dynamic>? requests =
+          await clientImpl.fetchEnrollmentRequests();
+      expect(requests.length, 3);
+      expect(requests[enrollKey1], jsonDecode(enrollValue1));
+      expect(requests[enrollKey2], jsonDecode(enrollValue2));
+      expect(requests[enrollKey3], jsonDecode(enrollValue3));
+    });
   });
 }

tests/at_functional_test/test/enrollment_test.dart

@@ -26,7 +26,7 @@ void main() {
     await setLastReceivedNotificationDateTime();
   });
 
-  void _stopSubscriptions() {
+  void stopSubscriptions() {
     atClientManager.atClient.notificationService.stopAllSubscriptions();
     print('subscriptions stopped');
   }
@@ -87,9 +87,73 @@ void main() {
           print('got enrollment notification: $enrollNotification');
           expect(enrollNotification.key,
               '$enrollmentIdFromServer.new.enrollments.__manage');
-          _stopSubscriptions();
+          stopSubscriptions();
         }, count: 1, max: 1));
   });
+
+  test(
+      'validate client functionality to fetch pending enrollments on legacy pkam authenticated client',
+      () async {
+    atClientManager = await TestUtils.initAtClient(atSign, 'new_app');
+    AtClient? client = atClientManager.atClient;
+    // fetch first otp
+    String? otp =
+        await TestUtils.executeCommandAndParse(client, 'otp:get', auth: true);
+    expect(otp, isNotNull);
+    // create first enrollment request
+    RemoteSecondary? secondRemoteSecondary =
+        RemoteSecondary(atSign, getClient2Preferences());
+    var apkamPublicKey =
+        at_demos.pkamPublicKeyMap['@eve🛠']; // can be any random public key
+    var newEnrollRequest = TestUtils.formatCommand(
+        'enroll:request:{"appName":"new_app","deviceName":"pixel","namespaces":{"new_app":"rw"},"otp":"$otp","apkamPublicKey":"$apkamPublicKey"}');
+    var enrollResponse = await TestUtils.executeCommandAndParse(
+        null, newEnrollRequest,
+        remoteSecondary: secondRemoteSecondary);
+    Map<String, dynamic> enrollResponse1JsonDecoded =
+        jsonDecode(enrollResponse!);
+    expect(enrollResponse1JsonDecoded['enrollmentId'], isNotNull);
+    expect(enrollResponse1JsonDecoded['status'], 'pending');
+
+    // fetch second otp
+    otp = await TestUtils.executeCommandAndParse(client, 'otp:get', auth: true);
+    expect(otp, isNotNull);
+    // create second enrollment request
+    newEnrollRequest = TestUtils.formatCommand(
+        'enroll:request:{"appName":"new_app","deviceName":"pixel7","namespaces":{"new_app":"rw", "wavi":"r"},"otp":"$otp","apkamPublicKey":"$apkamPublicKey"}');
+    enrollResponse = await TestUtils.executeCommandAndParse(
+        null, newEnrollRequest,
+        remoteSecondary: secondRemoteSecondary);
+    var enrollResponse2JsonDecoded = jsonDecode(enrollResponse!);
+    expect(enrollResponse2JsonDecoded['enrollmentId'], isNotNull);
+    expect(enrollResponse2JsonDecoded['status'], 'pending');
+
+    // fetch enrollment requests through client
+    Map<String, dynamic> enrollmentRequests =
+        await client.fetchEnrollmentRequests();
+    print(enrollmentRequests.entries);
+    expect(
+        enrollmentRequests.length, 4); // 4 entries - 2 entries from this test
+    // + 2 entries from the other test in this file.
+
+    String firstEnrollmentKey =
+        getEnrollmentKey(enrollResponse1JsonDecoded['enrollmentId'], atSign);
+    String secondEnrollmentKey =
+        getEnrollmentKey(enrollResponse2JsonDecoded['enrollmentId'], atSign);
+
+    expect(
+        (enrollmentRequests[firstEnrollmentKey]['namespace']
+            as Map<String, dynamic>)['new_app'],
+        'rw');
+    expect(
+        (enrollmentRequests[secondEnrollmentKey]['namespace']
+            as Map<String, dynamic>)['new_app'],
+        'rw');
+    expect(
+        (enrollmentRequests[secondEnrollmentKey]['namespace']
+            as Map<String, dynamic>)['wavi'],
+        'r');
+  });
 }
 
 Future<void> setLastReceivedNotificationDateTime() async {
@@ -115,6 +179,10 @@ Future<void> setLastReceivedNotificationDateTime() async {
       .put(lastReceivedNotificationAtKey, jsonEncode(atNotification.toJson()));
 }
 
+String getEnrollmentKey(String enrollmentId, String atsign) {
+  return '$enrollmentId.new.enrollments.__manage$atsign';
+}
+
 AtClientPreference getClient2Preferences() {
   return AtClientPreference()
     ..commitLogPath = 'test/hive/client_2/commit'

tests/at_functional_test/test/test_utils.dart

@@ -8,6 +8,7 @@ import 'package:at_client/at_client.dart';
 import 'package:at_functional_test/src/at_demo_credentials.dart'
     as demo_credentials;
 
+
 class TestUtils {
   static AtClientPreference getPreference(String atsign) {
     var preference = AtClientPreference();
@@ -52,4 +53,16 @@ class TestUtils {
         atClientManager.atClient, currentAtSign);
     return atClientManager;
   }
+
+  static String formatCommand(String command){
+    if(!command.contains('\n')) return '$command\n';
+    return command;
+  }
+
+  static Future<String?> executeCommandAndParse(AtClient? client, command, {bool auth = false, RemoteSecondary? remoteSecondary}) async {
+    remoteSecondary ??= client?.getRemoteSecondary();
+    String? response = await remoteSecondary?.executeCommand(formatCommand(command), auth: auth);
+    print('Command: $command -> Response: $response');
+    return response?.replaceFirst('data:', '');
+  }
 }