Connessione.cpp

Go to the documentation of this file.

#include "Connessione.h"
#include "ChannelGui.h"
#include "QueryGui.h"
#include "StatusGui.h"
#include "ClientGui.h"
#include "wxStringIRC.h"

// Event Table - Inizio
BEGIN_EVENT_TABLE(Connessione, wxEvtHandler)
    EVT_SOCKET(SOCKET_ID, Connessione::OnSocketEvent)
END_EVENT_TABLE()
// Event Table - Fine

Connessione::Connessione(wxString addr, int port, int timeout, bool rfcCompliant)
:serverAddr(addr), serverPort(port), serverTimeout(timeout), rfc_compliant(rfcCompliant){
    serverSocket = new wxSocketClient();  // Crea un nuovo Socket
    serverSocket->SetEventHandler(*this, SOCKET_ID);  // Imposta l'event handler
    serverSocket->SetNotify(wxSOCKET_INPUT_FLAG);  // Imposta gli eventi che devono
                                                   // essere catturati
    CreateStatus(_("~Status"));  // Crea una finestra di Status
    status = static_cast<StatusGui*>(GetTerminal(_("~Status")));
    wxString title = _("Status");
    title.Append(_(": ")).Append(addr);
    status->SetTitle(title);
    parserIn = new ParserIn(this);  // Crea il ParserIn
    parserOut = new ParserOut(this); // Crea il ParserIn
}

Connessione::~Connessione(){
    Disconnect();  // Chiude la connessione corrente
    serverSocket->Notify(FALSE);  // Disabilita la notifica degli eventi
    serverSocket->Discard();  // Elimina gli eventi nel buffer
    serverSocket->Destroy();  // Elimina il Socket
    wxTerminalsMap::iterator it;
    for(it = terminalsMap.begin(); it != terminalsMap.end(); ++it)
        it->second->Destroy();  // Elimina tutti i terminali associati alla connessione
    delete parserIn;  // Cancella il ParserIn
    delete parserOut;  // Cancella il ParserOut
}

bool Connessione::Connect(){
    wxIPV4address ipAddr;
    ipAddr.Hostname(serverAddr);
    ipAddr.Service(serverPort);
    serverSocket->Notify(TRUE);  // Imposta la notifica degli eventi
    serverSocket->SetTimeout(serverTimeout);  // Imposta il timeout
    serverSocket->Connect(ipAddr, TRUE);  // Tenta di connettersi
    if (!serverSocket->IsConnected())
    {
        serverSocket->Close();
        wxMessageBox(_("Impossibile connettersi all'host specificato!"), _("Errore!"));
        return false;
    }
    else{
        status->receiveMsg(_("Connessione effettuata! Attendere prego...\n"));
        status->receiveMsg(_("La connessione ad alcuni server può richiedere piu' di un minuto!\n"));
        return true;
    }
}

bool Connessione::Disconnect(){
    serverSocket->Close();  // Chiude la connessione
    if(serverSocket->IsDisconnected())
        return true;
    else
        return false;
}

bool Connessione::sendCommand(wxString command){
    wxChar* buf;
    size_t len;
    len  = (wxStrlen(command) + 1) * sizeof(wxChar);
    buf = new wxChar[wxStrlen(command) + 1];
    wxStrcpy(buf, command);
    serverSocket->Write(buf, len);  // Scrive sul socket il buffer
    serverSocket->Write(_("\n"), 1);  // Aggiunge il ritorno a capo al termine
                                      // del comando
    delete buf;  // Elimina il buffer
    
    if(!serverSocket->Error()){
        return true;
    }
    else {
        return false;
    }        
}

void Connessione::readSocket(){
    wxChar c;
    serverSocket->Read(&c, sizeof(wxChar));
    cmdBuffer << c;
    if(c == 0x0A){  // Attende un LF
        wxString buf = cmdBuffer;  // Inserisce in un buffer tampone
        cmdBuffer.clear();  // Ripulisce il buffer di ricezione
        buf = buf.Mid(0, (buf.Len() - 2));  // Elimina i caratteri speciali
        parserIn->getMessage(buf);
    }  
}

void Connessione::OnSocketEvent(wxSocketEvent& event)
{
  switch(event.GetSocketEvent())
  {
    case wxSOCKET_INPUT      : readSocket(); break;
    default                  : break;
  }
}

void Connessione::CreateChannel(wxString nome)
{
    wxString title = nome;
    if(rfc_compliant){  // Gestione dei caratteri speciali secondo l'RFC2812
        wxStringIRC nome_lower = nome;
        nome = nome_lower.Lower();
    }    
    else
        nome.MakeLower();  // Rende il nome del terminale lower case
    if(terminalsMap.count(nome)){  // Cerca il terminale nella hash map
        wxMessageBox(_("Gia' esiste un Terminale con questo nome!"), _("Errore!"));
        exit(1);
    }
    ClientGui* client = ClientGui::Instance(NULL);  // Ottiene il riferimento
                                                    // all'istanza di ClientGui
    terminalsMap[nome] = new ChannelGui(this, client);  // Crea un nuovo ChannelGui
    terminalsMap[nome]->SetName(nome);  // Imposta il nome della finestra
    terminalsMap[nome]->SetTitle(title);  // Imposta il titolo
    terminalsMap[nome]->Show(TRUE);  // Mostra il frame
}

