mirror of
https://github.com/qTox/qTox.git
synced 2024-03-22 14:00:36 +08:00
76cbaf18f1
The qTox Project is not associated with the Tox Project in any ways, with the exception of "qTox" using the Tox Projet's "toxcore" collection of libraries. In particular, the Tox Projet does not own copyright over the qTox Project's "qTox" collection of software, source code, and assets. The qTox Project's assets are under the sole copyright of the qTox contributors, and no partiular rights are granted to the Tox Project.
104 lines
2.8 KiB
C++
104 lines
2.8 KiB
C++
/*
|
|
This file is part of qTox, a Qt-based graphical interface for Tox.
|
|
|
|
This program is libre 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 COPYING file for more details.
|
|
*/
|
|
|
|
#include "offlinemsgengine.h"
|
|
#include "src/friend.h"
|
|
#include "src/historykeeper.h"
|
|
#include "src/misc/settings.h"
|
|
#include "src/core/core.h"
|
|
#include <QMutexLocker>
|
|
#include <QTimer>
|
|
|
|
const int OfflineMsgEngine::offlineTimeout = 2000;
|
|
QMutex OfflineMsgEngine::globalMutex;
|
|
|
|
OfflineMsgEngine::OfflineMsgEngine(Friend *frnd) :
|
|
mutex(QMutex::Recursive),
|
|
f(frnd)
|
|
{
|
|
}
|
|
|
|
OfflineMsgEngine::~OfflineMsgEngine()
|
|
{
|
|
}
|
|
|
|
void OfflineMsgEngine::dischargeReceipt(int receipt)
|
|
{
|
|
QMutexLocker ml(&mutex);
|
|
|
|
auto it = receipts.find(receipt);
|
|
if (it != receipts.end())
|
|
{
|
|
int mID = it.value();
|
|
auto msgIt = undeliveredMsgs.find(mID);
|
|
if (msgIt != undeliveredMsgs.end())
|
|
{
|
|
HistoryKeeper::getInstance()->markAsSent(mID);
|
|
msgIt.value().msg->markAsSent(QDateTime::currentDateTime());
|
|
undeliveredMsgs.erase(msgIt);
|
|
}
|
|
receipts.erase(it);
|
|
}
|
|
}
|
|
|
|
void OfflineMsgEngine::registerReceipt(int receipt, int messageID, ChatMessage::Ptr msg, const QDateTime ×tamp)
|
|
{
|
|
QMutexLocker ml(&mutex);
|
|
|
|
receipts[receipt] = messageID;
|
|
undeliveredMsgs[messageID] = {msg, timestamp, receipt};
|
|
}
|
|
|
|
void OfflineMsgEngine::deliverOfflineMsgs()
|
|
{
|
|
QMutexLocker ml(&mutex);
|
|
|
|
if (!Settings::getInstance().getFauxOfflineMessaging())
|
|
return;
|
|
|
|
if (f->getStatus() == Status::Offline)
|
|
return;
|
|
|
|
if (undeliveredMsgs.size() == 0)
|
|
return;
|
|
|
|
QMap<int, MsgPtr> msgs = undeliveredMsgs;
|
|
removeAllReciepts();
|
|
|
|
for (auto iter = msgs.begin(); iter != msgs.end(); iter++)
|
|
{
|
|
if (iter.value().timestamp.msecsTo(QDateTime::currentDateTime()) < offlineTimeout)
|
|
{
|
|
registerReceipt(iter.value().receipt, iter.key(), iter.value().msg, iter.value().timestamp);
|
|
continue;
|
|
}
|
|
QString messageText = iter.value().msg->toString();
|
|
int rec;
|
|
if (iter.value().msg->isAction())
|
|
rec = Core::getInstance()->sendAction(f->getFriendID(), messageText);
|
|
else
|
|
rec = Core::getInstance()->sendMessage(f->getFriendID(), messageText);
|
|
|
|
registerReceipt(rec, iter.key(), iter.value().msg);
|
|
}
|
|
}
|
|
|
|
void OfflineMsgEngine::removeAllReciepts()
|
|
{
|
|
QMutexLocker ml(&mutex);
|
|
|
|
receipts.clear();
|
|
undeliveredMsgs.clear();
|
|
}
|