encryptToDeviceMessagePayload method

Future<Map<String, dynamic>> encryptToDeviceMessagePayload(DeviceKeys device, String type, Map<String, dynamic> payload, { bool getFromDb = true, })

Encryptes a ToDeviceMessage for the given device with an existing olm session. Throws NoOlmSessionFoundException if there is no olm session with this device and none could be created.

Implementation

Future<Map<String, dynamic>> encryptToDeviceMessagePayload(
  DeviceKeys device,
  String type,
  Map<String, dynamic> payload, {
  bool getFromDb = true,
}) async {
  final sess =
      await getOlmSessions(device.curve25519Key!, getFromDb: getFromDb);
  if (sess.isEmpty) {
    throw NoOlmSessionFoundException(device);
  }
  final fullPayload = {
    'type': type,
    'content': payload,
    'sender': client.userID,
    'keys': {'ed25519': fingerprintKey},
    'recipient': device.userId,
    'recipient_keys': {'ed25519': device.ed25519Key},
  };
  final encryptResult = sess.first.session!.encrypt(json.encode(fullPayload));
  await storeOlmSession(sess.first);
  if (encryption.olmDatabase != null) {
    try {
      await encryption.olmDatabase?.setLastSentMessageUserDeviceKey(
        json.encode({
          'type': type,
          'content': payload,
        }),
        device.userId,
        device.deviceId!,
      );
    } catch (e, s) {
      // we can ignore this error, since it would just make us use a different olm session possibly
      Logs().w('Error while updating olm usage timestamp', e, s);
    }
  }
  final encryptedBody = <String, dynamic>{
    'algorithm': AlgorithmTypes.olmV1Curve25519AesSha2,
    'sender_key': identityKey,
    'ciphertext': <String, dynamic>{},
  };
  encryptedBody['ciphertext'][device.curve25519Key] = {
    'type': encryptResult.type,
    'body': encryptResult.body,
  };
  return encryptedBody;
}