ParseAggregate method updated, small bugs fixed

Author: mskayali

packages/dart/example/main.dart

@@ -23,13 +23,14 @@ Future<void> main() async {
     print("Response received successfully");
   }
 
-  final res = await ParseAggregate('DietPlan', pipeline: {
+  final res = await ParseAggregate('DietPlan').execute({
     r'$match': {'Name': 'Ketogenic'},
     r'$group': {
       '_id': r'isHungry',
       'count': {r'$sum': 1}
     },
-  }).execute();
+  });
+
+  print('${res.statusCode}, ${res.results}');
 
-  print('${res.statusCode}, ${res.data}');
 }

packages/dart/lib/parse_server_sdk.dart

@@ -33,12 +33,13 @@ part 'src/data/parse_core_data.dart';
 part 'src/data/parse_subclass_handler.dart';
 part 'src/enums/parse_enum_api_rq.dart';
 part 'src/network/options.dart';
-part 'src/network/parse_aggregate.dart';
+// part 'src/network/parse_aggregate.dart';
 part 'src/network/parse_client.dart';
 part 'src/network/parse_connectivity.dart';
 part 'src/network/parse_live_query.dart';
 part 'src/network/parse_query.dart';
 part 'src/objects/parse_acl.dart';
+part 'src/objects/parse_aggregate.dart';
 part 'src/objects/parse_array.dart';
 part 'src/objects/parse_base.dart';
 part 'src/objects/parse_cloneable.dart';
@@ -51,6 +52,7 @@ part 'src/objects/parse_file_web.dart';
 part 'src/objects/parse_function.dart';
 part 'src/objects/parse_geo_point.dart';
 part 'src/objects/parse_installation.dart';
+part 'src/objects/parse_jobs.dart';
 part 'src/objects/parse_number.dart';
 part 'src/objects/parse_object.dart';
 part 'src/objects/parse_operation/parse_add_operation.dart';

packages/dart/lib/src/base/parse_constants.dart

@@ -16,6 +16,8 @@ const String keyEndPointRequestPasswordReset = '/requestPasswordReset';
 const String keyEndPointClasses = '/classes/';
 const String keyEndPointHealth = '/health';
 const String keyEndPointAggregate = '/aggregate/';
+const String keyEndPointFunctions = '/functions/';
+const String keyEndPointJobs = '/jobs/';
 
 // ParseObject variables
 const String keyVarClassName = 'className';

packages/dart/lib/src/network/parse_aggregate.dart

@@ -0,0 +1,53 @@
+
+part of '../../parse_server_sdk.dart';
+
+class ParseAggregate extends ParseObject {
+
+  ParseAggregate(
+    this.functionName, {
+    bool? debug,
+    ParseClient? client,
+    bool? autoSendSessionId,
+  }) : super(
+          functionName,
+          client: client,
+          autoSendSessionId: autoSendSessionId,
+          debug: debug,
+        ) {
+    _path = '$keyEndPointAggregate$functionName';
+  }
+
+  final String functionName;
+
+  @override
+  late String _path;
+
+  Future<ParseResponse> execute(Map<String, dynamic> pipeline, {Map<String, String>? headers}) async {
+    final String uri = '${ParseCoreData().serverUrl}$_path';
+
+    Map<String, String> parameters = {};
+
+    if (pipeline.isEmpty) {
+      throw ArgumentError(
+        'pipeline must not be empty. Please add pipeline operations to aggregate data. '
+        'Example: {"\$group": {"_id": "\$userId", "totalScore": {"\$sum": "\$score"}}}',
+      );
+    } else {
+      parameters.addAll({
+        'pipeline': jsonEncode(pipeline.entries.map((e) => {e.key: e.value}).toList())
+      });
+      _setObjectData(pipeline);
+    }
+
+    try {
+      print(Uri.parse(uri).replace(queryParameters: parameters).toString());
+      final ParseNetworkResponse result = await _client.get(
+      Uri.parse(uri).replace(queryParameters: parameters).toString(),
+      options: ParseNetworkOptions(headers: headers)
+    );
+      return ParseResponse.fromParseNetworkResponse(result);
+    } on Exception catch (e) {
+      return handleException(e, ParseApiRQ.execute, _debug, parseClassName);
+    }
+  }
+}

packages/dart/lib/src/objects/parse_aggregate.dart

@@ -15,7 +15,7 @@ class ParseCloudFunction extends ParseObject {
           autoSendSessionId: autoSendSessionId,
           debug: debug,
         ) {
-    _path = '/functions/$functionName';
+    _path = '$keyEndPointFunctions$functionName';
   }
 
   final String functionName;

packages/dart/lib/src/objects/parse_function.dart

