Merge pull request #28 from nubank/error-handling

Error handling for DatabaseException

Author: luisrjaeger

CHANGELOG.md

@@ -1,3 +1,6 @@
+## 1.4.2
+* Handling DatabaseException and Bad State errors
+
 ## 1.4.1
 * Allow Dart 3
 

lib/src/constants.dart

@@ -1,6 +1,6 @@
 class Constants {
   static const packageName = 'amplitude-flutter';
-  static const packageVersion = '1.3.5';
+  static const packageVersion = '1.4.2';
 
   // Local storage
   static const kLocalStoreDeviceIdKey = 'amp:device_id';

lib/src/store.dart

@@ -31,31 +31,46 @@ class Store {
     if (db == null) {
       return 0;
     }
-    final result = await db.insert(EVENTS_TABLE, _serialize(event));
-    length++;
-    return result;
+
+    try {
+      final result = await db.insert(EVENTS_TABLE, _serialize(event));
+      length++;
+      return result;
+    } catch (ex) {
+      return 0;
+    }
   }
 
   Future<List<Object?>> addAll(List<Event> events) async {
     final db = await _getDb();
     if (db == null) {
       return [];
     }
-    final batch = db.batch();
-    for (final event in events) {
-      batch.insert(EVENTS_TABLE, _serialize(event));
-      length++;
+
+    try {
+      final batch = db.batch();
+      for (final event in events) {
+        batch.insert(EVENTS_TABLE, _serialize(event));
+        length++;
+      }
+      return await batch.commit(noResult: true);
+    } catch (ex) {
+      return [];
     }
-    return await batch.commit(noResult: true);
   }
 
   Future<void> empty() async {
     final db = await _getDb();
     if (db == null) {
       return;
     }
-    await db.rawDelete('DELETE FROM $EVENTS_TABLE; VACUUM;');
-    length = 0;
+
+    try {
+      await db.rawDelete('DELETE FROM $EVENTS_TABLE; VACUUM;');
+      length = 0;
+    } catch (ex) {
+      return;
+    }
   }
 
   Future<int?> count() async {
@@ -68,28 +83,44 @@ class Store {
     if (db == null) {
       return;
     }
-    final resultCount = await db.rawDelete(
-        'DELETE FROM $EVENTS_TABLE WHERE $COL_ID IN (SELECT T2.$COL_ID FROM $EVENTS_TABLE T2 ORDER BY T2.$COL_ID LIMIT $count)');
-    length -= resultCount;
+
+    try {
+      final resultCount = await db.rawDelete(
+          'DELETE FROM $EVENTS_TABLE WHERE $COL_ID IN (SELECT T2.$COL_ID FROM $EVENTS_TABLE T2 ORDER BY T2.$COL_ID LIMIT $count)');
+      length -= resultCount;
+    } catch (ex) {
+      return;
+    }
   }
 
   Future<void> delete(List<int?> eventIds) async {
     final db = await _getDb();
     if (db == null) {
       return;
     }
-    final count = await db.rawDelete(
-        'DELETE FROM $EVENTS_TABLE WHERE id IN (${eventIds.join(',')})');
-    length -= count;
+
+    try {
+      final count = await db.rawDelete(
+          'DELETE FROM $EVENTS_TABLE WHERE id IN (${eventIds.join(',')})');
+      length -= count;
+    } catch (ex) {
+      return;
+    }
   }
 
   Future<List<Event>> fetch(int count) async {
     final db = await _getDb();
     if (db == null) {
       return [];
     }
-    final records = await db.query(EVENTS_TABLE, limit: count, orderBy: COL_ID);
-    return records.map((m) => _deserialize(m)).toList();
+
+    try {
+      final records =
+          await db.query(EVENTS_TABLE, limit: count, orderBy: COL_ID);
+      return records.map((m) => _deserialize(m)).toList();
+    } catch (ex) {
+      return [];
+    }
   }
 
   Future<Database?> _init() async {

pubspec.yaml

@@ -1,6 +1,6 @@
 name: amplitude_flutter
 description: Official Flutter plugin for tracking events and revenue to Amplitude.
-version: 1.4.0
+version: 1.4.2
 homepage: https://github.com/amplitude/Amplitude-Flutter
 
 environment: