NetHTTPProtocol.cpp

Go to the documentation of this file.

/***************************** License **********************************

 Copyright (C) 2008 by Communicative Machines
 http://www.cmlabs.com   All rights reserved.

 This library is free software; you can redistribute it and/or
 modify it under the terms of the GNU Lesser General Public
 License as published by the Free Software Foundation; either
 version 2.1 of the License, or (at your option) any later version.

 This library 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
 Lesser General Public License for more details.

 You should have received a copy of the GNU Lesser General Public
 License along with this library; if not, write to the Free Software
 Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA

************************************************************************/
// NetHTTPProtocol.cpp: implementation of the NetHTTPProtocol class.
//
//////////////////////////////////////////////////////////////////////

#include "NetHTTPProtocol.h"

namespace cmlabs {

//////////////////////////////////////////////////////////////////////
// Construction/Destruction
//////////////////////////////////////////////////////////////////////

NetHTTPProtocol::NetHTTPProtocol():NetProtocol("HTTP")
{
        netTimeout = 60000;
        recHTTP = NULL;
}

NetHTTPProtocol::~NetHTTPProtocol()
{
        if (recHTTP != NULL)
                delete(recHTTP);
}

Object* NetHTTPProtocol::clone() const {
        return new NetHTTPProtocol();
}

bool NetHTTPProtocol::checkBufferForCompatibility(char* buffer, int length) {

        if (length < 1) return false;

        JString str = buffer;

        if ( (str.startsWith("GET ")) || (str.startsWith("PUT ")) || (str.startsWith("POST "))) {
                return true;
        }

        return false;
}

bool NetHTTPProtocol::initializeConversation(JSocket* socket) {
        if (socket == NULL)
                return false;
        return true;
}

bool NetHTTPProtocol::sendObject(JSocket* socket, Message* msg, bool isReply) {
        if (socket == NULL)
                return false;

        HTMLPage* page = (HTMLPage*) msg->getObject();
        if (page == NULL) {
//              printf("HTTP response NULL\n");
                page = new HTMLPage();
                page->title = "Web Interface Error";
                page->body = "No information found...";
        }
        if (page->generateHTML()) {
//              printf("HTML:\n'%s'\nEND\n\n", page->data);
//              JFile::writeAFileASCII("t:\\psy.out", page->data, page->datalength);
//              JFile::writeAFileBinary("t:\\psybin.out", page->data, page->datalength);
//              printf("\nHTML\n");
//              for (int n=0; n<page->datalength; n++) {
//                      printf("[%d]%c\n", (int) page->data[n], page->data[n]);
//              }
//              printf("\nEND\n");
                socket->write(page->data, page->datalength);
                if (!page->keep_alive) {
                        // wait(50);
                        socket->waitForWriteability(1000);
                        socket->disconnectNow();
                        // printf("*** Closing HTTP connection ***\n");
                }
                else {
                        // printf("*** Keeping HTTP connection alive ***\n");
                }
        }
        else {
                socket->writeln(page->printErrorHTML());
        }
//      JString str = page->toHTML();
//      printf("HTTP response string %d long...\n", str.length());
//      printf("Outputting HTML response: length %d\n", str.length());
//      if (msg.object != NULL) {
//              delete(msg.object);
//              msg.object = NULL;
//      }
//      if (socket->writeln(str) < 0) {
//              return false;
//      }
        // wait(50);
        // socket->disconnectNow();
//      delete(msg);
        return true;
}

Message* NetHTTPProtocol::receiveObject(JSocket* socket, int timeout) {

        if (recHTTP == NULL)
                recHTTP = new HTTPRequest();

        JTime start;
        // JTime now;
        JString str;
        Message* inMsg = NULL;

        JTime t1, t2;
        int t = start.getAge();
        while ( (!recHTTP->isComplete(socket)) && (t < timeout) ) {
                // socket->waitForReadability(t);
                str = socket->readln(10);
                if (str.isCRTerminated)
                        recHTTP->addEntry(str);
                // now = JTime();
                t = start.getAge();
        }

        if (recHTTP->isComplete(socket)) {
                if (DEBUGLEVEL(KITCHENSINK)) {
                        printf("[NetHTTP] HTTP request complete, generating response...\n");
                }
                inMsg = new Message(socket->getRemoteHostname(), "", "HTTP");
                inMsg->setObject(recHTTP);
                recHTTP = NULL;

                JString hostname = socket->getRemoteIPAddress();
                if (hostname.equals("localhost"))
                        hostname = socket->getLocalIPAddress();
                inMsg->setOrigin(hostname);
                inMsg->set("netprotocol", name);
        }

        return inMsg;
}



} // namespace cmlabs

---