Rename classes for more clarity.

JanezStupar · Nov 6, 2023 · da32aa3 · da32aa3
1 parent 16906d0
commit da32aa3
Show file tree

Hide file tree

Showing 3 changed files with 9 additions and 9 deletions.
diff --git a/lib/src/batch.dart b/lib/src/batch.dart
@@ -5,7 +5,7 @@ typedef OnChangeFunction = Future<void> Function(
     Iterable<String> tables, Hlc hlc);
 
 // Override of Sqflite's Batch class to allow for injection of CRDT logic
-class BatchCrdt with SqfliteCrdtImplMixin implements BatchApi {
+class BatchSynchroflite with SqfliteCrdtImplMixin implements BatchApi {
   final Batch _db;
   final bool inTransaction;
   int _length = 0;
@@ -22,7 +22,7 @@ class BatchCrdt with SqfliteCrdtImplMixin implements BatchApi {
 
   final affectedTables = <String>{};
 
-  BatchCrdt(this._db, this.canonicalTime, this.onDatasetChanged,
+  BatchSynchroflite(this._db, this.canonicalTime, this.onDatasetChanged,
       {this.inTransaction = false});
 
   void _enqueue(Function statement) {

diff --git a/lib/src/transaction.dart b/lib/src/transaction.dart
@@ -4,10 +4,10 @@
 // SPDX-License-Identifier: Apache-2.0
 part of 'package:synchroflite/synchroflite.dart';
 
-class TransactionSqfliteCrdt extends TransactionCrdt with SqfliteCrdtImplMixin {
+class TransactionSynchroflite extends TransactionCrdt with SqfliteCrdtImplMixin {
   final SqfliteApi _txn;
 
-  TransactionSqfliteCrdt(this._txn, canonicalTime) : super(_txn, canonicalTime);
+  TransactionSynchroflite(this._txn, canonicalTime) : super(_txn, canonicalTime);
 
   @override
   Future<R> _rawInsert<T, R>(T db, InsertStatement statement,
@@ -50,7 +50,7 @@ class TransactionSqfliteCrdt extends TransactionCrdt with SqfliteCrdtImplMixin {
     return _innerRawDelete(_txn, sql, args, canonicalTime);
   }
 
-  Batch batch() => BatchCrdt(_txn.batch(), canonicalTime, (tables, hlc) async {
+  Batch batch() => BatchSynchroflite(_txn.batch(), canonicalTime, (tables, hlc) async {
         affectedTables.addAll(tables);
       }, inTransaction: true);
 }
diff --git a/lib/synchroflite.dart b/lib/synchroflite.dart
@@ -142,14 +142,14 @@ class Synchroflite extends SqlCrdt with SqfliteCrdtImplMixin {
   }
 
   Batch batch() =>
-      BatchCrdt((_db.batch()), canonicalTime.increment(), onDatasetChanged);
+      BatchSynchroflite((_db.batch()), canonicalTime.increment(), onDatasetChanged);
 
   @override
   Future<void> transaction(
-      Future<void> Function(TransactionSqfliteCrdt txn) action) async {
-    late final TransactionSqfliteCrdt transaction;
+      Future<void> Function(TransactionSynchroflite txn) action) async {
+    late final TransactionSynchroflite transaction;
     await _db.transaction((txn) async {
-      transaction = TransactionSqfliteCrdt(txn, canonicalTime.increment());
+      transaction = TransactionSynchroflite(txn, canonicalTime.increment());
       await action(transaction);
     });
     // Notify on changes