setup method

Implementation

Future<void> setup(Room room) async {
  if (_room != room) {
    await _cleanUp();
    _room = room;
    _listener = _room!.createListener();
    _listener!
      ..on<LocalTrackPublishedEvent>((event) async {
        if (event.publication.encryptionType == EncryptionType.kNone ||
            isAV1Codec(event.publication.track?.codec ?? '')) {
          // no need to setup frame cryptor
          return;
        }
        final frameCryptor = await _addRtpSender(
            sender: event.publication.track!.sender!,
            identity: event.participant.identity,
            sid: event.publication.sid);
        if (kIsWeb && event.publication.track!.codec != null) {
          await frameCryptor.updateCodec(event.publication.track!.codec!);
        }
        frameCryptor.onFrameCryptorStateChanged = (trackId, state) {
          if (kDebugMode) {
            print('Sender::onFrameCryptorStateChanged: $state, trackId:  $trackId');
          }
          final participant = event.participant;
          [event.participant.events, participant.room.events].emit(TrackE2EEStateEvent(
            participant: participant,
            publication: event.publication,
            state: _e2eeStateFromFrameCryptoState(state),
          ));
        };
      })
      ..on<LocalTrackUnpublishedEvent>((event) async {
        for (var key in _frameCryptors.keys.toList()) {
          if (key.keys.first == event.participant.identity && key.values.first == event.publication.sid) {
            final frameCryptor = _frameCryptors.remove(key);
            await frameCryptor?.setEnabled(false);
            await frameCryptor?.dispose();
          }
        }
      })
      ..on<TrackSubscribedEvent>((event) async {
        final codec = event.publication.mimeType.split('/')[1];
        if (event.publication.encryptionType == EncryptionType.kNone || isAV1Codec(codec)) {
          // no need to setup frame cryptor
          return;
        }
        final frameCryptor = await _addRtpReceiver(
          receiver: event.track.receiver!,
          identity: event.participant.identity,
          sid: event.publication.sid,
        );
        if (kIsWeb) {
          await frameCryptor.updateCodec(codec.toLowerCase());
        }
        frameCryptor.onFrameCryptorStateChanged = (trackId, state) {
          if (kDebugMode) {
            print('Receiver::onFrameCryptorStateChanged: $state, trackId: $trackId');
          }
          final participant = event.participant;
          [event.participant.events, participant.room.events].emit(TrackE2EEStateEvent(
            participant: participant,
            publication: event.publication,
            state: _e2eeStateFromFrameCryptoState(state),
          ));
        };
      })
      ..on<TrackUnsubscribedEvent>((event) async {
        for (var key in _frameCryptors.keys.toList()) {
          if (key.keys.first == event.participant.identity && key.values.first == event.publication.sid) {
            final frameCryptor = _frameCryptors.remove(key);
            await frameCryptor?.setEnabled(false);
            await frameCryptor?.dispose();
          }
        }
      });
    _dataPacketCryptor ??= await dataPacketCryptorFactory.createDataPacketCryptor(
        algorithm: _algorithm, keyProvider: _keyProvider.keyProvider);
  }
}