querySince method

Implementation

@override
Future<List<T>> querySince(SyncScope scope, DateTime since) async {
  final sk = _scopeKey(scope);
  final q = db.select(db.items)
    ..where(
      (t) => supportsSoftDelete
          ? (t.scopeName.equals(scope.name) &
                t.scopeKeys.equals(sk) &
                t.updatedAt.isBiggerThanValue(since.toIso8601String()) &
                t.deletedAt.isNull())
          : (t.scopeName.equals(scope.name) &
                t.scopeKeys.equals(sk) &
                t.updatedAt.isBiggerThanValue(since.toIso8601String())),
    );
  final rows = await q.get();
  return rows
      .map((r) => fromJson(jsonDecode(r.payload) as Map<String, dynamic>))
      .toList(growable: false);
}