ACKme / Mbed 2 deprecated wiconnect-test-console

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:   WiConnect mbed

tests/blocking/socket/HttpGetTest.cpp@3:dddd476d5967, 2014-08-11 (annotated)

Committer:
dan_ackme
Date:
Mon Aug 11 13:55:39 2014 -0700
Revision:
3:dddd476d5967
Parent:
1:5137ec8f4c45
Child:
12:3dd3a1be40c1
use static buffers instead of malloc since default heap is so small

Who changed what in which revision?

UserRevisionLine numberNew 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 3:dddd476d5967 27 Socket socket(TEST_BUFFER_LENGTH, TEST_BUFFER);
dan_ackme 0:836c9a6383e0 28 const char *url;
dan_ackme 0:836c9a6383e0 29 bool addHeaders = false;
dan_ackme 3:dddd476d5967 30 int savedTimeout = wiconnect->getCommandDefaultTimeout();
dan_ackme 0:836c9a6383e0 31
dan_ackme 0:836c9a6383e0 32 if(argc < 1)
dan_ackme 0:836c9a6383e0 33 {
dan_ackme 0:836c9a6383e0 34 LOG_ERROR("must specify url");
dan_ackme 0:836c9a6383e0 35 return WICONNECT_BAD_ARG;
dan_ackme 0:836c9a6383e0 36 }
dan_ackme 0:836c9a6383e0 37 url = argv[0];
dan_ackme 0:836c9a6383e0 38
dan_ackme 0:836c9a6383e0 39 if(argc > 1)
dan_ackme 0:836c9a6383e0 40 {
dan_ackme 0:836c9a6383e0 41 addHeaders = true;
dan_ackme 0:836c9a6383e0 42 }
dan_ackme 0:836c9a6383e0 43
dan_ackme 3:dddd476d5967 44 wiconnect->setCommandDefaultTimeout(15000);
dan_ackme 0:836c9a6383e0 45 if(!WICONNECT_FAILED(result, wiconnect->httpGet(socket, url, addHeaders)))
dan_ackme 0:836c9a6383e0 46 {
dan_ackme 0:836c9a6383e0 47 uint32_t status;
dan_ackme 0:836c9a6383e0 48 if(addHeaders)
dan_ackme 0:836c9a6383e0 49 {
dan_ackme 0:836c9a6383e0 50 if(WICONNECT_FAILED(result, addHeadersPrompt(wiconnect, socket)))
dan_ackme 0:836c9a6383e0 51 {
dan_ackme 0:836c9a6383e0 52 goto exit;
dan_ackme 0:836c9a6383e0 53 }
dan_ackme 0:836c9a6383e0 54 else if(WICONNECT_FAILED(result, wiconnect->httpGetStatus(socket, &status)))
dan_ackme 0:836c9a6383e0 55 {
dan_ackme 0:836c9a6383e0 56 goto exit;
dan_ackme 0:836c9a6383e0 57 }
dan_ackme 0:836c9a6383e0 58 LOG_INFO("HTTP Status: %d", status);
dan_ackme 0:836c9a6383e0 59 }
dan_ackme 0:836c9a6383e0 60
dan_ackme 0:836c9a6383e0 61 result = readResponse(socket);
dan_ackme 0:836c9a6383e0 62 }
dan_ackme 0:836c9a6383e0 63
dan_ackme 0:836c9a6383e0 64 exit:
dan_ackme 3:dddd476d5967 65 wiconnect->setCommandDefaultTimeout(savedTimeout);
dan_ackme 3:dddd476d5967 66
dan_ackme 0:836c9a6383e0 67 return result;
dan_ackme 0:836c9a6383e0 68 }
dan_ackme 0:836c9a6383e0 69
dan_ackme 0:836c9a6383e0 70
dan_ackme 0:836c9a6383e0 71
dan_ackme 0:836c9a6383e0 72
dan_ackme 0:836c9a6383e0 73 /*************************************************************************************************/
dan_ackme 0:836c9a6383e0 74 static WiconnectResult addHeadersPrompt(Wiconnect *wiconnect, Socket &socket)
dan_ackme 0:836c9a6383e0 75 {
dan_ackme 0:836c9a6383e0 76 WiconnectResult result;
dan_ackme 0:836c9a6383e0 77
dan_ackme 0:836c9a6383e0 78 char buffer[128];
dan_ackme 0:836c9a6383e0 79 for(;;)
dan_ackme 0:836c9a6383e0 80 {
dan_ackme 0:836c9a6383e0 81 LOG_INFO("Enter header 'key,value\\n' (or 'done\\n' to issue request):");
dan_ackme 0:836c9a6383e0 82 char *ptr = buffer;
dan_ackme 0:836c9a6383e0 83
dan_ackme 0:836c9a6383e0 84 for(;;)
dan_ackme 0:836c9a6383e0 85 {
dan_ackme 0:836c9a6383e0 86 int c = consoleSerial.getc();
dan_ackme 0:836c9a6383e0 87 consoleSerial.putc(c);
dan_ackme 0:836c9a6383e0 88 if(c == '\r')
dan_ackme 0:836c9a6383e0 89 continue;
dan_ackme 0:836c9a6383e0 90 if(c == '\n')
dan_ackme 0:836c9a6383e0 91 {
dan_ackme 0:836c9a6383e0 92 *ptr = 0;
dan_ackme 0:836c9a6383e0 93 break;
dan_ackme 0:836c9a6383e0 94 }
dan_ackme 0:836c9a6383e0 95 *ptr++ = (char)c;
dan_ackme 0:836c9a6383e0 96 }
dan_ackme 0:836c9a6383e0 97
dan_ackme 0:836c9a6383e0 98 if(strcmp(buffer, "done") == 0)
dan_ackme 0:836c9a6383e0 99 {
dan_ackme 0:836c9a6383e0 100 return WICONNECT_SUCCESS;
dan_ackme 0:836c9a6383e0 101 }
dan_ackme 0:836c9a6383e0 102
dan_ackme 0:836c9a6383e0 103 char *value = strchr(buffer, ',');
dan_ackme 0:836c9a6383e0 104 if(value == NULL)
dan_ackme 0:836c9a6383e0 105 {
dan_ackme 0:836c9a6383e0 106 LOG_ERROR("Mal-formed key,value pair. Must be: <key>,<value>");
dan_ackme 0:836c9a6383e0 107 continue;
dan_ackme 0:836c9a6383e0 108 }
dan_ackme 0:836c9a6383e0 109
dan_ackme 0:836c9a6383e0 110 *value++ = 0;
dan_ackme 0:836c9a6383e0 111
dan_ackme 0:836c9a6383e0 112 if(WICONNECT_FAILED(result, wiconnect->httpAddHeader(socket, buffer, value)))
dan_ackme 0:836c9a6383e0 113 {
dan_ackme 0:836c9a6383e0 114 LOG_ERROR("Failed to add header key, value");
dan_ackme 0:836c9a6383e0 115 break;
dan_ackme 0:836c9a6383e0 116 }
dan_ackme 0:836c9a6383e0 117 }
dan_ackme 0:836c9a6383e0 118
dan_ackme 0:836c9a6383e0 119 return result;
dan_ackme 0:836c9a6383e0 120 }
dan_ackme 0:836c9a6383e0 121
dan_ackme 0:836c9a6383e0 122 /*************************************************************************************************/
dan_ackme 0:836c9a6383e0 123 static WiconnectResult readResponse(Socket &socket)
dan_ackme 0:836c9a6383e0 124 {
dan_ackme 0:836c9a6383e0 125 uint8_t c;
dan_ackme 0:836c9a6383e0 126
dan_ackme 0:836c9a6383e0 127 LOG_INFO("Response data:");
dan_ackme 0:836c9a6383e0 128 while(socket.getc(&c) == WICONNECT_SUCCESS) // NOTE: getc() is extremely inefficient here,
dan_ackme 0:836c9a6383e0 129 // is only used to test its functionality
dan_ackme 0:836c9a6383e0 130 {
dan_ackme 0:836c9a6383e0 131 logWrite(&c, 1);
dan_ackme 0:836c9a6383e0 132 }
dan_ackme 0:836c9a6383e0 133
dan_ackme 0:836c9a6383e0 134 return WICONNECT_SUCCESS;
dan_ackme 0:836c9a6383e0 135 }