Qt Network

#ifndef CLIENTCONNECT_H
#define CLIENTCONNECT_H
 
#include <QObject>
#include <QHostAddress>
#include <QTcpServer>
#include <QTcpSocket>
#include <QFile>
#include <QStringList>
#include <QApplication>
 
class ClientConnect : public QObject
{
    Q_OBJECT
private:
    enum states {TOE=0,//0 Нолики
                 TAC,  //1 Крестики
                 NO,   //2 Нет ожидающих игроков
                 YES,  //3 Есть игрок ожидающий соперника
                 NAME, //4 Значение говорящее клиенту отправить свое имя
                 PRES, //5 Значение говорящее клиенту представить всю инфу о себе
                 WINN, //6 Значение говорящее о результате игры
                 STEP, //7 Значение говорящее кто и куда походил
                 DOWN, //8 Игрок готов начать игру
                 CONN, //9 Соперник подключился
                 FULL, //10 Сервер переполнен
                 ERROR,//11 Ошибка...
                 NONE, //12 Ничья
                 CLNT, //13 Клиент
                 BAN,
                 SRV
 
                };
    QTcpServer *server;
    QTcpSocket *gamer;
    QTcpSocket *tmpGamer;
    QByteArray data;
    QHostAddress host;
    int srv_port;
    QList<QString> NameConUser;
    QHash <int, void(ClientConnect::*)(QStringList)> pointFunc;
    QHash <states, QTcpSocket *> TablePartGame; // содержит двух игроков играющих между собой
    QHash <states, QTcpSocket *> tmpTablPart; // временая переменная для простоты манипуляции с данными
    QHash <int, QHash <states, QTcpSocket *> > TableGamer; // полнная таблица игроков
    QString findstatic(QString); // поиск в файле статистики информации о подключенном игроке
 
    QTcpSocket * find_gamer(int, int);
    void writeHashPoint();
    void mesPRESS(QStringList);
    void mesSTEP(QStringList);
    void mesWIN(QStringList);
    void mesNAME(QStringList);
 
 
public:
    explicit ClientConnect(QObject *parent = 0);
    ClientConnect(QObject *parent, QHostAddress type_addr, int port);
 
signals:
    void press(QString); //  о том что игрок представился
    void step(QString); // о том что обработана строка хода игрока
    void win(QStringList); // сигнализируем интерфейсу что есть победитель
    void user_down(QString); // сигнал для оповещения что игрок отключился
public slots:
    void NewGamer();
    void GetMessage();
    void UserDisconnect(); // обрабатываем отключенного пользователя
};
#endif // CLIENTCONNECT_H

#include "clientconnect.h"
 
ClientConnect::ClientConnect(QObject *parent) :QObject(parent)
{
 
}
 
ClientConnect::ClientConnect(QObject *parent, QHostAddress type_addr, int port):QObject(parent), host(type_addr), srv_port(port)
{
    server = new QTcpServer(this);
    //заполняем контейнер указателей на функицию
    writeHashPoint();
    //запускаем сервер
    if(server->listen(host,srv_port))
    {
        qDebug()<<"SERVER STARTED!";
        connect(server,SIGNAL(newConnection()),this, SLOT(NewGamer()));
    }
    else
    {
         // qDebug()<<"ERROR: SERVER NOT RUNING " << server->errorString();
    }
}
 
void ClientConnect::NewGamer()
{
    qDebug()<<"USER CONNECTED";
    data.clear();
    gamer = server->nextPendingConnection();
    connect(gamer, SIGNAL(readyRead()), this, SLOT(GetMessage()));
    data.insert(0, QString("%1").arg(NAME));
    qDebug()<<"SEND DATA USER-Y " << data;
    gamer->write(data);
    data.clear();
}
 
void ClientConnect::GetMessage()
{
    gamer = (QTcpSocket*)sender();
    if(gamer->bytesAvailable() >0)
    {
        QString str(gamer->readAll());
        QStringList lst = str.split(";");
        qDebug()<< "SERVER GET DATA FROM GAMER: " << str;
        // если адрес функции верен выполняем ее
        if(pointFunc.value(lst.at(0).toInt()))
        {
            qDebug()<< "RUN FUNCTIONS: " << lst.at(0);
            (this->*(this->pointFunc[lst.at(0).toInt()]))(lst);
        }
    }
    else
    {
         // qDebug()<< "NO DATA!!!!!!!!";
    }
}
 
