ref: segregate chat sytem

ServerLMS/Systems/Parsers/processparser.cpp

@@ -1,7 +1,7 @@
 #include "processparser.h"
 #include "tasksAmmFim.h"
 
-ProcessParser::ProcessParser(QObject *parent) : QObject(parent)
+ProcessParser::ProcessParser(QObject *parent) : QObject(parent) //TODO: переименовать в XMLProcessParser?
 {
 
 }
@@ -500,7 +500,7 @@ void ProcessParser::clientMessage(QXmlStreamReader &xmlReader,ClientHandler *cli
             clientMessage.To = value;
     }
 
-    processingSystem->processingSendMessage(client, clientMessage);
+    processingSystem->processingSendMessage(clientMessage);
 
 }
 

ServerLMS/Systems/chatsystem.cpp

@@ -0,0 +1,83 @@
+#include "chatsystem.h"
+
+ChatSystem::ChatSystem()
+{
+
+}
+
+void ChatSystem::initialize(CommonClientHandler *commonClientHandler, DataParser *dataParser, QMap<int, ClientHandler*> *clientsMap)
+{
+    this->commonClientHandler = commonClientHandler;
+    this->dataParser = dataParser;
+    this->clientsMap = clientsMap;
+    clientNotSendedMessage = new QMap<QString,QStack<ClientMessage>*>;
+
+    auto stack = new QStack<ClientMessage>;
+    auto clientMessage1 = ClientMessage("1","102","Сообщение 1");
+    stack->append(clientMessage1);
+    auto clientMessage2 = ClientMessage("1","102","Сообщение 2");
+    stack->append(clientMessage2);
+
+    clientNotSendedMessage->insert("102", stack);
+}
+
+bool ChatSystem::sendTo(ClientMessage message)
+{
+    QByteArray byteArrayMsg = dataParser->ClientAnswer()->message(message.From,message.To,message.Text);
+
+    foreach(int idSocket, clientsMap->keys())
+    {
+        ClientHandler *handler = clientsMap->value(idSocket);
+        if(handler->getClient()->getId() == message.To)
+        {
+            handler->sendXmlAnswer(byteArrayMsg, PacketType::TYPE_XMLANSWER);
+            QString str = "Msg From Client [" + message.From + " to " + message.To + "] : " + message.Text;
+
+            return true;
+        }
+    }
+
+    return false;
+}
+
+bool ChatSystem::sendMessage(ClientMessage message)
+{
+    bool isSended = false;
+    isSended = sendTo(message);
+
+    if (!isSended)
+    {
+        if (clientNotSendedMessage->contains(message.To))
+        {
+            clientNotSendedMessage->find(message.To).value()->append(message);
+        }
+        else
+        {
+            auto stack = new QStack<ClientMessage>;
+            stack->append(message);
+            clientNotSendedMessage->insert(message.To, stack);
+        }
+
+        qDebug() << "Message stack count: " + QString::number(clientNotSendedMessage->count());
+    }
+
+    return true;
+}
+
+void ChatSystem::sendOldMessages(QString id)
+{
+    if (clientNotSendedMessage->contains(id))
+    {
+        auto stack = clientNotSendedMessage->find(id).value();
+
+        while (!stack->isEmpty())
+        {
+            auto message = stack->pop();
+            sendTo(message);
+        }
+    }
+    else
+    {
+        qDebug() << "client empty";
+    }
+}

ServerLMS/Systems/chatsystem.h

@@ -0,0 +1,27 @@
+#ifndef CHATSYSTEM_H
+#define CHATSYSTEM_H
+
+#include "commonclienthandler.h"
+#include <QObject>
+#include <Data/typesDataServerClient.h>
+
+class ChatSystem : public QObject
+{
+    Q_OBJECT
+public:
+    ChatSystem();
+    void initialize(CommonClientHandler *commonClientHandler, DataParser *dataParser, QMap<int, ClientHandler*> *clientsMap);
+    bool sendMessage(ClientMessage message);
+    //логика хранения отложенных сообщений
+    //хендлеры для отправки и приема
+
+    void sendOldMessages(QString id);
+private:
+    CommonClientHandler *commonClientHandler;
+    DataParser *dataParser;
+    QMap<int, ClientHandler*> *clientsMap;
+    QMap<QString,QStack<ClientMessage>*> *clientNotSendedMessage;
+    bool sendTo(ClientMessage message);
+};
+
+#endif // CHATSYSTEM_H

