mirror of
https://gitlab.linphone.org/BC/public/linphone-desktop.git
synced 2026-01-17 11:28:07 +00:00
320 lines
11 KiB
C++
320 lines
11 KiB
C++
/*
|
|
* Copyright (c) 2010-2024 Belledonne Communications SARL.
|
|
*
|
|
* This file is part of linphone-desktop
|
|
* (see https://www.linphone.org).
|
|
*
|
|
* This program is free software: you can redistribute it and/or modify
|
|
* it under the terms of the GNU General Public License as published by
|
|
* the Free Software Foundation, either version 3 of the License, or
|
|
* (at your option) any later version.
|
|
*
|
|
* This program is distributed in the hope that it will be useful,
|
|
* but WITHOUT ANY WARRANTY; without even the implied warranty of
|
|
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
|
|
* GNU General Public License for more details.
|
|
*
|
|
* You should have received a copy of the GNU General Public License
|
|
* along with this program. If not, see <http://www.gnu.org/licenses/>.
|
|
*/
|
|
|
|
#include "CallModel.hpp"
|
|
|
|
#include <QDebug>
|
|
|
|
#include "core/path/Paths.hpp"
|
|
#include "model/core/CoreModel.hpp"
|
|
#include "tool/Utils.hpp"
|
|
|
|
DEFINE_ABSTRACT_OBJECT(CallModel)
|
|
|
|
CallModel::CallModel(const std::shared_ptr<linphone::Call> &call, QObject *parent)
|
|
: ::Listener<linphone::Call, linphone::CallListener>(call, parent) {
|
|
mustBeInLinphoneThread(getClassName());
|
|
mDurationTimer.setInterval(1000);
|
|
mDurationTimer.setSingleShot(false);
|
|
connect(&mDurationTimer, &QTimer::timeout, this, [this]() { this->durationChanged(mMonitor->getDuration()); });
|
|
mDurationTimer.start();
|
|
|
|
mMicroVolumeTimer.setInterval(50);
|
|
mMicroVolumeTimer.setSingleShot(false);
|
|
connect(&mMicroVolumeTimer, &QTimer::timeout, this,
|
|
[this]() { this->microphoneVolumeChanged(Utils::computeVu(mMonitor->getRecordVolume())); });
|
|
mMicroVolumeTimer.start();
|
|
|
|
connect(this, &CallModel::stateChanged, this, [this] {
|
|
auto state = mMonitor->getState();
|
|
if (state == linphone::Call::State::Paused) setPaused(true);
|
|
});
|
|
}
|
|
|
|
CallModel::~CallModel() {
|
|
mustBeInLinphoneThread("~" + getClassName());
|
|
}
|
|
|
|
void CallModel::accept(bool withVideo) {
|
|
mustBeInLinphoneThread(log().arg(Q_FUNC_INFO));
|
|
auto core = CoreModel::getInstance()->getCore();
|
|
auto params = core->createCallParams(mMonitor);
|
|
params->enableVideo(withVideo);
|
|
params->setRecordFile(
|
|
Paths::getCapturesDirPath()
|
|
.append(Utils::generateSavedFilename(QString::fromStdString(mMonitor->getToAddress()->getUsername()), ""))
|
|
.append(".mkv")
|
|
.toStdString());
|
|
mMonitor->enableCamera(withVideo);
|
|
// Answer with local call address.
|
|
auto localAddress = mMonitor->getCallLog()->getLocalAddress();
|
|
for (auto account : core->getAccountList()) {
|
|
if (account->getParams()->getIdentityAddress()->weakEqual(localAddress)) {
|
|
params->setAccount(account);
|
|
break;
|
|
}
|
|
}
|
|
|
|
mMonitor->acceptWithParams(params);
|
|
}
|
|
|
|
void CallModel::decline() {
|
|
mustBeInLinphoneThread(log().arg(Q_FUNC_INFO));
|
|
auto errorInfo = linphone::Factory::get()->createErrorInfo();
|
|
errorInfo->set("SIP", linphone::Reason::Declined, 603, "Decline", "");
|
|
mMonitor->terminateWithErrorInfo(errorInfo);
|
|
}
|
|
|
|
void CallModel::terminate() {
|
|
mustBeInLinphoneThread(log().arg(Q_FUNC_INFO));
|
|
mMonitor->terminate();
|
|
}
|
|
void CallModel::setPaused(bool paused) {
|
|
mustBeInLinphoneThread(log().arg(Q_FUNC_INFO));
|
|
if (paused) {
|
|
auto status = mMonitor->pause();
|
|
if (status != -1) emit pausedChanged(paused);
|
|
} else {
|
|
auto status = mMonitor->resume();
|
|
if (status != -1) emit pausedChanged(paused);
|
|
}
|
|
}
|
|
|
|
void CallModel::transferTo(const std::shared_ptr<linphone::Address> &address) {
|
|
mustBeInLinphoneThread(log().arg(Q_FUNC_INFO));
|
|
if (mMonitor->transferTo(address) == -1)
|
|
qWarning() << log()
|
|
.arg(QStringLiteral("Unable to transfer: `%1`."))
|
|
.arg(Utils::coreStringToAppString(address->asStringUriOnly()));
|
|
}
|
|
|
|
void CallModel::terminateAllCalls() {
|
|
auto status = mMonitor->getCore()->terminateAllCalls();
|
|
}
|
|
|
|
void CallModel::setMicrophoneMuted(bool isMuted) {
|
|
mustBeInLinphoneThread(log().arg(Q_FUNC_INFO));
|
|
mMonitor->setMicrophoneMuted(isMuted);
|
|
emit microphoneMutedChanged(isMuted);
|
|
}
|
|
|
|
void CallModel::setSpeakerMuted(bool isMuted) {
|
|
mustBeInLinphoneThread(log().arg(Q_FUNC_INFO));
|
|
mMonitor->setSpeakerMuted(isMuted);
|
|
emit speakerMutedChanged(isMuted);
|
|
}
|
|
|
|
void CallModel::setCameraEnabled(bool enabled) {
|
|
mustBeInLinphoneThread(log().arg(Q_FUNC_INFO));
|
|
mMonitor->enableCamera(enabled);
|
|
auto core = CoreModel::getInstance()->getCore();
|
|
auto params = core->createCallParams(mMonitor);
|
|
params->enableVideo(enabled);
|
|
emit cameraEnabledChanged(enabled);
|
|
}
|
|
|
|
void CallModel::startRecording() {
|
|
mustBeInLinphoneThread(log().arg(Q_FUNC_INFO));
|
|
mMonitor->startRecording();
|
|
emit recordingChanged(mMonitor->getParams()->isRecording());
|
|
}
|
|
|
|
void CallModel::stopRecording() {
|
|
mustBeInLinphoneThread(log().arg(Q_FUNC_INFO));
|
|
mMonitor->stopRecording();
|
|
emit recordingChanged(mMonitor->getParams()->isRecording());
|
|
// TODO : display notification
|
|
}
|
|
|
|
void CallModel::setRecordFile(const std::string &path) {
|
|
mustBeInLinphoneThread(log().arg(Q_FUNC_INFO));
|
|
auto core = CoreModel::getInstance()->getCore();
|
|
auto params = core->createCallParams(mMonitor);
|
|
params->setRecordFile(path);
|
|
mMonitor->update(params);
|
|
}
|
|
|
|
void CallModel::setSpeakerVolumeGain(float gain) {
|
|
mMonitor->setSpeakerVolumeGain(gain);
|
|
emit speakerVolumeGainChanged(gain);
|
|
}
|
|
|
|
float CallModel::getSpeakerVolumeGain() const {
|
|
mustBeInLinphoneThread(log().arg(Q_FUNC_INFO));
|
|
auto gain = mMonitor->getSpeakerVolumeGain();
|
|
if (gain < 0) gain = CoreModel::getInstance()->getCore()->getPlaybackGainDb();
|
|
return gain;
|
|
}
|
|
|
|
void CallModel::setMicrophoneVolumeGain(float gain) {
|
|
mMonitor->setMicrophoneVolumeGain(gain);
|
|
emit microphoneVolumeGainChanged(gain);
|
|
}
|
|
|
|
float CallModel::getMicrophoneVolumeGain() const {
|
|
auto gain = mMonitor->getMicrophoneVolumeGain();
|
|
return gain;
|
|
}
|
|
|
|
float CallModel::getMicrophoneVolume() const {
|
|
auto volume = mMonitor->getRecordVolume();
|
|
return volume;
|
|
}
|
|
|
|
void CallModel::setInputAudioDevice(const std::shared_ptr<linphone::AudioDevice> &device) {
|
|
mMonitor->setInputAudioDevice(device);
|
|
std::string deviceName;
|
|
if (device) deviceName = device->getDeviceName();
|
|
emit inputAudioDeviceChanged(deviceName);
|
|
}
|
|
|
|
std::shared_ptr<const linphone::AudioDevice> CallModel::getInputAudioDevice() const {
|
|
return mMonitor->getInputAudioDevice();
|
|
}
|
|
|
|
void CallModel::setOutputAudioDevice(const std::shared_ptr<linphone::AudioDevice> &device) {
|
|
mMonitor->setOutputAudioDevice(device);
|
|
std::string deviceName;
|
|
if (device) deviceName = device->getDeviceName();
|
|
emit outputAudioDeviceChanged(deviceName);
|
|
}
|
|
|
|
std::shared_ptr<const linphone::AudioDevice> CallModel::getOutputAudioDevice() const {
|
|
return mMonitor->getOutputAudioDevice();
|
|
}
|
|
|
|
std::string CallModel::getRecordFile() const {
|
|
mustBeInLinphoneThread(log().arg(Q_FUNC_INFO));
|
|
return mMonitor->getParams()->getRecordFile();
|
|
}
|
|
|
|
std::shared_ptr<const linphone::Address> CallModel::getRemoteAddress() {
|
|
mustBeInLinphoneThread(log().arg(Q_FUNC_INFO));
|
|
return mMonitor->getRemoteAddress();
|
|
}
|
|
|
|
bool CallModel::getAuthenticationTokenVerified() const {
|
|
mustBeInLinphoneThread(log().arg(Q_FUNC_INFO));
|
|
return mMonitor->getAuthenticationTokenVerified();
|
|
}
|
|
|
|
void CallModel::setAuthenticationTokenVerified(bool verified) {
|
|
mustBeInLinphoneThread(log().arg(Q_FUNC_INFO));
|
|
mMonitor->setAuthenticationTokenVerified(verified);
|
|
emit authenticationTokenVerifiedChanged(verified);
|
|
}
|
|
|
|
std::string CallModel::getAuthenticationToken() const {
|
|
mustBeInLinphoneThread(log().arg(Q_FUNC_INFO));
|
|
auto token = mMonitor->getAuthenticationToken();
|
|
return token;
|
|
}
|
|
|
|
void CallModel::onDtmfReceived(const std::shared_ptr<linphone::Call> &call, int dtmf) {
|
|
emit dtmfReceived(call, dtmf);
|
|
}
|
|
|
|
void CallModel::onGoclearAckSent(const std::shared_ptr<linphone::Call> &call) {
|
|
emit goclearAckSent(call);
|
|
}
|
|
|
|
void CallModel::onEncryptionChanged(const std::shared_ptr<linphone::Call> &call,
|
|
bool on,
|
|
const std::string &authenticationToken) {
|
|
emit encryptionChanged(call, on, authenticationToken);
|
|
}
|
|
|
|
void CallModel::onSendMasterKeyChanged(const std::shared_ptr<linphone::Call> &call, const std::string &sendMasterKey) {
|
|
emit sendMasterKeyChanged(call, sendMasterKey);
|
|
}
|
|
|
|
void CallModel::onReceiveMasterKeyChanged(const std::shared_ptr<linphone::Call> &call,
|
|
const std::string &receiveMasterKey) {
|
|
emit receiveMasterKeyChanged(call, receiveMasterKey);
|
|
}
|
|
|
|
void CallModel::onInfoMessageReceived(const std::shared_ptr<linphone::Call> &call,
|
|
const std::shared_ptr<const linphone::InfoMessage> &message) {
|
|
emit infoMessageReceived(call, message);
|
|
}
|
|
|
|
void CallModel::onStateChanged(const std::shared_ptr<linphone::Call> &call,
|
|
linphone::Call::State state,
|
|
const std::string &message) {
|
|
if (state == linphone::Call::State::StreamsRunning) {
|
|
// After UpdatedByRemote, video direction could be changed.
|
|
auto params = call->getRemoteParams();
|
|
emit remoteVideoEnabledChanged(params && params->videoEnabled());
|
|
emit cameraEnabledChanged(call->cameraEnabled());
|
|
}
|
|
emit stateChanged(state, message);
|
|
}
|
|
|
|
void CallModel::onStatusChanged(const std::shared_ptr<linphone::Call> &call, linphone::Call::Status status) {
|
|
emit statusChanged(status);
|
|
}
|
|
|
|
void CallModel::onDirChanged(const std::shared_ptr<linphone::Call> &call, linphone::Call::Dir dir) {
|
|
emit dirChanged(dir);
|
|
}
|
|
|
|
void CallModel::onStatsUpdated(const std::shared_ptr<linphone::Call> &call,
|
|
const std::shared_ptr<const linphone::CallStats> &stats) {
|
|
emit statsUpdated(call, stats);
|
|
}
|
|
|
|
void CallModel::onTransferStateChanged(const std::shared_ptr<linphone::Call> &call, linphone::Call::State state) {
|
|
emit transferStateChanged(call, state);
|
|
}
|
|
|
|
void CallModel::onAckProcessing(const std::shared_ptr<linphone::Call> &call,
|
|
const std::shared_ptr<linphone::Headers> &ack,
|
|
bool isReceived) {
|
|
emit ackProcessing(call, ack, isReceived);
|
|
}
|
|
|
|
void CallModel::onTmmbrReceived(const std::shared_ptr<linphone::Call> &call, int streamIndex, int tmmbr) {
|
|
emit tmmbrReceived(call, streamIndex, tmmbr);
|
|
}
|
|
|
|
void CallModel::onSnapshotTaken(const std::shared_ptr<linphone::Call> &call, const std::string &filePath) {
|
|
emit snapshotTaken(call, filePath);
|
|
}
|
|
|
|
void CallModel::onNextVideoFrameDecoded(const std::shared_ptr<linphone::Call> &call) {
|
|
emit nextVideoFrameDecoded(call);
|
|
}
|
|
|
|
void CallModel::onCameraNotWorking(const std::shared_ptr<linphone::Call> &call, const std::string &cameraName) {
|
|
emit cameraNotWorking(call, cameraName);
|
|
}
|
|
|
|
void CallModel::onVideoDisplayErrorOccurred(const std::shared_ptr<linphone::Call> &call, int errorCode) {
|
|
emit videoDisplayErrorOccurred(call, errorCode);
|
|
}
|
|
|
|
void CallModel::onAudioDeviceChanged(const std::shared_ptr<linphone::Call> &call,
|
|
const std::shared_ptr<linphone::AudioDevice> &audioDevice) {
|
|
emit audioDeviceChanged(call, audioDevice);
|
|
}
|
|
|
|
void CallModel::onRemoteRecording(const std::shared_ptr<linphone::Call> &call, bool recording) {
|
|
emit remoteRecording(call, recording);
|
|
}
|