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.
tests/blocking/socket/HttpGetTest.cpp@0:836c9a6383e0, 2014-08-11 (annotated)
- Committer:
- dan_ackme
- Date:
- Mon Aug 11 11:31:32 2014 +0000
- Revision:
- 0:836c9a6383e0
- Child:
- 1:5137ec8f4c45
Initial check-in
Who changed what in which revision?
User | Revision | Line number | New contents of line |
---|---|---|---|
dan_ackme | 0:836c9a6383e0 | 1 | /* |
dan_ackme | 0:836c9a6383e0 | 2 | * Copyright 2014, ACKme Networks |
dan_ackme | 0:836c9a6383e0 | 3 | * All Rights Reserved. |
dan_ackme | 0:836c9a6383e0 | 4 | * |
dan_ackme | 0:836c9a6383e0 | 5 | * This is UNPUBLISHED PROPRIETARY SOURCE CODE of ACKme Networks; |
dan_ackme | 0:836c9a6383e0 | 6 | * the contents of this file may not be disclosed to third parties, copied |
dan_ackme | 0:836c9a6383e0 | 7 | * or duplicated in any form, in whole or in part, without the prior |
dan_ackme | 0:836c9a6383e0 | 8 | * written permission of ACKme Networks. |
dan_ackme | 0:836c9a6383e0 | 9 | */ |
dan_ackme | 0:836c9a6383e0 | 10 | |
dan_ackme | 0:836c9a6383e0 | 11 | |
dan_ackme | 0:836c9a6383e0 | 12 | #include "tests/Tests.h" |
dan_ackme | 0:836c9a6383e0 | 13 | #include "Wiconnect.h" |
dan_ackme | 0:836c9a6383e0 | 14 | |
dan_ackme | 0:836c9a6383e0 | 15 | |
dan_ackme | 0:836c9a6383e0 | 16 | |
dan_ackme | 0:836c9a6383e0 | 17 | static WiconnectResult addHeadersPrompt(Wiconnect *wiconnect, Socket &socket); |
dan_ackme | 0:836c9a6383e0 | 18 | static WiconnectResult readResponse(Socket &socket); |
dan_ackme | 0:836c9a6383e0 | 19 | |
dan_ackme | 0:836c9a6383e0 | 20 | |
dan_ackme | 0:836c9a6383e0 | 21 | |
dan_ackme | 0:836c9a6383e0 | 22 | /*************************************************************************************************/ |
dan_ackme | 0:836c9a6383e0 | 23 | WiconnectResult socketHttpGetCommand(int argc, char **argv) |
dan_ackme | 0:836c9a6383e0 | 24 | { |
dan_ackme | 0:836c9a6383e0 | 25 | WiconnectResult result; |
dan_ackme | 0:836c9a6383e0 | 26 | Wiconnect *wiconnect = Wiconnect::getInstance(); |
dan_ackme | 0:836c9a6383e0 | 27 | Socket socket(sizeof(testBuffer), testBuffer); |
dan_ackme | 0:836c9a6383e0 | 28 | const char *url; |
dan_ackme | 0:836c9a6383e0 | 29 | bool addHeaders = false; |
dan_ackme | 0:836c9a6383e0 | 30 | |
dan_ackme | 0:836c9a6383e0 | 31 | if(argc < 1) |
dan_ackme | 0:836c9a6383e0 | 32 | { |
dan_ackme | 0:836c9a6383e0 | 33 | LOG_ERROR("must specify url"); |
dan_ackme | 0:836c9a6383e0 | 34 | return WICONNECT_BAD_ARG; |
dan_ackme | 0:836c9a6383e0 | 35 | } |
dan_ackme | 0:836c9a6383e0 | 36 | url = argv[0]; |
dan_ackme | 0:836c9a6383e0 | 37 | |
dan_ackme | 0:836c9a6383e0 | 38 | if(argc > 1) |
dan_ackme | 0:836c9a6383e0 | 39 | { |
dan_ackme | 0:836c9a6383e0 | 40 | addHeaders = true; |
dan_ackme | 0:836c9a6383e0 | 41 | } |
dan_ackme | 0:836c9a6383e0 | 42 | |
dan_ackme | 0:836c9a6383e0 | 43 | |
dan_ackme | 0:836c9a6383e0 | 44 | if(!WICONNECT_FAILED(result, wiconnect->httpGet(socket, url, addHeaders))) |
dan_ackme | 0:836c9a6383e0 | 45 | { |
dan_ackme | 0:836c9a6383e0 | 46 | uint32_t status; |
dan_ackme | 0:836c9a6383e0 | 47 | if(addHeaders) |
dan_ackme | 0:836c9a6383e0 | 48 | { |
dan_ackme | 0:836c9a6383e0 | 49 | if(WICONNECT_FAILED(result, addHeadersPrompt(wiconnect, socket))) |
dan_ackme | 0:836c9a6383e0 | 50 | { |
dan_ackme | 0:836c9a6383e0 | 51 | goto exit; |
dan_ackme | 0:836c9a6383e0 | 52 | } |
dan_ackme | 0:836c9a6383e0 | 53 | else if(WICONNECT_FAILED(result, wiconnect->httpGetStatus(socket, &status))) |
dan_ackme | 0:836c9a6383e0 | 54 | { |
dan_ackme | 0:836c9a6383e0 | 55 | goto exit; |
dan_ackme | 0:836c9a6383e0 | 56 | } |
dan_ackme | 0:836c9a6383e0 | 57 | LOG_INFO("HTTP Status: %d", status); |
dan_ackme | 0:836c9a6383e0 | 58 | } |
dan_ackme | 0:836c9a6383e0 | 59 | |
dan_ackme | 0:836c9a6383e0 | 60 | result = readResponse(socket); |
dan_ackme | 0:836c9a6383e0 | 61 | } |
dan_ackme | 0:836c9a6383e0 | 62 | |
dan_ackme | 0:836c9a6383e0 | 63 | exit: |
dan_ackme | 0:836c9a6383e0 | 64 | return result; |
dan_ackme | 0:836c9a6383e0 | 65 | } |
dan_ackme | 0:836c9a6383e0 | 66 | |
dan_ackme | 0:836c9a6383e0 | 67 | |
dan_ackme | 0:836c9a6383e0 | 68 | |
dan_ackme | 0:836c9a6383e0 | 69 | |
dan_ackme | 0:836c9a6383e0 | 70 | /*************************************************************************************************/ |
dan_ackme | 0:836c9a6383e0 | 71 | static WiconnectResult addHeadersPrompt(Wiconnect *wiconnect, Socket &socket) |
dan_ackme | 0:836c9a6383e0 | 72 | { |
dan_ackme | 0:836c9a6383e0 | 73 | WiconnectResult result; |
dan_ackme | 0:836c9a6383e0 | 74 | |
dan_ackme | 0:836c9a6383e0 | 75 | char buffer[128]; |
dan_ackme | 0:836c9a6383e0 | 76 | for(;;) |
dan_ackme | 0:836c9a6383e0 | 77 | { |
dan_ackme | 0:836c9a6383e0 | 78 | LOG_INFO("Enter header 'key,value\\n' (or 'done\\n' to issue request):"); |
dan_ackme | 0:836c9a6383e0 | 79 | char *ptr = buffer; |
dan_ackme | 0:836c9a6383e0 | 80 | |
dan_ackme | 0:836c9a6383e0 | 81 | for(;;) |
dan_ackme | 0:836c9a6383e0 | 82 | { |
dan_ackme | 0:836c9a6383e0 | 83 | int c = consoleSerial.getc(); |
dan_ackme | 0:836c9a6383e0 | 84 | consoleSerial.putc(c); |
dan_ackme | 0:836c9a6383e0 | 85 | if(c == '\r') |
dan_ackme | 0:836c9a6383e0 | 86 | continue; |
dan_ackme | 0:836c9a6383e0 | 87 | if(c == '\n') |
dan_ackme | 0:836c9a6383e0 | 88 | { |
dan_ackme | 0:836c9a6383e0 | 89 | *ptr = 0; |
dan_ackme | 0:836c9a6383e0 | 90 | break; |
dan_ackme | 0:836c9a6383e0 | 91 | } |
dan_ackme | 0:836c9a6383e0 | 92 | *ptr++ = (char)c; |
dan_ackme | 0:836c9a6383e0 | 93 | } |
dan_ackme | 0:836c9a6383e0 | 94 | |
dan_ackme | 0:836c9a6383e0 | 95 | if(strcmp(buffer, "done") == 0) |
dan_ackme | 0:836c9a6383e0 | 96 | { |
dan_ackme | 0:836c9a6383e0 | 97 | return WICONNECT_SUCCESS; |
dan_ackme | 0:836c9a6383e0 | 98 | } |
dan_ackme | 0:836c9a6383e0 | 99 | |
dan_ackme | 0:836c9a6383e0 | 100 | char *value = strchr(buffer, ','); |
dan_ackme | 0:836c9a6383e0 | 101 | if(value == NULL) |
dan_ackme | 0:836c9a6383e0 | 102 | { |
dan_ackme | 0:836c9a6383e0 | 103 | LOG_ERROR("Mal-formed key,value pair. Must be: <key>,<value>"); |
dan_ackme | 0:836c9a6383e0 | 104 | continue; |
dan_ackme | 0:836c9a6383e0 | 105 | } |
dan_ackme | 0:836c9a6383e0 | 106 | |
dan_ackme | 0:836c9a6383e0 | 107 | *value++ = 0; |
dan_ackme | 0:836c9a6383e0 | 108 | |
dan_ackme | 0:836c9a6383e0 | 109 | if(WICONNECT_FAILED(result, wiconnect->httpAddHeader(socket, buffer, value))) |
dan_ackme | 0:836c9a6383e0 | 110 | { |
dan_ackme | 0:836c9a6383e0 | 111 | LOG_ERROR("Failed to add header key, value"); |
dan_ackme | 0:836c9a6383e0 | 112 | break; |
dan_ackme | 0:836c9a6383e0 | 113 | } |
dan_ackme | 0:836c9a6383e0 | 114 | } |
dan_ackme | 0:836c9a6383e0 | 115 | |
dan_ackme | 0:836c9a6383e0 | 116 | return result; |
dan_ackme | 0:836c9a6383e0 | 117 | } |
dan_ackme | 0:836c9a6383e0 | 118 | |
dan_ackme | 0:836c9a6383e0 | 119 | /*************************************************************************************************/ |
dan_ackme | 0:836c9a6383e0 | 120 | static WiconnectResult readResponse(Socket &socket) |
dan_ackme | 0:836c9a6383e0 | 121 | { |
dan_ackme | 0:836c9a6383e0 | 122 | uint8_t c; |
dan_ackme | 0:836c9a6383e0 | 123 | |
dan_ackme | 0:836c9a6383e0 | 124 | LOG_INFO("Response data:"); |
dan_ackme | 0:836c9a6383e0 | 125 | while(socket.getc(&c) == WICONNECT_SUCCESS) // NOTE: getc() is extremely inefficient here, |
dan_ackme | 0:836c9a6383e0 | 126 | // is only used to test its functionality |
dan_ackme | 0:836c9a6383e0 | 127 | { |
dan_ackme | 0:836c9a6383e0 | 128 | logWrite(&c, 1); |
dan_ackme | 0:836c9a6383e0 | 129 | } |
dan_ackme | 0:836c9a6383e0 | 130 | |
dan_ackme | 0:836c9a6383e0 | 131 | return WICONNECT_SUCCESS; |
dan_ackme | 0:836c9a6383e0 | 132 | } |
dan_ackme | 0:836c9a6383e0 | 133 |