ServerLMS/Systems/commonclienthandler.cpp

@@ -120,26 +120,7 @@ void CommonClientHandler::slot_sendPacketToAllClients(PacketType packetType)
     }
 }
 
-void CommonClientHandler::slotSendMessage(QString idFrom, QString idTo, QString text)
-{
-    QString textMsg = text;
 
-    QByteArray byteArrayMsg = dataParser->ClientAnswer()->message(idFrom,idTo,text);
-
-    //Проходим все открытые сокеты, ищем нужный
-    foreach(int idSocket, clientsMap->keys())
-    {
-        ClientHandler *handler = clientsMap->value(idSocket);
-        if(handler->getClient()->getId() == idTo)
-        {
-            handler->sendXmlAnswer(byteArrayMsg, PacketType::TYPE_XMLANSWER);
-            QString str = "Msg From Client [" + idFrom + " to " + idTo + "] : " + textMsg;
-
-            emit sigSendToLogger(str);
-                    break;
-        }
-    }
-}
 
 void CommonClientHandler::slot_sendTaskToClient(QString fullNameClient,QString textTask)
 {

ServerLMS/Systems/commonclienthandler.h

@@ -24,7 +24,7 @@ public:
     void slot_StatusTasksAMMofTraineeChanged(int trainee_id);
     void slot_StatusTasksFIMofTraineeChanged(int trainee_id);
     void slot_sendPacketToAllClients(PacketType packetType);
-    void slotSendMessage(QString loginFrom, QString loginTo, QString text);
+    bool slotSendMessage(QString loginFrom, QString loginTo, QString text);
     void slot_sendTaskToClient(QString fullNameClient, QString textTask);
 signals:
     void sigSendToLogger(QString text);

ServerLMS/Systems/processingsystem.cpp

@@ -15,12 +15,14 @@ void ProcessingSystem::initialize(ServerLMSWidget *server,
                                   DataParser *dataParser,
                                   CommonClientHandler *commonClientHandler,
                                   Logger *logger,
-                                  UpdateController *updateController)
+                                  UpdateController *updateController,
+                                  ChatSystem *chatSystem)
 {
     this->commonClientServer = commonClientHandler;
     this->dataParser = dataParser;
     this->server = server;
     this->updateController = updateController;
+    this->chatSystem = chatSystem;
 
     connect(this,&ProcessingSystem::sigListsInstructorsTraineesChanged,commonClientHandler, &CommonClientHandler::slot_ListsInstructorsTraineesChanged,Qt::AutoConnection);
 
@@ -29,7 +31,6 @@ void ProcessingSystem::initialize(ServerLMSWidget *server,
 
     connect(this,&ProcessingSystem::sigUpdateListClients,server, &ServerLMSWidget::slotUpdateListClients,Qt::AutoConnection);
     connect(this,&ProcessingSystem::sigSetData,updateController,&UpdateController::setDataInfo,Qt::AutoConnection);
-    connect(this,&ProcessingSystem::sigSendMessage,commonClientHandler, &CommonClientHandler::slotSendMessage,Qt::AutoConnection);
     connect(this,&ProcessingSystem::sigLogMessage,logger,&Logger::addTextToLogger,Qt::QueuedConnection);
 }
 
@@ -95,7 +96,6 @@ void ProcessingSystem::processingClientAutorization(ClientHandler *client, Clien
 
     QString str = QString(arrayAnswer);
     //logger->addTextToLogger("To Client: " + str);
-
     //Извещаем об изменениях в авторизации
     emit sigListsInstructorsTraineesChanged();
 }
@@ -474,9 +474,9 @@ void ProcessingSystem::processingClientQueryTasksXML(ClientHandler *client, Clie
     }
 }
 
