closeExpired method
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', []);
}
}