startOutgoingOlmSessions method

Future<void> startOutgoingOlmSessions(List<DeviceKeys> deviceKeys)

Implementation

Future<void> startOutgoingOlmSessions(List<DeviceKeys> deviceKeys) async {
  Logs().v(
    '[OlmManager] Starting session with ${deviceKeys.length} devices...',
  );
  final requestingKeysFrom = <String, Map<String, String>>{};
  for (final device in deviceKeys) {
    if (requestingKeysFrom[device.userId] == null) {
      requestingKeysFrom[device.userId] = {};
    }
    requestingKeysFrom[device.userId]![device.deviceId!] =
        'signed_curve25519';
  }

  final response = await client.claimKeys(requestingKeysFrom, timeout: 10000);

  for (final userKeysEntry in response.oneTimeKeys.entries) {
    final userId = userKeysEntry.key;
    for (final deviceKeysEntry in userKeysEntry.value.entries) {
      final deviceId = deviceKeysEntry.key;
      final fingerprintKey =
          client.userDeviceKeys[userId]!.deviceKeys[deviceId]!.ed25519Key;
      final identityKey =
          client.userDeviceKeys[userId]!.deviceKeys[deviceId]!.curve25519Key;
      for (final deviceKey in deviceKeysEntry.value.values) {
        if (fingerprintKey == null ||
            identityKey == null ||
            deviceKey is! Map<String, Object?> ||
            !deviceKey.checkJsonSignature(fingerprintKey, userId, deviceId) ||
            deviceKey['key'] is! String) {
          Logs().w(
            'Skipping invalid device key from $userId:$deviceId',
            deviceKey,
          );
          continue;
        }
        Logs().v('[OlmManager] Starting session with $userId:$deviceId');
        try {
          final session = _olmAccount!.createOutboundSession(
            identityKey: vod.Curve25519PublicKey.fromBase64(identityKey),
            oneTimeKey: vod.Curve25519PublicKey.fromBase64(
              deviceKey.tryGet<String>('key')!,
            ),
          );

          await storeOlmSession(
            OlmSession(
              key: client.userID!,
              identityKey: identityKey,
              sessionId: session.sessionId,
              session: session,
              lastReceived:
                  DateTime.now(), // we want to use a newly created session
            ),
          );
        } catch (e, s) {
          Logs().e(
            '[Vodozemac] Could not create new outbound olm session',
            e,
            s,
          );
        }
      }
    }
  }
}