-void ProcessingSystem::processingSendMessage(ClientHandler *client, ClientMessage clientMessage)
+void ProcessingSystem::processingSendMessage(ClientMessage clientMessage)
 {
-    emit sigSendMessage(clientMessage.From, clientMessage.To, clientMessage.Text);
+    chatSystem->sendMessage(clientMessage);
 }
 
 void ProcessingSystem::processingClientNotify(ClientHandler *client, ClientNotify clientNotify)

ServerLMS/Systems/processingsystem.h

@@ -7,6 +7,7 @@
 #include <clienthandler.h>
 #include <serverlmswidget.h>
 //#include "instructorsandtraineeswidget.h"
+#include "chatsystem.h"
 #include "providerdblms.h"
 
 class SendSystem;
@@ -27,14 +28,15 @@ public:
                     DataParser* dataParser,
                     CommonClientHandler *commonClientServer,
                     Logger *logger,
-                    UpdateController *updateComtroller);
+                    UpdateController *updateComtroller,
+                    ChatSystem *chatSystem);
 
     void processingClientAutorization(ClientHandler *client, ClientAutorization clientAutorization);
     void processingClientDeAutorization(ClientHandler *client, ClientDeAutorization clientDeAutorization);
     void processingClientQueryToDB(ClientHandler *client, ClientQueryToDB clientQueryToDB, int id = 0, void* data = nullptr);
     void processingClientQueryTasksXML(ClientHandler *client, ClientQueryTasksXML clientQueryTasksXML);
 
-    void processingSendMessage(ClientHandler *client, ClientMessage clientMessage);
+    void processingSendMessage(ClientMessage clientMessage);
     void processingClientNotify(ClientHandler *client, ClientNotify clientNotify);
 
     void setCurrentDataInfo(DataInfo *dataInfo);
@@ -57,7 +59,6 @@ signals:
     void sigStatusTasksFIMofTraineeChanged(int trainee_id);
     void sigLogMessage(QString log);
     void sigAddToMessanger(QString login,QString text);
-    void sigSendMessage(QString loginFrom, QString loginTo, QString text);
     void sigSetData(DataInfo *dataInfo);
 
 private:
@@ -66,6 +67,7 @@ private:
     DataParser *dataParser;
     UpdateController *updateController;
     ProviderDBLMS* providerDBLMS;
+    ChatSystem *chatSystem;
     void sendTaskListToUnity(ClientHandler *client);
 };
 

ServerLMS/Systems/recognizesystem.cpp

@@ -24,7 +24,6 @@ void RecognizeSystem::initialize(UpdateController *updateController,DataParser*
     socket = handler->getSocket();
 
     connect(this,&RecognizeSystem::sigCalculateHash,updateController,&UpdateController::calculateFullHashWithSetup,Qt::AutoConnection);
-    //connect(this,&RecognizeSystem::sigCalculateHash,updateController,&UpdateController::setUpCurrentServerHash,Qt::AutoConnection);
     connect(this,&RecognizeSystem::sigChangeVersion,updateController,&UpdateController::changeAssetVersion,Qt::AutoConnection);
     connect(this,&RecognizeSystem::sigDeleteVersion,updateController,&UpdateController::deleteAssetVersion,Qt::AutoConnection);
     connect(this,&RecognizeSystem::sigCopyVersion,updateController,&UpdateController::createCopyVersion,Qt::AutoConnection);
@@ -51,10 +50,6 @@ void RecognizeSystem::recognize()
 
             if(!isPackageTypeInited)        //первичная инициализация для типа клиента
             {
-//                char *read = new char[0];
-//                stream.readRawData(read,1);
-//                packetType = static_cast<PacketType>(QString(read[0]).toInt());
-
                 char *read = new char[4];
                 stream.readRawData(read,4);