Michael Spencer / Mbed 2 deprecated LaOS

Important changes to repositories hosted on mbed.com

Mbed hosted mercurial repositories are deprecated and are due to be permanently deleted in July 2026.

To keep a copy of this software download the repository Zip archive or clone locally using Mercurial.

It is also possible to export all your personal repositories from the account settings page.

Dependencies:   mbed

NetServices/services/http/client/HTTPClient.cpp@1:f5ac63519541, 2014-03-05 (annotated)

Committer:
Michael J. Spencer
Date:
Wed Mar 05 06:14:02 2014 -0800
Revision:
1:f5ac63519541
Initial commit.

Who changed what in which revision?

UserRevisionLine numberNew contents of line
Michael J. Spencer 1:f5ac63519541 1
Michael J. Spencer 1:f5ac63519541 2 /*
Michael J. Spencer 1:f5ac63519541 3 Copyright (c) 2010 Donatien Garnier (donatiengar [at] gmail [dot] com)
Michael J. Spencer 1:f5ac63519541 4
Michael J. Spencer 1:f5ac63519541 5 Permission is hereby granted, free of charge, to any person obtaining a copy
Michael J. Spencer 1:f5ac63519541 6 of this software and associated documentation files (the "Software"), to deal
Michael J. Spencer 1:f5ac63519541 7 in the Software without restriction, including without limitation the rights
Michael J. Spencer 1:f5ac63519541 8 to use, copy, modify, merge, publish, distribute, sublicense, and/or sell
Michael J. Spencer 1:f5ac63519541 9 copies of the Software, and to permit persons to whom the Software is
Michael J. Spencer 1:f5ac63519541 10 furnished to do so, subject to the following conditions:
Michael J. Spencer 1:f5ac63519541 11
Michael J. Spencer 1:f5ac63519541 12 The above copyright notice and this permission notice shall be included in
Michael J. Spencer 1:f5ac63519541 13 all copies or substantial portions of the Software.
Michael J. Spencer 1:f5ac63519541 14
Michael J. Spencer 1:f5ac63519541 15 THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
Michael J. Spencer 1:f5ac63519541 16 IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
Michael J. Spencer 1:f5ac63519541 17 FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
Michael J. Spencer 1:f5ac63519541 18 AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
Michael J. Spencer 1:f5ac63519541 19 LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
Michael J. Spencer 1:f5ac63519541 20 OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN
Michael J. Spencer 1:f5ac63519541 21 THE SOFTWARE.
Michael J. Spencer 1:f5ac63519541 22 */
Michael J. Spencer 1:f5ac63519541 23
Michael J. Spencer 1:f5ac63519541 24 #include "core/netservice.h"
Michael J. Spencer 1:f5ac63519541 25 #include "HTTPClient.h"
Michael J. Spencer 1:f5ac63519541 26 #include "../util/base64.h"
Michael J. Spencer 1:f5ac63519541 27 #include "../util/url.h"
Michael J. Spencer 1:f5ac63519541 28
Michael J. Spencer 1:f5ac63519541 29 //#define __DEBUG
Michael J. Spencer 1:f5ac63519541 30 #include "dbg/dbg.h"
Michael J. Spencer 1:f5ac63519541 31
Michael J. Spencer 1:f5ac63519541 32 #define HTTP_REQUEST_TIMEOUT 30000//15000
Michael J. Spencer 1:f5ac63519541 33 #define HTTP_PORT 80
Michael J. Spencer 1:f5ac63519541 34
Michael J. Spencer 1:f5ac63519541 35 #define CHUNK_SIZE 256
Michael J. Spencer 1:f5ac63519541 36
Michael J. Spencer 1:f5ac63519541 37 HTTPClient::HTTPClient() : NetService(false) /*Not owned by the pool*/, m_meth(HTTP_GET), m_pCbItem(NULL), m_pCbMeth(NULL), m_pCb(NULL),
Michael J. Spencer 1:f5ac63519541 38 m_watchdog(), m_timeout(0), m_pDnsReq(NULL), m_server(), m_path(),
Michael J. Spencer 1:f5ac63519541 39 m_closed(true), m_state(HTTP_CLOSED),
Michael J. Spencer 1:f5ac63519541 40 m_pDataOut(NULL), m_pDataIn(NULL), m_dataChunked(false), m_dataPos(0), m_dataLen(0), m_httpResponseCode(0), m_blockingResult(HTTP_PROCESSING)
Michael J. Spencer 1:f5ac63519541 41
Michael J. Spencer 1:f5ac63519541 42 {
Michael J. Spencer 1:f5ac63519541 43 setTimeout(HTTP_REQUEST_TIMEOUT);
Michael J. Spencer 1:f5ac63519541 44 m_buf = new char[CHUNK_SIZE];
Michael J. Spencer 1:f5ac63519541 45 DBG("New HTTPClient %p\n",this);
Michael J. Spencer 1:f5ac63519541 46 }
Michael J. Spencer 1:f5ac63519541 47
Michael J. Spencer 1:f5ac63519541 48 HTTPClient::~HTTPClient()
Michael J. Spencer 1:f5ac63519541 49 {
Michael J. Spencer 1:f5ac63519541 50 close();
Michael J. Spencer 1:f5ac63519541 51 delete[] m_buf;
Michael J. Spencer 1:f5ac63519541 52 }
Michael J. Spencer 1:f5ac63519541 53
Michael J. Spencer 1:f5ac63519541 54 void HTTPClient::basicAuth(const char* user, const char* password) //Basic Authentification
Michael J. Spencer 1:f5ac63519541 55 {
Michael J. Spencer 1:f5ac63519541 56 if(user==NULL)
Michael J. Spencer 1:f5ac63519541 57 {
Michael J. Spencer 1:f5ac63519541 58 m_reqHeaders.erase("Authorization"); //Remove auth str
Michael J. Spencer 1:f5ac63519541 59 return;
Michael J. Spencer 1:f5ac63519541 60 }
Michael J. Spencer 1:f5ac63519541 61 string auth = "Basic ";
Michael J. Spencer 1:f5ac63519541 62 string decStr = user;
Michael J. Spencer 1:f5ac63519541 63 decStr += ":";
Michael J. Spencer 1:f5ac63519541 64 decStr += password;
Michael J. Spencer 1:f5ac63519541 65 auth.append( Base64::encode(decStr) );
Michael J. Spencer 1:f5ac63519541 66 DBG("Auth str is %s\n", auth.c_str());
Michael J. Spencer 1:f5ac63519541 67 m_reqHeaders["Authorization"] = auth;
Michael J. Spencer 1:f5ac63519541 68 }
Michael J. Spencer 1:f5ac63519541 69
Michael J. Spencer 1:f5ac63519541 70 //High Level setup functions
Michael J. Spencer 1:f5ac63519541 71 HTTPResult HTTPClient::get(const char* uri, HTTPData* pDataIn) //Blocking
Michael J. Spencer 1:f5ac63519541 72 {
Michael J. Spencer 1:f5ac63519541 73 doGet(uri, pDataIn);
Michael J. Spencer 1:f5ac63519541 74 return blockingProcess();
Michael J. Spencer 1:f5ac63519541 75 }
Michael J. Spencer 1:f5ac63519541 76
Michael J. Spencer 1:f5ac63519541 77 HTTPResult HTTPClient::get(const char* uri, HTTPData* pDataIn, void (*pMethod)(HTTPResult)) //Non blocking
Michael J. Spencer 1:f5ac63519541 78 {
Michael J. Spencer 1:f5ac63519541 79 setOnResult(pMethod);
Michael J. Spencer 1:f5ac63519541 80 doGet(uri, pDataIn);
Michael J. Spencer 1:f5ac63519541 81 return HTTP_PROCESSING;
Michael J. Spencer 1:f5ac63519541 82 }
Michael J. Spencer 1:f5ac63519541 83
Michael J. Spencer 1:f5ac63519541 84 #if 0 //For info only
Michael J. Spencer 1:f5ac63519541 85 template<class T>
Michael J. Spencer 1:f5ac63519541 86 HTTPResult HTTPClient::get(const char* uri, HTTPData* pDataIn, T* pItem, void (T::*pMethod)(HTTPResult)) //Non blocking
Michael J. Spencer 1:f5ac63519541 87 {
Michael J. Spencer 1:f5ac63519541 88 setOnResult(pItem, pMethod);
Michael J. Spencer 1:f5ac63519541 89 doGet(uri, pDataIn);
Michael J. Spencer 1:f5ac63519541 90 return HTTP_PROCESSING;
Michael J. Spencer 1:f5ac63519541 91 }
Michael J. Spencer 1:f5ac63519541 92 #endif
Michael J. Spencer 1:f5ac63519541 93
Michael J. Spencer 1:f5ac63519541 94 HTTPResult HTTPClient::post(const char* uri, const HTTPData& dataOut, HTTPData* pDataIn) //Blocking
Michael J. Spencer 1:f5ac63519541 95 {
Michael J. Spencer 1:f5ac63519541 96 doPost(uri, dataOut, pDataIn);
Michael J. Spencer 1:f5ac63519541 97 return blockingProcess();
Michael J. Spencer 1:f5ac63519541 98 }
Michael J. Spencer 1:f5ac63519541 99
Michael J. Spencer 1:f5ac63519541 100 HTTPResult HTTPClient::post(const char* uri, const HTTPData& dataOut, HTTPData* pDataIn, void (*pMethod)(HTTPResult)) //Non blocking
Michael J. Spencer 1:f5ac63519541 101 {
Michael J. Spencer 1:f5ac63519541 102 setOnResult(pMethod);
Michael J. Spencer 1:f5ac63519541 103 doPost(uri, dataOut, pDataIn);
Michael J. Spencer 1:f5ac63519541 104 return HTTP_PROCESSING;
Michael J. Spencer 1:f5ac63519541 105 }
Michael J. Spencer 1:f5ac63519541 106
Michael J. Spencer 1:f5ac63519541 107 #if 0 //For info only
Michael J. Spencer 1:f5ac63519541 108 template<class T>
Michael J. Spencer 1:f5ac63519541 109 HTTPResult HTTPClient::post(const char* uri, const HTTPData& dataOut, HTTPData* pDataIn, T* pItem, void (T::*pMethod)(HTTPResult)) //Non blocking
Michael J. Spencer 1:f5ac63519541 110 {
Michael J. Spencer 1:f5ac63519541 111 setOnResult(pItem, pMethod);
Michael J. Spencer 1:f5ac63519541 112 doPost(uri, dataOut, pDataIn);
Michael J. Spencer 1:f5ac63519541 113 return HTTP_PROCESSING;
Michael J. Spencer 1:f5ac63519541 114 }
Michael J. Spencer 1:f5ac63519541 115 #endif
Michael J. Spencer 1:f5ac63519541 116
Michael J. Spencer 1:f5ac63519541 117 void HTTPClient::doGet(const char* uri, HTTPData* pDataIn)
Michael J. Spencer 1:f5ac63519541 118 {
Michael J. Spencer 1:f5ac63519541 119 m_meth = HTTP_GET;
Michael J. Spencer 1:f5ac63519541 120 setup(uri, NULL, pDataIn);
Michael J. Spencer 1:f5ac63519541 121 }
Michael J. Spencer 1:f5ac63519541 122
Michael J. Spencer 1:f5ac63519541 123 void HTTPClient::doPost(const char* uri, const HTTPData& dataOut, HTTPData* pDataIn)
Michael J. Spencer 1:f5ac63519541 124 {
Michael J. Spencer 1:f5ac63519541 125 m_meth = HTTP_POST;
Michael J. Spencer 1:f5ac63519541 126 setup(uri, (HTTPData*) &dataOut, pDataIn);
Michael J. Spencer 1:f5ac63519541 127 }
Michael J. Spencer 1:f5ac63519541 128
Michael J. Spencer 1:f5ac63519541 129 void HTTPClient::setOnResult( void (*pMethod)(HTTPResult) )
Michael J. Spencer 1:f5ac63519541 130 {
Michael J. Spencer 1:f5ac63519541 131 m_pCb = pMethod;
Michael J. Spencer 1:f5ac63519541 132 m_pCbItem = NULL;
Michael J. Spencer 1:f5ac63519541 133 m_pCbMeth = NULL;
Michael J. Spencer 1:f5ac63519541 134 }
Michael J. Spencer 1:f5ac63519541 135
Michael J. Spencer 1:f5ac63519541 136 #if 0 //For info only
Michael J. Spencer 1:f5ac63519541 137 template<class T>
Michael J. Spencer 1:f5ac63519541 138 void HTTPClient::setOnResult( T* pItem, void (T::*pMethod)(NtpResult) )
Michael J. Spencer 1:f5ac63519541 139 {
Michael J. Spencer 1:f5ac63519541 140 m_pCb = NULL;
Michael J. Spencer 1:f5ac63519541 141 m_pCbItem = (CDummy*) pItem;
Michael J. Spencer 1:f5ac63519541 142 m_pCbMeth = (void (CDummy::*)(NtpResult)) pMethod;
Michael J. Spencer 1:f5ac63519541 143 }
Michael J. Spencer 1:f5ac63519541 144 #endif
Michael J. Spencer 1:f5ac63519541 145
Michael J. Spencer 1:f5ac63519541 146 void HTTPClient::setTimeout(int ms)
Michael J. Spencer 1:f5ac63519541 147 {
Michael J. Spencer 1:f5ac63519541 148 m_timeout = ms;
Michael J. Spencer 1:f5ac63519541 149 //resetTimeout();
Michael J. Spencer 1:f5ac63519541 150 }
Michael J. Spencer 1:f5ac63519541 151
Michael J. Spencer 1:f5ac63519541 152 void HTTPClient::poll() //Called by NetServices
Michael J. Spencer 1:f5ac63519541 153 {
Michael J. Spencer 1:f5ac63519541 154 if(m_closed)
Michael J. Spencer 1:f5ac63519541 155 {
Michael J. Spencer 1:f5ac63519541 156 return;
Michael J. Spencer 1:f5ac63519541 157 }
Michael J. Spencer 1:f5ac63519541 158 if(m_watchdog.read_ms()>m_timeout)
Michael J. Spencer 1:f5ac63519541 159 {
Michael J. Spencer 1:f5ac63519541 160 onTimeout();
Michael J. Spencer 1:f5ac63519541 161 }
Michael J. Spencer 1:f5ac63519541 162 else if(m_state == HTTP_READ_DATA_INCOMPLETE)
Michael J. Spencer 1:f5ac63519541 163 {
Michael J. Spencer 1:f5ac63519541 164 readData(); //Try to read more data
Michael J. Spencer 1:f5ac63519541 165 if( m_state == HTTP_DONE )
Michael J. Spencer 1:f5ac63519541 166 {
Michael J. Spencer 1:f5ac63519541 167 //All data has been read, close w/ success :)
Michael J. Spencer 1:f5ac63519541 168 DBG("Done :)!\n");
Michael J. Spencer 1:f5ac63519541 169 onResult(HTTP_OK);
Michael J. Spencer 1:f5ac63519541 170 close();
Michael J. Spencer 1:f5ac63519541 171 }
Michael J. Spencer 1:f5ac63519541 172 }
Michael J. Spencer 1:f5ac63519541 173
Michael J. Spencer 1:f5ac63519541 174 }
Michael J. Spencer 1:f5ac63519541 175
Michael J. Spencer 1:f5ac63519541 176 int HTTPClient::getHTTPResponseCode()
Michael J. Spencer 1:f5ac63519541 177 {
Michael J. Spencer 1:f5ac63519541 178 return m_httpResponseCode;
Michael J. Spencer 1:f5ac63519541 179 }
Michael J. Spencer 1:f5ac63519541 180
Michael J. Spencer 1:f5ac63519541 181 void HTTPClient::setRequestHeader(const string& header, const string& value)
Michael J. Spencer 1:f5ac63519541 182 {
Michael J. Spencer 1:f5ac63519541 183 m_reqHeaders[header] = value;
Michael J. Spencer 1:f5ac63519541 184 }
Michael J. Spencer 1:f5ac63519541 185
Michael J. Spencer 1:f5ac63519541 186 string& HTTPClient::getResponseHeader(const string& header)
Michael J. Spencer 1:f5ac63519541 187 {
Michael J. Spencer 1:f5ac63519541 188 return m_respHeaders[header];
Michael J. Spencer 1:f5ac63519541 189 }
Michael J. Spencer 1:f5ac63519541 190
Michael J. Spencer 1:f5ac63519541 191 void HTTPClient::resetRequestHeaders()
Michael J. Spencer 1:f5ac63519541 192 {
Michael J. Spencer 1:f5ac63519541 193 m_reqHeaders.clear();
Michael J. Spencer 1:f5ac63519541 194 }
Michael J. Spencer 1:f5ac63519541 195
Michael J. Spencer 1:f5ac63519541 196 void HTTPClient::resetTimeout()
Michael J. Spencer 1:f5ac63519541 197 {
Michael J. Spencer 1:f5ac63519541 198 m_watchdog.reset();
Michael J. Spencer 1:f5ac63519541 199 m_watchdog.start();
Michael J. Spencer 1:f5ac63519541 200 }
Michael J. Spencer 1:f5ac63519541 201
Michael J. Spencer 1:f5ac63519541 202 void HTTPClient::init() //Create and setup socket if needed
Michael J. Spencer 1:f5ac63519541 203 {
Michael J. Spencer 1:f5ac63519541 204 close(); //Remove previous elements
Michael J. Spencer 1:f5ac63519541 205 if(!m_closed) //Already opened
Michael J. Spencer 1:f5ac63519541 206 return;
Michael J. Spencer 1:f5ac63519541 207 m_state = HTTP_WRITE_HEADERS;
Michael J. Spencer 1:f5ac63519541 208 m_pTCPSocket = new TCPSocket;
Michael J. Spencer 1:f5ac63519541 209 m_pTCPSocket->setOnEvent(this, &HTTPClient::onTCPSocketEvent);
Michael J. Spencer 1:f5ac63519541 210 m_closed = false;
Michael J. Spencer 1:f5ac63519541 211 m_httpResponseCode = 0;
Michael J. Spencer 1:f5ac63519541 212 }
Michael J. Spencer 1:f5ac63519541 213
Michael J. Spencer 1:f5ac63519541 214 void HTTPClient::close()
Michael J. Spencer 1:f5ac63519541 215 {
Michael J. Spencer 1:f5ac63519541 216 if(m_closed)
Michael J. Spencer 1:f5ac63519541 217 return;
Michael J. Spencer 1:f5ac63519541 218 m_state = HTTP_CLOSED;
Michael J. Spencer 1:f5ac63519541 219 //Now Request headers are kept btw requests unless resetRequestHeaders() is called
Michael J. Spencer 1:f5ac63519541 220 //m_reqHeaders.clear(); //Clear headers for next requests
Michael J. Spencer 1:f5ac63519541 221 m_closed = true; //Prevent recursive calling or calling on an object being destructed by someone else
Michael J. Spencer 1:f5ac63519541 222 m_watchdog.stop(); //Stop timeout
Michael J. Spencer 1:f5ac63519541 223 m_watchdog.reset();
Michael J. Spencer 1:f5ac63519541 224 m_pTCPSocket->resetOnEvent();
Michael J. Spencer 1:f5ac63519541 225 m_pTCPSocket->close();
Michael J. Spencer 1:f5ac63519541 226 delete m_pTCPSocket;
Michael J. Spencer 1:f5ac63519541 227 m_pTCPSocket = NULL;
Michael J. Spencer 1:f5ac63519541 228 if( m_pDnsReq )
Michael J. Spencer 1:f5ac63519541 229 {
Michael J. Spencer 1:f5ac63519541 230 m_pDnsReq->close();
Michael J. Spencer 1:f5ac63519541 231 delete m_pDnsReq;
Michael J. Spencer 1:f5ac63519541 232 m_pDnsReq = NULL;
Michael J. Spencer 1:f5ac63519541 233 }
Michael J. Spencer 1:f5ac63519541 234 }
Michael J. Spencer 1:f5ac63519541 235
Michael J. Spencer 1:f5ac63519541 236 void HTTPClient::setup(const char* uri, HTTPData* pDataOut, HTTPData* pDataIn) //Setup request, make DNS Req if necessary
Michael J. Spencer 1:f5ac63519541 237 {
Michael J. Spencer 1:f5ac63519541 238 init(); //Initialize client in known state, create socket
Michael J. Spencer 1:f5ac63519541 239 m_pDataOut = pDataOut;
Michael J. Spencer 1:f5ac63519541 240 m_pDataIn = pDataIn;
Michael J. Spencer 1:f5ac63519541 241 resetTimeout();
Michael J. Spencer 1:f5ac63519541 242
Michael J. Spencer 1:f5ac63519541 243 //Erase previous headers
Michael J. Spencer 1:f5ac63519541 244 //Do NOT clear m_reqHeaders as they might have already set before connecting
Michael J. Spencer 1:f5ac63519541 245 m_respHeaders.clear();
Michael J. Spencer 1:f5ac63519541 246
Michael J. Spencer 1:f5ac63519541 247 //Erase response buffer
Michael J. Spencer 1:f5ac63519541 248 if(m_pDataIn)
Michael J. Spencer 1:f5ac63519541 249 m_pDataIn->clear();
Michael J. Spencer 1:f5ac63519541 250
Michael J. Spencer 1:f5ac63519541 251 //Assert that buffers are initialized properly
Michael J. Spencer 1:f5ac63519541 252 m_dataLen = 0;
Michael J. Spencer 1:f5ac63519541 253 m_bufRemainingLen = 0;
Michael J. Spencer 1:f5ac63519541 254
Michael J. Spencer 1:f5ac63519541 255 Url url;
Michael J. Spencer 1:f5ac63519541 256 url.fromString(uri);
Michael J. Spencer 1:f5ac63519541 257
Michael J. Spencer 1:f5ac63519541 258 m_path = url.getPath();
Michael J. Spencer 1:f5ac63519541 259
Michael J. Spencer 1:f5ac63519541 260 m_server.setName(url.getHost().c_str());
Michael J. Spencer 1:f5ac63519541 261
Michael J. Spencer 1:f5ac63519541 262 if( url.getPort() > 0 )
Michael J. Spencer 1:f5ac63519541 263 {
Michael J. Spencer 1:f5ac63519541 264 m_server.setPort( url.getPort() );
Michael J. Spencer 1:f5ac63519541 265 }
Michael J. Spencer 1:f5ac63519541 266 else
Michael J. Spencer 1:f5ac63519541 267 {
Michael J. Spencer 1:f5ac63519541 268 m_server.setPort( HTTP_PORT );
Michael J. Spencer 1:f5ac63519541 269 }
Michael J. Spencer 1:f5ac63519541 270
Michael J. Spencer 1:f5ac63519541 271 DBG("URL parsed,\r\nHost: %s\r\nPort: %d\r\nPath: %s\n", url.getHost().c_str(), url.getPort(), url.getPath().c_str());
Michael J. Spencer 1:f5ac63519541 272
Michael J. Spencer 1:f5ac63519541 273 IpAddr ip;
Michael J. Spencer 1:f5ac63519541 274 if( url.getHostIp(&ip) )
Michael J. Spencer 1:f5ac63519541 275 {
Michael J. Spencer 1:f5ac63519541 276 m_server.setIp(ip);
Michael J. Spencer 1:f5ac63519541 277 connect();
Michael J. Spencer 1:f5ac63519541 278 }
Michael J. Spencer 1:f5ac63519541 279 else
Michael J. Spencer 1:f5ac63519541 280 {
Michael J. Spencer 1:f5ac63519541 281 DBG("DNS Query...\n");
Michael J. Spencer 1:f5ac63519541 282 m_pDnsReq = new DNSRequest();
Michael J. Spencer 1:f5ac63519541 283 m_pDnsReq->setOnReply(this, &HTTPClient::onDNSReply);
Michael J. Spencer 1:f5ac63519541 284 m_pDnsReq->resolve(&m_server);
Michael J. Spencer 1:f5ac63519541 285 DBG("HTTPClient : DNSRequest %p\n", m_pDnsReq);
Michael J. Spencer 1:f5ac63519541 286 }
Michael J. Spencer 1:f5ac63519541 287
Michael J. Spencer 1:f5ac63519541 288 }
Michael J. Spencer 1:f5ac63519541 289
Michael J. Spencer 1:f5ac63519541 290 void HTTPClient::connect() //Start Connection
Michael J. Spencer 1:f5ac63519541 291 {
Michael J. Spencer 1:f5ac63519541 292 resetTimeout();
Michael J. Spencer 1:f5ac63519541 293 DBG("Connecting...\n");
Michael J. Spencer 1:f5ac63519541 294 m_pTCPSocket->connect(m_server);
Michael J. Spencer 1:f5ac63519541 295 }
Michael J. Spencer 1:f5ac63519541 296
Michael J. Spencer 1:f5ac63519541 297 #define MIN(a,b) ((a)<(b)?(a):(b))
Michael J. Spencer 1:f5ac63519541 298 #define ABS(a) (((a)>0)?(a):0)
Michael J. Spencer 1:f5ac63519541 299 int HTTPClient::tryRead() //Try to read data from tcp packet and put in the HTTPData object
Michael J. Spencer 1:f5ac63519541 300 {
Michael J. Spencer 1:f5ac63519541 301 int len = 0;
Michael J. Spencer 1:f5ac63519541 302 int readLen;
Michael J. Spencer 1:f5ac63519541 303 do
Michael J. Spencer 1:f5ac63519541 304 {
Michael J. Spencer 1:f5ac63519541 305 if(m_state == HTTP_READ_DATA_INCOMPLETE) //First try to complete buffer copy
Michael J. Spencer 1:f5ac63519541 306 {
Michael J. Spencer 1:f5ac63519541 307 readLen = m_bufRemainingLen;
Michael J. Spencer 1:f5ac63519541 308 /* if (readLen == 0)
Michael J. Spencer 1:f5ac63519541 309 {
Michael J. Spencer 1:f5ac63519541 310 m_state = HTTP_READ_DATA;
Michael J. Spencer 1:f5ac63519541 311 continue;
Michael J. Spencer 1:f5ac63519541 312 }*/
Michael J. Spencer 1:f5ac63519541 313 }
Michael J. Spencer 1:f5ac63519541 314 else
Michael J. Spencer 1:f5ac63519541 315 {
Michael J. Spencer 1:f5ac63519541 316 readLen = m_pTCPSocket->recv(m_buf, MIN(ABS(m_dataLen-m_dataPos),CHUNK_SIZE));
Michael J. Spencer 1:f5ac63519541 317 if(readLen < 0) //Error
Michael J. Spencer 1:f5ac63519541 318 {
Michael J. Spencer 1:f5ac63519541 319 return readLen;
Michael J. Spencer 1:f5ac63519541 320 }
Michael J. Spencer 1:f5ac63519541 321
Michael J. Spencer 1:f5ac63519541 322 DBG("%d bytes read\n", readLen);
Michael J. Spencer 1:f5ac63519541 323
Michael J. Spencer 1:f5ac63519541 324 m_pBufRemaining = m_buf;
Michael J. Spencer 1:f5ac63519541 325 }
Michael J. Spencer 1:f5ac63519541 326 if (readLen == 0)
Michael J. Spencer 1:f5ac63519541 327 {
Michael J. Spencer 1:f5ac63519541 328 m_state = HTTP_READ_DATA;
Michael J. Spencer 1:f5ac63519541 329 return len;
Michael J. Spencer 1:f5ac63519541 330 }
Michael J. Spencer 1:f5ac63519541 331
Michael J. Spencer 1:f5ac63519541 332 DBG("Trying to write %d bytes\n", readLen);
Michael J. Spencer 1:f5ac63519541 333
Michael J. Spencer 1:f5ac63519541 334 int writtenLen = m_pDataIn->write(m_pBufRemaining, readLen);
Michael J. Spencer 1:f5ac63519541 335 m_dataPos += writtenLen;
Michael J. Spencer 1:f5ac63519541 336
Michael J. Spencer 1:f5ac63519541 337 DBG("%d bytes written\n", writtenLen);
Michael J. Spencer 1:f5ac63519541 338
Michael J. Spencer 1:f5ac63519541 339 if(writtenLen<readLen) //Data was not completely written
Michael J. Spencer 1:f5ac63519541 340 {
Michael J. Spencer 1:f5ac63519541 341 m_pBufRemaining += writtenLen;
Michael J. Spencer 1:f5ac63519541 342 m_bufRemainingLen = readLen - writtenLen;
Michael J. Spencer 1:f5ac63519541 343 m_state = HTTP_READ_DATA_INCOMPLETE;
Michael J. Spencer 1:f5ac63519541 344 return len + writtenLen;
Michael J. Spencer 1:f5ac63519541 345 }
Michael J. Spencer 1:f5ac63519541 346 else
Michael J. Spencer 1:f5ac63519541 347 {
Michael J. Spencer 1:f5ac63519541 348 m_state = HTTP_READ_DATA;
Michael J. Spencer 1:f5ac63519541 349 }
Michael J. Spencer 1:f5ac63519541 350 len += readLen;
Michael J. Spencer 1:f5ac63519541 351 } while(readLen>0);
Michael J. Spencer 1:f5ac63519541 352
Michael J. Spencer 1:f5ac63519541 353 return len;
Michael J. Spencer 1:f5ac63519541 354 }
Michael J. Spencer 1:f5ac63519541 355
Michael J. Spencer 1:f5ac63519541 356 void HTTPClient::readData() //Data has been read
Michael J. Spencer 1:f5ac63519541 357 {
Michael J. Spencer 1:f5ac63519541 358 if(m_pDataIn == NULL) //Nothing to read (in HEAD for instance, not supported now)
Michael J. Spencer 1:f5ac63519541 359 {
Michael J. Spencer 1:f5ac63519541 360 m_state = HTTP_DONE;
Michael J. Spencer 1:f5ac63519541 361 return;
Michael J. Spencer 1:f5ac63519541 362 }
Michael J. Spencer 1:f5ac63519541 363 DBG("Reading response...\n");
Michael J. Spencer 1:f5ac63519541 364 int len = 0;
Michael J. Spencer 1:f5ac63519541 365 do
Michael J. Spencer 1:f5ac63519541 366 {
Michael J. Spencer 1:f5ac63519541 367 if(m_dataChunked && (m_state != HTTP_READ_DATA_INCOMPLETE))
Michael J. Spencer 1:f5ac63519541 368 {
Michael J. Spencer 1:f5ac63519541 369 if(m_dataLen==0)
Michael J. Spencer 1:f5ac63519541 370 {
Michael J. Spencer 1:f5ac63519541 371 DBG("Reading chunk length...\n");
Michael J. Spencer 1:f5ac63519541 372 //New block
Michael J. Spencer 1:f5ac63519541 373 static char chunkHeader[16];
Michael J. Spencer 1:f5ac63519541 374 //We use m_dataPos to retain the read position in chunkHeader, it has been set to 0 before the first call of readData()
Michael J. Spencer 1:f5ac63519541 375 m_dataPos += readLine(chunkHeader + m_dataPos, ABS(16 - m_dataPos));
Michael J. Spencer 1:f5ac63519541 376 if( m_dataPos > 0 )
Michael J. Spencer 1:f5ac63519541 377 {
Michael J. Spencer 1:f5ac63519541 378 if( chunkHeader[strlen(chunkHeader)-1] == 0x0d )
Michael J. Spencer 1:f5ac63519541 379 {
Michael J. Spencer 1:f5ac63519541 380 sscanf(chunkHeader, "%x%*[^\r\n]", &m_dataLen);
Michael J. Spencer 1:f5ac63519541 381 DBG("Chunk length is %d\n", m_dataLen);
Michael J. Spencer 1:f5ac63519541 382 m_dataPos = 0;
Michael J. Spencer 1:f5ac63519541 383 }
Michael J. Spencer 1:f5ac63519541 384 else
Michael J. Spencer 1:f5ac63519541 385 {
Michael J. Spencer 1:f5ac63519541 386 //Wait for end of line
Michael J. Spencer 1:f5ac63519541 387 DBG("Wait for CRLF\n");
Michael J. Spencer 1:f5ac63519541 388 return;
Michael J. Spencer 1:f5ac63519541 389 }
Michael J. Spencer 1:f5ac63519541 390 }
Michael J. Spencer 1:f5ac63519541 391 else
Michael J. Spencer 1:f5ac63519541 392 {
Michael J. Spencer 1:f5ac63519541 393 DBG("Wait for data\n");
Michael J. Spencer 1:f5ac63519541 394 //Wait for data
Michael J. Spencer 1:f5ac63519541 395 return;
Michael J. Spencer 1:f5ac63519541 396 }
Michael J. Spencer 1:f5ac63519541 397 }
Michael J. Spencer 1:f5ac63519541 398 }
Michael J. Spencer 1:f5ac63519541 399
Michael J. Spencer 1:f5ac63519541 400 //Proper data recovery
Michael J. Spencer 1:f5ac63519541 401 len = tryRead();
Michael J. Spencer 1:f5ac63519541 402 if(len<0) //Error
Michael J. Spencer 1:f5ac63519541 403 {
Michael J. Spencer 1:f5ac63519541 404 onResult(HTTP_CONN);
Michael J. Spencer 1:f5ac63519541 405 return;
Michael J. Spencer 1:f5ac63519541 406 }
Michael J. Spencer 1:f5ac63519541 407
Michael J. Spencer 1:f5ac63519541 408 if(len>0)
Michael J. Spencer 1:f5ac63519541 409 resetTimeout();
Michael J. Spencer 1:f5ac63519541 410
Michael J. Spencer 1:f5ac63519541 411 if(m_state == HTTP_READ_DATA_INCOMPLETE)
Michael J. Spencer 1:f5ac63519541 412 return;
Michael J. Spencer 1:f5ac63519541 413
Michael J. Spencer 1:f5ac63519541 414 //Chunk Tail
Michael J. Spencer 1:f5ac63519541 415 if(m_dataChunked)
Michael J. Spencer 1:f5ac63519541 416 {
Michael J. Spencer 1:f5ac63519541 417 if(m_dataPos >= m_dataLen)
Michael J. Spencer 1:f5ac63519541 418 {
Michael J. Spencer 1:f5ac63519541 419 DBG("Chunk read, wait for CRLF\n");
Michael J. Spencer 1:f5ac63519541 420 char chunkTail[3];
Michael J. Spencer 1:f5ac63519541 421 m_dataPos += readLine(chunkTail, 3);
Michael J. Spencer 1:f5ac63519541 422 }
Michael J. Spencer 1:f5ac63519541 423
Michael J. Spencer 1:f5ac63519541 424 if(m_dataPos >= m_dataLen + 1) //1 == strlen("\n"),
Michael J. Spencer 1:f5ac63519541 425 {
Michael J. Spencer 1:f5ac63519541 426 DBG("End of chunk\n");
Michael J. Spencer 1:f5ac63519541 427 if(m_dataLen==0)
Michael J. Spencer 1:f5ac63519541 428 {
Michael J. Spencer 1:f5ac63519541 429 DBG("End of file\n");
Michael J. Spencer 1:f5ac63519541 430 //End of file
Michael J. Spencer 1:f5ac63519541 431 m_state = HTTP_DONE; //Done
Michael J. Spencer 1:f5ac63519541 432 }
Michael J. Spencer 1:f5ac63519541 433 m_dataLen = 0;
Michael J. Spencer 1:f5ac63519541 434 m_dataPos = 0;
Michael J. Spencer 1:f5ac63519541 435 }
Michael J. Spencer 1:f5ac63519541 436 }
Michael J. Spencer 1:f5ac63519541 437
Michael J. Spencer 1:f5ac63519541 438 } while(len>0);
Michael J. Spencer 1:f5ac63519541 439
Michael J. Spencer 1:f5ac63519541 440
Michael J. Spencer 1:f5ac63519541 441 if(!m_dataChunked && (m_dataPos >= m_dataLen)) //All Data has been received
Michael J. Spencer 1:f5ac63519541 442 {
Michael J. Spencer 1:f5ac63519541 443 DBG("End of file\n");
Michael J. Spencer 1:f5ac63519541 444 m_state = HTTP_DONE; //Done
Michael J. Spencer 1:f5ac63519541 445 }
Michael J. Spencer 1:f5ac63519541 446 }
Michael J. Spencer 1:f5ac63519541 447
Michael J. Spencer 1:f5ac63519541 448 void HTTPClient::writeData() //Data has been written & buf is free
Michael J. Spencer 1:f5ac63519541 449 {
Michael J. Spencer 1:f5ac63519541 450 if(m_pDataOut == NULL) //Nothing to write (in POST for instance)
Michael J. Spencer 1:f5ac63519541 451 {
Michael J. Spencer 1:f5ac63519541 452 m_dataLen = 0; //Reset Data Length
Michael J. Spencer 1:f5ac63519541 453 m_state = HTTP_READ_HEADERS;
Michael J. Spencer 1:f5ac63519541 454 return;
Michael J. Spencer 1:f5ac63519541 455 }
Michael J. Spencer 1:f5ac63519541 456 int len = m_pDataOut->read(m_buf, CHUNK_SIZE);
Michael J. Spencer 1:f5ac63519541 457 if( m_dataChunked )
Michael J. Spencer 1:f5ac63519541 458 {
Michael J. Spencer 1:f5ac63519541 459 //Write chunk header
Michael J. Spencer 1:f5ac63519541 460 char chunkHeader[16];
Michael J. Spencer 1:f5ac63519541 461 sprintf(chunkHeader, "%d\r\n", len);
Michael J. Spencer 1:f5ac63519541 462 int ret = m_pTCPSocket->send(chunkHeader, strlen(chunkHeader));
Michael J. Spencer 1:f5ac63519541 463 if(ret < 0)//Error
Michael J. Spencer 1:f5ac63519541 464 {
Michael J. Spencer 1:f5ac63519541 465 onResult(HTTP_CONN);
Michael J. Spencer 1:f5ac63519541 466 return;
Michael J. Spencer 1:f5ac63519541 467 }
Michael J. Spencer 1:f5ac63519541 468 }
Michael J. Spencer 1:f5ac63519541 469 m_pTCPSocket->send(m_buf, len);
Michael J. Spencer 1:f5ac63519541 470 m_dataPos+=len;
Michael J. Spencer 1:f5ac63519541 471 if( m_dataChunked )
Michael J. Spencer 1:f5ac63519541 472 {
Michael J. Spencer 1:f5ac63519541 473 m_pTCPSocket->send("\r\n", 2); //Chunk-terminating CRLF
Michael J. Spencer 1:f5ac63519541 474 }
Michael J. Spencer 1:f5ac63519541 475 if( ( !m_dataChunked && (m_dataPos >= m_dataLen) )
Michael J. Spencer 1:f5ac63519541 476 || ( m_dataChunked && !len ) ) //All Data has been sent
Michael J. Spencer 1:f5ac63519541 477 {
Michael J. Spencer 1:f5ac63519541 478 m_dataLen = 0; //Reset Data Length
Michael J. Spencer 1:f5ac63519541 479 m_state = HTTP_READ_HEADERS; //Wait for resp
Michael J. Spencer 1:f5ac63519541 480 }
Michael J. Spencer 1:f5ac63519541 481 }
Michael J. Spencer 1:f5ac63519541 482
Michael J. Spencer 1:f5ac63519541 483 void HTTPClient::onTCPSocketEvent(TCPSocketEvent e)
Michael J. Spencer 1:f5ac63519541 484 {
Michael J. Spencer 1:f5ac63519541 485 DBG("Event %d in HTTPClient::onTCPSocketEvent()\n", e);
Michael J. Spencer 1:f5ac63519541 486
Michael J. Spencer 1:f5ac63519541 487 if(m_closed)
Michael J. Spencer 1:f5ac63519541 488 {
Michael J. Spencer 1:f5ac63519541 489 DBG("WARN: Discarded\n");
Michael J. Spencer 1:f5ac63519541 490 return;
Michael J. Spencer 1:f5ac63519541 491 }
Michael J. Spencer 1:f5ac63519541 492
Michael J. Spencer 1:f5ac63519541 493 switch(e)
Michael J. Spencer 1:f5ac63519541 494 {
Michael J. Spencer 1:f5ac63519541 495 case TCPSOCKET_READABLE: //Incoming data
Michael J. Spencer 1:f5ac63519541 496 resetTimeout();
Michael J. Spencer 1:f5ac63519541 497 switch(m_state)
Michael J. Spencer 1:f5ac63519541 498 {
Michael J. Spencer 1:f5ac63519541 499 case HTTP_READ_HEADERS:
Michael J. Spencer 1:f5ac63519541 500 if( !readHeaders() )
Michael J. Spencer 1:f5ac63519541 501 {
Michael J. Spencer 1:f5ac63519541 502 return; //Connection has been closed or incomplete data
Michael J. Spencer 1:f5ac63519541 503 }
Michael J. Spencer 1:f5ac63519541 504 if( m_pDataIn )
Michael J. Spencer 1:f5ac63519541 505 {
Michael J. Spencer 1:f5ac63519541 506 //Data chunked?
Michael J. Spencer 1:f5ac63519541 507 if(m_respHeaders["Transfer-Encoding"].find("chunked")!=string::npos)
Michael J. Spencer 1:f5ac63519541 508 {
Michael J. Spencer 1:f5ac63519541 509 m_dataChunked = true;
Michael J. Spencer 1:f5ac63519541 510 m_dataPos = 0;
Michael J. Spencer 1:f5ac63519541 511 m_dataLen = 0;
Michael J. Spencer 1:f5ac63519541 512 DBG("Encoding is chunked, Content-Type is %s\n", m_respHeaders["Content-Type"].c_str() );
Michael J. Spencer 1:f5ac63519541 513 }
Michael J. Spencer 1:f5ac63519541 514 else
Michael J. Spencer 1:f5ac63519541 515 {
Michael J. Spencer 1:f5ac63519541 516 m_dataChunked = false;
Michael J. Spencer 1:f5ac63519541 517 int len = 0;
Michael J. Spencer 1:f5ac63519541 518 //DBG("Preparing read... len = %s\n", m_respHeaders["Content-Length"].c_str());
Michael J. Spencer 1:f5ac63519541 519 sscanf(m_respHeaders["Content-Length"].c_str(), "%d", &len);
Michael J. Spencer 1:f5ac63519541 520 m_pDataIn->setDataLen( len );
Michael J. Spencer 1:f5ac63519541 521 m_dataPos = 0;
Michael J. Spencer 1:f5ac63519541 522 m_dataLen = len;
Michael J. Spencer 1:f5ac63519541 523 DBG("Content-Length is %d, Content-Type is %s\n", len, m_respHeaders["Content-Type"].c_str() );
Michael J. Spencer 1:f5ac63519541 524 }
Michael J. Spencer 1:f5ac63519541 525 m_pDataIn->setDataType( m_respHeaders["Content-Type"] );
Michael J. Spencer 1:f5ac63519541 526 }
Michael J. Spencer 1:f5ac63519541 527 case HTTP_READ_DATA:
Michael J. Spencer 1:f5ac63519541 528 readData();
Michael J. Spencer 1:f5ac63519541 529 break;
Michael J. Spencer 1:f5ac63519541 530 case HTTP_READ_DATA_INCOMPLETE:
Michael J. Spencer 1:f5ac63519541 531 break; //We need to handle previously received data first
Michael J. Spencer 1:f5ac63519541 532 default:
Michael J. Spencer 1:f5ac63519541 533 //Should not receive data now, req is not complete
Michael J. Spencer 1:f5ac63519541 534 onResult(HTTP_PRTCL);
Michael J. Spencer 1:f5ac63519541 535 }
Michael J. Spencer 1:f5ac63519541 536 //All data has been read, close w/ success :)
Michael J. Spencer 1:f5ac63519541 537 if( m_state == HTTP_DONE )
Michael J. Spencer 1:f5ac63519541 538 {
Michael J. Spencer 1:f5ac63519541 539 DBG("Done :)!\n");
Michael J. Spencer 1:f5ac63519541 540 onResult(HTTP_OK);
Michael J. Spencer 1:f5ac63519541 541 }
Michael J. Spencer 1:f5ac63519541 542 break;
Michael J. Spencer 1:f5ac63519541 543 case TCPSOCKET_CONNECTED:
Michael J. Spencer 1:f5ac63519541 544 case TCPSOCKET_WRITEABLE: //We can send data
Michael J. Spencer 1:f5ac63519541 545 resetTimeout();
Michael J. Spencer 1:f5ac63519541 546 switch(m_state)
Michael J. Spencer 1:f5ac63519541 547 {
Michael J. Spencer 1:f5ac63519541 548 case HTTP_WRITE_HEADERS:
Michael J. Spencer 1:f5ac63519541 549 //Update headers fields according to m_pDataOut
Michael J. Spencer 1:f5ac63519541 550 if( m_pDataOut )
Michael J. Spencer 1:f5ac63519541 551 {
Michael J. Spencer 1:f5ac63519541 552 //Data is chunked?
Michael J. Spencer 1:f5ac63519541 553 if(m_pDataOut->getIsChunked())
Michael J. Spencer 1:f5ac63519541 554 {
Michael J. Spencer 1:f5ac63519541 555 m_dataChunked = true;
Michael J. Spencer 1:f5ac63519541 556 m_reqHeaders.erase("Content-Length");
Michael J. Spencer 1:f5ac63519541 557 m_reqHeaders["Transfer-Encoding"] = "chunked";
Michael J. Spencer 1:f5ac63519541 558 }
Michael J. Spencer 1:f5ac63519541 559 else
Michael J. Spencer 1:f5ac63519541 560 {
Michael J. Spencer 1:f5ac63519541 561 m_dataChunked = false;
Michael J. Spencer 1:f5ac63519541 562 char c_len[16] = "0";
Michael J. Spencer 1:f5ac63519541 563 int len = m_pDataOut->getDataLen();
Michael J. Spencer 1:f5ac63519541 564 sprintf(c_len, "%d", len);
Michael J. Spencer 1:f5ac63519541 565 m_dataPos = 0;
Michael J. Spencer 1:f5ac63519541 566 m_dataLen = len;
Michael J. Spencer 1:f5ac63519541 567 m_reqHeaders.erase("Transfer-Encoding");
Michael J. Spencer 1:f5ac63519541 568 m_reqHeaders["Content-Length"] = string(c_len);
Michael J. Spencer 1:f5ac63519541 569 }
Michael J. Spencer 1:f5ac63519541 570 string type = m_pDataOut->getDataType();
Michael J. Spencer 1:f5ac63519541 571 if(!type.empty())
Michael J. Spencer 1:f5ac63519541 572 {
Michael J. Spencer 1:f5ac63519541 573 m_reqHeaders["Content-Type"] = type;
Michael J. Spencer 1:f5ac63519541 574 }
Michael J. Spencer 1:f5ac63519541 575 else
Michael J. Spencer 1:f5ac63519541 576 {
Michael J. Spencer 1:f5ac63519541 577 m_reqHeaders.erase("Content-Type");
Michael J. Spencer 1:f5ac63519541 578 }
Michael J. Spencer 1:f5ac63519541 579 }
Michael J. Spencer 1:f5ac63519541 580 if( !writeHeaders() )
Michael J. Spencer 1:f5ac63519541 581 {
Michael J. Spencer 1:f5ac63519541 582 return; //Connection has been closed
Michael J. Spencer 1:f5ac63519541 583 }
Michael J. Spencer 1:f5ac63519541 584 break; //Wait for writeable event before sending payload
Michael J. Spencer 1:f5ac63519541 585 case HTTP_WRITE_DATA:
Michael J. Spencer 1:f5ac63519541 586 writeData();
Michael J. Spencer 1:f5ac63519541 587 break;
Michael J. Spencer 1:f5ac63519541 588 }
Michael J. Spencer 1:f5ac63519541 589 //Otherwise request has been sent, now wait for resp
Michael J. Spencer 1:f5ac63519541 590 break;
Michael J. Spencer 1:f5ac63519541 591 case TCPSOCKET_CONTIMEOUT:
Michael J. Spencer 1:f5ac63519541 592 case TCPSOCKET_CONRST:
Michael J. Spencer 1:f5ac63519541 593 case TCPSOCKET_CONABRT:
Michael J. Spencer 1:f5ac63519541 594 case TCPSOCKET_ERROR:
Michael J. Spencer 1:f5ac63519541 595 DBG("Connection error.\n");
Michael J. Spencer 1:f5ac63519541 596 onResult(HTTP_CONN);
Michael J. Spencer 1:f5ac63519541 597 case TCPSOCKET_DISCONNECTED:
Michael J. Spencer 1:f5ac63519541 598 //There might still be some data available for reading
Michael J. Spencer 1:f5ac63519541 599 //So if we are in a reading state, do not close the socket yet
Michael J. Spencer 1:f5ac63519541 600 if( (m_state != HTTP_READ_DATA_INCOMPLETE) && (m_state != HTTP_DONE) && (m_state != HTTP_CLOSED) )
Michael J. Spencer 1:f5ac63519541 601 {
Michael J. Spencer 1:f5ac63519541 602 onResult(HTTP_CONN);
Michael J. Spencer 1:f5ac63519541 603 }
Michael J. Spencer 1:f5ac63519541 604 DBG("Connection closed by remote host.\n");
Michael J. Spencer 1:f5ac63519541 605 break;
Michael J. Spencer 1:f5ac63519541 606 }
Michael J. Spencer 1:f5ac63519541 607 }
Michael J. Spencer 1:f5ac63519541 608
Michael J. Spencer 1:f5ac63519541 609 void HTTPClient::onDNSReply(DNSReply r)
Michael J. Spencer 1:f5ac63519541 610 {
Michael J. Spencer 1:f5ac63519541 611 if(m_closed)
Michael J. Spencer 1:f5ac63519541 612 {
Michael J. Spencer 1:f5ac63519541 613 DBG("WARN: Discarded\n");
Michael J. Spencer 1:f5ac63519541 614 return;
Michael J. Spencer 1:f5ac63519541 615 }
Michael J. Spencer 1:f5ac63519541 616
Michael J. Spencer 1:f5ac63519541 617 if( r != DNS_FOUND )
Michael J. Spencer 1:f5ac63519541 618 {
Michael J. Spencer 1:f5ac63519541 619 DBG("Could not resolve hostname.\n");
Michael J. Spencer 1:f5ac63519541 620 onResult(HTTP_DNS);
Michael J. Spencer 1:f5ac63519541 621 return;
Michael J. Spencer 1:f5ac63519541 622 }
Michael J. Spencer 1:f5ac63519541 623
Michael J. Spencer 1:f5ac63519541 624 DBG("DNS Resolved to %d.%d.%d.%d.\n",m_server.getIp()[0],m_server.getIp()[1],m_server.getIp()[2],m_server.getIp()[3]);
Michael J. Spencer 1:f5ac63519541 625 //If no error, m_server has been updated by m_pDnsReq so we're set to go !
Michael J. Spencer 1:f5ac63519541 626 m_pDnsReq->close();
Michael J. Spencer 1:f5ac63519541 627 delete m_pDnsReq;
Michael J. Spencer 1:f5ac63519541 628 m_pDnsReq = NULL;
Michael J. Spencer 1:f5ac63519541 629 connect();
Michael J. Spencer 1:f5ac63519541 630 }
Michael J. Spencer 1:f5ac63519541 631
Michael J. Spencer 1:f5ac63519541 632 void HTTPClient::onResult(HTTPResult r) //Called when exchange completed or on failure
Michael J. Spencer 1:f5ac63519541 633 {
Michael J. Spencer 1:f5ac63519541 634 if(m_pCbItem && m_pCbMeth)
Michael J. Spencer 1:f5ac63519541 635 (m_pCbItem->*m_pCbMeth)(r);
Michael J. Spencer 1:f5ac63519541 636 else if(m_pCb)
Michael J. Spencer 1:f5ac63519541 637 m_pCb(r);
Michael J. Spencer 1:f5ac63519541 638 m_blockingResult = r; //Blocking mode
Michael J. Spencer 1:f5ac63519541 639 close(); //FIXME:Remove suppl. close() calls
Michael J. Spencer 1:f5ac63519541 640 }
Michael J. Spencer 1:f5ac63519541 641
Michael J. Spencer 1:f5ac63519541 642 void HTTPClient::onTimeout() //Connection has timed out
Michael J. Spencer 1:f5ac63519541 643 {
Michael J. Spencer 1:f5ac63519541 644 DBG("Timed out.\n");
Michael J. Spencer 1:f5ac63519541 645 onResult(HTTP_TIMEOUT);
Michael J. Spencer 1:f5ac63519541 646 close();
Michael J. Spencer 1:f5ac63519541 647 }
Michael J. Spencer 1:f5ac63519541 648
Michael J. Spencer 1:f5ac63519541 649 //Headers
Michael J. Spencer 1:f5ac63519541 650
Michael J. Spencer 1:f5ac63519541 651 //TODO: Factorize w/ HTTPRequestHandler in a single HTTPHeader class
Michael J. Spencer 1:f5ac63519541 652
Michael J. Spencer 1:f5ac63519541 653 HTTPResult HTTPClient::blockingProcess() //Called in blocking mode, calls Net::poll() until return code is available
Michael J. Spencer 1:f5ac63519541 654 {
Michael J. Spencer 1:f5ac63519541 655 //Disable callbacks
Michael J. Spencer 1:f5ac63519541 656 m_pCb = NULL;
Michael J. Spencer 1:f5ac63519541 657 m_pCbItem = NULL;
Michael J. Spencer 1:f5ac63519541 658 m_pCbMeth = NULL;
Michael J. Spencer 1:f5ac63519541 659 m_blockingResult = HTTP_PROCESSING;
Michael J. Spencer 1:f5ac63519541 660 do
Michael J. Spencer 1:f5ac63519541 661 {
Michael J. Spencer 1:f5ac63519541 662 Net::poll();
Michael J. Spencer 1:f5ac63519541 663 } while(m_blockingResult == HTTP_PROCESSING);
Michael J. Spencer 1:f5ac63519541 664 Net::poll(); //Necessary for cleanup
Michael J. Spencer 1:f5ac63519541 665 return m_blockingResult;
Michael J. Spencer 1:f5ac63519541 666 }
Michael J. Spencer 1:f5ac63519541 667
Michael J. Spencer 1:f5ac63519541 668 bool HTTPClient::readHeaders()
Michael J. Spencer 1:f5ac63519541 669 {
Michael J. Spencer 1:f5ac63519541 670 static char* line = m_buf;
Michael J. Spencer 1:f5ac63519541 671 static char key[128];
Michael J. Spencer 1:f5ac63519541 672 static char value[128];
Michael J. Spencer 1:f5ac63519541 673 if(!m_dataLen) //No incomplete header in buffer, this is the first time we read data
Michael J. Spencer 1:f5ac63519541 674 {
Michael J. Spencer 1:f5ac63519541 675 if( readLine(line, 128) > 0 )
Michael J. Spencer 1:f5ac63519541 676 {
Michael J. Spencer 1:f5ac63519541 677 //Check RC
Michael J. Spencer 1:f5ac63519541 678 m_httpResponseCode = 0;
Michael J. Spencer 1:f5ac63519541 679 if( sscanf(line, "HTTP/%*d.%*d %d %*[^\r\n]", &m_httpResponseCode) != 1 )
Michael J. Spencer 1:f5ac63519541 680 {
Michael J. Spencer 1:f5ac63519541 681 //Cannot match string, error
Michael J. Spencer 1:f5ac63519541 682 DBG("Not a correct HTTP answer : %s\n", line);
Michael J. Spencer 1:f5ac63519541 683 onResult(HTTP_PRTCL);
Michael J. Spencer 1:f5ac63519541 684 close();
Michael J. Spencer 1:f5ac63519541 685 return false;
Michael J. Spencer 1:f5ac63519541 686 }
Michael J. Spencer 1:f5ac63519541 687
Michael J. Spencer 1:f5ac63519541 688 if(m_httpResponseCode != 200)
Michael J. Spencer 1:f5ac63519541 689 {
Michael J. Spencer 1:f5ac63519541 690 DBG("Response: error code %d\n", m_httpResponseCode);
Michael J. Spencer 1:f5ac63519541 691 HTTPResult res = HTTP_ERROR;
Michael J. Spencer 1:f5ac63519541 692 switch(m_httpResponseCode)
Michael J. Spencer 1:f5ac63519541 693 {
Michael J. Spencer 1:f5ac63519541 694 case 404:
Michael J. Spencer 1:f5ac63519541 695 res = HTTP_NOTFOUND;
Michael J. Spencer 1:f5ac63519541 696 break;
Michael J. Spencer 1:f5ac63519541 697 case 403:
Michael J. Spencer 1:f5ac63519541 698 res = HTTP_REFUSED;
Michael J. Spencer 1:f5ac63519541 699 break;
Michael J. Spencer 1:f5ac63519541 700 default:
Michael J. Spencer 1:f5ac63519541 701 res = HTTP_ERROR;
Michael J. Spencer 1:f5ac63519541 702 }
Michael J. Spencer 1:f5ac63519541 703 onResult(res);
Michael J. Spencer 1:f5ac63519541 704 close();
Michael J. Spencer 1:f5ac63519541 705 return false;
Michael J. Spencer 1:f5ac63519541 706 }
Michael J. Spencer 1:f5ac63519541 707 DBG("Response OK\n");
Michael J. Spencer 1:f5ac63519541 708 }
Michael J. Spencer 1:f5ac63519541 709 else
Michael J. Spencer 1:f5ac63519541 710 {
Michael J. Spencer 1:f5ac63519541 711 //Empty packet, weird!
Michael J. Spencer 1:f5ac63519541 712 DBG("Empty packet!\n");
Michael J. Spencer 1:f5ac63519541 713 onResult(HTTP_PRTCL);
Michael J. Spencer 1:f5ac63519541 714 close();
Michael J. Spencer 1:f5ac63519541 715 return false;
Michael J. Spencer 1:f5ac63519541 716 }
Michael J. Spencer 1:f5ac63519541 717 }
Michael J. Spencer 1:f5ac63519541 718 bool incomplete = false;
Michael J. Spencer 1:f5ac63519541 719 while( true )
Michael J. Spencer 1:f5ac63519541 720 {
Michael J. Spencer 1:f5ac63519541 721 int readLen = readLine(line + m_dataLen, 128 - m_dataLen, &incomplete);
Michael J. Spencer 1:f5ac63519541 722 m_dataLen = 0;
Michael J. Spencer 1:f5ac63519541 723 if( readLen <= 2 ) //if == 1 or 2, it is an empty line = end of headers
Michael J. Spencer 1:f5ac63519541 724 {
Michael J. Spencer 1:f5ac63519541 725 DBG("All headers read.\n");
Michael J. Spencer 1:f5ac63519541 726 m_state = HTTP_READ_DATA;
Michael J. Spencer 1:f5ac63519541 727 break;
Michael J. Spencer 1:f5ac63519541 728 }
Michael J. Spencer 1:f5ac63519541 729 else if( incomplete == true )
Michael J. Spencer 1:f5ac63519541 730 {
Michael J. Spencer 1:f5ac63519541 731 m_dataLen = readLen;//Sets data length available in buffer
Michael J. Spencer 1:f5ac63519541 732 return false;
Michael J. Spencer 1:f5ac63519541 733 }
Michael J. Spencer 1:f5ac63519541 734 //DBG("Header : %s\n", line);
Michael J. Spencer 1:f5ac63519541 735 int n = sscanf(line, "%[^:] : %[^\r\n]", key, value);
Michael J. Spencer 1:f5ac63519541 736 if ( n == 2 )
Michael J. Spencer 1:f5ac63519541 737 {
Michael J. Spencer 1:f5ac63519541 738 DBG("Read header : %s: %s\n", key, value);
Michael J. Spencer 1:f5ac63519541 739 m_respHeaders[key] = value;
Michael J. Spencer 1:f5ac63519541 740 }
Michael J. Spencer 1:f5ac63519541 741 //TODO: Impl n==1 case (part 2 of previous header)
Michael J. Spencer 1:f5ac63519541 742 }
Michael J. Spencer 1:f5ac63519541 743
Michael J. Spencer 1:f5ac63519541 744 return true;
Michael J. Spencer 1:f5ac63519541 745 }
Michael J. Spencer 1:f5ac63519541 746
Michael J. Spencer 1:f5ac63519541 747 bool HTTPClient::writeHeaders() //Called at the first writeData call
Michael J. Spencer 1:f5ac63519541 748 {
Michael J. Spencer 1:f5ac63519541 749 static char* line = m_buf;
Michael J. Spencer 1:f5ac63519541 750 const char* HTTP_METH_STR[] = {"GET", "POST", "HEAD"};
Michael J. Spencer 1:f5ac63519541 751
Michael J. Spencer 1:f5ac63519541 752 //Req
Michael J. Spencer 1:f5ac63519541 753 sprintf(line, "%s %s HTTP/1.1\r\nHost: %s\r\n", HTTP_METH_STR[m_meth], m_path.c_str(), m_server.getName()); //Write request
Michael J. Spencer 1:f5ac63519541 754 m_pTCPSocket->send(line, strlen(line));
Michael J. Spencer 1:f5ac63519541 755 DBG("Request: %s\n", line);
Michael J. Spencer 1:f5ac63519541 756
Michael J. Spencer 1:f5ac63519541 757 DBG("Writing headers:\n");
Michael J. Spencer 1:f5ac63519541 758 map<string,string>::iterator it;
Michael J. Spencer 1:f5ac63519541 759 for( it = m_reqHeaders.begin(); it != m_reqHeaders.end(); it++ )
Michael J. Spencer 1:f5ac63519541 760 {
Michael J. Spencer 1:f5ac63519541 761 sprintf(line, "%s: %s\r\n", (*it).first.c_str(), (*it).second.c_str() );
Michael J. Spencer 1:f5ac63519541 762 DBG("\r\n%s", line);
Michael J. Spencer 1:f5ac63519541 763 m_pTCPSocket->send(line, strlen(line));
Michael J. Spencer 1:f5ac63519541 764 }
Michael J. Spencer 1:f5ac63519541 765 m_pTCPSocket->send("\r\n",2); //End of head
Michael J. Spencer 1:f5ac63519541 766 m_state = HTTP_WRITE_DATA;
Michael J. Spencer 1:f5ac63519541 767 return true;
Michael J. Spencer 1:f5ac63519541 768 }
Michael J. Spencer 1:f5ac63519541 769
Michael J. Spencer 1:f5ac63519541 770 int HTTPClient::readLine(char* str, int maxLen, bool* pIncomplete /* = NULL*/)
Michael J. Spencer 1:f5ac63519541 771 {
Michael J. Spencer 1:f5ac63519541 772 int ret;
Michael J. Spencer 1:f5ac63519541 773 int len = 0;
Michael J. Spencer 1:f5ac63519541 774 if(pIncomplete)
Michael J. Spencer 1:f5ac63519541 775 *pIncomplete = false;
Michael J. Spencer 1:f5ac63519541 776 for(int i = 0; i < maxLen - 1; i++)
Michael J. Spencer 1:f5ac63519541 777 {
Michael J. Spencer 1:f5ac63519541 778 ret = m_pTCPSocket->recv(str, 1);
Michael J. Spencer 1:f5ac63519541 779 if(ret != 1)
Michael J. Spencer 1:f5ac63519541 780 {
Michael J. Spencer 1:f5ac63519541 781 if(pIncomplete)
Michael J. Spencer 1:f5ac63519541 782 *pIncomplete = true;
Michael J. Spencer 1:f5ac63519541 783 break;
Michael J. Spencer 1:f5ac63519541 784 }
Michael J. Spencer 1:f5ac63519541 785 if( (len > 1) && *(str-1)=='\r' && *str=='\n' )
Michael J. Spencer 1:f5ac63519541 786 {
Michael J. Spencer 1:f5ac63519541 787 break;
Michael J. Spencer 1:f5ac63519541 788 }
Michael J. Spencer 1:f5ac63519541 789 else if( *str=='\n' )
Michael J. Spencer 1:f5ac63519541 790 {
Michael J. Spencer 1:f5ac63519541 791 break;
Michael J. Spencer 1:f5ac63519541 792 }
Michael J. Spencer 1:f5ac63519541 793 str++;
Michael J. Spencer 1:f5ac63519541 794 len++;
Michael J. Spencer 1:f5ac63519541 795 }
Michael J. Spencer 1:f5ac63519541 796 *str = 0;
Michael J. Spencer 1:f5ac63519541 797 return len;
Michael J. Spencer 1:f5ac63519541 798 }