Diff: webservice.cpp

Revision:

0:5e8527b638e1

Child:

1:62e112d14c8f

--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/webservice.cpp	Tue Jan 11 23:00:09 2011 +0000
@@ -0,0 +1,200 @@
+#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;
+}
\ No newline at end of file