Hi, <br><br>I am working on a simple external to do HTTP requests from PD. The idea is to implement a simple way to send and receive simple data to a web server. This is intended to work together with a set of classes that will interpret the GET variables as key and values pairs where the values can be similar to FUDI protocol messages. The web page would then answer with a FUDI message or so. I don't use Python because I want it to be very fast, totally portable and easy to install. (I also agree with Hans regarding small tools to make a constellation of low level objects)
<br><br>Here are my bugs : perhaps I am not very good yet with strings in C, but I have several errors when I try to execute this code from within PD as an external. Well, when I get malloc errors, it must be only about memory size arithmetics, but when it gets into segmentation faults, I was just wondering if it could be because cURL starts a new thread. I think that thread are not much appropriate in PD's context. Do you think this is the problem, or I am just still a bit bad with memory maths ?
<br><br>Also, if you have ideas about this external, please don't hesitate. I think I will rename it to http, as it is not intended in downloading whole files, but just for simple HTTP requests.<br><br>See below for the current code, the makefile and one of the errors it creates.
<br><br>Alexandre Quessy<br><a href="http://alexandre.quessy.net">http://alexandre.quessy.net</a><br><br>============================= error when using it ====================<br><br>pd wget-help.pd <br>STACK_END old=0xbf9e5ffc; new=0xbf9efffc
<br>PDP: pure data packet<br>PDP: version 0.12.4<br>* About to connect() to <a href="http://alexandre.quessy.net">alexandre.quessy.net</a> port 80<br>* Trying 64.15.134.165... * connected<br>* Connected to <a href="http://alexandre.quessy.net">
alexandre.quessy.net</a> (<a href="http://64.15.134.165">64.15.134.165</a>) port 80<br>> GET /pd/curlme.php?asd=qwe+123 HTTP/1.1<br>User-Agent: Pure Data<br>Host: <a href="http://alexandre.quessy.net">alexandre.quessy.net
</a><br>Accept: */*<br><br>< HTTP/1.1 200 OK<br>< Date: Mon, 19 Jun 2006 16:03:44 GMT<br>< Server: Apache<br>< X-Powered-By: PHP/4.3.10-16<br>< Connection: close<br>< Transfer-Encoding: chunked<br>< Content-Type: text/html
<br>* Closing connection #0<br>socket receive error: Connection reset by peer (104)<br>Erreur de segmentation<br><br>================== makefile ====================================<br>
<br>
all: wget.pd_linux<br>
@echo "making wget"<br>
<br>
wget.pd_linux: wget.c <br>
gcc -DPD -O2 -funroll-loops -fomit-frame-pointer \<br>
-Wall -W -Wshadow -Wstrict-prototypes \<br>
-Wno-unused -Wno-parentheses -Wno-switch -o wget.o -c wget.c<br>
ld -export_dynamic -shared -o wget.pd_linux wget.o -lcurl -lc -lm<br>
strip --strip-unneeded wget.pd_linux<br>
rm wget.o<br>
<br><br><br>================== code : wget.c ================================<br><br>/**<br> * [wget] is a Pure Data object for simple HTTP requests.<br> *<br> * @url <a href="http://alexandre.quessy.net/">http://alexandre.quessy.net/
</a><br> * @author Alexandre Quessy <<a href="mailto:alexandre@quessy.net">alexandre@quessy.net</a>><br> * @license GNU General Public License 2006<br> */<br>#define PDWGET_VERSION "0.1.0"<br><br>/* PD includes */
<br>#include "m_pd.h"<br><br>/* cURL and standard C libraries */<br>#include <curl/curl.h><br>#include <string.h><br>#include <stdlib.h><br><br>/* Download callback function prototype */<br>size_t wget_callBack(void *ptr, size_t size, size_t nmemb, void *x);
<br><br>/** <br> * variables of the pd object <br> */<br>typedef struct wget {<br> t_object x_ob; /* The instance. Contains inlets and outlets */<br> t_outlet *x_outlet0; /* result string */<br> t_outlet *x_outlet1; /* HTTP error codes */
<br>} t_wget;<br><br><br><br>/** <br> * HTTP request.<br> */<br>void wget_request(t_wget *x, t_symbol *s, int argc, t_atom *argv) {<br> post("wget : called request.");<br> //curl_global_init(CURL_GLOBAL_NOTHING);//CURL_GLOBAL_ALL
<br> <br> //t_symbol *sym_tmp = atom_getsymbol(&argv[0]);<br> if (argc < 1) {<br> post("wget : Error : needs arguments.");<br> } else {<br> t_symbol *sym_tmp = atom_getsymbolarg(0, argc, argv);
<br> char *url = sym_tmp->s_name;<br> <br> post("wget : requesting : %s", url);<br> <br> /* cURL context */<br> CURL *pContext = curl_easy_init();<br> if (pContext == NULL) {<br> post("wget : Error : Null cURL handle.");
<br> } else {<br> /* cURL options */<br> CURLcode pCode = curl_easy_setopt(pContext, CURLOPT_URL, url);<br> curl_easy_setopt(pContext, CURLOPT_WRITEFUNCTION, wget_callBack, (void *) x);<br> curl_easy_setopt(pContext, CURLOPT_VERBOSE, 1);
<br> curl_easy_setopt(pContext, CURLOPT_HEADER, 0);<br> curl_easy_setopt(pContext, CURLOPT_NOPROGRESS, 1);<br> curl_easy_setopt(pContext, CURLOPT_USERAGENT, "Pure Data");<br> curl_easy_setopt(pContext, CURLOPT_NOSIGNAL, 1);
<br> curl_easy_setopt(pContext, CURLOPT_TIMEOUT, (long) 5);<br><br> /* cURL performing */<br> post("wget : Performing the request.");<br> const CURLcode result = curl_easy_perform(pContext);
<br> if(CURLE_OK != result) {<br> post("wget : Error from cURL: %s", curl_easy_strerror(result));<br> } else {<br> <br> /* HTTP code */<br> long lHttpCode;
<br> curl_easy_getinfo(pContext, CURLINFO_RESPONSE_CODE, &lHttpCode);<br> post("wget : HTTP response code: %ld ", lHttpCode);<br> //outlet_float(x->x_outlet1, (float) lHttpCode);
<br> }<br> }<br> <br> post("[wget] cleaning up...");<br> /* cURL cleanup */<br> curl_easy_cleanup(pContext);<br> post("[wget] Local cleaned up.");<br> //curl_global_cleanup();
<br> post("[wget] Global cleaned up.");<br> //outlet_list(x->x_outlet0, gensym("A_FLOAT"), numCols+1, &atoms); // &atoms ??<br> } // else<br>}<br><br>/** <br> * The representation of the class in PD.
<br> */<br>t_class *wget_class;<br><br>/** <br> * constructor <br> */<br>void *wget_new(t_symbol *selector, int argc, t_atom *argv) {<br> post("wget : creating a new object.");<br> t_wget *x = (t_wget *) pd_new(wget_class);
<br> x->x_outlet0 = outlet_new(&x->x_ob, gensym("list"));<br> x->x_outlet1 = outlet_new(&x->x_ob, gensym("float"));<br> return (void *)x;<br>}<br><br>/** <br> * setup <br> */
<br>void wget_setup(void) {<br> curl_global_init(CURL_GLOBAL_NOTHING);<br> wget_class = class_new(gensym("wget"), (t_newmethod) wget_new, 0, sizeof(t_wget), 0, A_GIMME, 0);<br> class_addmethod(wget_class, (t_method)wget_request, gensym("request"), A_GIMME, 0);
<br> <br> post("----------------------------------------------------");<br> post(" [wget] %s (c) GPL Copyleft 2006 Alexandre Quessy", PDWGET_VERSION);<br> post(" Simple HTTP requests for Pure Data.");
<br> post("----------------------------------------------------");<br>}<br><br>/** <br> * Callback implementation<br> */<br>size_t wget_callBack(void *ptr, size_t size, size_t nmemb, void *x) {<br> size_t totalSize = nmemb * size;
<br> char *dest = malloc(totalSize + 1); //(sizeof(char))<br> strcpy(dest, (char *) ptr);<br> post("[wget] : Getting data.");<br> dest[totalSize] = '\0';<br> post("result :");<br> post("===============================");
<br> post("%s", dest);<br> post("===============================");<br> <br> //outlet_symbol(((t_wget *)x)->x_outlet0, gensym(dest));<br> //free(dest);<br> return(totalSize);<br>}<br>
<br><br><br><br><br>