Suga koubou / Mbed 2 deprecated TinyHTTP

Tiny HTTP Client http://mbed.org/users/okini3939/notebook/tinyhttp

Dependencies:   EthernetNetIf mbed

TinyHTTP.cpp@0:f2bf5f966801, 2011-07-27 (annotated)

Committer:
okini3939
Date:
Wed Jul 27 16:08:54 2011 +0000
Revision:
0:f2bf5f966801
Child:
1:9f15e579d914

        

        
Who changed what in which revision?

        

            
                
UserRevisionLine numberNew contents of line

            
            


okini3939

0:f2bf5f966801


     1

/*





okini3939

0:f2bf5f966801


     2

 * mbed Tiny HTTP Client





okini3939

0:f2bf5f966801


     3

 * Copyright (c) 2011 Hiroshi Suga





okini3939

0:f2bf5f966801


     4

 * Released under the MIT License: http://mbed.org/license/mit





okini3939

0:f2bf5f966801


     5

 */





okini3939

0:f2bf5f966801


     6







okini3939

0:f2bf5f966801


     7

/** @file





okini3939

0:f2bf5f966801


     8

 * @brief Tiny HTTP Client





okini3939

0:f2bf5f966801


     9

 */





okini3939

0:f2bf5f966801


    10







okini3939

0:f2bf5f966801


    11

#include "mbed.h"





okini3939

0:f2bf5f966801


    12

#include "EthernetNetIf.h"





okini3939

0:f2bf5f966801


    13

#include "TCPSocket.h"





okini3939

0:f2bf5f966801


    14

#include "DNSRequest.h"





okini3939

0:f2bf5f966801


    15

#include "TinyHTTP.h"





okini3939

0:f2bf5f966801


    16







okini3939

0:f2bf5f966801


    17

#define STATUS_NONE 0





okini3939

0:f2bf5f966801


    18

#define STATUS_READABLE 1





okini3939

0:f2bf5f966801


    19

#define STATUS_CONNECTED 2





okini3939

0:f2bf5f966801


    20

#define STATUS_ERROR 3





okini3939

0:f2bf5f966801


    21

#define STATUS_DISCONNECTED 4





okini3939

0:f2bf5f966801


    22







okini3939

0:f2bf5f966801


    23







okini3939

0:f2bf5f966801


    24

TCPSocket *http;





okini3939

0:f2bf5f966801


    25

volatile int tcp_status = 0, dns_status = 0;





okini3939

0:f2bf5f966801


    26







okini3939

0:f2bf5f966801


    27

// Copyright (c) 2010 Donatien Garnier (donatiengar [at] gmail [dot] com)





okini3939

0:f2bf5f966801


    28

void base64enc(const char *input, unsigned int length, char *output) {





okini3939

0:f2bf5f966801


    29

  static const char base64[] = "ABCDEFGHIJKLMNOPQRSTUVWXYZabcdefghijklmnopqrstuvwxyz0123456789+/";





okini3939

0:f2bf5f966801


    30

  unsigned int c, c1, c2, c3;





okini3939

0:f2bf5f966801


    31

  for(unsigned int i = 0, j = 0; i<length; i+=3,j+=4) {





okini3939

0:f2bf5f966801


    32

    c1 = ((((unsigned char)*((unsigned char *)&input[i]))));





okini3939

0:f2bf5f966801


    33

    c2 = (length>i+1)?((((unsigned char)*((unsigned char *)&input[i+1])))):0;





okini3939

0:f2bf5f966801


    34

    c3 = (length>i+2)?((((unsigned char)*((unsigned char *)&input[i+2])))):0;





okini3939

0:f2bf5f966801


    35







okini3939

0:f2bf5f966801


    36

    c = ((c1 & 0xFC) >> 2);





okini3939

0:f2bf5f966801


    37

    output[j+0] = base64[c];





okini3939

0:f2bf5f966801


    38

    c = ((c1 & 0x03) << 4) | ((c2 & 0xF0) >> 4);





okini3939

0:f2bf5f966801


    39

    output[j+1] = base64[c];





okini3939

0:f2bf5f966801


    40

    c = ((c2 & 0x0F) << 2) | ((c3 & 0xC0) >> 6);





okini3939

0:f2bf5f966801


    41

    output[j+2] = (length>i+1)?base64[c]:'=';





okini3939

0:f2bf5f966801


    42

    c = (c3 & 0x3F);





okini3939

0:f2bf5f966801


    43

    output[j+3] = (length>i+2)?base64[c]:'=';





okini3939

0:f2bf5f966801


    44

  }





okini3939

0:f2bf5f966801


    45

  output[(((length-1)/3)+1)<<2] = '\0';





okini3939

0:f2bf5f966801


    46

}





