no message

Author: mskayali

packages/dart/example/main.dart

@@ -14,6 +14,8 @@ Future<void> main() async {
     ..set('Name', 'Ketogenic')
     ..set('Fat', 65);
 
+    // ParseAggregate('className', pipeline: {}).execute();
+
   var response = await dietPlan.save();
 
   if (response.success) {

packages/dart/lib/parse_server_sdk.dart

@@ -11,6 +11,7 @@ import 'package:cross_file/cross_file.dart';
 import 'package:dio/dio.dart';
 import 'package:meta/meta.dart';
 import 'package:mime/mime.dart';
+import 'package:parse_server_sdk/src/utils/url_replace.dart';
 import 'package:path/path.dart' as path;
 import 'package:sembast/sembast.dart';
 import 'package:sembast/sembast_io.dart';
@@ -29,111 +30,59 @@ export 'src/network/parse_dio_client.dart';
 export 'src/network/parse_http_client.dart';
 
 part 'src/base/parse_constants.dart';
-
 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_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_array.dart';
-
 part 'src/objects/parse_base.dart';
-
 part 'src/objects/parse_cloneable.dart';
-
 part 'src/objects/parse_config.dart';
-
 part 'src/objects/parse_error.dart';
-
 part 'src/objects/parse_exception.dart';
-
 part 'src/objects/parse_file.dart';
-
 part 'src/objects/parse_file_base.dart';
-
 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_number.dart';
-
 part 'src/objects/parse_object.dart';
-
 part 'src/objects/parse_operation/parse_add_operation.dart';
-
 part 'src/objects/parse_operation/parse_add_relation_operation.dart';
-
 part 'src/objects/parse_operation/parse_add_unique_operation.dart';
-
 part 'src/objects/parse_operation/parse_increment_operation.dart';
-
 part 'src/objects/parse_operation/parse_operation.dart';
-
 part 'src/objects/parse_operation/parse_remove_operation.dart';
-
 part 'src/objects/parse_operation/parse_remove_relation_operation.dart';
-
 part 'src/objects/parse_relation.dart';
-
 part 'src/objects/parse_response.dart';
-
 part 'src/objects/parse_save_state_aware_child.dart';
-
 part 'src/objects/parse_session.dart';
-
 part 'src/objects/parse_user.dart';
-
 part 'src/objects/parse_x_file.dart';
-
 part 'src/objects/response/parse_error_response.dart';
-
 part 'src/objects/response/parse_exception_response.dart';
-
 part 'src/objects/response/parse_response_builder.dart';
-
 part 'src/objects/response/parse_response_utils.dart';
-
 part 'src/objects/response/parse_success_no_results.dart';
-
 part 'src/storage/core_store.dart';
-
 part 'src/storage/core_store_memory.dart';
-
 part 'src/storage/core_store_sem_impl.dart';
-
 part 'src/storage/xxtea_codec.dart';
-
 part 'src/utils/parse_date_format.dart';
-
 part 'src/utils/parse_decoder.dart';
-
 part 'src/utils/parse_encoder.dart';
-
 part 'src/utils/parse_live_list.dart';
-
 part 'src/utils/parse_logger.dart';
-
 part 'src/utils/parse_login_helpers.dart';
-
 part 'src/utils/parse_utils.dart';
-
 part 'src/utils/valuable.dart';
 
 class Parse {

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

@@ -0,0 +1,30 @@
+part of '../../parse_server_sdk.dart';
+
+class ParseAggregate {
+  final String className;
+  final Map<String, dynamic> pipeline;
+  final bool? debug;
+  final ParseClient? client;
+  final bool? autoSendSessionId;
+  final String? parseClassName;
+
+  ParseAggregate(this.className,{required this.pipeline,this.debug, this.client, this.autoSendSessionId, this.parseClassName});
+
+  Future<ParseResponse> execute() async {
+    if(pipeline.isEmpty){
+      throw ArgumentError('pipeline must not be empty. Please add pipeline operations to aggregate data.  Example: {"\$group": {"_id": "\$userId", "totalScore": {"\$sum": "\$score"}}}  ');
+    }
+    final debugBool = isDebugEnabled(objectLevelDebug: debug);
+    final result = await ParseHTTPClient().get(
+      '${ParseCoreData().serverUrl}$keyEndPointAggregate/$className',
+      replace: UrlReplace(queryParameters: pipeline)
+    );
+    return handleResponse<ParseObject>(
+      this,
+      result,
+      ParseApiRQ.get,
+      debugBool,
+      parseClassName ?? 'ParseBase',
+    );
+  }
+}

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

@@ -1,9 +1,9 @@
 import 'dart:convert';
-import 'package:universal_io/io.dart';
 
 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,9 +30,20 @@ class ParseHTTPClient extends ParseClient {
     String path, {
     ParseNetworkOptions? options,
     ProgressCallback? onReceiveProgress,
+    UrlReplace? replace
   }) async {
     final http.Response response = await _client.get(
-      Uri.parse(path),
+      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),
       headers: options?.headers,
     );
     return ParseNetworkResponse(

packages/dart/lib/src/utils/url_replace.dart

@@ -0,0 +1,24 @@
+class UrlReplace{
+  String? scheme;
+  String? userInfo;
+  String? host;
+  int? port;
+  String? path;
+  Iterable<String>? pathSegments;
+  String? query;
+  Map<String, dynamic>? queryParameters;
+  String? fragment;
+
+  UrlReplace({
+    this.scheme,
+    this.userInfo,
+    this.host,
+    this.port,
+    this.path,
+    this.pathSegments,
+    this.query,
+    this.queryParameters,
+    this.fragment,
+  });
+
+}