source: trunk/zoo-kernel/ulinet.c @ 10

Last change on this file since 10 was 9, checked in by djay, 14 years ago

Update of both ZOO Kernel and ZOO Services (ogr base-vect-ops ServicesProvider?).
All the ZCFG files have been corrected to remove all references to wrong metadata (Test = Demo) to avoid validation issues.
Main Memory leaks has been removed from this version.
Addition of the Simplify Service in the C ogr base-vect-ops ServicesProvider? and addition of the Python version (without Simplify).
Update of the configure.ac and Makefile.in to follow dicussions on the mailing list and ensure to use our cgic206 and not another one, path to our cgic library is now directly in the Makefile.in file.
Accept the "-" character to name inputs, to solve issue on GRASS 7 integration.
Addition of the extension keyword for ZCFG file to be able to store resulting outputs in a file name using the extension suffix.
This version after a testing period shall be considerate as 1.0.1 version of the ZOO Project.

File size: 12.9 KB
Line 
1/**
2 *  ulinet.c
3 *
4 * Author : Gérald FENOY
5 *
6 * Copyright (c) 2008-2010 GeoLabs SARL
7 *
8 * Permission is hereby granted, free of charge, to any person obtaining a copy
9 * of this software and associated documentation files (the "Software"), to deal
10 * in the Software without restriction, including without limitation the rights
11 * to use, copy, modify, merge, publish, distribute, sublicense, and/or sell
12 * copies of the Software, and to permit persons to whom the Software is
13 * furnished to do so, subject to the following conditions:
14 *
15 * The above copyright notice and this permission notice shall be included in
16 * all copies or substantial portions of the Software.
17 *
18 * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
19 * IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
20 * FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
21 * AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
22 * LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
23 * OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN
24 * THE SOFTWARE.
25 *
26 */
27
28#define _ULINET
29#include "ulinet.h"
30#include <assert.h>
31
32size_t write_data_into(void *buffer, size_t size, size_t nmemb, void *data){
33  size_t realsize = size * nmemb;
34  HINTERNET *psInternet;
35  if(buffer==NULL || strlen((char*)buffer)==0){
36    buffer=NULL;
37    return -1;
38  }
39  psInternet=(HINTERNET *)data;
40  if(psInternet->pabyData){
41    psInternet->pabyData=(char*)realloc(psInternet->pabyData,psInternet->nDataLen+realsize+1);
42    psInternet->nDataAlloc+=psInternet->nDataLen+realsize+1;
43  }
44  else{
45    psInternet->pabyData=(char*)malloc(psInternet->nDataLen+realsize+1);
46    psInternet->nDataAlloc=realsize+1;
47  }
48
49  if (psInternet->pabyData) {
50    memcpy( psInternet->pabyData + psInternet->nDataLen, buffer, realsize);
51    psInternet->nDataLen += realsize;
52    psInternet->pabyData[psInternet->nDataLen] = 0;
53  }
54
55  buffer=NULL;
56  return realsize;
57}
58
59size_t header_write_data(void *buffer, size_t size, size_t nmemb, void *data){
60  if(strncmp("Set-Cookie: ",buffer,12)==0){
61    int i;
62    char env[1024];
63    char path[1024];
64    char domain[1024];
65        char* tmp;
66    for(i=0;i<12;i++)
67#ifndef WIN32
68      buffer++;
69#else
70        ;
71#endif
72    sscanf(buffer,"%s; path=%s; domain=%s",env,path,domain);
73    tmp=strcat(env,CCookie);
74#ifdef MSG_LAF_OUT
75    printf("\n**Cookie env : [%s] , path : [%s], domain : [%s]**\n",env,path,domain);
76    printf("buffer : %d (%s) (%s) (%s)\n",(buffer==NULL),buffer,tmp,CCookie);
77#endif
78    strcpy(CCookie,tmp);
79  }
80  return size * nmemb;//write_data_into(buffer,size,nmemb,data,HEADER);
81};
82
83
84void setProxy(CURL* handle,char* host,long port){
85}
86
87/**
88 * MACOSX
89 */
90#if defined(macintosh) || (defined(__MACH__) && defined(__APPLE__))
91
92
93char* CFStringToCString(CFStringRef dest,char *buffer){
94  CFStringEncoding encoding = kCFStringEncodingUTF8;
95  Boolean bool2 = CFStringGetCString(dest,buffer,1024,encoding);
96  if(bool2){
97    printf("Loaded into local_buffer");
98    return buffer;
99  }
100  return NULL;
101}
102
103OSStatus setProxiesForProtcol(CURL* handle,const char *proto){
104  OSStatus              err;
105  CFDictionaryRef proxyDict;
106  CFArrayRef            proxies;
107 
108  CFStringRef key_enabled;
109  CFStringRef key_host;
110  CFStringRef key_port;
111 
112  bool proxy_enabled;
113  char *proxy_host;
114  long proxy_port;
115 
116  proxyDict = NULL;
117  proxies = NULL;
118
119  err = noErr;
120  proxyDict = SCDynamicStoreCopyProxies(NULL);
121
122  if(proto=="http"){
123      key_enabled=kSCPropNetProxiesHTTPEnable;
124      key_host=kSCPropNetProxiesHTTPProxy;
125      key_port=kSCPropNetProxiesHTTPPort;
126  }
127  else
128    if(proto=="https"){
129      key_enabled=kSCPropNetProxiesHTTPSEnable;
130      key_host=kSCPropNetProxiesHTTPSProxy;
131      key_port=kSCPropNetProxiesHTTPSPort;
132    }
133
134  CFNumberGetValue(CFDictionaryGetValue(proxyDict,key_enabled),kCFNumberIntType,&proxy_enabled);
135  if(proxy_enabled){
136    CFNumberGetValue(CFDictionaryGetValue(proxyDict,key_port),CFNumberGetType(CFDictionaryGetValue(proxyDict,key_port)),&proxy_port);
137    char buffer[1024];
138    CFStringToCString(CFDictionaryGetValue(proxyDict,key_host),buffer);
139    proxy_host=buffer;
140
141#ifdef MSG_LAF_VERBOSE
142    printf("\n**[PROXY SETTINGS DETECTION %s (%d) %s:%li (%s)]**\n",proto,proxy_enabled,(char*)proxy_host,proxy_port,buffer);
143#endif
144
145    if (proxyDict == NULL) {
146      err = coreFoundationUnknownErr;
147    }
148
149    setProxy(handle,proxy_host,proxy_port);
150  }
151  return err;
152}
153#else
154/**
155 * Linux (Gnome)
156 */
157bool setProxiesForProtcol(CURL* handle,const char *proto){
158#ifdef MSG_LAF_VERBOSE
159  fprintf( stderr, "setProxiesForProtocol (do nothing) ...\n" );
160#endif
161}
162#endif
163
164HINTERNET InternetOpen(char* lpszAgent,int dwAccessType,char* lpszProxyName,char* lpszProxyBypass,int dwFlags){
165 
166  HINTERNET ret;
167  struct MemoryStruct header;
168  ret.hasCacheFile=0;
169  ret.nDataAlloc = 0;
170
171  ret.handle=curl_easy_init();
172
173  curl_easy_setopt(ret.handle, CURLOPT_COOKIEFILE, "ALL");
174#ifndef TIGER
175  curl_easy_setopt(ret.handle, CURLOPT_COOKIELIST, "ALL");
176#endif
177  curl_easy_setopt(ret.handle, CURLOPT_USERAGENT, lpszAgent);
178 
179  curl_easy_setopt(ret.handle,CURLOPT_FOLLOWLOCATION,1);
180  curl_easy_setopt(ret.handle,CURLOPT_MAXREDIRS,3);
181 
182  header.memory=NULL;
183  header.size = 0;
184
185  curl_easy_setopt(ret.handle, CURLOPT_HEADERFUNCTION, header_write_data);
186  curl_easy_setopt(ret.handle, CURLOPT_WRITEHEADER, (void *)&header);
187
188#ifdef MSG_LAF_VERBOSE
189  curl_easy_setopt(ret.handle, CURLOPT_VERBOSE, 1);
190#endif
191
192  return ret;
193}
194
195static size_t 
196CurlWriteCB(void *buffer, size_t size, size_t nmemb, void *reqInfo){
197  HINTERNET *psInternet = (HINTERNET *) reqInfo;
198
199  memcpy( psInternet->pabyData + psInternet->nDataLen, buffer,  nmemb * size );
200  psInternet->nDataLen += nmemb * size;
201  psInternet->pabyData[psInternet->nDataLen] = 0;
202
203  return nmemb *size;
204}
205
206void InternetCloseHandle(HINTERNET handle){
207  if(handle.hasCacheFile>0){
208    fclose(handle.file);
209    unlink(handle.filename);
210  }
211  else{
212    handle.pabyData = NULL;
213    handle.nDataAlloc = handle.nDataLen = 0;
214  }
215  if(handle.handle)
216    curl_easy_cleanup(handle.handle);
217  curl_global_cleanup();
218}
219
220HINTERNET InternetOpenUrl(HINTERNET hInternet,LPCTSTR lpszUrl,LPCTSTR lpszHeaders,size_t dwHeadersLength,size_t dwFlags,size_t dwContext){
221
222  char filename[255];
223  hInternet.nDataLen = 0;
224
225  hInternet.nDataAlloc = 0;
226  hInternet.pabyData= NULL;
227     
228  switch(dwFlags)
229    {
230    case INTERNET_FLAG_NO_CACHE_WRITE:   
231      hInternet.hasCacheFile=-1;
232      curl_easy_setopt(hInternet.handle, CURLOPT_WRITEFUNCTION, write_data_into);
233      curl_easy_setopt(hInternet.handle, CURLOPT_WRITEDATA, &hInternet);
234      break;
235    default:
236      sprintf(filename,"/tmp/ZOO_Cache%d",(int)time(NULL));
237      printf("file=%s",filename);
238#ifdef MSG_LAF_VERBOSE
239      printf("file=%s",filename);
240#endif
241      hInternet.filename=filename;
242      hInternet.file=fopen(hInternet.filename,"w+");
243   
244      hInternet.hasCacheFile=1;
245      curl_easy_setopt(hInternet.handle, CURLOPT_WRITEFUNCTION, NULL);
246      curl_easy_setopt(hInternet.handle, CURLOPT_WRITEDATA, hInternet.file);
247      hInternet.nDataLen=0;
248      break;
249    }
250#ifdef ULINET_DEBUG
251  fprintf(stderr,"URL (%s)\nBODY (%s)\n",lpszUrl,lpszHeaders);
252#endif
253  if(lpszHeaders!=NULL && strlen(lpszHeaders)>0){
254#ifdef MSG_LAF_VERBOSE
255    fprintf(stderr,"FROM ULINET !!");
256    fprintf(stderr,"HEADER : %s\n",lpszHeaders);
257#endif
258    //curl_easy_setopt(hInternet.handle,CURLOPT_COOKIE,lpszHeaders);
259    curl_easy_setopt(hInternet.handle,CURLOPT_POST,1);
260#ifdef ULINET_DEBUG
261    fprintf(stderr,"** (%s) %d **\n",lpszHeaders,dwHeadersLength);
262#endif
263    curl_easy_setopt(hInternet.handle,CURLOPT_POSTFIELDS,lpszHeaders);
264    //curl_easy_setopt(hInternet.handle,CURLOPT_POSTFIELDSIZE,dwHeadersLength+1);
265    if(hInternet.header!=NULL)
266      curl_easy_setopt(hInternet.handle,CURLOPT_HTTPHEADER,hInternet.header);
267  }
268
269  curl_easy_setopt(hInternet.handle,CURLOPT_URL,lpszUrl);
270  curl_easy_perform(hInternet.handle);
271
272  return hInternet;
273};
274
275int freeCookieList(HINTERNET hInternet){
276  memset(&CCookie[0],0,1024);
277#ifndef TIGER
278  curl_easy_setopt(hInternet.handle, CURLOPT_COOKIELIST, "ALL");
279#endif
280  return 1;
281}
282
283int InternetReadFile(HINTERNET hInternet,LPVOID lpBuffer,int dwNumberOfBytesToRead, size_t *lpdwNumberOfBytesRead){
284  int dwDataSize;
285
286  if(hInternet.hasCacheFile>0){
287    fseek (hInternet.file , 0 , SEEK_END);
288    dwDataSize=ftell(hInternet.file); //taille du ficher
289    rewind (hInternet.file);
290  }
291  else{
292    memset(lpBuffer,0,hInternet.nDataLen+1);
293    memcpy( lpBuffer, hInternet.pabyData, hInternet.nDataLen );
294    dwDataSize=hInternet.nDataLen;
295    free( hInternet.pabyData );
296    hInternet.pabyData=NULL;
297  }
298
299  if( dwNumberOfBytesToRead /* buffer size */ < dwDataSize )
300    return 0;
301
302#ifdef MSG_LAF_VERBOSE
303  printf("\nfile size : %dko\n",dwDataSize/1024);
304#endif
305
306  if(hInternet.hasCacheFile>0){
307    *lpdwNumberOfBytesRead = fread(lpBuffer,1,dwDataSize,hInternet.file); 
308  }
309  else{
310    *lpdwNumberOfBytesRead = hInternet.nDataLen;
311    free( hInternet.pabyData );
312    hInternet.pabyData = NULL;
313    hInternet.nDataAlloc = hInternet.nDataLen = 0;
314  }
315
316  CCookie[0]=0;
317
318  if( *lpdwNumberOfBytesRead < dwDataSize )
319      return 0;
320  else
321      return 1; // TRUE
322}
323
324bool InternetGetCookie(LPCTSTR lpszUrl,LPCTSTR lpszCookieName,LPTSTR lpszCookieData,LPDWORD lpdwSize){
325
326  bool ret=1; 
327  int count=0;
328  int hasCookie=-1;
329  char TMP[1024];
330  int j;
331  int tmpC=0;
332  lpszUrl=NULL;
333
334  for(j=0;j<strlen(CCookie);j++){
335    if(lpszCookieName[count]==CCookie[j]){
336      hasCookie=1;
337      count++;
338      if(count==strlen(lpszCookieName))
339        break;
340      continue;
341    }
342  }
343
344  if(hasCookie>0){
345    if(CCookie[count]=='='){
346      int i=0;
347      count++;
348      for(i=count;i<strlen(CCookie);i++){
349        if(CCookie[i]!=';'){
350          TMP[tmpC]=CCookie[i];
351          tmpC++;
352        }
353        else{
354          break;
355        }
356      }
357    }
358  }
359  else
360    return -1;
361
362  TMP[tmpC]=0;
363  strncpy(lpszCookieData,TMP,strlen(TMP)+1);
364  lpdwSize=(size_t*) strlen(lpszCookieData);
365
366#ifdef MSG_LAF_VERBOSE
367  printf("Cookie returned : (%s)",(char*)lpszCookieData);
368#endif
369
370  return ret;
371
372}
373
374#ifdef USE_JS
375#include "jsapi.h"
376
377char* JSValToChar(JSContext* context, jsval* arg) {
378  if(!JSVAL_IS_STRING(*arg)) {
379    return NULL;
380  }
381  char *c, *tmp;
382  JSString *jsmsg;
383  size_t len;
384  jsmsg = JS_ValueToString(context,*arg);
385  len = JS_GetStringLength(jsmsg);
386  tmp = JS_GetStringBytes(jsmsg);
387  c = (char*)malloc((len+1)*sizeof(char));
388  c[len] = '\0';
389  int i;
390#ifdef ULINET_DEBUG
391  fprintf(stderr,"%d \n",len);
392#endif
393  for(i = 0;i < len;i++) {
394    c[i] = tmp[i];
395    c[i+1] = 0;
396  }
397#ifdef ULINET_DEBUG
398  fprintf(stderr,"%s \n",c);
399#endif
400  return c;
401}
402
403HINTERNET setHeader(HINTERNET handle,JSContext *cx,JSObject *header){
404  jsuint length=0;
405#ifdef ULINET_DEBUG
406  fprintf(stderr,"setHeader\n");
407#endif
408  if(JS_IsArrayObject(cx,header)){
409#ifdef ULINET_DEBUG
410    fprintf(stderr,"header is an array\n");
411#endif
412    JS_GetArrayLength(cx,header,&length);
413#ifdef ULINET_DEBUG
414    fprintf(stderr,"header is an array of %d elements\n",length);
415#endif
416    jsint i=0;
417    handle.header=NULL;
418    for(i=0;i<length;i++){
419      jsval tmp;
420      JS_GetElement(cx,header,i,&tmp);
421      char *tmp1=JSValToChar(cx,&tmp);
422#ifdef ULINET_DEBUG
423      fprintf(stderr,"Element of array n° %d, value : %s\n",i,tmp1);
424#endif
425      handle.header=curl_slist_append(handle.header, tmp1);
426      free(tmp1);
427    }
428  }
429  else{
430    fprintf(stderr,"not an array !!!!!!!\n");
431  }
432  return handle;
433}
434
435JSBool
436JSRequest(JSContext *cx, JSObject *obj, uintN argc, jsval *argv, jsval *rval)
437{
438  HINTERNET hInternet;
439  char *url;
440  char *method;
441  JS_MaybeGC(cx);
442  hInternet=InternetOpen((LPCTSTR)"ZooWPSClient\0",
443                         INTERNET_OPEN_TYPE_PRECONFIG,
444                         NULL,NULL, 0);
445  if(!CHECK_INET_HANDLE(hInternet))
446    return JS_FALSE;
447  int i=0;
448  if(argc>=2){
449    method=JSValToChar(cx,&argv[0]);
450    url=JSValToChar(cx,&argv[1]);
451  }
452  else{
453    method=strdup("GET");
454    url=JSValToChar(cx,argv);
455  }
456  HINTERNET res;
457  if(argc==4){
458    char *body;
459    body=JSValToChar(cx,&argv[2]);
460    JSObject *header=JSVAL_TO_OBJECT(argv[3]);
461    HINTERNET res1;
462#ifdef ULINET_DEBUG
463    fprintf(stderr,"URL (%s) \nBODY (%s)\n",url,body);
464#endif
465    if(JS_IsArrayObject(cx,header))
466      res1=setHeader(hInternet,cx,header);
467#ifdef ULINET_DEBUG
468    fprintf(stderr,"BODY (%s)\n",body);
469#endif
470    res=InternetOpenUrl(res1,url,body,strlen(body),
471                        INTERNET_FLAG_NO_CACHE_WRITE,0);   
472    free(body);
473  }else{
474    if(argc==3){
475      char *body=JSValToChar(cx,&argv[2]);
476      res=InternetOpenUrl(hInternet,url,body,strlen(body),
477                          INTERNET_FLAG_NO_CACHE_WRITE,0);
478      free(body);
479    }
480    res=InternetOpenUrl(hInternet,url,NULL,0,
481                        INTERNET_FLAG_NO_CACHE_WRITE,0);
482  }
483  char* tmpValue=(char*)malloc((res.nDataLen+1)*sizeof(char));
484  size_t dwRead;
485  InternetReadFile(res,(LPVOID)tmpValue,res.nDataLen,&dwRead);
486#ifdef ULINET_DEBUG
487  fprintf(stderr,"content downloaded (%d) (%s) \n",dwRead,tmpValue);
488#endif
489  *rval=STRING_TO_JSVAL(JS_NewString(cx,tmpValue,strlen(tmpValue)));
490  free(url);
491  if(argc>=2)
492    free(method);
493  if(argc==4 && res.header!=NULL){
494    curl_slist_free_all(res.header);
495  }
496  InternetCloseHandle(hInternet);
497  JS_MaybeGC(cx);
498  return JS_TRUE;
499}
500#endif
Note: See TracBrowser for help on using the repository browser.

Search

ZOO Sponsors

http://www.zoo-project.org/trac/chrome/site/img/geolabs-logo.pnghttp://www.zoo-project.org/trac/chrome/site/img/neogeo-logo.png http://www.zoo-project.org/trac/chrome/site/img/apptech-logo.png http://www.zoo-project.org/trac/chrome/site/img/3liz-logo.png http://www.zoo-project.org/trac/chrome/site/img/gateway-logo.png

Become a sponsor !

Knowledge partners

http://www.zoo-project.org/trac/chrome/site/img/ocu-logo.png http://www.zoo-project.org/trac/chrome/site/img/gucas-logo.png http://www.zoo-project.org/trac/chrome/site/img/polimi-logo.png http://www.zoo-project.org/trac/chrome/site/img/fem-logo.png http://www.zoo-project.org/trac/chrome/site/img/supsi-logo.png http://www.zoo-project.org/trac/chrome/site/img/cumtb-logo.png

Become a knowledge partner

Related links

http://zoo-project.org/img/ogclogo.png http://zoo-project.org/img/osgeologo.png