okini3939

0:f2bf5f966801


    47

/*





okini3939

0:f2bf5f966801


    48

// Copyright (c) 2010 Donatien Garnier (donatiengar [at] gmail [dot] com)





okini3939

0:f2bf5f966801


    49

int url_encode(char *str, char *buf, int len) {





okini3939

0:f2bf5f966801


    50

//  char *pstr = str, *buf = (char*)malloc(strlen(str) * 3 + 1), *pbuf = buf;





okini3939

0:f2bf5f966801


    51

  if (len < strlen(str) * 3 + 1) return -1;





okini3939

0:f2bf5f966801


    52

  char *pstr = str, *pbuf = buf;





okini3939

0:f2bf5f966801


    53

  while (*pstr) {





okini3939

0:f2bf5f966801


    54

    if (isalnum(*pstr) || *pstr == '-' || *pstr == '_' || *pstr == '.' || *pstr == '~') 





okini3939

0:f2bf5f966801


    55

      *pbuf++ = *pstr;





okini3939

0:f2bf5f966801


    56

    else if (*pstr == ' ') 





okini3939

0:f2bf5f966801


    57

      *pbuf++ = '+';





okini3939

0:f2bf5f966801


    58

    else 





okini3939

0:f2bf5f966801


    59

      *pbuf++ = '%', *pbuf++ = to_hex(*pstr >> 4), *pbuf++ = to_hex(*pstr & 15);





okini3939

0:f2bf5f966801


    60

    pstr++;





okini3939

0:f2bf5f966801


    61

  }





okini3939

0:f2bf5f966801


    62

  *pbuf = '\0';





okini3939

0:f2bf5f966801


    63

  return 0;





okini3939

0:f2bf5f966801


    64

}





okini3939

0:f2bf5f966801


    65

*/





okini3939

0:f2bf5f966801


    66







okini3939

0:f2bf5f966801


    67

void isr_http (TCPSocketEvent e) {





okini3939

0:f2bf5f966801


    68







okini3939

0:f2bf5f966801


    69

#ifdef DEBUG





okini3939

0:f2bf5f966801


    70

    printf("tcp(%d)\r\n", e);





okini3939

0:f2bf5f966801


    71

#endif





okini3939

0:f2bf5f966801


    72

    switch(e) {





okini3939

0:f2bf5f966801


    73

    case TCPSOCKET_READABLE: //Incoming data





okini3939

0:f2bf5f966801


    74

        tcp_status = STATUS_READABLE;





okini3939

0:f2bf5f966801


    75

        break;





okini3939

0:f2bf5f966801


    76







okini3939

0:f2bf5f966801


    77

    case TCPSOCKET_CONNECTED:





okini3939

0:f2bf5f966801


    78

    case TCPSOCKET_WRITEABLE: //We can send data





okini3939

0:f2bf5f966801


    79

        tcp_status = STATUS_CONNECTED;





okini3939

0:f2bf5f966801


    80

        break;





okini3939

0:f2bf5f966801


    81







okini3939

0:f2bf5f966801


    82

    case TCPSOCKET_CONTIMEOUT:





okini3939

0:f2bf5f966801


    83

    case TCPSOCKET_CONRST:





okini3939

0:f2bf5f966801


    84

    case TCPSOCKET_CONABRT:





okini3939

0:f2bf5f966801


    85

    case TCPSOCKET_ERROR:





okini3939

0:f2bf5f966801


    86

        tcp_status = STATUS_ERROR;





okini3939

0:f2bf5f966801


    87

        break;





okini3939

0:f2bf5f966801


    88







okini3939

0:f2bf5f966801


    89

    case TCPSOCKET_DISCONNECTED:





okini3939

0:f2bf5f966801


    90

        tcp_status = STATUS_DISCONNECTED;





okini3939

0:f2bf5f966801


    91

        break;





okini3939

0:f2bf5f966801


    92

    }





okini3939

0:f2bf5f966801


    93

}





okini3939

0:f2bf5f966801


    94







okini3939

0:f2bf5f966801


    95

