Aggregate done!

Author: mskayali

packages/dart/example/main.dart

@@ -14,12 +14,18 @@ Future<void> main() async {
     ..set('Name', 'Ketogenic')
     ..set('Fat', 65);
 
-    // ParseAggregate('className', pipeline: {}).execute();
+
 
   var response = await dietPlan.save();
 
   if (response.success) {
     dietPlan = response.results?.first;
     print("Response received successfully");
   }
+
+  final res = await ParseAggregate('DietPlan', pipeline: {
+    r'$match': {'Name': 'Ketogenic'}
+  }).execute();
+
+  print(res);
 }

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

@@ -2,7 +2,7 @@ part of '../../parse_server_sdk.dart';
 
 class ParseAggregate {
   final String className;
-  final Map<String, dynamic> pipeline;
+  Map<String, dynamic> pipeline;
   final bool? debug;
   final ParseClient? client;
   final bool? autoSendSessionId;
@@ -11,16 +11,20 @@ class ParseAggregate {
   ParseAggregate(this.className,{required this.pipeline,this.debug, this.client, this.autoSendSessionId, this.parseClassName});
 
   Future<ParseResponse> execute() async {
+    Map<String,String> _pipeline={};
     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{
+      _pipeline.addAll({'pipeline':jsonEncode([pipeline])});
+    }
     final debugBool = isDebugEnabled(objectLevelDebug: debug);
-    final result = await ParseHTTPClient().get(
-      '${ParseCoreData().serverUrl}$keyEndPointAggregate/$className',
-      replace: UrlReplace(queryParameters: pipeline)
+    final result = await ParseObject(className)._client.get(
+      Uri.parse('${ParseCoreData().serverUrl}$keyEndPointAggregate$className').replace(queryParameters: _pipeline).toString(),
     );
+    print('result >>> ${result.data}');
     return handleResponse<ParseObject>(
-      this,
+      ParseObject(className),
       result,
       ParseApiRQ.get,
       debugBool,

packages/dart/lib/src/network/parse_http_client.dart

@@ -2,7 +2,6 @@ import 'dart:convert';
 
 import 'package:http/http.dart' as http;
 import 'package:parse_server_sdk/parse_server_sdk.dart';
-import 'package:parse_server_sdk/src/utils/url_replace.dart';
 import 'package:universal_io/io.dart';
 
 import 'http_client_io.dart' if (dart.library.js) 'http_client_js.dart';
@@ -30,20 +29,10 @@ class ParseHTTPClient extends ParseClient {
     String path, {
     ParseNetworkOptions? options,
     ProgressCallback? onReceiveProgress,
-    UrlReplace? replace
   }) async {
+
     final http.Response response = await _client.get(
-      replace != null ? Uri.parse(path).replace(
-        scheme:replace.scheme,
-        userInfo:replace.userInfo,
-        host:replace.host,
-        port:replace.port,
-        path:replace.path,
-        pathSegments:replace.pathSegments,
-        query:replace.query,
-        queryParameters:replace.queryParameters,
-        fragment:replace.fragment,
-      ): Uri.parse(path),
+      Uri.parse(path),
       headers: options?.headers,
     );
     return ParseNetworkResponse(

packages/flutter/example/.gitignore

@@ -5,9 +5,11 @@
 *.swp
 .DS_Store
 .atom/
+.build/
 .buildlog/
 .history
 .svn/
+.swiftpm/
 migrate_working_dir/
 
 # IntelliJ related