feat: Add saveEventually and deleteEventually in ParseObject

packages/dart/lib/parse_server_sdk.dart

@@ -27,62 +27,116 @@ 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_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_file.dart';
+
 part 'src/objects/parse_number.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_object.dart';
+
 part 'src/objects/parse_exception.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/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 {
   bool _hasBeenInitialized = false;
 
+  static bool objectsExistForEventually = false;
+
   /// To initialize Parse Server in your application
   ///
   /// This should be initialized in MyApp() creation
@@ -148,6 +202,12 @@ class Parse {
 
     _hasBeenInitialized = true;
 
+    objectsExistForEventually = await checkObjectsExistForEventually();
+
+    if (objectsExistForEventually) {
+      ParseObject.submitEventually();
+    }
+
     return this;
   }
 

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

@@ -58,6 +58,8 @@ const String keyParamSessionToken = 'sessionToken';
 // Storage
 const String keyParseStoreBase = 'flutter_parse_sdk_';
 const String keyParseStoreUser = '${keyParseStoreBase}user';
+const String keyParseStoreObjects = '${keyParseStoreBase}objects';
+const String keyParseStoreDeletes = '${keyParseStoreBase}deletes';
 const String keyParseStoreInstallation = '${keyParseStoreBase}installation';
 
 // Installation

packages/dart/lib/src/network/parse_dio_client.dart

@@ -229,6 +229,8 @@ class _ParseDioClient with dio.DioMixin implements dio.Dio {
       _logCUrl(options, data, path);
     }
 
+    checkForSubmitEventually();
+
     return super.request(
       path,
       data: data,

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

@@ -158,6 +158,8 @@ class _ParseHTTPClient extends http.BaseClient {
       _logCUrl(request);
     }
 
+    checkForSubmitEventually();
+
     return _client.send(request);
   }
 

packages/dart/lib/src/objects/parse_object.dart

@@ -153,6 +153,25 @@ class ParseObject extends ParseBase implements ParseCloneable {
     }
   }
 
+  Future<ParseResponse> saveEventually() async {
+    // save object
+    final ParseResponse response = await save();
+
+    if (response.success) {
+      // return success response
+      return response;
+    } else {
+      // if have network connection error
+      if ((response.error?.message ?? "").contains("NetworkError")) {
+        // save this object in CoreStore
+        await _addThisObjectToParseCoreDataList(keyParseStoreObjects);
+      } else {
+        return response;
+      }
+    }
+    return response;
+  }
+
   /// Saves the current object online.
   ///
   /// If the object not saved yet, this will create it. Otherwise,
