HTTPConnection.h

Go to the documentation of this file.

#include "NativeFeatureIncludes.h"
#if _RAKNET_SUPPORT_HTTPConnection==1 && _RAKNET_SUPPORT_TCPInterface==1

#ifndef __HTTP_CONNECTION
#define __HTTP_CONNECTION

#include "Export.h"
#include "RakString.h"
#include "RakMemoryOverride.h"
#include "RakNetTypes.h"
#include "DS_Queue.h"

namespace RakNet
{
class TCPInterface;
struct SystemAddress;

class RAK_DLL_EXPORT HTTPConnection
{
public:
    // GetInstance() and DestroyInstance(instance*)
    STATIC_FACTORY_DECLARATIONS(HTTPConnection)

    
    HTTPConnection();
    virtual ~HTTPConnection();

    void Init(TCPInterface *_tcp, const char *host, unsigned short port=80);

    void Post(const char *path, const char *data, const char *_contentType="application/x-www-form-urlencoded");

    void Get(const char *path);
    
    bool HasRead(void) const;

    RakNet::RakString Read(void);

    void Update(void);

    SystemAddress GetServerAddress(void) const;

   void ProcessTCPPacket(Packet *packet);

    enum ResponseCodes { NoBody=1001, OK=200, Deleted=1002 };

    HTTPConnection& operator=(const HTTPConnection& rhs){(void) rhs; return *this;}
   
    struct BadResponse
    {
    public:
        BadResponse() {code=0;}
        
        BadResponse(const unsigned char *_data, int _code)
            : data((const char *)_data), code(_code) {}
        
        BadResponse(const char *_data, int _code)
            : data(_data), code(_code) {}

        operator int () const { return code; }

        RakNet::RakString data;
        int code;  // ResponseCodes
    };

    bool HasBadResponse(int *code, RakNet::RakString *data);

    bool IsBusy(void) const;

    int GetState(void) const;

    struct OutgoingCommand
    {
        RakNet::RakString remotePath;
        RakNet::RakString data;
        RakNet::RakString contentType;
        bool isPost;
    };

     DataStructures::Queue<OutgoingCommand> outgoingCommand;
     OutgoingCommand currentProcessingCommand;

private:
    SystemAddress server;
    TCPInterface *tcp;
    RakNet::RakString host;
    unsigned short port;
    DataStructures::Queue<BadResponse> badResponses;

    enum ConnectionState
    {
        CS_NONE,
        CS_DISCONNECTING,
        CS_CONNECTING,
        CS_CONNECTED,
        CS_PROCESSING,
    } connectionState;

    RakNet::RakString incomingData;
    DataStructures::Queue<RakNet::RakString> results;

    void CloseConnection();
    
    /*
    enum { RAK_HTTP_INITIAL,
        RAK_HTTP_STARTING,
        RAK_HTTP_CONNECTING,
        RAK_HTTP_ESTABLISHED,
        RAK_HTTP_REQUEST_SENT,
        RAK_HTTP_IDLE } state;

    RakNet::RakString outgoing, incoming, path, contentType;
    void Process(Packet *packet); // the workhorse
    
    // this helps check the various status lists in TCPInterface
    typedef SystemAddress (TCPInterface::*StatusCheckFunction)(void);
    bool InList(StatusCheckFunction func);
    */

};

} // namespace RakNet

#endif

#endif // _RAKNET_SUPPORT_*