TraitementComServeurJeu.cpp

Go to the documentation of this file.

/***************************************************************************
 *   Copyright (C) 2007 by Pierre Schmitt, Ludovic Giacomello, Nhi Ly      *
 *                                                                         *
 *                                                                         *
 *   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 2 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, write to the                         *
 *   Free Software Foundation, Inc.,                                       *
 *   59 Temple Place - Suite 330, Boston, MA  02111-1307, USA.             *
 ***************************************************************************/

#include "TraitementComServeurJeu.h"

TraitementComServeurJeu::TraitementComServeurJeu(unsigned int port){
        mPort=port;
        mPartie=Partie::GetInstance();
        mBdD=BdD::GetInstance();
        mSJReady=false;
        cout<<endl<<"  SP TraitementComServeurJeu::Création d'un thread pour la communication avec un serveur de jeu sur le port "<<port<<endl;
        try{
                mSocket=new SocketUDP((unsigned int)port);
        } catch(SocketException s){ s.Afficher(); }
}

TraitementComServeurJeu::~TraitementComServeurJeu(){
        if(mSocket!=NULL) delete mSocket;
        
}
void* TraitementComServeurJeu::Traitement(){
        while(1){
                string cmd=mSocket->Ecouter();
                //On passe la chaine à toutes les méthodes en vue d'un éventuel traitement 
                TraiterHello(cmd);
                TraiterAttenteJoueur(cmd);      
                TraiterConnexionJoueur(cmd);
                TraiterServeurJeuPret(cmd);
                TraiterReceptionStatus(cmd);
                TraiterFinPartie(cmd);
                //Si aucune commande appropriée a été reçue on la renvoie
                mSocket->Envoyer(cmd);
        }
        return NULL;
}

void TraitementComServeurJeu::TraiterHello(string cmd){
        if(cmd=="HELLO"){
                cout<<"  SP TraitementComServeurJeu::Le serveur de jeu a initialisé le protocole de communication UDP"<<endl;
                mSocket->Envoyer(cmd);
                //On ajoute la partie 
                mPartie->AjouterPartie(mPort);
                mSJReady=true;
        }
}

void TraitementComServeurJeu::TraiterServeurJeuPret(string cmd){
        if(cmd=="READY"){
                cout<<"  SP TraitementComServeurJeu::Le serveur de jeu nous indique que la partie commence"<<endl;
                mSocket->Envoyer(cmd);
        }
}

void TraitementComServeurJeu::TraiterAttenteJoueur(string cmd){
        istringstream iss(cmd);
        string arg1, arg2;
        getline(iss,arg1,' '); 
        if(arg1=="WAITING"){
                getline(iss,arg2,' '); 
                cout<<" SP TraitementComServeurJeu::Le serveur de jeu attend la connexion de tous les joueurs ("<<arg2<<" fantomes automatiques)"<<endl;
                istringstream iss(arg2);
                unsigned int nbFantome;
                iss>>nbFantome;
                mPartie->SetNbFantomeAuto(mPort,nbFantome);
                mSocket->Envoyer(cmd);
        }
}

void TraitementComServeurJeu::TraiterConnexionJoueur(string cmd){
        istringstream iss(cmd);
        string arg1, arg2, arg3, arg4;
        getline(iss,arg1,' '); 
        if(arg1=="SET"){
                getline(iss,arg2,' '); 
                if(arg2=="PACMAN"){
                        getline(iss,arg3,' ');
                        cout<<"  SP TraitementComServeurJeu::Le serveur de jeu nous indique que pacman ("<<arg3<<") vient de se connecter"<<endl;
                        mPartie->SetLoginPacman(mPort,arg3);
                        mPartie->SetScorePacman(mPort,0);
                }
                if(arg2=="F"){
                        getline(iss,arg3,' '); 
                        getline(iss,arg4,' '); 
                        cout<<"  SP TraitementComServeurJeu::Le serveur de jeu nous indique qu'un fantome ("<<arg3<<") vient de se connecter"<<endl;
                        istringstream iss(arg4);
                        unsigned int noFantome;
                        iss>>noFantome;
                        mPartie->SetLoginF(mPort,noFantome,arg3);
                        mPartie->SetScoreF(mPort,noFantome,0);
                }
        }
}

void TraitementComServeurJeu::TraiterReceptionStatus(string cmd){
        istringstream iss(cmd);
        string arg1;
        getline(iss,arg1,' '); 
        if(arg1=="STATUS"){
                string loginP, scoreP, loginF1, scoreF1, loginF2, scoreF2, loginF3, scoreF3, nbPomme, status;
                getline(iss,loginP,' '); getline(iss,scoreP,' '); getline(iss,loginF1,' '); getline(iss,scoreF1,' '); 
                getline(iss,loginF2,' '); getline(iss,scoreF2,' '); getline(iss,loginF3,' '); getline(iss,scoreF3,' '); 
                getline(iss,nbPomme,' '); getline(iss,status,' '); 
                unsigned int sP, sF1, sF2, sF3;
                istringstream iss1(scoreP), iss2(scoreF1), iss3(scoreF2), iss4(scoreF3);
                iss1>>sP; iss2>>sF1; iss3>>sF2; iss4>>sF3;
                if(loginP!="hotplug") mPartie->SetScorePacman(mPort,sP); 
                if(loginF1!="hotplug") mPartie->SetScoreF(mPort,0,sF1); 
                if(loginF2!="hotplug")mPartie->SetScoreF(mPort,1,sF2); 
                if(loginF3!="hotplug") mPartie->SetScoreF(mPort,2,sF3);
                mSocket->Envoyer(cmd);
        }
}

void TraitementComServeurJeu::TraiterFinPartie(string cmd){
        if(cmd=="GAME OVER"){
                cout<<" SP TraitementComServeurJeu::Le serveur de jeu nous indique que la partie est terminée"<<endl;
                //On met a jour les scores 
                string loginP=mPartie->GetLoginPacman(mPort);
                if(loginP!="hotplug"){
                unsigned int scoreP=mBdD->GetScore(loginP);
                scoreP+=mPartie->GetScorePacman(mPort);
                mBdD->SetScore(loginP,scoreP);
                }
                string loginF1=mPartie->GetLoginF(mPort,0);
                if((loginF1!="auto")&&(loginF1!="hotplug")){
                        unsigned int scoreF1=mBdD->GetScore(loginF1);
                        scoreF1+=mPartie->GetScoreF(mPort,0);
                        mBdD->SetScore(loginF1,scoreF1);                
                }
                string loginF2=mPartie->GetLoginF(mPort,1);
                if((loginF2!="auto")&&(loginF2!="hotplug")){
                        unsigned int scoreF2=mBdD->GetScore(loginF2);
                        scoreF2+=mPartie->GetScoreF(mPort,1);
                        mBdD->SetScore(loginF2,scoreF2);                
                }
                string loginF3=mPartie->GetLoginF(mPort,2);
                if((loginF3!="auto")&&(loginF3!="hotplug")){
                        unsigned int scoreF3=mBdD->GetScore(loginF3);
                        scoreF3+=mPartie->GetScoreF(mPort,2);
                        mBdD->SetScore(loginF3,scoreF3);                
                }
                //On sauvegarde 
                mBdD->Sauvegarder();
                //On supprime la partie 
                mPartie->SupprimerPartie(mPort);
        }
}

---