void Connessione::CreateQuery(wxString nome)
{
    wxString title = nome;
    if(rfc_compliant){
        wxStringIRC nome_lower = nome;
        nome = nome_lower.Lower();
    }    
    else
        nome.MakeLower();  // Rende il nome del terminale lower case
    if(terminalsMap.count(nome)){
        wxMessageBox(_("Gia' esiste un Terminale con questo nome!"), _("Errore!"));
        exit(1);
    }
    ClientGui* client = ClientGui::Instance(NULL);
    terminalsMap[nome] = new QueryGui(this, client);
    terminalsMap[nome]->SetName(nome);
    terminalsMap[nome]->SetTitle(title);
    terminalsMap[nome]->Show(TRUE);
}

void Connessione::CreateStatus(wxString nome)
{
    wxString title = nome;
    if(rfc_compliant){
        wxStringIRC nome_lower = nome;
        nome = nome_lower.Lower();
    }    
    else
        nome.MakeLower();  // Rende il nome del terminale lower case
    if(terminalsMap.count(nome)){
        wxMessageBox(_("Gia' esiste un Terminale con questo nome!"), _("Errore!"));
        exit(1);
    }
    ClientGui* client = ClientGui::Instance(NULL);
    terminalsMap[nome] = new StatusGui(this, client);
    terminalsMap[nome]->SetName(nome);
    terminalsMap[nome]->SetTitle(title);
    terminalsMap[nome]->Show(TRUE);
}

bool Connessione::TerminalExists(wxString nome)
{
    if(rfc_compliant){
        wxStringIRC nome_lower = nome;
        nome = nome_lower.Lower();
    }    
    else
        nome.MakeLower();  // Rende il nome del terminale lower case
    return terminalsMap.count(nome);  // Ritorna true se trova il terminale
                                      // nella hash map
}

void Connessione::DeleteTerminal(wxString nome)
{
    if(rfc_compliant){
        wxStringIRC nome_lower = nome;
        nome = nome_lower.Lower();
    }    
    else
        nome.MakeLower();  // Rende il nome del terminale lower case
    if(!terminalsMap.count(nome)){  // Se il terminale non esiste mostra un errore
        wxMessageBox(_(nome), _("Errore!"));
        exit(1);
    }
    terminalsMap[nome]->Destroy();  // Involca la distruzione del terminale
    terminalsMap.erase(nome);  // Elimina il contenuto della mappa
    
    #ifdef TESTING
    if(terminalsMap.empty())
        wxMessageBox(_("Non ci sono più Terminali!"), _("Informazione!"));
    #endif
}

TerminalGui* Connessione::GetTerminal(wxString nome)
{
    if(rfc_compliant){
        wxStringIRC nome_lower = nome;
        nome = nome_lower.Lower();
    }    
    else
        nome.MakeLower();  // Rende il nome del terminale lower case
    if(terminalsMap[nome] == NULL){  // Se il terminale non esiste mostra un errore
        wxString msg = _("Il Terminale a cui cerchi di accedere non esiste! Nome: ");
        msg.Append(nome);
        wxMessageBox(msg, _("Errore!"));
        exit(1);
    }
    
    return terminalsMap[nome];  // Ritorna un riferimento al terminale richiesto
}

ParserOut* Connessione::getParserOut(){
    return parserOut;  // Ritorna un riferimento al ParserOut
}

wxString Connessione::GetMyNick()
{
    return parserIn->mynick;  // Ritorna il nick letto dal ParserIn al momento
                              // della connessione
}

StatusGui* Connessione::GetStatus()
{
    return status;  // Ritorna il riferimento alla StatusGui
}

void Connessione::UserQuit(wxString name, wxString msg)
{
    wxTerminalsMap::iterator it;
    // Viene usato un iteratore per scorrere la mappa di terminali
    for(it = terminalsMap.begin(); it != terminalsMap.end(); ++it){
       if(it->first.StartsWith(_("#")) || it->first.StartsWith(_("+")) ||
          it->first.StartsWith(_("&")) || it->first.StartsWith(_("!"))){
           ChannelGui* canale = static_cast<ChannelGui*>(GetTerminal(it->first));
           // Viene notificato al canale il QUIT dell'utente
           canale->receiveMsg(name+" è uscito dal server: "+msg, STYLE_BLUE);
           // Viene rimosso il nickname
           canale->removeUser(name);
       }   
    }   
}

void Connessione::UserChNick(wxString oldname, wxString newname)
{
    wxTerminalsMap::iterator it;
    // Viene usato un iteratore per scorrere la mappa di terminali
    for(it = terminalsMap.begin(); it != terminalsMap.end(); ++it){
       if(it->first.StartsWith(_("#")) || it->first.StartsWith(_("+")) ||
          it->first.StartsWith(_("&")) || it->first.StartsWith(_("!"))){
           ChannelGui* canale = static_cast<ChannelGui*>(GetTerminal(it->first));
           // Viene effettuato il cambio del nickname se il nick è presente nel canale
           if(canale->changeNick(oldname, newname))
           // Viene notificato al canale il cambio di nick
           canale->receiveMsg(oldname+" ha cambiato nick in "+newname+"\n", STYLE_BLUE);
       }   
    }   
}

---