void ClientConnect::writeHashPoint()
{
    pointFunc[PRES] = &ClientConnect::mesPRESS;
    pointFunc[STEP] = &ClientConnect::mesSTEP;
    pointFunc[WINN] = &ClientConnect::mesWIN;
    pointFunc[NAME] = &ClientConnect::mesNAME;
}
 
// обрабатываем сообщение о клиенте
void ClientConnect::mesPRESS(QStringList lst)
{
     qDebug()<<"mesPRESS RUNING";
    QString addUser="";
    //Указываем имя объекту
    qDebug()<<"mesPRESS OBJECT NAME " << lst.at(3) ;
    //                                           name           id table       id part
    gamer->setObjectName(QString("%1;%2;%3").arg(lst.at(3)).arg(lst.at(1)).arg(lst.at(2)));
    //ID_Table
    qDebug()<<"mesPRESS ID_TABLE " << lst.at(1);
    addUser+=QString("%1;").arg(lst.at(1));
    //ID_Part
    qDebug()<<"mesPRESS ID_PART " << lst.at(2);
    addUser+=QString("%1;").arg(lst.at(2));
    //NAME
    qDebug()<<"mesPRESS NAME " << lst.at(3);
    addUser+=QString("%1;").arg(lst.at(3));
    //IP
    qDebug()<<"mesPRESS IP "  << gamer->peerAddress().toString();
    addUser+=QString("%1;").arg(gamer->peerAddress().toString());
    //Port
    qDebug()<<"mesPRESS PORT " << srv_port ;
    addUser+=QString("%1;").arg(srv_port);
    //X|O
    qDebug()<<"mesPRESS X|O " << lst.at(4);
    addUser+=QString("%1;").arg(lst.at(4));
    // получаем статистику
    QString usrStatic = findstatic(lst.at(3));
    if(!usrStatic.isEmpty())
    {
        qDebug()<< "USER STATIC IS NOT EMPY " << usrStatic;
        //убираем имя пользователя из строки статистики
        usrStatic.replace(QString("%1;").arg(lst.at(3)),"");
         qDebug()<< "USER STATIC AFTE REPLACE " << usrStatic;
    }
    else
    {
        usrStatic=QString("0;0;0;0;");
    }
    qDebug()<<"mesPRESS USER STATIC " <<usrStatic;
 
    addUser+=usrStatic;
    qDebug()<< "NameConUser.size() ===" << NameConUser.size();
    qDebug()<< "NameConUser.size()%2 ===== "  << NameConUser.size()%2;
 
    if(NameConUser.size()%2==0)
    {
        // ищем адрес пративника, аргументы id d общей табл играков и id в партии
        gamer = find_gamer(lst.at(1).toInt(), lst.at(2).toInt());
        qDebug()<<"mesPRESS %2 != 0";
        data.clear();
        data.insert(0,QString("%1;%2;%3").arg(CONN).arg(lst.at(3)).arg(usrStatic));
        // сообщаем ожидающему игроку имя и статистику его соперника...
        gamer->write(data);
    }
    data.clear();
    // сообщаем GUI о подключившемся игроке
    emit press(addUser);
    qDebug("mesPRESS run");
}
 
// обработка сообщения о том куда кто походил
void ClientConnect::mesSTEP(QStringList lst)
{
    data.clear();
    QString userStep = QString("%1;%2;%3;%4;%5").arg(STEP).arg(lst.at(1)).arg(lst.at(2)).arg(lst.at(3)).arg(lst.at(4));
    qDebug()<< "SEND USER-Y STEP: " <<userStep;
    data.insert(0, userStep);
    qDebug()<<lst.size();
    qDebug()<<"X " <<lst.at(3);
    qDebug()<<"Y " <<lst.at(4);
    tmpGamer = find_gamer(lst.at(1).toInt(), lst.at(2).toInt());
    tmpGamer->write(data);
    emit step(QString("Игрок %1 сделал ход: %2 %3").arg(tmpGamer->objectName()).arg(lst.at(3)).arg(lst.at(4)));
    qDebug("mesSTEP run");
    data.clear();
}
 
 
void ClientConnect::mesWIN(QStringList lst)
{
    emit win(lst);
    qDebug("mesWIN run");
}
 
