safe<T> method

Future<T?> safe<T>(
  1. Future<T> callback(
    1. ScopedDatabase db
    ), {
  2. String? tag,
  3. bool exclusive = true,
  4. bool force = false,
})

Runs the callback through a non-closed ScopedDatabase, or returns null.

ScopedDatabase may be closed, for example, between E2E tests.

Implementation

Future<T?> safe<T>(
  Future<T> Function(ScopedDatabase db) callback, {
  String? tag,
  bool exclusive = true,
  bool force = false,
}) async {
  if (PlatformUtils.isWeb && !force) {
    // WAL doesn't work in Web, thus guard all the writes/reads with Web Locks
    // API: https://github.com/simolus3/sqlite3.dart/issues/200
    return await WebUtils.protect(
      tag: '${_scoped.db?.userId}',
      exclusive: exclusive,
      () async => await _scoped.wrapped(callback),
    );
  }

  return await _scoped.wrapped(callback);
}