mirror of https://github.com/qTox/qTox.git
apprb
11 years ago
7 changed files with 209 additions and 64 deletions
@ -0,0 +1,121 @@
@@ -0,0 +1,121 @@
|
||||
/*
|
||||
Copyright (C) 2015 by Project Tox <https://tox.im>
|
||||
|
||||
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.h" |
||||
#include <QMutexLocker> |
||||
#include <QTimer> |
||||
|
||||
const int OfflineMsgEngine::offlineTimeout = 2000; |
||||
QSet<OfflineMsgEngine*> OfflineMsgEngine::engines; |
||||
QMutex OfflineMsgEngine::globalMutex; |
||||
|
||||
OfflineMsgEngine::OfflineMsgEngine(Friend *frnd) : |
||||
mutex(QMutex::Recursive), |
||||
f(frnd) |
||||
{ |
||||
engines.insert(this); |
||||
} |
||||
|
||||
OfflineMsgEngine::~OfflineMsgEngine() |
||||
{ |
||||
engines.remove(this); |
||||
} |
||||
|
||||
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(); |
||||
msgIt.value().msg->featureUpdate(); |
||||
undeliveredMsgs.erase(msgIt); |
||||
} |
||||
receipts.erase(it); |
||||
} |
||||
} |
||||
|
||||
void OfflineMsgEngine::registerReceipt(int receipt, int messageID, MessageActionPtr 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->getRawMessage(); |
||||
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(); |
||||
} |
||||
|
||||
void OfflineMsgEngine::processAllMsgs() |
||||
{ |
||||
if (globalMutex.tryLock()) |
||||
{ |
||||
for (auto &it : engines) |
||||
{ |
||||
it->deliverOfflineMsgs(); |
||||
} |
||||
|
||||
globalMutex.unlock(); |
||||
} |
||||
} |
||||
@ -0,0 +1,61 @@
@@ -0,0 +1,61 @@
|
||||
/*
|
||||
Copyright (C) 2015 by Project Tox <https://tox.im>
|
||||
|
||||
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. |
||||
*/ |
||||
|
||||
#ifndef OFFLINEMSGENGINE_H |
||||
#define OFFLINEMSGENGINE_H |
||||
|
||||
#include <QObject> |
||||
#include <QSet> |
||||
#include <QMutex> |
||||
#include <QDateTime> |
||||
#include "src/widget/tool/chatactions/messageaction.h" |
||||
|
||||
struct Friend; |
||||
class QTimer; |
||||
|
||||
class OfflineMsgEngine : public QObject |
||||
{ |
||||
Q_OBJECT |
||||
public: |
||||
OfflineMsgEngine(Friend *); |
||||
virtual ~OfflineMsgEngine(); |
||||
|
||||
void dischargeReceipt(int receipt); |
||||
void registerReceipt(int receipt, int messageID, MessageActionPtr msg, const QDateTime ×tamp = QDateTime::currentDateTime()); |
||||
|
||||
public slots: |
||||
void deliverOfflineMsgs(); |
||||
void removeAllReciepts(); |
||||
static void processAllMsgs(); |
||||
|
||||
private: |
||||
struct MsgPtr { |
||||
MessageActionPtr msg; |
||||
QDateTime timestamp; |
||||
int receipt; |
||||
}; |
||||
|
||||
QMutex mutex; |
||||
Friend* f; |
||||
QHash<int, int> receipts; |
||||
QMap<int, MsgPtr> undeliveredMsgs; |
||||
|
||||
static QSet<OfflineMsgEngine*> engines; |
||||
static const int offlineTimeout; |
||||
static QMutex globalMutex; |
||||
}; |
||||
|
||||
#endif // OFFLINEMSGENGINE_H
|
||||
Loading…
Reference in new issue