void ClientConnect::mesNAME(QStringList lst)
{
    bool user_fail=false;
    for(int i=0; i<NameConUser.size(); ++i)
    {
        if(NameConUser.at(i)==lst.at(1))
        {
            user_fail=true;
        }
    }
    if(user_fail)
    {
        data.clear();
        data.insert(0,QString("%1;%2").arg(ERROR).arg(NAME));
        gamer->write(data);
        gamer->close();
        data.clear();
    }
    else
    {
        connect(gamer, SIGNAL(disconnected()),this, SLOT(UserDisconnect()));
        if(NameConUser.size()%2==0)
        {
            data.clear();
            data.insert(0, QString("%1;%2;%3;%4;%5").arg(PRES).arg(NO).arg(TableGamer.size()).arg(TablePartGame.size()).arg(TOE));
            gamer->write(data);
            TablePartGame.insert(TOE, gamer);
            NameConUser << lst.at(1);
        }
        else
        {
            data.clear();
            data.insert(0, QString("%1;%2;%3;%4;%5").arg(PRES).arg(YES).arg(TableGamer.size()).arg(TablePartGame.size()).arg(TAC));
            gamer->write(data);
            TablePartGame.insert(TAC, gamer);
            TableGamer.insert(TableGamer.size(), TablePartGame);
            TablePartGame.clear();
            NameConUser << lst.at(1);
        }
    qDebug()<< "NameConUser.size() " << TablePartGame.size();
    qDebug() << "TableGamer.size() " << TableGamer.size();
    }
  qDebug("mesNAME run");
}
 
QString ClientConnect::findstatic(QString name)
{
    QFile statFile(qApp->applicationDirPath() + "/stat.txt");
    QString stat;
    QRegExp rx(name+";\\d+;\\d+;\\d+;\\d+;");
    rx.setMinimal(true);
 
    if(statFile.open(QIODevice::ReadOnly | QIODevice::Text))
    {
        QTextStream rw(&statFile);
        while( !rw.atEnd())
        {
             stat = rw.readLine();
             if(stat.indexOf(rx,0)>=0)
             {
                qDebug()<<"STAT FOUND!!!!!!!!";
                 break;
             }
             else
             {
                 stat="";
             }
        }
        return stat;
    }
    else
    {
       qDebug()<<"STAT NOT FOUND";
        return "";
    }
}
 
void ClientConnect::UserDisconnect()
{
    QStringList key = sender()->objectName().split(";");
    qDebug() << "SENDER OBJECTNAME = " << key.at(0) << " " <<key.at(1) << " " << key.at(2);
    qDebug()<<"USER DISCONNECT TABLE GAMER SIZE == " << TableGamer.size();
    //ищем кто отключился, сообщяем противнику что игрок
    //отключился, добавляем информацию в лог сервера...
    data.clear();
    data.insert(0, QString("%1;%2").arg(DOWN).arg(CLNT));
    tmpGamer = find_gamer(key.at(1).toInt(), key.at(2).toInt());
    if (!tmpGamer->objectName().isEmpty())
    {
        tmpGamer->write(data);
    }
    if(TableGamer.size()>0)
    {
        tmpTablPart = TableGamer.value(key.at(1).toInt());
       qDebug() << "TMP TABLE SIZE "<<tmpTablPart.size();
        tmpTablPart.remove(static_cast<states>(key.at(2).toInt()));
       qDebug() << "TMP TABLE SIZE 2 "<<tmpTablPart.size();
        if(tmpTablPart.size()>0)
        {
            TableGamer.insert(key.at(1).toInt(),tmpTablPart);
        }
        else
        {
            TableGamer.remove(key.at(1).toInt());
        }
       qDebug()<<"USER DISCONNECT TABLE GAMER SIZE > 0 == " << TableGamer.size();
    }
    else
    {
        TablePartGame.clear();
    }
    NameConUser.removeOne(key.at(0));
    emit user_down(key.at(0));
}
 
