ACKme / Mbed 2 deprecated wiconnect-test-console

Dependencies:   WiConnect mbed

Committer:
dan_ackme
Date:
Sat Aug 23 05:40:50 2014 -0700
Revision:
15:a835e28308b6
Parent:
12:3dd3a1be40c1
Renamed Socket to WiconnectSocket

Who changed what in which revision?

UserRevisionLine numberNew contents of line
dan_ackme 12:3dd3a1be40c1 1 /**
dan_ackme 12:3dd3a1be40c1 2 * ACKme WiConnect Host Library is licensed under the BSD licence:
dan_ackme 12:3dd3a1be40c1 3 *
dan_ackme 12:3dd3a1be40c1 4 * Copyright (c)2014 ACKme Networks.
dan_ackme 12:3dd3a1be40c1 5 * All rights reserved.
dan_ackme 12:3dd3a1be40c1 6 *
dan_ackme 12:3dd3a1be40c1 7 * Redistribution and use in source and binary forms, with or without modification,
dan_ackme 12:3dd3a1be40c1 8 * are permitted provided that the following conditions are met:
dan_ackme 12:3dd3a1be40c1 9 *
dan_ackme 12:3dd3a1be40c1 10 * 1. Redistributions of source code must retain the above copyright notice,
dan_ackme 12:3dd3a1be40c1 11 * this list of conditions and the following disclaimer.
dan_ackme 12:3dd3a1be40c1 12 * 2. Redistributions in binary form must reproduce the above copyright notice,
dan_ackme 12:3dd3a1be40c1 13 * this list of conditions and the following disclaimer in the documentation
dan_ackme 12:3dd3a1be40c1 14 * and/or other materials provided with the distribution.
dan_ackme 12:3dd3a1be40c1 15 * 3. The name of the author may not be used to endorse or promote products
dan_ackme 12:3dd3a1be40c1 16 * derived from this software without specific prior written permission.
dan_ackme 12:3dd3a1be40c1 17 *
dan_ackme 12:3dd3a1be40c1 18 * THIS SOFTWARE IS PROVIDED BY THE AUTHOR ``AS IS AND ANY EXPRESS OR IMPLIED
dan_ackme 12:3dd3a1be40c1 19 * WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES OF
dan_ackme 12:3dd3a1be40c1 20 * MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT
dan_ackme 12:3dd3a1be40c1 21 * SHALL THE AUTHOR BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL,
dan_ackme 12:3dd3a1be40c1 22 * EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT
dan_ackme 12:3dd3a1be40c1 23 * OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS
dan_ackme 12:3dd3a1be40c1 24 * INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN
dan_ackme 12:3dd3a1be40c1 25 * CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING
dan_ackme 12:3dd3a1be40c1 26 * IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY
dan_ackme 12:3dd3a1be40c1 27 * OF SUCH DAMAGE.
dan_ackme 0:836c9a6383e0 28 */
dan_ackme 0:836c9a6383e0 29
dan_ackme 0:836c9a6383e0 30 #include "tests/Tests.h"
dan_ackme 0:836c9a6383e0 31 #include "Wiconnect.h"
dan_ackme 0:836c9a6383e0 32
dan_ackme 0:836c9a6383e0 33
dan_ackme 0:836c9a6383e0 34
dan_ackme 15:a835e28308b6 35 static WiconnectResult addHeadersPrompt(Wiconnect *wiconnect, WiconnectSocket &socket);
dan_ackme 15:a835e28308b6 36 static WiconnectResult readResponse(WiconnectSocket &socket);
dan_ackme 0:836c9a6383e0 37
dan_ackme 0:836c9a6383e0 38
dan_ackme 0:836c9a6383e0 39
dan_ackme 0:836c9a6383e0 40 /*************************************************************************************************/
dan_ackme 0:836c9a6383e0 41 WiconnectResult socketHttpGetCommand(int argc, char **argv)
dan_ackme 0:836c9a6383e0 42 {
dan_ackme 0:836c9a6383e0 43 WiconnectResult result;
dan_ackme 0:836c9a6383e0 44 Wiconnect *wiconnect = Wiconnect::getInstance();
dan_ackme 15:a835e28308b6 45 WiconnectSocket socket(TEST_BUFFER_LENGTH, TEST_BUFFER);
dan_ackme 0:836c9a6383e0 46 const char *url;
dan_ackme 0:836c9a6383e0 47 bool addHeaders = false;
dan_ackme 3:dddd476d5967 48 int savedTimeout = wiconnect->getCommandDefaultTimeout();
dan_ackme 0:836c9a6383e0 49
dan_ackme 0:836c9a6383e0 50 if(argc < 1)
dan_ackme 0:836c9a6383e0 51 {
dan_ackme 0:836c9a6383e0 52 LOG_ERROR("must specify url");
dan_ackme 0:836c9a6383e0 53 return WICONNECT_BAD_ARG;
dan_ackme 0:836c9a6383e0 54 }
dan_ackme 0:836c9a6383e0 55 url = argv[0];
dan_ackme 0:836c9a6383e0 56
dan_ackme 0:836c9a6383e0 57 if(argc > 1)
dan_ackme 0:836c9a6383e0 58 {
dan_ackme 0:836c9a6383e0 59 addHeaders = true;
dan_ackme 0:836c9a6383e0 60 }
dan_ackme 0:836c9a6383e0 61
dan_ackme 3:dddd476d5967 62 wiconnect->setCommandDefaultTimeout(15000);
dan_ackme 0:836c9a6383e0 63 if(!WICONNECT_FAILED(result, wiconnect->httpGet(socket, url, addHeaders)))
dan_ackme 0:836c9a6383e0 64 {
dan_ackme 0:836c9a6383e0 65 uint32_t status;
dan_ackme 0:836c9a6383e0 66 if(addHeaders)
dan_ackme 0:836c9a6383e0 67 {
dan_ackme 0:836c9a6383e0 68 if(WICONNECT_FAILED(result, addHeadersPrompt(wiconnect, socket)))
dan_ackme 0:836c9a6383e0 69 {
dan_ackme 0:836c9a6383e0 70 goto exit;
dan_ackme 0:836c9a6383e0 71 }
dan_ackme 0:836c9a6383e0 72 else if(WICONNECT_FAILED(result, wiconnect->httpGetStatus(socket, &status)))
dan_ackme 0:836c9a6383e0 73 {
dan_ackme 0:836c9a6383e0 74 goto exit;
dan_ackme 0:836c9a6383e0 75 }
dan_ackme 0:836c9a6383e0 76 LOG_INFO("HTTP Status: %d", status);
dan_ackme 0:836c9a6383e0 77 }
dan_ackme 0:836c9a6383e0 78
dan_ackme 0:836c9a6383e0 79 result = readResponse(socket);
dan_ackme 0:836c9a6383e0 80 }
dan_ackme 0:836c9a6383e0 81
dan_ackme 0:836c9a6383e0 82 exit:
dan_ackme 3:dddd476d5967 83 wiconnect->setCommandDefaultTimeout(savedTimeout);
dan_ackme 3:dddd476d5967 84
dan_ackme 0:836c9a6383e0 85 return result;
dan_ackme 0:836c9a6383e0 86 }
dan_ackme 0:836c9a6383e0 87
dan_ackme 0:836c9a6383e0 88
dan_ackme 0:836c9a6383e0 89
dan_ackme 0:836c9a6383e0 90
dan_ackme 0:836c9a6383e0 91 /*************************************************************************************************/
dan_ackme 15:a835e28308b6 92 static WiconnectResult addHeadersPrompt(Wiconnect *wiconnect, WiconnectSocket &socket)
dan_ackme 0:836c9a6383e0 93 {
dan_ackme 0:836c9a6383e0 94 WiconnectResult result;
dan_ackme 0:836c9a6383e0 95
dan_ackme 0:836c9a6383e0 96 char buffer[128];
dan_ackme 0:836c9a6383e0 97 for(;;)
dan_ackme 0:836c9a6383e0 98 {
dan_ackme 0:836c9a6383e0 99 LOG_INFO("Enter header 'key,value\\n' (or 'done\\n' to issue request):");
dan_ackme 0:836c9a6383e0 100 char *ptr = buffer;
dan_ackme 0:836c9a6383e0 101
dan_ackme 0:836c9a6383e0 102 for(;;)
dan_ackme 0:836c9a6383e0 103 {
dan_ackme 0:836c9a6383e0 104 int c = consoleSerial.getc();
dan_ackme 0:836c9a6383e0 105 consoleSerial.putc(c);
dan_ackme 0:836c9a6383e0 106 if(c == '\r')
dan_ackme 0:836c9a6383e0 107 continue;
dan_ackme 0:836c9a6383e0 108 if(c == '\n')
dan_ackme 0:836c9a6383e0 109 {
dan_ackme 0:836c9a6383e0 110 *ptr = 0;
dan_ackme 0:836c9a6383e0 111 break;
dan_ackme 0:836c9a6383e0 112 }
dan_ackme 0:836c9a6383e0 113 *ptr++ = (char)c;
dan_ackme 0:836c9a6383e0 114 }
dan_ackme 0:836c9a6383e0 115
dan_ackme 0:836c9a6383e0 116 if(strcmp(buffer, "done") == 0)
dan_ackme 0:836c9a6383e0 117 {
dan_ackme 0:836c9a6383e0 118 return WICONNECT_SUCCESS;
dan_ackme 0:836c9a6383e0 119 }
dan_ackme 0:836c9a6383e0 120
dan_ackme 0:836c9a6383e0 121 char *value = strchr(buffer, ',');
dan_ackme 0:836c9a6383e0 122 if(value == NULL)
dan_ackme 0:836c9a6383e0 123 {
dan_ackme 0:836c9a6383e0 124 LOG_ERROR("Mal-formed key,value pair. Must be: <key>,<value>");
dan_ackme 0:836c9a6383e0 125 continue;
dan_ackme 0:836c9a6383e0 126 }
dan_ackme 0:836c9a6383e0 127
dan_ackme 0:836c9a6383e0 128 *value++ = 0;
dan_ackme 0:836c9a6383e0 129
dan_ackme 0:836c9a6383e0 130 if(WICONNECT_FAILED(result, wiconnect->httpAddHeader(socket, buffer, value)))
dan_ackme 0:836c9a6383e0 131 {
dan_ackme 0:836c9a6383e0 132 LOG_ERROR("Failed to add header key, value");
dan_ackme 0:836c9a6383e0 133 break;
dan_ackme 0:836c9a6383e0 134 }
dan_ackme 0:836c9a6383e0 135 }
dan_ackme 0:836c9a6383e0 136
dan_ackme 0:836c9a6383e0 137 return result;
dan_ackme 0:836c9a6383e0 138 }
dan_ackme 0:836c9a6383e0 139
dan_ackme 0:836c9a6383e0 140 /*************************************************************************************************/
dan_ackme 15:a835e28308b6 141 static WiconnectResult readResponse(WiconnectSocket &socket)
dan_ackme 0:836c9a6383e0 142 {
dan_ackme 0:836c9a6383e0 143 uint8_t c;
dan_ackme 0:836c9a6383e0 144
dan_ackme 0:836c9a6383e0 145 LOG_INFO("Response data:");
dan_ackme 0:836c9a6383e0 146 while(socket.getc(&c) == WICONNECT_SUCCESS) // NOTE: getc() is extremely inefficient here,
dan_ackme 0:836c9a6383e0 147 // is only used to test its functionality
dan_ackme 0:836c9a6383e0 148 {
dan_ackme 0:836c9a6383e0 149 logWrite(&c, 1);
dan_ackme 0:836c9a6383e0 150 }
dan_ackme 0:836c9a6383e0 151
dan_ackme 0:836c9a6383e0 152 return WICONNECT_SUCCESS;
dan_ackme 0:836c9a6383e0 153 }