NetServeurCom.cpp

Aller à la documentation de ce fichier.

//##############################################################################
//#                                                                            #
//# fichier : ServeurCom.cpp                            version : V1.0         #
//# projet  : GestionAsso                               date :  02/12/2004     #
//# par     : aerith                                                           #
//#                                                                            #
//# Methodes de la classe ServeurCom                                           #
//#                                                                            #
//##############################################################################

#include    "ServeurCom.h"
#include    "../src/portable/Tools.h"

ServeurCom::ServeurCom()
{
    Requette= 0;
    Table   = 0;
    Id      = 0;
    Data    = NULL;
    DataOut = NULL;
    Last    = 0;
    Running = 0;
}

ServeurCom::~ServeurCom()
{
    if(Running == 1)
        Stop();
}

int     ServeurCom::Start(char *NomFichier)
{
    BEGIN

    TRY if(Running == 0)
        Running = 1;
    ENDTRY(15)

    if(CERROR)
        Stop();

    ENDBEGIN
}

int     ServeurCom::Stop()
{
    BEGIN

    TRY if(Running == 1)
    {
        Running = 0;
        
        Requette= 0;
        Table   = 0;
        Id      = 0;
        delete [] Data;
        delete [] DataOut;
        Last    = 0;
    }
    ENDTRY(16)

    ENDBEGIN
}

int     ServeurCom::Parse(char *Buffer)
{
    BEGIN

    TRY if(Running == 1)
    {
        TRY if(isnumber(gettok(Buffer, 0, " \n")))
        {
            Requette = AtoD(gettok(Buffer, 0, " \n"));
            
            switch(Requette)
            {
                case    INSERT  :
                    Last = 0;
                    CERROR = Insert(Buffer);
                    break;
            
                case    DELET   :
                    Last = 0;
                    CERROR = Delet(Buffer);
                    break;
                    
                case    NBENTRY :
                    Last = 0;
                    CERROR = NbEntry(Buffer);
                    break;
                    
                case    SELECT  :
                    Last = 0;
                    CERROR = Select(Buffer);
                    break;

                case    OK      :
                    if(Last)
                        CERROR = Select(Buffer);
                    else
                        CERROR = 13;
                    break;
                    
                case    ERR_REFU:
                    if(Last)
                        Last = 0;
                    else
                        CERROR = 13;
                    break;
                    
                case    ERR_NB  :
                    if(Last)
                        Last = 0;
                    else
                        CERROR = 13;
                    break;

                default :
                    CERROR = 13;
                    break;
            }
        }
        ENDTRY(13)
            
        if(CERROR == 13)
        {
            delete [] DataOut;

            DataOut = new char[8];
            sprintf(DataOut, "%i", ERR_PROT);
            
            CERROR = 0;
        }

    }
    ENDTRY(16)

    ENDBEGIN
}

int     ServeurCom::Insert(char *Buffer)
{
    BEGIN

    TRY if(Running == 1)
    {
        CERROR = SetTable(Buffer);
        
        if(Table == 0)
        {
            delete [] DataOut;

            DataOut = new char[8];
            sprintf(DataOut, "%i", ERR_TABLE);
        }
        else
        {
            TRY CERROR = SetId(Buffer);

            TRY CERROR = SetData(Buffer);

            TRY CERROR = Base.GetTable(Table).GetEntry(Id).SetDatas(Data);

            TRY CERROR = Base.GetTable(Table).GetEntry(Id).GetDatas();

            TRY
            {
                delete [] DataOut;

                DataOut = new char[strlen(Base.GetData()) + 16];
                sprintf(DataOut, "%i %i %s", DATA, Table, Base.GetData());
            }
        }
    }
    ENDTRY(16)

    ENDBEGIN
}

int     ServeurCom::Delet(char *Buffer)
{
    BEGIN

    TRY if(Running == 1)
    {
        CERROR = SetTable(Buffer);

        if(Table == 0)
        {
            delete [] DataOut;

            DataOut = new char[8];
            sprintf(DataOut, "%i", ERR_TABLE);
        }
        else
        {
            TRY CERROR = SetId(Buffer);

            if(Id == 0)
            {
                delete [] DataOut;

                DataOut = new char[8];
                sprintf(DataOut, "%i", ERR_ID);
            }
            else
            {
                TRY CERROR = Base.Remove(Table, Id);

                TRY CERROR = Base.Read(Table);

                TRY
                {
                    delete [] DataOut;

                    DataOut = new char[32];
                    sprintf(DataOut, "%i %i %i", NBENTRY, Table, Base.GetNbData());
                }
            }
        }
    }
    ENDTRY(16)

    ENDBEGIN
}

int     ServeurCom::NbEntry(char *Buffer)
{
    BEGIN

    TRY if(Running == 1)
    {
        CERROR = SetTable(Buffer);

        if(Table == 0)
        {
            delete [] DataOut;

            DataOut = new char[8];
            sprintf(DataOut, "%i", ERR_TABLE);
        }
        else
        {
            TRY CERROR = Base.Read(Table);

            TRY
            {
                delete [] DataOut;

                DataOut = new char[32];
                sprintf(DataOut, "%i %i %i", NBENTRY, Table, Base.GetNbData());
            }
        }
    }
    ENDTRY(16)

    ENDBEGIN
}

int     ServeurCom::Select(char *Buffer)
{
    BEGIN

    TRY if(Running == 1)
    {
        CERROR = SetTable(Buffer);

        if(Table == 0)
        {
            delete [] DataOut;

            DataOut = new char[8];
            sprintf(DataOut, "%i", ERR_TABLE);
        }
        else
        {
            TRY CERROR = SetId(Buffer);

            TRY CERROR = Base.Read(Table);

            TRY
            {
                delete [] DataOut;

                if(Last == 0)
                {
                    DataOut = new char[32];
                    sprintf(DataOut, "%i %i %i", NBENTRY, Table, Base.GetNbData());
                
                    Last = 1;
                }
                else if(Last <= Base.GetNbData())
                {
                    DataOut = new char[strlen(Base.GetData(Last - 1)) + 16];
                    sprintf(DataOut, "%i %i %s", DATA, Table, Base.GetData(Last - 1));

                    Last++;
                }
                else TRY if(Last > Base.GetNbData())
                {
                    DataOut = new char[8];
                    sprintf(DataOut, "%i", OK);

                    Last = 0;
                }
                ENDTRY(13)
            }
        }
    }
    ENDTRY(16)

    ENDBEGIN
}

int     ServeurCom::SetTable(char *Buffer)
{
    BEGIN

    TRY if(Running == 1)
    {
        Table = 0;

        TRY if(isnumber(gettok2(Buffer, 1, " \n")))
            Table = AtoD(gettok2(Buffer, 1, " \n"));
        ENDTRY(13)
    }
    ENDTRY(16)

    ENDBEGIN
}

int     ServeurCom::SetId(char *Buffer)
{
    BEGIN

    TRY if(Running == 1)
    {
        Id = 0;

        if(isnumber(gettok2(Buffer, 2, " \n")))
            Id = AtoD(gettok2(Buffer, 2, " \n"));
    }
    ENDTRY(16)

    ENDBEGIN
}

int     ServeurCom::SetData(char *Buffer)
{
    BEGIN

    TRY if(Running == 1)
    {
        TRY if(gettok2(Buffer, 1, ":\n"))
        {
            delete [] Data;

            Data = new char[strlen(gettok2(Buffer, 1, ":\n"))];
            strcpy(Data, gettok2(Buffer, 1, ":\n"));
        }
        ENDTRY(13)
    }
    ENDTRY(16)

    ENDBEGIN
}

---