QTcpSocket * ClientConnect::find_gamer(int tabl, int part)
{
    QHash <int, QHash <states, QTcpSocket *> >::const_iterator table = TableGamer.constBegin();
    while(table!=TableGamer.constEnd())
    {
        if(tabl ==table.key())
        {
            qDebug()<<"GOOD TABLE";
            tmpTablPart = table.value();
            qDebug()<<"tmpTablePart SIZE = " << tmpTablPart.size();
            QHash <states, QTcpSocket *>::const_iterator tblPart = tmpTablPart.constBegin();
            while(tblPart!= tmpTablPart.constEnd())
            {
                if(part!=tblPart.key())
                {
                qDebug()<<"GOOD PART " << tblPart.key();
                   return tblPart.value();
                }
                tblPart++;
            }
        }
        table++;
    }
    return new QTcpSocket();
}

#ifndef LANGAME_H
#define LANGAME_H
 
#include <QObject>
#include <QApplication>
#include <QHostAddress>
#include <QTcpSocket>
#include <QDebug>
#include <QSettings>
#include <QMessageBox>
 
 
class LanGame : public QObject
{
    Q_OBJECT
private:
 
    enum states {TOE=0,//0 Нолики
                 TAC,  //1 Крестики
                 NO,   //2 Нет ожидающих игроков
                 YES,  //3 Есть игрок ожидающий соперника
                 NAME, //4 Значение говорящее клиенту отправить свое имя
                 PRES, //5 Значение говорящее клиенту представить всю инфу о себе
                 WINN, //6 Значение говорящее о результате игры
                 STEP, //7 Значение говорящее кто и куда походил
                 DOWN, //8 Кто-то отключился
                 CONN, //9 Соперник подключился
                 FULL, //10 Сервер переполнен
                 ERROR,//11 Ошибка...
                 NONE, //12 Ничья
                 CLNT, //13 Клиент
                 BAN,
                 SRV
 
                };
 
    QHostAddress host;
    int srv_port;
    QTcpSocket *gamer;
    QByteArray data;
    QSettings *Options;
    QString id_table; // id в общей таблице
    QString id_part; // id в таблице партии
    QHash <int, void(LanGame::*)(QStringList)> pointFunc;
 
 
    void createConnect();
    void writeHashPoint();
 
    void mesPRES(QStringList);
    void mesNAME();
    void mesCONN(QStringList);
    void mesSTEP(QStringList);
    void mesDOWN(QStringList);
    void mesERROR(QStringList);
 
public:
    explicit LanGame(QObject *parent = 0);
    LanGame(QObject *parent, QHostAddress type_addr, int port);
 
signals:
    void connect_to_srv();
    void gamer_disconnect();
    void connectError(QAbstractSocket::SocketError);
    void pres(QString);
    void client_step(QPointF); //получен ход противника  /////////////////////////////////////////////// не забыть отослать сигнал
    void type_game(int); //тип игры
    void lan_znak(int); //за кого играем по сети
    void con_down(QString);
    void apponent_connect(QStringList);
    void client_error(QString);
 
public slots:
    void user_disconnect();
    void sl_winner(QString);
    void sl_sen_messange(QString);
 
private slots:
    void gamerError(QAbstractSocket::SocketError);
    void getMessage();
 
};
 
#endif // LANGAME_H

#include "langame.h"
 
LanGame::LanGame(QObject *parent) : QObject(parent)
{
 
}
 
LanGame::LanGame(QObject *parent, QHostAddress type_addr, int port):QObject(parent), host(type_addr), srv_port(port)
{
    gamer = new QTcpSocket(this);
    createConnect();
    writeHashPoint();
    Options = new QSettings(qApp->applicationDirPath() + "/config/options.ini", QSettings::IniFormat);
    gamer->connectToHost(host, srv_port);
}
 
