start method

Implementation

@override
Future<Rx<OngoingCall>> start(
  ChatId chatId, {
  bool withAudio = true,
  bool withVideo = true,
  bool withScreen = false,
}) async {
  Log.debug(
    'start($chatId, $withAudio, $withVideo, $withScreen)',
    '$runtimeType',
  );

  // TODO: Call should be displayed right away.
  if (chatId.isLocal && ensureRemoteDialog != null) {
    chatId = (await ensureRemoteDialog!.call(chatId))!.id;
  }

  if (calls[chatId] != null) {
    throw CallAlreadyExistsException();
  }

  final Rx<OngoingCall> call = Rx<OngoingCall>(
    OngoingCall(
      chatId,
      me,
      withAudio: withAudio,
      withVideo: withVideo,
      withScreen: withScreen,
      mediaSettings: media.value,
      creds: await generateCredentials(chatId),
      state: OngoingCallState.local,
    ),
  );

  calls[call.value.chatId.value] = call;

  final response = await _graphQlProvider.startChatCall(
    call.value.chatId.value,
    call.value.creds!,
    call.value.videoState.value == LocalTrackState.enabling ||
        call.value.videoState.value == LocalTrackState.enabled,
  );

  call.value.deviceId = response.deviceId;

  final ChatCall? chatCall = _chatCall(response.event);
  if (chatCall != null) {
    call.value.call.value = chatCall;
    transferCredentials(chatCall.chatId, chatCall.id);
  } else {
    throw CallAlreadyJoinedException(response.deviceId);
  }
  calls[call.value.chatId.value]?.refresh();

  return call;
}