smd.iotkit2.ch / Mbed 2 deprecated 2-10-01-Uebung

10.1 Kombiniert die Übung 6.4 Wenn sich jemand nähert, Lauflicht einschalten mit dem Yahoo Weather Dienst, dass bei Unterwarnungen das Lauflicht eingeschaltet wird.

Dependencies:   EthernetInterface mbed-rtos mbed spxml

Fork of YahooWeather by smd.iotkit2.ch

HTTPClient/HTTPClient.cpp@6:735d5412de0d, 2015-05-27 (annotated)

Committer:
stefan1691
Date:
Wed May 27 17:23:55 2015 +0000
Revision:
6:735d5412de0d
Parent:
2:c9e058ee6f87 
10.1 Kombiniert die ?bung 6.4 Wenn sich jemand n?hert, Lauflicht einschalten mit dem Yahoo Weather Dienst, dass bei Unterwarnungen das Lauflicht eingeschaltet wird.

Who changed what in which revision?

UserRevisionLine numberNew contents of line
marcel1691 1:2e29a33cd918 1 /* HTTPClient.cpp */
marcel1691 1:2e29a33cd918 2 /* Copyright (C) 2012 mbed.org, MIT License
marcel1691 1:2e29a33cd918 3 *
marcel1691 1:2e29a33cd918 4 * Permission is hereby granted, free of charge, to any person obtaining a copy of this software
marcel1691 1:2e29a33cd918 5 * and associated documentation files (the "Software"), to deal in the Software without restriction,
marcel1691 1:2e29a33cd918 6 * including without limitation the rights to use, copy, modify, merge, publish, distribute,
marcel1691 1:2e29a33cd918 7 * sublicense, and/or sell copies of the Software, and to permit persons to whom the Software is
marcel1691 1:2e29a33cd918 8 * furnished to do so, subject to the following conditions:
marcel1691 1:2e29a33cd918 9 *
marcel1691 1:2e29a33cd918 10 * The above copyright notice and this permission notice shall be included in all copies or
marcel1691 1:2e29a33cd918 11 * substantial portions of the Software.
marcel1691 1:2e29a33cd918 12 *
marcel1691 1:2e29a33cd918 13 * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR IMPLIED, INCLUDING
marcel1691 1:2e29a33cd918 14 * BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND
marcel1691 1:2e29a33cd918 15 * NONINFRINGEMENT. IN NO EVENT SHALL THE AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM,
marcel1691 1:2e29a33cd918 16 * DAMAGES OR OTHER LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
marcel1691 1:2e29a33cd918 17 * OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.
marcel1691 1:2e29a33cd918 18 */
marcel1691 1:2e29a33cd918 19
marcel1691 1:2e29a33cd918 20 //Debug is disabled by default
marcel1691 1:2e29a33cd918 21 //#define DEBUG "HTCL"
marcel1691 1:2e29a33cd918 22 #include <cstdio>
marcel1691 1:2e29a33cd918 23 #if (defined(DEBUG) && !defined(TARGET_LPC11U24))
marcel1691 1:2e29a33cd918 24 #define DBG(x, ...) std::printf("[DBG %s %3d] "x"\r\n", DEBUG, __LINE__, ##__VA_ARGS__);
marcel1691 1:2e29a33cd918 25 #define WARN(x, ...) std::printf("[WRN %s %3d] "x"\r\n", DEBUG, __LINE__, ##__VA_ARGS__);
marcel1691 1:2e29a33cd918 26 #define ERR(x, ...) std::printf("[ERR %s %3d] "x"\r\n", DEBUG, __LINE__, ##__VA_ARGS__);
marcel1691 1:2e29a33cd918 27 #define INFO(x, ...) std::printf("[INF %s %3d] "x"\r\n", DEBUG, __LINE__, ##__VA_ARGS__);
marcel1691 1:2e29a33cd918 28 #else
marcel1691 1:2e29a33cd918 29 #define DBG(x, ...)
marcel1691 1:2e29a33cd918 30 #define WARN(x, ...)
marcel1691 1:2e29a33cd918 31 #define ERR(x, ...)
marcel1691 1:2e29a33cd918 32 #define INFO(x, ...)
marcel1691 1:2e29a33cd918 33 #endif
marcel1691 1:2e29a33cd918 34
marcel1691 1:2e29a33cd918 35 //#define HTTP_PORT 80
marcel1691 1:2e29a33cd918 36
marcel1691 1:2e29a33cd918 37 #define OK 0
marcel1691 1:2e29a33cd918 38
marcel1691 1:2e29a33cd918 39 #define MIN(x,y) (((x)<(y))?(x):(y))
marcel1691 1:2e29a33cd918 40 #define MAX(x,y) (((x)>(y))?(x):(y))
marcel1691 1:2e29a33cd918 41
marcel1691 1:2e29a33cd918 42 #define CHUNK_SIZE 256
marcel1691 1:2e29a33cd918 43 #define MAXLEN_VALUE 120 /* Max URL and Max Value for Name:Value */
marcel1691 1:2e29a33cd918 44
marcel1691 1:2e29a33cd918 45 #include <cstring>
marcel1691 1:2e29a33cd918 46
marcel1691 1:2e29a33cd918 47 #include "HTTPClient.h"
marcel1691 1:2e29a33cd918 48
marcel1691 1:2e29a33cd918 49 HTTPClient::HTTPClient() :
marcel1691 1:2e29a33cd918 50 m_sock(), m_basicAuthUser(NULL), m_basicAuthPassword(NULL),
marcel1691 1:2e29a33cd918 51 m_nCustomHeaders(0), m_httpResponseCode(0),
marcel1691 1:2e29a33cd918 52 m_maxredirections(1), m_location(NULL)
marcel1691 1:2e29a33cd918 53 {
marcel1691 1:2e29a33cd918 54
marcel1691 1:2e29a33cd918 55 }
marcel1691 1:2e29a33cd918 56
marcel1691 1:2e29a33cd918 57 HTTPClient::~HTTPClient()
marcel1691 1:2e29a33cd918 58 {
marcel1691 1:2e29a33cd918 59
marcel1691 1:2e29a33cd918 60 }
marcel1691 1:2e29a33cd918 61
marcel1691 1:2e29a33cd918 62 void HTTPClient::basicAuth(const char* user, const char* password) //Basic Authentification
marcel1691 1:2e29a33cd918 63 {
marcel1691 1:2e29a33cd918 64 #if 1
marcel1691 1:2e29a33cd918 65 if (m_basicAuthUser)
marcel1691 1:2e29a33cd918 66 free(m_basicAuthUser);
marcel1691 1:2e29a33cd918 67 m_basicAuthUser = (char *)malloc(strlen(user)+1);
marcel1691 1:2e29a33cd918 68 strcpy(m_basicAuthUser, user);
marcel1691 1:2e29a33cd918 69 if (m_basicAuthPassword)
marcel1691 1:2e29a33cd918 70 free(m_basicAuthPassword);
marcel1691 1:2e29a33cd918 71 m_basicAuthPassword = (char *)malloc(strlen(password)+1);
marcel1691 1:2e29a33cd918 72 strcpy(m_basicAuthPassword, password);
marcel1691 1:2e29a33cd918 73 #else
marcel1691 1:2e29a33cd918 74 m_basicAuthUser = user;
marcel1691 1:2e29a33cd918 75 m_basicAuthPassword = password;
marcel1691 1:2e29a33cd918 76 #endif
marcel1691 1:2e29a33cd918 77 }
marcel1691 1:2e29a33cd918 78
marcel1691 1:2e29a33cd918 79 void HTTPClient::customHeaders(const char **headers, size_t pairs)
marcel1691 1:2e29a33cd918 80 {
marcel1691 1:2e29a33cd918 81 m_customHeaders = headers;
marcel1691 1:2e29a33cd918 82 m_nCustomHeaders = pairs;
marcel1691 1:2e29a33cd918 83 }
marcel1691 1:2e29a33cd918 84
marcel1691 1:2e29a33cd918 85
marcel1691 1:2e29a33cd918 86 HTTPResult HTTPClient::get(const char* url, IHTTPDataIn* pDataIn, int timeout /*= HTTP_CLIENT_DEFAULT_TIMEOUT*/) //Blocking
marcel1691 1:2e29a33cd918 87 {
marcel1691 1:2e29a33cd918 88 return connect(url, HTTP_GET, NULL, pDataIn, timeout);
marcel1691 1:2e29a33cd918 89 }
marcel1691 1:2e29a33cd918 90
marcel1691 1:2e29a33cd918 91 HTTPResult HTTPClient::get(const char* url, char* result, size_t maxResultLen, int timeout /*= HTTP_CLIENT_DEFAULT_TIMEOUT*/) //Blocking
marcel1691 1:2e29a33cd918 92 {
marcel1691 1:2e29a33cd918 93 HTTPText str(result, maxResultLen);
marcel1691 1:2e29a33cd918 94 return get(url, &str, timeout);
marcel1691 1:2e29a33cd918 95 }
marcel1691 1:2e29a33cd918 96
marcel1691 1:2e29a33cd918 97 HTTPResult HTTPClient::post(const char* url, const IHTTPDataOut& dataOut, IHTTPDataIn* pDataIn, int timeout /*= HTTP_CLIENT_DEFAULT_TIMEOUT*/) //Blocking
marcel1691 1:2e29a33cd918 98 {
marcel1691 1:2e29a33cd918 99 return connect(url, HTTP_POST, (IHTTPDataOut*)&dataOut, pDataIn, timeout);
marcel1691 1:2e29a33cd918 100 }
marcel1691 1:2e29a33cd918 101
marcel1691 1:2e29a33cd918 102 HTTPResult HTTPClient::put(const char* url, const IHTTPDataOut& dataOut, IHTTPDataIn* pDataIn, int timeout /*= HTTP_CLIENT_DEFAULT_TIMEOUT*/) //Blocking
marcel1691 1:2e29a33cd918 103 {
marcel1691 1:2e29a33cd918 104 return connect(url, HTTP_PUT, (IHTTPDataOut*)&dataOut, pDataIn, timeout);
marcel1691 1:2e29a33cd918 105 }
marcel1691 1:2e29a33cd918 106
marcel1691 1:2e29a33cd918 107 HTTPResult HTTPClient::del(const char* url, IHTTPDataIn* pDataIn, int timeout /*= HTTP_CLIENT_DEFAULT_TIMEOUT*/) //Blocking
marcel1691 1:2e29a33cd918 108 {
marcel1691 1:2e29a33cd918 109 return connect(url, HTTP_DELETE, NULL, pDataIn, timeout);
marcel1691 1:2e29a33cd918 110 }
marcel1691 1:2e29a33cd918 111
marcel1691 1:2e29a33cd918 112
marcel1691 1:2e29a33cd918 113 int HTTPClient::getHTTPResponseCode()
marcel1691 1:2e29a33cd918 114 {
marcel1691 1:2e29a33cd918 115 return m_httpResponseCode;
marcel1691 1:2e29a33cd918 116 }
marcel1691 1:2e29a33cd918 117
marcel1691 1:2e29a33cd918 118 void HTTPClient::setMaxRedirections(int i)
marcel1691 1:2e29a33cd918 119 {
marcel1691 1:2e29a33cd918 120 if (i < 1)
marcel1691 1:2e29a33cd918 121 i = 1;
marcel1691 1:2e29a33cd918 122 m_maxredirections = i;
marcel1691 1:2e29a33cd918 123 }
marcel1691 1:2e29a33cd918 124
marcel1691 1:2e29a33cd918 125 #define CHECK_CONN_ERR(ret) \
marcel1691 1:2e29a33cd918 126 do{ \
marcel1691 1:2e29a33cd918 127 if(ret) { \
marcel1691 1:2e29a33cd918 128 m_sock.close(); \
marcel1691 1:2e29a33cd918 129 ERR("Connection error (%d)", ret); \
marcel1691 1:2e29a33cd918 130 return HTTP_CONN; \
marcel1691 1:2e29a33cd918 131 } \
marcel1691 1:2e29a33cd918 132 } while(0)
marcel1691 1:2e29a33cd918 133
marcel1691 1:2e29a33cd918 134 #define PRTCL_ERR() \
marcel1691 1:2e29a33cd918 135 do{ \
marcel1691 1:2e29a33cd918 136 m_sock.close(); \
marcel1691 1:2e29a33cd918 137 ERR("Protocol error"); \
marcel1691 1:2e29a33cd918 138 return HTTP_PRTCL; \
marcel1691 1:2e29a33cd918 139 } while(0)
marcel1691 1:2e29a33cd918 140
marcel1691 1:2e29a33cd918 141 HTTPResult HTTPClient::connect(const char* url, HTTP_METH method, IHTTPDataOut* pDataOut, IHTTPDataIn* pDataIn, int timeout) //Execute request
marcel1691 1:2e29a33cd918 142 {
marcel1691 1:2e29a33cd918 143 m_httpResponseCode = 0; //Invalidate code
marcel1691 1:2e29a33cd918 144 m_timeout = timeout;
marcel1691 1:2e29a33cd918 145
marcel1691 1:2e29a33cd918 146 pDataIn->writeReset();
marcel1691 1:2e29a33cd918 147 if( pDataOut ) {
marcel1691 1:2e29a33cd918 148 pDataOut->readReset();
marcel1691 1:2e29a33cd918 149 }
marcel1691 1:2e29a33cd918 150
marcel1691 1:2e29a33cd918 151 char scheme[8];
marcel1691 1:2e29a33cd918 152 uint16_t port;
marcel1691 1:2e29a33cd918 153 char host[32];
marcel1691 1:2e29a33cd918 154 char path[MAXLEN_VALUE];
marcel1691 1:2e29a33cd918 155 size_t recvContentLength = 0;
marcel1691 1:2e29a33cd918 156 bool recvChunked = false;
marcel1691 1:2e29a33cd918 157 int crlfPos = 0;
marcel1691 1:2e29a33cd918 158 char buf[CHUNK_SIZE];
marcel1691 1:2e29a33cd918 159 size_t trfLen;
marcel1691 1:2e29a33cd918 160 int ret = 0;
marcel1691 1:2e29a33cd918 161
marcel1691 1:2e29a33cd918 162 int maxRedirect = m_maxredirections;
marcel1691 1:2e29a33cd918 163
marcel1691 1:2e29a33cd918 164 while (maxRedirect--) {
marcel1691 1:2e29a33cd918 165 bool takeRedirect = false;
marcel1691 1:2e29a33cd918 166
marcel1691 1:2e29a33cd918 167 INFO("parse: [%s]", url);
marcel1691 1:2e29a33cd918 168 //First we need to parse the url (http[s]://host[:port][/[path]]) -- HTTPS not supported (yet?)
marcel1691 1:2e29a33cd918 169 HTTPResult res = parseURL(url, scheme, sizeof(scheme), host, sizeof(host), &port, path, sizeof(path));
marcel1691 1:2e29a33cd918 170 if(res != HTTP_OK) {
marcel1691 1:2e29a33cd918 171 ERR("parseURL returned %d", res);
marcel1691 1:2e29a33cd918 172 return res;
marcel1691 1:2e29a33cd918 173 }
marcel1691 1:2e29a33cd918 174
marcel1691 1:2e29a33cd918 175 if(port == 0) { //TODO do handle HTTPS->443
marcel1691 1:2e29a33cd918 176 port = 80;
marcel1691 1:2e29a33cd918 177 }
marcel1691 1:2e29a33cd918 178
marcel1691 1:2e29a33cd918 179 DBG("Scheme: %s", scheme);
marcel1691 1:2e29a33cd918 180 DBG("Host: %s", host);
marcel1691 1:2e29a33cd918 181 DBG("Port: %d", port);
marcel1691 1:2e29a33cd918 182 DBG("Path: %s", path);
marcel1691 1:2e29a33cd918 183
marcel1691 1:2e29a33cd918 184 //Connect
marcel1691 1:2e29a33cd918 185 DBG("Connecting socket to server");
marcel1691 1:2e29a33cd918 186 ret = m_sock.connect(host, port);
marcel1691 1:2e29a33cd918 187 if (ret < 0) {
marcel1691 1:2e29a33cd918 188 m_sock.close();
marcel1691 1:2e29a33cd918 189 ERR("Could not connect");
marcel1691 1:2e29a33cd918 190 return HTTP_CONN;
marcel1691 1:2e29a33cd918 191 }
marcel1691 1:2e29a33cd918 192
marcel1691 1:2e29a33cd918 193 //Send request
marcel1691 1:2e29a33cd918 194 DBG("Sending request");
marcel1691 1:2e29a33cd918 195 const char* meth = (method==HTTP_GET)?"GET":(method==HTTP_POST)?"POST":(method==HTTP_PUT)?"PUT":(method==HTTP_DELETE)?"DELETE":"";
marcel1691 1:2e29a33cd918 196 snprintf(buf, sizeof(buf), "%s %s HTTP/1.1\r\nHost: %s:%d\r\nConnection: keep-alive\r\n", meth, path, host, port); //Write request
marcel1691 1:2e29a33cd918 197 INFO(" buf{%s}", buf);
marcel1691 1:2e29a33cd918 198 ret = send(buf);
marcel1691 1:2e29a33cd918 199 if (ret) {
marcel1691 1:2e29a33cd918 200 m_sock.close();
marcel1691 1:2e29a33cd918 201 ERR("Could not write request");
marcel1691 1:2e29a33cd918 202 return HTTP_CONN;
marcel1691 1:2e29a33cd918 203 }
marcel1691 1:2e29a33cd918 204
marcel1691 1:2e29a33cd918 205 // send authorization
marcel1691 1:2e29a33cd918 206 INFO("send auth (if defined)");
marcel1691 1:2e29a33cd918 207 if (m_basicAuthUser && m_basicAuthPassword) {
marcel1691 1:2e29a33cd918 208 strcpy(buf, "Authorization: Basic ");
marcel1691 1:2e29a33cd918 209 createauth(m_basicAuthUser, m_basicAuthPassword, buf+strlen(buf), sizeof(buf)-strlen(buf));
marcel1691 1:2e29a33cd918 210 strcat(buf, "\r\n");
marcel1691 1:2e29a33cd918 211 INFO(" (%s,%s) => (%s)", m_basicAuthUser, m_basicAuthPassword, buf);
marcel1691 1:2e29a33cd918 212 ret = send(buf);
marcel1691 1:2e29a33cd918 213 INFO(" ret = %d", ret);
marcel1691 1:2e29a33cd918 214 if(ret) {
marcel1691 1:2e29a33cd918 215 m_sock.close();
marcel1691 1:2e29a33cd918 216 ERR("Could not write request");
marcel1691 1:2e29a33cd918 217 return HTTP_CONN;
marcel1691 1:2e29a33cd918 218 }
marcel1691 1:2e29a33cd918 219 }
marcel1691 1:2e29a33cd918 220
marcel1691 1:2e29a33cd918 221 //Send all headers
marcel1691 1:2e29a33cd918 222 INFO("Send custom header(s) %d (if any)", m_nCustomHeaders);
marcel1691 1:2e29a33cd918 223 for (size_t nh = 0; nh < m_nCustomHeaders * 2; nh+=2) {
marcel1691 1:2e29a33cd918 224 INFO("hdr[%d] %s:", nh, m_customHeaders[nh]);
marcel1691 1:2e29a33cd918 225 INFO(" %s", m_customHeaders[nh+1]);
marcel1691 1:2e29a33cd918 226 snprintf(buf, sizeof(buf), "%s: %s\r\n", m_customHeaders[nh], m_customHeaders[nh+1]);
marcel1691 1:2e29a33cd918 227 ret = send(buf);
marcel1691 1:2e29a33cd918 228 if (ret) {
marcel1691 1:2e29a33cd918 229 ERR("closing");
marcel1691 1:2e29a33cd918 230 wait_ms(50);
marcel1691 1:2e29a33cd918 231 m_sock.close();
marcel1691 1:2e29a33cd918 232 ERR("Could not write request");
marcel1691 1:2e29a33cd918 233 return HTTP_CONN;
marcel1691 1:2e29a33cd918 234 }
marcel1691 1:2e29a33cd918 235 INFO(" hdr %d", ret);
marcel1691 1:2e29a33cd918 236 }
marcel1691 1:2e29a33cd918 237
marcel1691 1:2e29a33cd918 238 //Send default headers
marcel1691 1:2e29a33cd918 239 DBG("Sending headers");
marcel1691 1:2e29a33cd918 240 if( pDataOut != NULL ) {
marcel1691 1:2e29a33cd918 241 if( pDataOut->getIsChunked() ) {
marcel1691 1:2e29a33cd918 242 ret = send("Transfer-Encoding: chunked\r\n");
marcel1691 1:2e29a33cd918 243 CHECK_CONN_ERR(ret);
marcel1691 1:2e29a33cd918 244 } else {
marcel1691 1:2e29a33cd918 245 snprintf(buf, sizeof(buf), "Content-Length: %d\r\n", pDataOut->getDataLen());
marcel1691 1:2e29a33cd918 246 ret = send(buf);
marcel1691 1:2e29a33cd918 247 CHECK_CONN_ERR(ret);
marcel1691 1:2e29a33cd918 248 }
marcel1691 1:2e29a33cd918 249 char type[48];
marcel1691 1:2e29a33cd918 250 if( pDataOut->getDataType(type, 48) == HTTP_OK ) {
marcel1691 1:2e29a33cd918 251 snprintf(buf, sizeof(buf), "Content-Type: %s\r\n", type);
marcel1691 1:2e29a33cd918 252 ret = send(buf);
marcel1691 1:2e29a33cd918 253 CHECK_CONN_ERR(ret);
marcel1691 1:2e29a33cd918 254 }
marcel1691 1:2e29a33cd918 255 }
marcel1691 1:2e29a33cd918 256
marcel1691 1:2e29a33cd918 257 //Close headers
marcel1691 1:2e29a33cd918 258 DBG("Headers sent");
marcel1691 1:2e29a33cd918 259 ret = send("\r\n");
marcel1691 1:2e29a33cd918 260 CHECK_CONN_ERR(ret);
marcel1691 1:2e29a33cd918 261
marcel1691 1:2e29a33cd918 262 //Send data (if available)
marcel1691 1:2e29a33cd918 263 if( pDataOut != NULL ) {
marcel1691 1:2e29a33cd918 264 DBG("Sending data");
marcel1691 1:2e29a33cd918 265 while(true) {
marcel1691 1:2e29a33cd918 266 size_t writtenLen = 0;
marcel1691 1:2e29a33cd918 267 pDataOut->read(buf, CHUNK_SIZE, &trfLen);
marcel1691 1:2e29a33cd918 268 if( pDataOut->getIsChunked() ) {
marcel1691 1:2e29a33cd918 269 //Write chunk header
marcel1691 1:2e29a33cd918 270 char chunkHeader[16];
marcel1691 1:2e29a33cd918 271 snprintf(chunkHeader, sizeof(chunkHeader), "%X\r\n", trfLen); //In hex encoding
marcel1691 1:2e29a33cd918 272 ret = send(chunkHeader);
marcel1691 1:2e29a33cd918 273 CHECK_CONN_ERR(ret);
marcel1691 1:2e29a33cd918 274 } else if( trfLen == 0 ) {
marcel1691 1:2e29a33cd918 275 break;
marcel1691 1:2e29a33cd918 276 }
marcel1691 1:2e29a33cd918 277 if( trfLen != 0 ) {
marcel1691 1:2e29a33cd918 278 ret = send(buf, trfLen);
marcel1691 1:2e29a33cd918 279 CHECK_CONN_ERR(ret);
marcel1691 1:2e29a33cd918 280 }
marcel1691 1:2e29a33cd918 281
marcel1691 1:2e29a33cd918 282 if( pDataOut->getIsChunked() ) {
marcel1691 1:2e29a33cd918 283 ret = send("\r\n"); //Chunk-terminating CRLF
marcel1691 1:2e29a33cd918 284 CHECK_CONN_ERR(ret);
marcel1691 1:2e29a33cd918 285 } else {
marcel1691 1:2e29a33cd918 286 writtenLen += trfLen;
marcel1691 1:2e29a33cd918 287 if( writtenLen >= pDataOut->getDataLen() ) {
marcel1691 1:2e29a33cd918 288 break;
marcel1691 1:2e29a33cd918 289 }
marcel1691 1:2e29a33cd918 290 }
marcel1691 1:2e29a33cd918 291
marcel1691 1:2e29a33cd918 292 if( trfLen == 0 ) {
marcel1691 1:2e29a33cd918 293 break;
marcel1691 1:2e29a33cd918 294 }
marcel1691 1:2e29a33cd918 295 }
marcel1691 1:2e29a33cd918 296
marcel1691 1:2e29a33cd918 297 }
marcel1691 1:2e29a33cd918 298
marcel1691 1:2e29a33cd918 299 //Receive response
marcel1691 1:2e29a33cd918 300 DBG("Receiving response");
marcel1691 1:2e29a33cd918 301 //ret = recv(buf, CHUNK_SIZE - 1, CHUNK_SIZE - 1, &trfLen); //Read n bytes
marcel1691 1:2e29a33cd918 302 ret = recv(buf, 1, CHUNK_SIZE - 1, &trfLen); // recommended by Rob Noble to avoid timeout wait
marcel1691 1:2e29a33cd918 303 CHECK_CONN_ERR(ret);
marcel1691 1:2e29a33cd918 304 buf[trfLen] = '\0';
marcel1691 1:2e29a33cd918 305 INFO("Received \r\n(%s\r\n)", buf);
marcel1691 1:2e29a33cd918 306
marcel1691 1:2e29a33cd918 307 char* crlfPtr = strstr(buf, "\r\n");
marcel1691 1:2e29a33cd918 308 if( crlfPtr == NULL) {
marcel1691 1:2e29a33cd918 309 PRTCL_ERR();
marcel1691 1:2e29a33cd918 310 }
marcel1691 1:2e29a33cd918 311
marcel1691 1:2e29a33cd918 312 crlfPos = crlfPtr - buf;
marcel1691 1:2e29a33cd918 313 buf[crlfPos] = '\0';
marcel1691 1:2e29a33cd918 314
marcel1691 1:2e29a33cd918 315 //Parse HTTP response
marcel1691 1:2e29a33cd918 316 if( sscanf(buf, "HTTP/%*d.%*d %d %*[^\r\n]", &m_httpResponseCode) != 1 ) {
marcel1691 1:2e29a33cd918 317 //Cannot match string, error
marcel1691 1:2e29a33cd918 318 ERR("Not a correct HTTP answer : {%s}\n", buf);
marcel1691 1:2e29a33cd918 319 PRTCL_ERR();
marcel1691 1:2e29a33cd918 320 }
marcel1691 1:2e29a33cd918 321
marcel1691 1:2e29a33cd918 322 if( (m_httpResponseCode < 200) || (m_httpResponseCode >= 400) ) {
marcel1691 1:2e29a33cd918 323 //Did not return a 2xx code; TODO fetch headers/(&data?) anyway and implement a mean of writing/reading headers
marcel1691 1:2e29a33cd918 324 WARN("Response code %d", m_httpResponseCode);
marcel1691 1:2e29a33cd918 325 PRTCL_ERR();
marcel1691 1:2e29a33cd918 326 }
marcel1691 1:2e29a33cd918 327
marcel1691 1:2e29a33cd918 328 DBG("Reading headers");
marcel1691 1:2e29a33cd918 329
marcel1691 1:2e29a33cd918 330 memmove(buf, &buf[crlfPos+2], trfLen - (crlfPos + 2) + 1); //Be sure to move NULL-terminating char as well
marcel1691 1:2e29a33cd918 331 trfLen -= (crlfPos + 2);
marcel1691 1:2e29a33cd918 332
marcel1691 1:2e29a33cd918 333 recvContentLength = 0;
marcel1691 1:2e29a33cd918 334 recvChunked = false;
marcel1691 1:2e29a33cd918 335 //Now get headers
marcel1691 1:2e29a33cd918 336 while( true ) {
marcel1691 1:2e29a33cd918 337 crlfPtr = strstr(buf, "\r\n");
marcel1691 1:2e29a33cd918 338 if(crlfPtr == NULL) {
marcel1691 1:2e29a33cd918 339 if( trfLen < CHUNK_SIZE - 1 ) {
marcel1691 1:2e29a33cd918 340 size_t newTrfLen = 0;
marcel1691 1:2e29a33cd918 341 ret = recv(buf + trfLen, 1, CHUNK_SIZE - trfLen - 1, &newTrfLen);
marcel1691 1:2e29a33cd918 342 trfLen += newTrfLen;
marcel1691 1:2e29a33cd918 343 buf[trfLen] = '\0';
marcel1691 1:2e29a33cd918 344 DBG("Read %d chars; In buf: [%s]", newTrfLen, buf);
marcel1691 1:2e29a33cd918 345 CHECK_CONN_ERR(ret);
marcel1691 1:2e29a33cd918 346 continue;
marcel1691 1:2e29a33cd918 347 } else {
marcel1691 1:2e29a33cd918 348 PRTCL_ERR();
marcel1691 1:2e29a33cd918 349 }
marcel1691 1:2e29a33cd918 350 }
marcel1691 1:2e29a33cd918 351
marcel1691 1:2e29a33cd918 352 crlfPos = crlfPtr - buf;
marcel1691 1:2e29a33cd918 353
marcel1691 1:2e29a33cd918 354 if(crlfPos == 0) { //End of headers
marcel1691 1:2e29a33cd918 355 DBG("Headers read");
marcel1691 1:2e29a33cd918 356 memmove(buf, &buf[2], trfLen - 2 + 1); //Be sure to move NULL-terminating char as well
marcel1691 1:2e29a33cd918 357 trfLen -= 2;
marcel1691 1:2e29a33cd918 358 break;
marcel1691 1:2e29a33cd918 359 }
marcel1691 1:2e29a33cd918 360
marcel1691 1:2e29a33cd918 361 buf[crlfPos] = '\0';
marcel1691 1:2e29a33cd918 362
marcel1691 2:c9e058ee6f87 363 char key[36];
marcel1691 1:2e29a33cd918 364 char value[MAXLEN_VALUE];
marcel1691 1:2e29a33cd918 365
marcel1691 2:c9e058ee6f87 366 key[35] = '\0';
marcel1691 1:2e29a33cd918 367 value[MAXLEN_VALUE - 1] = '\0';
marcel1691 1:2e29a33cd918 368
marcel1691 2:c9e058ee6f87 369 int n = sscanf(buf, "%35[^:]: %119[^\r\n]", key, value);
marcel1691 1:2e29a33cd918 370 if ( n == 2 ) {
marcel1691 1:2e29a33cd918 371 DBG("Read header : %s: %s", key, value);
marcel1691 1:2e29a33cd918 372 if( !strcmp(key, "Content-Length") ) {
marcel1691 1:2e29a33cd918 373 sscanf(value, "%d", &recvContentLength);
marcel1691 1:2e29a33cd918 374 pDataIn->setDataLen(recvContentLength);
marcel1691 1:2e29a33cd918 375 } else if( !strcmp(key, "Transfer-Encoding") ) {
marcel1691 1:2e29a33cd918 376 if( !strcmp(value, "Chunked") || !strcmp(value, "chunked") ) {
marcel1691 1:2e29a33cd918 377 recvChunked = true;
marcel1691 1:2e29a33cd918 378 pDataIn->setIsChunked(true);
marcel1691 1:2e29a33cd918 379 }
marcel1691 1:2e29a33cd918 380 } else if( !strcmp(key, "Content-Type") ) {
marcel1691 1:2e29a33cd918 381 pDataIn->setDataType(value);
marcel1691 1:2e29a33cd918 382 } else if ( !strcmp(key, "Location") ) {
marcel1691 1:2e29a33cd918 383 if (m_location)
marcel1691 1:2e29a33cd918 384 free(m_location);
marcel1691 1:2e29a33cd918 385 m_location = (char *)malloc(strlen(value)+1);
marcel1691 1:2e29a33cd918 386 if (m_location) {
marcel1691 1:2e29a33cd918 387 strcpy(m_location,value);
marcel1691 1:2e29a33cd918 388 url = m_location;
marcel1691 1:2e29a33cd918 389 INFO("Following redirect[%d] to [%s]", maxRedirect, url);
marcel1691 1:2e29a33cd918 390 m_sock.close();
marcel1691 1:2e29a33cd918 391 takeRedirect = true;
marcel1691 1:2e29a33cd918 392 break; // exit the while(true) header to follow the redirect
marcel1691 1:2e29a33cd918 393 }
marcel1691 1:2e29a33cd918 394 }
marcel1691 1:2e29a33cd918 395
marcel1691 1:2e29a33cd918 396 memmove(buf, &buf[crlfPos+2], trfLen - (crlfPos + 2) + 1); //Be sure to move NULL-terminating char as well
marcel1691 1:2e29a33cd918 397 trfLen -= (crlfPos + 2);
marcel1691 1:2e29a33cd918 398 } else {
marcel1691 1:2e29a33cd918 399 ERR("Could not parse header");
marcel1691 1:2e29a33cd918 400 PRTCL_ERR();
marcel1691 1:2e29a33cd918 401 }
marcel1691 1:2e29a33cd918 402
marcel1691 1:2e29a33cd918 403 } // while(true) // get headers
marcel1691 1:2e29a33cd918 404 if (!takeRedirect)
marcel1691 1:2e29a33cd918 405 break;
marcel1691 1:2e29a33cd918 406 } // while (maxRedirect)
marcel1691 1:2e29a33cd918 407
marcel1691 1:2e29a33cd918 408 //Receive data
marcel1691 1:2e29a33cd918 409 DBG("Receiving data");
marcel1691 1:2e29a33cd918 410 while(true) {
marcel1691 1:2e29a33cd918 411 size_t readLen = 0;
marcel1691 1:2e29a33cd918 412
marcel1691 1:2e29a33cd918 413 if( recvChunked ) {
marcel1691 1:2e29a33cd918 414 //Read chunk header
marcel1691 1:2e29a33cd918 415 bool foundCrlf;
marcel1691 1:2e29a33cd918 416 do {
marcel1691 1:2e29a33cd918 417 foundCrlf = false;
marcel1691 1:2e29a33cd918 418 crlfPos=0;
marcel1691 1:2e29a33cd918 419 buf[trfLen]=0;
marcel1691 1:2e29a33cd918 420 if(trfLen >= 2) {
marcel1691 1:2e29a33cd918 421 for(; crlfPos < trfLen - 2; crlfPos++) {
marcel1691 1:2e29a33cd918 422 if( buf[crlfPos] == '\r' && buf[crlfPos + 1] == '\n' ) {
marcel1691 1:2e29a33cd918 423 foundCrlf = true;
marcel1691 1:2e29a33cd918 424 break;
marcel1691 1:2e29a33cd918 425 }
marcel1691 1:2e29a33cd918 426 }
marcel1691 1:2e29a33cd918 427 }
marcel1691 1:2e29a33cd918 428 if(!foundCrlf) { //Try to read more
marcel1691 1:2e29a33cd918 429 if( trfLen < CHUNK_SIZE ) {
marcel1691 1:2e29a33cd918 430 size_t newTrfLen = 0;
marcel1691 1:2e29a33cd918 431 ret = recv(buf + trfLen, 0, CHUNK_SIZE - trfLen - 1, &newTrfLen);
marcel1691 1:2e29a33cd918 432 trfLen += newTrfLen;
marcel1691 1:2e29a33cd918 433 CHECK_CONN_ERR(ret);
marcel1691 1:2e29a33cd918 434 continue;
marcel1691 1:2e29a33cd918 435 } else {
marcel1691 1:2e29a33cd918 436 PRTCL_ERR();
marcel1691 1:2e29a33cd918 437 }
marcel1691 1:2e29a33cd918 438 }
marcel1691 1:2e29a33cd918 439 } while(!foundCrlf);
marcel1691 1:2e29a33cd918 440 buf[crlfPos] = '\0';
marcel1691 1:2e29a33cd918 441 int n = sscanf(buf, "%x", &readLen);
marcel1691 1:2e29a33cd918 442 if(n!=1) {
marcel1691 1:2e29a33cd918 443 ERR("Could not read chunk length");
marcel1691 1:2e29a33cd918 444 PRTCL_ERR();
marcel1691 1:2e29a33cd918 445 }
marcel1691 1:2e29a33cd918 446
marcel1691 1:2e29a33cd918 447 memmove(buf, &buf[crlfPos+2], trfLen - (crlfPos + 2)); //Not need to move NULL-terminating char any more
marcel1691 1:2e29a33cd918 448 trfLen -= (crlfPos + 2);
marcel1691 1:2e29a33cd918 449
marcel1691 1:2e29a33cd918 450 if( readLen == 0 ) {
marcel1691 1:2e29a33cd918 451 //Last chunk
marcel1691 1:2e29a33cd918 452 break;
marcel1691 1:2e29a33cd918 453 }
marcel1691 1:2e29a33cd918 454 } else {
marcel1691 1:2e29a33cd918 455 readLen = recvContentLength;
marcel1691 1:2e29a33cd918 456 }
marcel1691 1:2e29a33cd918 457
marcel1691 1:2e29a33cd918 458 DBG("Retrieving %d bytes", readLen);
marcel1691 1:2e29a33cd918 459
marcel1691 1:2e29a33cd918 460 do {
marcel1691 1:2e29a33cd918 461 INFO("write %d,%d: %s", trfLen, readLen, buf);
marcel1691 1:2e29a33cd918 462 pDataIn->write(buf, MIN(trfLen, readLen));
marcel1691 1:2e29a33cd918 463 if( trfLen > readLen ) {
marcel1691 1:2e29a33cd918 464 memmove(buf, &buf[readLen], trfLen - readLen);
marcel1691 1:2e29a33cd918 465 trfLen -= readLen;
marcel1691 1:2e29a33cd918 466 readLen = 0;
marcel1691 1:2e29a33cd918 467 } else {
marcel1691 1:2e29a33cd918 468 readLen -= trfLen;
marcel1691 1:2e29a33cd918 469 }
marcel1691 1:2e29a33cd918 470
marcel1691 1:2e29a33cd918 471 if(readLen) {
marcel1691 1:2e29a33cd918 472 ret = recv(buf, 1, CHUNK_SIZE - trfLen - 1, &trfLen);
marcel1691 1:2e29a33cd918 473 CHECK_CONN_ERR(ret);
marcel1691 1:2e29a33cd918 474 }
marcel1691 1:2e29a33cd918 475 } while(readLen);
marcel1691 1:2e29a33cd918 476
marcel1691 1:2e29a33cd918 477 if( recvChunked ) {
marcel1691 1:2e29a33cd918 478 if(trfLen < 2) {
marcel1691 1:2e29a33cd918 479 size_t newTrfLen;
marcel1691 1:2e29a33cd918 480 //Read missing chars to find end of chunk
marcel1691 1:2e29a33cd918 481 INFO("read chunk");
marcel1691 1:2e29a33cd918 482 ret = recv(buf + trfLen, 2 - trfLen, CHUNK_SIZE - trfLen - 1, &newTrfLen);
marcel1691 1:2e29a33cd918 483 CHECK_CONN_ERR(ret);
marcel1691 1:2e29a33cd918 484 trfLen += newTrfLen;
marcel1691 1:2e29a33cd918 485 }
marcel1691 1:2e29a33cd918 486 if( (buf[0] != '\r') || (buf[1] != '\n') ) {
marcel1691 1:2e29a33cd918 487 ERR("Format error");
marcel1691 1:2e29a33cd918 488 PRTCL_ERR();
marcel1691 1:2e29a33cd918 489 }
marcel1691 1:2e29a33cd918 490 memmove(buf, &buf[2], trfLen - 2);
marcel1691 1:2e29a33cd918 491 trfLen -= 2;
marcel1691 1:2e29a33cd918 492 } else {
marcel1691 1:2e29a33cd918 493 break;
marcel1691 1:2e29a33cd918 494 }
marcel1691 1:2e29a33cd918 495
marcel1691 1:2e29a33cd918 496 }
marcel1691 1:2e29a33cd918 497
marcel1691 1:2e29a33cd918 498 m_sock.close();
marcel1691 1:2e29a33cd918 499 DBG("Completed HTTP transaction");
marcel1691 1:2e29a33cd918 500
marcel1691 1:2e29a33cd918 501 return HTTP_OK;
marcel1691 1:2e29a33cd918 502 }
marcel1691 1:2e29a33cd918 503
marcel1691 1:2e29a33cd918 504 HTTPResult HTTPClient::recv(char* buf, size_t minLen, size_t maxLen, size_t* pReadLen) //0 on success, err code on failure
marcel1691 1:2e29a33cd918 505 {
marcel1691 1:2e29a33cd918 506 DBG("Trying to read between %d and %d bytes", minLen, maxLen);
marcel1691 1:2e29a33cd918 507 size_t readLen = 0;
marcel1691 1:2e29a33cd918 508
marcel1691 1:2e29a33cd918 509 if (!m_sock.is_connected()) {
marcel1691 1:2e29a33cd918 510 WARN("Connection was closed by server");
marcel1691 1:2e29a33cd918 511 return HTTP_CLOSED; //Connection was closed by server
marcel1691 1:2e29a33cd918 512 }
marcel1691 1:2e29a33cd918 513
marcel1691 1:2e29a33cd918 514 int ret;
marcel1691 1:2e29a33cd918 515 while (readLen < maxLen) {
marcel1691 1:2e29a33cd918 516 if (readLen < minLen) {
marcel1691 1:2e29a33cd918 517 DBG("Trying to read at most %4d bytes [Blocking] %d,%d", minLen - readLen, minLen, readLen);
marcel1691 1:2e29a33cd918 518 m_sock.set_blocking(false, m_timeout);
marcel1691 1:2e29a33cd918 519 ret = m_sock.receive_all(buf + readLen, minLen - readLen);
marcel1691 1:2e29a33cd918 520 } else {
marcel1691 1:2e29a33cd918 521 DBG("Trying to read at most %4d bytes [Not blocking] %d,%d", maxLen - readLen, maxLen, readLen);
marcel1691 1:2e29a33cd918 522 m_sock.set_blocking(false, 0);
marcel1691 1:2e29a33cd918 523 ret = m_sock.receive(buf + readLen, maxLen - readLen);
marcel1691 1:2e29a33cd918 524 }
marcel1691 1:2e29a33cd918 525
marcel1691 1:2e29a33cd918 526 if (ret > 0) {
marcel1691 1:2e29a33cd918 527 readLen += ret;
marcel1691 1:2e29a33cd918 528 } else if ( ret == 0 ) {
marcel1691 1:2e29a33cd918 529 break;
marcel1691 1:2e29a33cd918 530 } else {
marcel1691 1:2e29a33cd918 531 if (!m_sock.is_connected()) {
marcel1691 1:2e29a33cd918 532 ERR("Connection error (recv returned %d)", ret);
marcel1691 1:2e29a33cd918 533 *pReadLen = readLen;
marcel1691 1:2e29a33cd918 534 return HTTP_CONN;
marcel1691 1:2e29a33cd918 535 } else {
marcel1691 1:2e29a33cd918 536 break;
marcel1691 1:2e29a33cd918 537 }
marcel1691 1:2e29a33cd918 538 }
marcel1691 1:2e29a33cd918 539 if (!m_sock.is_connected()) {
marcel1691 1:2e29a33cd918 540 break;
marcel1691 1:2e29a33cd918 541 }
marcel1691 1:2e29a33cd918 542 }
marcel1691 1:2e29a33cd918 543 DBG("Read %d bytes", readLen);
marcel1691 1:2e29a33cd918 544 buf[readLen] = '\0'; // DS makes it easier to see what's new.
marcel1691 1:2e29a33cd918 545 *pReadLen = readLen;
marcel1691 1:2e29a33cd918 546 return HTTP_OK;
marcel1691 1:2e29a33cd918 547 }
marcel1691 1:2e29a33cd918 548
marcel1691 1:2e29a33cd918 549 HTTPResult HTTPClient::send(char* buf, size_t len) //0 on success, err code on failure
marcel1691 1:2e29a33cd918 550 {
marcel1691 1:2e29a33cd918 551 if(len == 0) {
marcel1691 1:2e29a33cd918 552 len = strlen(buf);
marcel1691 1:2e29a33cd918 553 }
marcel1691 1:2e29a33cd918 554 DBG("send(%s,%d)", buf, len);
marcel1691 1:2e29a33cd918 555 size_t writtenLen = 0;
marcel1691 1:2e29a33cd918 556
marcel1691 1:2e29a33cd918 557 if(!m_sock.is_connected()) {
marcel1691 1:2e29a33cd918 558 WARN("Connection was closed by server");
marcel1691 1:2e29a33cd918 559 return HTTP_CLOSED; //Connection was closed by server
marcel1691 1:2e29a33cd918 560 }
marcel1691 1:2e29a33cd918 561
marcel1691 1:2e29a33cd918 562 m_sock.set_blocking(false, m_timeout);
marcel1691 1:2e29a33cd918 563 int ret = m_sock.send_all(buf, len);
marcel1691 1:2e29a33cd918 564 if(ret > 0) {
marcel1691 1:2e29a33cd918 565 writtenLen += ret;
marcel1691 1:2e29a33cd918 566 } else if( ret == 0 ) {
marcel1691 1:2e29a33cd918 567 WARN("Connection was closed by server");
marcel1691 1:2e29a33cd918 568 return HTTP_CLOSED; //Connection was closed by server
marcel1691 1:2e29a33cd918 569 } else {
marcel1691 1:2e29a33cd918 570 ERR("Connection error (send returned %d)", ret);
marcel1691 1:2e29a33cd918 571 return HTTP_CONN;
marcel1691 1:2e29a33cd918 572 }
marcel1691 1:2e29a33cd918 573
marcel1691 1:2e29a33cd918 574 DBG("Written %d bytes", writtenLen);
marcel1691 1:2e29a33cd918 575 return HTTP_OK;
marcel1691 1:2e29a33cd918 576 }
marcel1691 1:2e29a33cd918 577
marcel1691 1:2e29a33cd918 578 HTTPResult HTTPClient::parseURL(const char* url, char* scheme, size_t maxSchemeLen, char* host, size_t maxHostLen, uint16_t* port, char* path, size_t maxPathLen) //Parse URL
marcel1691 1:2e29a33cd918 579 {
marcel1691 1:2e29a33cd918 580 char* schemePtr = (char*) url;
marcel1691 1:2e29a33cd918 581 char* hostPtr = (char*) strstr(url, "://");
marcel1691 1:2e29a33cd918 582 if(hostPtr == NULL) {
marcel1691 1:2e29a33cd918 583 WARN("Could not find host");
marcel1691 1:2e29a33cd918 584 return HTTP_PARSE; //URL is invalid
marcel1691 1:2e29a33cd918 585 }
marcel1691 1:2e29a33cd918 586
marcel1691 1:2e29a33cd918 587 if( maxSchemeLen < hostPtr - schemePtr + 1 ) { //including NULL-terminating char
marcel1691 1:2e29a33cd918 588 WARN("Scheme str is too small (%d >= %d)", maxSchemeLen, hostPtr - schemePtr + 1);
marcel1691 1:2e29a33cd918 589 return HTTP_PARSE;
marcel1691 1:2e29a33cd918 590 }
marcel1691 1:2e29a33cd918 591 memcpy(scheme, schemePtr, hostPtr - schemePtr);
marcel1691 1:2e29a33cd918 592 scheme[hostPtr - schemePtr] = '\0';
marcel1691 1:2e29a33cd918 593
marcel1691 1:2e29a33cd918 594 hostPtr+=3;
marcel1691 1:2e29a33cd918 595
marcel1691 1:2e29a33cd918 596 size_t hostLen = 0;
marcel1691 1:2e29a33cd918 597
marcel1691 1:2e29a33cd918 598 char* portPtr = strchr(hostPtr, ':');
marcel1691 1:2e29a33cd918 599 if( portPtr != NULL ) {
marcel1691 1:2e29a33cd918 600 hostLen = portPtr - hostPtr;
marcel1691 1:2e29a33cd918 601 portPtr++;
marcel1691 1:2e29a33cd918 602 if( sscanf(portPtr, "%hu", port) != 1) {
marcel1691 1:2e29a33cd918 603 WARN("Could not find port");
marcel1691 1:2e29a33cd918 604 return HTTP_PARSE;
marcel1691 1:2e29a33cd918 605 }
marcel1691 1:2e29a33cd918 606 } else {
marcel1691 1:2e29a33cd918 607 *port=0;
marcel1691 1:2e29a33cd918 608 }
marcel1691 1:2e29a33cd918 609 char* pathPtr = strchr(hostPtr, '/');
marcel1691 1:2e29a33cd918 610 if( hostLen == 0 ) {
marcel1691 1:2e29a33cd918 611 hostLen = pathPtr - hostPtr;
marcel1691 1:2e29a33cd918 612 }
marcel1691 1:2e29a33cd918 613
marcel1691 1:2e29a33cd918 614 if( maxHostLen < hostLen + 1 ) { //including NULL-terminating char
marcel1691 1:2e29a33cd918 615 WARN("Host str is too small (%d >= %d)", maxHostLen, hostLen + 1);
marcel1691 1:2e29a33cd918 616 return HTTP_PARSE;
marcel1691 1:2e29a33cd918 617 }
marcel1691 1:2e29a33cd918 618 memcpy(host, hostPtr, hostLen);
marcel1691 1:2e29a33cd918 619 host[hostLen] = '\0';
marcel1691 1:2e29a33cd918 620
marcel1691 1:2e29a33cd918 621 size_t pathLen;
marcel1691 1:2e29a33cd918 622 char* fragmentPtr = strchr(hostPtr, '#');
marcel1691 1:2e29a33cd918 623 if(fragmentPtr != NULL) {
marcel1691 1:2e29a33cd918 624 pathLen = fragmentPtr - pathPtr;
marcel1691 1:2e29a33cd918 625 } else {
marcel1691 1:2e29a33cd918 626 pathLen = strlen(pathPtr);
marcel1691 1:2e29a33cd918 627 }
marcel1691 1:2e29a33cd918 628
marcel1691 1:2e29a33cd918 629 if( maxPathLen < pathLen + 1 ) { //including NULL-terminating char
marcel1691 1:2e29a33cd918 630 WARN("Path str is too small (%d >= %d)", maxPathLen, pathLen + 1);
marcel1691 1:2e29a33cd918 631 return HTTP_PARSE;
marcel1691 1:2e29a33cd918 632 }
marcel1691 1:2e29a33cd918 633 memcpy(path, pathPtr, pathLen);
marcel1691 1:2e29a33cd918 634 path[pathLen] = '\0';
marcel1691 1:2e29a33cd918 635
marcel1691 1:2e29a33cd918 636 return HTTP_OK;
marcel1691 1:2e29a33cd918 637 }
marcel1691 1:2e29a33cd918 638
marcel1691 1:2e29a33cd918 639 void HTTPClient::createauth (const char *user, const char *pwd, char *buf, int len)
marcel1691 1:2e29a33cd918 640 {
marcel1691 1:2e29a33cd918 641 char tmp[80];
marcel1691 1:2e29a33cd918 642
marcel1691 1:2e29a33cd918 643 snprintf(tmp, sizeof(tmp), "%s:%s", user, pwd);
marcel1691 1:2e29a33cd918 644 base64enc(tmp, strlen(tmp), &buf[strlen(buf)], len - strlen(buf));
marcel1691 1:2e29a33cd918 645 }
marcel1691 1:2e29a33cd918 646
marcel1691 1:2e29a33cd918 647 // Copyright (c) 2010 Donatien Garnier (donatiengar [at] gmail [dot] com)
marcel1691 1:2e29a33cd918 648 int HTTPClient::base64enc(const char *input, unsigned int length, char *output, int len)
marcel1691 1:2e29a33cd918 649 {
marcel1691 1:2e29a33cd918 650 static const char base64[] = "ABCDEFGHIJKLMNOPQRSTUVWXYZabcdefghijklmnopqrstuvwxyz0123456789+/";
marcel1691 1:2e29a33cd918 651 unsigned int c, c1, c2, c3;
marcel1691 1:2e29a33cd918 652
marcel1691 1:2e29a33cd918 653 if (len < ((((length-1)/3)+1)<<2)) return -1;
marcel1691 1:2e29a33cd918 654 for(unsigned int i = 0, j = 0; i<length; i+=3,j+=4) {
marcel1691 1:2e29a33cd918 655 c1 = ((((unsigned char)*((unsigned char *)&input[i]))));
marcel1691 1:2e29a33cd918 656 c2 = (length>i+1)?((((unsigned char)*((unsigned char *)&input[i+1])))):0;
marcel1691 1:2e29a33cd918 657 c3 = (length>i+2)?((((unsigned char)*((unsigned char *)&input[i+2])))):0;
marcel1691 1:2e29a33cd918 658
marcel1691 1:2e29a33cd918 659 c = ((c1 & 0xFC) >> 2);
marcel1691 1:2e29a33cd918 660 output[j+0] = base64[c];
marcel1691 1:2e29a33cd918 661 c = ((c1 & 0x03) << 4) | ((c2 & 0xF0) >> 4);
marcel1691 1:2e29a33cd918 662 output[j+1] = base64[c];
marcel1691 1:2e29a33cd918 663 c = ((c2 & 0x0F) << 2) | ((c3 & 0xC0) >> 6);
marcel1691 1:2e29a33cd918 664 output[j+2] = (length>i+1)?base64[c]:'=';
marcel1691 1:2e29a33cd918 665 c = (c3 & 0x3F);
marcel1691 1:2e29a33cd918 666 output[j+3] = (length>i+2)?base64[c]:'=';
marcel1691 1:2e29a33cd918 667 }
marcel1691 1:2e29a33cd918 668 output[(((length-1)/3)+1)<<2] = '\0';
marcel1691 1:2e29a33cd918 669 return 0;
marcel1691 1:2e29a33cd918 670 }