rizin/libr/socket/http.c
pancake 96accbd14b Begin r_io review. Fix r_socket_http query for xpcshell's httpd.js
- Added libr/io/README in order to documentate the api
- Some minor refactoring and code cleanup in libr/io
- Fix hexdump title
2013-05-31 02:09:45 +02:00

140 lines
3 KiB
C

/* radare - LGPL - Copyright 2011-2013 - pancake */
#include <r_socket.h>
#include <r_util.h>
static char *r_socket_http_answer (RSocket *s, int *code, int *rlen) {
const char *p, *dn;
int len, bufsz = 32768;
char *buf = malloc (bufsz); // XXX: use r_buffer here
/* Read Header */
char *resp;
len = r_socket_read_block (s, (unsigned char*) buf, bufsz);
if (len < 1) return 0;
if ((dn = r_str_casestr (buf, "\n\n"))) {
dn += 2;
} else if ((dn = r_str_casestr (buf, "\r\n\r\n"))) {
dn += 4;
} else return 0;
/* Parse Len */
p = r_str_casestr (buf, "Content-Length: ");
if (p)
len = atoi (p+16);
else len = len - (dn - buf);
resp = malloc (len+1);
memcpy (resp, dn, len);
resp[len] = '\n';
free (buf);
r_socket_close (s);
if (rlen) *rlen = len;
return resp;
}
R_API char *r_socket_http_get (const char *url, int *code, int *rlen) {
RSocket *s;
int ssl = !memcmp (url, "https://", 8);
char *response, *host, *path, *port = "80";
char *uri = strdup (url);
host = strstr (uri, "://");
if (!host) {
free (uri);
printf ("Invalid URI");
return NULL;
}
host += 3;
port = strchr (host, ':');
if (!port) {
port = (ssl)?"443":"80";
path = host;
} else {
*port++ = 0;
path = port;
}
path = strchr (path, '/');
if (!path) path = "";
else *path++ = 0;
s = r_socket_new (ssl);
if (!s) {
printf ("Cannot create socket\n");
free (uri);
return NULL;
}
if (!r_socket_connect_tcp (s, host, port, 0)) {
eprintf ("Cannot connect to %s:%s\n", host, port);
free (uri);
return NULL;
}
/* Send */
r_socket_printf (s,
"GET /%s HTTP/1.1\r\n"
"User-Agent: radare2 "R2_VERSION"\r\n"
"Accept: */*\r\n"
"Host: %s:%s\r\n"
"\r\n", path, host, port);
response = r_socket_http_answer (s, code, rlen);
free (uri);
return response;
}
R_API char *r_socket_http_post (const char *url, const char *data, int *code, int *rlen) {
RSocket *s;
int ssl = !memcmp (url, "https://", 8);
char *response, *host, *path, *port = "80";
char *uri = strdup (url);
host = strstr (uri, "://");
if (!host) {
free (uri);
printf ("Invalid URI");
return NULL;
}
host += 3;
port = strchr (host, ':');
if (!port)
port = (ssl)?"443":"80";
else
*port++ = 0;
path = strchr (host, '/');
if (!path)
path = "";
else
*path++ = 0;
s = r_socket_new (ssl);
if (!s) {
printf ("Cannot create socket\n");
free (uri);
return NULL;
}
if (!r_socket_connect_tcp (s, host, port, 0)) {
eprintf ("Cannot connect to %s:%s\n", host, port);
free (uri);
return NULL;
}
/* Send */
r_socket_printf (s,
"POST /%s HTTP/1.0\r\n"
"User-Agent: radare2 "R2_VERSION"\r\n"
"Accept: */*\r\n"
"Host: %s\r\n"
"Content-Length: %i\r\n"
"Content-Type: application/x-www-form-urlencoded\r\n"
"\r\n", path, host, strlen (data));
r_socket_write (s, (void *)data, strlen (data));
response = r_socket_http_answer (s, code, rlen);
free (uri);
return response;
}
#if TEST
void main () {
int ret;
char *p = r_socket_http_post ("http://www.radare.org/y/index.php", "a=b", &ret);
printf ("%s\n", p);
}
#endif