encryptToDeviceMessage method

Future<Map<String, Map<String, Map<String, dynamic>>>> encryptToDeviceMessage(List<DeviceKeys> deviceKeys, String type, Map<String, dynamic> payload)

Implementation

Future<Map<String, Map<String, Map<String, dynamic>>>> encryptToDeviceMessage(
  List<DeviceKeys> deviceKeys,
  String type,
  Map<String, dynamic> payload,
) async {
  final data = <String, Map<String, Map<String, dynamic>>>{};
  // first check if any of our sessions we want to encrypt for are in the database
  if (encryption.olmDatabase != null) {
    await getOlmSessionsForDevicesFromDatabase(
      deviceKeys.map((d) => d.curve25519Key!).toList(),
    );
  }
  final deviceKeysWithoutSession = List<DeviceKeys>.from(deviceKeys);
  deviceKeysWithoutSession.removeWhere(
    (DeviceKeys deviceKeys) =>
        olmSessions[deviceKeys.curve25519Key]?.isNotEmpty ?? false,
  );
  if (deviceKeysWithoutSession.isNotEmpty) {
    await startOutgoingOlmSessions(deviceKeysWithoutSession);
  }
  for (final device in deviceKeys) {
    final userData = data[device.userId] ??= {};
    try {
      userData[device.deviceId!] = await encryptToDeviceMessagePayload(
        device,
        type,
        payload,
        getFromDb: false,
      );
    } on NoOlmSessionFoundException catch (e) {
      Logs().d('[LibOlm] Error encrypting to-device event', e);
      continue;
    } catch (e, s) {
      Logs().wtf('[LibOlm] Error encrypting to-device event', e, s);
      continue;
    }
  }
  return data;
}