source: trunk/zoo-project/zoo-kernel/ulinet.c @ 471

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

Remove leaks from DescribeProcess? and JavaScript? support. Fix wrong ulinet update on previous commit. Use the new updateStatus/setOutputValue functions as described in #88 from longProcess. Add default value for QREncode service in ZCFG. Fix name of profile service in the ZCFG file.

  • Property svn:eol-style set to native
  • Property svn:mime-type set to text/x-csrc
File size: 10.0 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){
36    buffer=NULL;
37    return -1;
38  }
39  psInternet=(HINTERNET *)data;
40  if(psInternet->pabyData){
41    psInternet->pabyData=(unsigned char*)realloc(psInternet->pabyData,psInternet->nDataLen+realsize+1);
42    psInternet->nDataAlloc+=psInternet->nDataLen+realsize+1;
43  }
44  else{
45    psInternet->pabyData=(unsigned 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 = NULL;
109  CFStringRef key_host = NULL;
110  CFStringRef key_port = NULL;
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(strncmp(proto,"http",4)==0){
123      key_enabled=kSCPropNetProxiesHTTPEnable;
124      key_host=kSCPropNetProxiesHTTPProxy;
125      key_port=kSCPropNetProxiesHTTPPort;
126  }
127  else
128    if(strncmp(proto,"https",5)==0){
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  ret.mimeType = NULL;
171
172  curl_global_init(CURL_GLOBAL_ALL|CURL_GLOBAL_SSL|CURL_GLOBAL_WIN32);
173  ret.handle=curl_easy_init();
174
175  curl_easy_setopt(ret.handle, CURLOPT_COOKIEFILE, "ALL");
176#ifndef TIGER
177  curl_easy_setopt(ret.handle, CURLOPT_COOKIELIST, "ALL");
178#endif
179  curl_easy_setopt(ret.handle, CURLOPT_USERAGENT, lpszAgent);
180 
181  curl_easy_setopt(ret.handle,CURLOPT_FOLLOWLOCATION,1);
182  curl_easy_setopt(ret.handle,CURLOPT_MAXREDIRS,3);
183 
184  header.memory=NULL;
185  header.size = 0;
186
187  curl_easy_setopt(ret.handle, CURLOPT_HEADERFUNCTION, header_write_data);
188  curl_easy_setopt(ret.handle, CURLOPT_WRITEHEADER, (void *)&header);
189
190#ifdef MSG_LAF_VERBOSE
191  curl_easy_setopt(ret.handle, CURLOPT_VERBOSE, 1);
192#endif
193
194  return ret;
195}
196
197void InternetCloseHandle(HINTERNET handle){
198  if(handle.hasCacheFile>0){
199    fclose(handle.file);
200    unlink(handle.filename);
201    handle.mimeType = NULL;
202  }
203  else{
204    handle.pabyData = NULL;
205    handle.mimeType = NULL;
206    handle.nDataAlloc = handle.nDataLen = 0;
207  }
208  if(handle.handle)
209    curl_easy_cleanup(handle.handle);
210  curl_global_cleanup();
211}
212
213HINTERNET InternetOpenUrl(HINTERNET hInternet,LPCTSTR lpszUrl,LPCTSTR lpszHeaders,size_t dwHeadersLength,size_t dwFlags,size_t dwContext){
214
215  char filename[255];
216  hInternet.nDataLen = 0;
217
218  hInternet.nDataAlloc = 0;
219  hInternet.pabyData= NULL;
220     
221  switch(dwFlags)
222    {
223    case INTERNET_FLAG_NO_CACHE_WRITE:   
224      hInternet.hasCacheFile=-1;
225      curl_easy_setopt(hInternet.handle, CURLOPT_WRITEFUNCTION, write_data_into);
226      curl_easy_setopt(hInternet.handle, CURLOPT_WRITEDATA, &hInternet);
227      break;
228    default:
229      sprintf(filename,"/tmp/ZOO_Cache%d",(int)time(NULL));
230      filename[24]=0;
231      fprintf(stderr,"file=%s",filename);
232#ifdef MSG_LAF_VERBOSE
233      fprintf(stderr,"file=%s",filename);
234#endif
235      hInternet.filename=filename;
236      hInternet.file=fopen(hInternet.filename,"w+");
237   
238      hInternet.hasCacheFile=1;
239      curl_easy_setopt(hInternet.handle, CURLOPT_WRITEFUNCTION, NULL);
240      curl_easy_setopt(hInternet.handle, CURLOPT_WRITEDATA, hInternet.file);
241      hInternet.nDataLen=0;
242      break;
243    }
244#ifdef ULINET_DEBUG
245  fprintf(stderr,"URL (%s)\nBODY (%s)\n",lpszUrl,lpszHeaders);
246#endif
247  if(lpszHeaders!=NULL && strlen(lpszHeaders)>0){
248#ifdef MSG_LAF_VERBOSE
249    fprintf(stderr,"FROM ULINET !!");
250    fprintf(stderr,"HEADER : %s\n",lpszHeaders);
251#endif
252    //curl_easy_setopt(hInternet.handle,CURLOPT_COOKIE,lpszHeaders);
253    curl_easy_setopt(hInternet.handle,CURLOPT_POST,1);
254#ifdef ULINET_DEBUG
255    fprintf(stderr,"** (%s) %d **\n",lpszHeaders,dwHeadersLength);
256    curl_easy_setopt(hInternet.handle,CURLOPT_VERBOSE,1);
257#endif
258    curl_easy_setopt(hInternet.handle,CURLOPT_POSTFIELDS,lpszHeaders);
259    //curl_easy_setopt(hInternet.handle,CURLOPT_POSTFIELDSIZE,dwHeadersLength+1);
260    if(hInternet.header!=NULL)
261      curl_easy_setopt(hInternet.handle,CURLOPT_HTTPHEADER,hInternet.header);
262  }
263
264  curl_easy_setopt(hInternet.handle,CURLOPT_URL,lpszUrl);
265  curl_easy_perform(hInternet.handle);
266  curl_easy_getinfo(hInternet.handle,CURLINFO_CONTENT_TYPE,&hInternet.mimeType);
267#ifdef ULINET_DEBUG
268  fprintf(stderr,"DEBUG MIMETYPE: %s\n",hInternet.mimeType);
269#endif
270  return hInternet;
271};
272
273int freeCookieList(HINTERNET hInternet){
274  memset(&CCookie[0],0,1024);
275#ifndef TIGER
276  curl_easy_setopt(hInternet.handle, CURLOPT_COOKIELIST, "ALL");
277#endif
278  return 1;
279}
280
281int InternetReadFile(HINTERNET hInternet,LPVOID lpBuffer,int dwNumberOfBytesToRead, size_t *lpdwNumberOfBytesRead){
282  int dwDataSize;
283
284  if(hInternet.hasCacheFile>0){
285    fseek (hInternet.file , 0 , SEEK_END);
286    dwDataSize=ftell(hInternet.file); //taille du ficher
287    rewind (hInternet.file);
288  }
289  else{
290    memset(lpBuffer,0,hInternet.nDataLen+1);
291    memcpy(lpBuffer, hInternet.pabyData, hInternet.nDataLen );
292    dwDataSize=hInternet.nDataLen;
293    free( hInternet.pabyData );
294    hInternet.pabyData=NULL;
295  }
296
297  if( dwNumberOfBytesToRead /* buffer size */ < dwDataSize )
298    return 0;
299
300#ifdef MSG_LAF_VERBOSE
301  printf("\nfile size : %dko\n",dwDataSize/1024);
302#endif
303
304  if(hInternet.hasCacheFile>0){
305    *lpdwNumberOfBytesRead = fread(lpBuffer,1,dwDataSize,hInternet.file); 
306  }
307  else{
308    *lpdwNumberOfBytesRead = hInternet.nDataLen;
309    free( hInternet.pabyData );
310    hInternet.pabyData = NULL;
311    hInternet.nDataAlloc = hInternet.nDataLen = 0;
312  }
313
314  CCookie[0]=0;
315
316  if( *lpdwNumberOfBytesRead < dwDataSize )
317      return 0;
318  else
319      return 1; // TRUE
320}
321
322bool InternetGetCookie(LPCTSTR lpszUrl,LPCTSTR lpszCookieName,LPTSTR lpszCookieData,LPDWORD lpdwSize){
323
324  bool ret=1; 
325  int count=0;
326  int hasCookie=-1;
327  char TMP[1024];
328  int j;
329  int tmpC=0;
330  lpszUrl=NULL;
331
332  for(j=0;j<strlen(CCookie);j++){
333    if(lpszCookieName[count]==CCookie[j]){
334      hasCookie=1;
335      count++;
336      if(count==strlen(lpszCookieName))
337        break;
338      continue;
339    }
340  }
341
342  if(hasCookie>0){
343    if(CCookie[count]=='='){
344      int i=0;
345      count++;
346      for(i=count;i<strlen(CCookie);i++){
347        if(CCookie[i]!=';'){
348          TMP[tmpC]=CCookie[i];
349          tmpC++;
350        }
351        else{
352          break;
353        }
354      }
355    }
356  }
357  else
358    return -1;
359
360  TMP[tmpC]=0;
361  strncpy(lpszCookieData,TMP,strlen(TMP)+1);
362  lpdwSize=(size_t*) strlen(lpszCookieData);
363
364#ifdef MSG_LAF_VERBOSE
365  printf("Cookie returned : (%s)",(char*)lpszCookieData);
366#endif
367
368  return ret;
369
370}
371
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