closeExpired method

  1. @override
Future closeExpired(
  1. String? correlationId,
  2. DateTime request_time
)
override

Implementation

@override
Future closeExpired(String? correlationId, DateTime request_time) async {
  var criteria = {
    'request_time': {r'$lt': request_time},
    'active': true
  };
  var newItem = {
    r'$set': {
      'active': false,
      'request_time': DateTime.now(),
      'close_time': DateTime.now(),
      'user': null,
      'data': null
    }
  };

  var result = await collection!.update(criteria, newItem, multiUpdate: true);
  if (result != null && result['ok'] == 1.0) {
    logger.debug(correlationId, 'Closed %d expired sessions', []);
  }
}