source: trunk/zoo-project/zoo-kernel/zoo_loader.c @ 680

Last change on this file since 680 was 680, checked in by djay, 7 years ago

Various fixes for Windows support: generate uuid using UuidCreate?, pass usid to the created process, call TerminateProcess? on dismiss request.

  • Property svn:eol-style set to native
  • Property svn:mime-type set to text/x-csrc
File size: 11.6 KB
Line 
1/*
2 * Author : Gérald FENOY
3 *
4 *  Copyright 2008-2011 GeoLabs SARL. All rights reserved.
5 *
6 * Permission is hereby granted, free of charge, to any person obtaining a copy
7 * of this software and associated documentation files (the "Software"), to deal
8 * in the Software without restriction, including without limitation the rights
9 * to use, copy, modify, merge, publish, distribute, sublicense, and/or sell
10 * copies of the Software, and to permit persons to whom the Software is
11 * furnished to do so, subject to the following conditions:
12 *
13 * The above copyright notice and this permission notice shall be included in
14 * all copies or substantial portions of the Software.
15 *
16 * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
17 * IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
18 * FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
19 * AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
20 * LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
21 * OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN
22 * THE SOFTWARE.
23 */
24
25#define MALLOC_CHECK_ 0
26#define MALLOC_CHECK 0
27
28/**
29 * Specific includes
30 */
31#ifndef WIN32
32#include "fcgio.h"
33#include "fcgi_config.h"
34#include "fcgi_stdio.h"
35#endif
36#include <sys/types.h>
37#include <unistd.h>
38#include "service_internal.h"
39#include "response_print.h"
40
41
42#ifdef WIN32
43#include "windows.h"
44#define strtok_r strtok_s
45#endif
46
47extern "C" {
48#include "cgic.h"
49#include <libxml/tree.h>
50#include <libxml/xmlmemory.h>
51#include <libxml/parser.h>
52#include <libxml/xpath.h>
53#include <libxml/xpathInternals.h>
54}
55
56#include "service_internal.h"
57#include "request_parser.h"
58
59#ifdef WIN32
60#include "server_internal.h"
61#endif
62
63int runRequest(map**);
64
65using namespace std;
66
67#ifndef TRUE
68#define TRUE 1
69#endif
70#ifndef FALSE
71#define FALSE -1
72#endif
73
74/**
75 * Main entry point for cgic.
76 * @return 0 on sucess.
77 */
78int cgiMain(){
79  /**
80   * We'll use cgiOut as the default output (stdout) to produce plain text
81   * response.
82   */
83  dup2(fileno(cgiOut),fileno(stdout));
84#ifdef DEBUG
85  fprintf(cgiOut,"Content-Type: text/plain; charset=utf-8\r\nStatus: 200 OK\r\n\r\n");
86  fprintf(cgiOut,"Welcome on ZOO verbose debuging mode \r\n\r\n");
87  fflush(cgiOut);
88  fprintf (stderr, "Addr:%s\n", cgiRemoteAddr); 
89  fprintf (stderr, "RequestMethod: (%s) %d %d\n", cgiRequestMethod,strncasecmp(cgiRequestMethod,"post",4),strncmp(cgiContentType,"text/xml",8)==0 || strncasecmp(cgiRequestMethod,"post",4)==0); 
90  fprintf (stderr, "Request: %s\n", cgiQueryString);
91  fprintf (stderr, "ContentType: %s\n", cgiContentType);
92  fprintf (stderr, "ContentLength: %d\n", cgiContentLength);
93  fflush(stderr);
94#endif
95 
96  char *strQuery=NULL;
97  if(cgiQueryString!=NULL)
98    strQuery=zStrdup(cgiQueryString);
99  map* tmpMap=NULL;
100
101  if(strncmp(cgiContentType,"text/xml",8)==0 || 
102     strncasecmp(cgiRequestMethod,"post",4)==0){
103    if(cgiContentLength==0){
104       char *buffer=new char[2];
105       char *res=NULL;
106       int r=0;
107       while((r=fread(buffer,sizeof(char),1,cgiIn))){
108         buffer[1]=0;
109         if(res==NULL){
110           res=(char*)malloc(2*sizeof(char));
111           sprintf(res,"%s",buffer);
112         }
113         else{
114           res=(char*)realloc(res,(cgiContentLength+2)*sizeof(char));
115           memcpy(res + cgiContentLength, buffer, sizeof(char));
116           res[cgiContentLength+1]=0;
117         }
118         cgiContentLength+=r;
119       }
120       delete[] buffer;
121       if(res!=NULL && (strQuery==NULL || strlen(strQuery)==0))
122         tmpMap=createMap("request",res);
123       if(res!=NULL)
124         free(res);
125    }else{
126      char *buffer=new char[cgiContentLength+1];
127      if(fread(buffer,sizeof(char),cgiContentLength,cgiIn)>0){
128        buffer[cgiContentLength]=0;
129        tmpMap=createMap("request",buffer);
130      }else{
131        buffer[0]=0;
132        char **array, **arrayStep;
133        if (cgiFormEntries(&array) != cgiFormSuccess) {
134          return 1;
135        }
136        arrayStep = array;
137        while (*arrayStep) {
138          char *ivalue=new char[cgiContentLength];
139          cgiFormStringNoNewlines(*arrayStep, ivalue, cgiContentLength);
140          char* tmpValueFinal=(char*) malloc((strlen(*arrayStep)+strlen(ivalue)+2)*sizeof(char));       
141          sprintf(tmpValueFinal,"%s=%s",*arrayStep,ivalue);
142
143          if(strlen(buffer)==0){               
144            sprintf(buffer,"%s",tmpValueFinal);
145          }else{               
146            char *tmp=zStrdup(buffer);
147            sprintf(buffer,"%s&%s",tmp,tmpValueFinal);
148            free(tmp);
149          }       
150          free(tmpValueFinal);
151#ifdef DEBUG
152          fprintf(stderr,"(( \n %s \n %s \n ))",*arrayStep,ivalue);
153#endif
154          delete[]ivalue;
155          arrayStep++;
156        }       
157        if(tmpMap!=NULL)
158          addToMap(tmpMap,"request",buffer);
159        else
160          tmpMap=createMap("request",buffer);
161      }
162      delete[]buffer;
163    }   
164  }
165  else{
166#ifdef DEBUG
167    dumpMap(tmpMap);
168#endif
169    char **array, **arrayStep;
170    if (cgiFormEntries(&array) != cgiFormSuccess) {
171      return 1;
172    }
173    arrayStep = array;
174    while (*arrayStep) {
175      char *value=new char[cgiContentLength];
176      cgiFormStringNoNewlines(*arrayStep, value, cgiContentLength);
177#ifdef DEBUG
178      fprintf(stderr,"(( \n %s \n %s \n ))",*arrayStep,value);
179#endif
180#ifdef WIN32
181      char* tmp = url_decode(value); 
182      if(tmpMap!=NULL)         
183        addToMap(tmpMap,*arrayStep,tmp);
184      else             
185        tmpMap=createMap(*arrayStep,tmp);
186      free(tmp);
187#else
188      if(tmpMap!=NULL)
189        addToMap(tmpMap,*arrayStep,value);
190      else
191        tmpMap=createMap(*arrayStep,value);
192#endif 
193      arrayStep++;
194      delete[]value;
195    }
196    cgiStringArrayFree(array);
197  }
198
199#ifdef WIN32
200  map *tmpReq=getMap(tmpMap,"rfile");
201  if(tmpReq!=NULL){
202    FILE *lf=fopen(tmpReq->value,"r");
203    fseek(lf,0,SEEK_END);
204    long flen=ftell(lf);
205    fseek(lf,0,SEEK_SET);
206    char *buffer=(char*)malloc((flen+1)*sizeof(char));
207    fread(buffer,flen,1,lf);
208    fclose(lf);
209    addToMap(tmpMap,"request",buffer);
210    free(buffer);
211    cgiContentLength=flen+9;
212  }
213#endif
214  /**
215   * In case that the POST method was used, then check if params came in XML
216   * format else try to use the attribute "request" which should be the only
217   * one.
218   */
219  if(strncasecmp(cgiRequestMethod,"post",4)==0 || 
220     (count(tmpMap)==1 && strncmp(tmpMap->value,"<",1)==0) 
221#ifdef WIN32
222     ||tmpReq!=NULL
223#endif
224     ){
225    /**
226     * Store the original XML request in xrequest map
227     */
228    map* t1=getMap(tmpMap,"request");
229    if(t1!=NULL && strncasecmp(t1->value,"<",1)==0) {
230      addToMap(tmpMap,"xrequest",t1->value);
231      xmlInitParser();
232      xmlDocPtr doc = xmlParseMemory(t1->value,cgiContentLength);
233      {
234        xmlXPathObjectPtr reqptr=extractFromDoc(doc,"/*[local-name()='Envelope']/*[local-name()='Body']/*");
235        if(reqptr!=NULL){
236          xmlNodeSet* req=reqptr->nodesetval;
237          if(req!=NULL && req->nodeNr==1){
238            addToMap(tmpMap,"soap","true");
239            for(int k=0;k < req->nodeNr;k++){
240              xmlDocSetRootElement(doc, req->nodeTab[k]);
241              xmlChar *xmlbuff;
242              int buffersize;
243              xmlDocDumpFormatMemoryEnc(doc, &xmlbuff, &buffersize, "utf-8", 1);
244              addToMap(tmpMap,"xrequest",(char*)xmlbuff);
245              xmlFree(xmlbuff);
246            }
247          }
248          xmlXPathFreeObject(reqptr);
249        }
250      }
251
252      xmlNodePtr cur = xmlDocGetRootElement(doc);
253      char *tval;
254      tval=NULL;
255      tval = (char*) xmlGetProp(cur,BAD_CAST "service");
256      if(tval!=NULL){
257        addToMap(tmpMap,"service",tval);
258        xmlFree(tval);
259      }
260      tval=NULL;
261      tval = (char*) xmlGetProp(cur,BAD_CAST "language");
262      if(tval!=NULL){
263        addToMap(tmpMap,"language",tval);
264        xmlFree(tval);
265      }
266      const char* requests[3]={"GetCapabilities","DescribeProcess","Execute"};
267      for(int j=0;j<3;j++){
268        char tt[128];
269        sprintf(tt,"/*[local-name()='%s']",requests[j]);
270        xmlXPathObjectPtr reqptr=extractFromDoc(doc,tt);
271        if(reqptr!=NULL){
272          xmlNodeSet* req=reqptr->nodesetval;
273#ifdef DEBUG
274          fprintf(stderr,"%i",req->nodeNr);
275#endif
276          if(req!=NULL && req->nodeNr==1){
277            if(t1->value!=NULL)
278              free(t1->value);
279            t1->value=zStrdup(requests[j]);
280            j=2;
281          }
282          xmlXPathFreeObject(reqptr);
283        }
284      }
285      if(strncasecmp(t1->value,"GetCapabilities",15)==0){
286        xmlXPathObjectPtr versptr=extractFromDoc(doc,"/*/*/*[local-name()='Version']");
287        xmlNodeSet* vers=versptr->nodesetval;
288        if(vers!=NULL && vers->nodeTab!=NULL && vers->nodeTab[0]!=NULL){
289          xmlChar* content=xmlNodeListGetString(doc, vers->nodeTab[0]->xmlChildrenNode,1);
290          addToMap(tmpMap,"version",(char*)content);
291          xmlFree(content);
292        }
293        if(cur->ns){
294          addToMap(tmpMap,"wps_schemas",(char*)cur->ns->href);
295          int j=0;
296          for(j=0;j<2;j++)
297            if(strncasecmp(schemas[j][2],(char*)cur->ns->href,strlen(schemas[j][2]))==0){
298              char vers[6];
299              sprintf(vers,"%d.0.0",j+1);
300              addToMap(tmpMap,"version",(char*)vers);
301            }
302        }
303        xmlXPathFreeObject(versptr);
304      }else{
305        tval=NULL;
306        tval = (char*) xmlGetProp(cur,BAD_CAST "version");
307        if(tval!=NULL){
308          addToMap(tmpMap,"version",tval);
309          xmlFree(tval);
310        }
311        tval = (char*) xmlGetProp(cur,BAD_CAST "language");
312        if(tval!=NULL){
313          addToMap(tmpMap,"language",tval);
314          xmlFree(tval);
315        }
316        xmlXPathObjectPtr idptr=extractFromDoc(doc,"/*/*[local-name()='Identifier']");
317        if(idptr!=NULL){
318          xmlNodeSet* id=idptr->nodesetval;
319          if(id!=NULL){
320            char* identifiers=NULL;
321            identifiers=(char*)calloc(cgiContentLength,sizeof(char));
322            identifiers[0]=0;
323            for(int k=0;k<id->nodeNr;k++){
324              xmlChar* content=xmlNodeListGetString(doc, id->nodeTab[k]->xmlChildrenNode,1);
325              if(strlen(identifiers)>0){
326                char *tmp=zStrdup(identifiers);
327                snprintf(identifiers,strlen(tmp)+xmlStrlen(content)+2,"%s,%s",tmp,content);
328                free(tmp);
329              }
330              else{
331                snprintf(identifiers,xmlStrlen(content)+1,"%s",content);
332              }
333              xmlFree(content);
334            }
335            xmlXPathFreeObject(idptr);
336            addToMap(tmpMap,"Identifier",identifiers);
337            free(identifiers);
338          }
339        }else{
340          idptr=extractFromDoc(doc,"/*/*[local-name()='JobID']");
341          if(idptr!=NULL){
342            xmlNodeSet* id=idptr->nodesetval;
343            if(id!=NULL){
344              char* identifiers=NULL;
345              identifiers=(char*)calloc(cgiContentLength,sizeof(char));
346              identifiers[0]=0;
347              for(int k=0;k<id->nodeNr;k++){
348                xmlChar* content=xmlNodeListGetString(doc, id->nodeTab[k]->xmlChildrenNode,1);
349                if(strlen(identifiers)>0){
350                  char *tmp=zStrdup(identifiers);
351                  snprintf(identifiers,strlen(tmp)+xmlStrlen(content)+2,"%s,%s",tmp,content);
352                  free(tmp);
353                }
354                else{
355                  snprintf(identifiers,xmlStrlen(content)+1,"%s",content);
356                }
357                xmlFree(content);
358              }
359              xmlXPathFreeObject(idptr);
360              addToMap(tmpMap,"JobID",identifiers);
361              free(identifiers);
362            }
363        }
364        }
365      }
366      xmlFreeDoc(doc);
367      xmlCleanupParser();
368    }else{
369      freeMap(&tmpMap);
370      free(tmpMap);
371      tmpMap=createMap("not_valid","true");
372    }
373
374    char *token,*saveptr;
375    token=strtok_r(cgiQueryString,"&",&saveptr);
376    while(token!=NULL){
377      char *token1,*saveptr1;
378      char *name=NULL;
379      char *value=NULL;
380      token1=strtok_r(token,"=",&saveptr1);
381      while(token1!=NULL){
382        if(name==NULL)
383          name=zStrdup(token1);
384        else
385          value=zStrdup(token1);
386        token1=strtok_r(NULL,"=",&saveptr1);
387      }   
388      //addToMap(tmpMap,name,value);
389          /* knut: strtok(_r) ignores delimiter bytes at start and end of string;
390           * it will return non-empty string or NULL, e.g. "metapath=" yields value=NULL.
391           * This modification sets value="" instead of NULL.
392           */
393          addToMap(tmpMap,name, value != NULL ? value : "");
394
395      free(name);
396      free(value);
397      name=NULL;
398      value=NULL;
399      token=strtok_r(NULL,"&",&saveptr);
400    }
401   
402  }
403
404  if(strncasecmp(cgiContentType,"multipart/form-data",19)==0){
405    map* tmp=getMap(tmpMap,"dataInputs");
406    if(tmp!=NULL){
407      addToMap(tmpMap,"dataInputs",strstr(strQuery,"dataInputs=")+11);
408    }
409  }
410
411  if(strQuery!=NULL)
412    free(strQuery);
413
414 
415  runRequest(&tmpMap);
416
417  if(tmpMap!=NULL){
418    freeMap(&tmpMap);
419    free(tmpMap);
420  }
421  return 0;
422
423}
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