/home/toby/moos-ivp/MOOS-2375-Oct0611/Core/MOOSDB/HTTPConnection.h

Go to the documentation of this file.

#ifndef CHTTPCONNECTIONH

#include <MOOSUtilityLib/MOOSThread.h>
#include <map>

//forward decalarations
class XPCTcpSocket;
class CMOOSCommClient;
class CMOOSLock;





class CHTTPConnection
{
public:

    /**************************************************************/
    struct HTTPRequest
    {
        //type of request
        enum eRequest
        {
            GET,
            POST
        };
        eRequest m_eRequest;

        typedef std::map<std::string,std::list<std::string> > HEADERMAP;

        void AddHeader(std::string sLine)
        {
            MOOSRemoveChars(sLine," ");
            std::string sHeader = MOOSChomp(sLine,":");
            std::list<std::string> Values;

            while(!sLine.empty())
            {
                Values.push_back(MOOSChomp(sLine,","));
            }
            MOOSToUpper(sHeader);
            m_Headers[sHeader] = Values;

        }

        bool IsKeepAlive()
        {
            if(HasProperty("CONNECTION","keep-alive"))
                return true;
            if(HasProperty("CONNECTION","close"))
                return false;

            //default is true
            return true;
        }

        bool  GetKeepAliveTime(double & dfTimeOut)
        {
            std::list<std::string> Values;

            if(!GetHeader("Keep-Alive",Values))
                return false;

            if(Values.empty())
                return false;

            dfTimeOut =  atof(Values.begin()->c_str());

            return true;
        }

        bool HasProperty(std::string sHeader, std::string sProp)
        {
            std::list<std::string> Values;

            if(!GetHeader(sHeader,Values))
                return false;

            std::list<std::string>::iterator q;
            for(q = Values.begin();q!=Values.end();q++)
            {
                if(MOOSStrCmp(*q,sProp))
                    return true;
            }
            return false;

        }

        bool GetHeader(std::string sHeader, std::list<std::string> & Values)
        {
            MOOSToUpper(sHeader);
            if(m_Headers.find(sHeader)==m_Headers.end())
                return false;

            Values = m_Headers[sHeader];

            return true;

        }
        void Clean()
        {
            m_Headers.clear();
        }

        HEADERMAP m_Headers;
    };
    /************ END OF HTTPRequest definition ******************/



    CHTTPConnection(XPCTcpSocket* pNewSocket,CMOOSCommClient* pMOOSComms,CMOOSLock* pMOOSCommsLock);

    bool Run();

    bool HasCompleted();

    static bool _CB(void* pParam)
    {
        CHTTPConnection* pMe = (CHTTPConnection*) pParam;
        return pMe->Serve();
    }


protected:
    bool Serve();
    bool MakeWebPage();
    bool SendHeader();
    bool SendFailureHeader();
    bool SendWebPage();
    bool HandlePoke(std::string sPokeURL);
    /* build webpage of single variable */
    bool BuildSingleVariableWebPageContents( std::ostringstream & wp,MOOSMSG_LIST & MsgList);
    bool BuildFullDBWebPageContents( std::ostringstream & wp,MOOSMSG_LIST & MsgList);
    bool ReadRequest();

    bool ReadLine(std::string &);
    void SendLine(std::string sLine);
    void SendString(std::string sLine);
    
    
    std::string m_sWebPage;
    CMOOSThread m_ServeThread; 
    XPCTcpSocket* m_pSocket;
    
    std::string m_sFocusVariable;

    HTTPRequest m_Request;

    CMOOSCommClient * m_pMOOSComms;

    CMOOSLock * m_pMOOSCommsLock;

};
#endif