feat(gc): 21021171c24845b30236807de279fff8d3780a63

Author: serverpod_cloud

ground_control_client/lib/src/protocol/client.dart

@@ -60,6 +60,51 @@ import 'package:serverpod_auth_bridge_client/serverpod_auth_bridge_client.dart'
 import 'package:serverpod_auth_client/serverpod_auth_client.dart' as _i26;
 import 'protocol.dart' as _i27;
 
+/// Endpoint for global administrator to handle procurement for users.
+/// {@category Endpoint}
+class EndpointAdminProcurement extends _i1.EndpointRef {
+  EndpointAdminProcurement(_i1.EndpointCaller caller) : super(caller);
+
+  @override
+  String get name => 'adminProcurement';
+
+  /// Procures a product for a user.
+  /// If [productVersion] is not provided, the latest version is used.
+  /// If [overrideChecks] is true, the product availability checks are overridden.
+  ///
+  /// Throws a [NotFoundException] if the user or product is not found.
+  /// Throws a [InvalidValueException] if the user has no owner (not fully registered).
+  _i2.Future<void> procureProduct({
+    required String userEmail,
+    required String productName,
+    int? productVersion,
+    bool? overrideChecks,
+  }) =>
+      caller.callServerEndpoint<void>(
+        'adminProcurement',
+        'procureProduct',
+        {
+          'userEmail': userEmail,
+          'productName': productName,
+          'productVersion': productVersion,
+          'overrideChecks': overrideChecks,
+        },
+      );
+
+  /// Fetches a user's procured products.
+  /// Returns a list of `(String, String)` with the product ID and its type.
+  ///
+  /// Throws a [NotFoundException] if the user is not found.
+  /// Throws a [InvalidValueException] if the user has no owner (not fully registered).
+  _i2.Future<List<(String, String)>> listProcuredProducts(
+          {required String userEmail}) =>
+      caller.callServerEndpoint<List<(String, String)>>(
+        'adminProcurement',
+        'listProcuredProducts',
+        {'userEmail': userEmail},
+      );
+}
+
 /// Endpoint for global administrator projects access.
 /// {@category Endpoint}
 class EndpointAdminProjects extends _i1.EndpointRef {
@@ -949,6 +994,7 @@ class Client extends _i1.ServerpodClientShared {
           disconnectStreamsOnLostInternetConnection:
               disconnectStreamsOnLostInternetConnection,
         ) {
+    adminProcurement = EndpointAdminProcurement(this);
     adminProjects = EndpointAdminProjects(this);
     adminUsers = EndpointAdminUsers(this);
     auth = EndpointAuth(this);
@@ -969,6 +1015,8 @@ class Client extends _i1.ServerpodClientShared {
     modules = Modules(this);
   }
 
+  late final EndpointAdminProcurement adminProcurement;
+
   late final EndpointAdminProjects adminProjects;
 
   late final EndpointAdminUsers adminUsers;
@@ -1007,6 +1055,7 @@ class Client extends _i1.ServerpodClientShared {
 
   @override
   Map<String, _i1.EndpointRef> get endpointRefLookup => {
+        'adminProcurement': adminProcurement,
         'adminProjects': adminProjects,
         'adminUsers': adminUsers,
         'auth': auth,

ground_control_client/lib/src/protocol/protocol.dart

@@ -510,6 +510,23 @@ class Protocol extends _i1.SerializationManager {
               .toList()
           : null) as T;
     }
+    if (t == List<(String, String)>) {
+      return (data as List)
+          .map((e) => deserialize<(String, String)>(e))
+          .toList() as T;
+    }
+    if (t == _i1.getType<(String, String)>()) {
+      return (
+        deserialize<String>(((data as Map)['p'] as List)[0]),
+        deserialize<String>(data['p'][1]),
+      ) as T;
+    }
+    if (t == _i1.getType<(String, String)>()) {
+      return (
+        deserialize<String>(((data as Map)['p'] as List)[0]),
+        deserialize<String>(data['p'][1]),
+      ) as T;
+    }
     if (t == List<_i49.Project>) {
       return (data as List).map((e) => deserialize<_i49.Project>(e)).toList()
           as T;
@@ -869,3 +886,75 @@ class Protocol extends _i1.SerializationManager {
     return super.deserializeByClassName(data);
   }
 }
+
+/// Maps any `Record`s known to this [Protocol] to their JSON representation
+///
+/// Throws in case the record type is not known.
+///
+/// This method will return `null` (only) for `null` inputs.
+Map<String, dynamic>? mapRecordToJson(Record? record) {
+  if (record == null) {
+    return null;
+  }
+  if (record is (String, String)) {
+    return {
+      "p": [
+        record.$1,
+        record.$2,
+      ],
+    };
+  }
+  throw Exception('Unsupported record type ${record.runtimeType}');
+}
+
+/// Maps container types (like [List], [Map], [Set]) containing
+/// [Record]s or non-String-keyed [Map]s to their JSON representation.
+///
+/// It should not be called for [SerializableModel] types. These
+/// handle the "[Record] in container" mapping internally already.
+///
+/// It is only supposed to be called from generated protocol code.
+///
+/// Returns either a `List<dynamic>` (for List, Sets, and Maps with
+/// non-String keys) or a `Map<String, dynamic>` in case the input was
+/// a `Map<String, …>`.
+Object? mapContainerToJson(Object obj) {
+  if (obj is! Iterable && obj is! Map) {
+    throw ArgumentError.value(
+      obj,
+      'obj',
+      'The object to serialize should be of type List, Map, or Set',
+    );
+  }
+
+  dynamic mapIfNeeded(Object? obj) {
+    return switch (obj) {
+      Record record => mapRecordToJson(record),
+      Iterable iterable => mapContainerToJson(iterable),
+      Map map => mapContainerToJson(map),
+      Object? value => value,
+    };
+  }
+
+  switch (obj) {
+    case Map<String, dynamic>():
+      return {
+        for (var entry in obj.entries) entry.key: mapIfNeeded(entry.value),
+      };
+    case Map():
+      return [
+        for (var entry in obj.entries)
+          {
+            'k': mapIfNeeded(entry.key),
+            'v': mapIfNeeded(entry.value),
+          }
+      ];
+
+    case Iterable():
+      return [
+        for (var e in obj) mapIfNeeded(e),
+      ];
+  }
+
+  return obj;
+}