void LanGame::createConnect()
{
    connect(gamer, SIGNAL(connected()), this, SIGNAL(connect_to_srv()));
    connect(gamer, SIGNAL(disconnected()), this, SIGNAL(gamer_disconnect()));
    connect(gamer, SIGNAL(error(QAbstractSocket::SocketError)), this, SLOT(gamerError(QAbstractSocket::SocketError)));
    connect(gamer, SIGNAL(readyRead()), this, SLOT(getMessage()));
}
 
void LanGame::gamerError(QAbstractSocket::SocketError error)
{
    qDebug()<< gamer->errorString();
    gamer->close();
    emit connectError(error);
}
 
void LanGame::getMessage()
{
    if(gamer->bytesAvailable()>0)
    {
        qDebug()<<"GET MESSAGE ";
        QString str(gamer->readAll());
        QStringList lst = str.split(";");
        if(lst.at(0).toInt()==NAME)
        {
            qDebug() << "RUN FUNCTIONS!!!!" << lst.at(0);
            mesNAME();
        }
        else if (pointFunc.value(lst.at(0).toInt()))
        {
            qDebug() << "RUN FUNCTIONS!!!!" << lst.at(0);
            (this->*(this->pointFunc[lst.at(0).toInt()]))(lst);
        }
 
    }
 
}
 
void LanGame::writeHashPoint()
{
    pointFunc[PRES] = &LanGame::mesPRES;
    pointFunc[STEP] = &LanGame::mesSTEP;
    pointFunc[DOWN] = &LanGame::mesDOWN;
    pointFunc[CONN] = &LanGame::mesCONN;
    pointFunc[ERROR] = &LanGame::mesERROR;
}
 
void LanGame::mesERROR(QStringList lst)
{
    qDebug()<<"ERROR " << lst;
    emit client_error(lst.at(1));
    gamer->close();
}
 
void LanGame::mesCONN(QStringList lst)
{
    emit apponent_connect(lst);
}
 
void LanGame::mesDOWN(QStringList lst)
{
    emit con_down(lst.at(1));
    gamer->close();
}
 
void LanGame::mesSTEP(QStringList lst)
{
    qDebug()<<"Form SERVER get Message: " << lst;
    qDebug()<< "Координаты: " << lst.at(3).toInt() << lst.at(4).toInt();
    emit client_step(QPointF(lst.at(3).toInt(),lst.at(4).toInt()));
}
 
void LanGame::mesNAME()
{
    data.clear();
    data.insert(0, QString("%1;%2").arg(NAME).arg(Options->value("LanGame/Name","LanGamer_"+id_table).toString()));
    gamer->write(data);
}
 
void LanGame::mesPRES(QStringList lst)
{
    QString str_to_srv;
    qDebug()<<"Form SERVER get Message: " << lst;
    data.clear();
    id_table = lst.at(2);
    id_part = lst.at(3);
    qDebug()<<"IDClient: "<<id_table;
    emit lan_znak(lst.at(3).toInt());
    //ui->graphicsView->setEnabled(false);
    //Команда серверу
    data.insert(0,QString("%1;").arg(PRES));
    //наш ID_TABLE который выдал сервер
    data.insert(data.size(),QString("%1;").arg(id_table));
    //наш ID_Part который выдал сервер
    data.insert(data.size(),QString("%1;").arg(id_part));
    //наше имя
    data.insert(data.size(),Options->value("LanGame/Name","LanGamer_"+id_table).toString()+";");
    //За кого играем
    data.insert(data.size(),QString("%1;").arg(lst.at(4)));
    //передаем данные на сервер
    gamer->write(data);
    //чистим переменную на всякий случай :)
    data.clear();
    str_to_srv=QString("%1;%2;%3").arg(lst.at(1)).arg(id_table).arg(id_part);
    emit pres(str_to_srv);
}
 
void LanGame::user_disconnect()
{
    gamer->close();
}
 
void LanGame::sl_winner(QString str)
{
    data.clear();
    data.insert(0,str);
    gamer->write(data);
}
 
void LanGame::sl_sen_messange(QString str)
{
    data.clear();
    data.insert(0, str);
    gamer->write(data);
    data.clear();
}