@@ -0,0 +1,58 @@
+part of '../../parse_server_sdk.dart';
+
+class ParseJobs extends ParseObject {
+  /// Creates a new cloud function object
+  ///
+  /// {https://docs.parseplatform.org/cloudcode/guide/}
+  ParseJobs(
+    this.functionName, {
+    bool? debug,
+    ParseClient? client,
+    bool? autoSendSessionId,
+  }) : super(
+          functionName,
+          client: client,
+          autoSendSessionId: autoSendSessionId,
+          debug: debug,
+        ) {
+    _path = '$keyEndPointJobs$functionName';
+  }
+
+  final String functionName;
+
+  @override
+  // ignore: overridden_fields
+  late String _path;
+
+  /// Executes a cloud function
+  ///
+  /// To add the parameters, create an object and call [set](value to set)
+  Future<ParseResponse> execute({Map<String, dynamic>? parameters, Map<String, String>? headers}) async {
+    final String uri = '${ParseCoreData().serverUrl}$_path';
+    if (parameters != null) {
+      _setObjectData(parameters);
+    }
+    try {
+      final ParseNetworkResponse result = await _client.post(uri, options: ParseNetworkOptions(headers: headers), data: json.encode(_getObjectData()));
+      return handleResponse<ParseJobs>(this, result, ParseApiRQ.execute, _debug, parseClassName);
+    } on Exception catch (e) {
+      return handleException(e, ParseApiRQ.execute, _debug, parseClassName);
+    }
+  }
+
+  /// Executes a cloud function that returns a ParseObject type
+  ///
+  /// To add the parameters, create an object and call [set](value to set)
+  Future<ParseResponse> executeObjectFunction<T extends ParseObject>({Map<String, dynamic>? parameters, Map<String, String>? headers}) async {
+    final String uri = '${ParseCoreData().serverUrl}$_path';
+    if (parameters != null) {
+      _setObjectData(parameters);
+    }
+    try {
+      final ParseNetworkResponse result = await _client.post(uri, options: ParseNetworkOptions(headers: headers), data: json.encode(_getObjectData()));
+      return handleResponse<T>(this, result, ParseApiRQ.executeObjectionFunction, _debug, parseClassName);
+    } on Exception catch (e) {
+      return handleException(e, ParseApiRQ.executeObjectionFunction, _debug, parseClassName);
+    }
+  }
+}

packages/dart/lib/src/objects/parse_jobs.dart

@@ -1,22 +1,117 @@
 part of '../../parse_server_sdk.dart';
 
+/// A standardized response object returned by all Parse Server operations.
+///
+/// This class wraps the response received from the Parse Server and normalizes
+/// the structure so that your Dart application can easily determine:
+/// - whether the request was successful
+/// - the HTTP status code
+/// - the result(s) returned by the server
+/// - any error information
+///
+///
+/// ## Example usage
+/// ```dart
+/// final response = await myParseQuery.find();
+/// if (response.success) {
+///   print('Fetched ${response.count} objects.');
+///   for (final obj in response.results ?? []) {
+///     print(obj);
+///   }
+/// } else {
+///   print('Error: ${response.error?.message}');
+/// }
+/// ```
 class ParseResponse {
+  /// Creates a new [ParseResponse] instance.
+  ///
+  /// You typically don't instantiate this directly — it's created by
+  /// internal SDK logic, e.g. through [fromParseNetworkResponse].
   ParseResponse({
     this.error,
   });
 
+  /// Whether the request was successful.
+  ///
+  /// This is `true` if the HTTP status code was 200 or 201.
   bool success = false;
+
+  /// The HTTP status code returned by the Parse Server.
+  ///
+  /// Defaults to -1 if not yet populated.
   int statusCode = -1;
 
-  /// If result is a singular result, i.e. getByObjectID
+  /// The direct result from the Parse Server.
   ///
-  /// This is now deprecated - Please use results. This will contain a list of
-  /// results, no need to check if its a list or a list of elements anymore.
+  /// This might be a `Map`, a `List`, or any other decoded JSON.
+  ///
+  /// ---
+  /// ⚠️ **Deprecated:**
+  /// You should prefer using [results], which is guaranteed to be a list of results.
   dynamic result;
 
-  /// All results stored as a list - Even if only one response is returned
-  // ignore: always_specify_types
+  /// The list of results returned by the Parse Server.
+  ///
+  /// Even if only one object is returned, it will still be inside a list.
+  ///
+  /// This is the recommended way to access your fetched data.
   List? results;
+
+  /// The number of objects returned (i.e. `results.length`).
+  ///
+  /// Will be 0 if there were no results.
   int count = 0;
+
+  /// If the request failed, this contains error information.
   ParseError? error;
+
+  /// Builds a [ParseResponse] from a [ParseNetworkResponse],
+  /// typically after making an HTTP request.
+  ///
+  /// - Decodes JSON data
+  /// - Determines `success` based on HTTP status codes
+  /// - Populates [results] and [count] if the response contains a list
+  factory ParseResponse.fromParseNetworkResponse(ParseNetworkResponse response) {
+    final ParseResponse result = ParseResponse();
+    result.statusCode = response.statusCode;
+    result.success = response.statusCode >= 200 && response.statusCode < 300;
+    try {
+      // Attempt to decode JSON data
+      final data = jsonDecode(response.data);
+      // Fallback if `result` was not already populated
+      result.result ??= data;
+      // Handle typical Parse Server response structures
+      if (data is Map<String, dynamic>) {
+        if (data.containsKey('results')) {
+          final resultList = data['results'];
+          if (resultList is List) {
+            result.results = resultList;
+            result.count = resultList.length;
+          }
+        }else if(data.containsKey('error')){
+          result.error=ParseError(code:response.statusCode, message:data['error'].toString() );
+        }
+      } else if (data is List) {
+        result.results = data;
+        result.count = data.length;
+      }
+      result.results ??= [data];
+    } catch (e,s) {
+      result.error = ParseError(message: e.toString(),exception: Exception(s));
+    }
+    return result;
+  }
+  Map<String,dynamic> get toMap=>{
+    'success': success,
+    'statusCode': statusCode,
+    // 'result': result,
+    'results': results,
+    'count': count,
+    'error': error,
+  };
+
+  @override
+  String toString() {
+    return toMap.toString();
+  }
 }