closeExpired method

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

Implementation

@override
Future closeExpired(String? correlationId, DateTime request_time) async {
  var time = request_time.millisecondsSinceEpoch;
  var now = DateTime.now();
  var count = 0;

  for (var item in items) {
    if (item.active != null &&
        item.active &&
        item.request_time!.millisecondsSinceEpoch < time) {
      item.active = false;
      item.close_time = now;
      item.request_time = now;
      item.data = null;
      item.user = null;

      count++;
    }
  }

  if (count > 0) {
    logger.debug(correlationId, 'Closed %d expired sessions', [count]);

    await save(correlationId);
  } else {
    return null;
  }
}