File content as of revision 0:5e8527b638e1:

#include "Timer.h"

#include "webservice.h"

#include "spxmlnode.hpp"
#include "spxmlhandle.hpp"

#include "dnsresolve.h"

void WebService::onTCPSocketEvent(TCPSocketEvent e) {
//    printf("New TCPSocketEvent: %d\n",e);
    switch (e) {
        case TCPSOCKET_CONNECTED:
            _connected = true;
            _connecting=false;
            break;

        case TCPSOCKET_READABLE:
            break;
        case TCPSOCKET_WRITEABLE:
            break;

        case TCPSOCKET_CONTIMEOUT:
        case TCPSOCKET_CONRST:
        case TCPSOCKET_CONABRT:
        case TCPSOCKET_ERROR:
        case TCPSOCKET_DISCONNECTED: {
            // don't close the real socket here, as this may skip the already received data
            _connected = false;
            _connecting=false;
        }
        break;
    }
}

WebService::WebService(const char* url):_url(url) {
    _closed=false;
    _readpos=0;
    _readlen=0;
    _readpos=0;
    _readlen=0;

    _socket.setOnEvent(this,&WebService::onTCPSocketEvent);
}

SP_XmlDomParser* WebService::callService() {
    Url url;
    url.fromString(_url);

    string request=string("GET ").append(_url).append(" HTTP/1.0\r\n\r\n");

    IpAddr addr;
    if (!url.getHostIp(&addr)) {
        DNSResolver dr;
        addr=dr.resolveName(url.getHost().c_str());
    }
//    printf("host ip=%i.%i.%i.%i\n",addr[0],addr[1],addr[2],addr[3]);

    int port=0==url.getPort()?80:url.getPort();

    Host host(addr, port);

    TCPSocketErr bindErr = _socket.connect(host);

    if (bindErr != 0) {
        printf("connection error %i\n", bindErr);
        return false;
    }

    // wait for connection established
    _connecting=true;
    mbed::Timer tmr;
    tmr.start();

    while (_connecting) {
        Net::poll();
        wait(0.1);
        if (tmr.read()>10) {
            printf("reached timeout\n");
            break;
        }
    }

    if (!_connected) {
        printf("error - could not connect (timeout)\n");
        return NULL;
    }
//    printf("send request[%s]\n",request.c_str());
    _socket.send(request.c_str(),request.length());
    Net::poll();

    if (!_connected)
        return NULL;

    string firstLine=readResponseLine();
    // todo: parse for HTTP response
    // response must be for HTTP/1.0, and be 200
    if (0!=firstLine.compare("HTTP/1.0 200 OK"))
    {
        printf("call not sucessfull, response=%s\n",firstLine.c_str());
        return NULL;
    }    
    // skip headers    
    while (true) {
        string line=readResponseLine();
//        printf("header=[%s]\n",line.c_str());
        if (0==line.length())
            break;
    }
    SP_XmlDomParser *parser=new SP_XmlDomParser();
    while (true) {
        string line=readResponseLine();
//        printf("content=[%s]\n",line.c_str());
        parser->append(line.c_str(),line.length());
        if (0==line.length())
            break;
    }

    return parser;
}

void WebService::close() {
    if (_closed)
        return;

    while (_connected) {
        Net::poll();
        // read remaining data
        int err=_socket.recv(_readbuf,BUFSIZE-1);
        if (err<=0)
            break;
    }

    while (true) {
        Net::poll();
        // read remaining data
        int err=_socket.recv(_readbuf,BUFSIZE-1);
        if (err<=0)
            break;
    }

    _socket.resetOnEvent();
    _socket.close();

    _closed=true;
}



string WebService::readResponseLine() {
    string r;
    bool got_r=false;
    
    int emptyCount=0;
    while (true) {
        Net::poll();
        if (_readlen>_readpos) {
            while (_readbuf[_readpos]!=0 && _readpos<_readlen) {
                char c=_readbuf[_readpos++];
                if (!got_r) {
                    if (c=='\r') {
                        got_r=true;
                    } else {
                        r.push_back(c);
                    }
                } else {
                    if (c=='\n') {
                        return r;
                    } else {
                        r.push_back('\r'); // push missed \r also, so push it to string
                        r.push_back(c);
                        got_r=false;
                    }
                }
            }
        } else {
            int err=_socket.recv(_readbuf,BUFSIZE-1);
            if (err < 0) {
                printf("error while receiving data: %i!\n",err);
                break;
            } else if (err>0) {
                emptyCount=0;
                _readbuf[err]=0;
                _readlen=err;
                _readpos=0;
//                printf("r=%s\n",_readbuf);
            }
            else
            {
                // when we don't receive any data, and are not connected
                // we stop because there isn't anything left
                if (emptyCount++>2)
                    if (!_connected)
                        break;
            }
        }
        wait(0.1);
    }
    return r;
}