@@ -186,7 +205,7 @@ class ParseObject extends ParseBase implements ParseCloneable {
   ///
   /// Prefer using [save] over [update] and [create]
   Future<ParseResponse> save() async {
-    final ParseResponse childrenResponse = await _saveChildren(this);
+    final ParseResponse childrenResponse = await _saveChildren(this, _client);
     if (childrenResponse.success) {
       ParseResponse? response;
       if (objectId == null) {
@@ -207,7 +226,7 @@ class ParseObject extends ParseBase implements ParseCloneable {
     return childrenResponse;
   }
 
-  Future<ParseResponse> _saveChildren(dynamic object) async {
+  static Future<ParseResponse> _saveChildren(dynamic object, client) async {
     final Set<ParseObject> uniqueObjects = <ParseObject>{};
     final Set<ParseFileBase> uniqueFiles = <ParseFileBase>{};
     if (!_collectionDirtyChildren(
@@ -253,7 +272,7 @@ class ParseObject extends ParseBase implements ParseCloneable {
 
       // TODO(yulingtianxia): lazy User
       /* Batch requests have currently a limit of 50 packaged requests per single request
-      This splitting will split the overall array into segments of upto 50 requests
+      This splitting will split the overall array into segments of up to 50 requests
       and execute them concurrently with a wrapper task for all of them. */
       final List<List<ParseObject>> chunks = <List<ParseObject>>[];
       for (int i = 0; i < current.length; i += 50) {
@@ -271,7 +290,7 @@ class ParseObject extends ParseBase implements ParseCloneable {
         final ParseResponse response = await batchRequest(
           requests,
           chunk,
-          client: _client,
+          client: client,
         );
         totalResponse.success &= response.success;
 
@@ -371,7 +390,7 @@ class ParseObject extends ParseBase implements ParseCloneable {
     return true;
   }
 
-  bool _collectionDirtyChildren(
+  static bool _collectionDirtyChildren(
       dynamic object,
       Set<ParseObject> uniqueObjects,
       Set<ParseFileBase> uniqueFiles,
@@ -625,6 +644,32 @@ class ParseObject extends ParseBase implements ParseCloneable {
     }
   }
 
+  Future<ParseResponse> deleteEventually() async {
+    // save object
+    final ParseResponse response = await delete();
+
+    if (response.success) {
+      // return success response
+      return response;
+    } else {
+      // if have network connection error
+      if ((response.error?.message ?? "").contains("NetworkError")) {
+        // save this object in CoreStore
+        await _addThisObjectToParseCoreDataList(keyParseStoreDeletes);
+      } else {
+        return response;
+      }
+    }
+    return response;
+  }
+
+  Future<void> _addThisObjectToParseCoreDataList(String key) async {
+    final CoreStore coreStore = ParseCoreData().getStore();
+    List<String> list = await coreStore.getStringList(key) ?? [];
+    list.add(json.encode(toJson(full: true)));
+    await coreStore.setStringList(key, list);
+  }
+
   /// Deletes the current object locally and online
   Future<ParseResponse> delete<T extends ParseObject>({
     String? id,
@@ -677,4 +722,114 @@ class ParseObject extends ParseBase implements ParseCloneable {
       return this;
     }
   }
+
+  static Future<void> submitEventually(
+      {ParseClient? client, bool? autoSendSessionId}) async {
+    await submitSaveEventually(
+        client: client, autoSendSessionId: autoSendSessionId);
+    await submitDeleteEventually(
+        client: client, autoSendSessionId: autoSendSessionId);
+
+    Parse.objectsExistForEventually = await checkObjectsExistForEventually();
+  }
+
+  static Future<ParseResponse?> submitSaveEventually(
+      {ParseClient? client, bool? autoSendSessionId}) async {
+    // get client
+    ParseClient localClient = client ??
+        ParseCoreData().clientCreator(
+            sendSessionId:
+                autoSendSessionId ?? ParseCoreData().autoSendSessionId,
+            securityContext: ParseCoreData().securityContext);
+
+    // preparation ParseCoreData
+    final CoreStore coreStore = ParseCoreData().getStore();
+
+    // save
+    // get json parse saved objects
+    List<String>? listSaves =
+        await coreStore.getStringList(keyParseStoreObjects);
+
+    if (listSaves != null) {
+      List<ParseObject> parseObjectList = [];
+      for (var element in listSaves) {
+        // decode json
+        dynamic object = json.decode(element);
+        parseObjectList
+            .add(ParseObject(object[keyVarClassName]).fromJson(object));
+      }
+
+      // send parseObjects to server
+      ParseResponse response =
+          await ParseObject._saveChildren(parseObjectList, localClient);
+
+      // if success clear all objects
+      if (response.success) {
+        coreStore.setStringList(keyParseStoreObjects, []);
+      }
+
+      return response;
+    }
+
+    return null;
+  }
+
+  static Future<ParseResponse?> submitDeleteEventually(
+      {ParseClient? client, bool? autoSendSessionId}) async {
+    // preparation ParseCoreData
+    final CoreStore coreStore = ParseCoreData().getStore();
+
+    // delete
+    // get json parse saved objects
+    List<String>? listDeletes =
+        await coreStore.getStringList(keyParseStoreDeletes);
+
+    if (listDeletes != null) {
+      int firstLength = listDeletes.length;
+      List<String> elementsToRemove = [];
+      for (var element in listDeletes) {
+        // decode json
+        dynamic object = json.decode(element);
+
+        // crate parse object
+        ParseObject parseObject = ParseObject(object[keyVarClassName],
+                client: client, autoSendSessionId: autoSendSessionId)
+            .fromJson(object);
+
+        // delete parse object
+        ParseResponse deleteResponse = await parseObject.delete();
+
+        if (deleteResponse.success) {
+          // remove from list Deletes
+          elementsToRemove.add(element);
+        }
+      }
+
+      // Remove the elements after the loop
+      for (var elementToRemove in elementsToRemove) {
+        listDeletes.remove(elementToRemove);
+      }
+
+      // set new list deletes in coreStore
+      coreStore.setStringList(keyParseStoreDeletes, listDeletes);
+
+      bool success = true;
+      int statusCode = 200;
+
+      if (listDeletes.length == firstLength) {
+        // Nothing has been deleted
+        success = false;
+        statusCode = -1;
+      }
+
+      final ParseResponse response = ParseResponse()
+        ..success = success
+        ..results = <dynamic>[]
+        ..statusCode = statusCode;
+
+      return response;
+    }
+
+    return null;
+  }
 }