markInboundGroupSessionsAsNeedingUpload method

  1. @override
Future<void> markInboundGroupSessionsAsNeedingUpload()
override

Implementation

@override
Future<void> markInboundGroupSessionsAsNeedingUpload() async {
  final keys = await _inboundGroupSessionsBox.getAllKeys();
  for (final sessionId in keys) {
    final raw = copyMap(
      await _inboundGroupSessionsBox.get(sessionId) ?? {},
    );
    if (raw.isEmpty) continue;
    final roomId = raw.tryGet<String>('room_id');
    if (roomId == null) continue;
    await _inboundGroupSessionsUploadQueueBox.put(sessionId, roomId);
  }
  return;
}