WeatherStation - mbed Weather Platform firmware http://mbed.org/us…

Users » okini3939 » Code » WeatherStation

Suga koubou / Mbed 2 deprecated WeatherStation

mbed Weather Platform firmware http://mbed.org/users/okini3939/notebook/mbed-weather-platform-firmware/

Dependencies: ChaNFSSD EthernetNetIf I2CLEDDisp Agentbed ChaNFSUSB ILinterpreter mbed BMP085 WeatherMeters ConfigFile ChaNFS I2CLCD

TinyNet/TinyHTTP.cpp@8:bed0b81794ba, 2012-03-16 (annotated)

Committer:: okini3939
Date:: Fri Mar 16 15:26:46 2012 +0000
Revision:: 8:bed0b81794ba
Parent:: 3:058292da2cee

Who changed what in which revision?

User	Revision	Line number	New contents of line
okini3939	3:058292da2cee	1	/*
okini3939	3:058292da2cee	2	* mbed Tiny HTTP Client
okini3939	3:058292da2cee	3	* Copyright (c) 2011 Hiroshi Suga
okini3939	3:058292da2cee	4	* Released under the MIT License: http://mbed.org/license/mit
okini3939	3:058292da2cee	5	*/
okini3939	3:058292da2cee	6
okini3939	3:058292da2cee	7	/** @file
okini3939	3:058292da2cee	8	* @brief Tiny HTTP Client
okini3939	3:058292da2cee	9	*/
okini3939	3:058292da2cee	10
okini3939	3:058292da2cee	11	#include "mbed.h"
okini3939	3:058292da2cee	12	#include "EthernetNetIf.h"
okini3939	3:058292da2cee	13	#include "TCPSocket.h"
okini3939	3:058292da2cee	14	#include "DNSRequest.h"
okini3939	3:058292da2cee	15	#include "TinyHTTP.h"
okini3939	3:058292da2cee	16	#include <ctype.h>
okini3939	3:058292da2cee	17
okini3939	3:058292da2cee	18
okini3939	3:058292da2cee	19	static TCPSocket *http;
okini3939	3:058292da2cee	20	static volatile int tcp_ready, tcp_readable, tcp_writable;
okini3939	3:058292da2cee	21	static volatile int dns_status;
okini3939	3:058292da2cee	22
okini3939	3:058292da2cee	23	// Copyright (c) 2010 Donatien Garnier (donatiengar [at] gmail [dot] com)
okini3939	3:058292da2cee	24	static int base64enc(const char input, unsigned int length, char output, int len) {
okini3939	3:058292da2cee	25	static const char base64[] = "ABCDEFGHIJKLMNOPQRSTUVWXYZabcdefghijklmnopqrstuvwxyz0123456789+/";
okini3939	3:058292da2cee	26	unsigned int c, c1, c2, c3;
okini3939	3:058292da2cee	27
okini3939	3:058292da2cee	28	if (len < ((((length-1)/3)+1)<<2)) return -1;
okini3939	3:058292da2cee	29	for(unsigned int i = 0, j = 0; i<length; i+=3,j+=4) {
okini3939	3:058292da2cee	30	c1 = ((((unsigned char)((unsigned char )&input[i]))));
okini3939	3:058292da2cee	31	c2 = (length>i+1)?((((unsigned char)((unsigned char )&input[i+1])))):0;
okini3939	3:058292da2cee	32	c3 = (length>i+2)?((((unsigned char)((unsigned char )&input[i+2])))):0;
okini3939	3:058292da2cee	33
okini3939	3:058292da2cee	34	c = ((c1 & 0xFC) >> 2);
okini3939	3:058292da2cee	35	output[j+0] = base64[c];
okini3939	3:058292da2cee	36	c = ((c1 & 0x03) << 4) \| ((c2 & 0xF0) >> 4);
okini3939	3:058292da2cee	37	output[j+1] = base64[c];
okini3939	3:058292da2cee	38	c = ((c2 & 0x0F) << 2) \| ((c3 & 0xC0) >> 6);
okini3939	3:058292da2cee	39	output[j+2] = (length>i+1)?base64[c]:'=';
okini3939	3:058292da2cee	40	c = (c3 & 0x3F);
okini3939	3:058292da2cee	41	output[j+3] = (length>i+2)?base64[c]:'=';
okini3939	3:058292da2cee	42	}
okini3939	3:058292da2cee	43	output[(((length-1)/3)+1)<<2] = '\0';
okini3939	3:058292da2cee	44	return 0;
okini3939	3:058292da2cee	45	}
okini3939	3:058292da2cee	46
okini3939	3:058292da2cee	47	// Copyright (c) 2010 Donatien Garnier (donatiengar [at] gmail [dot] com)
okini3939	3:058292da2cee	48	int urlencode(char str, char buf, int len) {
okini3939	3:058292da2cee	49	static const char to_hex[] = "0123456789ABCDEF";
okini3939	3:058292da2cee	50	// char pstr = str, buf = (char)malloc(strlen(str) 3 + 1), *pbuf = buf;
okini3939	3:058292da2cee	51	char pstr = str, pbuf = buf;
okini3939	3:058292da2cee	52
okini3939	3:058292da2cee	53	if (len < (strlen(str) * 3 + 1)) return -1;
okini3939	3:058292da2cee	54	while (*pstr) {
okini3939	3:058292da2cee	55	if (isalnum(pstr) \|\| pstr == '-' \|\| pstr == '_' \|\| pstr == '.' \|\| *pstr == '~') {
okini3939	3:058292da2cee	56	pbuf++ = pstr;
okini3939	3:058292da2cee	57	} else if (*pstr == ' ') {
okini3939	3:058292da2cee	58	*pbuf++ = '+';
okini3939	3:058292da2cee	59	} else {
okini3939	3:058292da2cee	60	*pbuf++ = '%';
okini3939	3:058292da2cee	61	pbuf++ = to_hex[(pstr >> 4) & 0x0f];
okini3939	3:058292da2cee	62	pbuf++ = to_hex[pstr & 0x0f];
okini3939	3:058292da2cee	63	}
okini3939	3:058292da2cee	64	pstr++;
okini3939	3:058292da2cee	65	}
okini3939	3:058292da2cee	66	*pbuf = '\0';
okini3939	3:058292da2cee	67	return 0;
okini3939	3:058292da2cee	68	}
okini3939	3:058292da2cee	69
okini3939	3:058292da2cee	70
okini3939	3:058292da2cee	71	void isr_http (TCPSocketEvent e) {
okini3939	3:058292da2cee	72
okini3939	3:058292da2cee	73	#ifdef DEBUG
okini3939	3:058292da2cee	74	printf("tcp(%d)\r\n", e);
okini3939	3:058292da2cee	75	#endif
okini3939	3:058292da2cee	76	switch(e) {
okini3939	3:058292da2cee	77	case TCPSOCKET_CONNECTED:
okini3939	3:058292da2cee	78	tcp_ready = 1;
okini3939	3:058292da2cee	79	break;
okini3939	3:058292da2cee	80
okini3939	3:058292da2cee	81	case TCPSOCKET_READABLE: //Incoming data
okini3939	3:058292da2cee	82	tcp_readable = 1;
okini3939	3:058292da2cee	83	break;
okini3939	3:058292da2cee	84
okini3939	3:058292da2cee	85	case TCPSOCKET_WRITEABLE: //We can send data
okini3939	3:058292da2cee	86	tcp_writable = 1;
okini3939	3:058292da2cee	87	break;
okini3939	3:058292da2cee	88
okini3939	3:058292da2cee	89	case TCPSOCKET_CONTIMEOUT:
okini3939	3:058292da2cee	90	case TCPSOCKET_CONRST:
okini3939	3:058292da2cee	91	case TCPSOCKET_CONABRT:
okini3939	3:058292da2cee	92	case TCPSOCKET_ERROR:
okini3939	3:058292da2cee	93	case TCPSOCKET_DISCONNECTED:
okini3939	3:058292da2cee	94	tcp_ready = 0;
okini3939	3:058292da2cee	95	break;
okini3939	3:058292da2cee	96	}
okini3939	3:058292da2cee	97	}
okini3939	3:058292da2cee	98
okini3939	3:058292da2cee	99	void createauth (char user, char pwd, char *buf, int len) {
okini3939	3:058292da2cee	100	char tmp[80];
okini3939	3:058292da2cee	101
okini3939	3:058292da2cee	102	strncpy(buf, "Authorization: Basic ", len);
okini3939	3:058292da2cee	103	snprintf(tmp, sizeof(tmp), "%s:%s", user, pwd);
okini3939	3:058292da2cee	104	base64enc(tmp, strlen(tmp), &buf[strlen(buf)], len - strlen(buf));
okini3939	3:058292da2cee	105	strncat(buf, "\r\n", len - strlen(buf));
okini3939	3:058292da2cee	106	}
okini3939	3:058292da2cee	107
okini3939	3:058292da2cee	108	static void isr_dns (DNSReply r) {
okini3939	3:058292da2cee	109
okini3939	3:058292da2cee	110	#ifdef DEBUG
okini3939	3:058292da2cee	111	printf("dns(%d)\r\n", r);
okini3939	3:058292da2cee	112	#endif
okini3939	3:058292da2cee	113	if (DNS_FOUND) {
okini3939	3:058292da2cee	114	dns_status = 1;
okini3939	3:058292da2cee	115	} else {
okini3939	3:058292da2cee	116	dns_status = -1;
okini3939	3:058292da2cee	117	}
okini3939	3:058292da2cee	118	}
okini3939	3:058292da2cee	119
okini3939	3:058292da2cee	120	int httpRequest (int method, Host host, char uri, char head, char body) {
okini3939	3:058292da2cee	121	TCPSocketErr err;
okini3939	3:058292da2cee	122	Timer timeout;
okini3939	3:058292da2cee	123	char buf[1500];
okini3939	3:058292da2cee	124	int i, ret = -1;
okini3939	3:058292da2cee	125
okini3939	3:058292da2cee	126	http = new TCPSocket;
okini3939	3:058292da2cee	127	tcp_ready = 0;
okini3939	3:058292da2cee	128	tcp_readable = 0;
okini3939	3:058292da2cee	129	tcp_writable = 0;
okini3939	3:058292da2cee	130
okini3939	3:058292da2cee	131	http->setOnEvent(isr_http);
okini3939	3:058292da2cee	132
okini3939	3:058292da2cee	133	// connect
okini3939	3:058292da2cee	134	if (host->getIp().isNull()) {
okini3939	3:058292da2cee	135	// resolv
okini3939	3:058292da2cee	136	DNSRequest dns;
okini3939	3:058292da2cee	137	dns_status = 0;
okini3939	3:058292da2cee	138	dns.setOnReply(isr_dns);
okini3939	3:058292da2cee	139	if (dns.resolve(host) != DNS_OK) goto exit;
okini3939	3:058292da2cee	140	timeout.reset();
okini3939	3:058292da2cee	141	timeout.start();
okini3939	3:058292da2cee	142	while (timeout.read_ms() < HTTP_TIMEOUT) {
okini3939	3:058292da2cee	143	if (dns_status) break;
okini3939	3:058292da2cee	144	Net::poll();
okini3939	3:058292da2cee	145	}
okini3939	3:058292da2cee	146	timeout.stop();
okini3939	3:058292da2cee	147	if (dns_status <= 0) goto exit;
okini3939	3:058292da2cee	148	#ifdef DEBUG
okini3939	3:058292da2cee	149	printf("%s [%d.%d.%d.%d]\r\n", host->getName(), (unsigned char)host->getIp()[0], (unsigned char)host->getIp()[1], (unsigned char)host->getIp()[2], (unsigned char)host->getIp()[3]);
okini3939	3:058292da2cee	150	#endif
okini3939	3:058292da2cee	151	}
okini3939	3:058292da2cee	152	if (! host->getPort()) {
okini3939	3:058292da2cee	153	host->setPort(HTTP_PORT);
okini3939	3:058292da2cee	154	}
okini3939	3:058292da2cee	155	err = http->connect(*host);
okini3939	3:058292da2cee	156	if (err != TCPSOCKET_OK) goto exit;
okini3939	3:058292da2cee	157
okini3939	3:058292da2cee	158	// wait connect
okini3939	3:058292da2cee	159	timeout.reset();
okini3939	3:058292da2cee	160	timeout.start();
okini3939	3:058292da2cee	161	while (timeout.read_ms() < HTTP_TIMEOUT) {
okini3939	3:058292da2cee	162	if (tcp_ready) break;
okini3939	3:058292da2cee	163	Net::poll();
okini3939	3:058292da2cee	164	}
okini3939	3:058292da2cee	165	timeout.stop();
okini3939	3:058292da2cee	166	if (! tcp_ready) goto exit;
okini3939	3:058292da2cee	167
okini3939	3:058292da2cee	168	// send request
okini3939	3:058292da2cee	169	if (method == METHOD_POST) {
okini3939	3:058292da2cee	170	http->send("POST ", 5);
okini3939	3:058292da2cee	171	} else {
okini3939	3:058292da2cee	172	http->send("GET ", 4);
okini3939	3:058292da2cee	173	}
okini3939	3:058292da2cee	174	http->send(uri, strlen(uri));
okini3939	3:058292da2cee	175	http->send(" HTTP/1.1\r\nHost: ", 17);
okini3939	3:058292da2cee	176	http->send(host->getName(), strlen(host->getName()));
okini3939	3:058292da2cee	177	http->send("\r\n", 2);
okini3939	3:058292da2cee	178	http->send("Connection: close\r\n", 19);
okini3939	3:058292da2cee	179	if (head) {
okini3939	3:058292da2cee	180	http->send(head, strlen(head));
okini3939	3:058292da2cee	181	}
okini3939	3:058292da2cee	182	if (method == METHOD_POST) {
okini3939	3:058292da2cee	183	sprintf(buf, "Content-Length: %d\r\n", strlen(body));
okini3939	3:058292da2cee	184	http->send(buf, strlen(buf));
okini3939	3:058292da2cee	185	}
okini3939	3:058292da2cee	186	http->send("\r\n", 2);
okini3939	3:058292da2cee	187
okini3939	3:058292da2cee	188	// post method
okini3939	3:058292da2cee	189	if (method == METHOD_POST && body) {
okini3939	3:058292da2cee	190	http->send(body, strlen(body));
okini3939	3:058292da2cee	191	}
okini3939	3:058292da2cee	192
okini3939	3:058292da2cee	193	// wait responce
okini3939	3:058292da2cee	194	timeout.reset();
okini3939	3:058292da2cee	195	timeout.start();
okini3939	3:058292da2cee	196	while (timeout.read_ms() < HTTP_TIMEOUT) {
okini3939	3:058292da2cee	197	if (tcp_readable) break;
okini3939	3:058292da2cee	198	Net::poll();
okini3939	3:058292da2cee	199	}
okini3939	3:058292da2cee	200	timeout.stop();
okini3939	3:058292da2cee	201	if (! tcp_readable) goto exit;
okini3939	3:058292da2cee	202
okini3939	3:058292da2cee	203	// recv responce
okini3939	3:058292da2cee	204	i = http->recv(buf, sizeof(buf) - 1);
okini3939	3:058292da2cee	205	buf[i] = 0;
okini3939	3:058292da2cee	206	if (i < sizeof(buf) - 1) tcp_readable = 0;
okini3939	3:058292da2cee	207	if (strncmp(buf, "HTTP/", 5) == 0) {
okini3939	3:058292da2cee	208	ret = atoi(&buf[9]);
okini3939	3:058292da2cee	209	}
okini3939	3:058292da2cee	210	#ifdef DEBUG
okini3939	3:058292da2cee	211	printf(buf);
okini3939	3:058292da2cee	212	#endif
okini3939	3:058292da2cee	213
okini3939	3:058292da2cee	214	// recv dummy
okini3939	3:058292da2cee	215	timeout.reset();
okini3939	3:058292da2cee	216	timeout.start();
okini3939	3:058292da2cee	217	while (timeout.read_ms() < HTTP_TIMEOUT) {
okini3939	3:058292da2cee	218	if (tcp_readable) {
okini3939	3:058292da2cee	219	i = http->recv(buf, sizeof(buf) - 1);
okini3939	3:058292da2cee	220	buf[i] = 0;
okini3939	3:058292da2cee	221	if (i < sizeof(buf) - 1) tcp_readable = 0;
okini3939	3:058292da2cee	222	#ifdef DEBUG
okini3939	3:058292da2cee	223	printf(buf);
okini3939	3:058292da2cee	224	#endif
okini3939	3:058292da2cee	225	timeout.reset();
okini3939	3:058292da2cee	226	} else
okini3939	3:058292da2cee	227	if (! tcp_ready) {
okini3939	3:058292da2cee	228	break;
okini3939	3:058292da2cee	229	}
okini3939	3:058292da2cee	230	Net::poll();
okini3939	3:058292da2cee	231	}
okini3939	3:058292da2cee	232	timeout.stop();
okini3939	3:058292da2cee	233
okini3939	3:058292da2cee	234	exit:
okini3939	3:058292da2cee	235	http->resetOnEvent();
okini3939	3:058292da2cee	236	http->close();
okini3939	3:058292da2cee	237	delete http;
okini3939	3:058292da2cee	238
okini3939	3:058292da2cee	239	return ret;
okini3939	3:058292da2cee	240	}

Repository toolbox

Export to desktop IDE

Build repository

Repository details

Type:	Program
Mbed OS support:	Mbed 2 deprecated
Created:	04 Jul 2011
Imports:	120
Forks:	0
Commits:	9
Dependents:	0
Dependencies:	12
Followers:	8

TinyNet/TinyHTTP.cpp@8:bed0b81794ba, 2012-03-16 (annotated)

Who changed what in which revision?

Repository toolbox

Repository details

Important Information for this Arm website

Access Warning