Diffstat (limited to 'noncore/todayplugins/stockticker/libstocks/http.c') (more/less context) (ignore whitespace changes)
| -rw-r--r-- | noncore/todayplugins/stockticker/libstocks/http.c | 300 |
1 files changed, 300 insertions, 0 deletions
diff --git a/noncore/todayplugins/stockticker/libstocks/http.c b/noncore/todayplugins/stockticker/libstocks/http.c new file mode 100644 index 0000000..462080d --- a/dev/null +++ b/noncore/todayplugins/stockticker/libstocks/http.c @@ -0,0 +1,300 @@ +/* libstocks - Library to get current stock quotes from Yahoo Finance + * + * Copyright (C) 2000 Eric Laeuffer + * + * This library is free software; you can redistribute it and/or + * modify it under the terms of the GNU Library General Public + * License as published by the Free Software Foundation; either + * version 2 of the License, or (at your option) any later version. + * + * This library 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 + * Library General Public License for more details. + * + * You should have received a copy of the GNU Library General Public + * License along with this library; if not, write to the + * Free Software Foundation, Inc., 59 Temple Place - Suite 330, + * Boston, MA 02111-1307, USA. + */ + +#define __HTTP_C__ + +#ifdef __UNIX__ +#include <sys/socket.h> +#include <netinet/in.h> +#include <arpa/inet.h> +#include <netdb.h> +#include <unistd.h> +#elif __WINDOWS__ +#include <winsock.h> +#include <mbstring.h> +#endif + +#include <sys/types.h> +#include <ctype.h> +#include <string.h> +#include <stdlib.h> +#include <stdio.h> + +#include "http.h" +#include "stocks.h" + +#define BUF_SIZE 1024 +#define HEADER_MAXBUF 512 + +/* pointer to proxy server name or NULL */ +char *http_proxy_server=NULL; +/* proxy server port number or 0 */ +int http_proxy_port=0; + +/*****************************************************************************/ +/* Gets the file from http://http_server/http_file */ +/* This function is used to get quotes csv file from yahoo. */ +/* It allocates memory for the file and defines *pdata (the pointer of datas)*/ +/*****************************************************************************/ +libstocks_return_code http_get(char *http_file, char *http_server, char **pdata) +{ + struct hostent *host; /* structs needed by socket */ + struct sockaddr_in server; + int s; /* socket descriptor */ + char header[HEADER_MAXBUF]; /* request header */ + int hlg; /* header length */ + char buf[BUF_SIZE+1]; /* tempory buffer from socket read */ + int r; /* number of bytes read by read function */ + char *data=NULL; /* http server response */ + int data_lgr; /* http server response length */ + char *temp; /* pointer used to split header and csv */ + int error_code; /* error code returned by http server */ + char *csv_ptr; /* pointer to the csv content */ + int header_founded; /* test if header is founded */ + +#ifdef DEBUG + printf("*http_get\n"); +#endif + + /* get host info by name :*/ + if ((host = gethostbyname( http_proxy_server ? http_proxy_server : http_server))) + { + memset((char *) &server,0, sizeof(server)); + memmove((char *) &server.sin_addr, host->h_addr, host->h_length); + server.sin_family = host->h_addrtype; + server.sin_port = (unsigned short) htons( http_proxy_server ? http_proxy_port : 80 ); + + } else + { + +#ifdef DEBUG + printf(" gethostbyname : NOK\n"); +#endif + return ERRHOST; + } + + /* create socket */ + if ((s = socket(AF_INET, SOCK_STREAM, 0)) < 0) + { + +#ifdef DEBUG + printf(" create socket : NOK\n"); +#endif + return ERRSOCK; + } + + setsockopt(s, SOL_SOCKET, SO_KEEPALIVE, 0, 0); + + /* connect to server */ + if (connect(s, &server, sizeof(server)) < 0) + { +#ifdef DEBUG + printf(" connect to server : NOK\n"); +#endif + +#ifdef __UNIX__ + close(s); +#elif __WINDOWS__ + closesocket(s); +#endif + return ERRCONN; + } + + /* create header */ + if (http_proxy_server) + { + sprintf(header,"GET http://%.128s:80%.256s HTTP/1.0\015\012\015\012", + http_server, http_file); + } + else + { + sprintf(header,"GET %s HTTP/1.0\015\012\015\012",http_file); + } + + hlg=strlen(header); + + /* send header */ +#ifdef __UNIX__ + if (write(s,header,hlg)!=hlg) +#elif __WINDOWS__ + if (send(s,header,hlg, 0)!=hlg) +#endif + { +#ifdef DEBUG + printf(" send header : NOK\n"); +#endif + return ERRWHEA; + } + + data_lgr = 0; + r=1; + while(r) + { + /* Clear Buffer */ + memset(buf,0,BUF_SIZE+1); + +#ifdef __UNIX__ + r=read(s,buf,BUF_SIZE); +#elif __WINDOWS__ + r=recv(s,buf,BUF_SIZE,0); +#endif + + if (r) + { + if(!data_lgr) + { + if((data = malloc(r+1))==NULL) + { + fprintf(stderr,"Memory allocating error (%s line %d)\n" + ,__FILE__, __LINE__); + exit(1); + } + + memcpy(data,buf,r); + data_lgr = r; + data[r]=0; + } + else + { + if((temp = malloc(r+data_lgr+1))==NULL) + { + fprintf(stderr,"Memory allocating error (%s line %d)\n" + ,__FILE__, __LINE__); + exit(1); + } + memcpy(temp, data, data_lgr); + memcpy(temp+data_lgr, buf, r); + temp[r+data_lgr]=0; + data_lgr += r; + free(data); + data = temp; + } + } + } + + /* close socket */ +#ifdef __UNIX__ + close(s); +#elif __WINDOWS__ + closesocket(s); +#endif + +#ifdef DEBUG + printf("%s\n", data); +#endif + + /* get headers to test status line */ + /* and to split headers and content */ + + temp = data; + header_founded = 0; + while( !header_founded ) + { + if (*temp==0) return ERRRHEA; + + if( *temp==0x0A ) + { + /* test if it is the header end */ + temp ++; + if (*temp == 0x0D) temp++; + if (*temp == 0x0A) header_founded = 1; + } + else + temp++; + } + + *temp = 0; + temp++; + + sscanf(data,"HTTP/1.%*d %03d",&error_code); + + if (error_code != 200) + { +#ifdef DEBUG + printf(" HTTP error code : %d\n", error_code); +#endif + free(data); + return ERRPAHD; + } + + if ((csv_ptr = malloc(strlen(temp)+1))==NULL) + { + free(data); + fprintf(stderr,"Memory allocating error (%s line %d)\n" + ,__FILE__, __LINE__); + exit(1); + } + + memcpy(csv_ptr, temp, strlen(temp)+1); + free(data); + +#ifdef DEBUG + printf(" CSV\n"); + printf("%s,\n", csv_ptr); +#endif + + *pdata = csv_ptr; + + return 0; +} + +/******************************************************************************/ +/* Set the proxy server to use */ +/******************************************************************************/ +libstocks_return_code set_proxy(char *proxy) +{ + char *ptr; + char c; + +#ifdef DEBUG + printf("*set_proxy\n"); +#endif + + /* Parse the proxy URL - It must start with http:// */ +#ifdef __UNIX__ + if (strncasecmp("http://",proxy,7)) return ERRPROX; +#elif __WINDOWS__ + if (_mbsnbicmp("http://",proxy,7)) return ERRPROX; +#endif + + proxy+=7; + + /* find ":" in the proxy url */ + ptr = proxy; + for (c=*ptr; (c && c!=':');) c=*ptr++; + + /* ptr points just after the ":" or at the end of proxy if : not founded */ + *(ptr-1)=0; /* clear the ":" */ + + http_proxy_server=strdup(proxy); + +#ifdef DEBUG + printf("http_proxy_server : %s\n", http_proxy_server); +#endif + + /* get the port number of the url */ + if (sscanf(ptr,"%d",&http_proxy_port)!=1) return ERRPROX; + +#ifdef DEBUG + printf("http_proxy_port : %d\n", http_proxy_port); +#endif + + return 0; +} |