query method

  1. @override
Future<List<T>> query(
  1. SyncScope scope
)
override

Implementation

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