void createauth (char *user, char *pwd, char *buf) {





okini3939

0:f2bf5f966801


    96

    char tmp[80];





okini3939

0:f2bf5f966801


    97







okini3939

0:f2bf5f966801


    98

    snprintf(tmp, sizeof(tmp), "Authorization: Basic %s:%s\n", user, pwd);





okini3939

0:f2bf5f966801


    99

    base64enc(tmp, strlen(tmp), buf);





okini3939

0:f2bf5f966801


   100

}





okini3939

0:f2bf5f966801


   101







okini3939

0:f2bf5f966801


   102

void isr_dns (DNSReply r) {





okini3939

0:f2bf5f966801


   103







okini3939

0:f2bf5f966801


   104

    if (DNS_FOUND) {





okini3939

0:f2bf5f966801


   105

        dns_status = 1;





okini3939

0:f2bf5f966801


   106

    } else {





okini3939

0:f2bf5f966801


   107

        dns_status = -1;





okini3939

0:f2bf5f966801


   108

    }





okini3939

0:f2bf5f966801


   109

}





okini3939

0:f2bf5f966801


   110







okini3939

0:f2bf5f966801


   111

int httpRequest (int method, Host *host, char *uri, char *head, char *body) {





okini3939

0:f2bf5f966801


   112

    TCPSocketErr err;





okini3939

0:f2bf5f966801


   113

    char buf[500];





okini3939

0:f2bf5f966801


   114

    int i, ret = -1;





okini3939

0:f2bf5f966801


   115







okini3939

0:f2bf5f966801


   116

    http = new TCPSocket;





okini3939

0:f2bf5f966801


   117

    tcp_status = STATUS_NONE;





okini3939

0:f2bf5f966801


   118







okini3939

0:f2bf5f966801


   119

    http->setOnEvent(isr_http);





okini3939

0:f2bf5f966801


   120







okini3939

0:f2bf5f966801


   121

    // connect





okini3939

0:f2bf5f966801


   122

    if (host->getIp().isNull()) {





okini3939

0:f2bf5f966801


   123

        DNSRequest dns;





okini3939

0:f2bf5f966801


   124

        dns_status = 0;





okini3939

0:f2bf5f966801


   125

        dns.setOnReply(isr_dns);





okini3939

0:f2bf5f966801


   126

        if (dns.resolve(host) != DNS_OK) goto exit;





okini3939

0:f2bf5f966801


   127

        for (i = 0; i < HTTP_TIMEOUT / 10; i ++) {





okini3939

0:f2bf5f966801


   128

            if (dns_status) break;





okini3939

0:f2bf5f966801


   129

            Net::poll();





okini3939

0:f2bf5f966801


   130

            wait_ms(10);





okini3939

0:f2bf5f966801


   131

        }





okini3939

0:f2bf5f966801


   132

        while (dns_status < 0) goto exit;





okini3939

0:f2bf5f966801


   133

    }





okini3939

0:f2bf5f966801


   134

    if (! host->getPort()) {





okini3939

0:f2bf5f966801


   135

        host->setPort(HTTP_PORT);





okini3939

0:f2bf5f966801


   136

    }





okini3939

0:f2bf5f966801


   137

    err = http->connect(*host);





okini3939

0:f2bf5f966801


   138

    if (err != TCPSOCKET_OK) goto exit;





okini3939

0:f2bf5f966801


   139







okini3939

0:f2bf5f966801


   140

    // wait connect





okini3939

0:f2bf5f966801


   141

    for (i = 0; i < HTTP_TIMEOUT / 10; i ++) {





okini3939

0:f2bf5f966801


   142

        if (tcp_status != STATUS_NONE) break;





okini3939

0:f2bf5f966801


   143

        Net::poll();





okini3939

0:f2bf5f966801


   144

        wait_ms(10);





okini3939

0:f2bf5f966801


   145

    }





okini3939

0:f2bf5f966801


   146

    if (tcp_status != STATUS_CONNECTED) goto exit;





okini3939

0:f2bf5f966801


   147







okini3939

0:f2bf5f966801


   148

    // send request





okini3939

0:f2bf5f966801


   149

    if (method == METHOD_POST) {





okini3939

0:f2bf5f966801


   150

        http->send("POST ", 5);





okini3939

0:f2bf5f966801


   151

    } else {





okini3939

0:f2bf5f966801


   152

        http->send("GET ", 4);





okini3939

0:f2bf5f966801


   153

    }





okini3939

0:f2bf5f966801


   154

    http->send(uri, strlen(uri));





okini3939

0:f2bf5f966801


   155

    http->send(" HTTP/1.1\r\nHost: ", 17);





okini3939

0:f2bf5f966801


   156

    http->send(host->getName(), strlen(host->getName()));





okini3939

0:f2bf5f966801


   157

    http->send("\r\n", 2);





okini3939

0:f2bf5f966801


   158

    if (head) {





okini3939

0:f2bf5f966801


   159

        http->send(head, strlen(head));





okini3939

0:f2bf5f966801


   160

    }





okini3939

0:f2bf5f966801


   161

    if (method == METHOD_POST) {





okini3939

0:f2bf5f966801


   162

        sprintf(buf, "Content-Length: %d\r\n", strlen(body));





okini3939

0:f2bf5f966801


   163

        http->send(buf, strlen(buf));





okini3939

0:f2bf5f966801


   164

    }





okini3939

0:f2bf5f966801


   165

    http->send("\r\n", 2);





okini3939

0:f2bf5f966801


   166







okini3939

0:f2bf5f966801


   167

    // post method





okini3939

0:f2bf5f966801


   168

    if (method == METHOD_POST && body) {





okini3939

0:f2bf5f966801


   169

        http->send(body, strlen(body));





okini3939

0:f2bf5f966801


   170

    }





okini3939

0:f2bf5f966801


   171







okini3939

0:f2bf5f966801


   172

    // wait responce





okini3939

0:f2bf5f966801


   173

    for (i = 0; i < 1500; i ++) {





okini3939

0:f2bf5f966801


   174

        if (tcp_status != STATUS_CONNECTED) break;





okini3939

0:f2bf5f966801


   175

        Net::poll();





okini3939

0:f2bf5f966801


   176

        wait_ms(10);





okini3939

0:f2bf5f966801


   177

    }





okini3939

0:f2bf5f966801


   178

    if (tcp_status != STATUS_READABLE) goto exit;





okini3939

0:f2bf5f966801


   179







okini3939

0:f2bf5f966801


   180

    // recv responce





okini3939

0:f2bf5f966801


   181

    i = http->recv(buf, sizeof(buf));





okini3939

0:f2bf5f966801


   182

    buf[i] = 0;





okini3939

0:f2bf5f966801


   183

    if (strncmp(buf, "HTTP", 4) == 0) {





okini3939

0:f2bf5f966801


   184

        ret = atoi(&buf[9]);





okini3939

0:f2bf5f966801


   185

    }





okini3939

0:f2bf5f966801


   186

#ifdef DEBUG





okini3939

0:f2bf5f966801


   187

    printf(buf);





okini3939

0:f2bf5f966801


   188

#endif





okini3939

0:f2bf5f966801


   189







okini3939

0:f2bf5f966801


   190

    // recv dummy





okini3939

0:f2bf5f966801


   191

    for (i = 0; i < HTTP_TIMEOUT / 10; i ++) {





okini3939

0:f2bf5f966801


   192

        switch (tcp_status) {





okini3939

0:f2bf5f966801


   193

        case STATUS_READABLE:





okini3939

0:f2bf5f966801


   194

            int n = http->recv(buf, sizeof(buf));





okini3939

0:f2bf5f966801


   195

            buf[n] = 0;





okini3939

0:f2bf5f966801


   196

            i = 0;





okini3939

0:f2bf5f966801


   197

#ifdef DEBUG





okini3939

0:f2bf5f966801


   198

            printf(buf);





okini3939

0:f2bf5f966801


   199

#endif





okini3939

0:f2bf5f966801


   200

            break;





okini3939

0:f2bf5f966801


   201

        case STATUS_DISCONNECTED:





okini3939

0:f2bf5f966801


   202

        case STATUS_ERROR:





okini3939

0:f2bf5f966801


   203

            goto exit;





okini3939

0:f2bf5f966801


   204

        }





okini3939

0:f2bf5f966801


   205

        Net::poll();





okini3939

0:f2bf5f966801


   206

        wait_ms(10);





okini3939

0:f2bf5f966801


   207

    }





okini3939

0:f2bf5f966801


   208







okini3939

0:f2bf5f966801


   209

exit:





okini3939

0:f2bf5f966801


   210

    http->resetOnEvent();





okini3939

0:f2bf5f966801


   211

    http->close();





okini3939

0:f2bf5f966801


   212

    delete http;





okini3939

0:f2bf5f966801


   213







okini3939

0:f2bf5f966801


   214

    return ret;





okini3939

0:f2bf5f966801


   215

}