getEntries method

  1. @visibleForTesting
Future<List<OplogEntry>> getEntries({
  1. int? since,
})

Implementation

@visibleForTesting
Future<List<OplogEntry>> getEntries({int? since}) async {
  // `rowid` is never below 0, so -1 means "everything"
  since ??= -1;
  final oplog = '${opts.oplogTable}';

  final selectEntries = '''
    SELECT * FROM $oplog
      WHERE timestamp IS NOT NULL
        AND rowid > ${builder.makePositionalParam(1)}
      ORDER BY rowid ASC
  ''';
  final rows = await adapter.query(Statement(selectEntries, [since]));
  return rows.map(opLogEntryFromRow).toList();
}