mirror of
https://github.com/libretro/RetroArch.git
synced 2024-10-07 14:23:29 +00:00
472 lines
9.5 KiB
C
472 lines
9.5 KiB
C
/* RetroArch - A frontend for libretro.
|
|
* Copyright (C) 2011-2015 - Daniel De Matteis
|
|
* Copyright (C) 2014-2015 - Alfred Agrell
|
|
*
|
|
* RetroArch is free software: you can redistribute it and/or modify it under the terms
|
|
* of the GNU General Public License as published by the Free Software Found-
|
|
* ation, either version 3 of the License, or (at your option) any later version.
|
|
*
|
|
* RetroArch is distributed in the hope that it will be useful, but WITHOUT ANY WARRANTY;
|
|
* without even the implied warranty of MERCHANTABILITY or FITNESS FOR A PARTICULAR
|
|
* PURPOSE. See the GNU General Public License for more details.
|
|
*
|
|
* You should have received a copy of the GNU General Public License along with RetroArch.
|
|
* If not, see <http://www.gnu.org/licenses/>.
|
|
*/
|
|
|
|
#include "net_http.h"
|
|
#include <stdio.h>
|
|
#include <stdlib.h>
|
|
#include <ctype.h>
|
|
#include "netplay_compat.h"
|
|
#include <compat/strl.h>
|
|
|
|
enum
|
|
{
|
|
p_header_top,
|
|
p_header,
|
|
p_body,
|
|
p_body_chunklen,
|
|
p_done,
|
|
p_error
|
|
};
|
|
|
|
enum
|
|
{
|
|
t_full,
|
|
t_len, t_chunk
|
|
};
|
|
|
|
static bool net_http_parse_url(char *url, char **domain,
|
|
int *port, char **location)
|
|
{
|
|
char* scan;
|
|
|
|
if (strncmp(url, "http://", strlen("http://")) != 0)
|
|
return false;
|
|
|
|
scan = url + strlen("http://");
|
|
*domain = scan;
|
|
|
|
while (*scan != '/' && *scan != ':' && *scan != '\0')
|
|
scan++;
|
|
|
|
if (*scan == '\0')
|
|
return false;
|
|
|
|
*scan = '\0';
|
|
*port = 80;
|
|
|
|
if (*scan == ':')
|
|
{
|
|
|
|
if (!isdigit(scan[1]))
|
|
return false;
|
|
|
|
*port = strtoul(scan + 1, &scan, 10);
|
|
|
|
if (*scan != '/')
|
|
return false;
|
|
}
|
|
|
|
*location = scan + 1;
|
|
|
|
return true;
|
|
}
|
|
|
|
static int net_http_new_socket(const char * domain, int port)
|
|
{
|
|
int fd, i = 1;
|
|
#ifdef _WIN32
|
|
u_long mode = 1;
|
|
#else
|
|
struct timeval timeout;
|
|
#endif
|
|
struct addrinfo hints, *addr = NULL;
|
|
char portstr[16];
|
|
|
|
snprintf(portstr, sizeof(portstr), "%i", port);
|
|
|
|
memset(&hints, 0, sizeof(hints));
|
|
hints.ai_family = AF_UNSPEC;
|
|
hints.ai_socktype = SOCK_STREAM;
|
|
hints.ai_flags = 0;
|
|
|
|
if (getaddrinfo_rarch(domain, portstr, &hints, &addr) < 0)
|
|
return -1;
|
|
|
|
(void)i;
|
|
|
|
fd = socket(addr->ai_family, addr->ai_socktype, addr->ai_protocol);
|
|
|
|
#ifndef _WIN32
|
|
timeout.tv_sec=4;
|
|
timeout.tv_usec=0;
|
|
setsockopt(fd, SOL_SOCKET, SO_SNDTIMEO, (char*)&timeout, sizeof timeout);
|
|
#endif
|
|
|
|
if (connect(fd, addr->ai_addr, addr->ai_addrlen) != 0)
|
|
{
|
|
freeaddrinfo_rarch(addr);
|
|
socket_close(fd);
|
|
return -1;
|
|
}
|
|
|
|
freeaddrinfo_rarch(addr);
|
|
|
|
if (!socket_nonblock(fd))
|
|
{
|
|
socket_close(fd);
|
|
return -1;
|
|
}
|
|
|
|
return fd;
|
|
}
|
|
|
|
static void net_http_send(int fd, bool * error,
|
|
const char * data, size_t len)
|
|
{
|
|
if (*error)
|
|
return;
|
|
|
|
while (len)
|
|
{
|
|
ssize_t thislen = send(fd, data, len, MSG_NOSIGNAL);
|
|
|
|
if (thislen <= 0)
|
|
{
|
|
if (!isagain(thislen))
|
|
continue;
|
|
|
|
*error=true;
|
|
return;
|
|
}
|
|
|
|
data += thislen;
|
|
len -= thislen;
|
|
}
|
|
}
|
|
|
|
static void net_http_send_str(int fd, bool *error, const char *text)
|
|
{
|
|
net_http_send(fd, error, text, strlen(text));
|
|
}
|
|
|
|
static ssize_t net_http_recv(int fd, bool *error,
|
|
uint8_t *data, size_t maxlen)
|
|
{
|
|
ssize_t bytes;
|
|
|
|
if (*error)
|
|
return -1;
|
|
|
|
bytes = recv(fd, (char*)data, maxlen, 0);
|
|
|
|
if (bytes > 0)
|
|
return bytes;
|
|
else if (bytes == 0)
|
|
return -1;
|
|
else if (isagain(bytes))
|
|
return 0;
|
|
|
|
*error=true;
|
|
return -1;
|
|
}
|
|
|
|
http_t *net_http_new(const char * url)
|
|
{
|
|
bool error;
|
|
char *domain = NULL, *location = NULL;
|
|
int port = 0, fd = -1;
|
|
http_t *state = NULL;
|
|
char *urlcopy =(char*)malloc(strlen(url)+1);
|
|
|
|
strcpy(urlcopy, url);
|
|
|
|
if (!net_http_parse_url(urlcopy, &domain, &port, &location))
|
|
goto fail;
|
|
|
|
fd = net_http_new_socket(domain, port);
|
|
if (fd == -1)
|
|
goto fail;
|
|
|
|
error=false;
|
|
|
|
/* This is a bit lazy, but it works. */
|
|
net_http_send_str(fd, &error, "GET /");
|
|
net_http_send_str(fd, &error, location);
|
|
net_http_send_str(fd, &error, " HTTP/1.1\r\n");
|
|
|
|
net_http_send_str(fd, &error, "Host: ");
|
|
net_http_send_str(fd, &error, domain);
|
|
|
|
if (port!=80)
|
|
{
|
|
char portstr[16];
|
|
|
|
snprintf(portstr, sizeof(portstr), ":%i", port);
|
|
net_http_send_str(fd, &error, portstr);
|
|
}
|
|
|
|
net_http_send_str(fd, &error, "\r\n");
|
|
net_http_send_str(fd, &error, "Connection: close\r\n");
|
|
net_http_send_str(fd, &error, "\r\n");
|
|
|
|
if (error)
|
|
goto fail;
|
|
|
|
free(urlcopy);
|
|
|
|
state = (http_t*)malloc(sizeof(http_t));
|
|
state->fd = fd;
|
|
state->status = -1;
|
|
state->data = NULL;
|
|
state->part = p_header_top;
|
|
state->bodytype= t_full;
|
|
state->error = false;
|
|
state->pos = 0;
|
|
state->len = 0;
|
|
state->buflen = 512;
|
|
state->data = (char*)malloc(state->buflen);
|
|
|
|
return state;
|
|
|
|
fail:
|
|
if (fd != -1)
|
|
socket_close(fd);
|
|
free(urlcopy);
|
|
return NULL;
|
|
}
|
|
|
|
int net_http_fd(http_t *state)
|
|
{
|
|
return state->fd;
|
|
}
|
|
|
|
bool net_http_update(http_t *state, size_t* progress, size_t* total)
|
|
{
|
|
ssize_t newlen = 0;
|
|
|
|
if (state->error)
|
|
goto fail;
|
|
|
|
if (state->part < p_body)
|
|
{
|
|
newlen = net_http_recv(state->fd, &state->error,
|
|
(uint8_t*)state->data + state->pos, state->buflen - state->pos);
|
|
|
|
if (newlen < 0)
|
|
goto fail;
|
|
|
|
if (state->pos + newlen >= state->buflen - 64)
|
|
{
|
|
state->buflen *= 2;
|
|
state->data = (char*)realloc(state->data, state->buflen);
|
|
}
|
|
state->pos += newlen;
|
|
|
|
while (state->part < p_body)
|
|
{
|
|
char *dataend = state->data + state->pos;
|
|
char *lineend = (char*)memchr(state->data, '\n', state->pos);
|
|
|
|
if (!lineend)
|
|
break;
|
|
*lineend='\0';
|
|
if (lineend != state->data && lineend[-1]=='\r')
|
|
lineend[-1]='\0';
|
|
|
|
if (state->part == p_header_top)
|
|
{
|
|
if (strncmp(state->data, "HTTP/1.", strlen("HTTP/1."))!=0)
|
|
goto fail;
|
|
state->status=strtoul(state->data + strlen("HTTP/1.1 "), NULL, 10);
|
|
state->part = p_header;
|
|
}
|
|
else
|
|
{
|
|
if (!strncmp(state->data, "Content-Length: ",
|
|
strlen("Content-Length: ")))
|
|
{
|
|
state->bodytype = t_len;
|
|
state->len = strtol(state->data +
|
|
strlen("Content-Length: "), NULL, 10);
|
|
}
|
|
if (!strcmp(state->data, "Transfer-Encoding: chunked"))
|
|
{
|
|
state->bodytype=t_chunk;
|
|
}
|
|
|
|
/* TODO: save headers somewhere */
|
|
if (state->data[0]=='\0')
|
|
{
|
|
state->part = p_body;
|
|
if (state->bodytype == t_chunk)
|
|
state->part = p_body_chunklen;
|
|
}
|
|
}
|
|
|
|
memmove(state->data, lineend + 1, dataend-(lineend+1));
|
|
state->pos = (dataend-(lineend + 1));
|
|
}
|
|
if (state->part >= p_body)
|
|
{
|
|
newlen = state->pos;
|
|
state->pos = 0;
|
|
}
|
|
}
|
|
|
|
if (state->part >= p_body && state->part < p_done)
|
|
{
|
|
if (!newlen)
|
|
{
|
|
newlen = net_http_recv(state->fd, &state->error,
|
|
(uint8_t*)state->data + state->pos,
|
|
state->buflen - state->pos);
|
|
|
|
if (newlen < 0)
|
|
{
|
|
if (state->bodytype == t_full)
|
|
{
|
|
state->part = p_done;
|
|
state->data = (char*)realloc(state->data, state->len);
|
|
}
|
|
else
|
|
goto fail;
|
|
newlen=0;
|
|
}
|
|
|
|
if (state->pos + newlen >= state->buflen - 64)
|
|
{
|
|
state->buflen *= 2;
|
|
state->data = (char*)realloc(state->data, state->buflen);
|
|
}
|
|
}
|
|
|
|
parse_again:
|
|
if (state->bodytype == t_chunk)
|
|
{
|
|
if (state->part == p_body_chunklen)
|
|
{
|
|
state->pos += newlen;
|
|
if (state->pos - state->len >= 2)
|
|
{
|
|
/*
|
|
* len=start of chunk including \r\n
|
|
* pos=end of data
|
|
*/
|
|
|
|
char *fullend = state->data + state->pos;
|
|
char *end = (char*)memchr(state->data + state->len + 2,
|
|
'\n', state->pos - state->len - 2);
|
|
|
|
if (end)
|
|
{
|
|
size_t chunklen = strtoul(state->data+state->len, NULL, 16);
|
|
state->pos = state->len;
|
|
end++;
|
|
|
|
memmove(state->data+state->len, end, fullend-end);
|
|
|
|
state->len = chunklen;
|
|
newlen = (fullend - end);
|
|
|
|
/*
|
|
len=num bytes
|
|
newlen=unparsed bytes after \n
|
|
pos=start of chunk including \r\n
|
|
*/
|
|
|
|
state->part = p_body;
|
|
if (state->len == 0)
|
|
{
|
|
state->part = p_done;
|
|
state->len = state->pos;
|
|
state->data = (char*)realloc(state->data, state->len);
|
|
}
|
|
goto parse_again;
|
|
}
|
|
}
|
|
}
|
|
else if (state->part == p_body)
|
|
{
|
|
if ((size_t)newlen >= state->len)
|
|
{
|
|
state->pos += state->len;
|
|
newlen -= state->len;
|
|
state->len = state->pos;
|
|
state->part = p_body_chunklen;
|
|
goto parse_again;
|
|
}
|
|
else
|
|
{
|
|
state->pos += newlen;
|
|
state->len -= newlen;
|
|
}
|
|
}
|
|
}
|
|
else
|
|
{
|
|
state->pos += newlen;
|
|
|
|
if (state->pos == state->len)
|
|
{
|
|
state->part=p_done;
|
|
state->data = (char*)realloc(state->data, state->len);
|
|
}
|
|
if (state->pos > state->len)
|
|
goto fail;
|
|
}
|
|
}
|
|
|
|
if (progress)
|
|
*progress = state->pos;
|
|
|
|
if (total)
|
|
{
|
|
if (state->bodytype == t_len)
|
|
*total=state->len;
|
|
else
|
|
*total=0;
|
|
}
|
|
|
|
return (state->part==p_done);
|
|
|
|
fail:
|
|
state->error = true;
|
|
state->part = p_error;
|
|
state->status = -1;
|
|
|
|
return true;
|
|
}
|
|
|
|
int net_http_status(http_t *state)
|
|
{
|
|
return state->status;
|
|
}
|
|
|
|
uint8_t* net_http_data(http_t *state, size_t* len, bool accept_error)
|
|
{
|
|
if (!accept_error &&
|
|
(state->error || state->status<200 || state->status>299))
|
|
{
|
|
if (len)
|
|
*len=0;
|
|
return NULL;
|
|
}
|
|
|
|
if (len)
|
|
*len=state->len;
|
|
|
|
return (uint8_t*)state->data;
|
|
}
|
|
|
|
void net_http_delete(http_t *state)
|
|
{
|
|
if (state->fd != -1)
|
|
socket_close(state->fd);
|
|
if (state->data)
|
|
free(state->data);
|
|
free(state);
|
|
}
|